9 #if FW_ENABLE_TEXT_LOGGING 29 INT_IF_SCHEDININTERNAL,
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(
1200 ComponentIpcSerializableBuffer msg;
1204 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(INT_IF_SCHEDININTERNAL));
1207 static_cast<FwAssertArgType>(_status)
1211 _status = msg.serializeFrom(static_cast<FwIndexType>(0));
1214 static_cast<FwAssertArgType>(_status)
1221 if (qStatus == Os::Queue::Status::FULL) {
1228 static_cast<FwAssertArgType>(qStatus)
1244 this->cmdResponseOut_out(0, opCode, cmdSeq, response);
1265 ComponentIpcSerializableBuffer msg;
1269 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_CREATEDIRECTORY));
1272 static_cast<FwAssertArgType>(_status)
1278 _status = msg.serializeFrom(port);
1281 static_cast<FwAssertArgType>(_status)
1284 _status = msg.serializeFrom(opCode);
1287 static_cast<FwAssertArgType>(_status)
1290 _status = msg.serializeFrom(cmdSeq);
1293 static_cast<FwAssertArgType>(_status)
1296 _status = msg.serializeFrom(args);
1299 static_cast<FwAssertArgType>(_status)
1308 static_cast<FwAssertArgType>(qStatus)
1324 ComponentIpcSerializableBuffer msg;
1328 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_MOVEFILE));
1331 static_cast<FwAssertArgType>(_status)
1337 _status = msg.serializeFrom(port);
1340 static_cast<FwAssertArgType>(_status)
1343 _status = msg.serializeFrom(opCode);
1346 static_cast<FwAssertArgType>(_status)
1349 _status = msg.serializeFrom(cmdSeq);
1352 static_cast<FwAssertArgType>(_status)
1355 _status = msg.serializeFrom(args);
1358 static_cast<FwAssertArgType>(_status)
1367 static_cast<FwAssertArgType>(qStatus)
1383 ComponentIpcSerializableBuffer msg;
1387 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_REMOVEDIRECTORY));
1390 static_cast<FwAssertArgType>(_status)
1396 _status = msg.serializeFrom(port);
1399 static_cast<FwAssertArgType>(_status)
1402 _status = msg.serializeFrom(opCode);
1405 static_cast<FwAssertArgType>(_status)
1408 _status = msg.serializeFrom(cmdSeq);
1411 static_cast<FwAssertArgType>(_status)
1414 _status = msg.serializeFrom(args);
1417 static_cast<FwAssertArgType>(_status)
1426 static_cast<FwAssertArgType>(qStatus)
1442 ComponentIpcSerializableBuffer msg;
1446 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_REMOVEFILE));
1449 static_cast<FwAssertArgType>(_status)
1455 _status = msg.serializeFrom(port);
1458 static_cast<FwAssertArgType>(_status)
1461 _status = msg.serializeFrom(opCode);
1464 static_cast<FwAssertArgType>(_status)
1467 _status = msg.serializeFrom(cmdSeq);
1470 static_cast<FwAssertArgType>(_status)
1473 _status = msg.serializeFrom(args);
1476 static_cast<FwAssertArgType>(_status)
1485 static_cast<FwAssertArgType>(qStatus)
1501 ComponentIpcSerializableBuffer msg;
1505 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_APPENDFILE));
1508 static_cast<FwAssertArgType>(_status)
1514 _status = msg.serializeFrom(port);
1517 static_cast<FwAssertArgType>(_status)
1520 _status = msg.serializeFrom(opCode);
1523 static_cast<FwAssertArgType>(_status)
1526 _status = msg.serializeFrom(cmdSeq);
1529 static_cast<FwAssertArgType>(_status)
1532 _status = msg.serializeFrom(args);
1535 static_cast<FwAssertArgType>(_status)
1544 static_cast<FwAssertArgType>(qStatus)
1560 ComponentIpcSerializableBuffer msg;
1564 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_FILESIZE));
1567 static_cast<FwAssertArgType>(_status)
1573 _status = msg.serializeFrom(port);
1576 static_cast<FwAssertArgType>(_status)
1579 _status = msg.serializeFrom(opCode);
1582 static_cast<FwAssertArgType>(_status)
1585 _status = msg.serializeFrom(cmdSeq);
1588 static_cast<FwAssertArgType>(_status)
1591 _status = msg.serializeFrom(args);
1594 static_cast<FwAssertArgType>(_status)
1603 static_cast<FwAssertArgType>(qStatus)
1619 ComponentIpcSerializableBuffer msg;
1623 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_LISTDIRECTORY));
1626 static_cast<FwAssertArgType>(_status)
1632 _status = msg.serializeFrom(port);
1635 static_cast<FwAssertArgType>(_status)
1638 _status = msg.serializeFrom(opCode);
1641 static_cast<FwAssertArgType>(_status)
1644 _status = msg.serializeFrom(cmdSeq);
1647 static_cast<FwAssertArgType>(_status)
1650 _status = msg.serializeFrom(args);
1653 static_cast<FwAssertArgType>(_status)
1662 static_cast<FwAssertArgType>(qStatus)
1678 ComponentIpcSerializableBuffer msg;
1682 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_CALCULATECRC));
1685 static_cast<FwAssertArgType>(_status)
1691 _status = msg.serializeFrom(port);
1694 static_cast<FwAssertArgType>(_status)
1697 _status = msg.serializeFrom(opCode);
1700 static_cast<FwAssertArgType>(_status)
1703 _status = msg.serializeFrom(cmdSeq);
1706 static_cast<FwAssertArgType>(_status)
1709 _status = msg.serializeFrom(args);
1712 static_cast<FwAssertArgType>(_status)
1721 static_cast<FwAssertArgType>(qStatus)
1737 ComponentIpcSerializableBuffer msg;
1741 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_GENERATEDP));
1744 static_cast<FwAssertArgType>(_status)
1750 _status = msg.serializeFrom(port);
1753 static_cast<FwAssertArgType>(_status)
1756 _status = msg.serializeFrom(opCode);
1759 static_cast<FwAssertArgType>(_status)
1762 _status = msg.serializeFrom(cmdSeq);
1765 static_cast<FwAssertArgType>(_status)
1768 _status = msg.serializeFrom(args);
1771 static_cast<FwAssertArgType>(_status)
1780 static_cast<FwAssertArgType>(qStatus)
1904 this->timeCaller_out(0, _logTime);
1914 #if FW_AMPCS_COMPATIBLE 1919 static_cast<FwAssertArgType>(_status)
1929 static_cast<FwAssertArgType>(_status)
1932 #if FW_AMPCS_COMPATIBLE 1935 static_cast<U8>(
sizeof(U32))
1939 static_cast<FwAssertArgType>(_status)
1945 static_cast<FwAssertArgType>(_status)
1958 #if FW_ENABLE_TEXT_LOGGING 1959 if (this->isConnected_LogText_OutputPort(0)) {
1960 #if FW_OBJECT_NAMES == 1 1961 const char* _formatString =
1962 "(%s) %s: Could not create directory %s, returned status %" PRIu32
"";
1964 const char* _formatString =
1965 "%s: Could not create directory %s, returned status %" PRIu32
"";
1969 (void) _logString.
format(
1972 this->m_objName.toChar(),
1974 "DirectoryCreateError ",
1999 this->timeCaller_out(0, _logTime);
2009 #if FW_AMPCS_COMPATIBLE 2014 static_cast<FwAssertArgType>(_status)
2024 static_cast<FwAssertArgType>(_status)
2027 #if FW_AMPCS_COMPATIBLE 2030 static_cast<U8>(
sizeof(U32))
2034 static_cast<FwAssertArgType>(_status)
2040 static_cast<FwAssertArgType>(_status)
2053 #if FW_ENABLE_TEXT_LOGGING 2054 if (this->isConnected_LogText_OutputPort(0)) {
2055 #if FW_OBJECT_NAMES == 1 2056 const char* _formatString =
2057 "(%s) %s: Could not remove directory %s, returned status %" PRIu32
"";
2059 const char* _formatString =
2060 "%s: Could not remove directory %s, returned status %" PRIu32
"";
2064 (void) _logString.
format(
2067 this->m_objName.toChar(),
2069 "DirectoryRemoveError ",
2095 this->timeCaller_out(0, _logTime);
2105 #if FW_AMPCS_COMPATIBLE 2110 static_cast<FwAssertArgType>(_status)
2120 static_cast<FwAssertArgType>(_status)
2129 static_cast<FwAssertArgType>(_status)
2132 #if FW_AMPCS_COMPATIBLE 2135 static_cast<U8>(
sizeof(U32))
2139 static_cast<FwAssertArgType>(_status)
2145 static_cast<FwAssertArgType>(_status)
2158 #if FW_ENABLE_TEXT_LOGGING 2159 if (this->isConnected_LogText_OutputPort(0)) {
2160 #if FW_OBJECT_NAMES == 1 2161 const char* _formatString =
2162 "(%s) %s: Could not move file %s to file %s, returned status %" PRIu32
"";
2164 const char* _formatString =
2165 "%s: Could not move file %s to file %s, returned status %" PRIu32
"";
2169 (void) _logString.
format(
2172 this->m_objName.toChar(),
2200 this->timeCaller_out(0, _logTime);
2210 #if FW_AMPCS_COMPATIBLE 2215 static_cast<FwAssertArgType>(_status)
2225 static_cast<FwAssertArgType>(_status)
2228 #if FW_AMPCS_COMPATIBLE 2231 static_cast<U8>(
sizeof(U32))
2235 static_cast<FwAssertArgType>(_status)
2241 static_cast<FwAssertArgType>(_status)
2254 #if FW_ENABLE_TEXT_LOGGING 2255 if (this->isConnected_LogText_OutputPort(0)) {
2256 #if FW_OBJECT_NAMES == 1 2257 const char* _formatString =
2258 "(%s) %s: Could not remove file %s, returned status %" PRIu32
"";
2260 const char* _formatString =
2261 "%s: Could not remove file %s, returned status %" PRIu32
"";
2265 (void) _logString.
format(
2268 this->m_objName.toChar(),
2296 this->timeCaller_out(0, _logTime);
2306 #if FW_AMPCS_COMPATIBLE 2311 static_cast<FwAssertArgType>(_status)
2321 static_cast<FwAssertArgType>(_status)
2330 static_cast<FwAssertArgType>(_status)
2333 #if FW_AMPCS_COMPATIBLE 2336 static_cast<U8>(
sizeof(U32))
2340 static_cast<FwAssertArgType>(_status)
2346 static_cast<FwAssertArgType>(_status)
2359 #if FW_ENABLE_TEXT_LOGGING 2360 if (this->isConnected_LogText_OutputPort(0)) {
2361 #if FW_OBJECT_NAMES == 1 2362 const char* _formatString =
2363 "(%s) %s: Appending %s onto %s failed with status %" PRIu32
"";
2365 const char* _formatString =
2366 "%s: Appending %s onto %s failed with status %" PRIu32
"";
2370 (void) _logString.
format(
2373 this->m_objName.toChar(),
2375 "AppendFileFailed ",
2401 this->timeCaller_out(0, _logTime);
2411 #if FW_AMPCS_COMPATIBLE 2416 static_cast<FwAssertArgType>(_status)
2426 static_cast<FwAssertArgType>(_status)
2435 static_cast<FwAssertArgType>(_status)
2448 #if FW_ENABLE_TEXT_LOGGING 2449 if (this->isConnected_LogText_OutputPort(0)) {
2450 #if FW_OBJECT_NAMES == 1 2451 const char* _formatString =
2452 "(%s) %s: Appended %s to the end of %s";
2454 const char* _formatString =
2455 "%s: Appended %s to the end of %s";
2459 (void) _logString.
format(
2462 this->m_objName.toChar(),
2464 "AppendFileSucceeded ",
2486 this->timeCaller_out(0, _logTime);
2496 #if FW_AMPCS_COMPATIBLE 2501 static_cast<FwAssertArgType>(_status)
2511 static_cast<FwAssertArgType>(_status)
2524 #if FW_ENABLE_TEXT_LOGGING 2525 if (this->isConnected_LogText_OutputPort(0)) {
2526 #if FW_OBJECT_NAMES == 1 2527 const char* _formatString =
2528 "(%s) %s: Created directory %s successfully";
2530 const char* _formatString =
2531 "%s: Created directory %s successfully";
2535 (void) _logString.
format(
2538 this->m_objName.toChar(),
2540 "CreateDirectorySucceeded ",
2561 this->timeCaller_out(0, _logTime);
2571 #if FW_AMPCS_COMPATIBLE 2576 static_cast<FwAssertArgType>(_status)
2586 static_cast<FwAssertArgType>(_status)
2599 #if FW_ENABLE_TEXT_LOGGING 2600 if (this->isConnected_LogText_OutputPort(0)) {
2601 #if FW_OBJECT_NAMES == 1 2602 const char* _formatString =
2603 "(%s) %s: Removed directory %s successfully";
2605 const char* _formatString =
2606 "%s: Removed directory %s successfully";
2610 (void) _logString.
format(
2613 this->m_objName.toChar(),
2615 "RemoveDirectorySucceeded ",
2639 this->timeCaller_out(0, _logTime);
2649 #if FW_AMPCS_COMPATIBLE 2654 static_cast<FwAssertArgType>(_status)
2664 static_cast<FwAssertArgType>(_status)
2673 static_cast<FwAssertArgType>(_status)
2686 #if FW_ENABLE_TEXT_LOGGING 2687 if (this->isConnected_LogText_OutputPort(0)) {
2688 #if FW_OBJECT_NAMES == 1 2689 const char* _formatString =
2690 "(%s) %s: Moved file %s to file %s successfully";
2692 const char* _formatString =
2693 "%s: Moved file %s to file %s successfully";
2697 (void) _logString.
format(
2700 this->m_objName.toChar(),
2702 "MoveFileSucceeded ",
2724 this->timeCaller_out(0, _logTime);
2734 #if FW_AMPCS_COMPATIBLE 2739 static_cast<FwAssertArgType>(_status)
2749 static_cast<FwAssertArgType>(_status)
2762 #if FW_ENABLE_TEXT_LOGGING 2763 if (this->isConnected_LogText_OutputPort(0)) {
2764 #if FW_OBJECT_NAMES == 1 2765 const char* _formatString =
2766 "(%s) %s: Removed file %s successfully";
2768 const char* _formatString =
2769 "%s: Removed file %s successfully";
2773 (void) _logString.
format(
2776 this->m_objName.toChar(),
2778 "RemoveFileSucceeded ",
2802 this->timeCaller_out(0, _logTime);
2812 #if FW_AMPCS_COMPATIBLE 2817 static_cast<FwAssertArgType>(_status)
2827 static_cast<FwAssertArgType>(_status)
2836 static_cast<FwAssertArgType>(_status)
2849 #if FW_ENABLE_TEXT_LOGGING 2850 if (this->isConnected_LogText_OutputPort(0)) {
2851 #if FW_OBJECT_NAMES == 1 2852 const char* _formatString =
2853 "(%s) %s: Appending file %s to the end of %s...";
2855 const char* _formatString =
2856 "%s: Appending file %s to the end of %s...";
2860 (void) _logString.
format(
2863 this->m_objName.toChar(),
2865 "AppendFileStarted ",
2887 this->timeCaller_out(0, _logTime);
2897 #if FW_AMPCS_COMPATIBLE 2902 static_cast<FwAssertArgType>(_status)
2912 static_cast<FwAssertArgType>(_status)
2925 #if FW_ENABLE_TEXT_LOGGING 2926 if (this->isConnected_LogText_OutputPort(0)) {
2927 #if FW_OBJECT_NAMES == 1 2928 const char* _formatString =
2929 "(%s) %s: Creating directory %s...";
2931 const char* _formatString =
2932 "%s: Creating directory %s...";
2936 (void) _logString.
format(
2939 this->m_objName.toChar(),
2941 "CreateDirectoryStarted ",
2962 this->timeCaller_out(0, _logTime);
2972 #if FW_AMPCS_COMPATIBLE 2977 static_cast<FwAssertArgType>(_status)
2987 static_cast<FwAssertArgType>(_status)
3000 #if FW_ENABLE_TEXT_LOGGING 3001 if (this->isConnected_LogText_OutputPort(0)) {
3002 #if FW_OBJECT_NAMES == 1 3003 const char* _formatString =
3004 "(%s) %s: Removing directory %s...";
3006 const char* _formatString =
3007 "%s: Removing directory %s...";
3011 (void) _logString.
format(
3014 this->m_objName.toChar(),
3016 "RemoveDirectoryStarted ",
3040 this->timeCaller_out(0, _logTime);
3050 #if FW_AMPCS_COMPATIBLE 3055 static_cast<FwAssertArgType>(_status)
3065 static_cast<FwAssertArgType>(_status)
3074 static_cast<FwAssertArgType>(_status)
3087 #if FW_ENABLE_TEXT_LOGGING 3088 if (this->isConnected_LogText_OutputPort(0)) {
3089 #if FW_OBJECT_NAMES == 1 3090 const char* _formatString =
3091 "(%s) %s: Moving file %s to file %s...";
3093 const char* _formatString =
3094 "%s: Moving file %s to file %s...";
3098 (void) _logString.
format(
3101 this->m_objName.toChar(),
3125 this->timeCaller_out(0, _logTime);
3135 #if FW_AMPCS_COMPATIBLE 3140 static_cast<FwAssertArgType>(_status)
3150 static_cast<FwAssertArgType>(_status)
3163 #if FW_ENABLE_TEXT_LOGGING 3164 if (this->isConnected_LogText_OutputPort(0)) {
3165 #if FW_OBJECT_NAMES == 1 3166 const char* _formatString =
3167 "(%s) %s: Removing file %s...";
3169 const char* _formatString =
3170 "%s: Removing file %s...";
3174 (void) _logString.
format(
3177 this->m_objName.toChar(),
3179 "RemoveFileStarted ",
3203 this->timeCaller_out(0, _logTime);
3213 #if FW_AMPCS_COMPATIBLE 3218 static_cast<FwAssertArgType>(_status)
3228 static_cast<FwAssertArgType>(_status)
3231 #if FW_AMPCS_COMPATIBLE 3238 static_cast<FwAssertArgType>(_status)
3244 static_cast<FwAssertArgType>(_status)
3257 #if FW_ENABLE_TEXT_LOGGING 3258 if (this->isConnected_LogText_OutputPort(0)) {
3259 #if FW_OBJECT_NAMES == 1 3260 const char* _formatString =
3261 "(%s) %s: The size of file %s is %" PRIu64
" B";
3263 const char* _formatString =
3264 "%s: The size of file %s is %" PRIu64
" B";
3268 (void) _logString.
format(
3271 this->m_objName.toChar(),
3273 "FileSizeSucceeded ",
3298 this->timeCaller_out(0, _logTime);
3308 #if FW_AMPCS_COMPATIBLE 3313 static_cast<FwAssertArgType>(_status)
3323 static_cast<FwAssertArgType>(_status)
3326 #if FW_AMPCS_COMPATIBLE 3329 static_cast<U8>(
sizeof(U32))
3333 static_cast<FwAssertArgType>(_status)
3339 static_cast<FwAssertArgType>(_status)
3352 #if FW_ENABLE_TEXT_LOGGING 3353 if (this->isConnected_LogText_OutputPort(0)) {
3354 #if FW_OBJECT_NAMES == 1 3355 const char* _formatString =
3356 "(%s) %s: Failed to get the size of file %s, returned status %" PRIu32
"";
3358 const char* _formatString =
3359 "%s: Failed to get the size of file %s, returned status %" PRIu32
"";
3363 (void) _logString.
format(
3366 this->m_objName.toChar(),
3390 this->timeCaller_out(0, _logTime);
3400 #if FW_AMPCS_COMPATIBLE 3405 static_cast<FwAssertArgType>(_status)
3415 static_cast<FwAssertArgType>(_status)
3428 #if FW_ENABLE_TEXT_LOGGING 3429 if (this->isConnected_LogText_OutputPort(0)) {
3430 #if FW_OBJECT_NAMES == 1 3431 const char* _formatString =
3432 "(%s) %s: Checking size of file %s...";
3434 const char* _formatString =
3435 "%s: Checking size of file %s...";
3439 (void) _logString.
format(
3442 this->m_objName.toChar(),
3465 this->timeCaller_out(0, _logTime);
3475 #if FW_AMPCS_COMPATIBLE 3480 static_cast<FwAssertArgType>(_status)
3490 static_cast<FwAssertArgType>(_status)
3503 #if FW_ENABLE_TEXT_LOGGING 3504 if (this->isConnected_LogText_OutputPort(0)) {
3505 #if FW_OBJECT_NAMES == 1 3506 const char* _formatString =
3507 "(%s) %s: Listing contents of directory %s...";
3509 const char* _formatString =
3510 "%s: Listing contents of directory %s...";
3514 (void) _logString.
format(
3517 this->m_objName.toChar(),
3519 "ListDirectoryStarted ",
3543 this->timeCaller_out(0, _logTime);
3553 #if FW_AMPCS_COMPATIBLE 3558 static_cast<FwAssertArgType>(_status)
3568 static_cast<FwAssertArgType>(_status)
3571 #if FW_AMPCS_COMPATIBLE 3574 static_cast<U8>(
sizeof(U32))
3578 static_cast<FwAssertArgType>(_status)
3584 static_cast<FwAssertArgType>(_status)
3597 #if FW_ENABLE_TEXT_LOGGING 3598 if (this->isConnected_LogText_OutputPort(0)) {
3599 #if FW_OBJECT_NAMES == 1 3600 const char* _formatString =
3601 "(%s) %s: Directory %s contains %" PRIu32
" files";
3603 const char* _formatString =
3604 "%s: Directory %s contains %" PRIu32
" files";
3608 (void) _logString.
format(
3611 this->m_objName.toChar(),
3613 "ListDirectorySucceeded ",
3638 this->timeCaller_out(0, _logTime);
3648 #if FW_AMPCS_COMPATIBLE 3653 static_cast<FwAssertArgType>(_status)
3663 static_cast<FwAssertArgType>(_status)
3666 #if FW_AMPCS_COMPATIBLE 3669 static_cast<U8>(
sizeof(U32))
3673 static_cast<FwAssertArgType>(_status)
3679 static_cast<FwAssertArgType>(_status)
3692 #if FW_ENABLE_TEXT_LOGGING 3693 if (this->isConnected_LogText_OutputPort(0)) {
3694 #if FW_OBJECT_NAMES == 1 3695 const char* _formatString =
3696 "(%s) %s: Failed to list directory %s, returned status %" PRIu32
"";
3698 const char* _formatString =
3699 "%s: Failed to list directory %s, returned status %" PRIu32
"";
3703 (void) _logString.
format(
3706 this->m_objName.toChar(),
3708 "ListDirectoryError ",
3734 this->timeCaller_out(0, _logTime);
3744 #if FW_AMPCS_COMPATIBLE 3749 static_cast<FwAssertArgType>(_status)
3759 static_cast<FwAssertArgType>(_status)
3768 static_cast<FwAssertArgType>(_status)
3771 #if FW_AMPCS_COMPATIBLE 3778 static_cast<FwAssertArgType>(_status)
3784 static_cast<FwAssertArgType>(_status)
3797 #if FW_ENABLE_TEXT_LOGGING 3798 if (this->isConnected_LogText_OutputPort(0)) {
3799 #if FW_OBJECT_NAMES == 1 3800 const char* _formatString =
3801 "(%s) %s: Directory %s: %s (%" PRIu64
" bytes)";
3803 const char* _formatString =
3804 "%s: Directory %s: %s (%" PRIu64
" bytes)";
3808 (void) _logString.
format(
3811 this->m_objName.toChar(),
3813 "DirectoryListing ",
3839 this->timeCaller_out(0, _logTime);
3849 #if FW_AMPCS_COMPATIBLE 3854 static_cast<FwAssertArgType>(_status)
3864 static_cast<FwAssertArgType>(_status)
3873 static_cast<FwAssertArgType>(_status)
3886 #if FW_ENABLE_TEXT_LOGGING 3887 if (this->isConnected_LogText_OutputPort(0)) {
3888 #if FW_OBJECT_NAMES == 1 3889 const char* _formatString =
3890 "(%s) %s: Directory %s: %s";
3892 const char* _formatString =
3893 "%s: Directory %s: %s";
3897 (void) _logString.
format(
3900 this->m_objName.toChar(),
3902 "DirectoryListingSubdir ",
3924 this->timeCaller_out(0, _logTime);
3934 #if FW_AMPCS_COMPATIBLE 3939 static_cast<FwAssertArgType>(_status)
3949 static_cast<FwAssertArgType>(_status)
3962 #if FW_ENABLE_TEXT_LOGGING 3963 if (this->isConnected_LogText_OutputPort(0)) {
3964 #if FW_OBJECT_NAMES == 1 3965 const char* _formatString =
3966 "(%s) %s: Started CRC calculation for file %s";
3968 const char* _formatString =
3969 "%s: Started CRC calculation for file %s";
3973 (void) _logString.
format(
3976 this->m_objName.toChar(),
3978 "CalculateCrcStarted ",
4002 this->timeCaller_out(0, _logTime);
4012 #if FW_AMPCS_COMPATIBLE 4017 static_cast<FwAssertArgType>(_status)
4027 static_cast<FwAssertArgType>(_status)
4030 #if FW_AMPCS_COMPATIBLE 4033 static_cast<U8>(
sizeof(U32))
4037 static_cast<FwAssertArgType>(_status)
4043 static_cast<FwAssertArgType>(_status)
4056 #if FW_ENABLE_TEXT_LOGGING 4057 if (this->isConnected_LogText_OutputPort(0)) {
4058 #if FW_OBJECT_NAMES == 1 4059 const char* _formatString =
4060 "(%s) %s: Failed CRC calculation for file %s, returned status %" PRIu32
"";
4062 const char* _formatString =
4063 "%s: Failed CRC calculation for file %s, returned status %" PRIu32
"";
4067 (void) _logString.
format(
4070 this->m_objName.toChar(),
4072 "CalculateCrcFailed ",
4097 this->timeCaller_out(0, _logTime);
4107 #if FW_AMPCS_COMPATIBLE 4112 static_cast<FwAssertArgType>(_status)
4122 static_cast<FwAssertArgType>(_status)
4125 #if FW_AMPCS_COMPATIBLE 4128 static_cast<U8>(
sizeof(U32))
4132 static_cast<FwAssertArgType>(_status)
4138 static_cast<FwAssertArgType>(_status)
4151 #if FW_ENABLE_TEXT_LOGGING 4152 if (this->isConnected_LogText_OutputPort(0)) {
4153 #if FW_OBJECT_NAMES == 1 4154 const char* _formatString =
4155 "(%s) %s: %s has CRC value 0x%" PRIx32
"";
4157 const char* _formatString =
4158 "%s: %s has CRC value 0x%" PRIx32
"";
4162 (void) _logString.
format(
4165 this->m_objName.toChar(),
4167 "CalculateCrcSucceeded ",
4192 this->timeCaller_out(0, _logTime);
4202 #if FW_AMPCS_COMPATIBLE 4207 static_cast<FwAssertArgType>(_status)
4217 static_cast<FwAssertArgType>(_status)
4220 #if FW_AMPCS_COMPATIBLE 4227 static_cast<FwAssertArgType>(_status)
4233 static_cast<FwAssertArgType>(_status)
4246 #if FW_ENABLE_TEXT_LOGGING 4247 if (this->isConnected_LogText_OutputPort(0)) {
4248 #if FW_OBJECT_NAMES == 1 4249 const char* _formatString =
4250 "(%s) %s: Failed to format full path for file %s with status %s";
4252 const char* _formatString =
4253 "%s: Failed to format full path for file %s with status %s";
4257 status.toString(statusStr);
4260 (void) _logString.
format(
4263 this->m_objName.toChar(),
4265 "FileNameFormatError ",
4290 this->timeCaller_out(0, _logTime);
4300 #if FW_AMPCS_COMPATIBLE 4305 static_cast<FwAssertArgType>(_status)
4315 static_cast<FwAssertArgType>(_status)
4318 #if FW_AMPCS_COMPATIBLE 4321 static_cast<U8>(
sizeof(U64))
4325 static_cast<FwAssertArgType>(_status)
4331 static_cast<FwAssertArgType>(_status)
4344 #if FW_ENABLE_TEXT_LOGGING 4345 if (this->isConnected_LogText_OutputPort(0)) {
4346 #if FW_OBJECT_NAMES == 1 4347 const char* _formatString =
4348 "(%s) %s: Started data product generation for file %s (%" PRIu64
" bytes)";
4350 const char* _formatString =
4351 "%s: Started data product generation for file %s (%" PRIu64
" bytes)";
4355 (void) _logString.
format(
4358 this->m_objName.toChar(),
4360 "GenerateDpStarted ",
4385 this->timeCaller_out(0, _logTime);
4395 #if FW_AMPCS_COMPATIBLE 4400 static_cast<FwAssertArgType>(_status)
4410 static_cast<FwAssertArgType>(_status)
4413 #if FW_AMPCS_COMPATIBLE 4416 static_cast<U8>(
sizeof(U32))
4420 static_cast<FwAssertArgType>(_status)
4426 static_cast<FwAssertArgType>(_status)
4439 #if FW_ENABLE_TEXT_LOGGING 4440 if (this->isConnected_LogText_OutputPort(0)) {
4441 #if FW_OBJECT_NAMES == 1 4442 const char* _formatString =
4443 "(%s) %s: Completed data product generation for file %s in %" PRIu32
" chunks";
4445 const char* _formatString =
4446 "%s: Completed data product generation for file %s in %" PRIu32
" chunks";
4450 (void) _logString.
format(
4453 this->m_objName.toChar(),
4455 "GenerateDpComplete ",
4481 this->timeCaller_out(0, _logTime);
4491 #if FW_AMPCS_COMPATIBLE 4496 static_cast<FwAssertArgType>(_status)
4506 static_cast<FwAssertArgType>(_status)
4509 #if FW_AMPCS_COMPATIBLE 4516 static_cast<FwAssertArgType>(_status)
4522 static_cast<FwAssertArgType>(_status)
4525 #if FW_AMPCS_COMPATIBLE 4528 static_cast<U8>(
sizeof(U32))
4532 static_cast<FwAssertArgType>(_status)
4538 static_cast<FwAssertArgType>(_status)
4551 #if FW_ENABLE_TEXT_LOGGING 4552 if (this->isConnected_LogText_OutputPort(0)) {
4553 #if FW_OBJECT_NAMES == 1 4554 const char* _formatString =
4555 "(%s) %s: Data product generation failed for file %s at stage %s, status %" PRIu32
"";
4557 const char* _formatString =
4558 "%s: Data product generation failed for file %s at stage %s, status %" PRIu32
"";
4562 stage.toString(stageStr);
4565 (void) _logString.
format(
4568 this->m_objName.toChar(),
4570 "GenerateDpFailed ",
4593 this->timeCaller_out(0, _logTime);
4603 #if FW_AMPCS_COMPATIBLE 4608 static_cast<FwAssertArgType>(_status)
4618 static_cast<FwAssertArgType>(_status)
4631 #if FW_ENABLE_TEXT_LOGGING 4632 if (this->isConnected_LogText_OutputPort(0)) {
4633 #if FW_OBJECT_NAMES == 1 4634 const char* _formatString =
4635 "(%s) %s: Failed to allocate data product buffer for file %s";
4637 const char* _formatString =
4638 "%s: Failed to allocate data product buffer for file %s";
4642 (void) _logString.
format(
4645 this->m_objName.toChar(),
4647 "GenerateDpBufferFailed ",
4673 this->timeCaller_out(0, _logTime);
4683 #if FW_AMPCS_COMPATIBLE 4688 static_cast<FwAssertArgType>(_status)
4698 static_cast<FwAssertArgType>(_status)
4701 #if FW_AMPCS_COMPATIBLE 4704 static_cast<U8>(
sizeof(U64))
4708 static_cast<FwAssertArgType>(_status)
4714 static_cast<FwAssertArgType>(_status)
4717 #if FW_AMPCS_COMPATIBLE 4720 static_cast<U8>(
sizeof(U64))
4724 static_cast<FwAssertArgType>(_status)
4730 static_cast<FwAssertArgType>(_status)
4733 #if FW_AMPCS_COMPATIBLE 4736 static_cast<U8>(
sizeof(U64))
4740 static_cast<FwAssertArgType>(_status)
4746 static_cast<FwAssertArgType>(_status)
4759 #if FW_ENABLE_TEXT_LOGGING 4760 if (this->isConnected_LogText_OutputPort(0)) {
4761 #if FW_OBJECT_NAMES == 1 4762 const char* _formatString =
4763 "(%s) %s: Invalid offset range requested for file %s: [%" PRIu64
", %" PRIu64
") with file size %" PRIu64
"";
4765 const char* _formatString =
4766 "%s: Invalid offset range requested for file %s: [%" PRIu64
", %" PRIu64
") with file size %" PRIu64
"";
4770 (void) _logString.
format(
4773 this->m_objName.toChar(),
4775 "GenerateDpInvalidRange ",
4802 this->timeCaller_out(0, _logTime);
4812 #if FW_AMPCS_COMPATIBLE 4817 static_cast<FwAssertArgType>(_status)
4827 static_cast<FwAssertArgType>(_status)
4836 static_cast<FwAssertArgType>(_status)
4849 #if FW_ENABLE_TEXT_LOGGING 4850 if (this->isConnected_LogText_OutputPort(0)) {
4851 #if FW_OBJECT_NAMES == 1 4852 const char* _formatString =
4853 "(%s) %s: Path %s is outside the configured sandbox directory %s";
4855 const char* _formatString =
4856 "%s: Path %s is outside the configured sandbox directory %s";
4860 (void) _logString.
format(
4863 this->m_objName.toChar(),
4865 "PathOutsideSandbox ",
4897 this->timeCaller_out(0, _tlmTime);
4927 static_cast<FwAssertArgType>(_stat)
4949 static_cast<FwAssertArgType>(_stat)
4982 static_cast<FwAssertArgType>(buffer.
getSize()));
4983 buffer.
setSize(static_cast<U32>(packetSize));
4987 this->productSendOut_out(0, container.
getId(), buffer);
4999 this->timeCaller_out(0, _time);
5014 ComponentIpcSerializableBuffer _msg;
5024 static_cast<FwAssertArgType>(_msgStatus)
5034 static_cast<FwAssertArgType>(_deserStatus)
5037 MsgTypeEnum _msgType =
static_cast<MsgTypeEnum
>(_desMsg);
5039 if (_msgType == FILEMANAGER_COMPONENT_EXIT) {
5044 _deserStatus = _msg.deserializeTo(portNum);
5047 static_cast<FwAssertArgType>(_deserStatus)
5055 _deserStatus = _msg.deserializeTo(key);
5058 static_cast<FwAssertArgType>(_deserStatus)
5070 case CMD_CREATEDIRECTORY: {
5073 _deserStatus = _msg.deserializeTo(_opCode);
5076 static_cast<FwAssertArgType>(_deserStatus)
5081 _deserStatus = _msg.deserializeTo(_cmdSeq);
5084 static_cast<FwAssertArgType>(_deserStatus)
5089 _deserStatus = _msg.deserializeTo(args);
5092 static_cast<FwAssertArgType>(_deserStatus)
5115 #if FW_CMD_CHECK_RESIDUAL 5135 case CMD_MOVEFILE: {
5138 _deserStatus = _msg.deserializeTo(_opCode);
5141 static_cast<FwAssertArgType>(_deserStatus)
5146 _deserStatus = _msg.deserializeTo(_cmdSeq);
5149 static_cast<FwAssertArgType>(_deserStatus)
5154 _deserStatus = _msg.deserializeTo(args);
5157 static_cast<FwAssertArgType>(_deserStatus)
5195 #if FW_CMD_CHECK_RESIDUAL 5216 case CMD_REMOVEDIRECTORY: {
5219 _deserStatus = _msg.deserializeTo(_opCode);
5222 static_cast<FwAssertArgType>(_deserStatus)
5227 _deserStatus = _msg.deserializeTo(_cmdSeq);
5230 static_cast<FwAssertArgType>(_deserStatus)
5235 _deserStatus = _msg.deserializeTo(args);
5238 static_cast<FwAssertArgType>(_deserStatus)
5261 #if FW_CMD_CHECK_RESIDUAL 5281 case CMD_REMOVEFILE: {
5284 _deserStatus = _msg.deserializeTo(_opCode);
5287 static_cast<FwAssertArgType>(_deserStatus)
5292 _deserStatus = _msg.deserializeTo(_cmdSeq);
5295 static_cast<FwAssertArgType>(_deserStatus)
5300 _deserStatus = _msg.deserializeTo(args);
5303 static_cast<FwAssertArgType>(_deserStatus)
5341 #if FW_CMD_CHECK_RESIDUAL 5362 case CMD_APPENDFILE: {
5365 _deserStatus = _msg.deserializeTo(_opCode);
5368 static_cast<FwAssertArgType>(_deserStatus)
5373 _deserStatus = _msg.deserializeTo(_cmdSeq);
5376 static_cast<FwAssertArgType>(_deserStatus)
5381 _deserStatus = _msg.deserializeTo(args);
5384 static_cast<FwAssertArgType>(_deserStatus)
5422 #if FW_CMD_CHECK_RESIDUAL 5443 case CMD_FILESIZE: {
5446 _deserStatus = _msg.deserializeTo(_opCode);
5449 static_cast<FwAssertArgType>(_deserStatus)
5454 _deserStatus = _msg.deserializeTo(_cmdSeq);
5457 static_cast<FwAssertArgType>(_deserStatus)
5462 _deserStatus = _msg.deserializeTo(args);
5465 static_cast<FwAssertArgType>(_deserStatus)
5488 #if FW_CMD_CHECK_RESIDUAL 5508 case CMD_LISTDIRECTORY: {
5511 _deserStatus = _msg.deserializeTo(_opCode);
5514 static_cast<FwAssertArgType>(_deserStatus)
5519 _deserStatus = _msg.deserializeTo(_cmdSeq);
5522 static_cast<FwAssertArgType>(_deserStatus)
5527 _deserStatus = _msg.deserializeTo(args);
5530 static_cast<FwAssertArgType>(_deserStatus)
5553 #if FW_CMD_CHECK_RESIDUAL 5573 case CMD_CALCULATECRC: {
5576 _deserStatus = _msg.deserializeTo(_opCode);
5579 static_cast<FwAssertArgType>(_deserStatus)
5584 _deserStatus = _msg.deserializeTo(_cmdSeq);
5587 static_cast<FwAssertArgType>(_deserStatus)
5592 _deserStatus = _msg.deserializeTo(args);
5595 static_cast<FwAssertArgType>(_deserStatus)
5618 #if FW_CMD_CHECK_RESIDUAL 5638 case CMD_GENERATEDP: {
5641 _deserStatus = _msg.deserializeTo(_opCode);
5644 static_cast<FwAssertArgType>(_deserStatus)
5649 _deserStatus = _msg.deserializeTo(_cmdSeq);
5652 static_cast<FwAssertArgType>(_deserStatus)
5657 _deserStatus = _msg.deserializeTo(args);
5660 static_cast<FwAssertArgType>(_deserStatus)
5758 #if FW_CMD_CHECK_RESIDUAL 5783 case INT_IF_SCHEDININTERNAL: {
5787 _msg.getDeserializeSizeLeft() == 0,
5808 void FileManagerComponentBase ::
5819 compPtr->cmdIn_handlerBase(
5831 void FileManagerComponentBase ::
5840 compPtr->pingIn_handlerBase(
5846 void FileManagerComponentBase ::
5855 compPtr->schedIn_handlerBase(
5861 #if !FW_DIRECT_PORT_CALLS 5867 #if FW_ENABLE_TEXT_LOGGING 5869 void FileManagerComponentBase ::
5879 (0 <= portNum) && (portNum < this->getNum_LogText_OutputPorts()),
5880 static_cast<FwAssertArgType>(portNum)
5884 this->m_LogText_OutputPort[portNum].isConnected(),
5885 static_cast<FwAssertArgType>(portNum)
5887 this->m_LogText_OutputPort[portNum].invoke(
5897 void FileManagerComponentBase ::
5905 static_cast<FwAssertArgType>(portNum)
5909 this->m_cmdRegOut_OutputPort[portNum].isConnected(),
5910 static_cast<FwAssertArgType>(portNum)
5912 this->m_cmdRegOut_OutputPort[portNum].
invoke(
5917 void FileManagerComponentBase ::
5927 static_cast<FwAssertArgType>(portNum)
5931 this->m_cmdResponseOut_OutputPort[portNum].isConnected(),
5932 static_cast<FwAssertArgType>(portNum)
5934 this->m_cmdResponseOut_OutputPort[portNum].
invoke(
5941 void FileManagerComponentBase ::
5952 static_cast<FwAssertArgType>(portNum)
5956 this->m_eventOut_OutputPort[portNum].isConnected(),
5957 static_cast<FwAssertArgType>(portNum)
5959 this->m_eventOut_OutputPort[portNum].
invoke(
5977 static_cast<FwAssertArgType>(portNum)
5981 this->m_productGetOut_OutputPort[portNum].isConnected(),
5982 static_cast<FwAssertArgType>(portNum)
5984 return this->m_productGetOut_OutputPort[portNum].
invoke(
5991 void FileManagerComponentBase ::
6000 static_cast<FwAssertArgType>(portNum)
6004 this->m_productSendOut_OutputPort[portNum].isConnected(),
6005 static_cast<FwAssertArgType>(portNum)
6007 this->m_productSendOut_OutputPort[portNum].
invoke(
6013 void FileManagerComponentBase ::
6021 static_cast<FwAssertArgType>(portNum)
6025 this->m_timeCaller_OutputPort[portNum].isConnected(),
6026 static_cast<FwAssertArgType>(portNum)
6028 this->m_timeCaller_OutputPort[portNum].
invoke(
6033 void FileManagerComponentBase ::
6043 static_cast<FwAssertArgType>(portNum)
6047 this->m_tlmOut_OutputPort[portNum].isConnected(),
6048 static_cast<FwAssertArgType>(portNum)
6050 this->m_tlmOut_OutputPort[portNum].
invoke(
6065 ContainerId::T containerId,
6068 DpContainer& container
6072 const FwDpIdType globalId = baseId + containerId;
6075 const Fw::Success::T status = this->productGetOut_out(0, globalId, size, buffer);
6079 container = DpContainer(globalId, buffer, baseId);
6080 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.
void addCallPort(InputTimePort *callPort)
Register an input port.
static constexpr FwSizeType CAPACITY
void log_WARNING_HI_ListDirectoryError(const Fw::StringBase &dirName, U32 status) const
void AppendFile_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
void log_ACTIVITY_HI_DirectoryListingSubdir(const Fw::StringBase &dirName, const Fw::StringBase &subdirName) const
void setTimeTag(Fw::Time timeTag)
Set the time tag.
void log_ACTIVITY_HI_CreateDirectoryStarted(const Fw::StringBase &dirName) const
An error occurred while attempting to create a directory.
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
A command path argument was rejected by the configured sandbox directory.
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.
Invalid offset range requested for data product generation.
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
The File System component deleted an existing file without error.
static constexpr FwIndexType getNum_tlmOut_OutputPorts()
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)
File data product generation started.
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.
The File System component began creating a new directory.
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
Directory listing file entry.
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
bool isConnected_pingOut_OutputPort(FwIndexType portNum) const
DpContainer()
Constructor with default initialization.
virtual void schedInInternal_internalInterfaceHandler()=0
Internal interface handler for schedInInternal.
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)
The File System component began deleting an existing file.
void init()
Object initializer.
message to exit active component task
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.
The File System component moved a file to a new location without error.
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].
Channel ID for CommandsExecuted.
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.
An error occurred while attempting to remove a file.
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)
Directory listing completed successfully.
A data product container.
Omit length from serialization.
The File System component began deleting a directory.
ActiveComponentBase(const char *name)
Constructor.
void init()
Initialization function.
Error formatting a file path.
static constexpr FwIndexType getNum_schedIn_InputPorts()
void invoke(Fw::Time &time) const
Invoke a port connection.
Serializable::SizeType getDeserializeSizeLeft() const override
Get remaining deserialization buffer size.
Calculate the CRC of a file.
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.
FwIdType FwChanIdType
The type of a telemetry channel identifier.
Append 1 file's contents to the end of another.
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
The File System component began moving a file to a new location.
void schedInInternal_internalInterfaceInvoke()
Internal interface base-class function for schedInInternal.
virtual void CreateDirectory_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command CreateDirectory.
void resetDeser() override
Reset deserialization pointer to beginning of buffer.
File data product generation completed.
A serious but recoverable event.
FwSizeType FwSizeStoreType
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
virtual void schedInInternal_overflowHook()=0
Overflow hook for async input port schedInInternal.
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
Data product container allocation failed.
Command failed to deserialize.
void log_WARNING_HI_DirectoryRemoveError(const Fw::StringBase &dirName, U32 status) const
PlatformQueuePriorityType FwQueuePriorityType
The type of queue priorities used.
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
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
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
The File System component created a new directory without error.
void set_timeCaller_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeCaller[portNum].
The size of the serial representation.
void addCallPort(InputDpGetPort *callPort)
Register an input port.
The File System component deleted and existing directory without error.
void addCallPort(InputLogPort *callPort)
Register an input port.
Starting directory listing.
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].
static constexpr FwIndexType getNum_cmdIn_InputPorts()
An error occurred while attempting to remove a directory.
RateGroupDivider component implementation.
File data product generation failed.
virtual void pingIn_preMsgHook(FwIndexType portNum, U32 key)
Pre-message hook for async input port pingIn.
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.
The File System component appended 2 files without error.
An error occurred while attempting to move a file.
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.
void init()
Initialization function.
The File System component returned status non-zero when trying to append 2 files together.
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].
Remove a directory, which must be empty.
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.
List the contents of a directory.
void tlmWrite_CommandsExecuted(U32 arg, Fw::Time _tlmTime=Fw::Time()) const
void CreateDirectory_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
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.
The File System component appended 2 files without error.
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
Failed to list directory.