eive/eive-tmtc
14
0
Fork 0
Code Issues Pull Requests 1 Projects Releases 99 Wiki Activity

CFDP file downlink #233

Merged
muellerr merged 35 commits from cfdp-file-downlink into main 2023-09-14 11:44:23 +02:00
Conversation 1 Commits 35 Files Changed 12 +742 -658
34 changed files with 742 additions and 658 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 6657bf072c - Show all commits

10
eive_tmtc/cfdp/tm.py
View File

@@ -20,12 +20,8 @@ class CfdpInCcsdsWrapper(SpecificApidHandlerBase):
pdu = packet[SPACE_PACKET_HEADER_SIZE:] pdu = packet[SPACE_PACKET_HEADER_SIZE:]
pdu_base = PduFactory.from_raw(pdu) pdu_base = PduFactory.from_raw(pdu)
if pdu_base.pdu_type == PduType.FILE_DATA: if pdu_base.pdu_type == PduType.FILE_DATA:
_LOGGER.info("Received File Data PDU TM") _LOGGER.info("Received File Data PDU")
else: else:
if pdu_base.directive_type == DirectiveType.FINISHED_PDU: directive_type = DirectiveType(pdu_base.directive_type)
_LOGGER.info("Received Finished PDU TM") _LOGGER.info(f"Received File Directive PDU with type {directive_type!r}")
else:
_LOGGER.info(
f"Received File Directive PDU with type {pdu_base.directive_type!r} TM"
)
self.handler.pass_pdu_packet(pdu_base) self.handler.pass_pdu_packet(pdu_base)

6
eive_tmtc/cfdp/user.py
View File

@@ -25,7 +25,9 @@ class EiveCfdpUser(CfdpUserBase):
pass pass
def file_segment_recv_indication(self, params: FileSegmentRecvdParams): def file_segment_recv_indication(self, params: FileSegmentRecvdParams):
pass _LOGGER.info(
f"CFDP User: Received File Data PDU for {params.transaction_id} | Offset: {params.offset} | Segment Length: {params.length}"
)
def report_indication(self, transaction_id: TransactionId, status_report: any): def report_indication(self, transaction_id: TransactionId, status_report: any):
pass pass
@@ -49,4 +51,4 @@ class EiveCfdpUser(CfdpUserBase):
pass pass
def eof_recv_indication(self, transaction_id: TransactionId): def eof_recv_indication(self, transaction_id: TransactionId):
pass _LOGGER.info(f"CFDP User: EOF received for {transaction_id}")