fsfw/fsfw-example-tmtc-common
11
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

send eof packet to finish transaction

Browse Source
This commit is contained in:
Robin Müller 2022-09-14 14:00:37 +02:00
parent 6ee3fa67dc
commit 0e1d451651
No known key found for this signature in database
GPG Key ID: 11D4952C8CCEF814
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
common.py
View File

@ -424,7 +424,7 @@ class TcHandler(TcHandlerBase):
): ):
put_req = cfdp_procedure.request_wrapper.to_put_request() put_req = cfdp_procedure.request_wrapper.to_put_request()
put_req.cfg.destination_id = self.cfdp_dest_id 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_in_ccsds_wrapper.handler.put_request(put_req)
self.cfdp_handler_started = True self.cfdp_handler_started = True
( (
@ -443,6 +443,13 @@ class TcHandler(TcHandlerBase):
self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent() self.cfdp_in_ccsds_wrapper.confirm_source_packet_sent()
self.queue_helper.add_ccsds_tc(packet) self.queue_helper.add_ccsds_tc(packet)
self.queue_helper.add_log_cmd("CFDP Source: Sending File Data PDU") 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): def send_cb(self, params: SendCbParams):
if params.entry.is_tc: if params.entry.is_tc: