move to new DHB TM handler

CMakeLists.txt

@@ -451,8 +451,9 @@ if(TGT_BSP MATCHES "arm/q7s")
   target_link_libraries(${LIB_EIVE_MISSION} PUBLIC ${LIB_GPS} ${LIB_ARCSEC})
 endif()
 
-target_link_libraries(${UNITTEST_NAME} PRIVATE Catch2 ${LIB_EIVE_MISSION}
-                                               rapidcsv ${LIB_DUMMIES} ${LIB_GOMSPACE_CLIENTS})
+target_link_libraries(
+  ${UNITTEST_NAME} PRIVATE Catch2 ${LIB_EIVE_MISSION} rapidcsv ${LIB_DUMMIES}
+                           ${LIB_GOMSPACE_CLIENTS})
 
 if(TGT_BSP MATCHES "arm/egse")
   target_link_libraries(${OBSW_NAME} PRIVATE ${LIB_ARCSEC})

fsfw

@@ -1 +1 @@
-Subproject commit 9a590a3fcd81ed4dd48de503522b6d71f64205d2
+Subproject commit 21ac86619e2b1fecf71bd2aa0f09ecbd471c8531

linux/devices/GPSHyperionLinuxController.cpp

@@ -87,7 +87,7 @@ ReturnValue_t GPSHyperionLinuxController::initializeLocalDataPool(
   localDataPoolMap.emplace(GpsHyperion::SATS_IN_USE, new PoolEntry<uint8_t>());
   localDataPoolMap.emplace(GpsHyperion::SATS_IN_VIEW, new PoolEntry<uint8_t>());
   localDataPoolMap.emplace(GpsHyperion::FIX_MODE, new PoolEntry<uint8_t>());
-  poolManager.subscribeForRegularPeriodicPacket({gpsSet.getSid(), 30.0});
+  poolManager.subscribeForRegularPeriodicPacket({gpsSet.getSid(), false, 30.0});
   return returnvalue::OK;
 }
 

linux/devices/Max31865RtdLowlevelHandler.cpp

@@ -311,7 +311,7 @@ ReturnValue_t Max31865RtdReader::readReceivedMessage(CookieIF* cookie, uint8_t**
     return returnvalue::FAILED;
   }
   auto* rtdCookie = dynamic_cast<Max31865ReaderCookie*>(cookie);
