net_bktcp.h

实时监控

#ifndef _NET_BK_H
#define	_NET_BK_H

#include "../av/bk_buf.h"
#include "net_clienttcp.h"
#include "../notif/notif_bk.h"
#include "net.h"
#include "../decoder/g722/G722Player.h"
/*
 *	class net_bk, 备份网络线程
 */
//##ModelId=3F9A1D2400BA
class net_bktcp: public net_clienttcp
{
	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;

	//##ModelId=3F9A1D240100
	bool write_backup_data(byte* buf, int length);
	//##ModelId=3F9A1D240114
	BOOL RcvBackupFrameData();
	//##ModelId=3F9A1D240115
	int RcvBackupNewFrameData();
	//##ModelId=3F9A1D24011E
	int is_backup_header(int pos);
protected:
	//##ModelId=3F9A1D240129
	virtual bool on_net_tcp_recv(byte* buf, int length, ULONG from_ip, USHORT from_port);

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

	bool backup_is_start;
	
	//##ModelId=3F9A1D240146
	net_bktcp();
	//##ModelId=3F9A1D240147
	virtual ~net_bktcp();
	
	//##ModelId=3F9A1D240151
	void set_path(LPCTSTR p);

	void send_data();

	void set_bkcb(CALLEE cb);
	
	void terimt_destroy();
	//##ModelId=3F9A1D24015A
	virtual void destroy();
	//##ModelId=3F9A1D240164
	virtual bool create(ULONG ip, USHORT port);

	bool IsExit() { return exiting ;}

	CAudioBuffer m_send_buf;
};

#endif	// _NET_BK_H