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 98 "%s_cmdIn_InputPort[%" PRI_PlatformIntType
"]",
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 122 "%s_Run_InputPort[%" PRI_PlatformIntType
"]",
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 146 "%s_TlmRecv_InputPort[%" PRI_PlatformIntType
"]",
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 170 "%s_pingIn_InputPort[%" PRI_PlatformIntType
"]",
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 189 "%s_cmdRegOut_OutputPort[%" PRI_PlatformIntType
"]",
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 208 "%s_cmdResponseOut_OutputPort[%" PRI_PlatformIntType
"]",
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 227 "%s_eventOut_OutputPort[%" PRI_PlatformIntType
"]",
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 247 "%s_textEventOut_OutputPort[%" PRI_PlatformIntType
"]",
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 267 "%s_timeGetOut_OutputPort[%" PRI_PlatformIntType
"]",
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 286 "%s_tlmOut_OutputPort[%" PRI_PlatformIntType
"]",
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 305 "%s_PktSend_OutputPort[%" PRI_PlatformIntType
"]",
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 324 "%s_pingOut_OutputPort[%" PRI_PlatformIntType
"]",
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)
1056 this->m_PktSend_OutputPort[portNum].isConnected(),
1057 static_cast<FwAssertArgType>(portNum)
1059 this->m_PktSend_OutputPort[portNum].
invoke(
1073 static_cast<FwAssertArgType>(portNum)
1077 this->m_pingOut_OutputPort[portNum].isConnected(),
1078 static_cast<FwAssertArgType>(portNum)
1080 this->m_pingOut_OutputPort[portNum].
invoke(
1096 FW_ASSERT(this->m_cmdResponseOut_OutputPort[0].isConnected());
1097 this->m_cmdResponseOut_OutputPort[0].
invoke(opCode, cmdSeq, response);
1118 ComponentIpcSerializableBuffer msg;
1122 _status = msg.serialize(static_cast<FwEnumStoreType>(CMD_SET_LEVEL));
1125 static_cast<FwAssertArgType>(_status)
1131 _status = msg.serialize(port);
1134 static_cast<FwAssertArgType>(_status)
1137 _status = msg.serialize(opCode);
1140 static_cast<FwAssertArgType>(_status)
1143 _status = msg.serialize(cmdSeq);
1146 static_cast<FwAssertArgType>(_status)
1149 _status = msg.serialize(args);
1152 static_cast<FwAssertArgType>(_status)
1161 static_cast<FwAssertArgType>(qStatus)
1177 ComponentIpcSerializableBuffer msg;
1181 _status = msg.serialize(static_cast<FwEnumStoreType>(CMD_SEND_PKT));
1184 static_cast<FwAssertArgType>(_status)
1190 _status = msg.serialize(port);
1193 static_cast<FwAssertArgType>(_status)
1196 _status = msg.serialize(opCode);
1199 static_cast<FwAssertArgType>(_status)
1202 _status = msg.serialize(cmdSeq);
1205 static_cast<FwAssertArgType>(_status)
1208 _status = msg.serialize(args);
1211 static_cast<FwAssertArgType>(_status)
1220 static_cast<FwAssertArgType>(qStatus)
1263 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1264 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1272 if (this->m_eventOut_OutputPort[0].isConnected()) {
1276 #if FW_AMPCS_COMPATIBLE 1278 _status = _logBuff.
serialize(static_cast<U8>(1));
1281 static_cast<FwAssertArgType>(_status)
1285 #if FW_AMPCS_COMPATIBLE 1288 static_cast<U8>(
sizeof(U32))
1292 static_cast<FwAssertArgType>(_status)
1298 static_cast<FwAssertArgType>(_status)
1301 this->m_eventOut_OutputPort[0].
invoke(
1310 #if FW_ENABLE_TEXT_LOGGING 1311 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1312 #if FW_OBJECT_NAMES == 1 1313 const char* _formatString =
1314 "(%s) %s: Telemetry ID 0x%" PRIx32
" not packetized";
1316 const char* _formatString =
1317 "%s: Telemetry ID 0x%" PRIx32
" not packetized";
1324 this->m_objName.toChar(),
1330 this->m_textEventOut_OutputPort[0].invoke(
1345 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1346 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1354 if (this->m_eventOut_OutputPort[0].isConnected()) {
1358 #if FW_AMPCS_COMPATIBLE 1360 _status = _logBuff.
serialize(static_cast<U8>(1));
1363 static_cast<FwAssertArgType>(_status)
1367 #if FW_AMPCS_COMPATIBLE 1370 static_cast<U8>(
sizeof(U32))
1374 static_cast<FwAssertArgType>(_status)
1380 static_cast<FwAssertArgType>(_status)
1383 this->m_eventOut_OutputPort[0].
invoke(
1392 #if FW_ENABLE_TEXT_LOGGING 1393 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1394 #if FW_OBJECT_NAMES == 1 1395 const char* _formatString =
1396 "(%s) %s: Telemetry send level to %" PRIu32
"";
1398 const char* _formatString =
1399 "%s: Telemetry send level to %" PRIu32
"";
1406 this->m_objName.toChar(),
1412 this->m_textEventOut_OutputPort[0].invoke(
1430 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1431 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1439 if (this->m_eventOut_OutputPort[0].isConnected()) {
1443 #if FW_AMPCS_COMPATIBLE 1445 _status = _logBuff.
serialize(static_cast<U8>(2));
1448 static_cast<FwAssertArgType>(_status)
1452 #if FW_AMPCS_COMPATIBLE 1455 static_cast<U8>(
sizeof(U32))
1459 static_cast<FwAssertArgType>(_status)
1465 static_cast<FwAssertArgType>(_status)
1468 #if FW_AMPCS_COMPATIBLE 1471 static_cast<U8>(
sizeof(U32))
1475 static_cast<FwAssertArgType>(_status)
1481 static_cast<FwAssertArgType>(_status)
1484 this->m_eventOut_OutputPort[0].
invoke(
1493 #if FW_ENABLE_TEXT_LOGGING 1494 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1495 #if FW_OBJECT_NAMES == 1 1496 const char* _formatString =
1497 "(%s) %s: Requested send level %" PRIu32
" higher than max packet level of %" PRIu32
"";
1499 const char* _formatString =
1500 "%s: Requested send level %" PRIu32
" higher than max packet level of %" PRIu32
"";
1507 this->m_objName.toChar(),
1514 this->m_textEventOut_OutputPort[0].invoke(
1529 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1530 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1538 if (this->m_eventOut_OutputPort[0].isConnected()) {
1542 #if FW_AMPCS_COMPATIBLE 1544 _status = _logBuff.
serialize(static_cast<U8>(1));
1547 static_cast<FwAssertArgType>(_status)
1551 #if FW_AMPCS_COMPATIBLE 1554 static_cast<U8>(
sizeof(U32))
1558 static_cast<FwAssertArgType>(_status)
1564 static_cast<FwAssertArgType>(_status)
1567 this->m_eventOut_OutputPort[0].
invoke(
1576 #if FW_ENABLE_TEXT_LOGGING 1577 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1578 #if FW_OBJECT_NAMES == 1 1579 const char* _formatString =
1580 "(%s) %s: Sent packet ID %" PRIu32
"";
1582 const char* _formatString =
1583 "%s: Sent packet ID %" PRIu32
"";
1590 this->m_objName.toChar(),
1596 this->m_textEventOut_OutputPort[0].invoke(
1611 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1612 this->m_timeGetOut_OutputPort[0].
invoke(_logTime);
1620 if (this->m_eventOut_OutputPort[0].isConnected()) {
1624 #if FW_AMPCS_COMPATIBLE 1626 _status = _logBuff.
serialize(static_cast<U8>(1));
1629 static_cast<FwAssertArgType>(_status)
1633 #if FW_AMPCS_COMPATIBLE 1636 static_cast<U8>(
sizeof(U32))
1640 static_cast<FwAssertArgType>(_status)
1646 static_cast<FwAssertArgType>(_status)
1649 this->m_eventOut_OutputPort[0].
invoke(
1658 #if FW_ENABLE_TEXT_LOGGING 1659 if (this->m_textEventOut_OutputPort[0].isConnected()) {
1660 #if FW_OBJECT_NAMES == 1 1661 const char* _formatString =
1662 "(%s) %s: Could not find packet ID %" PRIu32
"";
1664 const char* _formatString =
1665 "%s: Could not find packet ID %" PRIu32
"";
1672 this->m_objName.toChar(),
1678 this->m_textEventOut_OutputPort[0].invoke(
1698 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1700 this->m_timeGetOut_OutputPort[0].isConnected() &&
1703 this->m_timeGetOut_OutputPort[0].
invoke(_tlmTime);
1710 static_cast<FwAssertArgType>(_stat)
1717 this->m_tlmOut_OutputPort[0].
invoke(
1732 if (this->m_timeGetOut_OutputPort[0].isConnected()) {
1734 this->m_timeGetOut_OutputPort[0].
invoke(_time);
1749 ComponentIpcSerializableBuffer _msg;
1759 static_cast<FwAssertArgType>(_msgStatus)
1769 static_cast<FwAssertArgType>(_deserStatus)
1772 MsgTypeEnum _msgType =
static_cast<MsgTypeEnum
>(_desMsg);
1774 if (_msgType == TLMPACKETIZER_COMPONENT_EXIT) {
1779 _deserStatus = _msg.deserialize(portNum);
1782 static_cast<FwAssertArgType>(_deserStatus)
1790 _deserStatus = _msg.deserialize(context);
1793 static_cast<FwAssertArgType>(_deserStatus)
1808 _deserStatus = _msg.deserialize(key);
1811 static_cast<FwAssertArgType>(_deserStatus)
1823 case CMD_SET_LEVEL: {
1826 _deserStatus = _msg.deserialize(_opCode);
1829 static_cast<FwAssertArgType>(_deserStatus)
1834 _deserStatus = _msg.deserialize(_cmdSeq);
1837 static_cast<FwAssertArgType>(_deserStatus)
1842 _deserStatus = _msg.deserialize(args);
1845 static_cast<FwAssertArgType>(_deserStatus)
1855 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1868 #if FW_CMD_CHECK_RESIDUAL 1870 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1888 case CMD_SEND_PKT: {
1891 _deserStatus = _msg.deserialize(_opCode);
1894 static_cast<FwAssertArgType>(_deserStatus)
1899 _deserStatus = _msg.deserialize(_cmdSeq);
1902 static_cast<FwAssertArgType>(_deserStatus)
1907 _deserStatus = _msg.deserialize(args);
1910 static_cast<FwAssertArgType>(_deserStatus)
1920 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1933 #if FW_CMD_CHECK_RESIDUAL 1935 if (this->m_cmdResponseOut_OutputPort[0].isConnected()) {
1963 void TlmPacketizerComponentBase ::
1975 const U32 idBase = callComp->
getIdBase();
1976 FW_ASSERT(opCode >= idBase, static_cast<FwAssertArgType>(opCode), static_cast<FwAssertArgType>(idBase));
1979 switch (opCode - idBase) {
1981 compPtr->SET_LEVEL_cmdHandlerBase(
1990 compPtr->SEND_PKT_cmdHandlerBase(
2004 void TlmPacketizerComponentBase ::
2013 compPtr->Run_handlerBase(
2019 void TlmPacketizerComponentBase ::
2030 compPtr->TlmRecv_handlerBase(
2038 void TlmPacketizerComponentBase ::
2047 compPtr->pingIn_handlerBase(
Set telemetry send level.
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].
Telemetry send level set.
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
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
Channel ID for SendLevel.
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.
Couldn't find the packet to send.
void invoke(FwOpcodeType opCode) const
Invoke a port interface.
void log_WARNING_LO_NoChan(U32 Id) const
Serializable::SizeType getBuffLeft() const
returns how much deserialization buffer is left
Svc::InputPingPort * get_pingIn_InputPort(FwIndexType portNum)
void init()
Initialization function.
message to exit active component task
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.
A less serious but recoverable event.
void init()
Initialization function.
void invoke(Fw::Time &time) const
Invoke a port interface.
Telemetry channel is not part of a telemetry packet.
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
Telemetry send level set.
void resetDeser()
reset deserialization to beginning
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
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
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.
Force a packet to be sent.
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
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.
void addCallPort(InputCmdResponsePort *callPort)
Register an input port.
void set_cmdRegOut_OutputPort(FwIndexType portNum, Fw::InputCmdRegPort *port)
Connect port to cmdRegOut[portNum].