开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
SockThread.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：3k
源码类别：

模拟服务器

开发平台：

C/C++

SockThread.cpp：源码内容
  1. // SockThread.cpp: implementation of the CSockThread class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "SockThread.h"
  7. #include "S3Relay.h"
  8. #include "Global.h"
  11. //////////////////////////////////////////////////////////////////////
  12. // Construction/Destruction
  13. //////////////////////////////////////////////////////////////////////
  15. CSockThread::CSockThread()
  16. : m_step(step_NONE), m_cntLoop(0), m_tickLoop(0)
  17. {
  19. }
  21. CSockThread::~CSockThread()
  22. {
  24. }
  27. DWORD CSockThread::Main(LPVOID lpParam)
  28. {
  29. try
  30. {
  31. DEBUGDO( m_step = step_NONE );
  32. DEBUGDO( m_tickLoop = 0 );
  33. DEBUGDO( m_cntLoop = 0 );
  36. DEBUGDO( m_step = step_EnterLoop);
  37. EnterLoop();
  39. while (!IsAskingStop())
  40. {
  41. DEBUGDO( m_tickLoop = ::GetTickCount() );
  42. DEBUGDO( ++ m_cntLoop );
  45. DEBUGDO( m_step = step_PrepareSock);
  46. PrepareSock();
  49. DEBUGDO( m_step = step_RelayCenter);
  50. g_RelayCenter.Route();
  51. DEBUGDO( m_step = step_RelayServer);
  52. g_RelayServer.Route();
  54. DEBUGDO( m_step = step_RootCenter);
  55. g_RootCenter.Route();
  57. DEBUGDO( m_step = step_GatewayCenter);
  58. g_GatewayCenter.Route();
  60. DEBUGDO( m_step = step_HostServer);
  61. g_HostServer.Route();
  62. DEBUGDO( m_step = step_TongServer);
  63. g_TongServer.Route();
  64. DEBUGDO( m_step = step_ChatServer);
  65. g_ChatServer.Route();
  68. DEBUGDO( m_step = step_UnprepareSock);
  69. UnprepareSock();
  72. DEBUGDO( m_step = step_Sleep);
  73. ::Sleep(breathe_interval);
  74. }
  76. DEBUGDO( m_step = step_LeaveLoop);
  77. LeaveLoop();
  78. }
  79. catch (...)
  80. {
  81. rTRACE("fatal: sock thread except");
  82. }
  84. return 0;
  85. }
  88. HANDLE CSockThread::Start()
  89. {
  90. if (m_hProcessor != NULL)
  91. return m_hProcessor;
  93. m_step = step_NONE;
  94. m_cntLoop = 0;
  95. m_tickLoop = 0;
  97. HANDLE reth = KThread::Start();
  98. if (!reth)
  99. {
  100. rTRACE("FAIL: SockThread start");
  101. return NULL;
  102. }
  104. rTRACE("SockThread start success");
  106. return reth;
  107. }
  109. BOOL CSockThread::Stop()
  110. {
  111. if (!m_hProcessor)
  112. return TRUE;
  114. if (!KThread::Stop())
  115. {
  116. rTRACE("FAIL: SockThread stop");
  117. return FALSE;
  118. }
  120. m_step = step_NONE;
  121. m_cntLoop = 0;
  122. m_tickLoop = 0;
  124. rTRACE("SockThread stop success");
  126. return TRUE;
  127. }
  130. BOOL CSockThread::TraceInfo()
  131. {
  132. static const char* stepdesc[] = {
  133. "NONE",
  134. "EnterLoop",
  135. "PrepareSock",
  136. "RelayCenter", 
  137. "RelayServer",
  138. "RootCenter",
  139. "GatewayCenter",
  140. "HostServer",
  141. "TongServer",
  142. "ChatServer",
  143. "UnprepareSock",
  144. "LeaveLoop",
  145. "Sleep",
  146. };
  148. rTRACE("message: [SockThread] tickLoop: %d, cntLoop: %d, step: %s", m_tickLoop, m_cntLoop, stepdesc[m_step]);
  150. return TRUE;
  151. }