linux/devices/GPSHyperionLinuxController.cpp

@@ -81,11 +81,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>());
-  bool enableHk = false;
+  poolManager.subscribeForPeriodicPacket(gpsSet.getSid(), false, 30.0, false);
-#if OBSW_ENABLE_PERIODIC_HK == 1
-  enableHk = true;
-#endif
-  poolManager.subscribeForPeriodicPacket(gpsSet.getSid(), enableHk, 60.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/ACUHandler.cpp

@@ -271,6 +271,7 @@ ReturnValue_t ACUHandler::initializeLocalDataPool(localpool::DataPool &localData
   localDataPoolMap.emplace(pool::ACU_WDT_CNT_GND, new PoolEntry<uint32_t>({0}));
   localDataPoolMap.emplace(pool::ACU_WDT_GND_LEFT, new PoolEntry<uint32_t>({0}));
 
+  poolManager.subscribeForPeriodicPacket(acuHkTableDataset.getSid(), false, 30.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/BpxBatteryHandler.cpp

@@ -270,10 +270,7 @@ ReturnValue_t BpxBatteryHandler::initializeLocalDataPool(localpool::DataPool& lo
   localDataPoolMap.emplace(BpxBattery::BATTERY_HEATER_MODE, &battheatMode);
   localDataPoolMap.emplace(BpxBattery::BATTHEAT_LOW_LIMIT, &battheatLow);
   localDataPoolMap.emplace(BpxBattery::BATTHEAT_HIGH_LIMIT, &battheatHigh);
-
+  poolManager.subscribeForPeriodicPacket(hkSet.getSid(), false, 30.0, false);
-#if OBSW_ENABLE_PERIODIC_HK == 1
-  poolManager.subscribeForPeriodicPacket(hkSet.getSid(), true, 1.0, false);
-#endif
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/GPSHyperionHandler.cpp

@@ -169,7 +169,7 @@ ReturnValue_t GPSHyperionHandler::initializeLocalDataPool(localpool::DataPool &l
   localDataPoolMap.emplace(GpsHyperion::UNIX_SECONDS, new PoolEntry<uint32_t>());
   localDataPoolMap.emplace(GpsHyperion::SATS_IN_USE, new PoolEntry<uint8_t>());
   localDataPoolMap.emplace(GpsHyperion::FIX_MODE, new PoolEntry<uint8_t>());
-  poolManager.subscribeForPeriodicPacket(gpsSet.getSid(), true, 2.0, false);
+  poolManager.subscribeForPeriodicPacket(gpsSet.getSid(), false, 30.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/GyroADIS1650XHandler.cpp

@@ -363,6 +363,7 @@ ReturnValue_t GyroADIS1650XHandler::initializeLocalDataPool(localpool::DataPool
   localDataPoolMap.emplace(ADIS1650X::FILTER_SETTINGS, new PoolEntry<uint8_t>());
   localDataPoolMap.emplace(ADIS1650X::MSC_CTRL_REGISTER, new PoolEntry<uint16_t>());
   localDataPoolMap.emplace(ADIS1650X::DEC_RATE_REGISTER, new PoolEntry<uint16_t>());
+  poolManager.subscribeForPeriodicPacket(primaryDataset.getSid(), false, 5.0, true);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/IMTQHandler.cpp

@@ -599,6 +599,8 @@ ReturnValue_t IMTQHandler::initializeLocalDataPool(localpool::DataPool& localDat
   localDataPoolMap.emplace(IMTQ::FINA_NEG_Z_COIL_Y_TEMPERATURE, new PoolEntry<uint16_t>({0}));
   localDataPoolMap.emplace(IMTQ::FINA_NEG_Z_COIL_Z_TEMPERATURE, new PoolEntry<uint16_t>({0}));
 
+  poolManager.subscribeForPeriodicPacket(engHkDataset.getSid(), false, 10.0, true);
+  poolManager.subscribeForPeriodicPacket(calMtmMeasurementSet.getSid(), false, 10.0, true);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/Max31865PT1000Handler.cpp

@@ -515,8 +515,7 @@ ReturnValue_t Max31865PT1000Handler::initializeLocalDataPool(localpool::DataPool
   localDataPoolMap.emplace(Max31865Definitions::PoolIds::TEMPERATURE_C,
                            new PoolEntry<float>({0}, 1, true));
   localDataPoolMap.emplace(Max31865Definitions::PoolIds::FAULT_BYTE, new PoolEntry<uint8_t>({0}));
-  //    poolManager.subscribeForPeriodicPacket(sensorDatasetSid,
+  poolManager.subscribeForPeriodicPacket(sensorDataset.getSid(), false, 30.0, false);
-  //            false, 4.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/PDU1Handler.cpp

@@ -426,7 +426,7 @@ ReturnValue_t PDU1Handler::initializeLocalDataPool(localpool::DataPool &localDat
   localDataPoolMap.emplace(P60System::pool::PDU1_WDT_CAN_LEFT, new PoolEntry<uint32_t>({0}));
   localDataPoolMap.emplace(P60System::pool::PDU1_WDT_CSP_LEFT1, new PoolEntry<uint8_t>({0}));
   localDataPoolMap.emplace(P60System::pool::PDU1_WDT_CSP_LEFT2, new PoolEntry<uint8_t>({0}));
-  poolManager.subscribeForPeriodicPacket(pdu1HkTableDataset.getSid(), false, 0.4, true);
+  poolManager.subscribeForPeriodicPacket(pdu1HkTableDataset.getSid(), false, 10.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/PDU2Handler.cpp

@@ -354,9 +354,7 @@ ReturnValue_t PDU2Handler::initializeLocalDataPool(localpool::DataPool &localDat
   localDataPoolMap.emplace(pool::PDU2_WDT_CAN_LEFT, new PoolEntry<uint32_t>({0}));
   localDataPoolMap.emplace(pool::PDU2_WDT_CSP_LEFT1, new PoolEntry<uint8_t>({0}));
   localDataPoolMap.emplace(pool::PDU2_WDT_CSP_LEFT2, new PoolEntry<uint8_t>({0}));
-#if OBSW_ENABLE_PERIODIC_HK == 1
+  poolManager.subscribeForPeriodicPacket(pdu2HkTableDataset.getSid(), false, 10.0, false);
-  poolManager.subscribeForPeriodicPacket(pdu2HkTableDataset.getSid(), false, 0.4, true);
-#endif
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/PayloadPcduHandler.cpp

@@ -293,7 +293,7 @@ ReturnValue_t PayloadPcduHandler::initializeLocalDataPool(localpool::DataPool& l
   localDataPoolMap.emplace(plpcdu::PlPcduPoolIds::CHANNEL_VEC, &channelValues);
   localDataPoolMap.emplace(plpcdu::PlPcduPoolIds::PROCESSED_VEC, &processedValues);
   localDataPoolMap.emplace(plpcdu::PlPcduPoolIds::TEMP, &tempC);
-  poolManager.subscribeForPeriodicPacket(adcSet.getSid(), false, 0.1, true);
+  poolManager.subscribeForPeriodicPacket(adcSet.getSid(), false, 5.0, true);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/RadiationSensorHandler.cpp

@@ -203,6 +203,7 @@ ReturnValue_t RadiationSensorHandler::initializeLocalDataPool(localpool::DataPoo
   localDataPoolMap.emplace(RAD_SENSOR::AIN5, new PoolEntry<uint16_t>({0}));
   localDataPoolMap.emplace(RAD_SENSOR::AIN6, new PoolEntry<uint16_t>({0}));
   localDataPoolMap.emplace(RAD_SENSOR::AIN7, new PoolEntry<uint16_t>({0}));
+  poolManager.subscribeForPeriodicPacket(dataset.getSid(), false, 20.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/RwHandler.cpp

@@ -279,7 +279,9 @@ ReturnValue_t RwHandler::initializeLocalDataPool(localpool::DataPool& localDataP
   localDataPoolMap.emplace(RwDefinitions::SPI_BYTES_READ, new PoolEntry<uint32_t>({0}));
   localDataPoolMap.emplace(RwDefinitions::SPI_REG_OVERRUN_ERRORS, new PoolEntry<uint32_t>({0}));
   localDataPoolMap.emplace(RwDefinitions::SPI_TOTAL_ERRORS, new PoolEntry<uint32_t>({0}));
-
+  poolManager.subscribeForPeriodicPacket(temperatureSet.getSid(), false, 30.0, false);
+  poolManager.subscribeForPeriodicPacket(statusSet.getSid(), false, 5.0, true);
+  poolManager.subscribeForPeriodicPacket(tmDataset.getSid(), false, 30.0, false);
   return RETURN_OK;
 }
 

mission/devices/SusHandler.cpp

@@ -200,6 +200,7 @@ ReturnValue_t SusHandler::initializeLocalDataPool(localpool::DataPool &localData
                                                   LocalDataPoolManager &poolManager) {
   localDataPoolMap.emplace(SUS::TEMPERATURE_C, &tempC);
   localDataPoolMap.emplace(SUS::CHANNEL_VEC, &channelVec);
+  poolManager.subscribeForPeriodicPacket(dataset.getSid(), false, 5.0, true);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/SyrlinksHkHandler.cpp

@@ -627,6 +627,9 @@ ReturnValue_t SyrlinksHkHandler::initializeLocalDataPool(localpool::DataPool& lo
   localDataPoolMap.emplace(syrlinks::TEMP_BASEBAND_BOARD, new PoolEntry<uint16_t>({0}));
   localDataPoolMap.emplace(syrlinks::TEMP_POWER_AMPLIFIER, new PoolEntry<uint16_t>({0}));
 
+  poolManager.subscribeForPeriodicPacket(txDataset.getSid(), false, 5.0, true);
+  poolManager.subscribeForPeriodicPacket(rxDataset.getSid(), false, 5.0, true);
+  poolManager.subscribeForPeriodicPacket(temperatureSet.getSid(), false, 10.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }
 

mission/devices/Tmp1075Handler.cpp

@@ -119,6 +119,7 @@ uint32_t Tmp1075Handler::getTransitionDelayMs(Mode_t modeFrom, Mode_t modeTo) {
 
 ReturnValue_t Tmp1075Handler::initializeLocalDataPool(localpool::DataPool &localDataPoolMap,
                                                       LocalDataPoolManager &poolManager) {
-  localDataPoolMap.emplace(TMP1075::TEMPERATURE_C_TMP1075_1, new PoolEntry<float>({0.0}));
+  localDataPoolMap.emplace(TMP1075::TEMPERATURE_C_TMP1075, new PoolEntry<float>({0.0}));
+  poolManager.subscribeForPeriodicPacket(dataset.getSid(), false, 30.0, false);
   return HasReturnvaluesIF::RETURN_OK;
 }

mission/devices/devicedefinitions/Tmp1075Definitions.h

@@ -21,7 +21,7 @@ static const uint32_t TMP1075_DATA_SET_ID = GET_TEMP;
 
 static const uint8_t MAX_REPLY_LENGTH = GET_TEMP_REPLY_SIZE;
 
-enum Tmp1075PoolIds : lp_id_t { TEMPERATURE_C_TMP1075_1, TEMPERATURE_C_TMP1075_2 };
+enum Tmp1075PoolIds : lp_id_t { TEMPERATURE_C_TMP1075 };
 
 class Tmp1075Dataset : public StaticLocalDataSet<sizeof(float)> {
  public:
@@ -29,7 +29,7 @@ class Tmp1075Dataset : public StaticLocalDataSet<sizeof(float)> {
 
   Tmp1075Dataset(object_id_t objectId) : StaticLocalDataSet(sid_t(objectId, TMP1075_DATA_SET_ID)) {}
 
-  lp_var_t<float> temperatureCelcius = lp_var_t<float>(sid.objectId, TEMPERATURE_C_TMP1075_1, this);
+  lp_var_t<float> temperatureCelcius = lp_var_t<float>(sid.objectId, TEMPERATURE_C_TMP1075, this);
 };
 }  // namespace TMP1075