Category

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

Game Server Simulator

Development Platform:

C/C++

NetConnect.cpp：Code Content
  1. // NetConnect.cpp: implementation of the CNetConnect class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "Global.h"
  7. #include "NetConnect.h"
  8. #include "NetServer.h"
  10. #include "S3Relay.h"
  12. #include "../../Multiserver/Heaven/Interface/IServer.h"
  13. #include "../../../headers/KProtocolDef.h"
  14. #include "../../../headers/KProtocol.h"
  17. //////////////////////////////////////////////////////////////////////
  18. // Construction/Destruction
  19. //////////////////////////////////////////////////////////////////////
  21. CNetConnectDup::CNetConnectDup(const CNetConnect& netconnect)
  22.  : m_pServer(NULL), m_IP(netconnect.GetIP()), m_id(netconnect.GetID())
  23. {
  24. CNetServer* pNetServer = netconnect.GetServer();
  25. if (pNetServer)
  26. {
  27. m_pServer = pNetServer->GetServer();
  28. _SafeAddRef(m_pServer);
  29. }
  30. }
  32. BOOL CNetConnectDup::SendPackage(const void* pData, size_t size) const
  33. {
  34. dTRACKSENDDATA(pData, size);
  36. if(!m_pServer)
  37. return FALSE;
  38. m_pServer->SendData(m_id, pData, size);
  39. return TRUE;
  40. }
  42. CNetConnectDup& CNetConnectDup::operator =(const CNetConnect& src)
  43. {
  44. _SafeRelease(m_pServer);
  45. CNetServer* pNetServer = src.GetServer();
  46. if (pNetServer)
  47. {
  48. m_pServer = pNetServer->GetServer();
  49. _SafeAddRef(m_pServer);
  50. }
  51. m_IP = src.GetIP();
  52. m_id = src.GetID();
  53. return *this;
  54. }
  57. CNetConnect::CNetConnect(CNetServer* pNetServer, unsigned long id)
  58. : m_pNetServer(pNetServer), m_id(id), m_IP(0), m_port(0), m_disconnect(0L)
  59. {
  60. assert(m_pNetServer);
  62. const char* pInfo = m_pNetServer->GetServer()->GetClientInfo(id);
  63. if (pInfo)
  64. {
  65. m_IP = _a2ip(pInfo);
  67. const char* pColon = strchr(pInfo, ':');
  68. if (pColon)
  69. m_port = atoi(pColon + 1);
  70. }
  71. }
  73. CNetConnect::~CNetConnect()
  74. {
  75. }
  78. void CNetConnect::_NotifyClientConnectCreate()
  79. {
  80. OnClientConnectCreate();
  81. }
  83. void CNetConnect::_NotifyClientConnectClose()
  84. {
  85. if (m_disconnect)
  86. return;
  87. ++ m_disconnect;
  89. OnClientConnectClose();
  90. }
  92. HRESULT CNetConnect::OnMessage( VOID* pData, size_t size )
  93. {
  94. dTRACKRECVDATA(pData, size);
  95. RecvPackage(pData, size);
  97. return S_OK;
  98. }
  100. DWORD CNetConnect::Main(LPVOID lpParam)
  101. {
  102. #ifndef _WORKMODE_SINGLETHREAD
  103. EnterLoop();
  104. #endif
  106. while (!IsAskingStop())
  107. {
  108. #ifdef _WORKMODE_MULTITHREAD2
  109. BeginRoute();
  110. EndRoute();
  111. Sleep(2000);
  112. continue;
  113. #else
  114. DoRoute();
  115. Sleep(breathe_interval);
  116. #endif
  117. }
  119. #ifndef _WORKMODE_SINGLETHREAD
  120. LeaveLoop();
  121. #endif
  123. return 0;
  124. }
  127. BOOL CNetConnect::SendPackage(const void* pData, size_t size)
  128. {
  129. IServer* pServer = m_pNetServer->GetServer();
  130. if (pServer == NULL)
  131. return FALSE;
  133. dTRACKSENDDATA(pData, size);
  134. pServer->SendData(m_id, pData, size);
  135. return TRUE;
  136. }
  138. BOOL CNetConnect::IsReady() const
  139. {
  140. return m_pNetServer->GetServer() != NULL;
  141. }
  143. BOOL CNetConnect::DoRoute()
  144. {
  145. IServer* pServer = m_pNetServer->GetServer();
  146. if (pServer == NULL)
  147. return FALSE;
  149. BeginRoute();
  151. for ( ; ; )
  152. {
  153. size_t size = 0;
  154. const void* pData = pServer->GetPackFromClient(m_id, size);
  155. if (!pData || size <= 0)
  156. break;
  158. dTRACKRECVDATA(pData, size);
  159. RecvPackage(pData, size);
  160. }
  162. EndRoute();
  164. return TRUE;
  165. }
  167. BOOL CNetConnect::Route()
  168. {
  169. return DoRoute();
  170. }