Category

Development Platform
Home > SourceCode/Document > Game Program > Game Server Simulator > View Code
DealPackage.cpp
Package: SwordOnline.rar　[view]
Upload User: dzyhzl
Upload Date: 2019-04-29
Package Size: 56270k
Code Size: 4k
Category:

Game Server Simulator

Development Platform:

C/C++

DealPackage.cpp：Code Content
  1. // DealPackage.cpp: implementation of the CDealPackage class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "S3Relay.h"
  7. #include "DealPackage.h"
  9. //////////////////////////////////////////////////////////////////////
  10. // Construction/Destruction
  11. //////////////////////////////////////////////////////////////////////
  13. CDealPackage::CDealPackage()
  14. {
  15. memset(m_Protocol2Proc, sizeof(m_Protocol2Proc), 0);
  17. }
  19. CDealPackage::~CDealPackage()
  20. {
  22. }
  25. BOOL CDealPackage::Initialize()
  26. {
  27. memset(m_Protocol2Proc, sizeof(m_Protocol2Proc), 0);
  29. m_Protocol2Proc[c2s_registerfamily] = Proc_c2sRegisterFamily;
  30. m_Protocol2Proc[c2s_entergame] = Proc_c2sEnterGame;
  31. m_Protocol2Proc[c2s_leavegame] = Proc_c2sLeaveGame;
  32. m_Protocol2Proc[c2s_relay] = Proc_c2sRelay;
  34. return TRUE;
  35. }
  37. BOOL CDealPackage::Uninitialize()
  38. {
  39. return TRUE;
  40. }
  44. BOOL CDealPackage::DealPackage(const CNetConnect* pConn, const void* pData, unsigned len)
  45. {
  46. assert(pConn != NULL && pData != NULL && len >= sizeof(BYTE));
  48. BYTE Protocol = *(BYTE*)pData;
  50. in_addr ia;
  51. ia.s_addr = pConn->GetIP();
  52. gTrace("%s -- recv size: %d", inet_ntoa(ia), len);
  54. if (!m_Protocol2Proc[Protocol])
  55. return FALSE;
  57. return (this->*m_Protocol2Proc[Protocol])(pConn, pData, len);
  58. }
  63. ///////////////////////////
  64. //deal proc ...
  66. BOOL CDealPackage::Proc_c2sRegisterFamily(const CNetConnect* pConn, const void* pData, unsigned len)
  67. {
  68. if (pData == NULL || len < sizeof(tagRegisterFamily))
  69. return FALSE;
  71. tagRegisterFamily* pRegFami = (tagRegisterFamily*)pData;
  72. assert(pRegFami->cProtocol == c2s_registerfamily);
  74. if (pRegFami->bRegister)
  75. {
  76. g_pConnTrack->RegConnect(pConn->GetID(), pRegFami->nFamily, pRegFami->RelayMethod);
  77. }
  78. else
  79. {
  80. g_pConnTrack->UnregConnect(pConn->GetID(), pRegFami->nFamily, pRegFami->RelayMethod);
  81. if (pRegFami->nFamily == 1)
  82. g_pPlayerTrack->ClearOnSvr(pConn->GetID());
  83. }
  85. return TRUE;
  86. }
  88. BOOL CDealPackage::Proc_c2sEnterGame(const CNetConnect* pConn, const void* pData, unsigned len)
  89. {
  90. if (pData == NULL || len < sizeof(tagEnterGame2))
  91. return FALSE;
  93. tagEnterGame2* pEnterGame2 = (tagEnterGame2*)pData;
  94. assert(pEnterGame2->cProtocol == c2s_entergame);
  96. if (!g_pConnTrack->IsConnOnMethod(pConn->GetID(), 1)) //forbid
  97. return FALSE;
  99. g_pPlayerTrack->Login(pEnterGame2->szAccount, pEnterGame2->szRoleName, pEnterGame2->dwNameID, pConn->GetID(), pEnterGame2->nPlayerIdx);
  101. return TRUE;
  102. }
  104. BOOL CDealPackage::Proc_c2sLeaveGame(const CNetConnect* pConn, const void* pData, unsigned len)
  105. {
  106. if (pData == NULL || len < sizeof(tagLeaveGame))
  107. return FALSE;
  109. tagLeaveGame* pLeaveGame = (tagLeaveGame*)pData;
  110. assert(pLeaveGame->cProtocol == c2s_leavegame);
  112. g_pPlayerTrack->Logout(pLeaveGame->szAccountName);
  114. return TRUE;
  115. }
  117. BOOL CDealPackage::Proc_c2sRelay(const CNetConnect* pConn, const void* pData, unsigned len)
  118. {
  119. if (pData == NULL || len < sizeof(RELAY_COMMAND))
  120. return FALSE;
  122. RELAY_COMMAND* pRelayCmd = (RELAY_COMMAND*)pData;
  123. assert(pRelayCmd->ProtocolType == c2s_relay);
  125. RELAY_COMMAND* pRelayCmdDup = (RELAY_COMMAND*)g_pMemory->Alloc(len);
  126. assert(pRelayCmdDup != NULL);
  127. memcpy(pRelayCmdDup, pData, len);
  128. pRelayCmdDup->ProtocolType = s2c_relay;
  129. pRelayCmdDup->nIP = pConn->GetIP();
  130. pRelayCmdDup->port = pConn->GetPort();
  132. in_addr ia;
  133. ia.s_addr = pConn->GetIP();
  134. gTrace("%s -- recv size: %d", inet_ntoa(ia), len);
  136. if (g_pNetRelay->RelayPackage(pConn->GetID(), pRelayCmd->nIP, pRelayCmd->port, pRelayCmdDup, len))
  137. return TRUE;
  139. g_pMemory->Free(pRelayCmdDup);
  140. return FALSE;
  141. }