9 #if FW_ENABLE_TEXT_LOGGING 41 class ComponentIpcSerializableBuffer :
51 MAX_DATA_SIZE =
sizeof(BuffUnion),
53 SERIALIZATION_SIZE = DATA_OFFSET + MAX_DATA_SIZE
56 ComponentIpcSerializableBuffer() :
Fw::LinearBufferBase(m_buff, sizeof(m_buff)) {
62 U8 m_buff[SERIALIZATION_SIZE];
105 if ((this->m_dataBuffer.getSize() + sizeDelta) <= this->m_dataBuffer.getCapacity()) {
107 status = this->m_dataBuffer.serializeFrom(
id);
109 status = this->m_dataBuffer.serializeSize(size);
113 this->m_dataSize += sizeDelta;
128 if (this->m_dataBuffer.getSize() + sizeDelta <= this->m_dataBuffer.getCapacity()) {
130 status = this->m_dataBuffer.serializeFrom(
id);
132 status = this->m_dataBuffer.serializeFrom(elt);
134 this->m_dataSize += sizeDelta;
155 #if !FW_DIRECT_PORT_CALLS 162 this->m_cmdIn_InputPort[port].
init();
167 this->m_cmdIn_InputPort[port].
setPortNum(port);
169 #if FW_OBJECT_NAMES == 1 173 this->m_objName.toChar(),
176 this->m_cmdIn_InputPort[port].setObjName(portName.
toChar());
181 #if !FW_DIRECT_PORT_CALLS 188 this->m_pingIn_InputPort[port].
init();
193 this->m_pingIn_InputPort[port].
setPortNum(port);
195 #if FW_OBJECT_NAMES == 1 199 this->m_objName.toChar(),
202 this->m_pingIn_InputPort[port].setObjName(portName.
toChar());
207 #if !FW_DIRECT_PORT_CALLS 214 this->m_schedIn_InputPort[port].
init();
219 this->m_schedIn_InputPort[port].
setPortNum(port);
221 #if FW_OBJECT_NAMES == 1 225 this->m_objName.toChar(),
228 this->m_schedIn_InputPort[port].setObjName(portName.
toChar());
233 #if !FW_DIRECT_PORT_CALLS && FW_ENABLE_TEXT_LOGGING 237 port < static_cast<FwIndexType>(this->getNum_LogText_OutputPorts());
240 this->m_LogText_OutputPort[port].
init();
242 #if FW_OBJECT_NAMES == 1 246 this->m_objName.toChar(),
249 this->m_LogText_OutputPort[port].setObjName(portName.
toChar());
254 #if !FW_DIRECT_PORT_CALLS 261 this->m_cmdRegOut_OutputPort[port].
init();
263 #if FW_OBJECT_NAMES == 1 267 this->m_objName.toChar(),
270 this->m_cmdRegOut_OutputPort[port].setObjName(portName.
toChar());
275 #if !FW_DIRECT_PORT_CALLS 282 this->m_cmdResponseOut_OutputPort[port].
init();
284 #if FW_OBJECT_NAMES == 1 288 this->m_objName.toChar(),
291 this->m_cmdResponseOut_OutputPort[port].setObjName(portName.
toChar());
296 #if !FW_DIRECT_PORT_CALLS 303 this->m_eventOut_OutputPort[port].
init();
305 #if FW_OBJECT_NAMES == 1 309 this->m_objName.toChar(),
312 this->m_eventOut_OutputPort[port].setObjName(portName.
toChar());
317 #if !FW_DIRECT_PORT_CALLS 324 this->m_productGetOut_OutputPort[port].
init();
326 #if FW_OBJECT_NAMES == 1 330 this->m_objName.toChar(),
333 this->m_productGetOut_OutputPort[port].setObjName(portName.
toChar());
338 #if !FW_DIRECT_PORT_CALLS 345 this->m_productSendOut_OutputPort[port].
init();
347 #if FW_OBJECT_NAMES == 1 351 this->m_objName.toChar(),
354 this->m_productSendOut_OutputPort[port].setObjName(portName.
toChar());
359 #if !FW_DIRECT_PORT_CALLS 366 this->m_timeCaller_OutputPort[port].
init();
368 #if FW_OBJECT_NAMES == 1 372 this->m_objName.toChar(),
375 this->m_timeCaller_OutputPort[port].setObjName(portName.
toChar());
380 #if !FW_DIRECT_PORT_CALLS 387 this->m_tlmOut_OutputPort[port].
init();
389 #if FW_OBJECT_NAMES == 1 393 this->m_objName.toChar(),
396 this->m_tlmOut_OutputPort[port].setObjName(portName.
toChar());
401 #if !FW_DIRECT_PORT_CALLS 408 this->m_pingOut_OutputPort[port].
init();
410 #if FW_OBJECT_NAMES == 1 414 this->m_objName.toChar(),
417 this->m_pingOut_OutputPort[port].setObjName(portName.
toChar());
425 static_cast<FwSizeType>(ComponentIpcSerializableBuffer::SERIALIZATION_SIZE)
429 static_cast<FwAssertArgType>(qStat)
433 #if !FW_DIRECT_PORT_CALLS 444 static_cast<FwAssertArgType>(portNum)
447 return &this->m_cmdIn_InputPort[portNum];
452 #if !FW_DIRECT_PORT_CALLS 463 static_cast<FwAssertArgType>(portNum)
466 return &this->m_pingIn_InputPort[portNum];
474 static_cast<FwAssertArgType>(portNum)
477 return &this->m_schedIn_InputPort[portNum];
482 #if !FW_DIRECT_PORT_CALLS 488 #if FW_ENABLE_TEXT_LOGGING == 1 490 void FileManagerComponentBase ::
491 set_LogText_OutputPort(
497 (0 <= portNum) && (portNum < this->getNum_LogText_OutputPorts()),
498 static_cast<FwAssertArgType>(portNum)
501 this->m_LogText_OutputPort[portNum].addCallPort(port);
514 static_cast<FwAssertArgType>(portNum)
517 this->m_cmdRegOut_OutputPort[portNum].
addCallPort(port);
528 static_cast<FwAssertArgType>(portNum)
531 this->m_cmdResponseOut_OutputPort[portNum].
addCallPort(port);
542 static_cast<FwAssertArgType>(portNum)
545 this->m_eventOut_OutputPort[portNum].
addCallPort(port);
556 static_cast<FwAssertArgType>(portNum)
559 this->m_productGetOut_OutputPort[portNum].
addCallPort(port);
570 static_cast<FwAssertArgType>(portNum)
573 this->m_productSendOut_OutputPort[portNum].
addCallPort(port);
584 static_cast<FwAssertArgType>(portNum)
587 this->m_timeCaller_OutputPort[portNum].
addCallPort(port);
598 static_cast<FwAssertArgType>(portNum)
601 this->m_tlmOut_OutputPort[portNum].
addCallPort(port);
606 #if !FW_DIRECT_PORT_CALLS 620 static_cast<FwAssertArgType>(portNum)
623 this->m_pingOut_OutputPort[portNum].
addCallPort(port);
628 #if !FW_DIRECT_PORT_CALLS && FW_PORT_SERIALIZATION 634 #if FW_ENABLE_TEXT_LOGGING == 1 636 void FileManagerComponentBase ::
637 set_LogText_OutputPort(
639 Fw::InputSerializePort* port
643 (0 <= portNum) && (portNum < this->getNum_LogText_OutputPorts()),
644 static_cast<FwAssertArgType>(portNum)
647 this->m_LogText_OutputPort[portNum].registerSerialPort(port);
655 Fw::InputSerializePort* port
660 static_cast<FwAssertArgType>(portNum)
663 this->m_cmdRegOut_OutputPort[portNum].registerSerialPort(port);
669 Fw::InputSerializePort* port
674 static_cast<FwAssertArgType>(portNum)
677 this->m_cmdResponseOut_OutputPort[portNum].registerSerialPort(port);
683 Fw::InputSerializePort* port
688 static_cast<FwAssertArgType>(portNum)
691 this->m_eventOut_OutputPort[portNum].registerSerialPort(port);
697 Fw::InputSerializePort* port
702 static_cast<FwAssertArgType>(portNum)
705 this->m_productSendOut_OutputPort[portNum].registerSerialPort(port);
711 Fw::InputSerializePort* port
716 static_cast<FwAssertArgType>(portNum)
719 this->m_timeCaller_OutputPort[portNum].registerSerialPort(port);
725 Fw::InputSerializePort* port
730 static_cast<FwAssertArgType>(portNum)
733 this->m_tlmOut_OutputPort[portNum].registerSerialPort(port);
738 #if !FW_DIRECT_PORT_CALLS && FW_PORT_SERIALIZATION 747 Fw::InputSerializePort* port
752 static_cast<FwAssertArgType>(portNum)
755 this->m_pingOut_OutputPort[portNum].registerSerialPort(port);
832 #if !FW_DIRECT_PORT_CALLS 838 #if FW_ENABLE_TEXT_LOGGING == 1 840 bool FileManagerComponentBase ::
841 isConnected_LogText_OutputPort(
FwIndexType portNum)
const 844 (0 <= portNum) && (portNum < this->getNum_LogText_OutputPorts()),
845 static_cast<FwAssertArgType>(portNum)
848 return this->m_LogText_OutputPort[portNum].isConnected();
858 static_cast<FwAssertArgType>(portNum)
861 return this->m_cmdRegOut_OutputPort[portNum].
isConnected();
869 static_cast<FwAssertArgType>(portNum)
872 return this->m_cmdResponseOut_OutputPort[portNum].
isConnected();
880 static_cast<FwAssertArgType>(portNum)
883 return this->m_eventOut_OutputPort[portNum].
isConnected();
891 static_cast<FwAssertArgType>(portNum)
894 return this->m_productGetOut_OutputPort[portNum].
isConnected();
902 static_cast<FwAssertArgType>(portNum)
905 return this->m_productSendOut_OutputPort[portNum].
isConnected();
913 static_cast<FwAssertArgType>(portNum)
916 return this->m_timeCaller_OutputPort[portNum].
isConnected();
924 static_cast<FwAssertArgType>(portNum)
927 return this->m_tlmOut_OutputPort[portNum].
isConnected();
932 #if !FW_DIRECT_PORT_CALLS 943 static_cast<FwAssertArgType>(portNum)
946 return this->m_pingOut_OutputPort[portNum].
isConnected();
967 FW_ASSERT(opCode >= idBase, static_cast<FwAssertArgType>(opCode), static_cast<FwAssertArgType>(idBase));
970 switch (opCode - idBase) {
1072 static_cast<FwAssertArgType>(portNum)
1080 ComponentIpcSerializableBuffer msg;
1084 _status = msg.serializeFrom(
1085 static_cast<FwEnumStoreType>(PINGIN_PING)
1089 static_cast<FwAssertArgType>(_status)
1093 _status = msg.serializeFrom(portNum);
1096 static_cast<FwAssertArgType>(_status)
1100 _status = msg.serializeFrom(key);
1103 static_cast<FwAssertArgType>(_status)
1110 if (qStatus == Os::Queue::Status::FULL) {
1117 static_cast<FwAssertArgType>(qStatus)
1130 static_cast<FwAssertArgType>(portNum)
1157 #if !FW_DIRECT_PORT_CALLS 1171 static_cast<FwAssertArgType>(portNum)
1175 this->m_pingOut_OutputPort[portNum].isConnected(),
1176 static_cast<FwAssertArgType>(portNum)
1178 this->m_pingOut_OutputPort[portNum].
invoke(
1192 ComponentIpcSerializableBuffer msg;
1196 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(INT_IF_RUN));
1199 static_cast<FwAssertArgType>(_status)
1203 _status = msg.serializeFrom(static_cast<FwIndexType>(0));
1206 static_cast<FwAssertArgType>(_status)
1213 if (qStatus == Os::Queue::Status::FULL) {
1220 static_cast<FwAssertArgType>(qStatus)
1236 this->cmdResponseOut_out(0, opCode, cmdSeq, response);
1257 ComponentIpcSerializableBuffer msg;
1261 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_CREATEDIRECTORY));
1264 static_cast<FwAssertArgType>(_status)
1270 _status = msg.serializeFrom(port);
1273 static_cast<FwAssertArgType>(_status)
1276 _status = msg.serializeFrom(opCode);
1279 static_cast<FwAssertArgType>(_status)
1282 _status = msg.serializeFrom(cmdSeq);
1285 static_cast<FwAssertArgType>(_status)
1288 _status = msg.serializeFrom(args);
1291 static_cast<FwAssertArgType>(_status)
1300 static_cast<FwAssertArgType>(qStatus)
1316 ComponentIpcSerializableBuffer msg;
1320 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_MOVEFILE));
1323 static_cast<FwAssertArgType>(_status)
1329 _status = msg.serializeFrom(port);
1332 static_cast<FwAssertArgType>(_status)
1335 _status = msg.serializeFrom(opCode);
1338 static_cast<FwAssertArgType>(_status)
1341 _status = msg.serializeFrom(cmdSeq);
1344 static_cast<FwAssertArgType>(_status)
1347 _status = msg.serializeFrom(args);
1350 static_cast<FwAssertArgType>(_status)
1359 static_cast<FwAssertArgType>(qStatus)
1375 ComponentIpcSerializableBuffer msg;
1379 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_REMOVEDIRECTORY));
1382 static_cast<FwAssertArgType>(_status)
1388 _status = msg.serializeFrom(port);
1391 static_cast<FwAssertArgType>(_status)
1394 _status = msg.serializeFrom(opCode);
1397 static_cast<FwAssertArgType>(_status)
1400 _status = msg.serializeFrom(cmdSeq);
1403 static_cast<FwAssertArgType>(_status)
1406 _status = msg.serializeFrom(args);
1409 static_cast<FwAssertArgType>(_status)
1418 static_cast<FwAssertArgType>(qStatus)
1434 ComponentIpcSerializableBuffer msg;
1438 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_REMOVEFILE));
1441 static_cast<FwAssertArgType>(_status)
1447 _status = msg.serializeFrom(port);
1450 static_cast<FwAssertArgType>(_status)
1453 _status = msg.serializeFrom(opCode);
1456 static_cast<FwAssertArgType>(_status)
1459 _status = msg.serializeFrom(cmdSeq);
1462 static_cast<FwAssertArgType>(_status)
1465 _status = msg.serializeFrom(args);
1468 static_cast<FwAssertArgType>(_status)
1477 static_cast<FwAssertArgType>(qStatus)
1493 ComponentIpcSerializableBuffer msg;
1497 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_APPENDFILE));
1500 static_cast<FwAssertArgType>(_status)
1506 _status = msg.serializeFrom(port);
1509 static_cast<FwAssertArgType>(_status)
1512 _status = msg.serializeFrom(opCode);
1515 static_cast<FwAssertArgType>(_status)
1518 _status = msg.serializeFrom(cmdSeq);
1521 static_cast<FwAssertArgType>(_status)
1524 _status = msg.serializeFrom(args);
1527 static_cast<FwAssertArgType>(_status)
1536 static_cast<FwAssertArgType>(qStatus)
1552 ComponentIpcSerializableBuffer msg;
1556 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_FILESIZE));
1559 static_cast<FwAssertArgType>(_status)
1565 _status = msg.serializeFrom(port);
1568 static_cast<FwAssertArgType>(_status)
1571 _status = msg.serializeFrom(opCode);
1574 static_cast<FwAssertArgType>(_status)
1577 _status = msg.serializeFrom(cmdSeq);
1580 static_cast<FwAssertArgType>(_status)
1583 _status = msg.serializeFrom(args);
1586 static_cast<FwAssertArgType>(_status)
1595 static_cast<FwAssertArgType>(qStatus)
1611 ComponentIpcSerializableBuffer msg;
1615 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_LISTDIRECTORY));
1618 static_cast<FwAssertArgType>(_status)
1624 _status = msg.serializeFrom(port);
1627 static_cast<FwAssertArgType>(_status)
1630 _status = msg.serializeFrom(opCode);
1633 static_cast<FwAssertArgType>(_status)
1636 _status = msg.serializeFrom(cmdSeq);
1639 static_cast<FwAssertArgType>(_status)
1642 _status = msg.serializeFrom(args);
1645 static_cast<FwAssertArgType>(_status)
1654 static_cast<FwAssertArgType>(qStatus)
1670 ComponentIpcSerializableBuffer msg;
1674 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_CALCULATECRC));
1677 static_cast<FwAssertArgType>(_status)
1683 _status = msg.serializeFrom(port);
1686 static_cast<FwAssertArgType>(_status)
1689 _status = msg.serializeFrom(opCode);
1692 static_cast<FwAssertArgType>(_status)
1695 _status = msg.serializeFrom(cmdSeq);
1698 static_cast<FwAssertArgType>(_status)
1701 _status = msg.serializeFrom(args);
1704 static_cast<FwAssertArgType>(_status)
1713 static_cast<FwAssertArgType>(qStatus)
1729 ComponentIpcSerializableBuffer msg;
1733 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_GENERATEDP));
1736 static_cast<FwAssertArgType>(_status)
1742 _status = msg.serializeFrom(port);
1745 static_cast<FwAssertArgType>(_status)
1748 _status = msg.serializeFrom(opCode);
1751 static_cast<FwAssertArgType>(_status)
1754 _status = msg.serializeFrom(cmdSeq);
1757 static_cast<FwAssertArgType>(_status)
1760 _status = msg.serializeFrom(args);
1763 static_cast<FwAssertArgType>(_status)
1772 static_cast<FwAssertArgType>(qStatus)
1896 this->timeCaller_out(0, _logTime);
1906 #if FW_AMPCS_COMPATIBLE 1911 static_cast<FwAssertArgType>(_status)
1921 static_cast<FwAssertArgType>(_status)
1924 #if FW_AMPCS_COMPATIBLE 1927 static_cast<U8>(
sizeof(U32))
1931 static_cast<FwAssertArgType>(_status)
1937 static_cast<FwAssertArgType>(_status)
1950 #if FW_ENABLE_TEXT_LOGGING 1951 if (this->isConnected_LogText_OutputPort(0)) {
1952 #if FW_OBJECT_NAMES == 1 1953 const char* _formatString =
1954 "(%s) %s: Could not create directory %s, returned status %" PRIu32
"";
1956 const char* _formatString =
1957 "%s: Could not create directory %s, returned status %" PRIu32
"";
1961 (void) _logString.
format(
1964 this->m_objName.toChar(),
1966 "DirectoryCreateError ",
1991 this->timeCaller_out(0, _logTime);
2001 #if FW_AMPCS_COMPATIBLE 2006 static_cast<FwAssertArgType>(_status)
2016 static_cast<FwAssertArgType>(_status)
2019 #if FW_AMPCS_COMPATIBLE 2022 static_cast<U8>(
sizeof(U32))
2026 static_cast<FwAssertArgType>(_status)
2032 static_cast<FwAssertArgType>(_status)
2045 #if FW_ENABLE_TEXT_LOGGING 2046 if (this->isConnected_LogText_OutputPort(0)) {
2047 #if FW_OBJECT_NAMES == 1 2048 const char* _formatString =
2049 "(%s) %s: Could not remove directory %s, returned status %" PRIu32
"";
2051 const char* _formatString =
2052 "%s: Could not remove directory %s, returned status %" PRIu32
"";
2056 (void) _logString.
format(
2059 this->m_objName.toChar(),
2061 "DirectoryRemoveError ",
2087 this->timeCaller_out(0, _logTime);
2097 #if FW_AMPCS_COMPATIBLE 2102 static_cast<FwAssertArgType>(_status)
2112 static_cast<FwAssertArgType>(_status)
2121 static_cast<FwAssertArgType>(_status)
2124 #if FW_AMPCS_COMPATIBLE 2127 static_cast<U8>(
sizeof(U32))
2131 static_cast<FwAssertArgType>(_status)
2137 static_cast<FwAssertArgType>(_status)
2150 #if FW_ENABLE_TEXT_LOGGING 2151 if (this->isConnected_LogText_OutputPort(0)) {
2152 #if FW_OBJECT_NAMES == 1 2153 const char* _formatString =
2154 "(%s) %s: Could not move file %s to file %s, returned status %" PRIu32
"";
2156 const char* _formatString =
2157 "%s: Could not move file %s to file %s, returned status %" PRIu32
"";
2161 (void) _logString.
format(
2164 this->m_objName.toChar(),
2192 this->timeCaller_out(0, _logTime);
2202 #if FW_AMPCS_COMPATIBLE 2207 static_cast<FwAssertArgType>(_status)
2217 static_cast<FwAssertArgType>(_status)
2220 #if FW_AMPCS_COMPATIBLE 2223 static_cast<U8>(
sizeof(U32))
2227 static_cast<FwAssertArgType>(_status)
2233 static_cast<FwAssertArgType>(_status)
2246 #if FW_ENABLE_TEXT_LOGGING 2247 if (this->isConnected_LogText_OutputPort(0)) {
2248 #if FW_OBJECT_NAMES == 1 2249 const char* _formatString =
2250 "(%s) %s: Could not remove file %s, returned status %" PRIu32
"";
2252 const char* _formatString =
2253 "%s: Could not remove file %s, returned status %" PRIu32
"";
2257 (void) _logString.
format(
2260 this->m_objName.toChar(),
2288 this->timeCaller_out(0, _logTime);
2298 #if FW_AMPCS_COMPATIBLE 2303 static_cast<FwAssertArgType>(_status)
2313 static_cast<FwAssertArgType>(_status)
2322 static_cast<FwAssertArgType>(_status)
2325 #if FW_AMPCS_COMPATIBLE 2328 static_cast<U8>(
sizeof(U32))
2332 static_cast<FwAssertArgType>(_status)
2338 static_cast<FwAssertArgType>(_status)
2351 #if FW_ENABLE_TEXT_LOGGING 2352 if (this->isConnected_LogText_OutputPort(0)) {
2353 #if FW_OBJECT_NAMES == 1 2354 const char* _formatString =
2355 "(%s) %s: Appending %s onto %s failed with status %" PRIu32
"";
2357 const char* _formatString =
2358 "%s: Appending %s onto %s failed with status %" PRIu32
"";
2362 (void) _logString.
format(
2365 this->m_objName.toChar(),
2367 "AppendFileFailed ",
2393 this->timeCaller_out(0, _logTime);
2403 #if FW_AMPCS_COMPATIBLE 2408 static_cast<FwAssertArgType>(_status)
2418 static_cast<FwAssertArgType>(_status)
2427 static_cast<FwAssertArgType>(_status)
2440 #if FW_ENABLE_TEXT_LOGGING 2441 if (this->isConnected_LogText_OutputPort(0)) {
2442 #if FW_OBJECT_NAMES == 1 2443 const char* _formatString =
2444 "(%s) %s: Appended %s to the end of %s";
2446 const char* _formatString =
2447 "%s: Appended %s to the end of %s";
2451 (void) _logString.
format(
2454 this->m_objName.toChar(),
2456 "AppendFileSucceeded ",
2478 this->timeCaller_out(0, _logTime);
2488 #if FW_AMPCS_COMPATIBLE 2493 static_cast<FwAssertArgType>(_status)
2503 static_cast<FwAssertArgType>(_status)
2516 #if FW_ENABLE_TEXT_LOGGING 2517 if (this->isConnected_LogText_OutputPort(0)) {
2518 #if FW_OBJECT_NAMES == 1 2519 const char* _formatString =
2520 "(%s) %s: Created directory %s successfully";
2522 const char* _formatString =
2523 "%s: Created directory %s successfully";
2527 (void) _logString.
format(
2530 this->m_objName.toChar(),
2532 "CreateDirectorySucceeded ",
2553 this->timeCaller_out(0, _logTime);
2563 #if FW_AMPCS_COMPATIBLE 2568 static_cast<FwAssertArgType>(_status)
2578 static_cast<FwAssertArgType>(_status)
2591 #if FW_ENABLE_TEXT_LOGGING 2592 if (this->isConnected_LogText_OutputPort(0)) {
2593 #if FW_OBJECT_NAMES == 1 2594 const char* _formatString =
2595 "(%s) %s: Removed directory %s successfully";
2597 const char* _formatString =
2598 "%s: Removed directory %s successfully";
2602 (void) _logString.
format(
2605 this->m_objName.toChar(),
2607 "RemoveDirectorySucceeded ",
2631 this->timeCaller_out(0, _logTime);
2641 #if FW_AMPCS_COMPATIBLE 2646 static_cast<FwAssertArgType>(_status)
2656 static_cast<FwAssertArgType>(_status)
2665 static_cast<FwAssertArgType>(_status)
2678 #if FW_ENABLE_TEXT_LOGGING 2679 if (this->isConnected_LogText_OutputPort(0)) {
2680 #if FW_OBJECT_NAMES == 1 2681 const char* _formatString =
2682 "(%s) %s: Moved file %s to file %s successfully";
2684 const char* _formatString =
2685 "%s: Moved file %s to file %s successfully";
2689 (void) _logString.
format(
2692 this->m_objName.toChar(),
2694 "MoveFileSucceeded ",
2716 this->timeCaller_out(0, _logTime);
2726 #if FW_AMPCS_COMPATIBLE 2731 static_cast<FwAssertArgType>(_status)
2741 static_cast<FwAssertArgType>(_status)
2754 #if FW_ENABLE_TEXT_LOGGING 2755 if (this->isConnected_LogText_OutputPort(0)) {
2756 #if FW_OBJECT_NAMES == 1 2757 const char* _formatString =
2758 "(%s) %s: Removed file %s successfully";
2760 const char* _formatString =
2761 "%s: Removed file %s successfully";
2765 (void) _logString.
format(
2768 this->m_objName.toChar(),
2770 "RemoveFileSucceeded ",
2794 this->timeCaller_out(0, _logTime);
2804 #if FW_AMPCS_COMPATIBLE 2809 static_cast<FwAssertArgType>(_status)
2819 static_cast<FwAssertArgType>(_status)
2828 static_cast<FwAssertArgType>(_status)
2841 #if FW_ENABLE_TEXT_LOGGING 2842 if (this->isConnected_LogText_OutputPort(0)) {
2843 #if FW_OBJECT_NAMES == 1 2844 const char* _formatString =
2845 "(%s) %s: Appending file %s to the end of %s...";
2847 const char* _formatString =
2848 "%s: Appending file %s to the end of %s...";
2852 (void) _logString.
format(
2855 this->m_objName.toChar(),
2857 "AppendFileStarted ",
2879 this->timeCaller_out(0, _logTime);
2889 #if FW_AMPCS_COMPATIBLE 2894 static_cast<FwAssertArgType>(_status)
2904 static_cast<FwAssertArgType>(_status)
2917 #if FW_ENABLE_TEXT_LOGGING 2918 if (this->isConnected_LogText_OutputPort(0)) {
2919 #if FW_OBJECT_NAMES == 1 2920 const char* _formatString =
2921 "(%s) %s: Creating directory %s...";
2923 const char* _formatString =
2924 "%s: Creating directory %s...";
2928 (void) _logString.
format(
2931 this->m_objName.toChar(),
2933 "CreateDirectoryStarted ",
2954 this->timeCaller_out(0, _logTime);
2964 #if FW_AMPCS_COMPATIBLE 2969 static_cast<FwAssertArgType>(_status)
2979 static_cast<FwAssertArgType>(_status)
2992 #if FW_ENABLE_TEXT_LOGGING 2993 if (this->isConnected_LogText_OutputPort(0)) {
2994 #if FW_OBJECT_NAMES == 1 2995 const char* _formatString =
2996 "(%s) %s: Removing directory %s...";
2998 const char* _formatString =
2999 "%s: Removing directory %s...";
3003 (void) _logString.
format(
3006 this->m_objName.toChar(),
3008 "RemoveDirectoryStarted ",
3032 this->timeCaller_out(0, _logTime);
3042 #if FW_AMPCS_COMPATIBLE 3047 static_cast<FwAssertArgType>(_status)
3057 static_cast<FwAssertArgType>(_status)
3066 static_cast<FwAssertArgType>(_status)
3079 #if FW_ENABLE_TEXT_LOGGING 3080 if (this->isConnected_LogText_OutputPort(0)) {
3081 #if FW_OBJECT_NAMES == 1 3082 const char* _formatString =
3083 "(%s) %s: Moving file %s to file %s...";
3085 const char* _formatString =
3086 "%s: Moving file %s to file %s...";
3090 (void) _logString.
format(
3093 this->m_objName.toChar(),
3117 this->timeCaller_out(0, _logTime);
3127 #if FW_AMPCS_COMPATIBLE 3132 static_cast<FwAssertArgType>(_status)
3142 static_cast<FwAssertArgType>(_status)
3155 #if FW_ENABLE_TEXT_LOGGING 3156 if (this->isConnected_LogText_OutputPort(0)) {
3157 #if FW_OBJECT_NAMES == 1 3158 const char* _formatString =
3159 "(%s) %s: Removing file %s...";
3161 const char* _formatString =
3162 "%s: Removing file %s...";
3166 (void) _logString.
format(
3169 this->m_objName.toChar(),
3171 "RemoveFileStarted ",
3195 this->timeCaller_out(0, _logTime);
3205 #if FW_AMPCS_COMPATIBLE 3210 static_cast<FwAssertArgType>(_status)
3220 static_cast<FwAssertArgType>(_status)
3223 #if FW_AMPCS_COMPATIBLE 3230 static_cast<FwAssertArgType>(_status)
3236 static_cast<FwAssertArgType>(_status)
3249 #if FW_ENABLE_TEXT_LOGGING 3250 if (this->isConnected_LogText_OutputPort(0)) {
3251 #if FW_OBJECT_NAMES == 1 3252 const char* _formatString =
3253 "(%s) %s: The size of file %s is %" PRIu64
" B";
3255 const char* _formatString =
3256 "%s: The size of file %s is %" PRIu64
" B";
3260 (void) _logString.
format(
3263 this->m_objName.toChar(),
3265 "FileSizeSucceeded ",
3290 this->timeCaller_out(0, _logTime);
3300 #if FW_AMPCS_COMPATIBLE 3305 static_cast<FwAssertArgType>(_status)
3315 static_cast<FwAssertArgType>(_status)
3318 #if FW_AMPCS_COMPATIBLE 3321 static_cast<U8>(
sizeof(U32))
3325 static_cast<FwAssertArgType>(_status)
3331 static_cast<FwAssertArgType>(_status)
3344 #if FW_ENABLE_TEXT_LOGGING 3345 if (this->isConnected_LogText_OutputPort(0)) {
3346 #if FW_OBJECT_NAMES == 1 3347 const char* _formatString =
3348 "(%s) %s: Failed to get the size of file %s, returned status %" PRIu32
"";
3350 const char* _formatString =
3351 "%s: Failed to get the size of file %s, returned status %" PRIu32
"";
3355 (void) _logString.
format(
3358 this->m_objName.toChar(),
3382 this->timeCaller_out(0, _logTime);
3392 #if FW_AMPCS_COMPATIBLE 3397 static_cast<FwAssertArgType>(_status)
3407 static_cast<FwAssertArgType>(_status)
3420 #if FW_ENABLE_TEXT_LOGGING 3421 if (this->isConnected_LogText_OutputPort(0)) {
3422 #if FW_OBJECT_NAMES == 1 3423 const char* _formatString =
3424 "(%s) %s: Checking size of file %s...";
3426 const char* _formatString =
3427 "%s: Checking size of file %s...";
3431 (void) _logString.
format(
3434 this->m_objName.toChar(),
3457 this->timeCaller_out(0, _logTime);
3467 #if FW_AMPCS_COMPATIBLE 3472 static_cast<FwAssertArgType>(_status)
3482 static_cast<FwAssertArgType>(_status)
3495 #if FW_ENABLE_TEXT_LOGGING 3496 if (this->isConnected_LogText_OutputPort(0)) {
3497 #if FW_OBJECT_NAMES == 1 3498 const char* _formatString =
3499 "(%s) %s: Listing contents of directory %s...";
3501 const char* _formatString =
3502 "%s: Listing contents of directory %s...";
3506 (void) _logString.
format(
3509 this->m_objName.toChar(),
3511 "ListDirectoryStarted ",
3535 this->timeCaller_out(0, _logTime);
3545 #if FW_AMPCS_COMPATIBLE 3550 static_cast<FwAssertArgType>(_status)
3560 static_cast<FwAssertArgType>(_status)
3563 #if FW_AMPCS_COMPATIBLE 3566 static_cast<U8>(
sizeof(U32))
3570 static_cast<FwAssertArgType>(_status)
3576 static_cast<FwAssertArgType>(_status)
3589 #if FW_ENABLE_TEXT_LOGGING 3590 if (this->isConnected_LogText_OutputPort(0)) {
3591 #if FW_OBJECT_NAMES == 1 3592 const char* _formatString =
3593 "(%s) %s: Directory %s contains %" PRIu32
" files";
3595 const char* _formatString =
3596 "%s: Directory %s contains %" PRIu32
" files";
3600 (void) _logString.
format(
3603 this->m_objName.toChar(),
3605 "ListDirectorySucceeded ",
3630 this->timeCaller_out(0, _logTime);
3640 #if FW_AMPCS_COMPATIBLE 3645 static_cast<FwAssertArgType>(_status)
3655 static_cast<FwAssertArgType>(_status)
3658 #if FW_AMPCS_COMPATIBLE 3661 static_cast<U8>(
sizeof(U32))
3665 static_cast<FwAssertArgType>(_status)
3671 static_cast<FwAssertArgType>(_status)
3684 #if FW_ENABLE_TEXT_LOGGING 3685 if (this->isConnected_LogText_OutputPort(0)) {
3686 #if FW_OBJECT_NAMES == 1 3687 const char* _formatString =
3688 "(%s) %s: Failed to list directory %s, returned status %" PRIu32
"";
3690 const char* _formatString =
3691 "%s: Failed to list directory %s, returned status %" PRIu32
"";
3695 (void) _logString.
format(
3698 this->m_objName.toChar(),
3700 "ListDirectoryError ",
3726 this->timeCaller_out(0, _logTime);
3736 #if FW_AMPCS_COMPATIBLE 3741 static_cast<FwAssertArgType>(_status)
3751 static_cast<FwAssertArgType>(_status)
3760 static_cast<FwAssertArgType>(_status)
3763 #if FW_AMPCS_COMPATIBLE 3770 static_cast<FwAssertArgType>(_status)
3776 static_cast<FwAssertArgType>(_status)
3789 #if FW_ENABLE_TEXT_LOGGING 3790 if (this->isConnected_LogText_OutputPort(0)) {
3791 #if FW_OBJECT_NAMES == 1 3792 const char* _formatString =
3793 "(%s) %s: Directory %s: %s (%" PRIu64
" bytes)";
3795 const char* _formatString =
3796 "%s: Directory %s: %s (%" PRIu64
" bytes)";
3800 (void) _logString.
format(
3803 this->m_objName.toChar(),
3805 "DirectoryListing ",
3831 this->timeCaller_out(0, _logTime);
3841 #if FW_AMPCS_COMPATIBLE 3846 static_cast<FwAssertArgType>(_status)
3856 static_cast<FwAssertArgType>(_status)
3865 static_cast<FwAssertArgType>(_status)
3878 #if FW_ENABLE_TEXT_LOGGING 3879 if (this->isConnected_LogText_OutputPort(0)) {
3880 #if FW_OBJECT_NAMES == 1 3881 const char* _formatString =
3882 "(%s) %s: Directory %s: %s";
3884 const char* _formatString =
3885 "%s: Directory %s: %s";
3889 (void) _logString.
format(
3892 this->m_objName.toChar(),
3894 "DirectoryListingSubdir ",
3916 this->timeCaller_out(0, _logTime);
3926 #if FW_AMPCS_COMPATIBLE 3931 static_cast<FwAssertArgType>(_status)
3941 static_cast<FwAssertArgType>(_status)
3954 #if FW_ENABLE_TEXT_LOGGING 3955 if (this->isConnected_LogText_OutputPort(0)) {
3956 #if FW_OBJECT_NAMES == 1 3957 const char* _formatString =
3958 "(%s) %s: Started CRC calculation for file %s";
3960 const char* _formatString =
3961 "%s: Started CRC calculation for file %s";
3965 (void) _logString.
format(
3968 this->m_objName.toChar(),
3970 "CalculateCrcStarted ",
3994 this->timeCaller_out(0, _logTime);
4004 #if FW_AMPCS_COMPATIBLE 4009 static_cast<FwAssertArgType>(_status)
4019 static_cast<FwAssertArgType>(_status)
4022 #if FW_AMPCS_COMPATIBLE 4025 static_cast<U8>(
sizeof(U32))
4029 static_cast<FwAssertArgType>(_status)
4035 static_cast<FwAssertArgType>(_status)
4048 #if FW_ENABLE_TEXT_LOGGING 4049 if (this->isConnected_LogText_OutputPort(0)) {
4050 #if FW_OBJECT_NAMES == 1 4051 const char* _formatString =
4052 "(%s) %s: Failed CRC calculation for file %s, returned status %" PRIu32
"";
4054 const char* _formatString =
4055 "%s: Failed CRC calculation for file %s, returned status %" PRIu32
"";
4059 (void) _logString.
format(
4062 this->m_objName.toChar(),
4064 "CalculateCrcFailed ",
4089 this->timeCaller_out(0, _logTime);
4099 #if FW_AMPCS_COMPATIBLE 4104 static_cast<FwAssertArgType>(_status)
4114 static_cast<FwAssertArgType>(_status)
4117 #if FW_AMPCS_COMPATIBLE 4120 static_cast<U8>(
sizeof(U32))
4124 static_cast<FwAssertArgType>(_status)
4130 static_cast<FwAssertArgType>(_status)
4143 #if FW_ENABLE_TEXT_LOGGING 4144 if (this->isConnected_LogText_OutputPort(0)) {
4145 #if FW_OBJECT_NAMES == 1 4146 const char* _formatString =
4147 "(%s) %s: %s has CRC value 0x%" PRIx32
"";
4149 const char* _formatString =
4150 "%s: %s has CRC value 0x%" PRIx32
"";
4154 (void) _logString.
format(
4157 this->m_objName.toChar(),
4159 "CalculateCrcSucceeded ",
4184 this->timeCaller_out(0, _logTime);
4194 #if FW_AMPCS_COMPATIBLE 4199 static_cast<FwAssertArgType>(_status)
4209 static_cast<FwAssertArgType>(_status)
4212 #if FW_AMPCS_COMPATIBLE 4219 static_cast<FwAssertArgType>(_status)
4225 static_cast<FwAssertArgType>(_status)
4238 #if FW_ENABLE_TEXT_LOGGING 4239 if (this->isConnected_LogText_OutputPort(0)) {
4240 #if FW_OBJECT_NAMES == 1 4241 const char* _formatString =
4242 "(%s) %s: Failed to format full path for file %s with status %s";
4244 const char* _formatString =
4245 "%s: Failed to format full path for file %s with status %s";
4249 status.toString(statusStr);
4252 (void) _logString.
format(
4255 this->m_objName.toChar(),
4257 "FileNameFormatError ",
4282 this->timeCaller_out(0, _logTime);
4292 #if FW_AMPCS_COMPATIBLE 4297 static_cast<FwAssertArgType>(_status)
4307 static_cast<FwAssertArgType>(_status)
4310 #if FW_AMPCS_COMPATIBLE 4313 static_cast<U8>(
sizeof(U64))
4317 static_cast<FwAssertArgType>(_status)
4323 static_cast<FwAssertArgType>(_status)
4336 #if FW_ENABLE_TEXT_LOGGING 4337 if (this->isConnected_LogText_OutputPort(0)) {
4338 #if FW_OBJECT_NAMES == 1 4339 const char* _formatString =
4340 "(%s) %s: Started data product generation for file %s (%" PRIu64
" bytes)";
4342 const char* _formatString =
4343 "%s: Started data product generation for file %s (%" PRIu64
" bytes)";
4347 (void) _logString.
format(
4350 this->m_objName.toChar(),
4352 "GenerateDpStarted ",
4377 this->timeCaller_out(0, _logTime);
4387 #if FW_AMPCS_COMPATIBLE 4392 static_cast<FwAssertArgType>(_status)
4402 static_cast<FwAssertArgType>(_status)
4405 #if FW_AMPCS_COMPATIBLE 4408 static_cast<U8>(
sizeof(U32))
4412 static_cast<FwAssertArgType>(_status)
4418 static_cast<FwAssertArgType>(_status)
4431 #if FW_ENABLE_TEXT_LOGGING 4432 if (this->isConnected_LogText_OutputPort(0)) {
4433 #if FW_OBJECT_NAMES == 1 4434 const char* _formatString =
4435 "(%s) %s: Completed data product generation for file %s in %" PRIu32
" chunks";
4437 const char* _formatString =
4438 "%s: Completed data product generation for file %s in %" PRIu32
" chunks";
4442 (void) _logString.
format(
4445 this->m_objName.toChar(),
4447 "GenerateDpComplete ",
4473 this->timeCaller_out(0, _logTime);
4483 #if FW_AMPCS_COMPATIBLE 4488 static_cast<FwAssertArgType>(_status)
4498 static_cast<FwAssertArgType>(_status)
4501 #if FW_AMPCS_COMPATIBLE 4508 static_cast<FwAssertArgType>(_status)
4514 static_cast<FwAssertArgType>(_status)
4517 #if FW_AMPCS_COMPATIBLE 4520 static_cast<U8>(
sizeof(U32))
4524 static_cast<FwAssertArgType>(_status)
4530 static_cast<FwAssertArgType>(_status)
4543 #if FW_ENABLE_TEXT_LOGGING 4544 if (this->isConnected_LogText_OutputPort(0)) {
4545 #if FW_OBJECT_NAMES == 1 4546 const char* _formatString =
4547 "(%s) %s: Data product generation failed for file %s at stage %s, status %" PRIu32
"";
4549 const char* _formatString =
4550 "%s: Data product generation failed for file %s at stage %s, status %" PRIu32
"";
4554 stage.toString(stageStr);
4557 (void) _logString.
format(
4560 this->m_objName.toChar(),
4562 "GenerateDpFailed ",
4585 this->timeCaller_out(0, _logTime);
4595 #if FW_AMPCS_COMPATIBLE 4600 static_cast<FwAssertArgType>(_status)
4610 static_cast<FwAssertArgType>(_status)
4623 #if FW_ENABLE_TEXT_LOGGING 4624 if (this->isConnected_LogText_OutputPort(0)) {
4625 #if FW_OBJECT_NAMES == 1 4626 const char* _formatString =
4627 "(%s) %s: Failed to allocate data product buffer for file %s";
4629 const char* _formatString =
4630 "%s: Failed to allocate data product buffer for file %s";
4634 (void) _logString.
format(
4637 this->m_objName.toChar(),
4639 "GenerateDpBufferFailed ",
4665 this->timeCaller_out(0, _logTime);
4675 #if FW_AMPCS_COMPATIBLE 4680 static_cast<FwAssertArgType>(_status)
4690 static_cast<FwAssertArgType>(_status)
4693 #if FW_AMPCS_COMPATIBLE 4696 static_cast<U8>(
sizeof(U64))
4700 static_cast<FwAssertArgType>(_status)
4706 static_cast<FwAssertArgType>(_status)
4709 #if FW_AMPCS_COMPATIBLE 4712 static_cast<U8>(
sizeof(U64))
4716 static_cast<FwAssertArgType>(_status)
4722 static_cast<FwAssertArgType>(_status)
4725 #if FW_AMPCS_COMPATIBLE 4728 static_cast<U8>(
sizeof(U64))
4732 static_cast<FwAssertArgType>(_status)
4738 static_cast<FwAssertArgType>(_status)
4751 #if FW_ENABLE_TEXT_LOGGING 4752 if (this->isConnected_LogText_OutputPort(0)) {
4753 #if FW_OBJECT_NAMES == 1 4754 const char* _formatString =
4755 "(%s) %s: Invalid offset range requested for file %s: [%" PRIu64
", %" PRIu64
") with file size %" PRIu64
"";
4757 const char* _formatString =
4758 "%s: Invalid offset range requested for file %s: [%" PRIu64
", %" PRIu64
") with file size %" PRIu64
"";
4762 (void) _logString.
format(
4765 this->m_objName.toChar(),
4767 "GenerateDpInvalidRange ",
4794 this->timeCaller_out(0, _logTime);
4804 #if FW_AMPCS_COMPATIBLE 4809 static_cast<FwAssertArgType>(_status)
4819 static_cast<FwAssertArgType>(_status)
4828 static_cast<FwAssertArgType>(_status)
4841 #if FW_ENABLE_TEXT_LOGGING 4842 if (this->isConnected_LogText_OutputPort(0)) {
4843 #if FW_OBJECT_NAMES == 1 4844 const char* _formatString =
4845 "(%s) %s: Path %s is outside the configured sandbox directory %s";
4847 const char* _formatString =
4848 "%s: Path %s is outside the configured sandbox directory %s";
4852 (void) _logString.
format(
4855 this->m_objName.toChar(),
4857 "PathOutsideSandbox ",
4889 this->timeCaller_out(0, _tlmTime);
4919 static_cast<FwAssertArgType>(_stat)
4941 static_cast<FwAssertArgType>(_stat)
4974 static_cast<FwAssertArgType>(buffer.
getSize()));
4975 buffer.
setSize(static_cast<U32>(packetSize));
4979 this->productSendOut_out(0, container.
getId(), buffer);
4991 this->timeCaller_out(0, _time);
5006 ComponentIpcSerializableBuffer _msg;
5016 static_cast<FwAssertArgType>(_msgStatus)
5026 static_cast<FwAssertArgType>(_deserStatus)
5029 MsgTypeEnum _msgType =
static_cast<MsgTypeEnum
>(_desMsg);
5031 if (_msgType == FILEMANAGER_COMPONENT_EXIT) {
5036 _deserStatus = _msg.deserializeTo(portNum);
5039 static_cast<FwAssertArgType>(_deserStatus)
5047 _deserStatus = _msg.deserializeTo(key);
5050 static_cast<FwAssertArgType>(_deserStatus)
5062 case CMD_CREATEDIRECTORY: {
5065 _deserStatus = _msg.deserializeTo(_opCode);
5068 static_cast<FwAssertArgType>(_deserStatus)
5073 _deserStatus = _msg.deserializeTo(_cmdSeq);
5076 static_cast<FwAssertArgType>(_deserStatus)
5081 _deserStatus = _msg.deserializeTo(args);
5084 static_cast<FwAssertArgType>(_deserStatus)
5107 #if FW_CMD_CHECK_RESIDUAL 5127 case CMD_MOVEFILE: {
5130 _deserStatus = _msg.deserializeTo(_opCode);
5133 static_cast<FwAssertArgType>(_deserStatus)
5138 _deserStatus = _msg.deserializeTo(_cmdSeq);
5141 static_cast<FwAssertArgType>(_deserStatus)
5146 _deserStatus = _msg.deserializeTo(args);
5149 static_cast<FwAssertArgType>(_deserStatus)
5187 #if FW_CMD_CHECK_RESIDUAL 5208 case CMD_REMOVEDIRECTORY: {
5211 _deserStatus = _msg.deserializeTo(_opCode);
5214 static_cast<FwAssertArgType>(_deserStatus)
5219 _deserStatus = _msg.deserializeTo(_cmdSeq);
5222 static_cast<FwAssertArgType>(_deserStatus)
5227 _deserStatus = _msg.deserializeTo(args);
5230 static_cast<FwAssertArgType>(_deserStatus)
5253 #if FW_CMD_CHECK_RESIDUAL 5273 case CMD_REMOVEFILE: {
5276 _deserStatus = _msg.deserializeTo(_opCode);
5279 static_cast<FwAssertArgType>(_deserStatus)
5284 _deserStatus = _msg.deserializeTo(_cmdSeq);
5287 static_cast<FwAssertArgType>(_deserStatus)
5292 _deserStatus = _msg.deserializeTo(args);
5295 static_cast<FwAssertArgType>(_deserStatus)
5333 #if FW_CMD_CHECK_RESIDUAL 5354 case CMD_APPENDFILE: {
5357 _deserStatus = _msg.deserializeTo(_opCode);
5360 static_cast<FwAssertArgType>(_deserStatus)
5365 _deserStatus = _msg.deserializeTo(_cmdSeq);
5368 static_cast<FwAssertArgType>(_deserStatus)
5373 _deserStatus = _msg.deserializeTo(args);
5376 static_cast<FwAssertArgType>(_deserStatus)
5414 #if FW_CMD_CHECK_RESIDUAL 5435 case CMD_FILESIZE: {
5438 _deserStatus = _msg.deserializeTo(_opCode);
5441 static_cast<FwAssertArgType>(_deserStatus)
5446 _deserStatus = _msg.deserializeTo(_cmdSeq);
5449 static_cast<FwAssertArgType>(_deserStatus)
5454 _deserStatus = _msg.deserializeTo(args);
5457 static_cast<FwAssertArgType>(_deserStatus)
5480 #if FW_CMD_CHECK_RESIDUAL 5500 case CMD_LISTDIRECTORY: {
5503 _deserStatus = _msg.deserializeTo(_opCode);
5506 static_cast<FwAssertArgType>(_deserStatus)
5511 _deserStatus = _msg.deserializeTo(_cmdSeq);
5514 static_cast<FwAssertArgType>(_deserStatus)
5519 _deserStatus = _msg.deserializeTo(args);
5522 static_cast<FwAssertArgType>(_deserStatus)
5545 #if FW_CMD_CHECK_RESIDUAL 5565 case CMD_CALCULATECRC: {
5568 _deserStatus = _msg.deserializeTo(_opCode);
5571 static_cast<FwAssertArgType>(_deserStatus)
5576 _deserStatus = _msg.deserializeTo(_cmdSeq);
5579 static_cast<FwAssertArgType>(_deserStatus)
5584 _deserStatus = _msg.deserializeTo(args);
5587 static_cast<FwAssertArgType>(_deserStatus)
5610 #if FW_CMD_CHECK_RESIDUAL 5630 case CMD_GENERATEDP: {
5633 _deserStatus = _msg.deserializeTo(_opCode);
5636 static_cast<FwAssertArgType>(_deserStatus)
5641 _deserStatus = _msg.deserializeTo(_cmdSeq);
5644 static_cast<FwAssertArgType>(_deserStatus)
5649 _deserStatus = _msg.deserializeTo(args);
5652 static_cast<FwAssertArgType>(_deserStatus)
5750 #if FW_CMD_CHECK_RESIDUAL 5779 _msg.getDeserializeSizeLeft() == 0,
5800 void FileManagerComponentBase ::
5811 compPtr->cmdIn_handlerBase(
5823 void FileManagerComponentBase ::
5832 compPtr->pingIn_handlerBase(
5838 void FileManagerComponentBase ::
5847 compPtr->schedIn_handlerBase(
5853 #if !FW_DIRECT_PORT_CALLS 5859 #if FW_ENABLE_TEXT_LOGGING 5861 void FileManagerComponentBase ::
5871 (0 <= portNum) && (portNum < this->getNum_LogText_OutputPorts()),
5872 static_cast<FwAssertArgType>(portNum)
5876 this->m_LogText_OutputPort[portNum].isConnected(),
5877 static_cast<FwAssertArgType>(portNum)
5879 this->m_LogText_OutputPort[portNum].invoke(
5889 void FileManagerComponentBase ::
5897 static_cast<FwAssertArgType>(portNum)
5901 this->m_cmdRegOut_OutputPort[portNum].isConnected(),
5902 static_cast<FwAssertArgType>(portNum)
5904 this->m_cmdRegOut_OutputPort[portNum].
invoke(
5909 void FileManagerComponentBase ::
5919 static_cast<FwAssertArgType>(portNum)
5923 this->m_cmdResponseOut_OutputPort[portNum].isConnected(),
5924 static_cast<FwAssertArgType>(portNum)
5926 this->m_cmdResponseOut_OutputPort[portNum].
invoke(
5933 void FileManagerComponentBase ::
5944 static_cast<FwAssertArgType>(portNum)
5948 this->m_eventOut_OutputPort[portNum].isConnected(),
5949 static_cast<FwAssertArgType>(portNum)
5951 this->m_eventOut_OutputPort[portNum].
invoke(
5969 static_cast<FwAssertArgType>(portNum)
5973 this->m_productGetOut_OutputPort[portNum].isConnected(),
5974 static_cast<FwAssertArgType>(portNum)
5976 return this->m_productGetOut_OutputPort[portNum].
invoke(
5983 void FileManagerComponentBase ::
5992 static_cast<FwAssertArgType>(portNum)
5996 this->m_productSendOut_OutputPort[portNum].isConnected(),
5997 static_cast<FwAssertArgType>(portNum)
5999 this->m_productSendOut_OutputPort[portNum].
invoke(
6005 void FileManagerComponentBase ::
6013 static_cast<FwAssertArgType>(portNum)
6017 this->m_timeCaller_OutputPort[portNum].isConnected(),
6018 static_cast<FwAssertArgType>(portNum)
6020 this->m_timeCaller_OutputPort[portNum].
invoke(
6025 void FileManagerComponentBase ::
6035 static_cast<FwAssertArgType>(portNum)
6039 this->m_tlmOut_OutputPort[portNum].isConnected(),
6040 static_cast<FwAssertArgType>(portNum)
6042 this->m_tlmOut_OutputPort[portNum].
invoke(
6057 ContainerId::T containerId,
6060 DpContainer& container
6064 const FwDpIdType globalId = baseId + containerId;
6067 const Fw::Success::T status = this->productGetOut_out(0, globalId, size, buffer);
6071 container = DpContainer(globalId, buffer, baseId);
6072 container.setPriority(priority);
bool isConnected_productSendOut_OutputPort(FwIndexType portNum) const
void set_eventOut_OutputPort(FwIndexType portNum, Fw::InputLogPort *port)
Connect port to eventOut[portNum].
Serialization/Deserialization operation was successful.
An error occurred while attempting to move a file.
void addCallPort(InputTimePort *callPort)
Register an input port.
virtual void run_internalInterfaceHandler()=0
Internal interface handler for run.
static constexpr FwSizeType CAPACITY
void log_WARNING_HI_ListDirectoryError(const Fw::StringBase &dirName, U32 status) const
Channel ID for CommandsExecuted.
void AppendFile_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void log_ACTIVITY_HI_DirectoryListingSubdir(const Fw::StringBase &dirName, const Fw::StringBase &subdirName) const
The File System component began moving a file to a new location.
void setTimeTag(Fw::Time timeTag)
Set the time tag.
void log_ACTIVITY_HI_CreateDirectoryStarted(const Fw::StringBase &dirName) const
FwIdType FwOpcodeType
The type of a command opcode.
virtual void ListDirectory_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command ListDirectory.
void log_ACTIVITY_HI_RemoveDirectorySucceeded(const Fw::StringBase &dirName) const
void init()
Initialization function.
void log_ACTIVITY_HI_DirectoryListing(const Fw::StringBase &dirName, const Fw::StringBase &fileName, FwSizeType fileSize) const
FwIdType getIdBase() const
virtual void MoveFile_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &sourceFileName, const Fw::CmdStringArg &destFileName)=0
PlatformSizeType FwSizeType
virtual void MoveFile_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command MoveFile.
U32 FwDpPriorityType
The type of a data product priority.
void log_ACTIVITY_HI_CalculateCrcStarted(const Fw::StringBase &fileName) const
Status receive(U8 *destination, FwSizeType capacity, BlockingType blockType, FwSizeType &actualSize, FwQueuePriorityType &priority) override
receive a message from the queue through delegate
void addCallPort(InputDpSendPort *callPort)
Register an input port.
void setSize(FwSizeType size)
virtual void CalculateCrc_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &filename)=0
Status
status returned from the queue send function
void log_WARNING_HI_FileSizeError(const Fw::StringBase &fileName, U32 status) const
void run_internalInterfaceInvoke()
Internal interface base-class function for run.
static constexpr FwIndexType getNum_tlmOut_OutputPorts()
The File System component began deleting a directory.
void log_ACTIVITY_HI_GenerateDpStarted(const Fw::StringBase &fileName, U64 bytesToWrite) const
BYTE pingInPortSize[Svc::PingPortBuffer::CAPACITY]
virtual void pingIn_handler(FwIndexType portNum, U32 key)=0
Handler for input port pingIn.
void FileSize_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
static constexpr FwIndexType getNum_productGetOut_OutputPorts()
SerializeStatus deserializeTo(U8 &val, Endianness mode=Endianness::BIG) override
Deserialize an 8-bit unsigned integer value.
void log_ACTIVITY_HI_FileSizeSucceeded(const Fw::StringBase &fileName, FwSizeType size) const
virtual void RemoveFile_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &fileName, bool ignoreErrors)=0
void log_ACTIVITY_HI_ListDirectorySucceeded(const Fw::StringBase &dirName, U32 fileCount) const
void cmdIn_handlerBase(FwIndexType portNum, FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
Handler base-class function for input port cmdIn.
An error occurred while attempting to remove a directory.
The File System component deleted and existing directory without error.
No room left in the buffer to serialize data.
static constexpr FwIndexType getNum_timeCaller_OutputPorts()
void invoke(U32 key) const
Invoke a port connection.
bool isConnected_productGetOut_OutputPort(FwIndexType portNum) const
void log_ACTIVITY_HI_CalculateCrcSucceeded(const Fw::StringBase &fileName, U32 crc) const
virtual const CHAR * toChar() const =0
Convert to a C-style char*.
void CalculateCrc_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void log_ACTIVITY_HI_ListDirectoryStarted(const Fw::StringBase &dirName) const
message to exit active component task
bool isConnected_tlmOut_OutputPort(FwIndexType portNum) const
static constexpr FwIndexType getNum_pingOut_OutputPorts()
static constexpr FwIndexType getNum_productSendOut_OutputPorts()
void init()
Initialization function.
Enum representing a command response.
virtual void RemoveFile_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command RemoveFile.
virtual void schedIn_handler(FwIndexType portNum, U32 context)=0
Handler for input port schedIn.
No time base has been established (Required)
void log_ACTIVITY_HI_MoveFileStarted(const Fw::StringBase &sourceFileName, const Fw::StringBase &destFileName) const
SerializeStatus serializeFrom(U8 val, Endianness mode=Endianness::BIG) override
Serialize an 8-bit unsigned integer value.
void addCallPort(InputCmdRegPort *callPort)
Register an input port.
void log_WARNING_HI_GenerateDpInvalidRange(const Fw::StringBase &fileName, U64 beginOffset, U64 endOffset, U64 fileSize) const
The File System component returned status non-zero when trying to append 2 files together.
bool isConnected_pingOut_OutputPort(FwIndexType portNum) const
Starting directory listing.
DpContainer()
Constructor with default initialization.
static constexpr FwIndexType getNum_eventOut_OutputPorts()
Os::Queue m_queue
queue object for active component
Svc::InputPingPort * get_pingIn_InputPort(FwIndexType portNum)
void pingOut_out(FwIndexType portNum, U32 key) const
Invoke output port pingOut.
void log_ACTIVITY_HI_AppendFileSucceeded(const Fw::StringBase &source, const Fw::StringBase &target) const
FileManagerComponentBase(const char *compName="")
Construct FileManagerComponentBase object.
void addCallPort(InputTlmPort *callPort)
Register an input port.
void ListDirectory_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void init()
Object initializer.
Directory listing subdirectory entry.
void log_WARNING_HI_PathOutsideSandbox(const Fw::StringBase &path, const Fw::StringBase &sandboxDir) const
SerializeStatus
forward declaration for string
Message will block until space is available.
void log_WARNING_HI_GenerateDpBufferFailed(const Fw::StringBase &fileName) const
void log_ACTIVITY_HI_CreateDirectorySucceeded(const Fw::StringBase &dirName) const
void set_cmdResponseOut_OutputPort(FwIndexType portNum, Fw::InputCmdResponsePort *port)
Connect port to cmdResponseOut[portNum].
U16 FwSizeStoreType
The type used to serialize a size value.
FwIdType FwEventIdType
The type of an event identifier.
void set_pingOut_OutputPort(FwIndexType portNum, Svc::InputPingPort *port)
Connect port to pingOut[portNum].
bool isConnected_cmdResponseOut_OutputPort(FwIndexType portNum) const
void invoke(FwOpcodeType opCode) const
Invoke a port connection.
static constexpr FwSizeType CAPACITY
void log_WARNING_HI_GenerateDpFailed(const Fw::StringBase &fileName, const Svc::FileManager_GenerateDpStage &stage, U32 status) const
virtual void CreateDirectory_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &dirName)=0
virtual void ListDirectory_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &dirName)=0
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects) ...
void RemoveFile_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void init()
Initialization function.
Error formatting a file path.
void log_ACTIVITY_HI_RemoveDirectoryStarted(const Fw::StringBase &dirName) const
Os::Queue::Status createQueue(FwSizeType depth, FwSizeType msgSize)
Fw::InputCmdPort * get_cmdIn_InputPort(FwIndexType portNum)
void RemoveDirectory_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
#define FW_MIN(a, b)
MIN macro (deprecated in C++, use std::min)
A data product container.
Omit length from serialization.
ActiveComponentBase(const char *name)
Constructor.
void init()
Initialization function.
Directory listing completed successfully.
static constexpr FwIndexType getNum_schedIn_InputPorts()
void invoke(Fw::Time &time) const
Invoke a port connection.
The File System component appended 2 files without error.
Serializable::SizeType getDeserializeSizeLeft() const override
Get remaining deserialization buffer size.
void invoke(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdResponse &response) const
Invoke a port connection.
virtual void FileSize_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command FileSize.
void invalidateBuffer()
Invalidate the packet buffer.
The File System component began deleting an existing file.
FwIdType FwChanIdType
The type of a telemetry channel identifier.
void addCallPort(InputPingPort *callPort)
Register an input port.
The size of the serial representation.
Status send(const U8 *buffer, FwSizeType size, FwQueuePriorityType priority, BlockingType blockType) override
send a message into the queue through delegate
File data product generation started.
virtual void CreateDirectory_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command CreateDirectory.
void resetDeser() override
Reset deserialization pointer to beginning of buffer.
Directory listing file entry.
A serious but recoverable event.
Errors dispatching messages.
Svc::InputSchedPort * get_schedIn_InputPort(FwIndexType portNum)
void cmdResponse_out(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdResponse response)
Emit command response.
bool isConnected_timeCaller_OutputPort(FwIndexType portNum) const
A command path argument was rejected by the configured sandbox directory.
static constexpr FwSizeType getPacketSizeForDataSize(FwSizeType dataSize)
Get the packet size for a given data size.
void invoke(FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val) const
Invoke a port connection.
const char * toChar() const
Convert to a C-style char*.
void log_ACTIVITY_HI_FileSizeStarted(const Fw::StringBase &fileName) const
void log_WARNING_HI_FileNameFormatError(const Fw::StringBase &fileName, const Fw::StringFormatStatus &status) const
Enum representing event severity.
virtual ~FileManagerComponentBase()
Destroy FileManagerComponentBase object.
FwSizeType getPacketSize() const
Get the packet size corresponding to the data size.
Fw::Buffer getBuffer() const
void tlmWrite(FwChanIdType id, Fw::TlmBuffer &_tlmBuff, Fw::Time _tlmTime=Fw::Time()) const
static constexpr FwIndexType getNum_cmdResponseOut_OutputPorts()
FormatStatus format(const CHAR *formatString,...)
write formatted string to buffer
void init()
Initialization function.
void MoveFile_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
Fw::SerializeStatus serializeRecord_FileChunkHeaderRecord(const Svc::FileManager_FileChunkHeader &elt)
void log_ACTIVITY_HI_GenerateDpComplete(const Fw::StringBase &fileName, U32 chunks) const
uint8_t U8
8-bit unsigned integer
void schedIn_handlerBase(FwIndexType portNum, U32 context)
Handler base-class function for input port schedIn.
virtual void FileSize_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &fileName)=0
void log_ACTIVITY_HI_MoveFileSucceeded(const Fw::StringBase &sourceFileName, const Fw::StringBase &destFileName) const
FwSizeType getSize() const
Command failed to deserialize.
The File System component deleted an existing file without error.
void log_WARNING_HI_DirectoryRemoveError(const Fw::StringBase &dirName, U32 status) const
PlatformQueuePriorityType FwQueuePriorityType
The type of queue priorities used.
The File System component appended 2 files without error.
Important informational events.
FwIdType FwDpIdType
The type of a data product identifier.
void pingIn_handlerBase(FwIndexType portNum, U32 key)
Handler base-class function for input port pingIn.
void invoke(FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args) const
Invoke a port connection.
void GenerateDp_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void log_ACTIVITY_HI_AppendFileStarted(const Fw::StringBase &source, const Fw::StringBase &target) const
bool isConnected_eventOut_OutputPort(FwIndexType portNum) const
File data product generation completed.
void tlmWrite_Errors(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
A message was sent requesting an exit of the loop.
void log_ACTIVITY_HI_RemoveFileStarted(const Fw::StringBase &fileName) const
The File System component moved a file to a new location without error.
Fw::Success invoke(FwDpIdType id, FwSizeType dataSize, Fw::Buffer &buffer) const
void set_tlmOut_OutputPort(FwIndexType portNum, Fw::InputTlmPort *port)
Connect port to tlmOut[portNum].
virtual void GenerateDp_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &fileName, U32 chunkSize, U64 beginOffset, U64 endOffset, U32 priority, const Svc::FileManager_GenerateDpMode &mode)=0
void set_cmdRegOut_OutputPort(FwIndexType portNum, Fw::InputCmdRegPort *port)
Connect port to cmdRegOut[portNum].
How the chunks of a file are emitted.
bool isConnected_cmdRegOut_OutputPort(FwIndexType portNum) const
PlatformIndexType FwIndexType
void set_timeCaller_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeCaller[portNum].
void addCallPort(InputDpGetPort *callPort)
Register an input port.
void addCallPort(InputLogPort *callPort)
Register an input port.
Where a data product generation failure occurred.
static constexpr FwIndexType getNum_pingIn_InputPorts()
void init()
Initialization function.
void log_WARNING_HI_AppendFileFailed(const Fw::StringBase &source, const Fw::StringBase &target, U32 status) const
void incNumMsgDropped()
increment the number of messages dropped
void regCommands()
Register commands with the Command Dispatcher.
void set_productSendOut_OutputPort(FwIndexType portNum, Fw::InputDpSendPort *port)
Connect port to productSendOut[portNum].
Failed to list directory.
static constexpr FwIndexType getNum_cmdIn_InputPorts()
Data product container allocation failed.
RateGroupDivider component implementation.
virtual void pingIn_preMsgHook(FwIndexType portNum, U32 key)
Pre-message hook for async input port pingIn.
The File System component began creating a new directory.
message sent/received okay
void log_WARNING_HI_CalculateCrcFailed(const Fw::StringBase &fileName, U32 status) const
virtual void AppendFile_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command AppendFile.
Fw::SerializeStatus serializeRecord_FileChunkDataRecord(const U8 *array, FwSizeType size)
virtual void GenerateDp_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command GenerateDp.
List the contents of a directory.
File data product generation failed.
Invalid offset range requested for data product generation.
Remove a directory, which must be empty.
Message will return with status when space is unavailable.
Implementation of malloc based allocator.
virtual void RemoveDirectory_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command RemoveDirectory.
An error occurred while attempting to create a directory.
void init()
Initialization function.
The File System component created a new directory without error.
Calculate the CRC of a file.
void log_WARNING_HI_DirectoryCreateError(const Fw::StringBase &dirName, U32 status) const
void set_productGetOut_OutputPort(FwIndexType portNum, Fw::InputDpGetPort *port)
Connect port to productGetOut[portNum].
Append 1 file's contents to the end of another.
void log_ACTIVITY_HI_RemoveFileSucceeded(const Fw::StringBase &fileName) const
void log_WARNING_HI_FileMoveError(const Fw::StringBase &sourceFileName, const Fw::StringBase &destFileName, U32 status) const
void invoke(FwDpIdType id, const Fw::Buffer &buffer) const
Invoke a port connection.
void tlmWrite_CommandsExecuted(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
void CreateDirectory_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
An error occurred while attempting to remove a file.
void init()
Initialization function.
virtual void RemoveDirectory_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &dirName)=0
void log_WARNING_HI_FileRemoveError(const Fw::StringBase &fileName, U32 status) const
PlatformAssertArgType FwAssertArgType
The type of arguments to assert functions.
void dpSend(DpContainer &container, Fw::Time timeTag=Fw::ZERO_TIME)
Send a data product.
virtual void CalculateCrc_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command CalculateCrc.
static constexpr FwIndexType getNum_cmdRegOut_OutputPorts()
void addCallPort(InputCmdResponsePort *callPort)
Register an input port.
SerializeStatus serializeTo(SerialBufferBase &buffer, Endianness mode=Endianness::BIG) const override
Serialize the contents of this object to a buffer.
BYTE cmdPortSize[Fw::CmdPortBuffer::CAPACITY]
virtual void AppendFile_cmdHandler(FwOpcodeType opCode, U32 cmdSeq, const Fw::CmdStringArg &source, const Fw::CmdStringArg &target)=0