10#if FW_ENABLE_TEXT_LOGGING
19 BUFFERSENDIN_BUFFERSEND,
32 class ComponentIpcSerializableBuffer :
42 MAX_DATA_SIZE =
sizeof(BuffUnion),
44 SERIALIZATION_SIZE = DATA_OFFSET + MAX_DATA_SIZE
48 return sizeof(m_buff);
55 const U8* getBuffAddr()
const {
61 U8 m_buff[SERIALIZATION_SIZE];
70 void FileUplinkComponentBase ::
82 port < static_cast<FwIndexType>(this->getNum_bufferSendIn_InputPorts());
85 this->m_bufferSendIn_InputPort[port].init();
86 this->m_bufferSendIn_InputPort[port].addCallComp(
90 this->m_bufferSendIn_InputPort[port].setPortNum(port);
92#if FW_OBJECT_NAMES == 1
96 this->m_objName.toChar(),
99 this->m_bufferSendIn_InputPort[port].setObjName(portName.
toChar());
106 port < static_cast<FwIndexType>(this->getNum_pingIn_InputPorts());
109 this->m_pingIn_InputPort[port].init();
110 this->m_pingIn_InputPort[port].addCallComp(
114 this->m_pingIn_InputPort[port].setPortNum(port);
116#if FW_OBJECT_NAMES == 1
120 this->m_objName.toChar(),
123 this->m_pingIn_InputPort[port].setObjName(portName.
toChar());
127#if FW_ENABLE_TEXT_LOGGING == 1
131 port < static_cast<FwIndexType>(this->getNum_LogText_OutputPorts());
134 this->m_LogText_OutputPort[port].init();
136#if FW_OBJECT_NAMES == 1
140 this->m_objName.toChar(),
143 this->m_LogText_OutputPort[port].setObjName(portName.
toChar());
151 port < static_cast<FwIndexType>(this->getNum_eventOut_OutputPorts());
154 this->m_eventOut_OutputPort[port].init();
156#if FW_OBJECT_NAMES == 1
160 this->m_objName.toChar(),
163 this->m_eventOut_OutputPort[port].setObjName(portName.
toChar());
170 port < static_cast<FwIndexType>(this->getNum_timeCaller_OutputPorts());
173 this->m_timeCaller_OutputPort[port].init();
175#if FW_OBJECT_NAMES == 1
179 this->m_objName.toChar(),
182 this->m_timeCaller_OutputPort[port].setObjName(portName.
toChar());
189 port < static_cast<FwIndexType>(this->getNum_tlmOut_OutputPorts());
192 this->m_tlmOut_OutputPort[port].init();
194#if FW_OBJECT_NAMES == 1
198 this->m_objName.toChar(),
201 this->m_tlmOut_OutputPort[port].setObjName(portName.
toChar());
208 port < static_cast<FwIndexType>(this->getNum_bufferSendOut_OutputPorts());
211 this->m_bufferSendOut_OutputPort[port].init();
213#if FW_OBJECT_NAMES == 1
217 this->m_objName.toChar(),
220 this->m_bufferSendOut_OutputPort[port].setObjName(portName.
toChar());
227 port < static_cast<FwIndexType>(this->getNum_pingOut_OutputPorts());
230 this->m_pingOut_OutputPort[port].init();
232#if FW_OBJECT_NAMES == 1
236 this->m_objName.toChar(),
239 this->m_pingOut_OutputPort[port].setObjName(portName.
toChar());
246 static_cast<FwSizeType>(ComponentIpcSerializableBuffer::SERIALIZATION_SIZE)
262 portNum < this->getNum_bufferSendIn_InputPorts(),
266 return &this->m_bufferSendIn_InputPort[portNum];
273 portNum < this->getNum_pingIn_InputPorts(),
277 return &this->m_pingIn_InputPort[portNum];
284#if FW_ENABLE_TEXT_LOGGING == 1
286 void FileUplinkComponentBase ::
287 set_LogText_OutputPort(
293 portNum < this->getNum_LogText_OutputPorts(),
297 this->m_LogText_OutputPort[portNum].addCallPort(port);
302 void FileUplinkComponentBase ::
303 set_eventOut_OutputPort(
309 portNum < this->getNum_eventOut_OutputPorts(),
313 this->m_eventOut_OutputPort[portNum].addCallPort(port);
316 void FileUplinkComponentBase ::
317 set_timeCaller_OutputPort(
323 portNum < this->getNum_timeCaller_OutputPorts(),
327 this->m_timeCaller_OutputPort[portNum].addCallPort(port);
330 void FileUplinkComponentBase ::
331 set_tlmOut_OutputPort(
337 portNum < this->getNum_tlmOut_OutputPorts(),
341 this->m_tlmOut_OutputPort[portNum].addCallPort(port);
348 void FileUplinkComponentBase ::
349 set_bufferSendOut_OutputPort(
355 portNum < this->getNum_bufferSendOut_OutputPorts(),
359 this->m_bufferSendOut_OutputPort[portNum].addCallPort(port);
362 void FileUplinkComponentBase ::
363 set_pingOut_OutputPort(
369 portNum < this->getNum_pingOut_OutputPorts(),
373 this->m_pingOut_OutputPort[portNum].addCallPort(port);
376#if FW_PORT_SERIALIZATION
382#if FW_ENABLE_TEXT_LOGGING == 1
384 void FileUplinkComponentBase ::
385 set_LogText_OutputPort(
387 Fw::InputSerializePort* port
391 portNum < this->getNum_LogText_OutputPorts(),
395 this->m_LogText_OutputPort[portNum].registerSerialPort(port);
400 void FileUplinkComponentBase ::
401 set_eventOut_OutputPort(
403 Fw::InputSerializePort* port
407 portNum < this->getNum_eventOut_OutputPorts(),
411 this->m_eventOut_OutputPort[portNum].registerSerialPort(port);
414 void FileUplinkComponentBase ::
415 set_timeCaller_OutputPort(
417 Fw::InputSerializePort* port
421 portNum < this->getNum_timeCaller_OutputPorts(),
425 this->m_timeCaller_OutputPort[portNum].registerSerialPort(port);
428 void FileUplinkComponentBase ::
429 set_tlmOut_OutputPort(
431 Fw::InputSerializePort* port
435 portNum < this->getNum_tlmOut_OutputPorts(),
439 this->m_tlmOut_OutputPort[portNum].registerSerialPort(port);
444#if FW_PORT_SERIALIZATION
450 void FileUplinkComponentBase ::
451 set_bufferSendOut_OutputPort(
453 Fw::InputSerializePort* port
457 portNum < this->getNum_bufferSendOut_OutputPorts(),
461 this->m_bufferSendOut_OutputPort[portNum].registerSerialPort(port);
464 void FileUplinkComponentBase ::
465 set_pingOut_OutputPort(
467 Fw::InputSerializePort* port
471 portNum < this->getNum_pingOut_OutputPorts(),
475 this->m_pingOut_OutputPort[portNum].registerSerialPort(port);
484 FileUplinkComponentBase ::
485 FileUplinkComponentBase(
const char* compName) :
486 Fw::ActiveComponentBase(compName)
488 this->m_FileWriteErrorThrottle = 0;
489 this->m_InvalidReceiveModeThrottle = 0;
490 this->m_PacketOutOfBoundsThrottle = 0;
491 this->m_PacketOutOfOrderThrottle = 0;
492 this->m_PacketDuplicateThrottle = 0;
495 FileUplinkComponentBase ::
496 ~FileUplinkComponentBase()
506 getNum_bufferSendIn_InputPorts()
const
512 getNum_pingIn_InputPorts()
const
521#if FW_ENABLE_TEXT_LOGGING == 1
524 getNum_LogText_OutputPorts()
const
532 getNum_eventOut_OutputPorts()
const
538 getNum_timeCaller_OutputPorts()
const
544 getNum_tlmOut_OutputPorts()
const
554 getNum_bufferSendOut_OutputPorts()
const
560 getNum_pingOut_OutputPorts()
const
569#if FW_ENABLE_TEXT_LOGGING == 1
571 bool FileUplinkComponentBase ::
572 isConnected_LogText_OutputPort(
FwIndexType portNum)
575 portNum < this->getNum_LogText_OutputPorts(),
579 return this->m_LogText_OutputPort[portNum].isConnected();
584 bool FileUplinkComponentBase ::
585 isConnected_eventOut_OutputPort(
FwIndexType portNum)
588 portNum < this->getNum_eventOut_OutputPorts(),
592 return this->m_eventOut_OutputPort[portNum].isConnected();
595 bool FileUplinkComponentBase ::
596 isConnected_timeCaller_OutputPort(
FwIndexType portNum)
599 portNum < this->getNum_timeCaller_OutputPorts(),
603 return this->m_timeCaller_OutputPort[portNum].isConnected();
606 bool FileUplinkComponentBase ::
610 portNum < this->getNum_tlmOut_OutputPorts(),
614 return this->m_tlmOut_OutputPort[portNum].isConnected();
621 bool FileUplinkComponentBase ::
622 isConnected_bufferSendOut_OutputPort(
FwIndexType portNum)
625 portNum < this->getNum_bufferSendOut_OutputPorts(),
629 return this->m_bufferSendOut_OutputPort[portNum].isConnected();
632 bool FileUplinkComponentBase ::
633 isConnected_pingOut_OutputPort(
FwIndexType portNum)
636 portNum < this->getNum_pingOut_OutputPorts(),
640 return this->m_pingOut_OutputPort[portNum].isConnected();
649 void FileUplinkComponentBase ::
650 bufferSendIn_handlerBase(
657 portNum < this->getNum_bufferSendIn_InputPorts(),
662 bufferSendIn_preMsgHook(
666 ComponentIpcSerializableBuffer msg;
670 _status = msg.serialize(
679 _status = msg.serialize(portNum);
686 _status = msg.serialize(fwBuffer);
702 void FileUplinkComponentBase ::
710 portNum < this->getNum_pingIn_InputPorts(),
719 ComponentIpcSerializableBuffer msg;
723 _status = msg.serialize(
732 _status = msg.serialize(portNum);
739 _status = msg.serialize(key);
763 void FileUplinkComponentBase ::
764 bufferSendIn_preMsgHook(
772 void FileUplinkComponentBase ::
785 void FileUplinkComponentBase ::
792 portNum < this->getNum_bufferSendOut_OutputPorts(),
795 this->m_bufferSendOut_OutputPort[portNum].invoke(
800 void FileUplinkComponentBase ::
807 portNum < this->getNum_pingOut_OutputPorts(),
810 this->m_pingOut_OutputPort[portNum].invoke(
819 void FileUplinkComponentBase ::
820 log_WARNING_HI_BadChecksum(
828 if (this->m_timeCaller_OutputPort[0].isConnected()) {
829 this->m_timeCaller_OutputPort[0].invoke(_logTime);
834 _id = this->getIdBase() + EVENTID_BADCHECKSUM;
837 if (this->m_eventOut_OutputPort[0].isConnected()) {
841#if FW_AMPCS_COMPATIBLE
856#if FW_AMPCS_COMPATIBLE
859 static_cast<U8>(
sizeof(U32))
872#if FW_AMPCS_COMPATIBLE
875 static_cast<U8>(
sizeof(U32))
888 this->m_eventOut_OutputPort[0].invoke(
897#if FW_ENABLE_TEXT_LOGGING
898 if (this->m_LogText_OutputPort[0].isConnected()) {
899#if FW_OBJECT_NAMES == 1
900 const char* _formatString =
901 "(%s) %s: Bad checksum value during receipt of file %s: computed 0x%" PRIx32
", read 0x%" PRIx32
"";
903 const char* _formatString =
904 "%s: Bad checksum value during receipt of file %s: computed 0x%" PRIx32
", read 0x%" PRIx32
"";
911 this->m_objName.toChar(),
919 this->m_LogText_OutputPort[0].invoke(
929 void FileUplinkComponentBase ::
930 log_WARNING_HI_FileOpenError(
const Fw::StringBase& fileName)
const
934 if (this->m_timeCaller_OutputPort[0].isConnected()) {
935 this->m_timeCaller_OutputPort[0].invoke(_logTime);
940 _id = this->getIdBase() + EVENTID_FILEOPENERROR;
943 if (this->m_eventOut_OutputPort[0].isConnected()) {
947#if FW_AMPCS_COMPATIBLE
962 this->m_eventOut_OutputPort[0].invoke(
971#if FW_ENABLE_TEXT_LOGGING
972 if (this->m_LogText_OutputPort[0].isConnected()) {
973#if FW_OBJECT_NAMES == 1
974 const char* _formatString =
975 "(%s) %s: Could not open file %s";
977 const char* _formatString =
978 "%s: Could not open file %s";
985 this->m_objName.toChar(),
991 this->m_LogText_OutputPort[0].invoke(
1001 void FileUplinkComponentBase ::
1002 log_ACTIVITY_HI_FileReceived(
const Fw::StringBase& fileName)
const
1006 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1007 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1012 _id = this->getIdBase() + EVENTID_FILERECEIVED;
1015 if (this->m_eventOut_OutputPort[0].isConnected()) {
1019#if FW_AMPCS_COMPATIBLE
1034 this->m_eventOut_OutputPort[0].invoke(
1043#if FW_ENABLE_TEXT_LOGGING
1044 if (this->m_LogText_OutputPort[0].isConnected()) {
1045#if FW_OBJECT_NAMES == 1
1046 const char* _formatString =
1047 "(%s) %s: Received file %s";
1049 const char* _formatString =
1050 "%s: Received file %s";
1057 this->m_objName.toChar(),
1063 this->m_LogText_OutputPort[0].invoke(
1073 void FileUplinkComponentBase ::
1077 if (this->m_FileWriteErrorThrottle >= EVENTID_FILEWRITEERROR_THROTTLE) {
1081 this->m_FileWriteErrorThrottle++;
1086 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1087 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1092 _id = this->getIdBase() + EVENTID_FILEWRITEERROR;
1095 if (this->m_eventOut_OutputPort[0].isConnected()) {
1099#if FW_AMPCS_COMPATIBLE
1114 this->m_eventOut_OutputPort[0].invoke(
1123#if FW_ENABLE_TEXT_LOGGING
1124 if (this->m_LogText_OutputPort[0].isConnected()) {
1125#if FW_OBJECT_NAMES == 1
1126 const char* _formatString =
1127 "(%s) %s: Could not write to file %s";
1129 const char* _formatString =
1130 "%s: Could not write to file %s";
1137 this->m_objName.toChar(),
1143 this->m_LogText_OutputPort[0].invoke(
1153 void FileUplinkComponentBase ::
1154 log_WARNING_HI_InvalidReceiveMode(
1160 if (this->m_InvalidReceiveModeThrottle >= EVENTID_INVALIDRECEIVEMODE_THROTTLE) {
1164 this->m_InvalidReceiveModeThrottle++;
1169 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1170 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1175 _id = this->getIdBase() + EVENTID_INVALIDRECEIVEMODE;
1178 if (this->m_eventOut_OutputPort[0].isConnected()) {
1182#if FW_AMPCS_COMPATIBLE
1191#if FW_AMPCS_COMPATIBLE
1194 static_cast<U8>(
sizeof(U32))
1201 _status = _logBuff.
serialize(packetType);
1207#if FW_AMPCS_COMPATIBLE
1210 static_cast<U8>(
sizeof(U32))
1223 this->m_eventOut_OutputPort[0].invoke(
1232#if FW_ENABLE_TEXT_LOGGING
1233 if (this->m_LogText_OutputPort[0].isConnected()) {
1234#if FW_OBJECT_NAMES == 1
1235 const char* _formatString =
1236 "(%s) %s: Packet type %" PRIu32
" received in mode %" PRIu32
"";
1238 const char* _formatString =
1239 "%s: Packet type %" PRIu32
" received in mode %" PRIu32
"";
1246 this->m_objName.toChar(),
1248 "InvalidReceiveMode ",
1253 this->m_LogText_OutputPort[0].invoke(
1263 void FileUplinkComponentBase ::
1264 log_WARNING_HI_PacketOutOfBounds(
1270 if (this->m_PacketOutOfBoundsThrottle >= EVENTID_PACKETOUTOFBOUNDS_THROTTLE) {
1274 this->m_PacketOutOfBoundsThrottle++;
1279 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1280 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1285 _id = this->getIdBase() + EVENTID_PACKETOUTOFBOUNDS;
1288 if (this->m_eventOut_OutputPort[0].isConnected()) {
1292#if FW_AMPCS_COMPATIBLE
1301#if FW_AMPCS_COMPATIBLE
1304 static_cast<U8>(
sizeof(U32))
1311 _status = _logBuff.
serialize(packetIndex);
1323 this->m_eventOut_OutputPort[0].invoke(
1332#if FW_ENABLE_TEXT_LOGGING
1333 if (this->m_LogText_OutputPort[0].isConnected()) {
1334#if FW_OBJECT_NAMES == 1
1335 const char* _formatString =
1336 "(%s) %s: Packet %" PRIu32
" out of bounds for file %s";
1338 const char* _formatString =
1339 "%s: Packet %" PRIu32
" out of bounds for file %s";
1346 this->m_objName.toChar(),
1348 "PacketOutOfBounds ",
1353 this->m_LogText_OutputPort[0].invoke(
1363 void FileUplinkComponentBase ::
1364 log_WARNING_HI_PacketOutOfOrder(
1370 if (this->m_PacketOutOfOrderThrottle >= EVENTID_PACKETOUTOFORDER_THROTTLE) {
1374 this->m_PacketOutOfOrderThrottle++;
1379 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1380 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1385 _id = this->getIdBase() + EVENTID_PACKETOUTOFORDER;
1388 if (this->m_eventOut_OutputPort[0].isConnected()) {
1392#if FW_AMPCS_COMPATIBLE
1401#if FW_AMPCS_COMPATIBLE
1404 static_cast<U8>(
sizeof(U32))
1411 _status = _logBuff.
serialize(packetIndex);
1417#if FW_AMPCS_COMPATIBLE
1420 static_cast<U8>(
sizeof(U32))
1427 _status = _logBuff.
serialize(lastPacketIndex);
1433 this->m_eventOut_OutputPort[0].invoke(
1442#if FW_ENABLE_TEXT_LOGGING
1443 if (this->m_LogText_OutputPort[0].isConnected()) {
1444#if FW_OBJECT_NAMES == 1
1445 const char* _formatString =
1446 "(%s) %s: Received packet %" PRIu32
" after packet %" PRIu32
"";
1448 const char* _formatString =
1449 "%s: Received packet %" PRIu32
" after packet %" PRIu32
"";
1456 this->m_objName.toChar(),
1458 "PacketOutOfOrder ",
1463 this->m_LogText_OutputPort[0].invoke(
1473 void FileUplinkComponentBase ::
1474 log_WARNING_HI_PacketDuplicate(U32 packetIndex)
1477 if (this->m_PacketDuplicateThrottle >= EVENTID_PACKETDUPLICATE_THROTTLE) {
1481 this->m_PacketDuplicateThrottle++;
1486 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1487 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1492 _id = this->getIdBase() + EVENTID_PACKETDUPLICATE;
1495 if (this->m_eventOut_OutputPort[0].isConnected()) {
1499#if FW_AMPCS_COMPATIBLE
1508#if FW_AMPCS_COMPATIBLE
1511 static_cast<U8>(
sizeof(U32))
1518 _status = _logBuff.
serialize(packetIndex);
1524 this->m_eventOut_OutputPort[0].invoke(
1533#if FW_ENABLE_TEXT_LOGGING
1534 if (this->m_LogText_OutputPort[0].isConnected()) {
1535#if FW_OBJECT_NAMES == 1
1536 const char* _formatString =
1537 "(%s) %s: Received a duplicate of packet %" PRIu32
"";
1539 const char* _formatString =
1540 "%s: Received a duplicate of packet %" PRIu32
"";
1547 this->m_objName.toChar(),
1553 this->m_LogText_OutputPort[0].invoke(
1563 void FileUplinkComponentBase ::
1564 log_ACTIVITY_HI_UplinkCanceled()
const
1568 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1569 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1574 _id = this->getIdBase() + EVENTID_UPLINKCANCELED;
1577 if (this->m_eventOut_OutputPort[0].isConnected()) {
1580#if FW_AMPCS_COMPATIBLE
1590 this->m_eventOut_OutputPort[0].invoke(
1599#if FW_ENABLE_TEXT_LOGGING
1600 if (this->m_LogText_OutputPort[0].isConnected()) {
1601#if FW_OBJECT_NAMES == 1
1602 const char* _formatString =
1603 "(%s) %s: Received CANCEL packet";
1605 const char* _formatString =
1606 "%s: Received CANCEL packet";
1613 this->m_objName.toChar(),
1618 this->m_LogText_OutputPort[0].invoke(
1628 void FileUplinkComponentBase ::
1629 log_WARNING_HI_DecodeError(I32 status)
const
1633 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1634 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1639 _id = this->getIdBase() + EVENTID_DECODEERROR;
1642 if (this->m_eventOut_OutputPort[0].isConnected()) {
1646#if FW_AMPCS_COMPATIBLE
1655#if FW_AMPCS_COMPATIBLE
1658 static_cast<U8>(
sizeof(I32))
1671 this->m_eventOut_OutputPort[0].invoke(
1680#if FW_ENABLE_TEXT_LOGGING
1681 if (this->m_LogText_OutputPort[0].isConnected()) {
1682#if FW_OBJECT_NAMES == 1
1683 const char* _formatString =
1684 "(%s) %s: Unable to decode file packet. Status: %" PRIi32
"";
1686 const char* _formatString =
1687 "%s: Unable to decode file packet. Status: %" PRIi32
"";
1694 this->m_objName.toChar(),
1700 this->m_LogText_OutputPort[0].invoke(
1714 void FileUplinkComponentBase ::
1715 log_WARNING_HI_FileWriteError_ThrottleClear()
1718 this->m_FileWriteErrorThrottle = 0;
1721 void FileUplinkComponentBase ::
1722 log_WARNING_HI_InvalidReceiveMode_ThrottleClear()
1725 this->m_InvalidReceiveModeThrottle = 0;
1728 void FileUplinkComponentBase ::
1729 log_WARNING_HI_PacketOutOfBounds_ThrottleClear()
1732 this->m_PacketOutOfBoundsThrottle = 0;
1735 void FileUplinkComponentBase ::
1736 log_WARNING_HI_PacketOutOfOrder_ThrottleClear()
1739 this->m_PacketOutOfOrderThrottle = 0;
1742 void FileUplinkComponentBase ::
1743 log_WARNING_HI_PacketDuplicate_ThrottleClear()
1746 this->m_PacketDuplicateThrottle = 0;
1753 void FileUplinkComponentBase ::
1754 tlmWrite_FilesReceived(
1759 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1761 this->m_timeCaller_OutputPort[0].isConnected() &&
1764 this->m_timeCaller_OutputPort[0].invoke(_tlmTime);
1776 _id = this->getIdBase() + CHANNELID_FILESRECEIVED;
1778 this->m_tlmOut_OutputPort[0].invoke(
1786 void FileUplinkComponentBase ::
1787 tlmWrite_PacketsReceived(
1792 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1794 this->m_timeCaller_OutputPort[0].isConnected() &&
1797 this->m_timeCaller_OutputPort[0].invoke(_tlmTime);
1809 _id = this->getIdBase() + CHANNELID_PACKETSRECEIVED;
1811 this->m_tlmOut_OutputPort[0].invoke(
1819 void FileUplinkComponentBase ::
1825 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1827 this->m_timeCaller_OutputPort[0].isConnected() &&
1830 this->m_timeCaller_OutputPort[0].invoke(_tlmTime);
1842 _id = this->getIdBase() + CHANNELID_WARNINGS;
1844 this->m_tlmOut_OutputPort[0].invoke(
1859 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1861 this->m_timeCaller_OutputPort[0].invoke(_time);
1876 ComponentIpcSerializableBuffer msg;
1899 MsgTypeEnum msgType =
static_cast<MsgTypeEnum
>(desMsg);
1901 if (msgType == FILEUPLINK_COMPONENT_EXIT) {
1902 return MSG_DISPATCH_EXIT;
1906 deserStatus = msg.deserialize(portNum);
1914 case BUFFERSENDIN_BUFFERSEND: {
1917 deserStatus = msg.deserialize(fwBuffer);
1923 this->bufferSendIn_handler(
1935 deserStatus = msg.deserialize(key);
1941 this->pingIn_handler(
1950 return MSG_DISPATCH_ERROR;
1953 return MSG_DISPATCH_OK;
1960 void FileUplinkComponentBase ::
1961 m_p_bufferSendIn_in(
1968 FileUplinkComponentBase* compPtr =
static_cast<FileUplinkComponentBase*
>(callComp);
1969 compPtr->bufferSendIn_handlerBase(
1975 void FileUplinkComponentBase ::
1983 FileUplinkComponentBase* compPtr =
static_cast<FileUplinkComponentBase*
>(callComp);
1984 compPtr->pingIn_handlerBase(
#define FW_MIN(a, b)
MIN macro.
uint8_t U8
8-bit unsigned integer
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
#define PRI_PlatformIntType
@ TB_NONE
No time base has been established.
PlatformAssertArgType FwAssertArgType
PlatformSizeType FwSizeType
#define FW_LOG_STRING_MAX_SIZE
Max size of log string parameter type.
PlatformQueuePriorityType FwQueuePriorityType
PlatformIndexType FwIndexType
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects)/*#en...
@ ACTIVE_COMPONENT_EXIT
message to exit active component task
@ WARNING_HI
A serious but recoverable event.
@ ACTIVITY_HI
Important informational events.
void init()
Object initializer.
const char * toChar() const
NATIVE_UINT_TYPE SizeType
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
void format(const CHAR *formatString,...)
write formatted string to buffer
virtual SerializeStatus serialize(SerializeBufferBase &buffer) const
serialization function
virtual const CHAR * toChar() const =0
@ BLOCKING
Message will block until space is available.
@ NONBLOCKING
Message will return with status when space is unavailable.
Status
status returned from the queue send function
@ OP_OK
message sent/received okay
SerializeStatus
forward declaration for string
@ FW_SERIALIZE_OK
Serialization/Deserialization operation was successful.