Skip to content
Snippets Groups Projects
Commit 4e01bea0 authored by Corné Lukken's avatar Corné Lukken
Browse files

L2SS-863: Fix refactored interface

parent 23c394a3
No related branches found
No related tags found
1 merge request!392L2SS-863: refactor SST collector
...@@ -115,7 +115,7 @@ def _start_loop(receiver, writer, reconnect, filename): ...@@ -115,7 +115,7 @@ def _start_loop(receiver, writer, reconnect, filename):
"""Main loop""" """Main loop"""
try: try:
while True: while True:
_receive_packets(receiver, writer, reconnect, filename, device) _receive_packets(receiver, writer, reconnect, filename)
except KeyboardInterrupt: except KeyboardInterrupt:
# user abort, don't complain # user abort, don't complain
logger.warning("Received keyboard interrupt. Stopping.") logger.warning("Received keyboard interrupt. Stopping.")
...@@ -123,10 +123,10 @@ def _start_loop(receiver, writer, reconnect, filename): ...@@ -123,10 +123,10 @@ def _start_loop(receiver, writer, reconnect, filename):
writer.close_writer() writer.close_writer()
def _receive_packets(receiver, writer, reconnect, filename, device): def _receive_packets(receiver, writer, reconnect, filename):
try: try:
packet = receiver.get_packet() packet = receiver.get_packet()
writer.next_packet(packet, device) writer.next_packet(packet)
except EOFError: except EOFError:
if reconnect and not filename: if reconnect and not filename:
logger.warning("Connection lost, attempting to reconnect") logger.warning("Connection lost, attempting to reconnect")
......
...@@ -270,7 +270,7 @@ class HDF5Writer(ABC): ...@@ -270,7 +270,7 @@ class HDF5Writer(ABC):
finally: finally:
filename = str(self.file) filename = str(self.file)
self.file.close() self.file.close()
logger.debug("%S closed", filename) logger.debug("%s closed", filename)
logger.debug( logger.debug(
"Received a total of %d statistics while running. With " "Received a total of %d statistics while running. With "
"%d written to disk", "%d written to disk",
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment