DragonNest/Server/DNMasterServer/DNIocpManager.cpp

#include "StdAfx.h"
#include "Connection.h"
#include "DNIocpManager.h"
#include "DNDivisionManager.h"
#include "DNLoginConnection.h"
#include "DNVillageConnection.h"
#include "DNGameConnection.h"
#include "DNUser.h"
#include "Log.h"
#include "DNServiceConnection.h"
#include "DNLogConnection.h"
#if defined(_KR)
#include "DNNexonAuth.h"
#endif	// _KR
#if defined(_KRAZ)
#include "DNActozShield.h"
#endif	// #if defined(_KRAZ)
#if defined(_TW) 
#include ".\\TW\\DNGamaniaAuth.h"
#endif	// #if defined(_TW)
#if defined(_JP)
#include "DNNHNNetCafe.h"
#endif	// #if defined(_JP)
#if defined(_TH)
#include "DNAsiaSoftPCCafe.h"
#endif
#ifdef PRE_ADD_DOORS
#include "DNDoorsConnection.h"
#endif		//#ifdef PRE_ADD_DOORS
#if defined(PRE_ADD_CHNC2C)
#include "DNC2C.h"
#endif

extern TMasterConfig g_Config;
extern CSyncLock g_UpdateLock;

HANDLE CDNIocpManager::m_hSignalProcess = INVALID_HANDLE_VALUE;

CDNIocpManager* g_pIocpManager = NULL;

CDNIocpManager::CDNIocpManager(void): CIocpManager()
{
	m_hProcessThread = INVALID_HANDLE_VALUE;
	m_hIdleThread = INVALID_HANDLE_VALUE;
	
	Final();

	m_hSignalProcess = CreateEvent(NULL, TRUE, FALSE, NULL);
}

CDNIocpManager::~CDNIocpManager(void)
{
	Final();
}

UINT __stdcall CDNIocpManager::ProcessThread(void *pParam)
{
	CDNIocpManager *pIocp = (CDNIocpManager*)pParam;

	CSocketContext *pSocketContext;
	CConnection *pCon = NULL;
	USHORT nRecv = 0;

	while(pIocp->m_bThreadSwitch)
	{
		if (!pIocp->m_ProcessCalls.empty())
		{
			pIocp->m_ProcessLock.Lock();
			pSocketContext = pIocp->m_ProcessCalls.front();
			pIocp->m_ProcessCalls.pop();
			pIocp->m_ProcessLock.UnLock();

			pCon = (CConnection*)pSocketContext->GetParam();

#if defined(_KR)
			if (pCon && pSocketContext->m_dwKeyParam == CONNECTIONKEY_AUTH){
				pCon->FlushAuthData();
				continue;
			}
#endif

#if defined(_TW)
			if (pCon && (pSocketContext->m_dwKeyParam == CONNECTIONKEY_TW_AUTHLOGIN || pSocketContext->m_dwKeyParam == CONNECTIONKEY_TW_AUTHLOGOUT))
			{
				pCon->RecvBufferClear();	// <20><><EFBFBD><EFBFBD> <20><>Ŷ <20><><EFBFBD><EFBFBD>
				continue;
			}
#endif	// #if defined(_TW)
#if defined(_TH)
			if (pCon && (pSocketContext->m_dwKeyParam == CONNECTIONKEY_TH_AUTH ))
			{
				pCon->FlushAuthData_TH();	// <20><><EFBFBD><EFBFBD> <20><>Ŷ <20><><EFBFBD><EFBFBD>
				continue;
			}
#endif //#if defined(_TH)

			if (pCon && pCon->FlushRecvData(timeGetTime()) == false)
			{
				g_pDivisionManager->DelConnection(pCon, (eConnectionKey)pSocketContext->m_dwKeyParam);
				g_Log.Log(LogType::_NORMAL, L"## IN_DISCONNECT connection destroyed %x\r\n", pCon);
				
				int nConType = pSocketContext->m_dwKeyParam;
				pIocp->ClearSocketContext(pSocketContext);
				pCon->SetSocketContext(NULL, NULL);

				switch( nConType )
				{
					case CONNECTIONKEY_LOGIN:
					case CONNECTIONKEY_SERVICEMANAGER:
					case CONNECTIONKEY_LOG:
						break;
					default:
					{
						SAFE_DELETE(pCon);
						pCon = NULL;
						break;
					}
				}
			}
		}
		else
		{
			// <20><><EFBFBD>μ<EFBFBD><CEBC><EFBFBD>ť<EFBFBD><C5A5> <20><><EFBFBD><EFBFBD> <20><><EFBFBD>ñ׳η<D7B3> <20>ٲٰ<D9B2> <20><>ȣ<EFBFBD><C8A3><EFBFBD><EFBFBD>
			ResetEvent(m_hSignalProcess);
			::WaitForSingleObject(m_hSignalProcess, 1000);
		}

		ULONG nCurTick = 0;
		static ULONG nPreTick = 0;

		nCurTick = timeGetTime();
		if (nPreTick == 0)
			nPreTick = nCurTick;

		if (nPreTick != 0 && nPreTick + DISTRIBUTE_IDLE_TICK < nCurTick)
		{
			if (g_pDivisionManager)
				g_pDivisionManager->InternalIdleProcess(nCurTick);
			nPreTick = nCurTick;
		}

		// DISTRIBUTE_IDLE_TICK <20><><EFBFBD><EFBFBD> <20>ʹ<EFBFBD> Ŀ<><C4BF> <20><><EFBFBD><EFBFBD> <20><><EFBFBD>ϴ<EFBFBD>.
		static UINT uiPvPUpdateTick = 0;
		if( uiPvPUpdateTick+100 < nCurTick )
		{
			if( g_pDivisionManager )
				g_pDivisionManager->UpdatePvPRoom( nCurTick );
			uiPvPUpdateTick = nCurTick;
		}
#if defined(PRE_ADD_CHNC2C)
		if ( g_pDnC2C )
			g_pDnC2C->Run();		
#endif // #if defined(PRE_ADD_CHNC2C)
	}

	return 0;
}

