diff --git a/common.py b/common.py index 8bba826..aac8ae4 100644 --- a/common.py +++ b/common.py @@ -424,7 +424,7 @@ class TcHandler(TcHandlerBase): ): put_req = cfdp_procedure.request_wrapper.to_put_request() put_req.cfg.destination_id = self.cfdp_dest_id - LOGGER.info(f"Starting put request with parameters:\n{put_req}") + LOGGER.info(f"CFDP: Starting file put request with parameters:\n{put_req}") self.cfdp_in_ccsds_wrapper.handler.put_request(put_req) self.cfdp_handler_started = True ( @@ -443,6 +443,13 @@ class TcHandler(TcHandlerBase): self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.queue_helper.add_ccsds_tc(packet) 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) def send_cb(self, params: SendCbParams): if params.entry.is_tc: