Skip to content
Snippets Groups Projects
Commit dcca937f authored by Robin Mueller's avatar Robin Mueller
Browse files

slight improvement

parent ba325499
No related branches found
No related tags found
No related merge requests found
...@@ -10,7 +10,7 @@ from collections import deque ...@@ -10,7 +10,7 @@ from collections import deque
from sendreceive.obsw_sequential_sender_receiver import SequentialCommandSenderReceiver from sendreceive.obsw_sequential_sender_receiver import SequentialCommandSenderReceiver
from comIF.obsw_com_interface import CommunicationInterface from comIF.obsw_com_interface import CommunicationInterface
from utility.obsw_tmtc_printer import TmTcPrinter from utility.obsw_tmtc_printer import TmTcPrinter
from sendreceive.obsw_tm_listener import TmListenerT from sendreceive.obsw_tm_listener import TmListener
import config.obsw_config as g import config.obsw_config as g
from utility.obsw_tmtc_printer import get_logger from utility.obsw_tmtc_printer import get_logger
...@@ -24,7 +24,7 @@ class MultipleCommandSenderReceiver(SequentialCommandSenderReceiver): ...@@ -24,7 +24,7 @@ class MultipleCommandSenderReceiver(SequentialCommandSenderReceiver):
This is generally done in the separate test classes in UnitTest This is generally done in the separate test classes in UnitTest
""" """
def __init__(self, com_interface: CommunicationInterface, tmtc_printer: TmTcPrinter, def __init__(self, com_interface: CommunicationInterface, tmtc_printer: TmTcPrinter,
tc_queue: Deque, tm_listener: TmListenerT, wait_intervals: list, tc_queue: Deque, tm_listener: TmListener, wait_intervals: list,
wait_time: Union[float, list], print_tm: bool): wait_time: Union[float, list], print_tm: bool):
""" """
TCs are sent in burst when applicable. Wait intervals can be specified by supplying TCs are sent in burst when applicable. Wait intervals can be specified by supplying
...@@ -101,8 +101,8 @@ class MultipleCommandSenderReceiver(SequentialCommandSenderReceiver): ...@@ -101,8 +101,8 @@ class MultipleCommandSenderReceiver(SequentialCommandSenderReceiver):
if self._tm_listener.event_reply_received.is_set(): if self._tm_listener.event_reply_received.is_set():
return self._tm_listener.retrieve_tm_packet_queue() return self._tm_listener.retrieve_tm_packet_queue()
else: else:
LOGGER.error("Multiple Command SenderReceiver: Configuration error," LOGGER.error("Multiple Command SenderReceiver: Configuration error, "
" reply event not set in TM listener") "reply event not set in TM listener")
def __clear_listener_tm_info_queue(self): def __clear_listener_tm_info_queue(self):
self._tm_listener.clear_tm_packet_queue() self._tm_listener.clear_tm_packet_queue()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment