TlmChanImpl.hpp

Go to the documentation of this file.

 
#ifndef TELEMCHANIMPL_HPP_
#define TELEMCHANIMPL_HPP_
 
#include <Svc/TlmChan/TlmChanComponentAc.hpp>
#include <TlmChanImplCfg.hpp>
#include <Os/Mutex.hpp>
#include <Fw/Tlm/TlmPacket.hpp>
 
namespace Svc {
 
    class TlmChanImpl: public TlmChanComponentBase {
        public:
            friend class TlmChanImplTester;
            TlmChanImpl(const char* compName);
            virtual ~TlmChanImpl();
            void init(
                    NATIVE_INT_TYPE queueDepth, 
                    NATIVE_INT_TYPE instance 
                    );
        PROTECTED:
 
            // can be overridden for alternate algorithms
            virtual NATIVE_UINT_TYPE doHash(FwChanIdType id);
 
        PRIVATE:
 
            // Port functions
            void TlmRecv_handler(NATIVE_INT_TYPE portNum, FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val);
            void TlmGet_handler(NATIVE_INT_TYPE portNum, FwChanIdType id, Fw::Time &timeTag, Fw::TlmBuffer &val);
            void Run_handler(NATIVE_INT_TYPE portNum, NATIVE_UINT_TYPE context);
            void pingIn_handler(
                const NATIVE_INT_TYPE portNum, 
                U32 key 
            );
 
            typedef struct tlmEntry {
                FwChanIdType id; 
                bool updated; 
                Fw::Time lastUpdate; 
                Fw::TlmBuffer buffer; 
                tlmEntry* next; 
                bool used; 
                NATIVE_UINT_TYPE bucketNo; 
            } TlmEntry;
 
            struct TlmSet {
                TlmEntry* slots[TLMCHAN_NUM_TLM_HASH_SLOTS]; 
                TlmEntry buckets[TLMCHAN_HASH_BUCKETS]; 
                NATIVE_INT_TYPE free; 
            } m_tlmEntries[2];
 
            U32 m_activeBuffer; // !< which buffer is active for storing telemetry
 
            // work variables
            Fw::ComBuffer m_comBuffer;
            Fw::TlmPacket m_tlmPacket;
 
    };
 
}
 
#endif /* TELEMCHANIMPL_HPP_ */