From bba7e61a35782cf6e8b7a2e855b0376d34f40e83 Mon Sep 17 00:00:00 2001
From: Jan David Mol <mol@astron.nl>
Date: Tue, 15 Jun 2021 04:41:33 +0200
Subject: [PATCH] L2SS-244: Don't go overly complex if we need a new buffer
every time anyway. Just return a set of bytes for each packet.
---
devices/clients/sst_client.py | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/devices/clients/sst_client.py b/devices/clients/sst_client.py
index cdaba3ad3..901a24df1 100644
--- a/devices/clients/sst_client.py
+++ b/devices/clients/sst_client.py
@@ -27,14 +27,13 @@ class sst_client(CommClient):
def start(self):
super().start()
- def __init__(self, host, port, fault_func, streams, try_interval=2, queuesize=1024, buffersize=9000):
+ def __init__(self, host, port, fault_func, streams, try_interval=2, queuesize=1024):
"""
Create the sst client and connect() to it and get the object node
"""
self.host = host
self.port = port
self.timeout = 0.1
- self.buffersize = buffersize
self.queuesize = queuesize
super().__init__(fault_func, streams, try_interval)
@@ -51,7 +50,7 @@ class sst_client(CommClient):
"""
if not self.connected:
self.queue = Queue(maxsize=self.queuesize)
- self.udp = UDP_Receiver(self.host, self.port, self.queue, self.buffersize, self.timeout)
+ self.udp = UDP_Receiver(self.host, self.port, self.queue, self.timeout)
self.sst = SST_collector(self.queue)
return super().connect()
--
GitLab