TlmChan.hpp

Go to the documentation of this file.

 
#ifndef TELEMCHANIMPL_HPP_
#define TELEMCHANIMPL_HPP_
 
#include <Fw/Tlm/TlmPacket.hpp>
#include <Svc/TlmChan/TlmChanComponentAc.hpp>
#include <TlmChanImplCfg.hpp>
 
namespace Svc {
 
class TlmChan : public TlmChanComponentBase {
  public:
    TlmChan(const char* compName);
    virtual ~TlmChan();
    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
};
 
}  // namespace Svc
 
#endif /* TELEMCHANIMPL_HPP_ */