cworkersocket.h

来自「WINCE下的播放器」· C头文件 代码 · 共 70 行

//
// CWorkerSocket.h
// Created by Qiming Lu, 2002-02-25
// 

#if !defined(__CWorkerSocket_h__)
#define __CWorkerSocket_h__

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

// Error codes 
#define S_SOCKET_OK                      0X10
#define E_SOCKET_CLOSE		             0X11
#define E_SOCKET_FAIL                    0X12
#define E_SOCKET_NOT_READY               0x13

// Message header,媒体数据信息头定义
typedef struct
{
	unsigned int    nMsgType:8;      // Payload type，负载数据类型
	unsigned int    nDataSize:16;    // Payload size，负载数据长度
} MSG_HEADER, *PMSG_HEADER;

// Message
//由服务器断发向客户端，表示已经停止发送数据
#define RECV_EXIT                        0x20  // Indicate stop receiving thread

//客户端发出，要求服务器停止数据发送
#define RECV_EXIT_REQUEST                0x21  // Request the remote to send some data

//////////////////////////////////////////////////////////////////////////////
class CWorkerSocket
{
public:
	CWorkerSocket();
	virtual ~CWorkerSocket();
	SOCKET    m_hSocket;

// Attributes
protected:
	bool      m_bReceiving;
	bool      m_bSending;

	HANDLE    m_hThrdFinish;
	HANDLE    m_hSendFinish;

public:
	bool Attach(SOCKET inSock);
	SOCKET Detach(void);
	int  Send(char * inData, int inLen);
	int  Receive(char * outBuf, int inLen);
	bool Connect(char * inTarget, int inPort);
	void Disconnect(void);

	// Receive functions
	bool StartReceiving(void);
	bool StopReceiving(void);
	virtual void ReceivingLoop(void);
	static UINT ReceivingThrd(void * pParam);

	// Send functions
	bool StartSending(void);
	bool StopSending(void);
	virtual void SendingLoop(void);
	static UINT SendingThrd(void * pParam);
};

#endif // !defined(__CWorkerSocket_h__)