diff --git a/common.py b/common.py index 8301d39..95b915f 100644 --- a/common.py +++ b/common.py @@ -433,25 +433,24 @@ class TcHandler(TcHandlerBase): pdu_holder, packet, ) = self.cfdp_in_ccsds_wrapper.pull_next_source_packet() - # print(pdu_holder) - self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.queue_helper.add_ccsds_tc(packet) + self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.queue_helper.add_log_cmd("CFDP Source: Sending Metadata PDU") ( pdu_holder, packet, ) = self.cfdp_in_ccsds_wrapper.pull_next_source_packet() - # print(pdu_holder) - self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.queue_helper.add_ccsds_tc(packet) + self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.queue_helper.add_log_cmd("CFDP Source: Sending File Data PDU") ( pdu_holder, packet, ) = self.cfdp_in_ccsds_wrapper.pull_next_source_packet() self.queue_helper.add_log_cmd("CFDP Source: Sending EOF PDU") - self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.queue_helper.add_ccsds_tc(packet) + self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() + self.cfdp_in_ccsds_wrapper.handler.source_handler.state_machine() def send_cb(self, params: SendCbParams): if params.entry.is_tc: