eive/fsfw
eive/fsfw
15
1
Fork 0
forked from fsfw/fsfw
Code Issues Pull Requests Releases 1 Wiki Activity

CFDP SOURCE handler #157

Merged
muellerr merged 107 commits from cfdp-source-handler into develop 2023-10-19 10:59:55 +02:00
Conversation 0 Commits 107 Files Changed 105 +5 -10
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 6021257a87 - Show all commits

14
src/fsfw/cfdp/handler/SourceHandler.cpp
View File

@ -50,19 +50,16 @@ cfdp::SourceHandler::FsmResult& cfdp::SourceHandler::fsmNacked() {
}
if (step == TransactionStep::TRANSACTION_START) {
sourceParams.user.transactionIndication(transactionParams.id);
step = TransactionStep::CRC_PROCEDURE;
}
if (step == TransactionStep::CRC_PROCEDURE) {
result = checksumGeneration();
if (result != OK) {
// TODO: Some error handling
addError(result);
}
step = TransactionStep::SENDING_METADATA;
}
meggert commented 2023-10-17 13:30:32 +02:00
Outdated
Review
Copy Link

boop

boop
if (step == TransactionStep::SENDING_METADATA) {
result = prepareAndSendMetadataPdu();
if (result != OK) {
// TODO: Error handling
addError(result);
}
fsmResult.callStatus = CallStatus::CALL_AGAIN;
return fsmResult;
meggert commented 2023-10-17 13:30:46 +02:00
Outdated
Review
Copy Link

boop

boop
@ -72,13 +69,13 @@ cfdp::SourceHandler::FsmResult& cfdp::SourceHandler::fsmNacked() {
result = prepareAndSendNextFileDataPdu(noFdPdu);
if (result == OK and !noFdPdu) {
fsmResult.callStatus = CallStatus::CALL_AGAIN;
return fsmResult;
}
return fsmResult;
}
if (step == TransactionStep::SENDING_EOF) {
result = prepareAndSendEofPdu();
if (result != OK) {
// TODO: Error handling
addError(result);
}
if (sourceParams.cfg.indicCfg.eofSentIndicRequired) {
sourceParams.user.eofSentIndication(transactionParams.id);
meggert commented 2023-10-17 13:31:01 +02:00
Outdated
Review
Copy Link

boop

boop
@ -139,8 +136,7 @@ ReturnValue_t cfdp::SourceHandler::checksumGeneration() {
params.size = readLen;
auto result = sourceParams.user.vfs.readFromFile(params, buf.data(), buf.size());
if (result != OK) {
// TODO: I think this is a case for a filestore rejection, but it might sense to print
// a warning or trigger an event because this should generally not happen
addError(result);
return FAILED;
}
crcCalc.add(buf.begin(), buf.begin() + readLen);
meggert commented 2023-10-17 13:32:02 +02:00
Review
Copy Link

boop

boop
muellerr commented 2023-10-19 10:02:43 +02:00
Review
Copy Link

Will be added when fault declaration works properly

Will be added when fault declaration works properly

1
src/fsfw/cfdp/handler/SourceHandler.h
View File

@ -30,7 +30,6 @@ class SourceHandler {
enum class TransactionStep : uint8_t {
IDLE = 0,
TRANSACTION_START = 1,
CRC_PROCEDURE = 2,
SENDING_METADATA = 3,
SENDING_FILE_DATA = 4,
SENDING_EOF = 5,