Closedown

This commit is contained in:
gac-x12sa
2022-12-20 14:56:22 +01:00
parent cd9c44b210
commit d45bc8934d

View File

@@ -88,9 +88,13 @@ class Array10(DeviceBase, Readable, Cacheable, Readable.ReadableType):
self.socket = self.context.socket(self.mode)
self.socket.connect(self.address)
print "Running ", self.mode, self.address
first = True
while self.running:
header = self.socket.recv(ZMQ.NOBLOCK)
if (header is not None):
if (header is not None):
if first:
print "Received!"
first=False
try:
self.header=json.loads(''.join(chr(i) for i in header))
self.data = self.socket.recv()