Skip to content
Snippets Groups Projects
Commit bba7e61a authored by Jan David Mol's avatar Jan David Mol
Browse files

L2SS-244: Don't go overly complex if we need a new buffer every time anyway....

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.
parent 6943f43a
No related branches found
No related tags found
1 merge request!56L2SS-244: Expose the SSTs in MPs
...@@ -27,14 +27,13 @@ class sst_client(CommClient): ...@@ -27,14 +27,13 @@ class sst_client(CommClient):
def start(self): def start(self):
super().start() 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 Create the sst client and connect() to it and get the object node
""" """
self.host = host self.host = host
self.port = port self.port = port
self.timeout = 0.1 self.timeout = 0.1
self.buffersize = buffersize
self.queuesize = queuesize self.queuesize = queuesize
super().__init__(fault_func, streams, try_interval) super().__init__(fault_func, streams, try_interval)
...@@ -51,7 +50,7 @@ class sst_client(CommClient): ...@@ -51,7 +50,7 @@ class sst_client(CommClient):
""" """
if not self.connected: if not self.connected:
self.queue = Queue(maxsize=self.queuesize) 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) self.sst = SST_collector(self.queue)
return super().connect() return super().connect()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment