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)
1112 static_cast<FwAssertArgType>(qStatus)
1125 static_cast<FwAssertArgType>(portNum)
1152 #if !FW_DIRECT_PORT_CALLS 1166 static_cast<FwAssertArgType>(portNum)
1170 this->m_pingOut_OutputPort[portNum].isConnected(),
1171 static_cast<FwAssertArgType>(portNum)
1173 this->m_pingOut_OutputPort[portNum].
invoke(
1187 ComponentIpcSerializableBuffer msg;
1191 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(INT_IF_RUN));
1194 static_cast<FwAssertArgType>(_status)
1198 _status = msg.serializeFrom(static_cast<FwIndexType>(0));
1201 static_cast<FwAssertArgType>(_status)
1208 if (qStatus == Os::Queue::Status::FULL) {
1215 static_cast<FwAssertArgType>(qStatus)
1231 this->cmdResponseOut_out(0, opCode, cmdSeq, response);
1252 ComponentIpcSerializableBuffer msg;
1256 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_CREATEDIRECTORY));
1259 static_cast<FwAssertArgType>(_status)
1265 _status = msg.serializeFrom(port);
1268 static_cast<FwAssertArgType>(_status)
1271 _status = msg.serializeFrom(opCode);
1274 static_cast<FwAssertArgType>(_status)
1277 _status = msg.serializeFrom(cmdSeq);
1280 static_cast<FwAssertArgType>(_status)
1283 _status = msg.serializeFrom(args);
1286 static_cast<FwAssertArgType>(_status)
1295 static_cast<FwAssertArgType>(qStatus)
1311 ComponentIpcSerializableBuffer msg;
1315 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_MOVEFILE));
1318 static_cast<FwAssertArgType>(_status)
1324 _status = msg.serializeFrom(port);
1327 static_cast<FwAssertArgType>(_status)
1330 _status = msg.serializeFrom(opCode);
1333 static_cast<FwAssertArgType>(_status)
1336 _status = msg.serializeFrom(cmdSeq);
1339 static_cast<FwAssertArgType>(_status)
1342 _status = msg.serializeFrom(args);
1345 static_cast<FwAssertArgType>(_status)
1354 static_cast<FwAssertArgType>(qStatus)
1370 ComponentIpcSerializableBuffer msg;
1374 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_REMOVEDIRECTORY));
1377 static_cast<FwAssertArgType>(_status)
1383 _status = msg.serializeFrom(port);
1386 static_cast<FwAssertArgType>(_status)
1389 _status = msg.serializeFrom(opCode);
1392 static_cast<FwAssertArgType>(_status)
1395 _status = msg.serializeFrom(cmdSeq);
1398 static_cast<FwAssertArgType>(_status)
1401 _status = msg.serializeFrom(args);
1404 static_cast<FwAssertArgType>(_status)
1413 static_cast<FwAssertArgType>(qStatus)
1429 ComponentIpcSerializableBuffer msg;
1433 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_REMOVEFILE));
1436 static_cast<FwAssertArgType>(_status)
1442 _status = msg.serializeFrom(port);
1445 static_cast<FwAssertArgType>(_status)
1448 _status = msg.serializeFrom(opCode);
1451 static_cast<FwAssertArgType>(_status)
1454 _status = msg.serializeFrom(cmdSeq);
1457 static_cast<FwAssertArgType>(_status)
1460 _status = msg.serializeFrom(args);
1463 static_cast<FwAssertArgType>(_status)
1472 static_cast<FwAssertArgType>(qStatus)
1488 ComponentIpcSerializableBuffer msg;
1492 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_APPENDFILE));
1495 static_cast<FwAssertArgType>(_status)
1501 _status = msg.serializeFrom(port);
1504 static_cast<FwAssertArgType>(_status)
1507 _status = msg.serializeFrom(opCode);
1510 static_cast<FwAssertArgType>(_status)
1513 _status = msg.serializeFrom(cmdSeq);
1516 static_cast<FwAssertArgType>(_status)
1519 _status = msg.serializeFrom(args);
1522 static_cast<FwAssertArgType>(_status)
1531 static_cast<FwAssertArgType>(qStatus)
1547 ComponentIpcSerializableBuffer msg;
1551 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_FILESIZE));
1554 static_cast<FwAssertArgType>(_status)
1560 _status = msg.serializeFrom(port);
1563 static_cast<FwAssertArgType>(_status)
1566 _status = msg.serializeFrom(opCode);
1569 static_cast<FwAssertArgType>(_status)
1572 _status = msg.serializeFrom(cmdSeq);
1575 static_cast<FwAssertArgType>(_status)
1578 _status = msg.serializeFrom(args);
1581 static_cast<FwAssertArgType>(_status)
1590 static_cast<FwAssertArgType>(qStatus)
1606 ComponentIpcSerializableBuffer msg;
1610 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_LISTDIRECTORY));
1613 static_cast<FwAssertArgType>(_status)
1619 _status = msg.serializeFrom(port);
1622 static_cast<FwAssertArgType>(_status)
1625 _status = msg.serializeFrom(opCode);
1628 static_cast<FwAssertArgType>(_status)
1631 _status = msg.serializeFrom(cmdSeq);
1634 static_cast<FwAssertArgType>(_status)
1637 _status = msg.serializeFrom(args);
1640 static_cast<FwAssertArgType>(_status)
1649 static_cast<FwAssertArgType>(qStatus)
1665 ComponentIpcSerializableBuffer msg;
1669 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_CALCULATECRC));
1672 static_cast<FwAssertArgType>(_status)
1678 _status = msg.serializeFrom(port);
1681 static_cast<FwAssertArgType>(_status)
1684 _status = msg.serializeFrom(opCode);
1687 static_cast<FwAssertArgType>(_status)
1690 _status = msg.serializeFrom(cmdSeq);
1693 static_cast<FwAssertArgType>(_status)
1696 _status = msg.serializeFrom(args);
1699 static_cast<FwAssertArgType>(_status)
1708 static_cast<FwAssertArgType>(qStatus)
1724 ComponentIpcSerializableBuffer msg;
1728 _status = msg.serializeFrom(static_cast<FwEnumStoreType>(CMD_GENERATEDP));
1731 static_cast<FwAssertArgType>(_status)
1737 _status = msg.serializeFrom(port);
1740 static_cast<FwAssertArgType>(_status)
1743 _status = msg.serializeFrom(opCode);
1746 static_cast<FwAssertArgType>(_status)
1749 _status = msg.serializeFrom(cmdSeq);
1752 static_cast<FwAssertArgType>(_status)
1755 _status = msg.serializeFrom(args);
1758 static_cast<FwAssertArgType>(_status)
1767 static_cast<FwAssertArgType>(qStatus)
1891 this->timeCaller_out(0, _logTime);
1901 #if FW_AMPCS_COMPATIBLE 1906 static_cast<FwAssertArgType>(_status)
1916 static_cast<FwAssertArgType>(_status)
1919 #if FW_AMPCS_COMPATIBLE 1922 static_cast<U8>(
sizeof(U32))
1926 static_cast<FwAssertArgType>(_status)
1932 static_cast<FwAssertArgType>(_status)
1945 #if FW_ENABLE_TEXT_LOGGING 1946 if (this->isConnected_LogText_OutputPort(0)) {
1947 #if FW_OBJECT_NAMES == 1 1948 const char* _formatString =
1949 "(%s) %s: Could not create directory %s, returned status %" PRIu32
"";
1951 const char* _formatString =
1952 "%s: Could not create directory %s, returned status %" PRIu32
"";
1956 (void) _logString.
format(
1959 this->m_objName.toChar(),
1961 "DirectoryCreateError ",
1986 this->timeCaller_out(0, _logTime);
1996 #if FW_AMPCS_COMPATIBLE 2001 static_cast<FwAssertArgType>(_status)
2011 static_cast<FwAssertArgType>(_status)
2014 #if FW_AMPCS_COMPATIBLE 2017 static_cast<U8>(
sizeof(U32))
2021 static_cast<FwAssertArgType>(_status)
2027 static_cast<FwAssertArgType>(_status)
2040 #if FW_ENABLE_TEXT_LOGGING 2041 if (this->isConnected_LogText_OutputPort(0)) {
2042 #if FW_OBJECT_NAMES == 1 2043 const char* _formatString =
2044 "(%s) %s: Could not remove directory %s, returned status %" PRIu32
"";
2046 const char* _formatString =
2047 "%s: Could not remove directory %s, returned status %" PRIu32
"";
2051 (void) _logString.
format(
2054 this->m_objName.toChar(),
2056 "DirectoryRemoveError ",
2082 this->timeCaller_out(0, _logTime);
2092 #if FW_AMPCS_COMPATIBLE 2097 static_cast<FwAssertArgType>(_status)
2107 static_cast<FwAssertArgType>(_status)
2116 static_cast<FwAssertArgType>(_status)
2119 #if FW_AMPCS_COMPATIBLE 2122 static_cast<U8>(
sizeof(U32))
2126 static_cast<FwAssertArgType>(_status)
2132 static_cast<FwAssertArgType>(_status)
2145 #if FW_ENABLE_TEXT_LOGGING 2146 if (this->isConnected_LogText_OutputPort(0)) {
2147 #if FW_OBJECT_NAMES == 1 2148 const char* _formatString =
2149 "(%s) %s: Could not move file %s to file %s, returned status %" PRIu32
"";
2151 const char* _formatString =
2152 "%s: Could not move file %s to file %s, returned status %" PRIu32
"";
2156 (void) _logString.
format(
2159 this->m_objName.toChar(),
2187 this->timeCaller_out(0, _logTime);
2197 #if FW_AMPCS_COMPATIBLE 2202 static_cast<FwAssertArgType>(_status)
2212 static_cast<FwAssertArgType>(_status)
2215 #if FW_AMPCS_COMPATIBLE 2218 static_cast<U8>(
sizeof(U32))
2222 static_cast<FwAssertArgType>(_status)
2228 static_cast<FwAssertArgType>(_status)
2241 #if FW_ENABLE_TEXT_LOGGING 2242 if (this->isConnected_LogText_OutputPort(0)) {
2243 #if FW_OBJECT_NAMES == 1 2244 const char* _formatString =
2245 "(%s) %s: Could not remove file %s, returned status %" PRIu32
"";
2247 const char* _formatString =
2248 "%s: Could not remove file %s, returned status %" PRIu32
"";
2252 (void) _logString.
format(
2255 this->m_objName.toChar(),
2283 this->timeCaller_out(0, _logTime);
2293 #if FW_AMPCS_COMPATIBLE 2298 static_cast<FwAssertArgType>(_status)
2308 static_cast<FwAssertArgType>(_status)
2317 static_cast<FwAssertArgType>(_status)
2320 #if FW_AMPCS_COMPATIBLE 2323 static_cast<U8>(
sizeof(U32))
2327 static_cast<FwAssertArgType>(_status)
2333 static_cast<FwAssertArgType>(_status)
2346 #if FW_ENABLE_TEXT_LOGGING 2347 if (this->isConnected_LogText_OutputPort(0)) {
2348 #if FW_OBJECT_NAMES == 1 2349 const char* _formatString =
2350 "(%s) %s: Appending %s onto %s failed with status %" PRIu32
"";
2352 const char* _formatString =
2353 "%s: Appending %s onto %s failed with status %" PRIu32
"";
2357 (void) _logString.
format(
2360 this->m_objName.toChar(),
2362 "AppendFileFailed ",
2388 this->timeCaller_out(0, _logTime);
2398 #if FW_AMPCS_COMPATIBLE 2403 static_cast<FwAssertArgType>(_status)
2413 static_cast<FwAssertArgType>(_status)
2422 static_cast<FwAssertArgType>(_status)
2435 #if FW_ENABLE_TEXT_LOGGING 2436 if (this->isConnected_LogText_OutputPort(0)) {
2437 #if FW_OBJECT_NAMES == 1 2438 const char* _formatString =
2439 "(%s) %s: Appended %s to the end of %s";
2441 const char* _formatString =
2442 "%s: Appended %s to the end of %s";
2446 (void) _logString.
format(
2449 this->m_objName.toChar(),
2451 "AppendFileSucceeded ",
2473 this->timeCaller_out(0, _logTime);
2483 #if FW_AMPCS_COMPATIBLE 2488 static_cast<FwAssertArgType>(_status)
2498 static_cast<FwAssertArgType>(_status)
2511 #if FW_ENABLE_TEXT_LOGGING 2512 if (this->isConnected_LogText_OutputPort(0)) {
2513 #if FW_OBJECT_NAMES == 1 2514 const char* _formatString =
2515 "(%s) %s: Created directory %s successfully";
2517 const char* _formatString =
2518 "%s: Created directory %s successfully";
2522 (void) _logString.
format(
2525 this->m_objName.toChar(),
2527 "CreateDirectorySucceeded ",
2548 this->timeCaller_out(0, _logTime);
2558 #if FW_AMPCS_COMPATIBLE 2563 static_cast<FwAssertArgType>(_status)
2573 static_cast<FwAssertArgType>(_status)
2586 #if FW_ENABLE_TEXT_LOGGING 2587 if (this->isConnected_LogText_OutputPort(0)) {
2588 #if FW_OBJECT_NAMES == 1 2589 const char* _formatString =
2590 "(%s) %s: Removed directory %s successfully";
2592 const char* _formatString =
2593 "%s: Removed directory %s successfully";
2597 (void) _logString.
format(
2600 this->m_objName.toChar(),
2602 "RemoveDirectorySucceeded ",
2626 this->timeCaller_out(0, _logTime);
2636 #if FW_AMPCS_COMPATIBLE 2641 static_cast<FwAssertArgType>(_status)
2651 static_cast<FwAssertArgType>(_status)
2660 static_cast<FwAssertArgType>(_status)
2673 #if FW_ENABLE_TEXT_LOGGING 2674 if (this->isConnected_LogText_OutputPort(0)) {
2675 #if FW_OBJECT_NAMES == 1 2676 const char* _formatString =
2677 "(%s) %s: Moved file %s to file %s successfully";
2679 const char* _formatString =
2680 "%s: Moved file %s to file %s successfully";
2684 (void) _logString.
format(
2687 this->m_objName.toChar(),
2689 "MoveFileSucceeded ",
2711 this->timeCaller_out(0, _logTime);
2721 #if FW_AMPCS_COMPATIBLE 2726 static_cast<FwAssertArgType>(_status)
2736 static_cast<FwAssertArgType>(_status)
2749 #if FW_ENABLE_TEXT_LOGGING 2750 if (this->isConnected_LogText_OutputPort(0)) {
2751 #if FW_OBJECT_NAMES == 1 2752 const char* _formatString =
2753 "(%s) %s: Removed file %s successfully";
2755 const char* _formatString =
2756 "%s: Removed file %s successfully";
2760 (void) _logString.
format(
2763 this->m_objName.toChar(),
2765 "RemoveFileSucceeded ",
2789 this->timeCaller_out(0, _logTime);
2799 #if FW_AMPCS_COMPATIBLE 2804 static_cast<FwAssertArgType>(_status)
2814 static_cast<FwAssertArgType>(_status)
2823 static_cast<FwAssertArgType>(_status)
2836 #if FW_ENABLE_TEXT_LOGGING 2837 if (this->isConnected_LogText_OutputPort(0)) {
2838 #if FW_OBJECT_NAMES == 1 2839 const char* _formatString =
2840 "(%s) %s: Appending file %s to the end of %s...";
2842 const char* _formatString =
2843 "%s: Appending file %s to the end of %s...";
2847 (void) _logString.
format(
2850 this->m_objName.toChar(),
2852 "AppendFileStarted ",
2874 this->timeCaller_out(0, _logTime);
2884 #if FW_AMPCS_COMPATIBLE 2889 static_cast<FwAssertArgType>(_status)
2899 static_cast<FwAssertArgType>(_status)
2912 #if FW_ENABLE_TEXT_LOGGING 2913 if (this->isConnected_LogText_OutputPort(0)) {
2914 #if FW_OBJECT_NAMES == 1 2915 const char* _formatString =
2916 "(%s) %s: Creating directory %s...";
2918 const char* _formatString =
2919 "%s: Creating directory %s...";
2923 (void) _logString.
format(
2926 this->m_objName.toChar(),
2928 "CreateDirectoryStarted ",
2949 this->timeCaller_out(0, _logTime);
2959 #if FW_AMPCS_COMPATIBLE 2964 static_cast<FwAssertArgType>(_status)
2974 static_cast<FwAssertArgType>(_status)
2987 #if FW_ENABLE_TEXT_LOGGING 2988 if (this->isConnected_LogText_OutputPort(0)) {
2989 #if FW_OBJECT_NAMES == 1 2990 const char* _formatString =
2991 "(%s) %s: Removing directory %s...";
2993 const char* _formatString =
2994 "%s: Removing directory %s...";
2998 (void) _logString.
format(
3001 this->m_objName.toChar(),
3003 "RemoveDirectoryStarted ",
3027 this->timeCaller_out(0, _logTime);
3037 #if FW_AMPCS_COMPATIBLE 3042 static_cast<FwAssertArgType>(_status)
3052 static_cast<FwAssertArgType>(_status)
3061 static_cast<FwAssertArgType>(_status)
3074 #if FW_ENABLE_TEXT_LOGGING 3075 if (this->isConnected_LogText_OutputPort(0)) {
3076 #if FW_OBJECT_NAMES == 1 3077 const char* _formatString =
3078 "(%s) %s: Moving file %s to file %s...";
3080 const char* _formatString =
3081 "%s: Moving file %s to file %s...";
3085 (void) _logString.
format(
3088 this->m_objName.toChar(),
3112 this->timeCaller_out(0, _logTime);
3122 #if FW_AMPCS_COMPATIBLE 3127 static_cast<FwAssertArgType>(_status)
3137 static_cast<FwAssertArgType>(_status)
3150 #if FW_ENABLE_TEXT_LOGGING 3151 if (this->isConnected_LogText_OutputPort(0)) {
3152 #if FW_OBJECT_NAMES == 1 3153 const char* _formatString =
3154 "(%s) %s: Removing file %s...";
3156 const char* _formatString =
3157 "%s: Removing file %s...";
3161 (void) _logString.
format(
3164 this->m_objName.toChar(),
3166 "RemoveFileStarted ",
3190 this->timeCaller_out(0, _logTime);
3200 #if FW_AMPCS_COMPATIBLE 3205 static_cast<FwAssertArgType>(_status)
3215 static_cast<FwAssertArgType>(_status)
3218 #if FW_AMPCS_COMPATIBLE 3225 static_cast<FwAssertArgType>(_status)
3231 static_cast<FwAssertArgType>(_status)
3244 #if FW_ENABLE_TEXT_LOGGING 3245 if (this->isConnected_LogText_OutputPort(0)) {
3246 #if FW_OBJECT_NAMES == 1 3247 const char* _formatString =
3248 "(%s) %s: The size of file %s is %" PRIu64
" B";
3250 const char* _formatString =
3251 "%s: The size of file %s is %" PRIu64
" B";
3255 (void) _logString.
format(
3258 this->m_objName.toChar(),
3260 "FileSizeSucceeded ",
3285 this->timeCaller_out(0, _logTime);
3295 #if FW_AMPCS_COMPATIBLE 3300 static_cast<FwAssertArgType>(_status)
3310 static_cast<FwAssertArgType>(_status)
3313 #if FW_AMPCS_COMPATIBLE 3316 static_cast<U8>(
sizeof(U32))
3320 static_cast<FwAssertArgType>(_status)
3326 static_cast<FwAssertArgType>(_status)
3339 #if FW_ENABLE_TEXT_LOGGING 3340 if (this->isConnected_LogText_OutputPort(0)) {
3341 #if FW_OBJECT_NAMES == 1 3342 const char* _formatString =
3343 "(%s) %s: Failed to get the size of file %s, returned status %" PRIu32
"";
3345 const char* _formatString =
3346 "%s: Failed to get the size of file %s, returned status %" PRIu32
"";
3350 (void) _logString.
format(
3353 this->m_objName.toChar(),
3377 this->timeCaller_out(0, _logTime);
3387 #if FW_AMPCS_COMPATIBLE 3392 static_cast<FwAssertArgType>(_status)
3402 static_cast<FwAssertArgType>(_status)
3415 #if FW_ENABLE_TEXT_LOGGING 3416 if (this->isConnected_LogText_OutputPort(0)) {
3417 #if FW_OBJECT_NAMES == 1 3418 const char* _formatString =
3419 "(%s) %s: Checking size of file %s...";
3421 const char* _formatString =
3422 "%s: Checking size of file %s...";
3426 (void) _logString.
format(
3429 this->m_objName.toChar(),
3452 this->timeCaller_out(0, _logTime);
3462 #if FW_AMPCS_COMPATIBLE 3467 static_cast<FwAssertArgType>(_status)
3477 static_cast<FwAssertArgType>(_status)
3490 #if FW_ENABLE_TEXT_LOGGING 3491 if (this->isConnected_LogText_OutputPort(0)) {
3492 #if FW_OBJECT_NAMES == 1 3493 const char* _formatString =
3494 "(%s) %s: Listing contents of directory %s...";
3496 const char* _formatString =
3497 "%s: Listing contents of directory %s...";
3501 (void) _logString.
format(
3504 this->m_objName.toChar(),
3506 "ListDirectoryStarted ",
3530 this->timeCaller_out(0, _logTime);
3540 #if FW_AMPCS_COMPATIBLE 3545 static_cast<FwAssertArgType>(_status)
3555 static_cast<FwAssertArgType>(_status)
3558 #if FW_AMPCS_COMPATIBLE 3561 static_cast<U8>(
sizeof(U32))
3565 static_cast<FwAssertArgType>(_status)
3571 static_cast<FwAssertArgType>(_status)
3584 #if FW_ENABLE_TEXT_LOGGING 3585 if (this->isConnected_LogText_OutputPort(0)) {
3586 #if FW_OBJECT_NAMES == 1 3587 const char* _formatString =
3588 "(%s) %s: Directory %s contains %" PRIu32
" files";
3590 const char* _formatString =
3591 "%s: Directory %s contains %" PRIu32
" files";
3595 (void) _logString.
format(
3598 this->m_objName.toChar(),
3600 "ListDirectorySucceeded ",
3625 this->timeCaller_out(0, _logTime);
3635 #if FW_AMPCS_COMPATIBLE 3640 static_cast<FwAssertArgType>(_status)
3650 static_cast<FwAssertArgType>(_status)
3653 #if FW_AMPCS_COMPATIBLE 3656 static_cast<U8>(
sizeof(U32))
3660 static_cast<FwAssertArgType>(_status)
3666 static_cast<FwAssertArgType>(_status)
3679 #if FW_ENABLE_TEXT_LOGGING 3680 if (this->isConnected_LogText_OutputPort(0)) {
3681 #if FW_OBJECT_NAMES == 1 3682 const char* _formatString =
3683 "(%s) %s: Failed to list directory %s, returned status %" PRIu32
"";
3685 const char* _formatString =
3686 "%s: Failed to list directory %s, returned status %" PRIu32
"";
3690 (void) _logString.
format(
3693 this->m_objName.toChar(),
3695 "ListDirectoryError ",
3721 this->timeCaller_out(0, _logTime);
3731 #if FW_AMPCS_COMPATIBLE 3736 static_cast<FwAssertArgType>(_status)
3746 static_cast<FwAssertArgType>(_status)
3755 static_cast<FwAssertArgType>(_status)
3758 #if FW_AMPCS_COMPATIBLE 3765 static_cast<FwAssertArgType>(_status)
3771 static_cast<FwAssertArgType>(_status)
3784 #if FW_ENABLE_TEXT_LOGGING 3785 if (this->isConnected_LogText_OutputPort(0)) {
3786 #if FW_OBJECT_NAMES == 1 3787 const char* _formatString =
3788 "(%s) %s: Directory %s: %s (%" PRIu64
" bytes)";
3790 const char* _formatString =
3791 "%s: Directory %s: %s (%" PRIu64
" bytes)";
3795 (void) _logString.
format(
3798 this->m_objName.toChar(),
3800 "DirectoryListing ",
3826 this->timeCaller_out(0, _logTime);
3836 #if FW_AMPCS_COMPATIBLE 3841 static_cast<FwAssertArgType>(_status)
3851 static_cast<FwAssertArgType>(_status)
3860 static_cast<FwAssertArgType>(_status)
3873 #if FW_ENABLE_TEXT_LOGGING 3874 if (this->isConnected_LogText_OutputPort(0)) {
3875 #if FW_OBJECT_NAMES == 1 3876 const char* _formatString =
3877 "(%s) %s: Directory %s: %s";
3879 const char* _formatString =
3880 "%s: Directory %s: %s";
3884 (void) _logString.
format(
3887 this->m_objName.toChar(),
3889 "DirectoryListingSubdir ",
3911 this->timeCaller_out(0, _logTime);
3921 #if FW_AMPCS_COMPATIBLE 3926 static_cast<FwAssertArgType>(_status)
3936 static_cast<FwAssertArgType>(_status)
3949 #if FW_ENABLE_TEXT_LOGGING 3950 if (this->isConnected_LogText_OutputPort(0)) {
3951 #if FW_OBJECT_NAMES == 1 3952 const char* _formatString =
3953 "(%s) %s: Started CRC calculation for file %s";
3955 const char* _formatString =
3956 "%s: Started CRC calculation for file %s";
3960 (void) _logString.
format(
3963 this->m_objName.toChar(),
3965 "CalculateCrcStarted ",
3989 this->timeCaller_out(0, _logTime);
3999 #if FW_AMPCS_COMPATIBLE 4004 static_cast<FwAssertArgType>(_status)
4014 static_cast<FwAssertArgType>(_status)
4017 #if FW_AMPCS_COMPATIBLE 4020 static_cast<U8>(
sizeof(U32))
4024 static_cast<FwAssertArgType>(_status)
4030 static_cast<FwAssertArgType>(_status)
4043 #if FW_ENABLE_TEXT_LOGGING 4044 if (this->isConnected_LogText_OutputPort(0)) {
4045 #if FW_OBJECT_NAMES == 1 4046 const char* _formatString =
4047 "(%s) %s: Failed CRC calculation for file %s, returned status %" PRIu32
"";
4049 const char* _formatString =
4050 "%s: Failed CRC calculation for file %s, returned status %" PRIu32
"";
4054 (void) _logString.
format(
4057 this->m_objName.toChar(),
4059 "CalculateCrcFailed ",
4084 this->timeCaller_out(0, _logTime);
4094 #if FW_AMPCS_COMPATIBLE 4099 static_cast<FwAssertArgType>(_status)
4109 static_cast<FwAssertArgType>(_status)
4112 #if FW_AMPCS_COMPATIBLE 4115 static_cast<U8>(
sizeof(U32))
4119 static_cast<FwAssertArgType>(_status)
4125 static_cast<FwAssertArgType>(_status)
4138 #if FW_ENABLE_TEXT_LOGGING 4139 if (this->isConnected_LogText_OutputPort(0)) {
4140 #if FW_OBJECT_NAMES == 1 4141 const char* _formatString =
4142 "(%s) %s: %s has CRC value 0x%" PRIx32
"";
4144 const char* _formatString =
4145 "%s: %s has CRC value 0x%" PRIx32
"";
4149 (void) _logString.
format(
4152 this->m_objName.toChar(),
4154 "CalculateCrcSucceeded ",
4179 this->timeCaller_out(0, _logTime);
4189 #if FW_AMPCS_COMPATIBLE 4194 static_cast<FwAssertArgType>(_status)
4204 static_cast<FwAssertArgType>(_status)
4207 #if FW_AMPCS_COMPATIBLE 4214 static_cast<FwAssertArgType>(_status)
4220 static_cast<FwAssertArgType>(_status)
4233 #if FW_ENABLE_TEXT_LOGGING 4234 if (this->isConnected_LogText_OutputPort(0)) {
4235 #if FW_OBJECT_NAMES == 1 4236 const char* _formatString =
4237 "(%s) %s: Failed to format full path for file %s with status %s";
4239 const char* _formatString =
4240 "%s: Failed to format full path for file %s with status %s";
4244 status.toString(statusStr);
4247 (void) _logString.
format(
4250 this->m_objName.toChar(),
4252 "FileNameFormatError ",
4277 this->timeCaller_out(0, _logTime);
4287 #if FW_AMPCS_COMPATIBLE 4292 static_cast<FwAssertArgType>(_status)
4302 static_cast<FwAssertArgType>(_status)
4305 #if FW_AMPCS_COMPATIBLE 4308 static_cast<U8>(
sizeof(U64))
4312 static_cast<FwAssertArgType>(_status)
4318 static_cast<FwAssertArgType>(_status)
4331 #if FW_ENABLE_TEXT_LOGGING 4332 if (this->isConnected_LogText_OutputPort(0)) {
4333 #if FW_OBJECT_NAMES == 1 4334 const char* _formatString =
4335 "(%s) %s: Started data product generation for file %s (%" PRIu64
" bytes)";
4337 const char* _formatString =
4338 "%s: Started data product generation for file %s (%" PRIu64
" bytes)";
4342 (void) _logString.
format(
4345 this->m_objName.toChar(),
4347 "GenerateDpStarted ",
4372 this->timeCaller_out(0, _logTime);
4382 #if FW_AMPCS_COMPATIBLE 4387 static_cast<FwAssertArgType>(_status)
4397 static_cast<FwAssertArgType>(_status)
4400 #if FW_AMPCS_COMPATIBLE 4403 static_cast<U8>(
sizeof(U32))
4407 static_cast<FwAssertArgType>(_status)
4413 static_cast<FwAssertArgType>(_status)
4426 #if FW_ENABLE_TEXT_LOGGING 4427 if (this->isConnected_LogText_OutputPort(0)) {
4428 #if FW_OBJECT_NAMES == 1 4429 const char* _formatString =
4430 "(%s) %s: Completed data product generation for file %s in %" PRIu32
" chunks";
4432 const char* _formatString =
4433 "%s: Completed data product generation for file %s in %" PRIu32
" chunks";
4437 (void) _logString.
format(
4440 this->m_objName.toChar(),
4442 "GenerateDpComplete ",
4468 this->timeCaller_out(0, _logTime);
4478 #if FW_AMPCS_COMPATIBLE 4483 static_cast<FwAssertArgType>(_status)
4493 static_cast<FwAssertArgType>(_status)
4496 #if FW_AMPCS_COMPATIBLE 4503 static_cast<FwAssertArgType>(_status)
4509 static_cast<FwAssertArgType>(_status)
4512 #if FW_AMPCS_COMPATIBLE 4515 static_cast<U8>(
sizeof(U32))
4519 static_cast<FwAssertArgType>(_status)
4525 static_cast<FwAssertArgType>(_status)
4538 #if FW_ENABLE_TEXT_LOGGING 4539 if (this->isConnected_LogText_OutputPort(0)) {
4540 #if FW_OBJECT_NAMES == 1 4541 const char* _formatString =
4542 "(%s) %s: Data product generation failed for file %s at stage %s, status %" PRIu32
"";
4544 const char* _formatString =
4545 "%s: Data product generation failed for file %s at stage %s, status %" PRIu32
"";
4549 stage.toString(stageStr);
4552 (void) _logString.
format(
4555 this->m_objName.toChar(),
4557 "GenerateDpFailed ",
4580 this->timeCaller_out(0, _logTime);
4590 #if FW_AMPCS_COMPATIBLE 4595 static_cast<FwAssertArgType>(_status)
4605 static_cast<FwAssertArgType>(_status)
4618 #if FW_ENABLE_TEXT_LOGGING 4619 if (this->isConnected_LogText_OutputPort(0)) {
4620 #if FW_OBJECT_NAMES == 1 4621 const char* _formatString =
4622 "(%s) %s: Failed to allocate data product buffer for file %s";
4624 const char* _formatString =
4625 "%s: Failed to allocate data product buffer for file %s";
4629 (void) _logString.
format(
4632 this->m_objName.toChar(),
4634 "GenerateDpBufferFailed ",
4660 this->timeCaller_out(0, _logTime);
4670 #if FW_AMPCS_COMPATIBLE 4675 static_cast<FwAssertArgType>(_status)
4685 static_cast<FwAssertArgType>(_status)
4688 #if FW_AMPCS_COMPATIBLE 4691 static_cast<U8>(
sizeof(U64))
4695 static_cast<FwAssertArgType>(_status)
4701 static_cast<FwAssertArgType>(_status)
4704 #if FW_AMPCS_COMPATIBLE 4707 static_cast<U8>(
sizeof(U64))
4711 static_cast<FwAssertArgType>(_status)
4717 static_cast<FwAssertArgType>(_status)
4720 #if FW_AMPCS_COMPATIBLE 4723 static_cast<U8>(
sizeof(U64))
4727 static_cast<FwAssertArgType>(_status)
4733 static_cast<FwAssertArgType>(_status)
4746 #if FW_ENABLE_TEXT_LOGGING 4747 if (this->isConnected_LogText_OutputPort(0)) {
4748 #if FW_OBJECT_NAMES == 1 4749 const char* _formatString =
4750 "(%s) %s: Invalid offset range requested for file %s: [%" PRIu64
", %" PRIu64
") with file size %" PRIu64
"";
4752 const char* _formatString =
4753 "%s: Invalid offset range requested for file %s: [%" PRIu64
", %" PRIu64
") with file size %" PRIu64
"";
4757 (void) _logString.
format(
4760 this->m_objName.toChar(),
4762 "GenerateDpInvalidRange ",
4796 this->timeCaller_out(0, _tlmTime);
4826 static_cast<FwAssertArgType>(_stat)
4848 static_cast<FwAssertArgType>(_stat)
4881 static_cast<FwAssertArgType>(buffer.
getSize()));
4882 buffer.
setSize(static_cast<U32>(packetSize));
4886 this->productSendOut_out(0, container.
getId(), buffer);
4898 this->timeCaller_out(0, _time);
4913 ComponentIpcSerializableBuffer _msg;
4923 static_cast<FwAssertArgType>(_msgStatus)
4933 static_cast<FwAssertArgType>(_deserStatus)
4936 MsgTypeEnum _msgType =
static_cast<MsgTypeEnum
>(_desMsg);
4938 if (_msgType == FILEMANAGER_COMPONENT_EXIT) {
4943 _deserStatus = _msg.deserializeTo(portNum);
4946 static_cast<FwAssertArgType>(_deserStatus)
4954 _deserStatus = _msg.deserializeTo(key);
4957 static_cast<FwAssertArgType>(_deserStatus)
4969 case CMD_CREATEDIRECTORY: {
4972 _deserStatus = _msg.deserializeTo(_opCode);
4975 static_cast<FwAssertArgType>(_deserStatus)
4980 _deserStatus = _msg.deserializeTo(_cmdSeq);
4983 static_cast<FwAssertArgType>(_deserStatus)
4988 _deserStatus = _msg.deserializeTo(args);
4991 static_cast<FwAssertArgType>(_deserStatus)
5014 #if FW_CMD_CHECK_RESIDUAL 5034 case CMD_MOVEFILE: {
5037 _deserStatus = _msg.deserializeTo(_opCode);
5040 static_cast<FwAssertArgType>(_deserStatus)
5045 _deserStatus = _msg.deserializeTo(_cmdSeq);
5048 static_cast<FwAssertArgType>(_deserStatus)
5053 _deserStatus = _msg.deserializeTo(args);
5056 static_cast<FwAssertArgType>(_deserStatus)
5094 #if FW_CMD_CHECK_RESIDUAL 5115 case CMD_REMOVEDIRECTORY: {
5118 _deserStatus = _msg.deserializeTo(_opCode);
5121 static_cast<FwAssertArgType>(_deserStatus)
5126 _deserStatus = _msg.deserializeTo(_cmdSeq);
5129 static_cast<FwAssertArgType>(_deserStatus)
5134 _deserStatus = _msg.deserializeTo(args);
5137 static_cast<FwAssertArgType>(_deserStatus)
5160 #if FW_CMD_CHECK_RESIDUAL 5180 case CMD_REMOVEFILE: {
5183 _deserStatus = _msg.deserializeTo(_opCode);
5186 static_cast<FwAssertArgType>(_deserStatus)
5191 _deserStatus = _msg.deserializeTo(_cmdSeq);
5194 static_cast<FwAssertArgType>(_deserStatus)
5199 _deserStatus = _msg.deserializeTo(args);
5202 static_cast<FwAssertArgType>(_deserStatus)
5240 #if FW_CMD_CHECK_RESIDUAL 5261 case CMD_APPENDFILE: {
5264 _deserStatus = _msg.deserializeTo(_opCode);
5267 static_cast<FwAssertArgType>(_deserStatus)
5272 _deserStatus = _msg.deserializeTo(_cmdSeq);
5275 static_cast<FwAssertArgType>(_deserStatus)
5280 _deserStatus = _msg.deserializeTo(args);
5283 static_cast<FwAssertArgType>(_deserStatus)
5321 #if FW_CMD_CHECK_RESIDUAL 5342 case CMD_FILESIZE: {
5345 _deserStatus = _msg.deserializeTo(_opCode);
5348 static_cast<FwAssertArgType>(_deserStatus)
5353 _deserStatus = _msg.deserializeTo(_cmdSeq);
5356 static_cast<FwAssertArgType>(_deserStatus)
5361 _deserStatus = _msg.deserializeTo(args);
5364 static_cast<FwAssertArgType>(_deserStatus)
5387 #if FW_CMD_CHECK_RESIDUAL 5407 case CMD_LISTDIRECTORY: {
5410 _deserStatus = _msg.deserializeTo(_opCode);
5413 static_cast<FwAssertArgType>(_deserStatus)
5418 _deserStatus = _msg.deserializeTo(_cmdSeq);
5421 static_cast<FwAssertArgType>(_deserStatus)
5426 _deserStatus = _msg.deserializeTo(args);
5429 static_cast<FwAssertArgType>(_deserStatus)
5452 #if FW_CMD_CHECK_RESIDUAL 5472 case CMD_CALCULATECRC: {
5475 _deserStatus = _msg.deserializeTo(_opCode);
5478 static_cast<FwAssertArgType>(_deserStatus)
5483 _deserStatus = _msg.deserializeTo(_cmdSeq);
5486 static_cast<FwAssertArgType>(_deserStatus)
5491 _deserStatus = _msg.deserializeTo(args);
5494 static_cast<FwAssertArgType>(_deserStatus)
5517 #if FW_CMD_CHECK_RESIDUAL 5537 case CMD_GENERATEDP: {
5540 _deserStatus = _msg.deserializeTo(_opCode);
5543 static_cast<FwAssertArgType>(_deserStatus)
5548 _deserStatus = _msg.deserializeTo(_cmdSeq);
5551 static_cast<FwAssertArgType>(_deserStatus)
5556 _deserStatus = _msg.deserializeTo(args);
5559 static_cast<FwAssertArgType>(_deserStatus)
5657 #if FW_CMD_CHECK_RESIDUAL 5686 _msg.getDeserializeSizeLeft() == 0,
5707 void FileManagerComponentBase ::
5718 compPtr->cmdIn_handlerBase(
5730 void FileManagerComponentBase ::
5739 compPtr->pingIn_handlerBase(
5745 void FileManagerComponentBase ::
5754 compPtr->schedIn_handlerBase(
5760 #if !FW_DIRECT_PORT_CALLS 5766 #if FW_ENABLE_TEXT_LOGGING 5768 void FileManagerComponentBase ::
5778 (0 <= portNum) && (portNum < this->getNum_LogText_OutputPorts()),
5779 static_cast<FwAssertArgType>(portNum)
5783 this->m_LogText_OutputPort[portNum].isConnected(),
5784 static_cast<FwAssertArgType>(portNum)
5786 this->m_LogText_OutputPort[portNum].invoke(
5796 void FileManagerComponentBase ::
5804 static_cast<FwAssertArgType>(portNum)
5808 this->m_cmdRegOut_OutputPort[portNum].isConnected(),
5809 static_cast<FwAssertArgType>(portNum)
5811 this->m_cmdRegOut_OutputPort[portNum].
invoke(
5816 void FileManagerComponentBase ::
5826 static_cast<FwAssertArgType>(portNum)
5830 this->m_cmdResponseOut_OutputPort[portNum].isConnected(),
5831 static_cast<FwAssertArgType>(portNum)
5833 this->m_cmdResponseOut_OutputPort[portNum].
invoke(
5840 void FileManagerComponentBase ::
5851 static_cast<FwAssertArgType>(portNum)
5855 this->m_eventOut_OutputPort[portNum].isConnected(),
5856 static_cast<FwAssertArgType>(portNum)
5858 this->m_eventOut_OutputPort[portNum].
invoke(
5876 static_cast<FwAssertArgType>(portNum)
5880 this->m_productGetOut_OutputPort[portNum].isConnected(),
5881 static_cast<FwAssertArgType>(portNum)
5883 return this->m_productGetOut_OutputPort[portNum].
invoke(
5890 void FileManagerComponentBase ::
5899 static_cast<FwAssertArgType>(portNum)
5903 this->m_productSendOut_OutputPort[portNum].isConnected(),
5904 static_cast<FwAssertArgType>(portNum)
5906 this->m_productSendOut_OutputPort[portNum].
invoke(
5912 void FileManagerComponentBase ::
5920 static_cast<FwAssertArgType>(portNum)
5924 this->m_timeCaller_OutputPort[portNum].isConnected(),
5925 static_cast<FwAssertArgType>(portNum)
5927 this->m_timeCaller_OutputPort[portNum].
invoke(
5932 void FileManagerComponentBase ::
5942 static_cast<FwAssertArgType>(portNum)
5946 this->m_tlmOut_OutputPort[portNum].isConnected(),
5947 static_cast<FwAssertArgType>(portNum)
5949 this->m_tlmOut_OutputPort[portNum].
invoke(
5964 ContainerId::T containerId,
5967 DpContainer& container
5971 const FwDpIdType globalId = baseId + containerId;
5974 const Fw::Success::T status = this->productGetOut_out(0, globalId, size, buffer);
5978 container = DpContainer(globalId, buffer, baseId);
5979 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.
virtual void run_internalInterfaceHandler()=0
Internal interface handler for run.
Append 1 file's contents to the end of another.
static constexpr FwSizeType CAPACITY
void log_WARNING_HI_ListDirectoryError(const Fw::StringBase &dirName, U32 status) const
The File System component deleted and existing directory without error.
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
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
The File System component moved a file to a new location without error.
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.
Channel ID for CommandsExecuted.
static constexpr FwIndexType getNum_tlmOut_OutputPorts()
void log_ACTIVITY_HI_GenerateDpStarted(const Fw::StringBase &fileName, U64 bytesToWrite) const
message to exit active component task
The File System component began deleting a directory.
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
File data product generation failed.
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.
No room left in the buffer to serialize data.
List the contents of a directory.
static constexpr FwIndexType getNum_timeCaller_OutputPorts()
void invoke(U32 key) const
Invoke a port connection.
bool isConnected_productGetOut_OutputPort(FwIndexType portNum) const
Starting directory listing.
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
bool isConnected_tlmOut_OutputPort(FwIndexType portNum) const
static constexpr FwIndexType getNum_pingOut_OutputPorts()
static constexpr FwIndexType getNum_productSendOut_OutputPorts()
Calculate the CRC of a file.
void init()
Initialization function.
Enum representing a command response.
File data product generation started.
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
The File System component began moving a file to a new location.
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.
SerializeStatus
forward declaration for string
Data product container allocation failed.
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].
The File System component returned status non-zero when trying to append 2 files together.
U16 FwSizeStoreType
The type used to serialize a size value.
FwIdType FwEventIdType
The type of an event identifier.
An error occurred while attempting to remove a directory.
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
Directory listing completed successfully.
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.
File data product generation completed.
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.
static constexpr FwIndexType getNum_schedIn_InputPorts()
void invoke(Fw::Time &time) const
Invoke a port connection.
An error occurred while attempting to create a directory.
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.
FwIdType FwChanIdType
The type of a telemetry channel identifier.
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
An error occurred while attempting to move a file.
An error occurred while attempting to remove a file.
virtual void CreateDirectory_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command CreateDirectory.
void resetDeser() override
Reset deserialization pointer to beginning of buffer.
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
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
The File System component appended 2 files without error.
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.
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.
Error formatting a file path.
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
void set_timeCaller_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeCaller[portNum].
The File System component began deleting an existing file.
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()
The File System component began creating a new directory.
void init()
Initialization function.
Directory listing subdirectory entry.
Invalid offset range requested for data product generation.
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()
RateGroupDivider component implementation.
The size of the serial representation.
Failed to list directory.
virtual void pingIn_preMsgHook(FwIndexType portNum, U32 key)
Pre-message hook for async input port pingIn.
message sent/received okay
The File System component created a new directory without error.
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.
Remove a directory, which must be empty.
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 deleted an existing file without error.
Message will return with status when space is unavailable.
The File System component appended 2 files without error.
Implementation of malloc based allocator.
virtual void RemoveDirectory_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command RemoveDirectory.
void init()
Initialization function.
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].
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)
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.
Directory listing file entry.
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