recvagent.h

组播发送测试网络程序,客户端

// RecvAgent.h: interface for the CRecvAgent class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_RECVAGENT_H__EA133345_0307_4014_ADF0_58B7FD2A6518__INCLUDED_)
#define AFX_RECVAGENT_H__EA133345_0307_4014_ADF0_58B7FD2A6518__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000
#include "RBaseStream.h"
class CRecvAgent : public  CRBaseStream  
{
public:
	char* GetPackageInfo(char *pbuffer,int len);
	void SetBlockListSize(long lcount);
	long GetPackageSize();
	long GetRecvPackageCount();
	long GetLossCount();
	void Close();
	void Init(char *strIP, DWORD dwPort,bool bisSave);
	void SetSave(bool);
	CRecvAgent();
	virtual ~CRecvAgent();

private:
	void CheckBlockListError();
	void CheckIsLoss();
	void SetProInfo(int nSize);
	void SaveData();
	DWORD RStreamThread();
	bool   m_bIsSave;
	FILE * fp;
	long m_lLossPackageCount;
	long m_lRecvPackageCount;
	
	DWORD m_dwPackageSize;
	DataBlock databuff;
	DWORD m_dwPreBlockIndex,m_dwPreRecvBlockIndex;
    DWORD m_dwRealbitrate;
	DWORD dwCurMSGDataSize,dwLastMSGTime,m_dwNow,dwPreTime;

    int m_nDelayCount,m_nSaveBlockCount;
	int m_nMaxBlockListSize;
    char m_strOutFile[MAX_PATH];
	BlockListInfo  zBlockInfo;
};

#endif // !defined(AFX_RECVAGENT_H__EA133345_0307_4014_ADF0_58B7FD2A6518__INCLUDED_)