11#if FW_ENABLE_TEXT_LOGGING
25 class ComponentIpcSerializableBuffer :
40 return sizeof(m_buff);
47 const U8* getBuffAddr()
const {
53 U8 m_buff[SERIALIZATION_SIZE];
62 void StreamCrossoverComponentBase ::
71 port < static_cast<PlatformIntType>(this->getNum_streamIn_InputPorts());
74 this->m_streamIn_InputPort[port].init();
75 this->m_streamIn_InputPort[port].addCallComp(
79 this->m_streamIn_InputPort[port].setPortNum(port);
81#if FW_OBJECT_NAMES == 1
90 this->m_streamIn_InputPort[port].setObjName(portName);
97 port < static_cast<PlatformIntType>(this->getNum_logOut_OutputPorts());
100 this->m_logOut_OutputPort[port].init();
102#if FW_OBJECT_NAMES == 1
111 this->m_logOut_OutputPort[port].setObjName(portName);
115#if FW_ENABLE_TEXT_LOGGING == 1
119 port < static_cast<PlatformIntType>(this->getNum_logTextOut_OutputPorts());
122 this->m_logTextOut_OutputPort[port].init();
124#if FW_OBJECT_NAMES == 1
133 this->m_logTextOut_OutputPort[port].setObjName(portName);
141 port < static_cast<PlatformIntType>(this->getNum_timeCaller_OutputPorts());
144 this->m_timeCaller_OutputPort[port].init();
146#if FW_OBJECT_NAMES == 1
155 this->m_timeCaller_OutputPort[port].setObjName(portName);
162 port < static_cast<PlatformIntType>(this->getNum_errorDeallocate_OutputPorts());
165 this->m_errorDeallocate_OutputPort[port].init();
167#if FW_OBJECT_NAMES == 1
176 this->m_errorDeallocate_OutputPort[port].setObjName(portName);
183 port < static_cast<PlatformIntType>(this->getNum_streamOut_OutputPorts());
186 this->m_streamOut_OutputPort[port].init();
188#if FW_OBJECT_NAMES == 1
197 this->m_streamOut_OutputPort[port].setObjName(portName);
62 void StreamCrossoverComponentBase :: {
…}
210 portNum < this->getNum_streamIn_InputPorts(),
214 return &this->m_streamIn_InputPort[portNum];
221 void StreamCrossoverComponentBase ::
222 set_logOut_OutputPort(
228 portNum < this->getNum_logOut_OutputPorts(),
232 this->m_logOut_OutputPort[portNum].addCallPort(port);
221 void StreamCrossoverComponentBase :: {
…}
235#if FW_ENABLE_TEXT_LOGGING == 1
237 void StreamCrossoverComponentBase ::
238 set_logTextOut_OutputPort(
244 portNum < this->getNum_logTextOut_OutputPorts(),
248 this->m_logTextOut_OutputPort[portNum].addCallPort(port);
253 void StreamCrossoverComponentBase ::
254 set_timeCaller_OutputPort(
260 portNum < this->getNum_timeCaller_OutputPorts(),
264 this->m_timeCaller_OutputPort[portNum].addCallPort(port);
253 void StreamCrossoverComponentBase :: {
…}
271 void StreamCrossoverComponentBase ::
272 set_errorDeallocate_OutputPort(
278 portNum < this->getNum_errorDeallocate_OutputPorts(),
282 this->m_errorDeallocate_OutputPort[portNum].addCallPort(port);
271 void StreamCrossoverComponentBase :: {
…}
285 void StreamCrossoverComponentBase ::
286 set_streamOut_OutputPort(
292 portNum < this->getNum_streamOut_OutputPorts(),
296 this->m_streamOut_OutputPort[portNum].addCallPort(port);
285 void StreamCrossoverComponentBase :: {
…}
299#if FW_PORT_SERIALIZATION
305 void StreamCrossoverComponentBase ::
306 set_logOut_OutputPort(
308 Fw::InputSerializePort* port
312 portNum < this->getNum_logOut_OutputPorts(),
316 this->m_logOut_OutputPort[portNum].registerSerialPort(port);
319#if FW_ENABLE_TEXT_LOGGING == 1
321 void StreamCrossoverComponentBase ::
322 set_logTextOut_OutputPort(
324 Fw::InputSerializePort* port
328 portNum < this->getNum_logTextOut_OutputPorts(),
332 this->m_logTextOut_OutputPort[portNum].registerSerialPort(port);
337 void StreamCrossoverComponentBase ::
338 set_timeCaller_OutputPort(
340 Fw::InputSerializePort* port
344 portNum < this->getNum_timeCaller_OutputPorts(),
348 this->m_timeCaller_OutputPort[portNum].registerSerialPort(port);
353#if FW_PORT_SERIALIZATION
359 void StreamCrossoverComponentBase ::
360 set_errorDeallocate_OutputPort(
362 Fw::InputSerializePort* port
366 portNum < this->getNum_errorDeallocate_OutputPorts(),
370 this->m_errorDeallocate_OutputPort[portNum].registerSerialPort(port);
379 StreamCrossoverComponentBase ::
380 StreamCrossoverComponentBase(
const char* compName) :
381 Fw::PassiveComponentBase(compName)
379 StreamCrossoverComponentBase :: {
…}
386 StreamCrossoverComponentBase ::
387 ~StreamCrossoverComponentBase()
386 StreamCrossoverComponentBase :: {
…}
397 getNum_streamIn_InputPorts()
407 getNum_logOut_OutputPorts()
412#if FW_ENABLE_TEXT_LOGGING == 1
415 getNum_logTextOut_OutputPorts()
423 getNum_timeCaller_OutputPorts()
433 getNum_errorDeallocate_OutputPorts()
439 getNum_streamOut_OutputPorts()
448 bool StreamCrossoverComponentBase ::
452 portNum < this->getNum_logOut_OutputPorts(),
456 return this->m_logOut_OutputPort[portNum].isConnected();
448 bool StreamCrossoverComponentBase :: {
…}
459#if FW_ENABLE_TEXT_LOGGING == 1
461 bool StreamCrossoverComponentBase ::
465 portNum < this->getNum_logTextOut_OutputPorts(),
469 return this->m_logTextOut_OutputPort[portNum].isConnected();
474 bool StreamCrossoverComponentBase ::
478 portNum < this->getNum_timeCaller_OutputPorts(),
482 return this->m_timeCaller_OutputPort[portNum].isConnected();
474 bool StreamCrossoverComponentBase :: {
…}
489 bool StreamCrossoverComponentBase ::
493 portNum < this->getNum_errorDeallocate_OutputPorts(),
497 return this->m_errorDeallocate_OutputPort[portNum].isConnected();
489 bool StreamCrossoverComponentBase :: {
…}
500 bool StreamCrossoverComponentBase ::
504 portNum < this->getNum_streamOut_OutputPorts(),
508 return this->m_streamOut_OutputPort[portNum].isConnected();
500 bool StreamCrossoverComponentBase :: {
…}
517 void StreamCrossoverComponentBase ::
518 streamIn_handlerBase(
526 portNum < this->getNum_streamIn_InputPorts(),
531 this->streamIn_handler(
517 void StreamCrossoverComponentBase :: {
…}
542 void StreamCrossoverComponentBase ::
549 portNum < this->getNum_errorDeallocate_OutputPorts(),
552 this->m_errorDeallocate_OutputPort[portNum].invoke(
542 void StreamCrossoverComponentBase :: {
…}
564 portNum < this->getNum_streamOut_OutputPorts(),
567 return this->m_streamOut_OutputPort[portNum].invoke(
576 void StreamCrossoverComponentBase ::
581 if (this->m_timeCaller_OutputPort[0].isConnected()) {
582 this->m_timeCaller_OutputPort[0].invoke(_logTime);
587 _id = this->getIdBase() + EVENTID_STREAMOUTERROR;
590 if (this->m_logOut_OutputPort[0].isConnected()) {
594#if FW_AMPCS_COMPATIBLE
603#if FW_AMPCS_COMPATIBLE
613 _status = _logBuff.
serialize(sendStatus);
619 this->m_logOut_OutputPort[0].invoke(
628#if FW_ENABLE_TEXT_LOGGING
629 if (this->m_logTextOut_OutputPort[0].isConnected()) {
630#if FW_OBJECT_NAMES == 1
631 const char* _formatString =
632 "(%s) %s: StreamCrossover StreamOut Error: %s";
634 const char* _formatString =
635 "%s: StreamCrossover StreamOut Error: %s";
641 sendStatus.toString(sendStatusStr);
657 this->m_logTextOut_OutputPort[0].invoke(
576 void StreamCrossoverComponentBase :: {
…}
674 if (this->m_timeCaller_OutputPort[0].isConnected()) {
676 this->m_timeCaller_OutputPort[0].invoke(_time);
688 void StreamCrossoverComponentBase ::
PlatformIntType NATIVE_INT_TYPE
uint8_t U8
8-bit unsigned integer
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
PlatformUIntType NATIVE_UINT_TYPE
int PlatformIntType
DefaultTypes.hpp provides fallback defaults for the platform types.
#define PRI_PlatformIntType
@ TB_NONE
No time base has been established.
PlatformAssertArgType FwAssertArgType
#define FW_LOG_TEXT_BUFFER_SIZE
Max size of string for text log message.
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects)
BYTE streamInPortSize[Drv::InputByteStreamRecvPort::SERIALIZED_SIZE]
@ SERIALIZED_SIZE
The size of the serial representation.
Auto-generated base for StreamCrossover component.
void streamIn_handlerBase(NATIVE_INT_TYPE portNum, Fw::Buffer &recvBuffer, const Drv::RecvStatus &recvStatus)
Handler base-class function for input port streamIn.
@ WARNING_HI
A serious but recoverable event.
void init()
Object initializer.
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
const char * toChar() const
gets char buffer
SerializeStatus
forward declaration for string
@ FW_SERIALIZE_OK
Serialization/Deserialization operation was successful.