extern void SavePartyID();
extern void SaveVoiceChannelID();
UINT __stdcall CDNIocpManager::IdleThread(void *pParam)
{
	CDNIocpManager *pIocp = (CDNIocpManager*)pParam;

	DWORD CurTick = 0;
	static DWORD PreTick = 0;

	while(pIocp->m_bThreadSwitch){
		CurTick = timeGetTime();
		if (PreTick == 0)
			PreTick = CurTick;
		
		if (PreTick != 0 && PreTick + 1000 < CurTick)
		{
			if (g_pDivisionManager)
				g_pDivisionManager->ExternalIdleProcess(CurTick);			
			PreTick = CurTick;

			static int s_nCount = 0;
			if (s_nCount == 0 || s_nCount%(60) == 0)
			{
				SavePartyID();
				SaveVoiceChannelID();
			}
			s_nCount++;
		}

#if defined(_KR) && defined(_FINAL_BUILD)	// pc bang
		if (g_pNexonAuth) g_pNexonAuth->Reconnect(CurTick);
		if (g_pNexonAuth) g_pNexonAuth->DoUpdate(CurTick);
#endif
#if defined(_KRAZ)
		if (g_pActozShield)
			g_pActozShield->RepeatCheckerResult(CurTick);
#endif	// #if defined(_KRAZ)
#if defined(_TW) && defined(_FINAL_BUILD)
		if (g_pGamaniaAuthLogOut) 			
			g_pGamaniaAuthLogOut->Reconnect(CurTick);		
#endif	// #if defined(_TW)

#if defined(_JP) && defined(_FINAL_BUILD)
		if (g_pNHNNetCafe)
			g_pNHNNetCafe->Reconnect(CurTick);
#endif	// #if defined(_JP) && defined(_FINAL_BUILD)
#if defined(_TH) && defined(_FINAL_BUILD)
		if (g_pAsiaSoftPCCafe)
			g_pAsiaSoftPCCafe->Reconnect(CurTick);
#endif
#ifdef PRE_ADD_DOORS
		if (g_pDoorsConnection)
			g_pDoorsConnection->Reconnect(CurTick);
#endif		//#ifdef PRE_ADD_DOORS
		Sleep(500);
	}
	return 0;
}

int CDNIocpManager::Init(int nSocketCountMax)
{
	CIocpManager::Init(nSocketCountMax);
	return CreateThread();
}

void CDNIocpManager::Final()
{
	CIocpManager::Final();

	while (!m_ProcessCalls.empty()){
		m_ProcessCalls.pop();
	}

	if( m_hProcessThread != INVALID_HANDLE_VALUE )
	{
		WaitForSingleObject( m_hProcessThread, INFINITE );
		CloseHandle( m_hProcessThread );
	}
	if( m_hIdleThread != INVALID_HANDLE_VALUE )
	{
		WaitForSingleObject( m_hIdleThread, INFINITE );
		CloseHandle( m_hIdleThread );
	}

	CloseHandle(m_hSignalProcess);
}

int CDNIocpManager::CreateThread()
{
	UINT ThreadID;

	m_hProcessThread = (HANDLE)_beginthreadex(NULL, 0, &ProcessThread, this, 0, &ThreadID);
	if (m_hProcessThread == INVALID_HANDLE_VALUE) return -1;

	m_hIdleThread = (HANDLE)_beginthreadex(NULL, 0, &IdleThread, this, 0, &ThreadID);
	if (m_hIdleThread == INVALID_HANDLE_VALUE) return -1;

	return 0;
}

void CDNIocpManager::AddProcessCall(CSocketContext *pSocketContext)
{
	m_ProcessLock.Lock();
	m_ProcessCalls.push(pSocketContext);
	SetEvent(m_hSignalProcess);
	m_ProcessLock.UnLock();
}

void CDNIocpManager::OnAccept(CSocketContext *pSocketContext, const char* pIp, const int nPort)
{
	switch(pSocketContext->m_dwKeyParam)
	{
	case CONNECTIONKEY_LOGIN:
		{
			CDNLoginConnection * pCon = g_pDivisionManager->FindLoginConnection(pIp, nPort);
			if (!pCon) {
				DetachSocket(pSocketContext, L"DivisionManager Login Connect Failed");
				return;
			}

			pSocketContext->SetParam(pCon);
			pCon->SetSocketContext(this, pSocketContext);
			pCon->SetServerConnection(false);
			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:Login] Socket:%d, Ip:%S\r\n", pSocketContext->m_Socket, pCon->GetIp());
		}
		break;

	case CONNECTIONKEY_VILLAGE:
		{
			CDNVillageConnection * pCon = g_pDivisionManager->VillageServerConnected(pIp, nPort);
			if (!pCon)
			{
				DetachSocket(pSocketContext, L"DivisionManager Village Connect Failed");
				return;
			}

			pSocketContext->SetParam(pCon);
			pCon->SetSocketContext(this, pSocketContext);
			pCon->SetServerConnection(true);
			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:Village] Socket:%d, Ip:%S\r\n", pSocketContext->m_Socket, pCon->GetIp());
		}
		break;

	case CONNECTIONKEY_GAME:
		{
			CDNGameConnection * pCon = g_pDivisionManager->GameServerConnected(pIp, nPort);
			if (!pCon)
			{
				DetachSocket(pSocketContext, L"DivisionManager Game Connect Failed");
				return;
			}

			pSocketContext->SetParam(pCon);
			pCon->SetSocketContext(this, pSocketContext);
			pCon->SetServerConnection(true);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:Game] Socket:%d, Ip:%S\r\n", pSocketContext->m_Socket, pCon->GetIp());
		}
		break;
	case CONNECTIONKEY_SERVICEMANAGER:
		{
			pSocketContext->SetParam(g_pServiceConnection);
			g_pServiceConnection->SetSocketContext(this, pSocketContext);
			g_pServiceConnection->SetDelete(false);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:Service] Socket:%d, Ip:%S\r\n", pSocketContext->m_Socket, g_pServiceConnection->GetIp());
		}
		break;

		case CONNECTIONKEY_LOG:
		{
			pSocketContext->SetParam(g_pLogConnection);
			g_pLogConnection->SetSocketContext(this, pSocketContext);
			g_pLogConnection->SetServerConnection(false);

			g_Log.Log( LogType::_FILEDBLOG, g_Config.nWorldSetID, 0, 0, 0, L"[OnAccept:Log] Socket:%d, Ip:%S\r\n", pSocketContext->m_Socket, g_pLogConnection->GetIp());
			break;
		}

