10 #if FW_ENABLE_TEXT_LOGGING 35 class ComponentIpcSerializableBuffer :
45 MAX_DATA_SIZE =
sizeof(BuffUnion),
47 SERIALIZATION_SIZE = DATA_OFFSET + MAX_DATA_SIZE
51 return sizeof(m_buff);
58 const U8* getBuffAddr()
const {
64 U8 m_buff[SERIALIZATION_SIZE];
88 this->m_cmdIn_InputPort[port].
init();
93 this->m_cmdIn_InputPort[port].
setPortNum(port);
95 #if FW_OBJECT_NAMES == 1 99 this->m_objName.toChar(),
102 this->m_cmdIn_InputPort[port].setObjName(portName.
toChar());
112 this->m_Run_InputPort[port].
init();
119 #if FW_OBJECT_NAMES == 1 123 this->m_objName.toChar(),
126 this->m_Run_InputPort[port].setObjName(portName.
toChar());
136 this->m_TlmRecv_InputPort[port].
init();
141 this->m_TlmRecv_InputPort[port].
setPortNum(port);
143 #if FW_OBJECT_NAMES == 1 147 this->m_objName.toChar(),
150 this->m_TlmRecv_InputPort[port].setObjName(portName.
toChar());
160 this->m_pingIn_InputPort[port].
init();
165 this->m_pingIn_InputPort[port].
setPortNum(port);
167 #if FW_OBJECT_NAMES == 1 171 this->m_objName.toChar(),
174 this->m_pingIn_InputPort[port].setObjName(portName.
toChar());
184 this->m_cmdRegOut_OutputPort[port].
init();
186 #if FW_OBJECT_NAMES == 1 190 this->m_objName.toChar(),
193 this->m_cmdRegOut_OutputPort[port].setObjName(portName.
toChar());
203 this->m_cmdResponseOut_OutputPort[port].
init();
205 #if FW_OBJECT_NAMES == 1 209 this->m_objName.toChar(),
212 this->m_cmdResponseOut_OutputPort[port].setObjName(portName.
toChar());
222 this->m_eventOut_OutputPort[port].
init();
224 #if FW_OBJECT_NAMES == 1 228 this->m_objName.toChar(),
231 this->m_eventOut_OutputPort[port].setObjName(portName.
toChar());
235 #if FW_ENABLE_TEXT_LOGGING == 1 239 port < static_cast<FwIndexType>(this->getNum_textEventOut_OutputPorts());
242 this->m_textEventOut_OutputPort[port].
init();
244 #if FW_OBJECT_NAMES == 1 248 this->m_objName.toChar(),
251 this->m_textEventOut_OutputPort[port].setObjName(portName.
toChar());
262 this->m_timeGetOut_OutputPort[port].
init();
264 #if FW_OBJECT_NAMES == 1 268 this->m_objName.toChar(),
271 this->m_timeGetOut_OutputPort[port].setObjName(portName.
toChar());
281 this->m_tlmOut_OutputPort[port].
init();
283 #if FW_OBJECT_NAMES == 1 287 this->m_objName.toChar(),
290 this->m_tlmOut_OutputPort[port].setObjName(portName.
toChar());
300 this->m_PktSend_OutputPort[port].
init();
302 #if FW_OBJECT_NAMES == 1 306 this->m_objName.toChar(),
309 this->m_PktSend_OutputPort[port].setObjName(portName.
toChar());
319 this->m_pingOut_OutputPort[port].
init();
321 #if FW_OBJECT_NAMES == 1 325 this->m_objName.toChar(),
328 this->m_pingOut_OutputPort[port].setObjName(portName.
toChar());
335 static_cast<FwSizeType>(ComponentIpcSerializableBuffer::SERIALIZATION_SIZE)
339 static_cast<FwAssertArgType>(qStat)
352 static_cast<FwAssertArgType>(portNum)
355 return &this->m_cmdIn_InputPort[portNum];
367 static_cast<FwAssertArgType>(portNum)
370 return &this->m_Run_InputPort[portNum];
378 static_cast<FwAssertArgType>(portNum)
381 return &this->m_TlmRecv_InputPort[portNum];
389 static_cast<FwAssertArgType>(portNum)
392 return &this->m_pingIn_InputPort[portNum];
407 static_cast<FwAssertArgType>(portNum)
410 this->m_cmdRegOut_OutputPort[portNum].
addCallPort(port);
421 static_cast<FwAssertArgType>(portNum)
424 this->m_cmdResponseOut_OutputPort[portNum].
addCallPort(port);
435 static_cast<FwAssertArgType>(portNum)
438 this->m_eventOut_OutputPort[portNum].
addCallPort(port);
441 #if FW_ENABLE_TEXT_LOGGING == 1 443 void TlmPacketizerComponentBase ::
444 set_textEventOut_OutputPort(
450 portNum < this->getNum_textEventOut_OutputPorts(),
451 static_cast<FwAssertArgType>(portNum)
454 this->m_textEventOut_OutputPort[portNum].addCallPort(port);
467 static_cast<FwAssertArgType>(portNum)
470 this->m_timeGetOut_OutputPort[portNum].
addCallPort(port);
481 static_cast<FwAssertArgType>(portNum)
484 this->m_tlmOut_OutputPort[portNum].
addCallPort(port);
499 static_cast<FwAssertArgType>(portNum)
502 this->m_PktSend_OutputPort[portNum].
addCallPort(port);
513 static_cast<FwAssertArgType>(portNum)
516 this->m_pingOut_OutputPort[portNum].
addCallPort(port);
519 #if FW_PORT_SERIALIZATION 528 Fw::InputSerializePort* port
533 static_cast<FwAssertArgType>(portNum)
536 this->m_cmdRegOut_OutputPort[portNum].registerSerialPort(port);
542 Fw::InputSerializePort* port
547 static_cast<FwAssertArgType>(portNum)
550 this->m_cmdResponseOut_OutputPort[portNum].registerSerialPort(port);
556 Fw::InputSerializePort* port
561 static_cast<FwAssertArgType>(portNum)
564 this->m_eventOut_OutputPort[portNum].registerSerialPort(port);
567 #if FW_ENABLE_TEXT_LOGGING == 1 569 void TlmPacketizerComponentBase ::
570 set_textEventOut_OutputPort(
572 Fw::InputSerializePort* port
576 portNum < this->getNum_textEventOut_OutputPorts(),
577 static_cast<FwAssertArgType>(portNum)
580 this->m_textEventOut_OutputPort[portNum].registerSerialPort(port);
588 Fw::InputSerializePort* port
593 static_cast<FwAssertArgType>(portNum)
596 this->m_timeGetOut_OutputPort[portNum].registerSerialPort(port);
602 Fw::InputSerializePort* port
607 static_cast<FwAssertArgType>(portNum)
610 this->m_tlmOut_OutputPort[portNum].registerSerialPort(port);
615 #if FW_PORT_SERIALIZATION 624 Fw::InputSerializePort* port
629 static_cast<FwAssertArgType>(portNum)
632 this->m_PktSend_OutputPort[portNum].registerSerialPort(port);
638 Fw::InputSerializePort* port
643 static_cast<FwAssertArgType>(portNum)
646 this->m_pingOut_OutputPort[portNum].registerSerialPort(port);
658 FW_ASSERT(this->m_cmdRegOut_OutputPort[0].isConnected());
660 this->m_cmdRegOut_OutputPort[0].
invoke(
664 this->m_cmdRegOut_OutputPort[0].
invoke(
675 Fw::ActiveComponentBase(compName)
740 #if FW_ENABLE_TEXT_LOGGING == 1 743 getNum_textEventOut_OutputPorts()
const 787 static_cast<FwAssertArgType>(portNum)
790 return this->m_cmdRegOut_OutputPort[portNum].
isConnected();
798 static_cast<FwAssertArgType>(portNum)
801 return this->m_cmdResponseOut_OutputPort[portNum].
isConnected();
809 static_cast<FwAssertArgType>(portNum)
812 return this->m_eventOut_OutputPort[portNum].
isConnected();
815 #if FW_ENABLE_TEXT_LOGGING == 1 817 bool TlmPacketizerComponentBase ::
818 isConnected_textEventOut_OutputPort(
FwIndexType portNum)
821 portNum < this->getNum_textEventOut_OutputPorts(),
822 static_cast<FwAssertArgType>(portNum)
825 return this->m_textEventOut_OutputPort[portNum].isConnected();
835 static_cast<FwAssertArgType>(portNum)
838 return this->m_timeGetOut_OutputPort[portNum].
isConnected();
846 static_cast<FwAssertArgType>(portNum)
849 return this->m_tlmOut_OutputPort[portNum].
isConnected();
861 static_cast<FwAssertArgType>(portNum)
864 return this->m_PktSend_OutputPort[portNum].
isConnected();
872 static_cast<FwAssertArgType>(portNum)
875 return this->m_pingOut_OutputPort[portNum].
isConnected();
893 static_cast<FwAssertArgType>(portNum)
901 ComponentIpcSerializableBuffer msg;
905 _status = msg.serialize(
906 static_cast<FwEnumStoreType>(RUN_SCHED)
910 static_cast<FwAssertArgType>(_status)
914 _status = msg.serialize(portNum);
917 static_cast<FwAssertArgType>(_status)
921 _status = msg.serialize(context);
924 static_cast<FwAssertArgType>(_status)
933 static_cast<FwAssertArgType>(qStatus)
948 static_cast<FwAssertArgType>(portNum)
969 static_cast<FwAssertArgType>(portNum)
977 ComponentIpcSerializableBuffer msg;
981 _status = msg.serialize(
982 static_cast<FwEnumStoreType>(PINGIN_PING)
986 static_cast<FwAssertArgType>(_status)
990 _status = msg.serialize(portNum);
993 static_cast<FwAssertArgType>(_status)
997 _status = msg.serialize(key);
1000 static_cast<FwAssertArgType>(_status)
1009 static_cast<FwAssertArgType>(qStatus)
1052 static_cast<FwAssertArgType>(portNum)
1054 this->m_PktSend_OutputPort[portNum].
invoke(
1068 static_cast<FwAssertArgType>(portNum)
1070 this->m_pingOut_OutputPort[portNum].
invoke(
1086 FW_ASSERT(this->m_cmdResponseOut_OutputPort[0].isConnected());
1087 this->m_cmdResponseOut_OutputPort[0].
invoke(opCode, cmdSeq, response);
1108 ComponentIpcSerializableBuffer msg;
1112 _status = msg.serialize(static_cast<FwEnumStoreType>(CMD_SET_LEVEL));
1115 static_cast<FwAssertArgType>(_status)
1121 _status = msg.serialize(port);
1124 static_cast<FwAssertArgType>(_status)
1127 _status = msg.serialize(opCode);
1130 static_cast<FwAssertArgType>(_status)
1133 _status = msg.serialize(cmdSeq);
1136 static_cast<FwAssertArgType>(_status)
1139 _status = msg.serialize(args);
1142 static_cast<FwAssertArgType>(_status)
1151 static_cast<FwAssertArgType>(qStatus)
1167 ComponentIpcSerializableBuffer msg;
1171 _status = msg.serialize(static_cast<FwEnumStoreType>(CMD_SEND_PKT));
1174 static_cast<FwAssertArgType>(_status)
1180 _status = msg.serialize(port);
1183 static_cast<FwAssertArgType>(_status)
1186 _status = msg.serialize(opCode);
1189 static_cast<FwAssertArgType>(_status)
1192 _status = msg.serialize(cmdSeq);
1195 static_cast<FwAssertArgType>(_status)
1198 _status = msg.serialize(args);
1201 static_cast<FwAssertArgType>(_status)
1210 static_cast<FwAssertArgType>(qStatus)
1253 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1254 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1262 if (this->m_eventOut_OutputPort[0].isConnected()) {
1266 #if FW_AMPCS_COMPATIBLE 1268 _status = _logBuff.
serialize(static_cast<U8>(1));
1271 static_cast<FwAssertArgType>(_status)
1275 #if FW_AMPCS_COMPATIBLE 1278 static_cast<U8>(
sizeof(U32))
1282 static_cast<FwAssertArgType>(_status)
1288 static_cast<FwAssertArgType>(_status)
1291 this->m_eventOut_OutputPort[0].
invoke(
1300 #if FW_ENABLE_TEXT_LOGGING 1301 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1302 #if FW_OBJECT_NAMES == 1 1303 const char* _formatString =
1304 "(%s) %s: Telemetry ID 0x%" PRIx32
" not packetized";
1306 const char* _formatString =
1307 "%s: Telemetry ID 0x%" PRIx32
" not packetized";
1314 this->m_objName.toChar(),
1320 this->m_textEventOut_OutputPort[0].invoke(
1335 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1336 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1344 if (this->m_eventOut_OutputPort[0].isConnected()) {
1348 #if FW_AMPCS_COMPATIBLE 1350 _status = _logBuff.
serialize(static_cast<U8>(1));
1353 static_cast<FwAssertArgType>(_status)
1357 #if FW_AMPCS_COMPATIBLE 1360 static_cast<U8>(
sizeof(U32))
1364 static_cast<FwAssertArgType>(_status)
1370 static_cast<FwAssertArgType>(_status)
1373 this->m_eventOut_OutputPort[0].
invoke(
1382 #if FW_ENABLE_TEXT_LOGGING 1383 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1384 #if FW_OBJECT_NAMES == 1 1385 const char* _formatString =
1386 "(%s) %s: Telemetry send level to %" PRIu32
"";
1388 const char* _formatString =
1389 "%s: Telemetry send level to %" PRIu32
"";
1396 this->m_objName.toChar(),
1402 this->m_textEventOut_OutputPort[0].invoke(
1420 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1421 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1429 if (this->m_eventOut_OutputPort[0].isConnected()) {
1433 #if FW_AMPCS_COMPATIBLE 1435 _status = _logBuff.
serialize(static_cast<U8>(2));
1438 static_cast<FwAssertArgType>(_status)
1442 #if FW_AMPCS_COMPATIBLE 1445 static_cast<U8>(
sizeof(U32))
1449 static_cast<FwAssertArgType>(_status)
1455 static_cast<FwAssertArgType>(_status)
1458 #if FW_AMPCS_COMPATIBLE 1461 static_cast<U8>(
sizeof(U32))
1465 static_cast<FwAssertArgType>(_status)
1471 static_cast<FwAssertArgType>(_status)
1474 this->m_eventOut_OutputPort[0].
invoke(
1483 #if FW_ENABLE_TEXT_LOGGING 1484 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1485 #if FW_OBJECT_NAMES == 1 1486 const char* _formatString =
1487 "(%s) %s: Requested send level %" PRIu32
" higher than max packet level of %" PRIu32
"";
1489 const char* _formatString =
1490 "%s: Requested send level %" PRIu32
" higher than max packet level of %" PRIu32
"";
1497 this->m_objName.toChar(),
1504 this->m_textEventOut_OutputPort[0].invoke(
1519 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1520 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1528 if (this->m_eventOut_OutputPort[0].isConnected()) {
1532 #if FW_AMPCS_COMPATIBLE 1534 _status = _logBuff.
serialize(static_cast<U8>(1));
1537 static_cast<FwAssertArgType>(_status)
1541 #if FW_AMPCS_COMPATIBLE 1544 static_cast<U8>(
sizeof(U32))
1548 static_cast<FwAssertArgType>(_status)
1554 static_cast<FwAssertArgType>(_status)
1557 this->m_eventOut_OutputPort[0].
invoke(
1566 #if FW_ENABLE_TEXT_LOGGING 1567 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1568 #if FW_OBJECT_NAMES == 1 1569 const char* _formatString =
1570 "(%s) %s: Sent packet ID %" PRIu32
"";
1572 const char* _formatString =
1573 "%s: Sent packet ID %" PRIu32
"";
1580 this->m_objName.toChar(),
1586 this->m_textEventOut_OutputPort[0].invoke(
1601 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1602 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1610 if (this->m_eventOut_OutputPort[0].isConnected()) {
1614 #if FW_AMPCS_COMPATIBLE 1616 _status = _logBuff.
serialize(static_cast<U8>(1));
1619 static_cast<FwAssertArgType>(_status)
1623 #if FW_AMPCS_COMPATIBLE 1626 static_cast<U8>(
sizeof(U32))
1630 static_cast<FwAssertArgType>(_status)
1636 static_cast<FwAssertArgType>(_status)
1639 this->m_eventOut_OutputPort[0].
invoke(
1648 #if FW_ENABLE_TEXT_LOGGING 1649 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1650 #if FW_OBJECT_NAMES == 1 1651 const char* _formatString =
1652 "(%s) %s: Could not find packet ID %" PRIu32
"";
1654 const char* _formatString =
1655 "%s: Could not find packet ID %" PRIu32
"";
1662 this->m_objName.toChar(),
1668 this->m_textEventOut_OutputPort[0].invoke(
1688 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1690 this->m_timeGetOut_OutputPort[0].isConnected() &&
1693 this->m_timeGetOut_OutputPort[0].
invoke(_tlmTime);
1700 static_cast<FwAssertArgType>(_stat)
1707 this->m_tlmOut_OutputPort[0].
invoke(
1722 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1724 this->m_timeGetOut_OutputPort[0].
invoke(_time);
1739 ComponentIpcSerializableBuffer msg;
1749 static_cast<FwAssertArgType>(msgStatus)
1759 static_cast<FwAssertArgType>(deserStatus)
1762 MsgTypeEnum msgType =
static_cast<MsgTypeEnum
>(desMsg);
1764 if (msgType == TLMPACKETIZER_COMPONENT_EXIT) {
1769 deserStatus = msg.deserialize(portNum);
1772 static_cast<FwAssertArgType>(deserStatus)
1780 deserStatus = msg.deserialize(context);
1783 static_cast<FwAssertArgType>(deserStatus)
1798 deserStatus = msg.deserialize(key);
1801 static_cast<FwAssertArgType>(deserStatus)
1813 case CMD_SET_LEVEL: {
1816 deserStatus = msg.deserialize(opCode);
1819 static_cast<FwAssertArgType>(deserStatus)
1824 deserStatus = msg.deserialize(cmdSeq);
1827 static_cast<FwAssertArgType>(deserStatus)
1832 deserStatus = msg.deserialize(args);
1835 static_cast<FwAssertArgType>(deserStatus)
1845 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1858 #if FW_CMD_CHECK_RESIDUAL 1860 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1878 case CMD_SEND_PKT: {
1881 deserStatus = msg.deserialize(opCode);
1884 static_cast<FwAssertArgType>(deserStatus)
1889 deserStatus = msg.deserialize(cmdSeq);
1892 static_cast<FwAssertArgType>(deserStatus)
1897 deserStatus = msg.deserialize(args);
1900 static_cast<FwAssertArgType>(deserStatus)
1910 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1923 #if FW_CMD_CHECK_RESIDUAL 1925 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1953 void TlmPacketizerComponentBase ::
1965 const U32 idBase = callComp->
getIdBase();
1966 FW_ASSERT(opCode >= idBase, static_cast<FwAssertArgType>(opCode), static_cast<FwAssertArgType>(idBase));
1969 switch (opCode - idBase) {
1971 compPtr->SET_LEVEL_cmdHandlerBase(
1980 compPtr->SEND_PKT_cmdHandlerBase(
1994 void TlmPacketizerComponentBase ::
2003 compPtr->Run_handlerBase(
2009 void TlmPacketizerComponentBase ::
2020 compPtr->TlmRecv_handlerBase(
2028 void TlmPacketizerComponentBase ::
2037 compPtr->pingIn_handlerBase(
Serialization/Deserialization operation was successful.
void SEND_PKT_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
FwIndexType getNum_cmdRegOut_OutputPorts() const
void addCallPort(InputTimePort *callPort)
Register an input port.
void invoke(Fw::ComBuffer &data, U32 context) const
Invoke a port interface.
void init()
Initialization function.
void set_PktSend_OutputPort(FwIndexType portNum, Fw::InputComPort *port)
Connect port to PktSend[portNum].
void pingIn_handlerBase(FwIndexType portNum, U32 key)
Handler base-class function for input port pingIn.
FwIndexType getNum_Run_InputPorts() const
Fw::InputCmdPort * get_cmdIn_InputPort(FwIndexType portNum)
FwIndexType getNum_pingIn_InputPorts() const
NATIVE_UINT_TYPE SizeType
virtual void TlmRecv_handler(FwIndexType portNum, FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val)=0
Handler for input port TlmRecv.
void Run_handlerBase(FwIndexType portNum, U32 context)
Handler base-class function for input port Run.
Status
status returned from the queue send function
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
Telemetry send level set.
PlatformSizeType FwSizeType
void invoke(U32 key) const
Invoke a port interface.
void TlmRecv_handlerBase(FwIndexType portNum, FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val)
Handler base-class function for input port TlmRecv.
FwIndexType getNum_eventOut_OutputPorts() const
void PktSend_out(FwIndexType portNum, Fw::ComBuffer &data, U32 context)
Invoke output port PktSend.
bool isConnected_tlmOut_OutputPort(FwIndexType portNum)
void init()
Initialization function.
void cmdResponse_out(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdResponse response)
Emit command response.
Enum representing a command response.
void addCallPort(InputCmdRegPort *callPort)
Register an input port.
PlatformIndexType FwIndexType
virtual void pingIn_preMsgHook(FwIndexType portNum, U32 key)
Pre-message hook for async input port pingIn.
FwIndexType getNum_timeGetOut_OutputPorts() const
Os::Queue m_queue
queue object for active component
void addCallPort(InputTlmPort *callPort)
Register an input port.
virtual ~TlmPacketizerComponentBase()
Destroy TlmPacketizerComponentBase object.
void set_pingOut_OutputPort(FwIndexType portNum, Svc::InputPingPort *port)
Connect port to pingOut[portNum].
void init()
Object initializer.
SerializeStatus
forward declaration for string
Message will block until space is available.
void invoke(FwOpcodeType opCode) const
Invoke a port interface.
void log_WARNING_LO_NoChan(U32 Id) const
Couldn't find the packet to send.
Serializable::SizeType getBuffLeft() const
returns how much deserialization buffer is left
Svc::InputPingPort * get_pingIn_InputPort(FwIndexType portNum)
void init()
Initialization function.
Less important informational events.
Os::Queue::Status createQueue(FwSizeType depth, FwSizeType msgSize)
virtual void Run_preMsgHook(FwIndexType portNum, U32 context)
Pre-message hook for async input port Run.
Telemetry send level set.
A less serious but recoverable event.
void init()
Initialization function.
void invoke(Fw::Time &time) const
Invoke a port interface.
const char * toChar() const
void invoke(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdResponse &response) const
Invoke a port interface.
No time base has been established.
void addCallPort(InputPingPort *callPort)
Register an input port.
Status send(const U8 *buffer, FwSizeType size, FwQueuePriorityType priority, BlockingType blockType) override
send a message into the queue through delegate
void log_WARNING_LO_PacketNotFound(U32 id) const
Force a packet to be sent.
void resetDeser()
reset deserialization to beginning
Set telemetry send level.
virtual void pingIn_handler(FwIndexType portNum, U32 key)=0
Handler for input port pingIn.
Errors dispatching messages.
void invoke(FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val) const
Invoke a port interface.
bool isConnected_cmdRegOut_OutputPort(FwIndexType portNum)
void set_eventOut_OutputPort(FwIndexType portNum, Fw::InputLogPort *port)
Connect port to eventOut[portNum].
void set_tlmOut_OutputPort(FwIndexType portNum, Fw::InputTlmPort *port)
Connect port to tlmOut[portNum].
FormatStatus format(const CHAR *formatString,...)
write formatted string to buffer
void init()
Initialization function.
void log_WARNING_LO_MaxLevelExceed(U32 level, U32 max) const
virtual void Run_handler(FwIndexType portNum, U32 context)=0
Handler for input port Run.
uint8_t U8
8-bit unsigned integer
#define PRI_PlatformIntType
Command failed to deserialize.
Important informational events.
virtual void SET_LEVEL_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, U32 level)=0
void invoke(FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args) const
Invoke a port interface.
virtual void SEND_PKT_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, U32 id)=0
PlatformQueuePriorityType FwQueuePriorityType
message to exit active component task
A message was sent requesting an exit of the loop.
FwIndexType getNum_TlmRecv_InputPorts() const
void tlmWrite_SendLevel(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
FwIndexType getNum_cmdResponseOut_OutputPorts() const
SerializeStatus deserialize(U8 &val)
deserialize 8-bit unsigned int
TlmPacketizerComponentBase(const char *compName="")
Construct TlmPacketizerComponentBase object.
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
void set_timeGetOut_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeGetOut[portNum].
void addCallPort(InputLogPort *callPort)
Register an input port.
void init()
Initialization function.
virtual void SEND_PKT_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command SEND_PKT.
FwIndexType getNum_cmdIn_InputPorts() const
Channel ID for SendLevel.
message sent/received okay
bool isConnected_PktSend_OutputPort(FwIndexType portNum)
Svc::InputSchedPort * get_Run_InputPort(FwIndexType portNum)
bool isConnected_pingOut_OutputPort(FwIndexType portNum)
FwIndexType getNum_PktSend_OutputPorts() const
void addCallPort(InputComPort *callPort)
Register an input port.
Fw::InputTlmPort * get_TlmRecv_InputPort(FwIndexType portNum)
void log_ACTIVITY_HI_LevelSet(U32 id) const
FwIndexType getNum_tlmOut_OutputPorts() const
bool isConnected_timeGetOut_OutputPort(FwIndexType portNum)
void regCommands()
Register commands with the Command Dispatcher.
bool isConnected_eventOut_OutputPort(FwIndexType portNum)
Message will return with status when space is unavailable.
Status receive(U8 *destination, FwSizeType capacity, BlockingType blockType, FwSizeType &actualSize, FwQueuePriorityType &priority) override
receive a message from the queue through delegate
FwIndexType getNum_pingOut_OutputPorts() const
bool isConnected_cmdResponseOut_OutputPort(FwIndexType portNum)
void init()
Initialization function.
void log_ACTIVITY_LO_PacketSent(U32 id) const
void SET_LEVEL_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects) ...
virtual void SET_LEVEL_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command SET_LEVEL.
void set_cmdResponseOut_OutputPort(FwIndexType portNum, Fw::InputCmdResponsePort *port)
Connect port to cmdResponseOut[portNum].
void pingOut_out(FwIndexType portNum, U32 key)
Invoke output port pingOut.
Telemetry channel is not part of a telemetry packet.
void addCallPort(InputCmdResponsePort *callPort)
Register an input port.
void set_cmdRegOut_OutputPort(FwIndexType portNum, Fw::InputCmdRegPort *port)
Connect port to cmdRegOut[portNum].