| @@ -70,14 +70,17 def main(): | |||||
| 70 | receiver.bind("tcp://0.0.0.0:4444") |
|
70 | receiver.bind("tcp://0.0.0.0:4444") | |
| 71 |
|
71 | |||
| 72 | while True: |
|
72 | while True: | |
|
|
73 | time.sleep(0.1) | |||
| 73 | try: |
|
74 | try: | |
| 74 | buffer = receiver.recv_json() |
|
75 | buffer = receiver.recv_json() | |
| 75 | except Exception as e: |
|
76 | except Exception as e: | |
| 76 | print('{} - {}'.format(datetime.now(), e)) |
|
77 | print('{} - {}'.format(datetime.now(), e)) | |
|
|
78 | receiver.send_string('fail') | |||
| 77 | continue |
|
79 | continue | |
| 78 | #print(buffer) |
|
80 | #print(buffer) | |
| 79 | if not isinstance(buffer, dict): |
|
81 | if not isinstance(buffer, dict): | |
| 80 | print('Invalid data received: {}').format(str(buffer)) |
|
82 | print('Invalid data received: {}').format(str(buffer)) | |
|
|
83 | receiver.send_string('fail') | |||
| 81 | continue |
|
84 | continue | |
| 82 |
|
85 | |||
| 83 | if not update(buffer): |
|
86 | if not update(buffer): | |
General Comments 0
You need to be logged in to leave comments.
Login now