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];
85 this->m_bufferSendIn_InputPort[port].
init();
90 this->m_bufferSendIn_InputPort[port].
setPortNum(port);
92 #if FW_OBJECT_NAMES == 1 95 "%s_bufferSendIn_InputPort[%" PRI_PlatformIntType
"]",
96 this->m_objName.toChar(),
99 this->m_bufferSendIn_InputPort[port].setObjName(portName.
toChar());
109 this->m_pingIn_InputPort[port].
init();
114 this->m_pingIn_InputPort[port].
setPortNum(port);
116 #if FW_OBJECT_NAMES == 1 119 "%s_pingIn_InputPort[%" PRI_PlatformIntType
"]",
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 139 "%s_LogText_OutputPort[%" PRI_PlatformIntType
"]",
140 this->m_objName.toChar(),
143 this->m_LogText_OutputPort[port].setObjName(portName.
toChar());
154 this->m_eventOut_OutputPort[port].
init();
156 #if FW_OBJECT_NAMES == 1 159 "%s_eventOut_OutputPort[%" PRI_PlatformIntType
"]",
160 this->m_objName.toChar(),
163 this->m_eventOut_OutputPort[port].setObjName(portName.
toChar());
173 this->m_timeCaller_OutputPort[port].
init();
175 #if FW_OBJECT_NAMES == 1 178 "%s_timeCaller_OutputPort[%" PRI_PlatformIntType
"]",
179 this->m_objName.toChar(),
182 this->m_timeCaller_OutputPort[port].setObjName(portName.
toChar());
192 this->m_tlmOut_OutputPort[port].
init();
194 #if FW_OBJECT_NAMES == 1 197 "%s_tlmOut_OutputPort[%" PRI_PlatformIntType
"]",
198 this->m_objName.toChar(),
201 this->m_tlmOut_OutputPort[port].setObjName(portName.
toChar());
211 this->m_bufferSendOut_OutputPort[port].
init();
213 #if FW_OBJECT_NAMES == 1 216 "%s_bufferSendOut_OutputPort[%" PRI_PlatformIntType
"]",
217 this->m_objName.toChar(),
220 this->m_bufferSendOut_OutputPort[port].setObjName(portName.
toChar());
230 this->m_pingOut_OutputPort[port].
init();
232 #if FW_OBJECT_NAMES == 1 235 "%s_pingOut_OutputPort[%" PRI_PlatformIntType
"]",
236 this->m_objName.toChar(),
239 this->m_pingOut_OutputPort[port].setObjName(portName.
toChar());
246 static_cast<FwSizeType>(ComponentIpcSerializableBuffer::SERIALIZATION_SIZE)
250 static_cast<FwAssertArgType>(qStat)
263 static_cast<FwAssertArgType>(portNum)
266 return &this->m_bufferSendIn_InputPort[portNum];
274 static_cast<FwAssertArgType>(portNum)
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(),
294 static_cast<FwAssertArgType>(portNum)
297 this->m_LogText_OutputPort[portNum].addCallPort(port);
310 static_cast<FwAssertArgType>(portNum)
313 this->m_eventOut_OutputPort[portNum].
addCallPort(port);
324 static_cast<FwAssertArgType>(portNum)
327 this->m_timeCaller_OutputPort[portNum].
addCallPort(port);
338 static_cast<FwAssertArgType>(portNum)
341 this->m_tlmOut_OutputPort[portNum].
addCallPort(port);
356 static_cast<FwAssertArgType>(portNum)
359 this->m_bufferSendOut_OutputPort[portNum].
addCallPort(port);
370 static_cast<FwAssertArgType>(portNum)
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(),
392 static_cast<FwAssertArgType>(portNum)
395 this->m_LogText_OutputPort[portNum].registerSerialPort(port);
403 Fw::InputSerializePort* port
408 static_cast<FwAssertArgType>(portNum)
411 this->m_eventOut_OutputPort[portNum].registerSerialPort(port);
417 Fw::InputSerializePort* port
422 static_cast<FwAssertArgType>(portNum)
425 this->m_timeCaller_OutputPort[portNum].registerSerialPort(port);
431 Fw::InputSerializePort* port
436 static_cast<FwAssertArgType>(portNum)
439 this->m_tlmOut_OutputPort[portNum].registerSerialPort(port);
444 #if FW_PORT_SERIALIZATION 453 Fw::InputSerializePort* port
458 static_cast<FwAssertArgType>(portNum)
461 this->m_bufferSendOut_OutputPort[portNum].registerSerialPort(port);
467 Fw::InputSerializePort* port
472 static_cast<FwAssertArgType>(portNum)
475 this->m_pingOut_OutputPort[portNum].registerSerialPort(port);
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;
521 #if FW_ENABLE_TEXT_LOGGING == 1 524 getNum_LogText_OutputPorts()
const 569 #if FW_ENABLE_TEXT_LOGGING == 1 571 bool FileUplinkComponentBase ::
572 isConnected_LogText_OutputPort(
FwIndexType portNum)
575 portNum < this->getNum_LogText_OutputPorts(),
576 static_cast<FwAssertArgType>(portNum)
579 return this->m_LogText_OutputPort[portNum].isConnected();
589 static_cast<FwAssertArgType>(portNum)
592 return this->m_eventOut_OutputPort[portNum].
isConnected();
600 static_cast<FwAssertArgType>(portNum)
603 return this->m_timeCaller_OutputPort[portNum].
isConnected();
611 static_cast<FwAssertArgType>(portNum)
614 return this->m_tlmOut_OutputPort[portNum].
isConnected();
626 static_cast<FwAssertArgType>(portNum)
629 return this->m_bufferSendOut_OutputPort[portNum].
isConnected();
637 static_cast<FwAssertArgType>(portNum)
640 return this->m_pingOut_OutputPort[portNum].
isConnected();
658 static_cast<FwAssertArgType>(portNum)
666 ComponentIpcSerializableBuffer msg;
670 _status = msg.serialize(
671 static_cast<FwEnumStoreType>(BUFFERSENDIN_BUFFERSEND)
675 static_cast<FwAssertArgType>(_status)
679 _status = msg.serialize(portNum);
682 static_cast<FwAssertArgType>(_status)
686 _status = msg.serialize(fwBuffer);
689 static_cast<FwAssertArgType>(_status)
698 static_cast<FwAssertArgType>(qStatus)
711 static_cast<FwAssertArgType>(portNum)
719 ComponentIpcSerializableBuffer msg;
723 _status = msg.serialize(
724 static_cast<FwEnumStoreType>(PINGIN_PING)
728 static_cast<FwAssertArgType>(_status)
732 _status = msg.serialize(portNum);
735 static_cast<FwAssertArgType>(_status)
739 _status = msg.serialize(key);
742 static_cast<FwAssertArgType>(_status)
751 static_cast<FwAssertArgType>(qStatus)
793 static_cast<FwAssertArgType>(portNum)
797 this->m_bufferSendOut_OutputPort[portNum].isConnected(),
798 static_cast<FwAssertArgType>(portNum)
800 this->m_bufferSendOut_OutputPort[portNum].
invoke(
813 static_cast<FwAssertArgType>(portNum)
817 this->m_pingOut_OutputPort[portNum].isConnected(),
818 static_cast<FwAssertArgType>(portNum)
820 this->m_pingOut_OutputPort[portNum].
invoke(
838 if (this->m_timeCaller_OutputPort[0].isConnected()) {
839 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
847 if (this->m_eventOut_OutputPort[0].isConnected()) {
851 #if FW_AMPCS_COMPATIBLE 853 _status = _logBuff.
serialize(static_cast<U8>(3));
856 static_cast<FwAssertArgType>(_status)
863 static_cast<FwAssertArgType>(_status)
866 #if FW_AMPCS_COMPATIBLE 869 static_cast<U8>(
sizeof(U32))
873 static_cast<FwAssertArgType>(_status)
879 static_cast<FwAssertArgType>(_status)
882 #if FW_AMPCS_COMPATIBLE 885 static_cast<U8>(
sizeof(U32))
889 static_cast<FwAssertArgType>(_status)
895 static_cast<FwAssertArgType>(_status)
898 this->m_eventOut_OutputPort[0].
invoke(
907 #if FW_ENABLE_TEXT_LOGGING 908 if (this->m_LogText_OutputPort[0].isConnected()) {
909 #if FW_OBJECT_NAMES == 1 910 const char* _formatString =
911 "(%s) %s: Bad checksum value during receipt of file %s: computed 0x%" PRIx32
", read 0x%" PRIx32
"";
913 const char* _formatString =
914 "%s: Bad checksum value during receipt of file %s: computed 0x%" PRIx32
", read 0x%" PRIx32
"";
921 this->m_objName.toChar(),
929 this->m_LogText_OutputPort[0].invoke(
944 if (this->m_timeCaller_OutputPort[0].isConnected()) {
945 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
953 if (this->m_eventOut_OutputPort[0].isConnected()) {
957 #if FW_AMPCS_COMPATIBLE 959 _status = _logBuff.
serialize(static_cast<U8>(1));
962 static_cast<FwAssertArgType>(_status)
969 static_cast<FwAssertArgType>(_status)
972 this->m_eventOut_OutputPort[0].
invoke(
981 #if FW_ENABLE_TEXT_LOGGING 982 if (this->m_LogText_OutputPort[0].isConnected()) {
983 #if FW_OBJECT_NAMES == 1 984 const char* _formatString =
985 "(%s) %s: Could not open file %s";
987 const char* _formatString =
988 "%s: Could not open file %s";
995 this->m_objName.toChar(),
1001 this->m_LogText_OutputPort[0].invoke(
1016 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1017 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1025 if (this->m_eventOut_OutputPort[0].isConnected()) {
1029 #if FW_AMPCS_COMPATIBLE 1031 _status = _logBuff.
serialize(static_cast<U8>(1));
1034 static_cast<FwAssertArgType>(_status)
1041 static_cast<FwAssertArgType>(_status)
1044 this->m_eventOut_OutputPort[0].
invoke(
1053 #if FW_ENABLE_TEXT_LOGGING 1054 if (this->m_LogText_OutputPort[0].isConnected()) {
1055 #if FW_OBJECT_NAMES == 1 1056 const char* _formatString =
1057 "(%s) %s: Received file %s";
1059 const char* _formatString =
1060 "%s: Received file %s";
1067 this->m_objName.toChar(),
1073 this->m_LogText_OutputPort[0].invoke(
1091 this->m_FileWriteErrorThrottle++;
1096 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1097 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1105 if (this->m_eventOut_OutputPort[0].isConnected()) {
1109 #if FW_AMPCS_COMPATIBLE 1111 _status = _logBuff.
serialize(static_cast<U8>(1));
1114 static_cast<FwAssertArgType>(_status)
1121 static_cast<FwAssertArgType>(_status)
1124 this->m_eventOut_OutputPort[0].
invoke(
1133 #if FW_ENABLE_TEXT_LOGGING 1134 if (this->m_LogText_OutputPort[0].isConnected()) {
1135 #if FW_OBJECT_NAMES == 1 1136 const char* _formatString =
1137 "(%s) %s: Could not write to file %s";
1139 const char* _formatString =
1140 "%s: Could not write to file %s";
1147 this->m_objName.toChar(),
1153 this->m_LogText_OutputPort[0].invoke(
1174 this->m_InvalidReceiveModeThrottle++;
1179 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1180 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1188 if (this->m_eventOut_OutputPort[0].isConnected()) {
1192 #if FW_AMPCS_COMPATIBLE 1194 _status = _logBuff.
serialize(static_cast<U8>(2));
1197 static_cast<FwAssertArgType>(_status)
1201 #if FW_AMPCS_COMPATIBLE 1204 static_cast<U8>(
sizeof(U32))
1208 static_cast<FwAssertArgType>(_status)
1211 _status = _logBuff.
serialize(packetType);
1214 static_cast<FwAssertArgType>(_status)
1217 #if FW_AMPCS_COMPATIBLE 1220 static_cast<U8>(
sizeof(U32))
1224 static_cast<FwAssertArgType>(_status)
1230 static_cast<FwAssertArgType>(_status)
1233 this->m_eventOut_OutputPort[0].
invoke(
1242 #if FW_ENABLE_TEXT_LOGGING 1243 if (this->m_LogText_OutputPort[0].isConnected()) {
1244 #if FW_OBJECT_NAMES == 1 1245 const char* _formatString =
1246 "(%s) %s: Packet type %" PRIu32
" received in mode %" PRIu32
"";
1248 const char* _formatString =
1249 "%s: Packet type %" PRIu32
" received in mode %" PRIu32
"";
1256 this->m_objName.toChar(),
1258 "InvalidReceiveMode ",
1263 this->m_LogText_OutputPort[0].invoke(
1284 this->m_PacketOutOfBoundsThrottle++;
1289 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1290 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1298 if (this->m_eventOut_OutputPort[0].isConnected()) {
1302 #if FW_AMPCS_COMPATIBLE 1304 _status = _logBuff.
serialize(static_cast<U8>(2));
1307 static_cast<FwAssertArgType>(_status)
1311 #if FW_AMPCS_COMPATIBLE 1314 static_cast<U8>(
sizeof(U32))
1318 static_cast<FwAssertArgType>(_status)
1321 _status = _logBuff.
serialize(packetIndex);
1324 static_cast<FwAssertArgType>(_status)
1330 static_cast<FwAssertArgType>(_status)
1333 this->m_eventOut_OutputPort[0].
invoke(
1342 #if FW_ENABLE_TEXT_LOGGING 1343 if (this->m_LogText_OutputPort[0].isConnected()) {
1344 #if FW_OBJECT_NAMES == 1 1345 const char* _formatString =
1346 "(%s) %s: Packet %" PRIu32
" out of bounds for file %s";
1348 const char* _formatString =
1349 "%s: Packet %" PRIu32
" out of bounds for file %s";
1356 this->m_objName.toChar(),
1358 "PacketOutOfBounds ",
1363 this->m_LogText_OutputPort[0].invoke(
1384 this->m_PacketOutOfOrderThrottle++;
1389 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1390 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1398 if (this->m_eventOut_OutputPort[0].isConnected()) {
1402 #if FW_AMPCS_COMPATIBLE 1404 _status = _logBuff.
serialize(static_cast<U8>(2));
1407 static_cast<FwAssertArgType>(_status)
1411 #if FW_AMPCS_COMPATIBLE 1414 static_cast<U8>(
sizeof(U32))
1418 static_cast<FwAssertArgType>(_status)
1421 _status = _logBuff.
serialize(packetIndex);
1424 static_cast<FwAssertArgType>(_status)
1427 #if FW_AMPCS_COMPATIBLE 1430 static_cast<U8>(
sizeof(U32))
1434 static_cast<FwAssertArgType>(_status)
1437 _status = _logBuff.
serialize(lastPacketIndex);
1440 static_cast<FwAssertArgType>(_status)
1443 this->m_eventOut_OutputPort[0].
invoke(
1452 #if FW_ENABLE_TEXT_LOGGING 1453 if (this->m_LogText_OutputPort[0].isConnected()) {
1454 #if FW_OBJECT_NAMES == 1 1455 const char* _formatString =
1456 "(%s) %s: Received packet %" PRIu32
" after packet %" PRIu32
"";
1458 const char* _formatString =
1459 "%s: Received packet %" PRIu32
" after packet %" PRIu32
"";
1466 this->m_objName.toChar(),
1468 "PacketOutOfOrder ",
1473 this->m_LogText_OutputPort[0].invoke(
1491 this->m_PacketDuplicateThrottle++;
1496 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1497 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1505 if (this->m_eventOut_OutputPort[0].isConnected()) {
1509 #if FW_AMPCS_COMPATIBLE 1511 _status = _logBuff.
serialize(static_cast<U8>(1));
1514 static_cast<FwAssertArgType>(_status)
1518 #if FW_AMPCS_COMPATIBLE 1521 static_cast<U8>(
sizeof(U32))
1525 static_cast<FwAssertArgType>(_status)
1528 _status = _logBuff.
serialize(packetIndex);
1531 static_cast<FwAssertArgType>(_status)
1534 this->m_eventOut_OutputPort[0].
invoke(
1543 #if FW_ENABLE_TEXT_LOGGING 1544 if (this->m_LogText_OutputPort[0].isConnected()) {
1545 #if FW_OBJECT_NAMES == 1 1546 const char* _formatString =
1547 "(%s) %s: Received a duplicate of packet %" PRIu32
"";
1549 const char* _formatString =
1550 "%s: Received a duplicate of packet %" PRIu32
"";
1557 this->m_objName.toChar(),
1563 this->m_LogText_OutputPort[0].invoke(
1578 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1579 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1587 if (this->m_eventOut_OutputPort[0].isConnected()) {
1590 #if FW_AMPCS_COMPATIBLE 1593 _status = _logBuff.
serialize(static_cast<U8>(0));
1596 static_cast<FwAssertArgType>(_status)
1600 this->m_eventOut_OutputPort[0].
invoke(
1609 #if FW_ENABLE_TEXT_LOGGING 1610 if (this->m_LogText_OutputPort[0].isConnected()) {
1611 #if FW_OBJECT_NAMES == 1 1612 const char* _formatString =
1613 "(%s) %s: Received CANCEL packet";
1615 const char* _formatString =
1616 "%s: Received CANCEL packet";
1623 this->m_objName.toChar(),
1628 this->m_LogText_OutputPort[0].invoke(
1643 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1644 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
1652 if (this->m_eventOut_OutputPort[0].isConnected()) {
1656 #if FW_AMPCS_COMPATIBLE 1658 _status = _logBuff.
serialize(static_cast<U8>(1));
1661 static_cast<FwAssertArgType>(_status)
1665 #if FW_AMPCS_COMPATIBLE 1668 static_cast<U8>(
sizeof(I32))
1672 static_cast<FwAssertArgType>(_status)
1678 static_cast<FwAssertArgType>(_status)
1681 this->m_eventOut_OutputPort[0].
invoke(
1690 #if FW_ENABLE_TEXT_LOGGING 1691 if (this->m_LogText_OutputPort[0].isConnected()) {
1692 #if FW_OBJECT_NAMES == 1 1693 const char* _formatString =
1694 "(%s) %s: Unable to decode file packet. Status: %" PRIi32
"";
1696 const char* _formatString =
1697 "%s: Unable to decode file packet. Status: %" PRIi32
"";
1704 this->m_objName.toChar(),
1710 this->m_LogText_OutputPort[0].invoke(
1728 this->m_FileWriteErrorThrottle = 0;
1735 this->m_InvalidReceiveModeThrottle = 0;
1742 this->m_PacketOutOfBoundsThrottle = 0;
1749 this->m_PacketOutOfOrderThrottle = 0;
1756 this->m_PacketDuplicateThrottle = 0;
1769 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1771 this->m_timeCaller_OutputPort[0].isConnected() &&
1774 this->m_timeCaller_OutputPort[0].
invoke(_tlmTime);
1781 static_cast<FwAssertArgType>(_stat)
1788 this->m_tlmOut_OutputPort[0].
invoke(
1802 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1804 this->m_timeCaller_OutputPort[0].isConnected() &&
1807 this->m_timeCaller_OutputPort[0].
invoke(_tlmTime);
1814 static_cast<FwAssertArgType>(_stat)
1821 this->m_tlmOut_OutputPort[0].
invoke(
1835 if (this->m_tlmOut_OutputPort[0].isConnected()) {
1837 this->m_timeCaller_OutputPort[0].isConnected() &&
1840 this->m_timeCaller_OutputPort[0].
invoke(_tlmTime);
1847 static_cast<FwAssertArgType>(_stat)
1854 this->m_tlmOut_OutputPort[0].
invoke(
1869 if (this->m_timeCaller_OutputPort[0].isConnected()) {
1871 this->m_timeCaller_OutputPort[0].
invoke(_time);
1886 ComponentIpcSerializableBuffer _msg;
1896 static_cast<FwAssertArgType>(_msgStatus)
1906 static_cast<FwAssertArgType>(_deserStatus)
1909 MsgTypeEnum _msgType =
static_cast<MsgTypeEnum
>(_desMsg);
1911 if (_msgType == FILEUPLINK_COMPONENT_EXIT) {
1916 _deserStatus = _msg.deserialize(portNum);
1919 static_cast<FwAssertArgType>(_deserStatus)
1924 case BUFFERSENDIN_BUFFERSEND: {
1927 _deserStatus = _msg.deserialize(fwBuffer);
1930 static_cast<FwAssertArgType>(_deserStatus)
1945 _deserStatus = _msg.deserialize(key);
1948 static_cast<FwAssertArgType>(_deserStatus)
1970 void FileUplinkComponentBase ::
1971 m_p_bufferSendIn_in(
1979 compPtr->bufferSendIn_handlerBase(
1985 void FileUplinkComponentBase ::
1994 compPtr->pingIn_handlerBase(
Serialization/Deserialization operation was successful.
Throttle reset count for InvalidReceiveMode.
void tlmWrite_FilesReceived(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
void addCallPort(InputTimePort *callPort)
Register an input port.
bool isConnected_eventOut_OutputPort(FwIndexType portNum)
void set_bufferSendOut_OutputPort(FwIndexType portNum, Fw::InputBufferSendPort *port)
Connect port to bufferSendOut[portNum].
FwIndexType getNum_bufferSendOut_OutputPorts() const
bool isConnected_pingOut_OutputPort(FwIndexType portNum)
void log_ACTIVITY_HI_UplinkCanceled() const
Status
status returned from the queue send function
void log_WARNING_HI_BadChecksum(const Fw::StringBase &fileName, U32 computed, U32 read) const
Error decoding file packet.
void set_eventOut_OutputPort(FwIndexType portNum, Fw::InputLogPort *port)
Connect port to eventOut[portNum].
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
bool isConnected_tlmOut_OutputPort(FwIndexType portNum)
void log_WARNING_HI_InvalidReceiveMode_ThrottleClear()
Reset throttle value for InvalidReceiveMode.
FwIndexType getNum_bufferSendIn_InputPorts() const
PlatformSizeType FwSizeType
void invoke(U32 key) const
Invoke a port interface.
void init()
Initialization function.
virtual void bufferSendIn_handler(FwIndexType portNum, Fw::Buffer &fwBuffer)=0
Handler for input port bufferSendIn.
PlatformIndexType FwIndexType
The File Uplink component encountered a duplicate packet during file receipt.
Throttle reset count for FileWriteError.
Os::Queue m_queue
queue object for active component
bool isConnected_timeCaller_OutputPort(FwIndexType portNum)
void addCallPort(InputTlmPort *callPort)
Register an input port.
The File Uplink component received a CANCEL packet.
void init()
Object initializer.
void log_WARNING_HI_DecodeError(I32 status) const
FwIndexType getNum_pingIn_InputPorts() const
SerializeStatus
forward declaration for string
An error occurred writing to a file.
Message will block until space is available.
void log_WARNING_HI_PacketDuplicate(U32 packetIndex)
void log_ACTIVITY_HI_FileReceived(const Fw::StringBase &fileName) const
void log_WARNING_HI_PacketOutOfOrder_ThrottleClear()
Reset throttle value for PacketOutOfOrder.
virtual void pingIn_preMsgHook(FwIndexType portNum, U32 key)
Pre-message hook for async input port pingIn.
void log_WARNING_HI_PacketOutOfBounds(U32 packetIndex, const Fw::StringBase &fileName)
void init()
Initialization function.
message to exit active component task
Fw::InputBufferSendPort * get_bufferSendIn_InputPort(FwIndexType portNum)
During receipt of a file, the computed checksum value did not match the stored value.
Os::Queue::Status createQueue(FwSizeType depth, FwSizeType msgSize)
void log_WARNING_HI_PacketDuplicate_ThrottleClear()
Reset throttle value for PacketDuplicate.
#define FW_MIN(a, b)
MIN macro.
void invoke(Fw::Buffer &fwBuffer) const
Invoke a port interface.
An error occurred opening a file.
void bufferSendIn_handlerBase(FwIndexType portNum, Fw::Buffer &fwBuffer)
Handler base-class function for input port bufferSendIn.
FwIndexType getNum_pingOut_OutputPorts() const
void init()
Initialization function.
void addCallPort(InputBufferSendPort *callPort)
Register an input port.
void invoke(Fw::Time &time) const
Invoke a port interface.
void log_WARNING_HI_FileWriteError(const Fw::StringBase &fileName)
FileUplinkComponentBase(const char *compName="")
Construct FileUplinkComponentBase object.
const char * toChar() const
No time base has been established.
FwIndexType getNum_eventOut_OutputPorts() const
void tlmWrite_Warnings(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
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
A serious but recoverable event.
Errors dispatching messages.
Channel ID for PacketsReceived.
bool isConnected_bufferSendOut_OutputPort(FwIndexType portNum)
void log_WARNING_HI_FileWriteError_ThrottleClear()
Reset throttle value for FileWriteError.
void invoke(FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val) const
Invoke a port interface.
void log_WARNING_HI_FileOpenError(const Fw::StringBase &fileName) const
FormatStatus format(const CHAR *formatString,...)
write formatted string to buffer
void init()
Initialization function.
virtual ~FileUplinkComponentBase()
Destroy FileUplinkComponentBase object.
uint8_t U8
8-bit unsigned integer
void pingIn_handlerBase(FwIndexType portNum, U32 key)
Handler base-class function for input port pingIn.
void log_WARNING_HI_InvalidReceiveMode(U32 packetType, U32 mode)
Svc::InputPingPort * get_pingIn_InputPort(FwIndexType portNum)
Important informational events.
void init()
Initialization function.
Throttle reset count for PacketOutOfBounds.
void invoke(FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args) const
Invoke a port interface.
virtual void bufferSendIn_preMsgHook(FwIndexType portNum, Fw::Buffer &fwBuffer)
Pre-message hook for async input port bufferSendIn.
PlatformQueuePriorityType FwQueuePriorityType
The File Uplink component successfully received a file.
FwIndexType getNum_timeCaller_OutputPorts() const
A message was sent requesting an exit of the loop.
void bufferSendOut_out(FwIndexType portNum, Fw::Buffer &fwBuffer)
Invoke output port bufferSendOut.
virtual void pingIn_handler(FwIndexType portNum, U32 key)=0
Handler for input port pingIn.
During receipt of a file, the File Uplink component encountered a packet with offset and size out of ...
void tlmWrite_PacketsReceived(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
Throttle reset count for PacketOutOfOrder.
void set_timeCaller_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeCaller[portNum].
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
void set_pingOut_OutputPort(FwIndexType portNum, Svc::InputPingPort *port)
Connect port to pingOut[portNum].
void addCallPort(InputLogPort *callPort)
Register an input port.
message sent/received okay
virtual SerializeStatus serialize(SerializeBufferBase &buffer) const
serialization function
Message will return with status when space is unavailable.
The File Uplink component received a packet with a type that was invalid for the current receive mode...
Status receive(U8 *destination, FwSizeType capacity, BlockingType blockType, FwSizeType &actualSize, FwQueuePriorityType &priority) override
receive a message from the queue through delegate
Throttle reset count for PacketDuplicate.
void set_tlmOut_OutputPort(FwIndexType portNum, Fw::InputTlmPort *port)
Connect port to tlmOut[portNum].
Channel ID for FilesReceived.
void log_WARNING_HI_PacketOutOfBounds_ThrottleClear()
Reset throttle value for PacketOutOfBounds.
void pingOut_out(FwIndexType portNum, U32 key)
Invoke output port pingOut.
void log_WARNING_HI_PacketOutOfOrder(U32 packetIndex, U32 lastPacketIndex)
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects) ...
The File Uplink component encountered an out-of-order packet during file receipt. ...
FwIndexType getNum_tlmOut_OutputPorts() const
#define FW_LOG_STRING_MAX_SIZE
Max size of log string parameter type.
virtual const CHAR * toChar() const =0