10 #if FW_ENABLE_TEXT_LOGGING
32 this->m_streamIn_InputPort[port].
init();
37 this->m_streamIn_InputPort[port].
setPortNum(port);
39 #if FW_OBJECT_NAMES == 1
43 this->m_objName.toChar(),
46 this->m_streamIn_InputPort[port].setObjName(portName.
toChar());
56 this->m_logOut_OutputPort[port].
init();
58 #if FW_OBJECT_NAMES == 1
62 this->m_objName.toChar(),
65 this->m_logOut_OutputPort[port].setObjName(portName.
toChar());
69 #if FW_ENABLE_TEXT_LOGGING == 1
73 port < static_cast<FwIndexType>(this->getNum_logTextOut_OutputPorts());
76 this->m_logTextOut_OutputPort[port].
init();
78 #if FW_OBJECT_NAMES == 1
82 this->m_objName.toChar(),
85 this->m_logTextOut_OutputPort[port].setObjName(portName.
toChar());
96 this->m_timeCaller_OutputPort[port].
init();
98 #if FW_OBJECT_NAMES == 1
102 this->m_objName.toChar(),
105 this->m_timeCaller_OutputPort[port].setObjName(portName.
toChar());
115 this->m_errorDeallocate_OutputPort[port].
init();
117 #if FW_OBJECT_NAMES == 1
121 this->m_objName.toChar(),
124 this->m_errorDeallocate_OutputPort[port].setObjName(portName.
toChar());
134 this->m_streamOut_OutputPort[port].
init();
136 #if FW_OBJECT_NAMES == 1
140 this->m_objName.toChar(),
143 this->m_streamOut_OutputPort[port].setObjName(portName.
toChar());
160 return &this->m_streamIn_InputPort[portNum];
178 this->m_logOut_OutputPort[portNum].
addCallPort(port);
181 #if FW_ENABLE_TEXT_LOGGING == 1
183 void StreamCrossoverComponentBase ::
184 set_logTextOut_OutputPort(
190 portNum < this->getNum_logTextOut_OutputPorts(),
194 this->m_logTextOut_OutputPort[portNum].addCallPort(port);
210 this->m_timeCaller_OutputPort[portNum].
addCallPort(port);
228 this->m_errorDeallocate_OutputPort[portNum].
addCallPort(port);
242 this->m_streamOut_OutputPort[portNum].
addCallPort(port);
245 #if FW_PORT_SERIALIZATION
254 Fw::InputSerializePort* port
262 this->m_logOut_OutputPort[portNum].registerSerialPort(port);
265 #if FW_ENABLE_TEXT_LOGGING == 1
267 void StreamCrossoverComponentBase ::
268 set_logTextOut_OutputPort(
270 Fw::InputSerializePort* port
274 portNum < this->getNum_logTextOut_OutputPorts(),
278 this->m_logTextOut_OutputPort[portNum].registerSerialPort(port);
286 Fw::InputSerializePort* port
294 this->m_timeCaller_OutputPort[portNum].registerSerialPort(port);
299 #if FW_PORT_SERIALIZATION
308 Fw::InputSerializePort* port
316 this->m_errorDeallocate_OutputPort[portNum].registerSerialPort(port);
327 Fw::PassiveComponentBase(compName)
358 #if FW_ENABLE_TEXT_LOGGING == 1
361 getNum_logTextOut_OutputPorts()
const
402 return this->m_logOut_OutputPort[portNum].
isConnected();
405 #if FW_ENABLE_TEXT_LOGGING == 1
407 bool StreamCrossoverComponentBase ::
408 isConnected_logTextOut_OutputPort(
FwIndexType portNum)
411 portNum < this->getNum_logTextOut_OutputPorts(),
415 return this->m_logTextOut_OutputPort[portNum].isConnected();
428 return this->m_timeCaller_OutputPort[portNum].
isConnected();
443 return this->m_errorDeallocate_OutputPort[portNum].
isConnected();
454 return this->m_streamOut_OutputPort[portNum].
isConnected();
498 this->m_errorDeallocate_OutputPort[portNum].
invoke(
513 return this->m_streamOut_OutputPort[portNum].
invoke(
527 if (this->m_timeCaller_OutputPort[0].isConnected()) {
528 this->m_timeCaller_OutputPort[0].
invoke(_logTime);
536 if (this->m_logOut_OutputPort[0].isConnected()) {
540 #if FW_AMPCS_COMPATIBLE
549 #if FW_AMPCS_COMPATIBLE
559 _status = _logBuff.
serialize(sendStatus);
565 this->m_logOut_OutputPort[0].
invoke(
574 #if FW_ENABLE_TEXT_LOGGING
575 if (this->m_logTextOut_OutputPort[0].isConnected()) {
576 #if FW_OBJECT_NAMES == 1
577 const char* _formatString =
578 "(%s) %s: StreamCrossover StreamOut Error: %s";
580 const char* _formatString =
581 "%s: StreamCrossover StreamOut Error: %s";
585 sendStatus.toString(sendStatusStr);
591 this->m_objName.toChar(),
597 this->m_logTextOut_OutputPort[0].invoke(
614 if (this->m_timeCaller_OutputPort[0].isConnected()) {
616 this->m_timeCaller_OutputPort[0].
invoke(_time);
628 void StreamCrossoverComponentBase ::
uint8_t U8
8-bit unsigned integer
#define FW_NUM_ARRAY_ELEMENTS(a)
number of elements in an array
#define PRI_PlatformIntType
@ TB_NONE
No time base has been established.
PlatformAssertArgType FwAssertArgType
PlatformIndexType FwIndexType
#define FW_OBJECT_NAMES
Indicates whether or not object names are stored (more memory, can be used for tracking objects)
void init()
Initialization function.
Drv::SendStatus invoke(Fw::Buffer &sendBuffer)
Invoke a port interface.
void addCallPort(InputByteStreamSendPort *callPort)
Register an input port.
Status associated with the received data.
Status returned by the send call.
@ SERIALIZED_SIZE
The size of the serial representation.
Auto-generated base for StreamCrossover component.
void set_streamOut_OutputPort(FwIndexType portNum, Drv::InputByteStreamSendPort *port)
Connect port to streamOut[portNum].
void set_errorDeallocate_OutputPort(FwIndexType portNum, Fw::InputBufferSendPort *port)
Connect port to errorDeallocate[portNum].
void log_WARNING_HI_StreamOutError(Drv::SendStatus sendStatus)
bool isConnected_timeCaller_OutputPort(FwIndexType portNum)
@ EVENTID_STREAMOUTERROR
Indicates buffer failed to send to streamOut.
FwIndexType getNum_errorDeallocate_OutputPorts() const
bool isConnected_logOut_OutputPort(FwIndexType portNum)
FwIndexType getNum_streamOut_OutputPorts() const
void errorDeallocate_out(FwIndexType portNum, Fw::Buffer &fwBuffer)
Invoke output port errorDeallocate.
bool isConnected_errorDeallocate_OutputPort(FwIndexType portNum)
void set_timeCaller_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeCaller[portNum].
virtual ~StreamCrossoverComponentBase()
Destroy StreamCrossoverComponentBase object.
FwIndexType getNum_logOut_OutputPorts() const
Drv::InputByteStreamRecvPort * get_streamIn_InputPort(FwIndexType portNum)
Drv::SendStatus streamOut_out(FwIndexType portNum, Fw::Buffer &sendBuffer)
Invoke output port streamOut.
StreamCrossoverComponentBase(const char *compName="")
Construct StreamCrossoverComponentBase object.
void streamIn_handlerBase(FwIndexType portNum, Fw::Buffer &recvBuffer, const Drv::RecvStatus &recvStatus)
Handler base-class function for input port streamIn.
virtual void streamIn_handler(FwIndexType portNum, Fw::Buffer &recvBuffer, const Drv::RecvStatus &recvStatus)=0
Handler for input port streamIn.
void set_logOut_OutputPort(FwIndexType portNum, Fw::InputLogPort *port)
Connect port to logOut[portNum].
bool isConnected_streamOut_OutputPort(FwIndexType portNum)
FwIndexType getNum_streamIn_InputPorts() const
FwIndexType getNum_timeCaller_OutputPorts() const
@ WARNING_HI
A serious but recoverable event.
void init()
Object initializer.
const char * toChar() const
void addCallPort(InputBufferSendPort *callPort)
Register an input port.
void invoke(Fw::Buffer &fwBuffer)
Invoke a port interface.
void init()
Initialization function.
void init()
Initialization function.
void invoke(FwEventIdType id, Fw::Time &timeTag, const Fw::LogSeverity &severity, Fw::LogBuffer &args)
Invoke a port interface.
void addCallPort(InputLogPort *callPort)
Register an input port.
void addCallPort(InputTimePort *callPort)
Register an input port.
void invoke(Fw::Time &time)
Invoke a port interface.
void init()
Initialization function.
SerializeStatus serialize(U8 val)
serialize 8-bit unsigned int
void format(const CHAR *formatString,...)
write formatted string to buffer
const char * toChar() const
SerializeStatus
forward declaration for string
@ FW_SERIALIZE_OK
Serialization/Deserialization operation was successful.