#if defined(_KR) && defined(_FINAL_BUILD)	// pc bang
	case CONNECTIONKEY_AUTH:
		{
			pSocketContext->SetParam(g_pNexonAuth);
			g_pNexonAuth->SetSocketContext(this, pSocketContext);
			g_pNexonAuth->SetServerConnection(false);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:Auth] Socket:%d, Ip:%S\r\n", pSocketContext->m_Socket, g_pNexonAuth->GetIp());
		}
		break;
#endif	// _KR

#if defined(_TW) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TW_AUTHLOGOUT:
		{
			pSocketContext->SetParam(g_pGamaniaAuthLogOut);
			g_pGamaniaAuthLogOut->SetSocketContext(this, pSocketContext);
			g_pGamaniaAuthLogOut->SetServerConnection(false);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:GamaniaAuthLogOut] Socket:%d, Ip:%S, Port:%d\r\n", pSocketContext->m_Socket, g_pGamaniaAuthLogOut->GetIp(), g_pGamaniaAuthLogOut->GetPort());
		}
		break;
#endif	// #if defined(_TW)
#if defined(_TH) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TH_AUTH :
		{
			pSocketContext->SetParam(g_pAsiaSoftPCCafe);
			g_pAsiaSoftPCCafe->SetSocketContext(this, pSocketContext);
			g_pAsiaSoftPCCafe->SetServerConnection(false);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:AsiaSoftPCCafe] Socket:%d, Ip:%S, Port:%d\r\n", pSocketContext->m_Socket, g_pAsiaSoftPCCafe->GetIp(), g_pAsiaSoftPCCafe->GetPort());
		}
		break;
#endif

#ifdef PRE_ADD_DOORS
	case CONNECTIONKEY_DOORS:
		{
			pSocketContext->SetParam(g_pDoorsConnection);
			g_pDoorsConnection->SetSocketContext(this, pSocketContext);
			g_pDoorsConnection->SetServerConnection(false);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnAccept:DoorsServer] Socket:%d, Ip:%S, Port:%d\r\n", pSocketContext->m_Socket, g_pDoorsConnection->GetIp(), g_pDoorsConnection->GetPort());
		}
		break;
#endif		//#ifdef PRE_ADD_DOORS
	}
}

// 2009.02.03 <20><><EFBFBD><EFBFBD>
// OnConnected() <20><><EFBFBD><EFBFBD> BufferClear()<29><> <20>Ұ<EFBFBD><D2B0><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڸ<EFBFBD><DAB8><EFBFBD> <20><>Ŷ<EFBFBD><C5B6><EFBFBD><EFBFBD><EFBFBD>°<EFBFBD><C2B0><EFBFBD> <20><><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20><>Ŷ <20><><EFBFBD>ǵ<EFBFBD>.
// CIocpManager::AttachSocket() <20>Լ<EFBFBD><D4BC><EFBFBD><EFBFBD><EFBFBD> BufferClear() <20><> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>

