TnbPollingTrigger.h

[詳解]

#pragma once
#include "TnbThread.h"
 
 
 
//TNB Library
namespace TNB
{
 
 
 
template<typename TYP = BYTE>
class CPollingTriggerT : public CThread::IRunner
{
public:
 
    struct IPort
    {
        virtual ~IPort(void) {}
        virtual DWORD GetPortData(TYP& _dat) = 0;
    };
 
    struct IListener
    {
        virtual ~IListener(void) {}
        virtual void OnPollingBitChanged(TYP changeBit, TYP dataBit) = 0;
        virtual void OnPollingError(DWORD error) = 0;
    };
 
 
    //---------------------------------------
 
 
    CPollingTriggerT(void) : m_pListener(NULL), m_interval(100), m_chatter(3), m_chatCount(0)
    {
    }
 
    virtual ~CPollingTriggerT(void)
    {
        m_thread.Stop();
    }
 
    bool Start(void)
    {
        m_thread.Stop();
        m_thread.SetRunner(this);
        return m_thread.Start(_T("PollingTigger"));
    }
 
    void Stop(void)
    {
        m_thread.Stop();
    }
 
    void SetParameter(IPort* P, IListener* L, DWORD interval = 100, DWORD chatter = 3)
    {
        Stop();
        m_pPort = P;
        m_pListener = L;
        m_chatData.Resize(chatter);
        loop ( i, m_chatData.GetSize() )
        {
            m_chatData[i] = 0;
        }
        m_interval = interval;
        m_chatter = chatter;
        m_chatCount = chatter;
        m_fixData = 0;
    }
 
    CThreadStatus& ReferThreadStatus(void)
    {
        return m_thread;
    }
 
protected:
    virtual DWORD Run(void)
    {
        while ( IsRunnable() )
        {
            ::Sleep(m_interval);
            TYP b;
            DWORD r = m_pPort->GetPortData(b);
            if ( r != 0 )
            {
                if ( m_pListener != NULL )
                {
                    m_pListener->OnPollingError(r);
                }
            }
            else
            {
                m_Input(b);
            }
        }
        return 0;
    }
    void m_Input(TYP b)
    {
        if ( m_chatter > 1 )
        {
            TYP cf = 0; // 変化フラグ 最終的に 0 なら確定
            loop ( i, m_chatter - 1 )
            {
                TYP t = m_chatData[(m_chatCount - i) % m_chatter];
                cf |= TYP(t ^ b); //差異のあるBITは１になる。
            }
            TYP da = TYP((m_fixData & cf) | (b & ~cf)); //確定したものを格納。それ以外は前のまま
            TYP ch = TYP(m_fixData ^ da);               // 変化したら BITが１になる。
            m_fixData = da;
            if ( ch != 0 && m_pListener != NULL )
            {
                //TRACE2("  変化;[%02X] 確定;[%02X]\n", ch, da);
                m_pListener->OnPollingBitChanged(ch, da);
            }
            m_chatCount++;
            m_chatData[m_chatCount % m_chatter] = b;
        }
        else
        {
            TYP ch = TYP(m_fixData ^ b);                // 変化したら BITが１になる。
            m_fixData = b;
            if ( ch != 0 && m_pListener != NULL )
            {
                m_pListener->OnPollingBitChanged(ch, b);
            }
        }
    }
 
private:
    CThread             m_thread;       
    IPort*              m_pPort;        
    IListener*          m_pListener;    
    DWORD               m_interval;     
    DWORD               m_chatter;      
    CWorkMemT<TYP>      m_chatData;     
    DWORD               m_chatCount;    
    TYP                 m_fixData;      
    friend class CPollingTriggerTest;
};
 
 
 
typedef CPollingTriggerT<BYTE> CPollingTrigger;
 
 
 
}; //TNB