Closedown

This commit is contained in:
gac-x12sa
2022-12-20 14:10:15 +01:00
parent 83d0ff03dd
commit f6f8a3c67a

View File

@@ -89,11 +89,13 @@ class Array10(DeviceBase, Readable, Cacheable, Readable.ReadableType):
self.socket.connect(self.address)
while self.running:
header = self.socket.recv(ZMQ.NOBLOCK)
if (header is not None):
if (header is not None):
print "Header"
try:
self.header=json.loads(''.join(chr(i) for i in header))
self.data = self.socket.recv()
if self.data is not None:
print "Data"
self.setCache({"header":self.header, "data":self.data}, None)
self.message_count=self.message_count+1
if self.array_dev is not None: