empty response queue to avoid desync

2021-09-10 01:22:44 +02:00 · 2021-09-10 01:22:44 +02:00 · 6aef0660a3
parent 885a516fe3
commit 6aef0660a3
1 changed files with 2 additions and 1 deletions
--- a/remote_control/measurement_server.py
+++ b/remote_control/measurement_server.py
@ -79,7 +79,8 @@ class MeasurementHandler(socketserver.BaseRequestHandler):
                time.sleep(0.2)
                self.request.sendall(b'.\n')
                pass
-            reply = self.server.response_queue.get()
+            while not self.server.response_queue.empty():
+                reply = self.server.response_queue.get()

            # send back response to the original source
            print(f"sending reply {reply} back to correspondent {self.request}")