Skip to content
Snippets Groups Projects
Commit 3427ef7c authored by Taya Snijder's avatar Taya Snijder
Browse files

fixed stopping queue

parent b2b7f3be
No related branches found
No related tags found
1 merge request!50Resolve L2SS-188 "2021 05 27 branched from master udp recv sst client"
...@@ -128,14 +128,9 @@ class UDP_Receiver(Thread): ...@@ -128,14 +128,9 @@ class UDP_Receiver(Thread):
while self.stream_on: while self.stream_on:
try: try:
#self.sock.sendto(b"test", ("", self.port))
# packet = Array('B', self.buffersize)
packet = [bytearray(self.buffersize)] packet = [bytearray(self.buffersize)]
self.sock.recvmsg_into(packet[0:self.buffersize]) self.sock.recvmsg_into(packet[0:self.buffersize])
self.deque.append(packet) self.deque.append(packet)
# print(packet)
except socket.timeout: except socket.timeout:
pass pass
...@@ -168,8 +163,8 @@ class SST(Thread): ...@@ -168,8 +163,8 @@ class SST(Thread):
if len(self.deque) > 0: if len(self.deque) > 0:
packet = self.deque.popleft() packet = self.deque.popleft()
# if packet is None: if packet is None:
# break break
self.process_packet(packet) self.process_packet(packet)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment