ComQueue.hpp

Go to the documentation of this file.

// ======================================================================
// \title  ComQueue.hpp
// \author vbai
// \brief  hpp file for ComQueue component implementation class
// ======================================================================
 
#ifndef Svc_ComQueue_HPP
#define Svc_ComQueue_HPP
 
#include <Fw/Buffer/Buffer.hpp>
#include <Fw/Com/ComBuffer.hpp>
#include <Svc/ComQueue/ComQueueComponentAc.hpp>
#include <Utils/Types/Queue.hpp>
#include "Fw/Types/MemAllocator.hpp"
#include "Os/Mutex.hpp"
 
namespace Svc {
 
// ----------------------------------------------------------------------
// Types
// ----------------------------------------------------------------------
 
class ComQueue : public ComQueueComponentBase {
  public:
    static const FwIndexType COM_PORT_COUNT = ComQueueComponentBase::NUM_COMQUEUEIN_INPUT_PORTS;
 
    static const FwIndexType BUFFER_PORT_COUNT = ComQueueComponentBase::NUM_BUFFQUEUEIN_INPUT_PORTS;
 
    static const FwIndexType TOTAL_PORT_COUNT = COM_PORT_COUNT + BUFFER_PORT_COUNT;
 
    struct QueueConfigurationEntry {
        FwSizeType depth;      
        FwIndexType priority;  
    };
 
    struct QueueConfigurationTable {
        QueueConfigurationEntry entries[TOTAL_PORT_COUNT];
        QueueConfigurationTable();
    };
 
  private:
    // ----------------------------------------------------------------------
    // Internal data structures
    // ----------------------------------------------------------------------
 
    struct QueueMetadata {
        FwSizeType depth;      
        FwIndexType priority;  
        FwIndexType index;     
        FwSizeType msgSize;    
    };
 
    enum SendState {
        READY,   
        WAITING  
    };
 
  public:
    // ----------------------------------------------------------------------
    // Construction, initialization, and destruction
    // ----------------------------------------------------------------------
 
    ComQueue(const char* const compName 
    );
 
    ~ComQueue();
 
    void configure(QueueConfigurationTable queueConfig,  
                   NATIVE_UINT_TYPE allocationId,        
                   Fw::MemAllocator& allocator           
    );
 
    void cleanup();
 
  private:
    // ----------------------------------------------------------------------
    // Handler implementations for user-defined typed input ports
    // ----------------------------------------------------------------------
 
    void buffQueueIn_handler(const NATIVE_INT_TYPE portNum, 
                             Fw::Buffer& fwBuffer );
 
    void comQueueIn_handler(const NATIVE_INT_TYPE portNum, 
                            Fw::ComBuffer& data,           
                            U32 context                    
    );
 
    void comStatusIn_handler(const NATIVE_INT_TYPE portNum, 
                             Fw::Success& condition         
    );
 
    void run_handler(const NATIVE_INT_TYPE portNum, 
                     U32 context                    
    );
 
    // ----------------------------------------------------------------------
    // Hook implementations for typed async input ports
    // ----------------------------------------------------------------------
 
    void buffQueueIn_overflowHook(FwIndexType portNum, 
                                  Fw::Buffer& fwBuffer 
    );
 
    // ----------------------------------------------------------------------
    // Helper Functions
    // ----------------------------------------------------------------------
 
    bool enqueue(const FwIndexType queueNum,  
                 QueueType queueType,         
                 const U8* data,              
                 const FwSizeType size        
    );
 
    void sendComBuffer(Fw::ComBuffer& comBuffer  
    );
 
    void sendBuffer(Fw::Buffer& buffer  
    );
 
    void processQueue();
    // ----------------------------------------------------------------------
    // Member variables
    // ----------------------------------------------------------------------
    Types::Queue m_queues[TOTAL_PORT_COUNT];  
    QueueMetadata m_prioritizedList[TOTAL_PORT_COUNT];  
    bool m_throttle[TOTAL_PORT_COUNT];  
    SendState m_state;  
 
    // Storage for Fw::MemAllocator properties
    NATIVE_UINT_TYPE m_allocationId;  
    Fw::MemAllocator* m_allocator;    
    void* m_allocation;               
};
 
}  // end namespace Svc
 
#endif