-  if(rtdCookie == nullptr) {
+  if (rtdCookie == nullptr) {
     return returnvalue::FAILED;
   }
   uint8_t* exchangePtr = rtdCookie->exchangeBuf.data();

linux/devices/ploc/PlocSupervisorHandler.cpp

@@ -417,7 +417,7 @@ ReturnValue_t PlocSupervisorHandler::buildCommandFromCommand(DeviceCommandId_t d
       break;
     }
     case LOGGING_SET_TOPIC: {
-      if(commandData == nullptr or commandDataLen == 0) {
+      if (commandData == nullptr or commandDataLen == 0) {
         return HasActionsIF::INVALID_PARAMETERS;
       }
       uint8_t tpc = *(commandData);

linux/devices/startracker/StarTrackerHandler.cpp

@@ -1830,7 +1830,7 @@ ReturnValue_t StarTrackerHandler::handleChecksumReply() {
   }
   PoolReadGuard rg(&checksumSet);
   checksumSet.checksum = checksumReply.getChecksum();
-  handleDeviceTM(&checksumSet, startracker::CHECKSUM);
+  handleDeviceTm(util::DataWrapper(checksumSet), startracker::CHECKSUM);
 #if OBSW_VERBOSE_LEVEL >= 1 && OBSW_DEBUG_STARTRACKER == 1
   checksumReply.printChecksum();
 #endif /* OBSW_VERBOSE_LEVEL >= 1 && OBSW_DEBUG_STARTRACKER == 1 */

mission/controller/AcsController.cpp

@@ -45,7 +45,7 @@ ReturnValue_t AcsController::initializeLocalDataPool(localpool::DataPool &localD
   localDataPoolMap.emplace(acsctrl::PoolIds::MGM_3_RM3100_UT, &mgm3PoolVec);
   localDataPoolMap.emplace(acsctrl::PoolIds::MGM_IMTQ_CAL_NT, &imtqMgmPoolVec);
   localDataPoolMap.emplace(acsctrl::PoolIds::MGM_IMTQ_CAL_ACT_STATUS, &imtqCalActStatus);
-  poolManager.subscribeForRegularPeriodicPacket({mgmData.getSid(), 5.0});
+  poolManager.subscribeForRegularPeriodicPacket({mgmData.getSid(), false, 5.0});
   return returnvalue::OK;
 }
 

mission/devices/ACUHandler.cpp

@@ -43,7 +43,8 @@ void ACUHandler::letChildHandleHkReply(DeviceCommandId_t id, const uint8_t *pack
 }
 
 void ACUHandler::letChildHandleConfigReply(DeviceCommandId_t id, const uint8_t *packet) {
-  handleDeviceTM(packet, ACU::CONFIG_TABLE_SIZE, id);
+  util::DataWrapper wrapper(packet, ACU::CONFIG_TABLE_SIZE);
+  handleDeviceTm(wrapper, id);
 }
 
 LocalPoolDataSetBase *ACUHandler::getDataSetHandle(sid_t sid) {

mission/devices/GomspaceDeviceHandler.cpp

@@ -177,7 +177,9 @@ ReturnValue_t GomspaceDeviceHandler::interpretDeviceReply(DeviceCommandId_t id,
   switch (id) {
     case (GOMSPACE::PING): {
       SerializeElement<uint32_t> replyTime = *packet;
-      handleDeviceTM(&replyTime, id, true);
+      util::DataWrapper wrapper;
+      wrapper.setSerializable(replyTime);
+      handleDeviceTm(wrapper, id, true);
       break;
     }
     case (GOMSPACE::PARAM_GET): {
@@ -204,7 +206,7 @@ ReturnValue_t GomspaceDeviceHandler::interpretDeviceReply(DeviceCommandId_t id,
       uint16_t address = cspGetParamReply.getAddress();
       /* Pack relevant information into a tm packet */
       ParamReply paramReply(action, tableId, address, payloadLength, tempPayloadBuffer);
-      handleDeviceTM(&paramReply, id, true);
+      handleDeviceTm(util::DataWrapper(paramReply), id, true);
       break;
     }
     case (GOMSPACE::PARAM_SET): {

mission/devices/P60DockHandler.cpp

@@ -24,11 +24,6 @@ ReturnValue_t P60DockHandler::buildNormalDeviceCommand(DeviceCommandId_t *id) {
 
 void P60DockHandler::letChildHandleHkReply(DeviceCommandId_t id, const uint8_t *packet) {
   parseHkTableReply(packet);
-  /**
-   * Hk table will be sent to the commander if hk table request was not triggered by the
-   * P60DockHandler itself.
-   */
-  handleDeviceTM(&coreHk, id, true);
 }
 
 void P60DockHandler::parseHkTableReply(const uint8_t *packet) {
@@ -273,5 +268,5 @@ void P60DockHandler::printHkTableLatchups() {
 void P60DockHandler::setDebugMode(bool enable) { this->debugMode = enable; }
 
 void P60DockHandler::letChildHandleConfigReply(DeviceCommandId_t id, const uint8_t *packet) {
-  handleDeviceTM(packet, P60Dock::CONFIG_TABLE_SIZE, id);
+  handleDeviceTm(util::DataWrapper(packet, P60Dock::CONFIG_TABLE_SIZE), id);
 }

mission/devices/PDU1Handler.cpp

@@ -22,7 +22,6 @@ ReturnValue_t PDU1Handler::buildNormalDeviceCommand(DeviceCommandId_t *id) {
 
 void PDU1Handler::letChildHandleHkReply(DeviceCommandId_t id, const uint8_t *packet) {
   parseHkTableReply(packet);
-  handleDeviceTM(&coreHk, id, true);
 }
 
 void PDU1Handler::assignChannelHookFunction(GOMSPACE::ChannelSwitchHook hook, void *args) {
@@ -81,7 +80,9 @@ ReturnValue_t PDU1Handler::setParamCallback(SetParamMessageUnpacker &unpacker,
 }
 
 void PDU1Handler::letChildHandleConfigReply(DeviceCommandId_t id, const uint8_t *packet) {
-  handleDeviceTM(packet, PDU::CONFIG_TABLE_SIZE, id);
+  util::DataWrapper wrapper;
+  wrapper.setRawData({packet, PDU::CONFIG_TABLE_SIZE});
+  handleDeviceTm(wrapper, id);
 }
 
 void PDU1Handler::parseHkTableReply(const uint8_t *packet) {

mission/devices/PDU2Handler.cpp

@@ -22,15 +22,12 @@ ReturnValue_t PDU2Handler::buildNormalDeviceCommand(DeviceCommandId_t *id) {
 
 void PDU2Handler::letChildHandleHkReply(DeviceCommandId_t id, const uint8_t *packet) {
   parseHkTableReply(packet);
-  /**
-   * Hk table will be sent to the commander if hk table request was not triggered by the
-   * PDU2Handler itself.
-   */
-  handleDeviceTM(&coreHk, id, true);
 }
 
 void PDU2Handler::letChildHandleConfigReply(DeviceCommandId_t id, const uint8_t *packet) {
-  handleDeviceTM(packet, PDU::CONFIG_TABLE_SIZE, id);
+  util::DataWrapper wrapper;
+  wrapper.setRawData({packet, PDU::CONFIG_TABLE_SIZE});
+  handleDeviceTm(wrapper, id);
 }
 
 void PDU2Handler::assignChannelHookFunction(GOMSPACE::ChannelSwitchHook hook, void *args) {