From 3427ef7cb33a475b54f6d9c6caa045ca3c76c4d1 Mon Sep 17 00:00:00 2001
From: Thijs <snijder@astron.nl>
Date: Tue, 8 Jun 2021 13:06:20 +0200
Subject: [PATCH] fixed stopping queue
---
devices/clients/sst_client.py | 9 ++-------
1 file changed, 2 insertions(+), 7 deletions(-)
diff --git a/devices/clients/sst_client.py b/devices/clients/sst_client.py
index bd137bfec..506051312 100644
--- a/devices/clients/sst_client.py
+++ b/devices/clients/sst_client.py
@@ -128,14 +128,9 @@ class UDP_Receiver(Thread):
while self.stream_on:
try:
-
- #self.sock.sendto(b"test", ("", self.port))
-
- # packet = Array('B', self.buffersize)
packet = [bytearray(self.buffersize)]
self.sock.recvmsg_into(packet[0:self.buffersize])
self.deque.append(packet)
- # print(packet)
except socket.timeout:
pass
@@ -168,8 +163,8 @@ class SST(Thread):
if len(self.deque) > 0:
packet = self.deque.popleft()
- # if packet is None:
- # break
+ if packet is None:
+ break
self.process_packet(packet)
--
GitLab