SeqDispatcher.hpp

Go to the documentation of this file.

// ======================================================================
// \title  SeqDispatcher.hpp
// \author zimri.leisher
// \brief  hpp file for SeqDispatcher component implementation class
// ======================================================================
 
#ifndef SeqDispatcher_HPP
#define SeqDispatcher_HPP
 
#include "Svc/SeqDispatcher/SeqDispatcherComponentAc.hpp"
#include "Svc/SeqDispatcher/SeqDispatcher_CmdSequencerStateEnumAc.hpp"
#include "FppConstantsAc.hpp"
#include "Fw/Types/WaitEnumAc.hpp"
#include "Fw/Types/StringBase.hpp"
 
namespace Svc {
 
class SeqDispatcher : public SeqDispatcherComponentBase {
  public:
    // ----------------------------------------------------------------------
    // Construction, initialization, and destruction
    // ----------------------------------------------------------------------
 
    SeqDispatcher(const char* const compName 
    );
 
    ~SeqDispatcher();
 
  PROTECTED:
 
    void
    seqDoneIn_handler(NATIVE_INT_TYPE portNum,         
                      FwOpcodeType opCode,             
                      U32 cmdSeq,                      
                      const Fw::CmdResponse& response  
    );
 
    void seqStartIn_handler(NATIVE_INT_TYPE portNum, 
                            const Fw::StringBase& fileName 
    );
 
    void seqRunIn_handler(NATIVE_INT_TYPE portNum, 
                          const Fw::StringBase& fileName 
    );
 
  PRIVATE:
 
    // number of sequences dispatched (successful or otherwise)
    U32 m_dispatchedCount = 0;
    // number of errors from dispatched sequences (CmdResponse::EXECUTION_ERROR)
    U32 m_errorCount = 0;
    // number of sequencers in state AVAILABLE
    U32 m_sequencersAvailable = SeqDispatcherSequencerPorts;
 
    struct DispatchEntry {
        FwOpcodeType opCode;  
        U32 cmdSeq;
        // store the state of each sequencer
        SeqDispatcher_CmdSequencerState state;
        // store the sequence currently running for each sequencer
        Fw::String sequenceRunning = "<no seq>";
    } m_entryTable[SeqDispatcherSequencerPorts];  
 
    FwIndexType getNextAvailableSequencerIdx();
 
    void runSequence(FwIndexType sequencerIdx, 
                     const Fw::StringBase& fileName, 
                     Fw::Wait block);
 
    // ----------------------------------------------------------------------
    // Command handler implementations
    // ----------------------------------------------------------------------
 
    void RUN_cmdHandler(const FwOpcodeType opCode,        
                        const U32 cmdSeq,                 
                        const Fw::CmdStringArg& fileName, 
                        Fw::Wait block);
 
    void LOG_STATUS_cmdHandler(const FwOpcodeType opCode, 
                               const U32 cmdSeq);         
};
 
}  // end namespace components
 
#endif