741 lines
20 KiB
C++
741 lines
20 KiB
C++
#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(); // ¼ö½Å ÆÐŶ ¹«½Ã
|
||
continue;
|
||
}
|
||
#endif // #if defined(_TW)
|
||
#if defined(_TH)
|
||
if (pCon && (pSocketContext->m_dwKeyParam == CONNECTIONKEY_TH_AUTH ))
|
||
{
|
||
pCon->FlushAuthData_TH(); // ¼ö½Å ÆÐŶ ¹«½Ã
|
||
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
|
||
{
|
||
// ÇÁ·Î¼¼½ºÅ¥°¡ ºñ¸é ³í½Ã±×³Î·Î ¹Ù²Ù°í ½ÅÈ£´ë±â
|
||
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 °ªÀÌ ³Ê¹« Ä¿¼ µû·Î µ½´Ï´Ù.
|
||
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 ±è¹ä
|
||
// OnConnected() ¿¡¼ BufferClear()À» ÇÒ°æ¿ì Á¢¼ÓÇÏÀÚ¸¶ÀÚ ÆÐŶº¸³»´Â°æ¿ì ¹öÆÛ ²¿¿©¼ ÆÐŶ À¯½ÇµÊ.
|
||
// CIocpManager::AttachSocket() ÇÔ¼ö¿¡¼ BufferClear() ·Î º¯°æÇÔ
|
||
|
||
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);
|
||
// Á¢¼ÓµÇ¾úÀ¸´Ï ¹º°¡ ÁغñÇضó°í ¾Ë¸²!!! [¹Ù·Î º¸³¾°ÍÀΰ¡ ¾Æ´Ï¸é ·ÎÁ÷³»¿¡¼ ¹º°¡ ÀÏÀÌ ³¡³ª¾ß ó¸®ÇÒ°ÍÀΰ¡.]
|
||
//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)
|
||
{
|
||
// ¼¹ö¿¡¼ Ä¿³ØÆ®¸¦ ½Ãµµ ÇÏ´Â ¾Öµé¸¸ ³Ö¾îÁÖ¼¼¿ä..AddConnectionEx¸¦ È£ÃâÇÏ´Â ¾Öµé?
|
||
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());
|
||
// Àá±ñ ¸·¾ÆµÎ°ÚÀ½!!! 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");
|
||
}
|
||
}
|
||
}
|