#pragma once
|
#include "device.h"
|
|
#define MVSOL_DEVICE_FOUND 34700
|
|
#define MVSOL_DEVICE_MANAGER_STATE (WM_USER+0x1001)
|
|
namespace mvsol {
|
|
class AFX_EXT_CLASS DeviceManagerUdp
|
{
|
friend class DeviceInfo;
|
|
public:
|
DeviceManagerUdp(HWND hwnd);
|
~DeviceManagerUdp();
|
|
enum DeviceManagerState
|
{
|
kSendingBegin = 0,
|
kSendingEnd,
|
};
|
|
class SocketData
|
{
|
public:
|
SocketData();
|
~SocketData();
|
|
std::string localip;
|
|
sockaddr_in local;
|
sockaddr_in remote;
|
|
SOCKET socket;
|
|
CWinThread* thread;
|
BOOL isstop;
|
|
PBYTE buffer;
|
INT buffersize;
|
|
void* pthis;
|
INT index;
|
|
BOOL isconnected;
|
};
|
|
//Operation
|
public:
|
BOOL Open();
|
BOOL Open(INT index);
|
void Close();
|
void Close(INT index);
|
|
void Send();
|
void Send(INT index);
|
|
void IpAddress(const DeviceInfo& device, DWORD ipaddress);
|
void SetID(const DeviceInfo&device, uint64_t id);
|
|
protected:
|
void Init();
|
INT Encrypt(const PBYTE indata, const INT indatasize, PBYTE outdata, PINT outdatasize);
|
INT Decrypt(const PBYTE indata, const INT indatasize, PBYTE outdata, PINT outdatasize);
|
|
void StartReceiveThread();
|
void StartReceiveThread(INT index);
|
void StopReceiveThread();
|
void StopReceiveThread(INT index);
|
void OnThreadReceive(INT index);
|
static UINT ThreadReceiveFunc(LPVOID param);
|
|
void StartSendThread();
|
void StopSendThread();
|
void OnThreadSend();
|
static UINT ThreadSendFunc(LPVOID param);
|
|
protected:
|
virtual int Parse(INT index, const PBYTE indata, INT indatasize);
|
virtual int OnReceivePacket(INT index, const PBYTE indata, INT indatasize);
|
|
//Attribution
|
public:
|
|
|
protected:
|
SocketData* socketdata_;
|
INT socketdatasize_;
|
|
WSAData wsadata_;
|
|
HWND parenthandle_;
|
|
CWinThread* thread_;
|
BOOL isstop_;
|
|
};
|
|
|
} // namespace mvsol
|
