samplelogentry.h

Go to the documentation of this file.

#pragma once
 
#include "samplelog_intf.h"
#include <adtfucom3/adtf_ucom3.h>
 
namespace adtf
{
namespace streaming
{
namespace ant
{ 
class cSampleLogEntry 
{
    public:
        class IHandleInfo
        {
            public:
                virtual adtf_util::cString GetThreadName(uint64_t ui64ProcId, 
                                                         int32_t i32ThreadId) const = 0;
                virtual adtf_util::cString GetHandleName(tHandle hHandle) const = 0;
        };
 
    public:
        cSampleLogEntry();
        cSampleLogEntry(const cSampleLogEntry& oEntry);

        cSampleLogEntry& operator= (const cSampleLogEntry& oEntry);
        cSampleLogEntry(const ISampleLog::tSampleLogEntry& sEntry);

        ~cSampleLogEntry();
 
        cSampleLogEntry(cSampleLogEntry&& oEntry);
        cSampleLogEntry& operator= (cSampleLogEntry&& oEntry);
    public:

        tResult SetEntry(const ISampleLog::tSampleLogEntry* psEntry);
        const ISampleLog::tSampleLogEntry* GetEntry() const;
        
        tResult ToStream(ucom::ant::IStream& oOutStream, size_t& nSizeWritten) const;
        tResult FromStream(const ucom::ant::IStream& oInStream, size_t& nSizeRead);

        bool operator ==(const ISampleLog::tSampleLogEntry& sEntry) const;
        bool operator ==(const cSampleLogEntry& oEntry) const;
        
        operator const ISampleLog::tSampleLogEntry*() const;
        operator const ISampleLog::tSampleLogEntry&() const;

        tResult ToString(const adtf_util::cString& strSampleID,
                         adtf_util::cString& strResult,
                         const IHandleInfo* pHandleInfo=nullptr,
                         const adtf_util::cString& strSeparator=";") const;
    public:
        static ISampleLog::tSampleLogSampleID GetEmptySampleID();
        static bool  IsEqualSampleID(const ISampleLog::tSampleLogSampleID& sID1,
                                      const ISampleLog::tSampleLogSampleID& sID2);
    private:
        tResult SetAdditionalData(const void* pData, size_t szAdditionalData);
        bool   IsEqual(const ISampleLog::tSampleLogEntry& sEntry) const;
 
    private:
        ISampleLog::tSampleLogEntry              m_sEntry;
        adtf_util::cMemoryBlock                  m_oAdditionalData;
    
};
 
class cSampleLogEntryTransmitReceiveStateBuffer
{
    public:
        cSampleLogEntryTransmitReceiveStateBuffer();
        virtual ~cSampleLogEntryTransmitReceiveStateBuffer();
        tResult AddEntry(const ISampleLog::tSampleLogEntryCreatorID& ui64ID);
        tResult SetEntry(const ISampleLog::tSampleLogEntryCreatorID& ui64CreatorID,
                         const ISampleLog::tSampleLogEntryEventID& ui32EventID,           
                         const tTimeStamp& tmEntryTime,
                         const ISampleLog::tSampleLogSampleID& sSampleId);
        tResult MemoryLock(const bool& bLock);

        tResult LogBuffer(const ISampleLog::tSampleLogEntryCreatorID& ui64ID,
                          const tTimeStamp& tmCurrent,
                          ISampleLog& oLogSample);
        tResult Clear();

        static tResult ToString(const ISampleLog::tSampleLogTransmitReceiveState& sState,
                                adtf_util::cString& strResult,
                                const cSampleLogEntry::IHandleInfo* pHandleInfo=nullptr,
                                const adtf_util::cString& strSeparator=";");
 
    private: 
        adtf_util::cMemoryBlock                                                    m_oBuffer;
        std::unordered_map<ISampleLog::tSampleLogEntryCreatorID, size_t>            m_oPositionMap;
        ISampleLog::tSampleLogTransmitReceiveState*                                m_pCurrentBuffer;
        size_t                                                                      m_szCurrentSize; 
        bool                                                                      m_bLocked;
};
 
} // namespace ant
using ant::cSampleLogEntryTransmitReceiveStateBuffer;
using ant::cSampleLogEntry;
 
} // namespace streaming
} // namespace adtf