void CDNIocpManager::OnConnected(CSocketContext *pSocketContext)
{
	switch(pSocketContext->m_dwKeyParam)
	{
	case CONNECTIONKEY_LOGIN:
		{
			CDNLoginConnection *pLoginCon = reinterpret_cast<CDNLoginConnection*>(pSocketContext->GetParam());
			if (!pLoginCon) {
				return;
			}

			pLoginCon->SetActive(true);
			pLoginCon->SetDelete(false);
		
			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:Login] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;

	case CONNECTIONKEY_VILLAGE:
		{
			CDNVillageConnection *pVillageCon = (CDNVillageConnection*)pSocketContext->GetParam();
			if (!pVillageCon) return;

			pVillageCon->SetActive(true);
			pVillageCon->SetDelete(false);
			//pVillageCon->BufferClear();

			//Village Connection Resgistration Start Point
			if (g_Config.nWorldSetID > 0)
			{
				pVillageCon->SendRegistWorldID();
			}
			else
			{
				DetachSocket(pSocketContext, L"MasterServer Initialized Yet Try Again");
				return;
			}

			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:Village] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;

	case CONNECTIONKEY_GAME:
		{
			CDNGameConnection *pGameCon = (CDNGameConnection*)pSocketContext->GetParam();
			if (!pGameCon) return;

			pGameCon->SetActive(true);
			pGameCon->SetDelete(false);
			//pGameCon->BufferClear();

			//Game Connection Resgistration Start Point
			if (g_Config.nWorldSetID > 0)
			{
				pGameCon->SendRegistWorldID();
			}
			else
			{
				DetachSocket(pSocketContext, L"MasterServer Initialized Yet Try Again");
				return;
			}

			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:Game] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;

	case CONNECTIONKEY_SERVICEMANAGER:
		{
			g_pServiceConnection->SetActive(true);
			g_pServiceConnection->SetDelete(false);
			// <20><><EFBFBD>ӵǾ<D3B5><C7BE><EFBFBD><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD> <20>غ<EFBFBD><D8BA>ض<EFBFBD><D8B6><EFBFBD> <20>˸<EFBFBD>!!! [<5B>ٷ<EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ΰ<EFBFBD> <20>ƴϸ<C6B4> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> ó<><C3B3><EFBFBD>Ұ<EFBFBD><D2B0>ΰ<EFBFBD>.]
			//g_pServiceConnection->OnConnected();
		}
		break;

	case CONNECTIONKEY_LOG:
		{
			g_pLogConnection->SetActive(true);
			g_pLogConnection->SetDelete(false);
		}
		break;

#if defined(_KR) && defined(_FINAL_BUILD)	// pc bang
	case CONNECTIONKEY_AUTH:
		{
			g_pNexonAuth->SetActive(true);
			g_pNexonAuth->SetDelete(false);

			g_pNexonAuth->SendInitialize(g_Config.nAuthDomainSN);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:Auth] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif	// _KR

#if defined(_TW) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TW_AUTHLOGOUT:
		{
			g_pGamaniaAuthLogOut->SetActive(true);
			g_pGamaniaAuthLogOut->SetDelete(false);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:GamaniaAuthLogOut] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif	// #if defined(_TW)
#if defined(_TH) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TH_AUTH :
		{
			g_pAsiaSoftPCCafe->SetActive(true);
			g_pAsiaSoftPCCafe->SetDelete(false);
			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:AsiaSoftPCCafe] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif
#ifdef PRE_ADD_DOORS
	case CONNECTIONKEY_DOORS:
		{
			g_pDoorsConnection->SetActive(true);
			g_pDoorsConnection->SetDelete(false);
			g_Log.Log(LogType::_FILEDBLOG, L"[OnConnected:DoorsServer] Socket:%d\r\n", pSocketContext->m_Socket);

			g_pDoorsConnection->SendRegist(g_Config.nWorldSetID, g_Config.DoorsIdenty[0].szIP, g_Config.DoorsIdenty[0].nPort, g_Config.DoorsIdenty[1].szIP, g_Config.DoorsIdenty[1].nPort);
		}
		break;
#endif		//#ifdef PRE_ADD_DOORS
	}
}

