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 "MultSock.h"	// Added by ClassView
//#include "MyVideoMpublic.h"	// Added by ClassView
//#include "MyCommPublic.h"
#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

class CRBaseStream  
{
public:


	CRBaseStream();
	virtual ~CRBaseStream();	
	//VideoStreamStruct *p_RStreamVideo;
	
public:
	BOOL m_bIsInited;
	Stream_Status GetStreamStatus();
	void Stop();
	void Pause();
	void Start();
	WSAEVENT m_eventRecive;
	int m_nActiveXStatus;   	//控件的状态 0未初始化 1已经初始化 2 正在接收数据
	virtual void Close();
	virtual DWORD StreamThread();
	virtual int  Create(LPCTSTR strAddr, unsigned short uPort);

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


protected:
	CMultiSock m_sSocket;
	struct sockaddr_in m_socLocal;          //本机地址
	struct sockaddr_in m_socDest;			//组播地址

	HANDLE m_hBeginPlay,m_hPausePlay,m_hStopPlay,m_hTerminateThread,m_hThread;
	Stream_Status m_zStreamStatus;
    DWORD m_dwThreadId;
private:

					
};

#endif // !defined(AFX_RBASESTREAM_H__3F1CF9A3_F16D_488F_8FF1_D1387C935546__INCLUDED_)