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