2023-03-09 17:44:05 +01:00
|
|
|
#include <fsfw/tasks/TaskFactory.h>
|
2023-03-10 02:05:51 +01:00
|
|
|
#include <fsfw/timemanager/Stopwatch.h>
|
2023-03-09 17:44:05 +01:00
|
|
|
#include <mission/tmtc/PersistentSingleTmStoreTask.h>
|
2023-03-27 21:23:09 +02:00
|
|
|
#include <unistd.h>
|
2023-03-09 17:44:05 +01:00
|
|
|
|
2023-03-10 19:01:31 +01:00
|
|
|
PersistentSingleTmStoreTask::PersistentSingleTmStoreTask(
|
|
|
|
object_id_t objectId, StorageManagerIF& ipcStore, PersistentTmStoreWithTmQueue& tmStore,
|
2023-03-28 15:15:38 +02:00
|
|
|
VirtualChannel& channel, Event eventIfDumpDone, Event eventIfCancelled, SdCardMountedIF& sdcMan)
|
2023-03-10 19:01:31 +01:00
|
|
|
: TmStoreTaskBase(objectId, ipcStore, channel, sdcMan),
|
|
|
|
storeWithQueue(tmStore),
|
2023-03-28 15:15:38 +02:00
|
|
|
dumpContext(eventIfDumpDone, eventIfCancelled) {}
|
2023-03-09 17:44:05 +01:00
|
|
|
|
|
|
|
ReturnValue_t PersistentSingleTmStoreTask::performOperation(uint8_t opCode) {
|
|
|
|
while (true) {
|
2023-03-10 02:05:51 +01:00
|
|
|
// Delay done by the check
|
2023-03-09 20:16:00 +01:00
|
|
|
if (not cyclicStoreCheck()) {
|
|
|
|
continue;
|
|
|
|
}
|
2023-03-11 14:59:55 +01:00
|
|
|
bool busy = handleOneStore(storeWithQueue, dumpContext);
|
2023-03-09 19:42:20 +01:00
|
|
|
if (not busy) {
|
2023-03-28 21:45:04 +02:00
|
|
|
TaskFactory::delayTask(100);
|
2023-03-27 21:39:37 +02:00
|
|
|
} else if (dumpContext.vcBusyDuringDump) {
|
2023-03-28 21:45:04 +02:00
|
|
|
// TODO: Might not be necessary
|
|
|
|
TaskFactory::delayTask(10);
|
2023-03-28 14:59:31 +02:00
|
|
|
}
|
2023-03-09 17:44:05 +01:00
|
|
|
}
|
|
|
|
}
|
2023-03-09 20:16:00 +01:00
|
|
|
|
2023-03-10 02:05:51 +01:00
|
|
|
bool PersistentSingleTmStoreTask::initStoresIfPossible() {
|
|
|
|
if (sdcMan.isSdCardUsable(std::nullopt)) {
|
|
|
|
storeWithQueue.initializeTmStore();
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
return false;
|
|
|
|
}
|