void CDNIocpManager::OnConnectFail(CSocketContext *pSocketContext)
{
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD> Ŀ<><C4BF>Ʈ<EFBFBD><C6AE> <20>õ<EFBFBD> <20>ϴ<EFBFBD> <20>ֵ鸸 <20>־<EFBFBD><D6BE>ּ<EFBFBD><D6BC><EFBFBD>..AddConnectionEx<45><78> ȣ<><C8A3><EFBFBD>ϴ<EFBFBD> <20>ֵ<EFBFBD>?
	CConnection* pConnection = static_cast<CConnection*>(pSocketContext->GetParam());
	if( !pConnection )
		return;

	pConnection->SetConnecting(false);

	switch(pSocketContext->m_dwKeyParam)
	{
	case CONNECTIONKEY_LOGIN:
		{
#if !defined( STRESS_TEST )
			g_Log.Log(LogType::_FILEDBLOG, L"LoginServer Fail(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
#endif
		}
		break;
	case CONNECTIONKEY_LOG:
		{
			// g_Log.Log(_ERROR, L"LogServer Fail(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
			// <20><><EFBFBD><EFBFBD> <20><><EFBFBD>Ƶΰ<C6B5><CEB0><EFBFBD>!!! 080918 saset
		}
		break;
	case CONNECTIONKEY_SERVICEMANAGER :
		{
			g_Log.Log(LogType::_FILEDBLOG, L"ServiceManager Connect Failed(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
		}
		break;
#if defined(_KR) && defined(_FINAL_BUILD)	// pc bang
	case CONNECTIONKEY_AUTH:
		{
			g_Log.Log(LogType::_FILEDBLOG, L"AuthServer Fail(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
		}
		break;
#endif
#if defined(_TW) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TW_AUTHLOGIN:
		{
			g_Log.Log(LogType::_FILEDBLOG, L"AuthLoginServer Fail(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
		}
	case CONNECTIONKEY_TW_AUTHLOGOUT:
		{
			g_Log.Log(LogType::_FILEDBLOG, L"AuthLogOutServer Fail(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
		}
		break;
#endif	// #if defined(_TW)
#if defined(_TH) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TH_AUTH :
		{
			g_Log.Log(LogType::_FILEDBLOG, L"AsiaSoftPCCafe Fail(%S, %d)\r\n", pConnection->GetIp(), pConnection->GetPort());
		}
		break;
#endif
	}
}

void CDNIocpManager::OnDisconnected(CSocketContext *pSocketContext)
{
	switch(pSocketContext->m_dwKeyParam)
	{
	case CONNECTIONKEY_LOGIN:
		{
			CDNLoginConnection *pLoginCon = reinterpret_cast<CDNLoginConnection*>(pSocketContext->GetParam());
			if (!pLoginCon) return;
			
			DNTPacket Header = { 0, };
			Header.cMainCmd = IN_DISCONNECT;
			Header.iLen = sizeof(USHORT) + (sizeof(BYTE) * 2);

			pLoginCon->BufferClear();
			pLoginCon->SetActive(false);
			pLoginCon->SetDelete(true);
			pLoginCon->AddRecvData( Header );

			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:Login] Socket:%d\r\n", pSocketContext->m_Socket);
			AddProcessCall(pSocketContext);
		}
		break;

	case CONNECTIONKEY_VILLAGE:
		{
			CDNVillageConnection *pVillageCon = (CDNVillageConnection*)pSocketContext->GetParam();
			if (!pVillageCon) return;

			DNTPacket Header = { 0, };
			Header.cMainCmd = IN_DISCONNECT;
			Header.iLen = sizeof(USHORT) + (sizeof(BYTE) * 2);

			pVillageCon->BufferClear();
			pVillageCon->SetActive(false);
			pVillageCon->SetDelete(true);
			pVillageCon->AddRecvData( Header );
			pVillageCon->SetConnectionCompleted( false );

			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:Village] Socket:%d\r\n", pSocketContext->m_Socket);
			AddProcessCall(pSocketContext);
		}
		break;

	case CONNECTIONKEY_GAME:
		{
			CDNGameConnection *pGameCon = (CDNGameConnection*)pSocketContext->GetParam();
			if (!pGameCon) return;

			DNTPacket Header = { 0, };
			Header.cMainCmd = IN_DISCONNECT;
			Header.iLen = sizeof(USHORT) + (sizeof(BYTE) * 2);

			pGameCon->BufferClear();
			pGameCon->SetActive(false);
			pGameCon->SetDelete(true);
			pGameCon->AddRecvData( Header );

			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:Game] Socket:%d\r\n", pSocketContext->m_Socket);
			AddProcessCall(pSocketContext);
		}
		break;

	case CONNECTIONKEY_SERVICEMANAGER:
		{
			DNTPacket Header = { 0, };
			Header.cMainCmd = IN_DISCONNECT;
			Header.iLen = sizeof(USHORT) + (sizeof(BYTE) * 2);

			g_pServiceConnection->Disconnected();
			g_pServiceConnection->BufferClear();
			g_pServiceConnection->SetActive(false);
			g_pServiceConnection->SetDelete(true);
			g_pServiceConnection->AddRecvData( Header );

			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:SM] Socket:%d\r\n", pSocketContext->m_Socket);
			AddProcessCall(pSocketContext);
		}
		break;

	case CONNECTIONKEY_LOG:
		{
			DNTPacket Header = { 0, };
			Header.cMainCmd = IN_DISCONNECT;
			Header.iLen = sizeof(USHORT) + (sizeof(BYTE) * 2);

			g_pLogConnection->BufferClear();
			g_pLogConnection->SetActive(false);
			g_pLogConnection->SetDelete(true);
			g_pLogConnection->AddRecvData( Header );
#if defined(PRE_ADD_LOGSERVER_HEARTBEAT)
			g_pLogConnection->ResetLiveCheck();
#endif
			g_Log.Log(LogType::_FILELOG, L"[OnDisconnected:Log] Socket:%d\r\n", pSocketContext->m_Socket);
			AddProcessCall(pSocketContext);
		}
		break;

#if defined(_KR) && defined(_FINAL_BUILD)	// pc bang
	case CONNECTIONKEY_AUTH:
		{
			g_pNexonAuth->SetActive(false);
			g_pNexonAuth->SetDelete(true);
			ClearSocketContext(pSocketContext);
			g_pNexonAuth->SetSocketContext(NULL, NULL);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:Auth] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif	// _KR

#if defined(_TW) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TW_AUTHLOGOUT:
		{
			g_pGamaniaAuthLogOut->SetActive(false);
			g_pGamaniaAuthLogOut->SetDelete(true);
			ClearSocketContext(pSocketContext);
			g_pGamaniaAuthLogOut->SetSocketContext(NULL, NULL);

			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:GamaniaAuthLogOut] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif	// #if defined(_TW)
#if defined(_TH) && defined(_FINAL_BUILD)
	case CONNECTIONKEY_TH_AUTH :
		{
			g_pAsiaSoftPCCafe->SetActive(false);
			g_pAsiaSoftPCCafe->SetDelete(true);
			//ClearSocketContext(pSocketContext);
			//g_pAsiaSoftPCCafe->SetSocketContext(NULL, NULL);
			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:AsiaSoftPCCafe] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif
#ifdef PRE_ADD_DOORS
	case CONNECTIONKEY_DOORS:
		{
			g_pDoorsConnection->SetActive(false);
			g_pDoorsConnection->SetDelete(true);
			ClearSocketContext(pSocketContext);
			g_pDoorsConnection->SetSocketContext(NULL, NULL);
			g_Log.Log(LogType::_FILEDBLOG, L"[OnDisconnected:DoorServer] Socket:%d\r\n", pSocketContext->m_Socket);
		}
		break;
#endif		//#ifdef PRE_ADD_DOORS
	}
}

void CDNIocpManager::OnReceive(CSocketContext *pSocketContext, DWORD dwBytesTransferred)
{
	CConnection *pCon = (CConnection*)pSocketContext->GetParam();
	if (pCon) {
		int nResult = pCon->AddRecvData( pSocketContext );

		if (nResult > 0){
			AddProcessCall(pSocketContext);
		}
		else if (nResult == SIZEERR){
			g_Log.Log(LogType::_ERROR, L"[OnReceive SizeError] Socket:%lld Size:%d\r\n", pSocketContext->m_Socket, pSocketContext->m_RecvIO.Len);
			DetachSocket(pSocketContext, L"OnReceive SizeError");
		}
		else if (nResult == -1){
			g_Log.Log(LogType::_ERROR, L"[OnReceive] Socket:%lld Size:%d\r\n", pSocketContext->m_Socket, pSocketContext->m_RecvIO.Len);
			DetachSocket(pSocketContext, L"OnReceive");
		}
	}
}