10 #if FW_ENABLE_TEXT_LOGGING 21 CMD_DUMP_FILTER_STATE,
31 BYTE loqQueueIntIfSize[
41 class ComponentIpcSerializableBuffer :
51 MAX_DATA_SIZE =
sizeof(BuffUnion),
53 SERIALIZATION_SIZE = DATA_OFFSET + MAX_DATA_SIZE
57 return sizeof(m_buff);
64 const U8* getBuffAddr()
const {
70 U8 m_buff[SERIALIZATION_SIZE];
94 this->m_CmdDisp_InputPort[port].
init();
99 this->m_CmdDisp_InputPort[port].
setPortNum(port);
101 #if FW_OBJECT_NAMES == 1 104 "%s_CmdDisp_InputPort[%" PRI_PlatformIntType
"]",
105 this->m_objName.toChar(),
108 this->m_CmdDisp_InputPort[port].setObjName(portName.
toChar());
118 this->m_LogRecv_InputPort[port].
init();
123 this->m_LogRecv_InputPort[port].
setPortNum(port);
125 #if FW_OBJECT_NAMES == 1 128 "%s_LogRecv_InputPort[%" PRI_PlatformIntType
"]",
129 this->m_objName.toChar(),
132 this->m_LogRecv_InputPort[port].setObjName(portName.
toChar());
142 this->m_pingIn_InputPort[port].
init();
147 this->m_pingIn_InputPort[port].
setPortNum(port);
149 #if FW_OBJECT_NAMES == 1 152 "%s_pingIn_InputPort[%" PRI_PlatformIntType
"]",
153 this->m_objName.toChar(),
156 this->m_pingIn_InputPort[port].setObjName(portName.
toChar());
166 this->m_CmdReg_OutputPort[port].
init();
168 #if FW_OBJECT_NAMES == 1 171 "%s_CmdReg_OutputPort[%" PRI_PlatformIntType
"]",
172 this->m_objName.toChar(),
175 this->m_CmdReg_OutputPort[port].setObjName(portName.
toChar());
185 this->m_CmdStatus_OutputPort[port].
init();
187 #if FW_OBJECT_NAMES == 1 190 "%s_CmdStatus_OutputPort[%" PRI_PlatformIntType
"]",
191 this->m_objName.toChar(),
194 this->m_CmdStatus_OutputPort[port].setObjName(portName.
toChar());
204 this->m_Log_OutputPort[port].
init();
206 #if FW_OBJECT_NAMES == 1 209 "%s_Log_OutputPort[%" PRI_PlatformIntType
"]",
210 this->m_objName.toChar(),
213 this->m_Log_OutputPort[port].setObjName(portName.
toChar());
217 #if FW_ENABLE_TEXT_LOGGING == 1 221 port < static_cast<FwIndexType>(this->getNum_LogText_OutputPorts());
224 this->m_LogText_OutputPort[port].
init();
226 #if FW_OBJECT_NAMES == 1 229 "%s_LogText_OutputPort[%" PRI_PlatformIntType
"]",
230 this->m_objName.toChar(),
233 this->m_LogText_OutputPort[port].setObjName(portName.
toChar());
244 this->m_Time_OutputPort[port].
init();
246 #if FW_OBJECT_NAMES == 1 249 "%s_Time_OutputPort[%" PRI_PlatformIntType
"]",
250 this->m_objName.toChar(),
253 this->m_Time_OutputPort[port].setObjName(portName.
toChar());
263 this->m_FatalAnnounce_OutputPort[port].
init();
265 #if FW_OBJECT_NAMES == 1 268 "%s_FatalAnnounce_OutputPort[%" PRI_PlatformIntType
"]",
269 this->m_objName.toChar(),
272 this->m_FatalAnnounce_OutputPort[port].setObjName(portName.
toChar());
282 this->m_PktSend_OutputPort[port].
init();
284 #if FW_OBJECT_NAMES == 1 287 "%s_PktSend_OutputPort[%" PRI_PlatformIntType
"]",
288 this->m_objName.toChar(),
291 this->m_PktSend_OutputPort[port].setObjName(portName.
toChar());
301 this->m_pingOut_OutputPort[port].
init();
303 #if FW_OBJECT_NAMES == 1 306 "%s_pingOut_OutputPort[%" PRI_PlatformIntType
"]",
307 this->m_objName.toChar(),
310 this->m_pingOut_OutputPort[port].setObjName(portName.
toChar());
317 static_cast<FwSizeType>(ComponentIpcSerializableBuffer::SERIALIZATION_SIZE)
321 static_cast<FwAssertArgType>(qStat)
334 static_cast<FwAssertArgType>(portNum)
337 return &this->m_CmdDisp_InputPort[portNum];
349 static_cast<FwAssertArgType>(portNum)
352 return &this->m_LogRecv_InputPort[portNum];
360 static_cast<FwAssertArgType>(portNum)
363 return &this->m_pingIn_InputPort[portNum];
378 static_cast<FwAssertArgType>(portNum)
381 this->m_CmdReg_OutputPort[portNum].
addCallPort(port);
392 static_cast<FwAssertArgType>(portNum)
395 this->m_CmdStatus_OutputPort[portNum].
addCallPort(port);
406 static_cast<FwAssertArgType>(portNum)
412 #if FW_ENABLE_TEXT_LOGGING == 1 414 void ActiveLoggerComponentBase ::
415 set_LogText_OutputPort(
421 portNum < this->getNum_LogText_OutputPorts(),
422 static_cast<FwAssertArgType>(portNum)
425 this->m_LogText_OutputPort[portNum].addCallPort(port);
438 static_cast<FwAssertArgType>(portNum)
441 this->m_Time_OutputPort[portNum].
addCallPort(port);
456 static_cast<FwAssertArgType>(portNum)
459 this->m_FatalAnnounce_OutputPort[portNum].
addCallPort(port);
470 static_cast<FwAssertArgType>(portNum)
473 this->m_PktSend_OutputPort[portNum].
addCallPort(port);
484 static_cast<FwAssertArgType>(portNum)
487 this->m_pingOut_OutputPort[portNum].
addCallPort(port);
490 #if FW_PORT_SERIALIZATION 499 Fw::InputSerializePort* port
504 static_cast<FwAssertArgType>(portNum)
507 this->m_CmdReg_OutputPort[portNum].registerSerialPort(port);
513 Fw::InputSerializePort* port
518 static_cast<FwAssertArgType>(portNum)
521 this->m_CmdStatus_OutputPort[portNum].registerSerialPort(port);
527 Fw::InputSerializePort* port
532 static_cast<FwAssertArgType>(portNum)
535 this->m_Log_OutputPort[portNum].registerSerialPort(port);
538 #if FW_ENABLE_TEXT_LOGGING == 1 540 void ActiveLoggerComponentBase ::
541 set_LogText_OutputPort(
543 Fw::InputSerializePort* port
547 portNum < this->getNum_LogText_OutputPorts(),
548 static_cast<FwAssertArgType>(portNum)
551 this->m_LogText_OutputPort[portNum].registerSerialPort(port);
559 Fw::InputSerializePort* port
564 static_cast<FwAssertArgType>(portNum)
567 this->m_Time_OutputPort[portNum].registerSerialPort(port);
572 #if FW_PORT_SERIALIZATION 581 Fw::InputSerializePort* port
586 static_cast<FwAssertArgType>(portNum)
589 this->m_FatalAnnounce_OutputPort[portNum].registerSerialPort(port);
595 Fw::InputSerializePort* port
600 static_cast<FwAssertArgType>(portNum)
603 this->m_PktSend_OutputPort[portNum].registerSerialPort(port);
609 Fw::InputSerializePort* port
614 static_cast<FwAssertArgType>(portNum)
617 this->m_pingOut_OutputPort[portNum].registerSerialPort(port);
629 FW_ASSERT(this->m_CmdReg_OutputPort[0].isConnected());
631 this->m_CmdReg_OutputPort[0].
invoke(
635 this->m_CmdReg_OutputPort[0].
invoke(
639 this->m_CmdReg_OutputPort[0].
invoke(
650 Fw::ActiveComponentBase(compName)
709 #if FW_ENABLE_TEXT_LOGGING == 1 712 getNum_LogText_OutputPorts()
const 756 static_cast<FwAssertArgType>(portNum)
759 return this->m_CmdReg_OutputPort[portNum].
isConnected();
767 static_cast<FwAssertArgType>(portNum)
770 return this->m_CmdStatus_OutputPort[portNum].
isConnected();
778 static_cast<FwAssertArgType>(portNum)
781 return this->m_Log_OutputPort[portNum].
isConnected();
784 #if FW_ENABLE_TEXT_LOGGING == 1 786 bool ActiveLoggerComponentBase ::
787 isConnected_LogText_OutputPort(
FwIndexType portNum)
790 portNum < this->getNum_LogText_OutputPorts(),
791 static_cast<FwAssertArgType>(portNum)
794 return this->m_LogText_OutputPort[portNum].isConnected();
804 static_cast<FwAssertArgType>(portNum)
807 return this->m_Time_OutputPort[portNum].
isConnected();
819 static_cast<FwAssertArgType>(portNum)
822 return this->m_FatalAnnounce_OutputPort[portNum].
isConnected();
830 static_cast<FwAssertArgType>(portNum)
833 return this->m_PktSend_OutputPort[portNum].
isConnected();
841 static_cast<FwAssertArgType>(portNum)
844 return this->m_pingOut_OutputPort[portNum].
isConnected();
865 static_cast<FwAssertArgType>(portNum)
887 static_cast<FwAssertArgType>(portNum)
895 ComponentIpcSerializableBuffer msg;
899 _status = msg.serialize(
900 static_cast<FwEnumStoreType>(PINGIN_PING)
904 static_cast<FwAssertArgType>(_status)
908 _status = msg.serialize(portNum);
911 static_cast<FwAssertArgType>(_status)
915 _status = msg.serialize(key);
918 static_cast<FwAssertArgType>(_status)
927 static_cast<FwAssertArgType>(qStatus)
960 static_cast<FwAssertArgType>(portNum)
964 this->m_FatalAnnounce_OutputPort[portNum].isConnected(),
965 static_cast<FwAssertArgType>(portNum)
967 this->m_FatalAnnounce_OutputPort[portNum].
invoke(
981 static_cast<FwAssertArgType>(portNum)
985 this->m_PktSend_OutputPort[portNum].isConnected(),
986 static_cast<FwAssertArgType>(portNum)
988 this->m_PktSend_OutputPort[portNum].
invoke(
1002 static_cast<FwAssertArgType>(portNum)
1006 this->m_pingOut_OutputPort[portNum].isConnected(),
1007 static_cast<FwAssertArgType>(portNum)
1009 this->m_pingOut_OutputPort[portNum].
invoke(
1026 ComponentIpcSerializableBuffer msg;
1030 _status = msg.serialize(static_cast<FwEnumStoreType>(INT_IF_LOQQUEUE));
1033 static_cast<FwAssertArgType>(_status)
1037 _status = msg.serialize(static_cast<FwIndexType>(0));
1040 static_cast<FwAssertArgType>(_status)
1043 _status = msg.serialize(
id);
1046 static_cast<FwAssertArgType>(_status)
1049 _status = msg.serialize(timeTag);
1052 static_cast<FwAssertArgType>(_status)
1055 _status = msg.serialize(severity);
1058 static_cast<FwAssertArgType>(_status)
1061 _status = msg.serialize(args);
1064 static_cast<FwAssertArgType>(_status)
1071 if (qStatus == Os::Queue::Status::FULL) {
1078 static_cast<FwAssertArgType>(qStatus)
1093 FW_ASSERT(this->m_CmdStatus_OutputPort[0].isConnected());
1094 this->m_CmdStatus_OutputPort[0].
invoke(opCode, cmdSeq, response);
1119 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1120 this->m_CmdStatus_OutputPort[0].
invoke(
1132 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1133 this->m_CmdStatus_OutputPort[0].
invoke(
1142 #if FW_CMD_CHECK_RESIDUAL 1146 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1147 this->m_CmdStatus_OutputPort[0].
invoke(
1176 ComponentIpcSerializableBuffer msg;
1180 _status = msg.serialize(static_cast<FwEnumStoreType>(CMD_SET_ID_FILTER));
1183 static_cast<FwAssertArgType>(_status)
1189 _status = msg.serialize(port);
1192 static_cast<FwAssertArgType>(_status)
1195 _status = msg.serialize(opCode);
1198 static_cast<FwAssertArgType>(_status)
1201 _status = msg.serialize(cmdSeq);
1204 static_cast<FwAssertArgType>(_status)
1207 _status = msg.serialize(args);
1210 static_cast<FwAssertArgType>(_status)
1219 static_cast<FwAssertArgType>(qStatus)
1235 ComponentIpcSerializableBuffer msg;
1239 _status = msg.serialize(static_cast<FwEnumStoreType>(CMD_DUMP_FILTER_STATE));
1242 static_cast<FwAssertArgType>(_status)
1248 _status = msg.serialize(port);
1251 static_cast<FwAssertArgType>(_status)
1254 _status = msg.serialize(opCode);
1257 static_cast<FwAssertArgType>(_status)
1260 _status = msg.serialize(cmdSeq);
1263 static_cast<FwAssertArgType>(_status)
1266 _status = msg.serialize(args);
1269 static_cast<FwAssertArgType>(_status)
1278 static_cast<FwAssertArgType>(qStatus)
1324 if (this->m_Time_OutputPort[0].isConnected()) {
1325 this->m_Time_OutputPort[0].
invoke(_logTime);
1333 if (this->m_Log_OutputPort[0].isConnected()) {
1337 #if FW_AMPCS_COMPATIBLE 1339 _status = _logBuff.
serialize(static_cast<U8>(2));
1342 static_cast<FwAssertArgType>(_status)
1346 #if FW_AMPCS_COMPATIBLE 1353 static_cast<FwAssertArgType>(_status)
1359 static_cast<FwAssertArgType>(_status)
1362 #if FW_AMPCS_COMPATIBLE 1365 static_cast<U8>(
sizeof(
U8))
1369 static_cast<FwAssertArgType>(_status)
1375 static_cast<FwAssertArgType>(_status)
1378 this->m_Log_OutputPort[0].
invoke(
1387 #if FW_ENABLE_TEXT_LOGGING 1388 if (this->m_LogText_OutputPort[0].isConnected()) {
1389 #if FW_OBJECT_NAMES == 1 1390 const char* _formatString =
1391 "(%s) %s: %s filter state. %d";
1393 const char* _formatString =
1394 "%s: %s filter state. %d";
1398 severity.toString(severityStr);
1404 this->m_objName.toChar(),
1406 "SEVERITY_FILTER_STATE ",
1411 this->m_LogText_OutputPort[0].invoke(
1426 if (this->m_Time_OutputPort[0].isConnected()) {
1427 this->m_Time_OutputPort[0].
invoke(_logTime);
1435 if (this->m_Log_OutputPort[0].isConnected()) {
1439 #if FW_AMPCS_COMPATIBLE 1441 _status = _logBuff.
serialize(static_cast<U8>(1));
1444 static_cast<FwAssertArgType>(_status)
1448 #if FW_AMPCS_COMPATIBLE 1451 static_cast<U8>(
sizeof(U32))
1455 static_cast<FwAssertArgType>(_status)
1461 static_cast<FwAssertArgType>(_status)
1464 this->m_Log_OutputPort[0].
invoke(
1473 #if FW_ENABLE_TEXT_LOGGING 1474 if (this->m_LogText_OutputPort[0].isConnected()) {
1475 #if FW_OBJECT_NAMES == 1 1476 const char* _formatString =
1477 "(%s) %s: ID %" PRIu32
" is filtered.";
1479 const char* _formatString =
1480 "%s: ID %" PRIu32
" is filtered.";
1487 this->m_objName.toChar(),
1489 "ID_FILTER_ENABLED ",
1493 this->m_LogText_OutputPort[0].invoke(
1508 if (this->m_Time_OutputPort[0].isConnected()) {
1509 this->m_Time_OutputPort[0].
invoke(_logTime);
1517 if (this->m_Log_OutputPort[0].isConnected()) {
1521 #if FW_AMPCS_COMPATIBLE 1523 _status = _logBuff.
serialize(static_cast<U8>(1));
1526 static_cast<FwAssertArgType>(_status)
1530 #if FW_AMPCS_COMPATIBLE 1533 static_cast<U8>(
sizeof(U32))
1537 static_cast<FwAssertArgType>(_status)
1543 static_cast<FwAssertArgType>(_status)
1546 this->m_Log_OutputPort[0].
invoke(
1555 #if FW_ENABLE_TEXT_LOGGING 1556 if (this->m_LogText_OutputPort[0].isConnected()) {
1557 #if FW_OBJECT_NAMES == 1 1558 const char* _formatString =
1559 "(%s) %s: ID filter list is full. Cannot filter %" PRIu32
" .";
1561 const char* _formatString =
1562 "%s: ID filter list is full. Cannot filter %" PRIu32
" .";
1569 this->m_objName.toChar(),
1571 "ID_FILTER_LIST_FULL ",
1575 this->m_LogText_OutputPort[0].invoke(
1590 if (this->m_Time_OutputPort[0].isConnected()) {
1591 this->m_Time_OutputPort[0].
invoke(_logTime);
1599 if (this->m_Log_OutputPort[0].isConnected()) {
1603 #if FW_AMPCS_COMPATIBLE 1605 _status = _logBuff.
serialize(static_cast<U8>(1));
1608 static_cast<FwAssertArgType>(_status)
1612 #if FW_AMPCS_COMPATIBLE 1615 static_cast<U8>(
sizeof(U32))
1619 static_cast<FwAssertArgType>(_status)
1625 static_cast<FwAssertArgType>(_status)
1628 this->m_Log_OutputPort[0].
invoke(
1637 #if FW_ENABLE_TEXT_LOGGING 1638 if (this->m_LogText_OutputPort[0].isConnected()) {
1639 #if FW_OBJECT_NAMES == 1 1640 const char* _formatString =
1641 "(%s) %s: ID filter ID %" PRIu32
" removed.";
1643 const char* _formatString =
1644 "%s: ID filter ID %" PRIu32
" removed.";
1651 this->m_objName.toChar(),
1653 "ID_FILTER_REMOVED ",
1657 this->m_LogText_OutputPort[0].invoke(
1672 if (this->m_Time_OutputPort[0].isConnected()) {
1673 this->m_Time_OutputPort[0].
invoke(_logTime);
1681 if (this->m_Log_OutputPort[0].isConnected()) {
1685 #if FW_AMPCS_COMPATIBLE 1687 _status = _logBuff.
serialize(static_cast<U8>(1));
1690 static_cast<FwAssertArgType>(_status)
1694 #if FW_AMPCS_COMPATIBLE 1697 static_cast<U8>(
sizeof(U32))
1701 static_cast<FwAssertArgType>(_status)
1707 static_cast<FwAssertArgType>(_status)
1710 this->m_Log_OutputPort[0].
invoke(
1719 #if FW_ENABLE_TEXT_LOGGING 1720 if (this->m_LogText_OutputPort[0].isConnected()) {
1721 #if FW_OBJECT_NAMES == 1 1722 const char* _formatString =
1723 "(%s) %s: ID filter ID %" PRIu32
" not found.";
1725 const char* _formatString =
1726 "%s: ID filter ID %" PRIu32
" not found.";
1733 this->m_objName.toChar(),
1735 "ID_FILTER_NOT_FOUND ",
1739 this->m_LogText_OutputPort[0].invoke(
1756 if (this->m_Time_OutputPort[0].isConnected()) {
1758 this->m_Time_OutputPort[0].
invoke(_time);
1773 ComponentIpcSerializableBuffer _msg;
1783 static_cast<FwAssertArgType>(_msgStatus)
1793 static_cast<FwAssertArgType>(_deserStatus)
1796 MsgTypeEnum _msgType =
static_cast<MsgTypeEnum
>(_desMsg);
1798 if (_msgType == ACTIVELOGGER_COMPONENT_EXIT) {
1803 _deserStatus = _msg.deserialize(portNum);
1806 static_cast<FwAssertArgType>(_deserStatus)
1814 _deserStatus = _msg.deserialize(key);
1817 static_cast<FwAssertArgType>(_deserStatus)
1829 case CMD_SET_ID_FILTER: {
1832 _deserStatus = _msg.deserialize(_opCode);
1835 static_cast<FwAssertArgType>(_deserStatus)
1840 _deserStatus = _msg.deserialize(_cmdSeq);
1843 static_cast<FwAssertArgType>(_deserStatus)
1848 _deserStatus = _msg.deserialize(args);
1851 static_cast<FwAssertArgType>(_deserStatus)
1861 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1876 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1889 #if FW_CMD_CHECK_RESIDUAL 1891 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1910 case CMD_DUMP_FILTER_STATE: {
1913 _deserStatus = _msg.deserialize(_opCode);
1916 static_cast<FwAssertArgType>(_deserStatus)
1921 _deserStatus = _msg.deserialize(_cmdSeq);
1924 static_cast<FwAssertArgType>(_deserStatus)
1929 _deserStatus = _msg.deserialize(args);
1932 static_cast<FwAssertArgType>(_deserStatus)
1940 #if FW_CMD_CHECK_RESIDUAL 1942 if (this->m_CmdStatus_OutputPort[0].isConnected()) {
1957 case INT_IF_LOQQUEUE: {
1959 _deserStatus = _msg.deserialize(
id);
1964 static_cast<FwAssertArgType>(_deserStatus)
1968 _deserStatus = _msg.deserialize(timeTag);
1973 static_cast<FwAssertArgType>(_deserStatus)
1977 _deserStatus = _msg.deserialize(severity);
1982 static_cast<FwAssertArgType>(_deserStatus)
1986 _deserStatus = _msg.deserialize(args);
1991 static_cast<FwAssertArgType>(_deserStatus)
1997 _msg.getBuffLeft() == 0,
2023 void ActiveLoggerComponentBase ::
2035 const U32 idBase = callComp->
getIdBase();
2036 FW_ASSERT(opCode >= idBase, static_cast<FwAssertArgType>(opCode), static_cast<FwAssertArgType>(idBase));
2039 switch (opCode - idBase) {
2041 compPtr->SET_EVENT_FILTER_cmdHandlerBase(
2050 compPtr->SET_ID_FILTER_cmdHandlerBase(
2059 compPtr->DUMP_FILTER_STATE_cmdHandlerBase(
2073 void ActiveLoggerComponentBase ::
2085 compPtr->LogRecv_handlerBase(
2094 void ActiveLoggerComponentBase ::
2103 compPtr->pingIn_handlerBase(
Serialization/Deserialization operation was successful.
void addCallPort(InputTimePort *callPort)
Register an input port.
PlatformAssertArgType FwAssertArgType
void invoke(Fw::ComBuffer &data, U32 context) const
Invoke a port interface.
void init()
Initialization function.
void set_CmdReg_OutputPort(FwIndexType portNum, Fw::InputCmdRegPort *port)
Connect port to CmdReg[portNum].
void LogRecv_handlerBase(FwIndexType portNum, FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args)
Handler base-class function for input port LogRecv.
Status
status returned from the queue send function
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
const char * toChar() const
void FatalAnnounce_out(FwIndexType portNum, FwEventIdType Id)
Invoke output port FatalAnnounce.
virtual ~ActiveLoggerComponentBase()
Destroy ActiveLoggerComponentBase object.
PlatformSizeType FwSizeType
void invoke(U32 key) const
Invoke a port interface.
void set_CmdStatus_OutputPort(FwIndexType portNum, Fw::InputCmdResponsePort *port)
Connect port to CmdStatus[portNum].
void set_PktSend_OutputPort(FwIndexType portNum, Fw::InputComPort *port)
Connect port to PktSend[portNum].
void SET_EVENT_FILTER_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
FwIndexType getNum_Log_OutputPorts() const
void cmdResponse_out(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdResponse response)
Emit command response.
void DUMP_FILTER_STATE_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void loqQueue_internalInterfaceInvoke(FwEventIdType id, const Fw::Time &timeTag, const Fw::LogSeverity &severity, const Fw::LogBuffer &args)
Internal interface base-class function for loqQueue.
The size of the serial representation.
FwIndexType getNum_FatalAnnounce_OutputPorts() const
Removed an ID from the filter.
Enum representing a command response.
void invoke(FwEventIdType Id) const
Invoke a port interface.
bool isConnected_pingOut_OutputPort(FwIndexType portNum)
void addCallPort(InputCmdRegPort *callPort)
Register an input port.
FwIndexType getNum_PktSend_OutputPorts() const
bool isConnected_Log_OutputPort(FwIndexType portNum)
PlatformIndexType FwIndexType
Os::Queue m_queue
queue object for active component
void PktSend_out(FwIndexType portNum, Fw::ComBuffer &data, U32 context)
Invoke output port PktSend.
void pingOut_out(FwIndexType portNum, U32 key)
Invoke output port pingOut.
void init()
Object initializer.
virtual void pingIn_handler(FwIndexType portNum, U32 key)=0
Handler for input port pingIn.
SerializeStatus
forward declaration for string
void log_WARNING_LO_ID_FILTER_LIST_FULL(U32 ID) const
virtual void pingIn_preMsgHook(FwIndexType portNum, U32 key)
Pre-message hook for async input port pingIn.
Message will block until space is available.
void set_Time_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to Time[portNum].
void invoke(FwOpcodeType opCode) const
Invoke a port interface.
void addCallPort(InputFatalEventPort *callPort)
Register an input port.
Dump the filter states via events.
Serializable::SizeType getBuffLeft() const
returns how much deserialization buffer is left
void init()
Initialization function.
FwIndexType getNum_CmdReg_OutputPorts() const
message to exit active component task
Less important informational events.
Os::Queue::Status createQueue(FwSizeType depth, FwSizeType msgSize)
A less serious but recoverable event.
void init()
Initialization function.
Svc::InputPingPort * get_pingIn_InputPort(FwIndexType portNum)
ActiveLoggerComponentBase(const char *compName="")
Construct ActiveLoggerComponentBase object.
bool isConnected_CmdReg_OutputPort(FwIndexType portNum)
void invoke(Fw::Time &time) const
Invoke a port interface.
virtual void loqQueue_internalInterfaceHandler(FwEventIdType id, const Fw::Time &timeTag, const Fw::LogSeverity &severity, const Fw::LogBuffer &args)=0
Internal interface handler for loqQueue.
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.
virtual void SET_EVENT_FILTER_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, Svc::ActiveLogger_FilterSeverity filterLevel, Svc::ActiveLogger_Enabled filterEnabled)=0
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_ACTIVITY_LO_SEVERITY_FILTER_STATE(Svc::ActiveLogger_FilterSeverity severity, bool enabled) const
FwIndexType getNum_CmdDisp_InputPorts() const
void resetDeser()
reset deserialization to beginning
Errors dispatching messages.
Fw::InputCmdPort * get_CmdDisp_InputPort(FwIndexType portNum)
void set_FatalAnnounce_OutputPort(FwIndexType portNum, Svc::InputFatalEventPort *port)
Connect port to FatalAnnounce[portNum].
Enum representing event severity.
virtual void LogRecv_handler(FwIndexType portNum, FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args)=0
Handler for input port LogRecv.
FwIndexType getNum_CmdStatus_OutputPorts() const
FormatStatus format(const CHAR *formatString,...)
write formatted string to buffer
void init()
Initialization function.
FwIndexType getNum_pingOut_OutputPorts() const
Fw::InputLogPort * get_LogRecv_InputPort(FwIndexType portNum)
uint8_t U8
8-bit unsigned integer
The size of the serial representation.
FwIndexType getNum_pingIn_InputPorts() const
Command failed to deserialize.
virtual void DUMP_FILTER_STATE_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command DUMP_FILTER_STATE.
Important informational events.
virtual void SET_ID_FILTER_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, U32 ID, Svc::ActiveLogger_Enabled idFilterEnabled)=0
void invoke(FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args) const
Invoke a port interface.
void set_Log_OutputPort(FwIndexType portNum, Fw::InputLogPort *port)
Connect port to Log[portNum].
PlatformQueuePriorityType FwQueuePriorityType
void pingIn_handlerBase(FwIndexType portNum, U32 key)
Handler base-class function for input port pingIn.
A message was sent requesting an exit of the loop.
Dump severity filter state.
void SET_ID_FILTER_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
SerializeStatus deserialize(U8 &val)
deserialize 8-bit unsigned int
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
void addCallPort(InputLogPort *callPort)
Register an input port.
void init()
Initialization function.
void set_pingOut_OutputPort(FwIndexType portNum, Svc::InputPingPort *port)
Connect port to pingOut[portNum].
void incNumMsgDropped()
increment the number of messages dropped
bool isConnected_CmdStatus_OutputPort(FwIndexType portNum)
FwIndexType getNum_LogRecv_InputPorts() const
message sent/received okay
bool isConnected_Time_OutputPort(FwIndexType portNum)
void addCallPort(InputComPort *callPort)
Register an input port.
FwIndexType getNum_Time_OutputPorts() const
Enabled and disabled state.
Attempted to add ID to full ID filter ID.
Message will return with status when space is unavailable.
virtual void SET_ID_FILTER_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command SET_ID_FILTER.
void init()
Initialization function.
Status receive(U8 *destination, FwSizeType capacity, BlockingType blockType, FwSizeType &actualSize, FwQueuePriorityType &priority) override
receive a message from the queue through delegate
void regCommands()
Register commands with the Command Dispatcher.
bool isConnected_FatalAnnounce_OutputPort(FwIndexType portNum)
Set filter for reporting events. Events are not stored in component.
void init()
Initialization function.
void log_WARNING_LO_ID_FILTER_NOT_FOUND(U32 ID) const
bool isConnected_PktSend_OutputPort(FwIndexType portNum)
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects) ...
virtual void DUMP_FILTER_STATE_cmdHandler(FwOpcodeType opCode, U32 cmdSeq)=0
void log_ACTIVITY_HI_ID_FILTER_REMOVED(U32 ID) const
void log_ACTIVITY_HI_ID_FILTER_ENABLED(U32 ID) const
void addCallPort(InputCmdResponsePort *callPort)
Register an input port.