net_bk.h

实时监控

#ifndef _NET_BK_H
#define	_NET_BK_H

#include "../av/bk_buf.h"
#include "net_tcp.h"
#include "../notif/notif_bk.h"
#include "net.h"
/*
 *	class net_bk, 备份网络线程
 */
//##ModelId=3F9A1D2400BA
class net_bk: public net_tcp
{
	DWORD total_bytes ;
	
	//##ModelId=3F9A1D2400C5
	CString path;
	//##ModelId=3F9A1D2400CF
	backup_data_buf bkbuf;
	//##ModelId=3F9A1D2400E2
	DWORD bklength;
	//##ModelId=3F9A1D2400EC
	FILE* bkfile;

	//##ModelId=3F9A1D2400F6
	volatile bool exiting;
	volatile bool finished;

	//##ModelId=3F9A1D240100
	void write_backup_data(byte* buf, int length);
	//##ModelId=3F9A1D240114
	BOOL RcvBackupFrameData();
	//##ModelId=3F9A1D240115
	BOOL RcvBackupNewFrameData();
	//##ModelId=3F9A1D24011E
	BOOL is_backup_header(int pos);
protected:
	//##ModelId=3F9A1D240129
	virtual void on_recv(byte* buf, int length);

public:
	//##ModelId=3F9A1D24013D
	CALLEE bkcb;

	bool backup_is_start;
	
	//##ModelId=3F9A1D240146
	net_bk();
	//##ModelId=3F9A1D240147
	virtual ~net_bk();
	
	//##ModelId=3F9A1D240151
	void set_path(LPCTSTR p);
	
	//##ModelId=3F9A1D24015A
	virtual void destroy();
	//##ModelId=3F9A1D240164
	virtual bool create(net_addr& na,int type);

	bool IsExit() { return exiting ;}
	bool IsFinished(){ return finished;}
};

#endif	// _NET_BK_H