stupid PCDU
This commit is contained in:
parent
632b813bdb
commit
0ae8b4e85e
@ -65,8 +65,8 @@ ReturnValue_t PcduHandler::performOperation(uint8_t counter) {
|
|||||||
ReturnValue_t PcduHandler::initialize() {
|
ReturnValue_t PcduHandler::initialize() {
|
||||||
ReturnValue_t result;
|
ReturnValue_t result;
|
||||||
|
|
||||||
IPCStore = ObjectManager::instance()->get<StorageManagerIF>(objects::IPC_STORE);
|
ipcStore = ObjectManager::instance()->get<StorageManagerIF>(objects::IPC_STORE);
|
||||||
if (IPCStore == nullptr) {
|
if (ipcStore == nullptr) {
|
||||||
return ObjectManagerIF::CHILD_INIT_FAILED;
|
return ObjectManagerIF::CHILD_INIT_FAILED;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -162,10 +162,13 @@ void PcduHandler::updateHkTableDataset(store_address_t storeId, LocalPoolDataSet
|
|||||||
sizeof(CCSDSTime::CDS_short), dataset);
|
sizeof(CCSDSTime::CDS_short), dataset);
|
||||||
const uint8_t* packet_ptr = nullptr;
|
const uint8_t* packet_ptr = nullptr;
|
||||||
size_t size = 0;
|
size_t size = 0;
|
||||||
result = IPCStore->getData(storeId, &packet_ptr, &size);
|
result = ipcStore->getData(storeId, &packet_ptr, &size);
|
||||||
if (result != returnvalue::OK) {
|
if (result != returnvalue::OK) {
|
||||||
sif::error << "PCDUHandler::updateHkTableDataset: Failed to get data from IPCStore."
|
sif::error << "PCDUHandler::updateHkTableDataset: Failed to get data from IPC store, result 0x"
|
||||||
<< std::endl;
|
<< std::hex << std::setw(4) << std::setfill('0') << result << std::dec
|
||||||
|
<< std::setfill(' ') << std::endl;
|
||||||
|
result = ipcStore->deleteData(storeId);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
result = packetUpdate.deSerialize(&packet_ptr, &size, SerializeIF::Endianness::MACHINE);
|
result = packetUpdate.deSerialize(&packet_ptr, &size, SerializeIF::Endianness::MACHINE);
|
||||||
if (result != returnvalue::OK) {
|
if (result != returnvalue::OK) {
|
||||||
@ -173,7 +176,7 @@ void PcduHandler::updateHkTableDataset(store_address_t storeId, LocalPoolDataSet
|
|||||||
"in hk table dataset"
|
"in hk table dataset"
|
||||||
<< std::endl;
|
<< std::endl;
|
||||||
}
|
}
|
||||||
result = IPCStore->deleteData(storeId);
|
result = ipcStore->deleteData(storeId);
|
||||||
if (result != returnvalue::OK) {
|
if (result != returnvalue::OK) {
|
||||||
sif::error << "PCDUHandler::updateHkTableDataset: Failed to delete data in IPCStore"
|
sif::error << "PCDUHandler::updateHkTableDataset: Failed to delete data in IPCStore"
|
||||||
<< std::endl;
|
<< std::endl;
|
||||||
@ -396,7 +399,7 @@ ReturnValue_t PcduHandler::sendSwitchCommand(uint8_t switchNr, ReturnValue_t onO
|
|||||||
setParamMessage.serialize(&commandPtr, &serializedLength, maxSize, SerializeIF::Endianness::BIG);
|
setParamMessage.serialize(&commandPtr, &serializedLength, maxSize, SerializeIF::Endianness::BIG);
|
||||||
|
|
||||||
store_address_t storeAddress;
|
store_address_t storeAddress;
|
||||||
result = IPCStore->addData(&storeAddress, command, sizeof(command));
|
result = ipcStore->addData(&storeAddress, command, sizeof(command));
|
||||||
|
|
||||||
CommandMessage message;
|
CommandMessage message;
|
||||||
ActionMessage::setCommand(&message, GOMSPACE::PARAM_SET, storeAddress);
|
ActionMessage::setCommand(&message, GOMSPACE::PARAM_SET, storeAddress);
|
||||||
|
@ -94,7 +94,7 @@ class PcduHandler : public PowerSwitchIF,
|
|||||||
* Pointer to the IPCStore.
|
* Pointer to the IPCStore.
|
||||||
* This caches the pointer received from the objectManager in the constructor.
|
* This caches the pointer received from the objectManager in the constructor.
|
||||||
*/
|
*/
|
||||||
StorageManagerIF* IPCStore = nullptr;
|
StorageManagerIF* ipcStore = nullptr;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Message queue to communicate with other objetcs. Used for example to receive
|
* Message queue to communicate with other objetcs. Used for example to receive
|
||||||
|
Loading…
Reference in New Issue
Block a user