pshell_config/x12sa-eiger
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Closedown

Browse Source
This commit is contained in:
gac-x12sa
2023-04-03 15:49:29 +02:00
parent 6596b8f743
commit f917e68080
3 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
script/devices/Array10.py
View File

@@ -80,14 +80,14 @@ class Array10(DeviceBase, Readable, Cacheable, Readable.ReadableType):
self.socket = self.context.socket(self.mode)
self.socket.connect(self.address)
if self.mode == ZMQ.SUB:
self.socket.subscribe("")
self.getLogger().info("Running " + str(self.mode) + " " + str(self.address))
first = True
while self.running:
header = self.socket.recv(ZMQ.NOBLOCK)
if (header is not None):
try:
self.header=json.loads(''.join(chr(i) for i in header))
self.socket.subscribe("")
self.getLogger().info("Running " + str(self.mode) + " " + str(self.address))
first = True
while self.running:
header = self.socket.recv(ZMQ.NOBLOCK)
if (header is not None):
try:
self.header=json.loads(''.join(chr(i) for i in header))
self.shape = self.header.get("shape", None)
self.dtype = self.header.get("type", "int8")
data = self.socket.recv()
@@ -97,7 +97,7 @@ class Array10(DeviceBase, Readable, Cacheable, Readable.ReadableType):
self.message_count=self.message_count+1
self.devArray.set(self.data)
if self.message_count % self.devMatrix.modulo == 0:
if self.shape: self.shape=(self.shape[1],self.shape[0]) #TODO: FIXME
#if self.shape: self.shape=(self.shape[1],self.shape[0]) #TODO: FIXME
self.devMatrix.set(self.data, self.shape)
continue
except Exception as e: