mcdaq_device.h

#ifndef _CPL_MCDAQ_DEVICE_H_
#define _CPL_MCDAQ_DEVICE_H_

#include "base classses.h"
#include "cpl queue.h"
#include "misc tools.h"


class CChannelMCDAQ;

#define MCDAQ_MAN_STR   _T("DAQMan")
class CManagerMCDAQ : public CManager
{
public:
    CManagerMCDAQ(CComm* pcComm, const TCHAR szPipe[], int nChan, int &nError);
    virtual ~CManagerMCDAQ();
    void ProcessData(const void *pHead, DWORD dwSize, __int64 llId);
    void Result(void *pHead, bool bPass) {if (m_pcMemPool) m_pcMemPool->PoolRelease(pHead);}
    virtual DWORD GetInfo(void* pHead, DWORD dwSize);
    const unsigned short            m_usChans;  // number of daq ports availible for use.
private:
    std::vector<CChannelMCDAQ*>     m_acDAQDevices; // list of all the daq channels acive, could be NULL
};


typedef struct SMCDAQPacket
{
    __int64         llId;   // the pipe that gets the response
    SMCDAQWData*    psData;
} SMCDAQPacket;


#define MCDAQ_CHAN_STR  _T("DAQChan")
class CChannelMCDAQ : public CDevice
{
public:
    CChannelMCDAQ(const TCHAR szPipe[], int nChan, SChanInitMCDAQ &sChanInit, int &nError, 
        LARGE_INTEGER &llStart);
    virtual ~CChannelMCDAQ();
    void ProcessData(const void *pHead, DWORD dwSize, __int64 llId);
    void Result(void *pHead, bool bPass) {if (m_pcMemPool) m_pcMemPool->PoolRelease(pHead);}
    DWORD GetInfo(void* pHead, DWORD dwSize);

    DWORD ThreadProc(); // thread that reads/writes to physical device
    
    const SChanInitMCDAQ        m_sChanInit;    // channel initialization info
    const std::tstring          m_csPipeName;   // channels pipe name
    const unsigned short        m_usChan;       // channel/MCDAQ channel for this instance
private:
    CTimer                      m_cTimer;       // timer of this channel
    unsigned short              m_usLastWrite;  // the last word written

    HANDLE                      m_hStopEvent;   // signals stop
    HANDLE                      m_hWriteEvent;  // signals a new write ready
    HANDLE                      m_hReadEvent;   // signals a read request
    CQueue<SMCDAQPacket*>       m_asWPackets;   // holds the requested write packets
    std::vector<long long>      m_allReads;     // holds the pipes that requested reads
    CRITICAL_SECTION            m_hReadSafe;    // protects access to m_allReads

    HANDLE                      m_hThread;      // handle to thread
};
#endif