#include?“StdAfx.h“
#include?“.\acceptcontext.h“
#include?“baseDefine.h“

bool?CAcceptContext::m_bInitialized?=?false;
CRITICAL_SECTION?CAcceptContext::m_struCriSec?=?{0};
CContextStack*?CAcceptContext::m_pAcceptContextStack?=?NULL;
CContextStack*?CAcceptContext::m_pAcceptContextManageStack?=?NULL;
CAcceptContext::CAcceptContext（int?opModeSOCKET?listenSocketSOCKET?clientSocket）
{
	m_iOperateMode?=?opMode;
	m_struListenSocket?=?listenSocket;
	m_hSocket?=?clientSocket;
	ZeroMemory（&m_struOperateOlsizeof（WSAOVERLAPPED））;
	ZeroMemory（m_ucAddressbufACCEPT_ADDRESS_LENGTH*2）;

}
CAcceptContext::~CAcceptContext（void）
{
????m_iOperateMode?=?SC_WAIT_ACCEPT;
	m_struListenSocket?=?NULL;
//	closesocket（m_hSocket）;
	m_hSocket?=?NULL;
	ZeroMemory（&m_struOperateOlsizeof（WSAOVERLAPPED））;
	ZeroMemory（m_ucAddressbufACCEPT_ADDRESS_LENGTH*2）;
}
void?CAcceptContext::SetAcceptParameters（SOCKET?listenSocketSOCKET?clientSocket）
{
	m_struListenSocket?=?listenSocket;
	m_hSocket?=?clientSocket;
}
void?CAcceptContext::ResetContext（）
{
????//m_iOperateMode?=?SC_WAIT_ACCEPT;
	m_struListenSocket?=?NULL;
	m_hSocket?=?NULL;
	ZeroMemory（&m_struOperateOlsizeof（WSAOVERLAPPED））;
	ZeroMemory（m_ucAddressbufACCEPT_ADDRESS_LENGTH*2）;
}
void?CAcceptContext::InitContextPool（long?poolSize/*?=?DEFAULT_ACCEPT_CONTEXT_POOL*/）
{
	if（m_bInitialized）
		return?;

	m_pAcceptContextStack?=?new?CContextStack（）;
	m_pAcceptContextManageStack??=?new?CContextStack（）;

	if（m_pAcceptContextStack?==?NULL）
		return?;

	InitializeCriticalSection（&m_struCriSec）;
????CAcceptContext*?pContext?=?NULL;
	for（int?i=0;i	{
		pContext?=?new?CAcceptContext（SC_WAIT_ACCEPTNULLNULL）;
		if（pContext）
		{
			m_pAcceptContextStack->Push（pContext）;//鏈接對象入棧
			m_pAcceptContextManageStack->Push（pContext）;	
			pContext->m_iContextIndex?=?m_pAcceptContextManageStack->Size（）;
		}
	}
????m_bInitialized?=?true;
}
CAcceptContext*?CAcceptContext::GetContext（）
{
	if（!m_bInitialized）
		return?0;

	CAcceptContext*?pContext?=?NULL;
	EnterCriticalSection（&m_struCriSec）;
	if（!m_pAcceptContextStack->IsEmpty（））
	{
		pContext?=?（CAcceptContext*）m_pAcceptContextStack->Pop（）;
	}
	else
	{
					
		pContext?=?new?CAcceptContext（SC_WAIT_ACCEPTNULLNULL）;
		
		pContext->m_iContextIndex?=?m_pAcceptContextManageStack->Size（）;
		m_pAcceptContextManageStack->Push（pContext）;
	}
	LeaveCriticalSection（&m_struCriSec）;

	//此處有可能會出現(xiàn)線程同步問題
	return?pContext;
}
void?CAcceptContext::ReleaseContext（）
{
	if（this）
	{
		EnterCriticalSection（&m_struCriSec）;
????????m_pAcceptContextStack->Push（this）;
		LeaveCriticalSection（&m_struCriSec）;
	}
}
//銷毀整個鏈接池context
void?CAcceptContext::DestroyContextPool（）
{
	CAcceptContext*?pContext?=?NULL;
	int?size?=?m_pAcceptContextStack->Size（）;
	for（int?i=0;i	{
		pContext?=?（CAcceptContext*）m_pAcceptContextManageStack->Pop（）;
		if（pContext）
		{
			delete?pContext;
			pContext?=?NULL;
		}
	}