![]() |
F´ Flight Software - C/C++ Documentation
A framework for building embedded system applications to NASA flight quality standards.
|
#include <Svc/BufferAccumulator/BufferAccumulator.hpp>
Public Member Functions | |
| BufferAccumulator (const char *const compName) | |
| ~BufferAccumulator () | |
| void | allocateQueue (NATIVE_INT_TYPE identifier, Fw::MemAllocator &allocator, NATIVE_UINT_TYPE maxNumBuffers) |
| void | deallocateQueue (Fw::MemAllocator &allocator) |
| Return allocated queue. Should be done during shutdown. | |
Public Member Functions inherited from Svc::BufferAccumulatorComponentBase | |
| void | init (FwSizeType queueDepth, FwEnumStoreType instance=0) |
| Initialize BufferAccumulatorComponentBase object. | |
| Fw::InputCmdPort * | get_cmdIn_InputPort (FwIndexType portNum) |
| Fw::InputBufferSendPort * | get_bufferSendInFill_InputPort (FwIndexType portNum) |
| Fw::InputBufferSendPort * | get_bufferSendInReturn_InputPort (FwIndexType portNum) |
| Svc::InputPingPort * | get_pingIn_InputPort (FwIndexType portNum) |
| void | set_cmdRegOut_OutputPort (FwIndexType portNum, Fw::InputCmdRegPort *port) |
| Connect port to cmdRegOut[portNum]. | |
| void | set_cmdResponseOut_OutputPort (FwIndexType portNum, Fw::InputCmdResponsePort *port) |
| Connect port to cmdResponseOut[portNum]. | |
| void | set_eventOut_OutputPort (FwIndexType portNum, Fw::InputLogPort *port) |
| Connect port to eventOut[portNum]. | |
| void | set_timeCaller_OutputPort (FwIndexType portNum, Fw::InputTimePort *port) |
| Connect port to timeCaller[portNum]. | |
| void | set_tlmOut_OutputPort (FwIndexType portNum, Fw::InputTlmPort *port) |
| Connect port to tlmOut[portNum]. | |
| void | set_bufferSendOutDrain_OutputPort (FwIndexType portNum, Fw::InputBufferSendPort *port) |
| Connect port to bufferSendOutDrain[portNum]. | |
| void | set_bufferSendOutReturn_OutputPort (FwIndexType portNum, Fw::InputBufferSendPort *port) |
| Connect port to bufferSendOutReturn[portNum]. | |
| void | set_pingOut_OutputPort (FwIndexType portNum, Svc::InputPingPort *port) |
| Connect port to pingOut[portNum]. | |
| void | regCommands () |
| Register commands with the Command Dispatcher. | |
Public Member Functions inherited from Fw::ActiveComponentBase | |
| void | start (Os::Task::ParamType priority=Os::Task::TASK_DEFAULT, Os::Task::ParamType stackSize=Os::Task::TASK_DEFAULT, Os::Task::ParamType cpuAffinity=Os::Task::TASK_DEFAULT, Os::Task::ParamType identifier=Os::Task::TASK_DEFAULT) |
| called by instantiator when task is to be started | |
| void | exit () |
| exit task in active component | |
| Os::Task::Status | join () |
| Join the thread. | |
| DEPRECATED (Os::Task::Status join(void **value_ptr), "Switch to .join()") | |
| Join to thread with discarded value_ptr. | |
Public Member Functions inherited from Fw::PassiveComponentBase | |
| void | setIdBase (const U32) |
| Set the ID base. | |
| U32 | getIdBase () const |
Additional Inherited Members | |
Public Types inherited from Fw::ActiveComponentBase | |
| enum | { ACTIVE_COMPONENT_EXIT } |
Public Types inherited from Fw::QueuedComponentBase | |
| enum | MsgDispatchStatus { MSG_DISPATCH_OK , MSG_DISPATCH_EMPTY , MSG_DISPATCH_ERROR , MSG_DISPATCH_EXIT } |
Protected Types inherited from Svc::BufferAccumulatorComponentBase | |
| enum | { NUM_CMDIN_INPUT_PORTS = 1 } |
| Enumerations for numbers of special input ports. More... | |
| enum | { NUM_BUFFERSENDINFILL_INPUT_PORTS = 1 , NUM_BUFFERSENDINRETURN_INPUT_PORTS = 1 , NUM_PINGIN_INPUT_PORTS = 1 } |
| Enumerations for numbers of typed input ports. More... | |
| enum | { NUM_CMDREGOUT_OUTPUT_PORTS = 1 , NUM_CMDRESPONSEOUT_OUTPUT_PORTS = 1 , NUM_EVENTOUT_OUTPUT_PORTS = 1 , NUM_EVENTOUTTEXT_OUTPUT_PORTS = 1 , NUM_TIMECALLER_OUTPUT_PORTS = 1 , NUM_TLMOUT_OUTPUT_PORTS = 1 } |
| Enumerations for numbers of special output ports. More... | |
| enum | { NUM_BUFFERSENDOUTDRAIN_OUTPUT_PORTS = 1 , NUM_BUFFERSENDOUTRETURN_OUTPUT_PORTS = 1 , NUM_PINGOUT_OUTPUT_PORTS = 1 } |
| Enumerations for numbers of typed output ports. More... | |
| enum | { OPCODE_BA_SETMODE = 0x0 , OPCODE_BA_DRAINBUFFERS = 0x1 } |
| Command opcodes. More... | |
| enum | { EVENTID_BA_BUFFERACCEPTED = 0x0 , EVENTID_BA_QUEUEFULL = 0x1 , EVENTID_BA_STILLDRAINING = 0x2 , EVENTID_BA_ALREADYDRAINING = 0x3 , EVENTID_BA_DRAINSTALLED = 0x4 , EVENTID_BA_PARTIALDRAINDONE = 0x5 , EVENTID_BA_NONBLOCKDRAIN = 0x6 } |
| Event IDs. More... | |
| enum | { CHANNELID_BA_NUMQUEUEDBUFFERS = 0x0 } |
| Channel IDs. More... | |
Protected Types inherited from Fw::ActiveComponentBase | |
| enum | Lifecycle { CREATED , DISPATCHING , FINALIZING , DONE } |
| Tracks the lifecycle of the component. More... | |
Protected Member Functions inherited from Svc::BufferAccumulatorComponentBase | |
| BufferAccumulatorComponentBase (const char *compName="") | |
| Construct BufferAccumulatorComponentBase object. | |
| virtual | ~BufferAccumulatorComponentBase () |
| Destroy BufferAccumulatorComponentBase object. | |
| FwIndexType | getNum_cmdIn_InputPorts () const |
| FwIndexType | getNum_bufferSendInFill_InputPorts () const |
| FwIndexType | getNum_bufferSendInReturn_InputPorts () const |
| FwIndexType | getNum_pingIn_InputPorts () const |
| FwIndexType | getNum_cmdRegOut_OutputPorts () const |
| FwIndexType | getNum_cmdResponseOut_OutputPorts () const |
| FwIndexType | getNum_eventOut_OutputPorts () const |
| FwIndexType | getNum_timeCaller_OutputPorts () const |
| FwIndexType | getNum_tlmOut_OutputPorts () const |
| FwIndexType | getNum_bufferSendOutDrain_OutputPorts () const |
| FwIndexType | getNum_bufferSendOutReturn_OutputPorts () const |
| FwIndexType | getNum_pingOut_OutputPorts () const |
| bool | isConnected_cmdRegOut_OutputPort (FwIndexType portNum) |
| bool | isConnected_cmdResponseOut_OutputPort (FwIndexType portNum) |
| bool | isConnected_eventOut_OutputPort (FwIndexType portNum) |
| bool | isConnected_timeCaller_OutputPort (FwIndexType portNum) |
| bool | isConnected_tlmOut_OutputPort (FwIndexType portNum) |
| bool | isConnected_bufferSendOutDrain_OutputPort (FwIndexType portNum) |
| bool | isConnected_bufferSendOutReturn_OutputPort (FwIndexType portNum) |
| bool | isConnected_pingOut_OutputPort (FwIndexType portNum) |
| void | bufferSendInFill_handlerBase (FwIndexType portNum, Fw::Buffer &fwBuffer) |
| Handler base-class function for input port bufferSendInFill. | |
| void | bufferSendInReturn_handlerBase (FwIndexType portNum, Fw::Buffer &fwBuffer) |
| Handler base-class function for input port bufferSendInReturn. | |
| void | pingIn_handlerBase (FwIndexType portNum, U32 key) |
| Handler base-class function for input port pingIn. | |
| virtual void | bufferSendInFill_preMsgHook (FwIndexType portNum, Fw::Buffer &fwBuffer) |
| Pre-message hook for async input port bufferSendInFill. | |
| virtual void | bufferSendInReturn_preMsgHook (FwIndexType portNum, Fw::Buffer &fwBuffer) |
| Pre-message hook for async input port bufferSendInReturn. | |
| virtual void | pingIn_preMsgHook (FwIndexType portNum, U32 key) |
| Pre-message hook for async input port pingIn. | |
| void | bufferSendOutDrain_out (FwIndexType portNum, Fw::Buffer &fwBuffer) |
| Invoke output port bufferSendOutDrain. | |
| void | bufferSendOutReturn_out (FwIndexType portNum, Fw::Buffer &fwBuffer) |
| Invoke output port bufferSendOutReturn. | |
| void | pingOut_out (FwIndexType portNum, U32 key) |
| Invoke output port pingOut. | |
| void | cmdResponse_out (FwOpcodeType opCode, U32 cmdSeq, Fw::CmdResponse response) |
| Emit command response. | |
| void | BA_SetMode_cmdHandlerBase (FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args) |
| void | BA_DrainBuffers_cmdHandlerBase (FwOpcodeType opCode, U32 cmdSeq, Fw::CmdArgBuffer &args) |
| virtual void | BA_SetMode_preMsgHook (FwOpcodeType opCode, U32 cmdSeq) |
| Pre-message hook for command BA_SetMode. | |
| virtual void | BA_DrainBuffers_preMsgHook (FwOpcodeType opCode, U32 cmdSeq) |
| Pre-message hook for command BA_DrainBuffers. | |
| void | log_ACTIVITY_HI_BA_BufferAccepted () const |
| void | log_WARNING_HI_BA_QueueFull () const |
| void | log_WARNING_HI_BA_StillDraining (U32 numDrained, U32 numToDrain) const |
| void | log_WARNING_HI_BA_AlreadyDraining () const |
| void | log_WARNING_HI_BA_DrainStalled (U32 numDrained, U32 numToDrain) const |
| void | log_ACTIVITY_HI_BA_PartialDrainDone (U32 numDrained) const |
| void | log_WARNING_LO_BA_NonBlockDrain (U32 numWillDrain, U32 numReqDrain) const |
| void | tlmWrite_BA_NumQueuedBuffers (U32 arg, Fw::Time _tlmTime=Fw::Time()) const |
| Fw::Time | getTime () |
Protected Member Functions inherited from Fw::ActiveComponentBase | |
| ActiveComponentBase (const char *name) | |
| Constructor. | |
| virtual | ~ActiveComponentBase () |
| Destructor. | |
| void | init (NATIVE_INT_TYPE instance) |
| initialization code | |
| virtual void | preamble () |
| A function that will be called before the event loop is entered. | |
| MsgDispatchStatus | dispatch () |
| The function that will dispatching messages. | |
| virtual void | finalizer () |
| A function that will be called after exiting the loop. | |
Protected Member Functions inherited from Fw::QueuedComponentBase | |
| QueuedComponentBase (const char *name) | |
| Constructor. | |
| virtual | ~QueuedComponentBase () |
| Destructor. | |
| void | init (NATIVE_INT_TYPE instance) |
| initialization function | |
| Os::Queue::Status | createQueue (FwSizeType depth, FwSizeType msgSize) |
| NATIVE_INT_TYPE | getNumMsgsDropped () |
| return number of messages dropped | |
| void | incNumMsgDropped () |
| increment the number of messages dropped | |
Protected Member Functions inherited from Fw::PassiveComponentBase | |
| PassiveComponentBase (const char *name) | |
| Named constructor. | |
| virtual | ~PassiveComponentBase () |
| Destructor. | |
| void | init (NATIVE_INT_TYPE instance) |
| Initialization function. | |
| NATIVE_INT_TYPE | getInstance () const |
Protected Member Functions inherited from Fw::ObjBase | |
| ObjBase (const char *name) | |
| ObjBase constructor. | |
| virtual | ~ObjBase () |
| Destructor. | |
| void | init () |
| Object initializer. | |
Protected Attributes inherited from Fw::ActiveComponentBase | |
| Os::Task | m_task |
| task object for active component | |
Protected Attributes inherited from Fw::QueuedComponentBase | |
| Os::Queue | m_queue |
| queue object for active component | |
Definition at line 23 of file BufferAccumulator.hpp.
| Svc::BufferAccumulator::BufferAccumulator | ( | const char *const | compName | ) |
Construct BufferAccumulator instance
| compName | The component name |
Definition at line 26 of file BufferAccumulator.cpp.
| Svc::BufferAccumulator::~BufferAccumulator | ( | ) |
Destroy BufferAccumulator instance
Definition at line 42 of file BufferAccumulator.cpp.
| void Svc::BufferAccumulator::allocateQueue | ( | NATIVE_INT_TYPE | identifier, |
| Fw::MemAllocator & | allocator, | ||
| NATIVE_UINT_TYPE | maxNumBuffers | ||
| ) |
Give the class a memory buffer. Should be called after constructor and init, but before task is spawned.
| maxNumBuffers | The maximum number of buffers |
Definition at line 48 of file BufferAccumulator.cpp.
| void Svc::BufferAccumulator::deallocateQueue | ( | Fw::MemAllocator & | allocator | ) |
Return allocated queue. Should be done during shutdown.
Definition at line 62 of file BufferAccumulator.cpp.