client: fixe subs default values, work with prosys server

opcua/binary_client.py

@@ -47,12 +47,12 @@ class BinaryClient(object):
         self._thread = Thread(target=self._run)
         self._thread.start()
 
-    def _send_request(self, request, callback=None):
+    def _send_request(self, request, callback=None, timeout=1000):
         #HACK to make sure we can convert our request to binary before increasing request counter etc ...
         request.to_binary()
         #END HACK
         with self._lock:
-            request.RequestHeader = self._create_request_header()
+            request.RequestHeader = self._create_request_header(timeout)
             hdr = ua.Header(ua.MessageType.SecureMessage, ua.ChunkType.Single, self._security_token.ChannelId)
             symhdr = self._create_sym_algo_header()
             seqhdr = self._create_sequence_header()
@@ -147,14 +147,14 @@ class BinaryClient(object):
             alle.append(data)
         alle.insert(0, hdr.to_binary())
         alle = b"".join(alle)
-        self._socket.send(alle)
+        self._socket.sendall(alle)
 
-    def _create_request_header(self):
+    def _create_request_header(self, timeout=1000):
         hdr = ua.RequestHeader()
         hdr.AuthenticationToken = self._authentication_token
         self._request_handle += 1
         hdr.RequestHandle = self._request_handle
-        hdr.TimeoutHint = 10000
+        hdr.TimeoutHint = timeout
         return hdr
 
     def _create_sym_algo_header(self):
@@ -177,6 +177,7 @@ class BinaryClient(object):
         """
         self.logger.info("opening connection")
         self._socket = socket.create_connection((host, port))
+        self._socket.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)#nodelay ncessary to avoid packing in one frame, some servers do not like it
         self.start()
 
     def disconnect_socket(self):
@@ -332,7 +333,7 @@ class BinaryClient(object):
             acks = []
         request = ua.PublishRequest()
         request.SubscriptionAcknowledgements = acks
-        self._send_request(request, self._call_publish_callback)
+        self._send_request(request, self._call_publish_callback, timeout=0)
 
     def _call_publish_callback(self, rcall):
         self.logger.info("call_publish_callback")

opcua/client.py

@@ -209,7 +209,7 @@ class Client(object):
         params.RequestedPublishingInterval = period
         params.RequestedLifetimeCount = 3000
         params.RequestedMaxKeepAliveCount = 10000
-        params.MaxNotificationsPerPublish = 0
+        params.MaxNotificationsPerPublish = 4294967295
         params.PublishingEnabled = True
         params.Priority = 0
         return Subscription(self.bclient, params, handler)

opcua/subscription.py

@@ -74,14 +74,18 @@ class Subscription(object):
         self._client_handle += 1
         mparams.ClientHandle = self._client_handle
         mparams.SamplingInterval = self.parameters.RequestedPublishingInterval
+        mparams.QueueSize = 1
+        mparams.DiscardOldest = True
 
         mir = ua.MonitoredItemCreateRequest() 
         mir.ItemToMonitor = rv
+        mir.MonitoringMode = ua.MonitoringMode.Reporting
         mir.RequestedParameters = mparams
 
         params = ua.CreateMonitoredItemsParameters()
         params.SubscriptionId = self.subscription_id
         params.ItemsToCreate.append(mir)
+        params.TimestampsToReturn = ua.TimestampsToReturn.Neither
 
         results = self.server.create_monitored_items(params)
         result = results[0]