sendstream.h

组播发送测试网络程序,服务器端

// SendStream.h: interface for the CSendStream class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_SENDSTREAM_H__26E8FA52_A7A7_4F8B_8E09_8429FBAC0317__INCLUDED_)
#define AFX_SENDSTREAM_H__26E8FA52_A7A7_4F8B_8E09_8429FBAC0317__INCLUDED_

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

#include "BaseStream.h"

class CSendStream : public CBaseStream  
{
public:
	void Close();
	DWORD GetSpanTime();
	DWORD GetCountEach();
	
	DWORD GetPackageSize();
	void FillBlock(char *pinfo);
	void SetPackageSize(DWORD);
	DWORD SendMultiData();
	void Init(char *strIP,char *,DWORD dwPort,int );
	DWORD GetRealBitrate();
	void SetBitrate(DWORD );
	CSendStream();
	virtual ~CSendStream();
private:
	void SetProInfo(int nSize);
	DWORD StreamThread();
    DWORD m_dwRealbitrate;
    DataBlock BlockBuff;
    DWORD m_dwPackageSize;
//	DWORD m_dwPerSendCount;
   
	DWORD m_dwBlockCountEach,m_dwBlockSpanTime;
	DWORD m_dwRealSize;
private:
	void CalculatePara(float fBitrate,float fPackageSize);
	DWORD  CalculateBlockSize(float );
	DWORD  CalculateBitrate();
	void CheckTransportPara();
    BOOL m_bIsLimitedBitrate;
	HANDLE m_hTimerEvent;
	MMRESULT mmTimerID;
    DWORD dwThreadId;

	HANDLE m_hIOMUTEX;
   DWORD dwCurMSGDataSize,dwLastMSGTime,m_dwNow,dwPreTime;
   int m_nDelayCount;
};

#endif // !defined(AFX_SENDSTREAM_H__26E8FA52_A7A7_4F8B_8E09_8429FBAC0317__INCLUDED_)