TnbAbstractReport.h

[詳解]

#pragma once
#include "TnbReport.h"
#include "TnbTickCount.h"
#include "TnbDump.h"
#include "TnbReportViewer.h"
 
 
 
//TNB Library
namespace TNB
{
 
 
 
class CAbstractReport : public IReport, public CSyncSection
{
    DEFSUPER(IReport);
public:
 
    CAbstractReport(DWORD dwInterfaceId = 0) 
        : m_dwInterfaceId(dwInterfaceId), m_iIdleEventInterval(0), m_piListner(NULL)
    {
    }
 
    virtual ~CAbstractReport(void) 
    {
    }
 
    virtual void SetListener(IReport::IListener* piCommListener = NULL)
    {
        m_piListner = piCommListener;
    }
 
    virtual DWORD GetInterfaceId(void) const
    {
        return m_dwInterfaceId;
    }
 
    virtual void SetIdleEventMode(int iInterval = 0)
    {
        if ( iInterval > 0 )
        {
            m_iIdleEventInterval = iInterval;
        }
        else
        {
            m_iIdleEventInterval = 0;
        }
    }
 
    int GetIdleInterval(void) const
    {
        return m_iIdleEventInterval;
    }
 
    virtual void Purge(void) 
    {
    }
 
    bool WaitConnect(DWORD dwTime) const
    {
        if ( ! IsAlive() )
        {
            return false;
        }
        CTickCount tick;
        while ( ! tick.IsPassed(dwTime) )
        {
            if ( IsConnect() )
            {
                return true;
            }
            ::Sleep(10);
        }
        return IsConnect();
    }
 
    void DisableReportViewer(void)
    {
        m_viewer.Invalid();
    }
 
protected:
 
    void m_OnSend(size_t sizeData, LPCVOID lpcvData)
    {
        TRACE1("%s:Send\n", GetReportName());
        #ifndef _TnbREPORT_Dump_OFF
            DebugDump(sizeData, lpcvData);
        #endif
        m_ToViewer(sizeData, lpcvData, TNBVIW_DIRE_SEND | GetReportID());
    }
    
    bool m_OnEvent(const CReportEvent& ev)
    {
        if ( ev.HasData() )
        {
            //開発用TRACE
            TRACE1("%s:Receive\n", GetReportName());
            #ifndef _TnbREPORT_Dump_OFF
                DebugDump(ev.GetDataSize(), ev.GetData());
            #endif
        }
        if ( ev.HasData() )
        {
            m_ToViewer(ev.GetDataSize(), ev.GetData(), TNBVIW_DIRE_RECV | GetReportID());
        }
        else if ( ev.GetEvent() != ReportEvent_Idle )
        {
            m_ToViewer(ev.GetEventString(), GetReportID());
        }
        bool boRc = true;
        if ( m_piListner != NULL )
        {
            EXCLUSIVE(this);
            boRc = m_piListner->OnReportEvent(ev);
        }
        return boRc;
    }
 
    void ToViewer(size_t sizeData, LPCVOID lpcvData)
    {
        m_ToViewer(sizeData, lpcvData, TNBVIW_TYPE_RAWTEXT | GetReportID());
    }
 
    void ToViewer(LPCTSTR lpszText)
    {
        m_ToViewer(lpszText, TNBVIW_TYPE_RAWTEXT | GetReportID());
    }
 
private:
    // [出力] ダンプ出力.
    void m_ToViewer(size_t sizeData, LPCVOID lpcvData, DWORD cookie)
    {
        m_viewer.ToViewer(sizeData, lpcvData, cookie);
    }
    // [出力] 文字列出力.
    void m_ToViewer(LPCTSTR lpszText, DWORD cookie)
    {
        m_viewer.ToViewer(lpszText, cookie);
    }
    CReportViewer   m_viewer;               
    DWORD           m_dwInterfaceId;        
    IListener*      m_piListner;            
    int             m_iIdleEventInterval;   
};
 
 
 
}; // TNB