Subversion Repositories DevTools

//---------------------------------------------------------------------------

#ifndef UdTransferThreadH

#define UdTransferThreadH

//---------------------------------------------------------------------------

#include <Classes.hpp>

#include <vector>

#include "UdTransferManager.h"

class DeviceSimulatorThread;

class IDeviceFactory;

//---------------------------------------------------------------------------

class UdTransferThread : public TThread

{

    typedef struct tagTHREADNAME_INFO

    {

        DWORD dwType;     // must be 0x1000

        LPCSTR szName;    // pointer to name (in user addr space)

        DWORD dwThreadID; // thread ID (-1=caller thread)

        DWORD dwFlags;    // reserved for future use, must be zero

    } THREADNAME_INFO;

public:

    __fastcall UdTransferThread( const UdTransferTask & task,

                                 UdTransferManager * manager,

                                 IDeviceFactory * deviceFactory );

    bool __fastcall IsRunning() { return m_running; }                                 

    void __fastcall StopTransfer() { m_running = false; }

    void __fastcall GetTransferStatistics( UdTransferStatistics & stats );

protected:

    void __fastcall Execute();

private:

    void SetName();

    bool InitialiseTask();

    bool ConnectDeviceSimulators();

    void RampTransferBatch();

    bool TransferNextBatch();

    void CheckDeviceSimulatorThreads();

    bool TransferUdFile( const AnsiString & filename );

    int  GetBatchSize();

private:

    bool    m_running;

    bool    m_error;

    bool    m_renameSent;

    bool    m_ignoreSent;

    bool    m_simulators;

    int     m_lastDevice;

    int     m_maxDevices;

    int     m_deviceId;

    int     m_connectTimeout;

    AnsiString m_deviceType;

    struct Ramp

    {

        bool        running;

        int         batchSize;

        int         count;

    } m_ramp;

    UdTransferManager *     m_manager;

    UdTransferTask          m_task;

    UdTransferStatistics    m_stats;

    IDeviceFactory *        m_deviceFactory;

    std::vector<DeviceSimulatorThread *> m_devices;  

};

//---------------------------------------------------------------------------

#endif