29GenericHubComponentImpl ::~GenericHubComponentImpl() {}
31void GenericHubComponentImpl ::send_data(
const HubType type,
38 Fw::Buffer outgoing = dataOutAllocate_out(0,
static_cast<U32
>(size +
sizeof(U32) +
sizeof(U32) +
sizeof(
FwBuffSizeType)));
41 status = serialize.
serialize(
static_cast<U32
>(type));
43 status = serialize.
serialize(
static_cast<U32
>(port));
48 dataOut_out(0, outgoing);
56 send_data(HUB_TYPE_BUFFER, portNum, fwBuffer.
getData(), fwBuffer.
getSize());
57 bufferDeallocate_out(0, fwBuffer);
61 HubType type = HUB_TYPE_MAX;
76 type =
static_cast<HubType
>(type_in);
85 U32 rawSize =
static_cast<U32
>(fwBuffer.
getSize() -
sizeof(U32) -
sizeof(U32) -
sizeof(
FwBuffSizeType));
86 FW_ASSERT(rawSize ==
static_cast<U32
>(size));
87 if (type == HUB_TYPE_PORT) {
90 status = wrapper.setBuffLen(rawSize);
92 portOut_out(
static_cast<FwIndexType>(port), wrapper);
94 dataInDeallocate_out(0, fwBuffer);
95 }
else if (type == HUB_TYPE_BUFFER) {
98 buffersOut_out(
static_cast<FwIndexType>(port), fwBuffer);
99 }
else if (type == HUB_TYPE_EVENT) {
116 this->LogSend_out(
static_cast<FwIndexType>(port),
id, timeTag, severity, args);
119 dataInDeallocate_out(0, fwBuffer);
120 }
else if (type == HUB_TYPE_CHANNEL) {
134 this->TlmSend_out(
static_cast<FwIndexType>(port),
id, timeTag, val);
137 dataInDeallocate_out(0, fwBuffer);
141void GenericHubComponentImpl ::LogRecv_handler(
const NATIVE_INT_TYPE portNum,
149 serializer.resetSer();
150 status = serializer.serialize(
id);
152 status = serializer.serialize(timeTag);
154 status = serializer.serialize(severity);
156 status = serializer.serialize(args);
158 U32 size = serializer.getBuffLength();
159 this->send_data(HubType::HUB_TYPE_EVENT, portNum, buffer, size);
163void GenericHubComponentImpl ::TlmRecv_handler(
const NATIVE_INT_TYPE portNum,
170 serializer.resetSer();
171 status = serializer.serialize(
id);
173 status = serializer.serialize(timeTag);
175 status = serializer.serialize(val);
177 U32 size = serializer.getBuffLength();
178 this->send_data(HubType::HUB_TYPE_CHANNEL, portNum, buffer, size);
PlatformIntType NATIVE_INT_TYPE
uint8_t U8
8-bit unsigned integer
#define FW_LOG_BUFFER_MAX_SIZE
FwSizeStoreType FwBuffSizeType
#define FW_PORT_SERIALIZATION
#define FW_TLM_BUFFER_MAX_SIZE
PlatformIndexType FwIndexType
C++-compatible configuration header for fprime configuration.
void set(U8 *data, U32 size, U32 context=NO_CONTEXT)
SerializeBufferBase & getSerializeRepr()
External serialize buffer with no copy semantics.
Enum representing event severity.
@ SERIALIZED_SIZE
The size of the serial representation.
SerializeStatus setBuffLen(Serializable::SizeType length)
sets buffer length manually after filling with data
Serializable::SizeType getBuffLength() const
returns current buffer size
SerializeStatus deserialize(U8 &val)
deserialize 8-bit unsigned int
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
virtual U8 * getBuffAddr()=0
gets buffer address for data filling
Auto-generated base for GenericHub component.
SerializeStatus
forward declaration for string
@ FW_SERIALIZE_OK
Serialization/Deserialization operation was successful.