net_udp.h

实时监控

#ifndef _NET_UDP_H
#define _NET_UDP_H

#include "net_base.h"
#include "net_addr.h"
#include "thread.h"
#include "event.h"
#include "../notif/notif_base.h"
#include "../notif/notif_net.h"

//#define USE_MSG

/*
 *	Socket - UDP基本功能封装
 */
//##ModelId=3F9A1D220107
class net_udp: private thread_base
{
protected:
	//##ModelId=3F9A1D220113
	SOCKET h;
	//##ModelId=3F9A1D220126
	net_addr local;
public:
	//##ModelId=3F9A1D22012F
	net_udp();
	//##ModelId=3F9A1D220130
	virtual ~net_udp();
	
	//##ModelId=3F9A1D22013A
	ULONG get_ip() const;
	//##ModelId=3F9A1D22013C
	USHORT get_port() const;

	//##ModelId=3F9A1D220144
	virtual bool create(net_addr& addr, BOOL image_type);
	//##ModelId=3F9A1D22014D
	virtual void destroy();
	//##ModelId=3F9A1D220157
	virtual DWORD send(byte* buf, int length, net_addr& target);
	//##ModelId=3F9A1D22016B
	virtual DWORD recv(byte* buf, net_addr* from = NULL);

private:
	//##ModelId=3F9A1D220176
	virtual void entry();
	//##ModelId=3F9A1D220180
	void reset_read();
	//##ModelId=3F9A1D220189
	void got_something();

	byte get_data_buf[8192] ;

	void create_new_bind_socket(net_addr& addr, USHORT & new_port, BOOL image_type);
	//##ModelId=3F9A1D22018A
	virtual void on_net_udp_recv(byte* buf, int length, net_addr* from){};
};

#endif	// _NET_UDP_H