rbasestream.h

组播网络程序测试,对于学习组播技术有帮助

// RBaseStream.h: interface for the CRBaseStream class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_RBASESTREAM_H__3F1CF9A3_F16D_488F_8FF1_D1387C935546__INCLUDED_)
#define AFX_RBASESTREAM_H__3F1CF9A3_F16D_488F_8FF1_D1387C935546__INCLUDED_
//#include "MyBvodPublic.h"
#include "multsock.h"
#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

class CRBaseStream  
{
public:
	CRBaseStream();
	virtual ~CRBaseStream();	
	
public:
//	char * GetBufferPoint();
	int RecvData(LPVOID lpBuf, int iSize);
	Stream_Status GetStreamStatus();
	void Stop();
	void Pause();
	void Start();
	virtual void CloseStream();
	virtual DWORD RStreamThread();
	virtual int  Create(SOCKADDR_IN myAddr, SOCKADDR_IN multiAddr);

	static DWORD __stdcall InitialThread(void* pVoid)
	{   //TRACE("init thread\n");
		CRBaseStream* pThis = (CRBaseStream*)pVoid;
		return pThis->RStreamThread();
	}

   
public:
	HANDLE m_hRecvEvent;
protected:
	bool IsClose();
	ListSocketBlock m_listBlock;
	CMultiSock m_sSocket;
	HANDLE m_hBeginRecv,m_hPauseRecv,m_hStopRecv,m_hTerminateThread,m_hThread;
    HANDLE m_hCheckCloseEvent;
	
	Stream_Status m_zStreamStatus;


    DWORD m_dwThreadId;
   // char zDataBuff[64*1024];
				
};

#endif // !defined(AFX_RBASESTREAM_H__3F1CF9A3_F16D_488F_8FF1_D1387C935546__INCLUDED_)