Skip to content

Commit 0467ce5

Browse files
authored
Merge pull request #383 from avinxshKD/fix/zmq-simtime-framing-382
Fix/zmq simtime framing
2 parents 327116d + d737a7e commit 0467ce5

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

concoredocker.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,6 +211,11 @@ def read(port_identifier, name, initstr_val):
211211
zmq_p = zmq_ports[port_identifier]
212212
try:
213213
message = zmq_p.recv_json_with_retry()
214+
if isinstance(message, list) and len(message) > 0:
215+
first_element = message[0]
216+
if isinstance(first_element, (int, float)):
217+
simtime = max(simtime, first_element)
218+
return message[1:]
214219
return message
215220
except zmq.error.ZMQError as e:
216221
logging.error(f"ZMQ read error on port {port_identifier} (name: {name}): {e}. Returning default.")

0 commit comments

Comments
 (0)