From 0e1d4516519573fb33319eac7e9a56906a8db1a6 Mon Sep 17 00:00:00 2001 From: Robin Mueller Date: Wed, 14 Sep 2022 14:00:37 +0200 Subject: [PATCH] send eof packet to finish transaction --- common.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) 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: