7 #ifndef Svc_DpWriterComponentAc_HPP 8 #define Svc_DpWriterComponentAc_HPP 21 #if FW_ENABLE_TEXT_LOGGING == 1 192 #if FW_ENABLE_TEXT_LOGGING == 1 195 void set_textEventOut_OutputPort(
238 #if FW_PORT_SERIALIZATION 249 Fw::InputSerializePort* port
255 Fw::InputSerializePort* port
261 Fw::InputSerializePort* port
264 #if FW_ENABLE_TEXT_LOGGING == 1 267 void set_textEventOut_OutputPort(
269 Fw::InputSerializePort* port
277 Fw::InputSerializePort* port
283 Fw::InputSerializePort* port
288 #if FW_PORT_SERIALIZATION 299 Fw::InputSerializePort* port
305 Fw::InputSerializePort* port
311 Fw::InputSerializePort* port
335 const char* compName =
"" 389 #if FW_ENABLE_TEXT_LOGGING == 1 394 FwIndexType getNum_textEventOut_OutputPorts()
const;
456 #if FW_ENABLE_TEXT_LOGGING == 1 461 bool isConnected_textEventOut_OutputPort(
824 static void m_p_cmdIn_in(
839 static void m_p_bufferSendIn_in(
846 static void m_p_schedIn_in(
888 #if FW_ENABLE_TEXT_LOGGING == 1 923 std::atomic<FwIndexType> m_InvalidBufferThrottle;
926 std::atomic<FwIndexType> m_BufferTooSmallForPacketThrottle;
929 std::atomic<FwIndexType> m_InvalidHeaderHashThrottle;
932 std::atomic<FwIndexType> m_InvalidHeaderThrottle;
935 std::atomic<FwIndexType> m_BufferTooSmallForDataThrottle;
938 std::atomic<FwIndexType> m_FileOpenErrorThrottle;
941 std::atomic<FwIndexType> m_FileWriteErrorThrottle;
950 bool m_first_update_NumBuffersReceived;
953 bool m_first_update_NumBytesWritten;
956 bool m_first_update_NumSuccessfulWrites;
959 bool m_first_update_NumFailedWrites;
962 bool m_first_update_NumErrors;
971 U32 m_last_NumBuffersReceived;
974 U64 m_last_NumBytesWritten;
977 U32 m_last_NumSuccessfulWrites;
980 U32 m_last_NumFailedWrites;
983 U32 m_last_NumErrors;
void deallocBufferSendOut_out(FwIndexType portNum, Fw::Buffer &fwBuffer)
Invoke output port deallocBufferSendOut.
FwIndexType getNum_cmdResponseOut_OutputPorts() const
virtual ~DpWriterComponentBase()
Destroy DpWriterComponentBase object.
bool isConnected_procBufferSendOut_OutputPort(FwIndexType portNum)
FwIdType FwOpcodeType
The type of a command opcode.
void log_WARNING_HI_BufferTooSmallForData(FwSizeType bufferSize, U32 minSize)
void schedIn_handlerBase(FwIndexType portNum, U32 context)
Handler base-class function for input port schedIn.
virtual void CLEAR_EVENT_THROTTLE_cmdHandler(FwOpcodeType opCode, U32 cmdSeq)=0
PlatformSizeType FwSizeType
U32 FwDpPriorityType
The type of a data product priority.
void set_dpWrittenOut_OutputPort(FwIndexType portNum, Svc::InputDpWrittenPort *port)
Connect port to dpWrittenOut[portNum].
bool isConnected_deallocBufferSendOut_OutputPort(FwIndexType portNum)
Received buffer is too small to hold a data product packet.
Throttle reset count for InvalidHeader.
void cmdResponse_out(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdResponse response)
Emit command response.
friend class DpWriterTester
Friend class tester implementation to support white-box testing.
FwIndexType getNum_cmdRegIn_OutputPorts() const
Enum representing a command response.
virtual void bufferSendIn_preMsgHook(FwIndexType portNum, Fw::Buffer &fwBuffer)
Pre-message hook for async input port bufferSendIn.
An error occurred when opening a file.
Received buffer is invalid.
Throttle reset count for FileOpenError.
Throttle reset count for FileWriteError.
Channel ID for NumBytesWritten.
bool isConnected_tlmOut_OutputPort(FwIndexType portNum)
void tlmWrite_NumErrors(U32 arg, Fw::Time _tlmTime=Fw::Time())
void init()
Object initializer.
FwIndexType getNum_schedIn_InputPorts() const
Fw::InputBufferSendPort * get_bufferSendIn_InputPort(FwIndexType portNum)
Channel ID for NumErrors.
void log_WARNING_HI_InvalidBuffer_ThrottleClear()
Reset throttle value for InvalidBuffer.
void tlmWrite_NumFailedWrites(U32 arg, Fw::Time _tlmTime=Fw::Time())
void log_WARNING_HI_FileWriteError_ThrottleClear()
Reset throttle value for FileWriteError.
Throttle reset count for BufferTooSmallForPacket.
void CLEAR_EVENT_THROTTLE_cmdHandlerBase(FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args)
FwIndexType getNum_timeGetOut_OutputPorts() const
bool isConnected_dpWrittenOut_OutputPort(FwIndexType portNum)
Error occurred when deserializing the packet header.
void procBufferSendOut_out(FwIndexType portNum, Fw::Buffer &fwBuffer)
Invoke output port procBufferSendOut.
The received buffer has an invalid header hash.
Channel ID for NumFailedWrites.
void dpWrittenOut_out(FwIndexType portNum, const Fw::StringBase &fileName, FwDpPriorityType priority, FwSizeType size)
Invoke output port dpWrittenOut.
Fw::InputCmdPort * get_cmdIn_InputPort(FwIndexType portNum)
void log_WARNING_HI_InvalidHeaderHash(FwSizeType bufferSize, U32 storedHash, U32 computedHash)
void set_deallocBufferSendOut_OutputPort(FwIndexType portNum, Fw::InputBufferSendPort *port)
Connect port to deallocBufferSendOut[portNum].
An error occurred when writing to a file.
void tlmWrite_NumBuffersReceived(U32 arg, Fw::Time _tlmTime=Fw::Time())
bool isConnected_eventOut_OutputPort(FwIndexType portNum)
Channel ID for NumSuccessfulWrites.
void log_WARNING_HI_BufferTooSmallForData_ThrottleClear()
Reset throttle value for BufferTooSmallForData.
void log_WARNING_HI_FileOpenError_ThrottleClear()
Reset throttle value for FileOpenError.
Throttle reset count for InvalidHeaderHash.
DpWriterComponentBase(const char *compName="")
Construct DpWriterComponentBase object.
void log_WARNING_HI_FileOpenError(U32 status, const Fw::StringBase &file)
void log_WARNING_HI_InvalidHeader_ThrottleClear()
Reset throttle value for InvalidHeader.
void log_WARNING_HI_InvalidHeaderHash_ThrottleClear()
Reset throttle value for InvalidHeaderHash.
void log_WARNING_HI_BufferTooSmallForPacket(FwSizeType bufferSize, U32 minSize)
void regCommands()
Register commands with the Command Dispatcher.
FwIndexType getNum_bufferSendIn_InputPorts() const
Channel ID for NumBuffersReceived.
void set_tlmOut_OutputPort(FwIndexType portNum, Fw::InputTlmPort *port)
Connect port to tlmOut[portNum].
void set_cmdResponseOut_OutputPort(FwIndexType portNum, Fw::InputCmdResponsePort *port)
Connect port to cmdResponseOut[portNum].
Throttle reset count for BufferTooSmallForData.
void log_ACTIVITY_LO_FileWritten(U32 bytes, const Fw::StringBase &file) const
virtual void CLEAR_EVENT_THROTTLE_preMsgHook(FwOpcodeType opCode, U32 cmdSeq)
Pre-message hook for command CLEAR_EVENT_THROTTLE.
virtual void schedIn_handler(FwIndexType portNum, U32 context)=0
Handler for input port schedIn.
FwIndexType getNum_tlmOut_OutputPorts() const
PlatformIndexType FwIndexType
void set_eventOut_OutputPort(FwIndexType portNum, Fw::InputLogPort *port)
Connect port to eventOut[portNum].
FwIndexType getNum_cmdIn_InputPorts() const
virtual void bufferSendIn_handler(FwIndexType portNum, Fw::Buffer &fwBuffer)=0
Handler for input port bufferSendIn.
bool isConnected_cmdResponseOut_OutputPort(FwIndexType portNum)
FwIndexType getNum_dpWrittenOut_OutputPorts() const
void log_WARNING_HI_FileWriteError(U32 status, U32 bytesWritten, U32 bytesToWrite, const Fw::StringBase &file)
void set_timeGetOut_OutputPort(FwIndexType portNum, Fw::InputTimePort *port)
Connect port to timeGetOut[portNum].
RateGroupDivider component implementation.
Received buffer is too small to hold the data specified in the header.
bool isConnected_cmdRegIn_OutputPort(FwIndexType portNum)
friend class DpWriterTesterBase
Friend class tester to support autocoded test harness.
FwIndexType getNum_deallocBufferSendOut_OutputPorts() const
void bufferSendIn_handlerBase(FwIndexType portNum, Fw::Buffer &fwBuffer)
Handler base-class function for input port bufferSendIn.
void tlmWrite_NumBytesWritten(U64 arg, Fw::Time _tlmTime=Fw::Time())
virtual void schedIn_preMsgHook(FwIndexType portNum, U32 context)
Pre-message hook for async input port schedIn.
void log_WARNING_HI_InvalidHeader(FwSizeType bufferSize, U32 errorCode)
void tlmWrite_NumSuccessfulWrites(U32 arg, Fw::Time _tlmTime=Fw::Time())
void log_WARNING_HI_BufferTooSmallForPacket_ThrottleClear()
Reset throttle value for BufferTooSmallForPacket.
void set_procBufferSendOut_OutputPort(FwIndexType portNum, Fw::InputBufferSendPort *port)
Connect port to procBufferSendOut[portNum].
void log_WARNING_HI_InvalidBuffer()
FwIndexType getNum_procBufferSendOut_OutputPorts() const
Svc::InputSchedPort * get_schedIn_InputPort(FwIndexType portNum)
void set_cmdRegIn_OutputPort(FwIndexType portNum, Fw::InputCmdRegPort *port)
Connect port to cmdRegIn[portNum].
Auto-generated base for DpWriter component.
FwIndexType getNum_eventOut_OutputPorts() const
bool isConnected_timeGetOut_OutputPort(FwIndexType portNum)
Throttle reset count for InvalidBuffer.