/** @file Connector.h 
@brief 
<pre>
*	Copyright (c) 2007，第九城市游戏研发中心
*	All rights reserved.
*
*	当前版本：
*	作    者：zhangsongwei
*	完成日期：2007-10-10
*
*	取代版本：
*	作    者：
*	完成日期：
</pre>*/

#ifndef CONNECTOR_H
#define CONNECTOR_H

#include "./BufQueue/BufQueue.h"
#include "./BufQueue/BufQueueImp.h"

/**
* @class CConnector
*
* @brief 抽象地连接器工厂类
*/
template <class SVC_HANDLER, ACE_PEER_CONNECTOR_1>
class CConnector : public ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2>
{
public:
	typedef ACE_Connector<SVC_HANDLER, ACE_PEER_CONNECTOR_2> parent;

	/// 缺省构造
	CConnector(void);

	/// 构造
	CConnector(IBufQueue *pReadQueue, IBufQueue *pSendQueue, unsigned int uiPeerBufferSize);

	/// 析构
	virtual ~CConnector(void);

public:
	/// 重写handler的获取规则
	virtual int make_svc_handler(SVC_HANDLER *&sh);


	/// 获取/设置队列
	/// 获取已读队列
	IBufQueue * ReadQueue(void);

	/// 设置已读队列
	void ReadQueue(IBufQueue *pReadQueue);

	/// 获取待发队列
	IBufQueue * SendQueue(void);

	/// 设置待发队列
	void SendQueue(IBufQueue *pSendQueue);

private:
	/// 已读消息队列 
	IBufQueue *m_pReadQueue;

	/// 待发消息队列
	IBufQueue *m_pSendQueue;

	/// 连接端发送缓存
	unsigned int m_uiPeerBufferSize;

};

#if defined(ACE_TEMPLATES_REQUIRE_SOURCE)
#include "Connector.cpp"
#endif

#if defined(ACE_TEMPLATES_REQUIRE_PRAGMA)
#pragma implementation("Connector.cpp")
#endif
#endif/*CONNECTOR_H*/