diff options
| author |   Hanoh Haim <hhaim@cisco.com> | 2015-11-12 15:33:30 +0200 |
|---|---|---|
| committer | Hanoh Haim <hhaim@cisco.com> | 2015-11-12 15:33:30 +0200 |
| commit | 45b71cff9d0465b77f82e4cd40b64a9f3183c1c7 (patch) | |
| tree | 131242205381140fffeab0e7c2e05618efcc39ce /scripts/automation/trex_control_plane/client | |
| parent | 12aa72196b6ccac1b335fa7f06e9351c28c79158 (diff) | |
refactor stream object
Diffstat (limited to 'scripts/automation/trex_control_plane/client')
| -rw-r--r-- | scripts/automation/trex_control_plane/client/trex_async_client.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/scripts/automation/trex_control_plane/client/trex_async_client.py b/scripts/automation/trex_control_plane/client/trex_async_client.py index 72cce5aa..d13513bf 100644 --- a/scripts/automation/trex_control_plane/client/trex_async_client.py +++ b/scripts/automation/trex_control_plane/client/trex_async_client.py @@ -181,7 +181,8 @@ class CTRexAsyncClient(): self.socket.setsockopt(zmq.SUBSCRIBE, '') while self.active: - msg = json.loads(self.socket.recv_string()) + line = self.socket.recv_string(); + msg = json.loads(line) key = msg['name'] self.raw_snapshot[key] = msg['data'] |