some renaming , hk packets finished
This commit is contained in:
parent
a181f19c02
commit
9e7d92b387
75
housekeeping/HousekeepingPacketDownlink.h
Normal file
75
housekeeping/HousekeepingPacketDownlink.h
Normal file
@ -0,0 +1,75 @@
|
||||
#ifndef FRAMEWORK_HOUSEKEEPING_HOUSEKEEPINGPACKETDOWNLINK_H_
|
||||
#define FRAMEWORK_HOUSEKEEPING_HOUSEKEEPINGPACKETDOWNLINK_H_
|
||||
#include <framework/datapoollocal/LocalPoolDataSetBase.h>
|
||||
#include <framework/housekeeping/HousekeepingMessage.h>
|
||||
#include <framework/serialize/SerialLinkedListAdapter.h>
|
||||
#include <framework/storagemanager/StorageManagerIF.h>
|
||||
|
||||
/**
|
||||
* @brief This class will be used to serialize general housekeeping packets
|
||||
* which are destined to be downlinked into the store.
|
||||
* @details
|
||||
* The housekeeping packets are stored into the IPC store and forwarded
|
||||
* to the designated housekeeping handler.
|
||||
*/
|
||||
class HousekeepingPacketDownlink: public SerialLinkedListAdapter<SerializeIF> {
|
||||
public:
|
||||
HousekeepingPacketDownlink(sid_t sid, float collectionInterval, uint8_t
|
||||
numberOfParameters, LocalPoolDataSetBase* dataSetPtr):
|
||||
sourceId(sid.objectId), setId(sid.ownerSetId),
|
||||
collectionInterval(collectionInterval),
|
||||
numberOfParameters(numberOfParameters), dataSetPtr(dataSetPtr),
|
||||
hkData(dataSetPtr) {
|
||||
setLinks();
|
||||
}
|
||||
|
||||
// virtual ReturnValue_t serialize(uint8_t** buffer, size_t* size,
|
||||
// size_t maxSize, Endianness streamEndianness) const override {
|
||||
// ReturnValue_t result = SerialLinkedListAdapter::serialize(buffer, size,
|
||||
// maxSize, streamEndianness);
|
||||
// if(result != HasReturnvaluesIF::RETURN_OK) {
|
||||
// return result;
|
||||
// }
|
||||
// return dataSetPtr->serialize(buffer, size, maxSize, streamEndianness);
|
||||
// }
|
||||
//
|
||||
// virtual size_t getSerializedSize() const override {
|
||||
//
|
||||
// }
|
||||
|
||||
virtual ReturnValue_t moveToOtherStore(StorageManagerIF* formerStore,
|
||||
store_address_t storeId, StorageManagerIF* otherStore,
|
||||
store_address_t* newStoreId, uint8_t** buffer, size_t size) {
|
||||
const uint8_t* dataPtr = nullptr;
|
||||
size_t hkDataSize = 0;
|
||||
ReturnValue_t result = formerStore->getData(storeId, &dataPtr, &hkDataSize);
|
||||
if(result != HasReturnvaluesIF::RETURN_OK) {
|
||||
return result;
|
||||
}
|
||||
|
||||
otherStore->addData(newStoreId, dataPtrgetSerializedSize(),
|
||||
buffer);
|
||||
std::memcpy
|
||||
|
||||
}
|
||||
|
||||
private:
|
||||
void setLinks() {
|
||||
setStart(&sourceId);
|
||||
sourceId.setNext(&setId);
|
||||
setId.setNext(&collectionInterval);
|
||||
collectionInterval.setNext(&numberOfParameters);
|
||||
numberOfParameters.setNext(&hkData);
|
||||
}
|
||||
|
||||
SerializeElement<object_id_t> sourceId;
|
||||
SerializeElement<uint32_t> setId;
|
||||
SerializeElement<float> collectionInterval;
|
||||
SerializeElement<uint8_t> numberOfParameters;
|
||||
LinkedElement<SerializeIF> hkData;
|
||||
LocalPoolDataSetBase* dataSetPtr;
|
||||
};
|
||||
|
||||
|
||||
|
||||
#endif /* FRAMEWORK_HOUSEKEEPING_HOUSEKEEPINGPACKETDOWNLINK_H_ */
|
@ -1,5 +1,5 @@
|
||||
#ifndef FRAMEWORK_HOUSEKEEPING_INTERNALHOUSEKEEPINGPACKET_H_
|
||||
#define FRAMEWORK_HOUSEKEEPING_INTERNALHOUSEKEEPINGPACKET_H_
|
||||
#ifndef FRAMEWORK_HOUSEKEEPING_HOUSEKEEPINGPACKETUPDATE_H_
|
||||
#define FRAMEWORK_HOUSEKEEPING_HOUSEKEEPINGPACKETUPDATE_H_
|
||||
|
||||
#include <framework/serialize/SerialBufferAdapter.h>
|
||||
#include <framework/serialize/SerialLinkedListAdapter.h>
|
||||
@ -9,7 +9,7 @@
|
||||
* @brief This helper class will be used to serialize and deserialize
|
||||
* internal housekeeping packets into the store.
|
||||
*/
|
||||
class InternalHousekeepingPacket: public SerializeIF {
|
||||
class HousekeepingPacketUpdate: public SerializeIF {
|
||||
public:
|
||||
/**
|
||||
* @param timeStamp
|
||||
@ -17,7 +17,7 @@ public:
|
||||
* @param hkData
|
||||
* @param hkDataSize
|
||||
*/
|
||||
InternalHousekeepingPacket(uint8_t* timeStamp, size_t timeStampSize,
|
||||
HousekeepingPacketUpdate(uint8_t* timeStamp, size_t timeStampSize,
|
||||
LocalPoolDataSetBase* dataSetPtr):
|
||||
timeStamp(timeStamp), timeStampSize(timeStampSize),
|
||||
dataSetPtr(dataSetPtr) {};
|
||||
@ -70,4 +70,4 @@ private:
|
||||
|
||||
|
||||
|
||||
#endif /* FRAMEWORK_HOUSEKEEPING_INTERNALHOUSEKEEPINGPACKET_H_ */
|
||||
#endif /* FRAMEWORK_HOUSEKEEPING_HOUSEKEEPINGPACKETUPDATE_H_ */
|
Loading…
Reference in New Issue
Block a user