alarm server.h

实时监控

#ifndef _ALARM_SERVER_H
#define	_ALARM_SERVER_H

#include "thread.h"
#include "vector"

struct accept_connect
{
	sockaddr  m_acceptsockaddr;
	SOCKET accept_socket ;
};

typedef std::vector<accept_connect*> connect_list;
typedef connect_list::iterator cit;

class net_alarmserver: public thread_base
{
protected:
	
	FD_SET InternalReadfds;

	BOOL m_lisen_exit;

	connect_list connect_vect;

	friend DWORD WINAPI ListenServerThread(LPVOID p);

	virtual void entry();

	virtual void got_something();

	virtual bool on_net_tcp_recv(byte* buf, int length);

private:

	byte getdatabuf[512];

	SOCKET server_socket;

	HANDLE ListenThreadHandle;

	void send_alarm_id(DWORD pstid, DWORD psgid);

public:
	net_alarmserver();

	void destroy();

	virtual bool create(USHORT bindport);

};

#endif