DpCatalog.hpp

Go to the documentation of this file.

// ======================================================================
// \title  DpCatalog.hpp
// \author tcanham
// \brief  hpp file for DpCatalog component implementation class
// ======================================================================
 
#ifndef Svc_DpCatalog_HPP
#define Svc_DpCatalog_HPP
 
#include "Svc/DpCatalog/DpCatalogComponentAc.hpp"
#include "Svc/DpCatalog/DpRecordSerializableAc.hpp"
 
#include <Fw/Types/MemAllocator.hpp>
 
#include <DpCfg.hpp>
#include <DpCatalogCfg.hpp>
#include <Fw/Types/FileNameString.hpp>
 
namespace Svc {
 
    class DpCatalog :
        public DpCatalogComponentBase
    {
 
    public:
 
        // ----------------------------------------------------------------------
        // Component construction and destruction
        // ----------------------------------------------------------------------
 
        DpCatalog(
            const char* const compName 
        );
 
        ~DpCatalog();
 
        void configure(
            Fw::FileNameString directories[DP_MAX_DIRECTORIES],
            FwSizeType numDirs,
            NATIVE_UINT_TYPE memId,
            Fw::MemAllocator& allocator
        );
 
        // @brief clean up component. 
        // Deallocates memory.       
        void shutdown();
 
 
 
    PRIVATE:
 
        // ----------------------------------------------------------------------
        // Handler implementations for user-defined typed input ports
        // ----------------------------------------------------------------------
 
        void fileDone_handler(
            NATIVE_INT_TYPE portNum, 
            const Svc::SendFileResponse& resp
        ) override;
 
        void pingIn_handler(
            NATIVE_INT_TYPE portNum, 
            U32 key 
        ) override;
 
    PRIVATE:
 
        // ----------------------------------------------------------------------
        // Handler implementations for commands
        // ----------------------------------------------------------------------
 
        void BUILD_CATALOG_cmdHandler(
            FwOpcodeType opCode, 
            U32 cmdSeq 
        ) override;
 
        void START_XMIT_CATALOG_cmdHandler(
            FwOpcodeType opCode, 
            U32 cmdSeq, 
            Fw::Wait wait 
        ) override;
 
        void STOP_XMIT_CATALOG_cmdHandler(
            FwOpcodeType opCode, 
            U32 cmdSeq 
        ) override;
 
        void CLEAR_CATALOG_cmdHandler(
            FwOpcodeType opCode, 
            U32 cmdSeq 
        ) override;
 
 
        // ----------------------------------
        // Private data structures
        // ----------------------------------
 
        struct DpStateEntry {
            bool entry; 
            FwIndexType dir; 
            DpRecord record; 
 
        };
 
        struct DpSortedList {
            DpStateEntry* recPtr; 
            bool sent; 
        };
 
 
        // ----------------------------------
        // Private helpers
        // ----------------------------------
 
        bool insertEntry(DpStateEntry& entry);
 
        void deleteEntry(DpStateEntry& entry);
 
        void sendNextEntry();
 
        bool checkInit();
 
        Fw::CmdResponse doCatalogBuild();
 
        Fw::CmdResponse doCatalogXmit();
 
        // ----------------------------------
        // Private data
        // ----------------------------------
        bool m_initialized; 
        DpStateEntry* m_dpList; 
        DpSortedList* m_sortedDpList; 
 
        FwSizeType m_numDpRecords; 
        FwSizeType m_numDpSlots; 
 
        Fw::FileNameString m_directories[DP_MAX_DIRECTORIES]; 
        FwSizeType m_numDirectories; 
        Fw::String m_fileList[DP_MAX_FILES]; 
 
        NATIVE_UINT_TYPE m_memSize; 
        void* m_memPtr; 
        NATIVE_UINT_TYPE m_allocatorId; 
        Fw::MemAllocator* m_allocator; 
 
        bool m_xmitInProgress; 
        DpSortedList* m_currXmitRecord; 
        Fw::FileNameString m_currXmitFileName; 
        bool m_xmitCmdWait; 
        U64 m_xmitBytes; 
 
        FwOpcodeType m_xmitOpCode; 
        U32 m_xmitCmdSeq; 
 
    };
 
}
 
#endif