11#if FW_ENABLE_TEXT_LOGGING
20 BUFFERSENDIN_BUFFERSEND,
33 class ComponentIpcSerializableBuffer :
48 return sizeof(m_buff);
55 const U8* getBuffAddr()
const {
61 U8 m_buff[SERIALIZATION_SIZE];
70 void FileUplinkComponentBase ::
82 port < static_cast<PlatformIntType>(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
99 char portName[2*FW_OBJ_NAME_MAX_SIZE];
107 this->m_bufferSendIn_InputPort[port].setObjName(portName);
114 port < static_cast<PlatformIntType>(this->getNum_pingIn_InputPorts());
117 this->m_pingIn_InputPort[port].init();
118 this->m_pingIn_InputPort[port].addCallComp(
122 this->m_pingIn_InputPort[port].setPortNum(port);
124#if FW_OBJECT_NAMES == 1
131 char portName[2*FW_OBJ_NAME_MAX_SIZE];
139 this->m_pingIn_InputPort[port].setObjName(portName);
143#if FW_ENABLE_TEXT_LOGGING == 1
147 port < static_cast<PlatformIntType>(this->getNum_LogText_OutputPorts());
150 this->m_LogText_OutputPort[port].init();
152#if FW_OBJECT_NAMES == 1
159 char portName[2*FW_OBJ_NAME_MAX_SIZE];
167 this->m_LogText_OutputPort[port].setObjName(portName);
175 port < static_cast<PlatformIntType>(this->getNum_eventOut_OutputPorts());
178 this->m_eventOut_OutputPort[port].init();
180#if FW_OBJECT_NAMES == 1
187 char portName[2*FW_OBJ_NAME_MAX_SIZE];
195 this->m_eventOut_OutputPort[port].setObjName(portName);
202 port < static_cast<PlatformIntType>(this->getNum_timeCaller_OutputPorts());
205 this->m_timeCaller_OutputPort[port].init();
207#if FW_OBJECT_NAMES == 1
214 char portName[2*FW_OBJ_NAME_MAX_SIZE];
222 this->m_timeCaller_OutputPort[port].setObjName(portName);
229 port < static_cast<PlatformIntType>(this->getNum_tlmOut_OutputPorts());
232 this->m_tlmOut_OutputPort[port].init();
234#if FW_OBJECT_NAMES == 1
241 char portName[2*FW_OBJ_NAME_MAX_SIZE];
249 this->m_tlmOut_OutputPort[port].setObjName(portName);
256 port < static_cast<PlatformIntType>(this->getNum_bufferSendOut_OutputPorts());
259 this->m_bufferSendOut_OutputPort[port].init();
261#if FW_OBJECT_NAMES == 1
268 char portName[2*FW_OBJ_NAME_MAX_SIZE];
276 this->m_bufferSendOut_OutputPort[port].setObjName(portName);
283 port < static_cast<PlatformIntType>(this->getNum_pingOut_OutputPorts());
286 this->m_pingOut_OutputPort[port].init();
288#if FW_OBJECT_NAMES == 1
295 char portName[2*FW_OBJ_NAME_MAX_SIZE];
303 this->m_pingOut_OutputPort[port].setObjName(portName);
309 ComponentIpcSerializableBuffer::SERIALIZATION_SIZE
70 void FileUplinkComponentBase :: {
…}
325 portNum < this->getNum_bufferSendIn_InputPorts(),
329 return &this->m_bufferSendIn_InputPort[portNum];
336 portNum < this->getNum_pingIn_InputPorts(),
340 return &this->m_pingIn_InputPort[portNum];
347#if FW_ENABLE_TEXT_LOGGING == 1
349 void FileUplinkComponentBase ::
350 set_LogText_OutputPort(
356 portNum < this->getNum_LogText_OutputPorts(),
360 this->m_LogText_OutputPort[portNum].addCallPort(port);
365 void FileUplinkComponentBase ::
366 set_eventOut_OutputPort(
372 portNum < this->getNum_eventOut_OutputPorts(),
376 this->m_eventOut_OutputPort[portNum].addCallPort(port);
365 void FileUplinkComponentBase :: {
…}
379 void FileUplinkComponentBase ::
380 set_timeCaller_OutputPort(
386 portNum < this->getNum_timeCaller_OutputPorts(),
390 this->m_timeCaller_OutputPort[portNum].addCallPort(port);
379 void FileUplinkComponentBase :: {
…}
393 void FileUplinkComponentBase ::
394 set_tlmOut_OutputPort(
400 portNum < this->getNum_tlmOut_OutputPorts(),
404 this->m_tlmOut_OutputPort[portNum].addCallPort(port);
393 void FileUplinkComponentBase :: {
…}
411 void FileUplinkComponentBase ::
412 set_bufferSendOut_OutputPort(
418 portNum < this->getNum_bufferSendOut_OutputPorts(),
422 this->m_bufferSendOut_OutputPort[portNum].addCallPort(port);
411 void FileUplinkComponentBase :: {
…}
425 void FileUplinkComponentBase ::
426 set_pingOut_OutputPort(
432 portNum < this->getNum_pingOut_OutputPorts(),
436 this->m_pingOut_OutputPort[portNum].addCallPort(port);
425 void FileUplinkComponentBase :: {
…}
439#if FW_PORT_SERIALIZATION
445#if FW_ENABLE_TEXT_LOGGING == 1
447 void FileUplinkComponentBase ::
448 set_LogText_OutputPort(
450 Fw::InputSerializePort* port
454 portNum < this->getNum_LogText_OutputPorts(),
458 this->m_LogText_OutputPort[portNum].registerSerialPort(port);
463 void FileUplinkComponentBase ::
464 set_eventOut_OutputPort(
466 Fw::InputSerializePort* port
470 portNum < this->getNum_eventOut_OutputPorts(),
474 this->m_eventOut_OutputPort[portNum].registerSerialPort(port);
477 void FileUplinkComponentBase ::
478 set_timeCaller_OutputPort(
480 Fw::InputSerializePort* port
484 portNum < this->getNum_timeCaller_OutputPorts(),
488 this->m_timeCaller_OutputPort[portNum].registerSerialPort(port);
491 void FileUplinkComponentBase ::
492 set_tlmOut_OutputPort(
494 Fw::InputSerializePort* port
498 portNum < this->getNum_tlmOut_OutputPorts(),
502 this->m_tlmOut_OutputPort[portNum].registerSerialPort(port);
507#if FW_PORT_SERIALIZATION
513 void FileUplinkComponentBase ::
514 set_bufferSendOut_OutputPort(
516 Fw::InputSerializePort* port
520 portNum < this->getNum_bufferSendOut_OutputPorts(),
524 this->m_bufferSendOut_OutputPort[portNum].registerSerialPort(port);
527 void FileUplinkComponentBase ::
528 set_pingOut_OutputPort(
530 Fw::InputSerializePort* port
534 portNum < this->getNum_pingOut_OutputPorts(),
538 this->m_pingOut_OutputPort[portNum].registerSerialPort(port);
547 FileUplinkComponentBase ::
548 FileUplinkComponentBase(
const char* compName) :
549 Fw::ActiveComponentBase(compName)
551 this->m_FileWriteErrorThrottle = 0;
552 this->m_InvalidReceiveModeThrottle = 0;
553 this->m_PacketOutOfBoundsThrottle = 0;
554 this->m_PacketOutOfOrderThrottle = 0;
547 FileUplinkComponentBase :: {
…}
557 FileUplinkComponentBase ::
558 ~FileUplinkComponentBase()
557 FileUplinkComponentBase :: {
…}
568 getNum_bufferSendIn_InputPorts()
const
574 getNum_pingIn_InputPorts()
const
583#if FW_ENABLE_TEXT_LOGGING == 1
586 getNum_LogText_OutputPorts()
const
594 getNum_eventOut_OutputPorts()
const
600 getNum_timeCaller_OutputPorts()
const
606 getNum_tlmOut_OutputPorts()
const
616 getNum_bufferSendOut_OutputPorts()
const
622 getNum_pingOut_OutputPorts()
const
631#if FW_ENABLE_TEXT_LOGGING == 1
633 bool FileUplinkComponentBase ::
637 portNum < this->getNum_LogText_OutputPorts(),
641 return this->m_LogText_OutputPort[portNum].isConnected();
646 bool FileUplinkComponentBase ::
650 portNum < this->getNum_eventOut_OutputPorts(),
654 return this->m_eventOut_OutputPort[portNum].isConnected();
646 bool FileUplinkComponentBase :: {
…}
657 bool FileUplinkComponentBase ::
661 portNum < this->getNum_timeCaller_OutputPorts(),
665 return this->m_timeCaller_OutputPort[portNum].isConnected();
657 bool FileUplinkComponentBase :: {
…}
668 bool FileUplinkComponentBase ::
672 portNum < this->getNum_tlmOut_OutputPorts(),
676 return this->m_tlmOut_OutputPort[portNum].isConnected();
668 bool FileUplinkComponentBase :: {
…}
683 bool FileUplinkComponentBase ::
687 portNum < this->getNum_bufferSendOut_OutputPorts(),
691 return this->m_bufferSendOut_OutputPort[portNum].isConnected();
683 bool FileUplinkComponentBase :: {
…}
694 bool FileUplinkComponentBase ::
698 portNum < this->getNum_pingOut_OutputPorts(),
702 return this->m_pingOut_OutputPort[portNum].isConnected();
694 bool FileUplinkComponentBase :: {
…}
711 void FileUplinkComponentBase ::
712 bufferSendIn_handlerBase(
719 portNum < this->getNum_bufferSendIn_InputPorts(),
724 bufferSendIn_preMsgHook(
728 ComponentIpcSerializableBuffer msg;
732 _status = msg.serialize(
741 _status = msg.serialize(portNum);
748 _status = msg.serialize(fwBuffer);
711 void FileUplinkComponentBase :: {
…}
764 void FileUplinkComponentBase ::
772 portNum < this->getNum_pingIn_InputPorts(),
781 ComponentIpcSerializableBuffer msg;
785 _status = msg.serialize(
794 _status = msg.serialize(portNum);
801 _status = msg.serialize(key);
764 void FileUplinkComponentBase :: {
…}
825 void FileUplinkComponentBase ::
826 bufferSendIn_preMsgHook(
825 void FileUplinkComponentBase :: {
…}
834 void FileUplinkComponentBase ::
834 void FileUplinkComponentBase :: {
…}
847 void FileUplinkComponentBase ::
854 portNum < this->getNum_bufferSendOut_OutputPorts(),
857 this->m_bufferSendOut_OutputPort[portNum].invoke(
847 void FileUplinkComponentBase :: {
…}
862 void FileUplinkComponentBase ::
869 portNum < this->getNum_pingOut_OutputPorts(),
872 this->m_pingOut_OutputPort[portNum].invoke(
862 void FileUplinkComponentBase :: {
…}
881 void FileUplinkComponentBase ::
882 log_WARNING_HI_BadChecksum(
890 if (this->m_timeCaller_OutputPort[0].isConnected()) {
891 this->m_timeCaller_OutputPort[0].invoke(_logTime);
896 _id = this->getIdBase() + EVENTID_BADCHECKSUM;
899 if (this->m_eventOut_OutputPort[0].isConnected()) {
903#if FW_AMPCS_COMPATIBLE
912 _status = fileName.
serialize(_logBuff, 40);
918#if FW_AMPCS_COMPATIBLE
921 static_cast<U8>(
sizeof(U32))
934#if FW_AMPCS_COMPATIBLE
937 static_cast<U8>(
sizeof(U32))
950 this->m_eventOut_OutputPort[0].invoke(
959#if FW_ENABLE_TEXT_LOGGING
960 if (this->m_LogText_OutputPort[0].isConnected()) {
961#if FW_OBJECT_NAMES == 1
962 const char* _formatString =
963 "(%s) %s: Bad checksum value during receipt of file %s: computed 0x%" PRIx32
", read 0x%" PRIx32
"";
965 const char* _formatString =
966 "%s: Bad checksum value during receipt of file %s: computed 0x%" PRIx32
", read 0x%" PRIx32
"";
987 this->m_LogText_OutputPort[0].invoke(
881 void FileUplinkComponentBase :: {
…}
997 void FileUplinkComponentBase ::
1002 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1003 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1008 _id = this->getIdBase() + EVENTID_FILEOPENERROR;
1011 if (this->m_eventOut_OutputPort[0].isConnected()) {
1015#if FW_AMPCS_COMPATIBLE
1024 _status = fileName.
serialize(_logBuff, 40);
1030 this->m_eventOut_OutputPort[0].invoke(
1039#if FW_ENABLE_TEXT_LOGGING
1040 if (this->m_LogText_OutputPort[0].isConnected()) {
1041#if FW_OBJECT_NAMES == 1
1042 const char* _formatString =
1043 "(%s) %s: Could not open file %s";
1045 const char* _formatString =
1046 "%s: Could not open file %s";
1065 this->m_LogText_OutputPort[0].invoke(
997 void FileUplinkComponentBase :: {
…}
1075 void FileUplinkComponentBase ::
1080 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1081 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1086 _id = this->getIdBase() + EVENTID_FILERECEIVED;
1089 if (this->m_eventOut_OutputPort[0].isConnected()) {
1093#if FW_AMPCS_COMPATIBLE
1102 _status = fileName.
serialize(_logBuff, 40);
1108 this->m_eventOut_OutputPort[0].invoke(
1117#if FW_ENABLE_TEXT_LOGGING
1118 if (this->m_LogText_OutputPort[0].isConnected()) {
1119#if FW_OBJECT_NAMES == 1
1120 const char* _formatString =
1121 "(%s) %s: Received file %s";
1123 const char* _formatString =
1124 "%s: Received file %s";
1143 this->m_LogText_OutputPort[0].invoke(
1075 void FileUplinkComponentBase :: {
…}
1153 void FileUplinkComponentBase ::
1157 if (this->m_FileWriteErrorThrottle >= EVENTID_FILEWRITEERROR_THROTTLE) {
1161 this->m_FileWriteErrorThrottle++;
1166 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1167 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1172 _id = this->getIdBase() + EVENTID_FILEWRITEERROR;
1175 if (this->m_eventOut_OutputPort[0].isConnected()) {
1179#if FW_AMPCS_COMPATIBLE
1188 _status = fileName.
serialize(_logBuff, 40);
1194 this->m_eventOut_OutputPort[0].invoke(
1203#if FW_ENABLE_TEXT_LOGGING
1204 if (this->m_LogText_OutputPort[0].isConnected()) {
1205#if FW_OBJECT_NAMES == 1
1206 const char* _formatString =
1207 "(%s) %s: Could not write to file %s";
1209 const char* _formatString =
1210 "%s: Could not write to file %s";
1229 this->m_LogText_OutputPort[0].invoke(
1153 void FileUplinkComponentBase :: {
…}
1239 void FileUplinkComponentBase ::
1240 log_WARNING_HI_InvalidReceiveMode(
1246 if (this->m_InvalidReceiveModeThrottle >= EVENTID_INVALIDRECEIVEMODE_THROTTLE) {
1250 this->m_InvalidReceiveModeThrottle++;
1255 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1256 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1261 _id = this->getIdBase() + EVENTID_INVALIDRECEIVEMODE;
1264 if (this->m_eventOut_OutputPort[0].isConnected()) {
1268#if FW_AMPCS_COMPATIBLE
1277#if FW_AMPCS_COMPATIBLE
1280 static_cast<U8>(
sizeof(U32))
1287 _status = _logBuff.
serialize(packetType);
1293#if FW_AMPCS_COMPATIBLE
1296 static_cast<U8>(
sizeof(U32))
1309 this->m_eventOut_OutputPort[0].invoke(
1318#if FW_ENABLE_TEXT_LOGGING
1319 if (this->m_LogText_OutputPort[0].isConnected()) {
1320#if FW_OBJECT_NAMES == 1
1321 const char* _formatString =
1322 "(%s) %s: Packet type %" PRIu32
" received in mode %" PRIu32
"";
1324 const char* _formatString =
1325 "%s: Packet type %" PRIu32
" received in mode %" PRIu32
"";
1337 "InvalidReceiveMode ",
1345 this->m_LogText_OutputPort[0].invoke(
1239 void FileUplinkComponentBase :: {
…}
1355 void FileUplinkComponentBase ::
1356 log_WARNING_HI_PacketOutOfBounds(
1362 if (this->m_PacketOutOfBoundsThrottle >= EVENTID_PACKETOUTOFBOUNDS_THROTTLE) {
1366 this->m_PacketOutOfBoundsThrottle++;
1371 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1372 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1377 _id = this->getIdBase() + EVENTID_PACKETOUTOFBOUNDS;
1380 if (this->m_eventOut_OutputPort[0].isConnected()) {
1384#if FW_AMPCS_COMPATIBLE
1393#if FW_AMPCS_COMPATIBLE
1396 static_cast<U8>(
sizeof(U32))
1403 _status = _logBuff.
serialize(packetIndex);
1409 _status = fileName.
serialize(_logBuff, 40);
1415 this->m_eventOut_OutputPort[0].invoke(
1424#if FW_ENABLE_TEXT_LOGGING
1425 if (this->m_LogText_OutputPort[0].isConnected()) {
1426#if FW_OBJECT_NAMES == 1
1427 const char* _formatString =
1428 "(%s) %s: Packet %" PRIu32
" out of bounds for file %s";
1430 const char* _formatString =
1431 "%s: Packet %" PRIu32
" out of bounds for file %s";
1443 "PacketOutOfBounds ",
1451 this->m_LogText_OutputPort[0].invoke(
1355 void FileUplinkComponentBase :: {
…}
1461 void FileUplinkComponentBase ::
1462 log_WARNING_HI_PacketOutOfOrder(
1468 if (this->m_PacketOutOfOrderThrottle >= EVENTID_PACKETOUTOFORDER_THROTTLE) {
1472 this->m_PacketOutOfOrderThrottle++;
1477 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1478 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1483 _id = this->getIdBase() + EVENTID_PACKETOUTOFORDER;
1486 if (this->m_eventOut_OutputPort[0].isConnected()) {
1490#if FW_AMPCS_COMPATIBLE
1499#if FW_AMPCS_COMPATIBLE
1502 static_cast<U8>(
sizeof(U32))
1509 _status = _logBuff.
serialize(packetIndex);
1515#if FW_AMPCS_COMPATIBLE
1518 static_cast<U8>(
sizeof(U32))
1525 _status = _logBuff.
serialize(lastPacketIndex);
1531 this->m_eventOut_OutputPort[0].invoke(
1540#if FW_ENABLE_TEXT_LOGGING
1541 if (this->m_LogText_OutputPort[0].isConnected()) {
1542#if FW_OBJECT_NAMES == 1
1543 const char* _formatString =
1544 "(%s) %s: Received packet %" PRIu32
" after packet %" PRIu32
"";
1546 const char* _formatString =
1547 "%s: Received packet %" PRIu32
" after packet %" PRIu32
"";
1559 "PacketOutOfOrder ",
1567 this->m_LogText_OutputPort[0].invoke(
1461 void FileUplinkComponentBase :: {
…}
1577 void FileUplinkComponentBase ::
1578 log_ACTIVITY_HI_UplinkCanceled()
1582 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1583 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1588 _id = this->getIdBase() + EVENTID_UPLINKCANCELED;
1591 if (this->m_eventOut_OutputPort[0].isConnected()) {
1594#if FW_AMPCS_COMPATIBLE
1604 this->m_eventOut_OutputPort[0].invoke(
1613#if FW_ENABLE_TEXT_LOGGING
1614 if (this->m_LogText_OutputPort[0].isConnected()) {
1615#if FW_OBJECT_NAMES == 1
1616 const char* _formatString =
1617 "(%s) %s: Received CANCEL packet";
1619 const char* _formatString =
1620 "%s: Received CANCEL packet";
1638 this->m_LogText_OutputPort[0].invoke(
1577 void FileUplinkComponentBase :: {
…}
1648 void FileUplinkComponentBase ::
1649 log_WARNING_HI_DecodeError(I32 status)
1653 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1654 this->m_timeCaller_OutputPort[0].invoke(_logTime);
1659 _id = this->getIdBase() + EVENTID_DECODEERROR;
1662 if (this->m_eventOut_OutputPort[0].isConnected()) {
1666#if FW_AMPCS_COMPATIBLE
1675#if FW_AMPCS_COMPATIBLE
1678 static_cast<U8>(
sizeof(I32))
1691 this->m_eventOut_OutputPort[0].invoke(
1700#if FW_ENABLE_TEXT_LOGGING
1701 if (this->m_LogText_OutputPort[0].isConnected()) {
1702#if FW_OBJECT_NAMES == 1
1703 const char* _formatString =
1704 "(%s) %s: Unable to decode file packet. Status: %" PRIi32
"";
1706 const char* _formatString =
1707 "%s: Unable to decode file packet. Status: %" PRIi32
"";
1726 this->m_LogText_OutputPort[0].invoke(
1648 void FileUplinkComponentBase :: {
…}
1740 void FileUplinkComponentBase ::
1741 log_WARNING_HI_FileWriteError_ThrottleClear()
1744 this->m_FileWriteErrorThrottle = 0;
1740 void FileUplinkComponentBase :: {
…}
1747 void FileUplinkComponentBase ::
1748 log_WARNING_HI_InvalidReceiveMode_ThrottleClear()
1751 this->m_InvalidReceiveModeThrottle = 0;
1747 void FileUplinkComponentBase :: {
…}
1754 void FileUplinkComponentBase ::
1755 log_WARNING_HI_PacketOutOfBounds_ThrottleClear()
1758 this->m_PacketOutOfBoundsThrottle = 0;
1754 void FileUplinkComponentBase :: {
…}
1761 void FileUplinkComponentBase ::
1762 log_WARNING_HI_PacketOutOfOrder_ThrottleClear()
1765 this->m_PacketOutOfOrderThrottle = 0;
1761 void FileUplinkComponentBase :: {
…}
1772 void FileUplinkComponentBase ::
1773 tlmWrite_FilesReceived(
1778 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1780 this->m_timeCaller_OutputPort[0].isConnected() &&
1783 this->m_timeCaller_OutputPort[0].invoke(_tlmTime);
1795 _id = this->getIdBase() + CHANNELID_FILESRECEIVED;
1797 this->m_tlmOut_OutputPort[0].invoke(
1772 void FileUplinkComponentBase :: {
…}
1805 void FileUplinkComponentBase ::
1806 tlmWrite_PacketsReceived(
1811 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1813 this->m_timeCaller_OutputPort[0].isConnected() &&
1816 this->m_timeCaller_OutputPort[0].invoke(_tlmTime);
1828 _id = this->getIdBase() + CHANNELID_PACKETSRECEIVED;
1830 this->m_tlmOut_OutputPort[0].invoke(
1805 void FileUplinkComponentBase :: {
…}
1838 void FileUplinkComponentBase ::
1844 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1846 this->m_timeCaller_OutputPort[0].isConnected() &&
1849 this->m_timeCaller_OutputPort[0].invoke(_tlmTime);
1861 _id = this->getIdBase() + CHANNELID_WARNINGS;
1863 this->m_tlmOut_OutputPort[0].invoke(
1838 void FileUplinkComponentBase :: {
…}
1878 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1880 this->m_timeCaller_OutputPort[0].invoke(_time);
1895 ComponentIpcSerializableBuffer msg;
1918 MsgTypeEnum msgType =
static_cast<MsgTypeEnum
>(desMsg);
1920 if (msgType == FILEUPLINK_COMPONENT_EXIT) {
1921 return MSG_DISPATCH_EXIT;
1925 deserStatus = msg.deserialize(portNum);
1933 case BUFFERSENDIN_BUFFERSEND: {
1936 deserStatus = msg.deserialize(fwBuffer);
1942 this->bufferSendIn_handler(
1954 deserStatus = msg.deserialize(key);
1960 this->pingIn_handler(
1969 return MSG_DISPATCH_ERROR;
1972 return MSG_DISPATCH_OK;
1979 void FileUplinkComponentBase ::
1980 m_p_bufferSendIn_in(
1987 FileUplinkComponentBase* compPtr =
static_cast<FileUplinkComponentBase*
>(callComp);
1988 compPtr->bufferSendIn_handlerBase(
1994 void FileUplinkComponentBase ::
2002 FileUplinkComponentBase* compPtr =
static_cast<FileUplinkComponentBase*
>(callComp);
2003 compPtr->pingIn_handlerBase(
PlatformIntType NATIVE_INT_TYPE
uint8_t U8
8-bit unsigned integer
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
PlatformUIntType NATIVE_UINT_TYPE
int PlatformIntType
DefaultTypes.hpp provides fallback defaults for the platform types.
#define PRI_PlatformIntType
@ TB_NONE
No time base has been established.
PlatformAssertArgType FwAssertArgType
#define FW_LOG_TEXT_BUFFER_SIZE
Max size of string for text log message.
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects)
@ ACTIVE_COMPONENT_EXIT
message to exit active component task
@ WARNING_HI
A serious but recoverable event.
@ ACTIVITY_HI
Important informational events.
const char * toChar() const override
SerializeStatus serialize(SerializeBufferBase &buffer) const override
serialization function
void init()
Object initializer.
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
@ QUEUE_OK
message sent/received okay
@ QUEUE_BLOCKING
Queue receive blocks until a message arrives.
@ QUEUE_NONBLOCKING
Queue receive always returns even if there is no message.
SerializeStatus
forward declaration for string
@ FW_SERIALIZE_OK
Serialization/Deserialization operation was successful.