#include "stdafx.h"

#include "RYL_ServerRequestKeeper.h"

#include <Network/Session/Session.h>
#include <Network/Dispatch/Dispatch.h>

CServerRequestKeeper::CServerRequestKeeper() 
: m_RequestKey(0)
{
}

CServerRequestKeeper::~CServerRequestKeeper()
{
	CCSLock::Syncronize sync(m_RequestMapLock);

	m_RequestMap.clear();
}

unsigned long CServerRequestKeeper::Push(CPacketDispatch* lpPacketDispatch, unsigned long dwClientRequest)
{
	CCSLock::Syncronize sync(m_RequestMapLock);

	m_RequestMap.insert(std::make_pair(++m_RequestKey, RequestInfo(dwClientRequest, lpPacketDispatch)));

	return m_RequestKey;
}

bool CServerRequestKeeper::Pop(unsigned long dwRequestKey)
{
	CCSLock::Syncronize sync(m_RequestMapLock);

	std::pair<isMapReqMap::iterator, isMapReqMap::iterator> itrs = m_RequestMap.equal_range(dwRequestKey);

	for(; itrs.first != itrs.second; ++itrs.first)
	{		
		m_RequestMap.erase(itrs.first);
		return true;
	}
	
	return false;
}

bool CServerRequestKeeper::GetRequest(unsigned long dwRequestKey, CServerRequestKeeper::RequestInfo& Out_Info)
{
	CCSLock::Syncronize sync(m_RequestMapLock);

	std::pair<isMapReqMap::iterator, isMapReqMap::iterator> itrs = m_RequestMap.equal_range(dwRequestKey);

	for(; itrs.first != itrs.second; ++itrs.first)
	{
		Out_Info = itrs.first->second;		
		return true;
	}
	
	return false;
}

// 해당 ClientDispatch가 소멸했을경우를 대비하여 소멸자에 이녀석을 추가시켜놓자...
void CServerRequestKeeper::RemoveAllSelectDispatch(CPacketDispatch* lpPacketDispatch)
{
	CCSLock::Syncronize sync(m_RequestMapLock);
	isMapReqMap::iterator itr = m_RequestMap.begin();
		
	for(; itr != m_RequestMap.end(); )
	{
		RequestInfo& Info = itr->second;

		if(lpPacketDispatch == Info.m_lpPacketDispatch)
		{
			m_RequestMap.erase(itr++);
		}
		else
		{
			++itr;
		}
	}
}