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

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

模拟服务器

开发平台：

C/C++

SwordOnLineServer.cpp：源码内容
  1. #define _WIN32_WINNT 0x0400
  2. #include <objbase.h>
  3. #include <initguid.h>
  4. #include "KEngine.h"
  5. #include "KCore.h"
  6. #include "KSafeList.h"
  7. #include "SwordOnLineServer.h"
  8. #include "../Core/src/CoreServerShell.h"
  9. #include <crtdbg.h>
  11. #define GAME_FPS 20
  13. typedef HRESULT ( __stdcall * pfnCreateServerInterface )(
  14. REFIID riid,
  15. void **ppv
  16. );
  19. static const int g_snMaxPlayerCount = 500;
  20. static const int g_snPrecision = 10;
  21. static const int g_snMaxBuffer = 500;
  22. static const int g_snBufferSize = 16384;
  24. KPakList g_PakList;
  25. KSafeList g_PlayerRemoveList;
  27. void __stdcall ServerCallBack(LPVOID lpParam, const unsigned long &ulnID, const unsigned long &uEventType);
  29. enum PLAYER_GAME_STATUS
  30. {
  31. PLAYER_BEGIN = 0,
  32. PLAYER_LISTLOADING,
  33. PLAYER_DBLOADING,
  34. PLAYER_NEWLOADING,
  35. PLAYER_SYNC_REPLY,
  36. PLAYER_PLAYING,
  37. };
  39. KSwordOnLineSever::KSwordOnLineSever()
  40. {
  41. m_bRuning = false;
  42. m_szInformation[0] = 0;
  43. m_szStatusString[0] = 0;
  44. m_pCoreServerShell = NULL;
  45. m_pServer = NULL;
  46. m_nUpdateInterval = DEFUALT_UPDATE_INTERFAL;
  47. m_nLoopElapse = 0;
  48. m_pnPlayerIndex = NULL;
  49. m_pPlayerData = NULL;
  50. m_pPlayerGameStatus = NULL;
  51. m_pNetConnectStatus = NULL;
  52. m_pnPlayerAccountKey = NULL;
  53. m_nMaxPlayer = 0;
  54. m_hModule = 0;
  55. }
  57. KSwordOnLineSever::~KSwordOnLineSever()
  58. {
  59. ShutDown();
  60. }
  62. bool KSwordOnLineSever::Init()
  63. {
  64. m_hModule = ::LoadLibrary( "heaven.dll" );
  66. if ( m_hModule )
  67. {
  68. pfnCreateServerInterface pFactroyFun = ( pfnCreateServerInterface )GetProcAddress( m_hModule, "CreateInterface" );
  70. IServerFactory *pServerFactory = NULL;
  72. if ( SUCCEEDED( pFactroyFun( IID_IServerFactory, reinterpret_cast< void ** >( &pServerFactory ) ) ) )
  73. {
  74. pServerFactory->SetEnvironment( g_snMaxPlayerCount, g_snPrecision, g_snMaxBuffer, g_snBufferSize  );
  76. pServerFactory->CreateServerInterface( IID_IIOCPServer, reinterpret_cast< void ** >( &m_pServer ) );
  78. pServerFactory->Release();
  79. }
  80. }
  82. if (!m_pServer)
  83. return false;
  85. if (FAILED(m_pServer->Startup()))
  86. return false;
  88. m_pServer->RegisterMsgFilter( reinterpret_cast< void * >( m_pServer ), ServerCallBack );
  90. m_nMaxPlayer = g_snMaxPlayerCount + g_snPrecision;
  91. if (m_nMaxPlayer <= 0)
  92. m_nMaxPlayer = 1;
  94. if (!m_pnPlayerIndex)
  95. {
  96. m_pnPlayerIndex = (int *)new int[m_nMaxPlayer];
  97. }
  98. ZeroMemory(m_pnPlayerIndex, sizeof(int) * m_nMaxPlayer);
  100. if (!m_pPlayerData)
  101. {
  102. m_pPlayerData = (LoginData *)new LoginData[m_nMaxPlayer];
  103. }
  104. ZeroMemory(m_pPlayerData, sizeof(LoginData) * m_nMaxPlayer);
  106. if (!m_pPlayerGameStatus)
  107. {
  108. m_pPlayerGameStatus = (GameStatus *)new GameStatus[m_nMaxPlayer];
  109. }
  111. if (!m_pNetConnectStatus)
  112. {
  113. m_pNetConnectStatus = (ConnectStatus *)new ConnectStatus[m_nMaxPlayer];
  114. }
  116. if (!m_pnPlayerAccountKey)
  117. {
  118. m_pnPlayerAccountKey = (DWORD *)new int[m_nMaxPlayer];
  119. }
  120. ZeroMemory(m_pnPlayerAccountKey, sizeof(DWORD) * m_nMaxPlayer);
  122. return true;
  123. }
  125. void KSwordOnLineSever::GetStatus(char* pszStatusString, char* pszInformation)
  126. {
  127. _ASSERT(pszStatusString);
  128. _ASSERT(pszInformation);
  129. strcpy(pszInformation, m_szInformation);
  130. strcpy(pszStatusString, m_szStatusString);
  131. }
  133. int KSwordOnLineSever::GetClientConnectInfo(ClientConnectInfo* pInfo, int& nPos)
  134. {
  135. const char* pChar;
  136. if (pInfo && nPos >= 0 && nPos < m_nMaxPlayer)
  137. {
  138. pInfo->AddrInfo[0] = 0;
  139. pInfo->Character[0] = 0;
  140. while(nPos < m_nMaxPlayer)
  141. {
  142. pChar = (const char *)m_pServer->GetClientInfo(nPos);
  144. if (pChar)
  145. {
  146. strcpy(pInfo->AddrInfo, pChar);
  147. if (m_pCoreServerShell)
  148. m_pCoreServerShell->GetGameData(SGDI_CHARACTER_NAME,
  149. (unsigned int)pInfo->Character, nPos);
  150. nPos++;
  151. return 1;
  152. }
  153. nPos ++;
  154. }
  155. } // need modify later
  156. return 0;
  157. }
  160. bool KSwordOnLineSever::Launch()
  161. {
  162. if (m_bRuning)
  163. {
  164. strcpy(m_szStatusString, "Already launched.");
  165. return true;
  166. }
  168. if (!m_pServer)
  169. {
  170. strcpy(m_szStatusString, "Not init server.");
  171. return false;
  172. }
  174. m_szInformation[0] = 0;
  175. strcpy(m_szStatusString, "Launching...");
  176. #ifdef _DEBUG
  177. g_FindDebugWindow("#32770", "DebugWin");
  178. #endif
  180. g_SetRootPath(NULL);
  182. g_PakList.Open("config.ini");
  184. if (FAILED(m_pServer->OpenService(INADDR_ANY, 6666)))
  185. {
  186. strcpy(m_szInformation, "Failed to Create NetServer.");
  187. strcpy(m_szStatusString, "Launch FAILED!");
  188. return false;
  189. }
  191. if (m_pCoreServerShell == NULL)
  192. m_pCoreServerShell = ::CoreGetServerShell();
  193. if (m_pCoreServerShell == NULL)
  194. {
  195. strcpy(m_szInformation, "Failed to Create CoreShell.");
  196. strcpy(m_szStatusString, "Launch FAILED!");
  197. return false;
  198. }
  200. IServer *pClonServer = NULL;
  201. m_pServer->QueryInterface( IID_IIOCPServer, reinterpret_cast< void ** >( &pClonServer ) );
  202. m_pCoreServerShell->OperationRequest(SSOI_LAUNCH, (unsigned int)pClonServer, 0);
  204. m_Timer.Start();
  205. m_GameLoop = 0;
  206. m_bRuning = true;
  207. m_szInformation[0] = 0;
  208. strcpy(m_szStatusString, "Launch SUCCESSED!");
  209. return true;
  210. }
  212. bool KSwordOnLineSever::ShutDown()
  213. {
  214. strcpy(m_szInformation, "Restart, if U wish to launch again.");
  215. strcpy(m_szStatusString, "Server has been shutdown.");
  216. if (m_pCoreServerShell)
  217. {
  218. m_pCoreServerShell->Release();
  219. m_pCoreServerShell = NULL;
  220. }
  222. if (m_pnPlayerIndex)
  223. {
  224. delete [] m_pnPlayerIndex;
  225. m_pnPlayerIndex = NULL;
  226. }
  228. if (m_pPlayerData)
  229. {
  230. delete [] m_pPlayerData;
  231. m_pPlayerData = NULL;
  232. }
  234. if (m_pPlayerGameStatus)
  235. {
  236. delete [] m_pPlayerGameStatus;
  237. m_pPlayerGameStatus = NULL;
  238. }
  240. if (m_pNetConnectStatus)
  241. {
  242. delete [] m_pNetConnectStatus;
  243. m_pNetConnectStatus = NULL;
  244. }
  246. if (m_pnPlayerAccountKey)
  247. {
  248. delete [] m_pnPlayerAccountKey;
  249. m_pnPlayerAccountKey = NULL;
  250. }
  252. if (m_pServer)
  253. {
  254. m_pServer->CloseService();
  255. m_pServer->Cleanup();
  256. m_pServer->Release();
  257. m_pServer = NULL;
  258. }
  259. if (m_hModule)
  260. {
  261. ::FreeLibrary( m_hModule );
  262. m_hModule = NULL;
  263. }
  264. m_bRuning = false;
  265. return true;
  266. }
  268. //返回值表示状态是否更新
  269. bool KSwordOnLineSever::Breathe()
  270. {
  271. static KTimer s_Timer;
  272. DWORD t1;
  274. if (m_bRuning && m_pCoreServerShell)
  275. {
  276. s_Timer.Start();
  277. MessageLoop(); //处理网络消息
  278. t1 = s_Timer.GetElapse();
  279. g_DebugLog("[FPS]Message:%dms", t1);
  281. if (m_GameLoop * 1000 <= m_Timer.GetElapse() * GAME_FPS)
  282. {
  283. s_Timer.Start();
  284. MainLoop();
  285. t1 = s_Timer.GetElapse();
  286. g_DebugLog("[FPS]MainLoop:%dms", t1);
  287. }
  288. else
  289. {
  290. //SwitchToThread();
  291. Sleep(1);
  292. }
  294. #define STRING_MIN_LEN 9
  295. #define STRING_MAX_LEN 15
  296. char szStatusString[20] = "@ Runing.........";
  297. static int  s_nStatusLen = STRING_MIN_LEN;
  298. if ((++m_nLoopElapse) >= m_nUpdateInterval)
  299. {
  300. /* m_nLoopElapse = 0;
  301. if (szStatusString[0] == '@')
  302. {
  303. memcpy(m_szStatusString, szStatusString, s_nStatusLen);
  304. m_szStatusString[s_nStatusLen] = 0;
  305. if ((++s_nStatusLen) > STRING_MAX_LEN)
  306. s_nStatusLen = STRING_MIN_LEN;
  307. }
  308. */
  309. int nTime = m_pCoreServerShell->GetLoopRate();
  310. int nHour, nMinute, nSecond, nMinSecond;
  311. #define defHOUR_TIME (3600 * 20)
  312. #define defMINUTE_TIME (60 * 20)
  313. #define defSECOND_TIME 20
  314. #define defMINSECOND_TIME 2
  315. nHour = nTime / defHOUR_TIME;
  316. nTime -= nHour * defHOUR_TIME;
  317. nMinute = nTime / defMINUTE_TIME;
  318. nTime -= nMinute * defMINUTE_TIME;
  319. nSecond = nTime / defSECOND_TIME;
  320. nTime -= nSecond * defSECOND_TIME;
  321. nMinSecond = nTime / defMINSECOND_TIME;
  322. sprintf(m_szStatusString, "Time:(%3d:%3d:%3d.%d)", nHour, nMinute, nSecond, nMinSecond);
  323. int nClientCount = -1;
  324. KCoreConnectInfo Info;
  325. nClientCount = m_pServer->GetClientCount();
  326. m_pCoreServerShell->GetConnectInfo(&Info);
  328. sprintf(m_szInformation, "ClientNum:%d PlayerNum:%d", nClientCount, Info.nNumPlayer);
  330. return true;
  331. }
  332. }
  333. return false;
  334. }
  336. void KSwordOnLineSever::SetUpdateInterval(int nInterval)
  337. {
  338. m_nUpdateInterval = nInterval;
  339. }
  341. void KSwordOnLineSever::MessageLoop()
  342. {
  343. DWORD dwNetTime = 0;
  344. DWORD dwProcTime = 0;
  345. const char* pChar = NULL;
  346. unsigned int nSize = 0;
  347. KTimer sTimer;
  349. _ASSERT(m_pCoreServerShell);
  351. g_PlayerRemoveList.Lock();
  352. KIndexNode* pNode = (KIndexNode *)g_PlayerRemoveList.GetHead();
  353. while (pNode)
  354. {
  355. KIndexNode* pTempNode = (KIndexNode *)pNode->GetNext();
  356. m_pCoreServerShell->ClientDisconnect(pNode->m_nIndex);
  358. pNode->Remove();
  359. if (pNode)
  360. {
  361. delete pNode;
  362. pNode = NULL;
  363. }
  364. pNode = pTempNode;
  365. }
  366. g_PlayerRemoveList.Unlock();
  368. for (int i = 0; i < m_nMaxPlayer; i++)
  369. {
  371. if (NET_UNCONNECT == GetNetStatus(i))
  372. continue;
  374. do
  375. {
  376. sTimer.Start();
  377. pChar = (const char*)m_pServer->GetPackFromClient(i, nSize);
  378. dwNetTime += sTimer.GetElapseFrequency();
  380. if (!pChar || 0 == nSize)
  381. break;
  383. sTimer.Start();
  384. if (!m_pCoreServerShell->CheckProtocolSize(pChar, nSize))
  385. break;
  386. MessageProcess(i, pChar, nSize);
  387. dwProcTime += sTimer.GetElapseFrequency();
  388. } while (1);
  389. }
  391. g_DebugLog("[FPS]Net:Proc(%d:%d)", dwNetTime, dwProcTime);
  392. }
  395. BOOL KSwordOnLineSever::ProcessLoginProtocol(int nClient, const char* pChar, int nSize)
  396. {
  397. const char* pBuffer = pChar;
  399. if (*pBuffer != c2s_login)
  400. {
  401. return FALSE;
  402. }
  403. else
  404. {
  405. strcpy(m_pPlayerData[nClient].szAccount, (const char *)pBuffer + 1);
  406. DBI_COMMAND Command = DBI_GETPLAYERLISTFROMACCOUNT;
  407. memset(m_pPlayerData[nClient].PlayerBaseInfo, 0, sizeof(S3DBI_RoleBaseInfo) * MAX_PLAYER_IN_ACCOUNT);
  408. void* pTmpPoint1 = m_pPlayerData[nClient].szAccount;
  409. void* pTmpPoint2 = &m_pPlayerData[nClient];
  411. g_AccessDBMsgList(DBMSG_PUSH, &nClient, (DBI_COMMAND*)&Command, (void **)&pTmpPoint1, (void **)&pTmpPoint2);
  412. return TRUE;
  413. }
  414. return FALSE;
  415. }
  417. void KSwordOnLineSever::SendPlayerListToClient(int nClient)
  418. {
  419. ROLE_LIST_SYNC PlayerListSync;
  420. PlayerListSync.ProtocolType = s2c_syncrolelist;
  421. for (int i = 0; i < MAX_PLAYER_IN_ACCOUNT; i++)
  422. {
  423. strcpy(PlayerListSync.m_RoleList[i].szName, m_pPlayerData[nClient].PlayerBaseInfo[i].szRoleName);
  424. PlayerListSync.m_RoleList[i].Sex = (BYTE)m_pPlayerData[nClient].PlayerBaseInfo[i].nSex;
  425. PlayerListSync.m_RoleList[i].ArmorType = (BYTE)m_pPlayerData[nClient].PlayerBaseInfo[i].nArmorType;
  426. PlayerListSync.m_RoleList[i].HelmType = (BYTE)m_pPlayerData[nClient].PlayerBaseInfo[i].nHelmType;
  427. PlayerListSync.m_RoleList[i].WeaponType = (BYTE)m_pPlayerData[nClient].PlayerBaseInfo[i].nWeaponType;
  428. PlayerListSync.m_RoleList[i].Level = (BYTE)m_pPlayerData[nClient].PlayerBaseInfo[i].nLevel;
  429. }
  430. m_pServer->PackDataToClient(nClient, &PlayerListSync, sizeof(PlayerListSync));
  432. }
  434. // return : -1 失败，协议不对  0 成功 1 协议正确，数据包错误  2 协议正确，校验错误 ……
  435. int KSwordOnLineSever::RecvClientPlayerSelect(int nClient, const char* pChar, int nSize, int *pnSel)
  436. {
  437. const char* pBuffer = pChar;
  439. if (*pBuffer != c2s_dbplayerselect)
  440. {
  441. return -1;
  442. }
  443. else
  444. {
  445. if (sizeof(DB_PLAYERSELECT_COMMAND) != nSize)
  446. return 1;
  448. DB_PLAYERSELECT_COMMAND* pCommand = (DB_PLAYERSELECT_COMMAND*)pBuffer;
  449. if (pCommand->m_nSelect >= 0 && pCommand->m_nSelect < m_pPlayerData[nClient].nRoleCount)
  450. {
  451. *pnSel = pCommand->m_nSelect;
  452. return 0;
  453. }
  454. else
  455. return 2;
  456. }
  457. }
  458. //--------------------------------------------------------------------------------
  459. // return : -1 失败，协议不对  0 成功 1 协议正确，数据包错误
  460. //          2 协议正确，校验错误1 同名  3 协议正确，校验错误2 角色数量已满 ……
  461. //--------------------------------------------------------------------------------
  462. int KSwordOnLineSever::RecvClientPlayerNew(int nClient, const char* pChar, int nSize, int *pnRole, int *pnSeries, char *lpszName)
  463. {
  464. //BYTE* pTemp = m_NetServer.Client_data_array[nClient].RecieveBuffer;
  465. const char* pBuffer = pChar;
  466. // BYTE* pBuffer = pTemp;
  467. if (*pBuffer != c2s_newplayer)
  468. {
  469. return -1;
  470. }
  471. else
  472. {
  473. NEW_PLAYER_COMMAND *pNew = (NEW_PLAYER_COMMAND*)pBuffer;
  474. if (pNew->m_btRoleNo > 1 || pNew->m_btSeries >= series_num)
  475. return 1;
  476. char szName[32];
  477. memset(szName, 0, sizeof(szName));
  478. memcpy(szName, pNew->m_szName, pNew->m_wLength - 2 - 2);
  480. // if CheckCanNew() 判断是否可以添加新角色 not end
  482. *pnRole = pNew->m_btRoleNo;
  483. *pnSeries = pNew->m_btSeries;
  484. strcpy(lpszName, szName);
  485. return 0;
  486. }
  487. }
  489. BOOL KSwordOnLineSever::ProcessSyncReplyProtocol(int nClient, const char* pChar, int nSize)
  490. {
  491. const char* pBuffer = pChar;
  492. if (*pBuffer != c2s_syncend)
  493. {
  494. return FALSE;
  495. }
  496. else
  497. {
  498. return TRUE;
  499. }
  500. return FALSE;
  501. }
  503. int KSwordOnLineSever::OperationRequest(unsigned int uOper, unsigned int uParam, int nParam)
  504. {
  505. if (m_pCoreServerShell)
  506. return m_pCoreServerShell->OperationRequest(uOper, uParam, nParam);
  507. return 0;
  508. }
  510. extern int  CORE_API g_ClearOutOfDateDBMsgInList(int nPlayerIndex);
  511. void KSwordOnLineSever::MainLoop()
  512. {
  513. DWORD dwNowTime;
  515. m_pServer->PreparePackSink();
  517. for (int i = 0; i < m_nMaxPlayer; i++)
  518. {
  519. if (NET_UNCONNECT == GetNetStatus(i))
  520. continue;
  522. m_pPlayerGameStatus[i].sMutex.Lock();
  523. switch(m_pPlayerGameStatus[i].nGameStatus)
  524. {
  525. case PLAYER_LISTLOADING:
  526. if (m_pCoreServerShell->IsCharacterListLoadFinished(i))
  527. {
  528. SendPlayerListToClient(i);
  529. m_pnPlayerIndex[i] = 0;
  530. m_pPlayerGameStatus[i].nGameStatus = PLAYER_DBLOADING;
  531. g_DebugLog("[TRACE]Send List to Client:%d", i);
  532. }
  533. break;
  534. case PLAYER_NEWLOADING:
  535. if (m_pnPlayerIndex[i] > 0)
  536. {
  537. int bSyncEnd = (m_pPlayerData[i].nStep == STEP_SYNC_END);
  538. m_pCoreServerShell->NewPlayerIniLoading(m_pnPlayerIndex[i],
  539. bSyncEnd, m_pPlayerData[i].nStep, m_pPlayerData[i].nParam);
  540. if (bSyncEnd)
  541. {
  542. m_pPlayerGameStatus[i].nGameStatus = PLAYER_SYNC_REPLY;
  543. BYTE SyncEnd;
  544. SyncEnd = s2c_syncend;
  545. m_pServer->PackDataToClient(i, &SyncEnd, sizeof(BYTE));
  546. m_pCoreServerShell->SaveNewRole(m_pnPlayerIndex[i]);
  547. g_DebugLog("[TRACE]SyncEnd:%d", i);
  548. }
  549. }
  550. break;
  551. case PLAYER_DBLOADING:
  552. /* dwNowTime = m_Timer.GetElapse();
  553. if (dwNowTime - m_pPlayerGameStatus[i].dwLastOperationTime > 600000)
  554. {
  555. m_pServer->ShutdownClient(i);
  556. break;
  557. }*/
  558. if (m_pnPlayerIndex[i] > 0)
  559. {
  560. int bSyncEnd = (m_pPlayerData[i].nStep == STEP_SYNC_END);
  561. m_pCoreServerShell->PlayerDbLoading(m_pnPlayerIndex[i],
  562. bSyncEnd, m_pPlayerData[i].nStep, m_pPlayerData[i].nParam);
  563. if (bSyncEnd)
  564. {
  565. m_pPlayerGameStatus[i].dwLastOperationTime = m_Timer.GetElapse();
  566. m_pPlayerGameStatus[i].nGameStatus = PLAYER_SYNC_REPLY;
  567. BYTE SyncEnd;
  568. SyncEnd = s2c_syncend;
  569. m_pServer->PackDataToClient(i, &SyncEnd, sizeof(BYTE));
  570. g_DebugLog("[TRACE]SyncEnd:%d", i);
  571. }
  572. }
  573. break;
  574. /* case PLAYER_SYNC_REPLY:
  575. dwNowTime = m_Timer.GetElapse();
  576. if (dwNowTime - m_pPlayerGameStatus[i].dwLastOperationTime > 600000)
  577. {
  578. m_pServer->ShutdownClient(i);
  579. break;
  580. }
  581. break;*/
  582. default:
  583. break;
  584. }
  585. m_pPlayerGameStatus[i].sMutex.Unlock();
  586. }
  588. m_pCoreServerShell->Breathe();
  590. m_pServer->SendPackToClient();
  591. m_GameLoop++;
  593. }
  595. void KSwordOnLineSever::MessageProcess(const unsigned long i, const char* pChar, size_t nSize)
  596. {
  597. _ASSERT(pChar && nSize);
  599. m_pPlayerGameStatus[i].sMutex.Lock();
  600. switch(m_pPlayerGameStatus[i].nGameStatus)
  601. {
  602. case PLAYER_PLAYING:
  603. m_pCoreServerShell->ProcessClientMessage(i, pChar, nSize);
  604. break;
  605. case PLAYER_BEGIN:
  606. if (ProcessLoginProtocol(i, pChar, nSize))
  607. {
  608. m_pPlayerGameStatus[i].nGameStatus = PLAYER_LISTLOADING;
  609. m_pPlayerGameStatus[i].dwLastOperationTime = m_Timer.GetElapse();
  610. strcpy(m_szStatusString, "A player apply login.");
  611. g_DebugLog("[Login]%s", m_szStatusString);
  612. }
  613. break;
  614. case PLAYER_DBLOADING:
  615. {
  616. int nRet, nSel;
  617. int nRole, nSeries;
  618. char szName[32];
  619. if( (nRet = RecvClientPlayerSelect(i, pChar, nSize, &nSel)) != -1 )
  620. {
  621. if (nRet == 0) // 成功
  622. {
  623. g_DebugLog("[TRACE]Recv role select:%d", nSel);
  624. m_pPlayerGameStatus[i].dwLastOperationTime = m_Timer.GetElapse();
  625. m_pnPlayerIndex[i] = m_pCoreServerShell->AddCharacter(
  626. m_pPlayerData[i].PlayerBaseInfo[nSel].szRoleName, i, m_pPlayerData[i].szAccount);
  627. strcpy(m_szStatusString, "A player Selected character.");
  628. g_DebugLog("[TRACE]%s", m_szStatusString);
  629. if (m_pnPlayerIndex[i] > 0)
  630. {
  631. int bSyncEnd = (m_pPlayerData[i].nStep == STEP_SYNC_END);
  632. m_pCoreServerShell->PlayerDbLoading(m_pnPlayerIndex[i],
  633. bSyncEnd, m_pPlayerData[i].nStep, m_pPlayerData[i].nParam);
  634. if (bSyncEnd)
  635. {
  636. m_pPlayerGameStatus[i].nGameStatus = PLAYER_SYNC_REPLY;
  637. BYTE SyncEnd;
  638. SyncEnd = s2c_syncend;
  639. m_pServer->SendData(i, &SyncEnd, sizeof(BYTE));
  640. g_DebugLog("[TRACE]SyncEnd:%d", i);
  641. }
  642. }
  643. }
  644. else // 失败
  645. {
  646. }
  647. }
  648. else if ( (nRet = RecvClientPlayerNew(i, pChar, nSize, &nRole, &nSeries, szName)) != -1 )
  649. {
  650. if (nRet == 0) // 成功
  651. {
  652. m_pPlayerGameStatus[i].dwLastOperationTime = m_Timer.GetElapse();
  653. m_pnPlayerIndex[i] = m_pCoreServerShell->CreateNewPlayer(i, nRole, nSeries, szName, m_pPlayerData[i].szAccount);
  654. strcpy(m_szStatusString, "Create a new role.");
  655. if (m_pnPlayerIndex[i] > 0)
  656. {
  657. m_pPlayerData[i].nStep = 0;
  658. m_pPlayerData[i].nParam = 0;
  659. m_pPlayerGameStatus[i].nGameStatus = PLAYER_NEWLOADING;
  660. m_pCoreServerShell->NewPlayerIniLoading(m_pnPlayerIndex[i],
  661. FALSE, m_pPlayerData[i].nStep, m_pPlayerData[i].nParam);
  662. }
  663. }
  664. else if (nRet == 1) // 数据包错
  665. {
  666. }
  667. else if (nRet == 2) // 同名 错
  668. {
  669. }
  670. else if (nRet == 3) // 角色数量已满 错
  671. {
  672. }
  673. }
  674. }
  675. break;
  676. case PLAYER_SYNC_REPLY:
  677. if (ProcessSyncReplyProtocol(i, pChar, nSize))
  678. {
  679. m_pCoreServerShell->PlayerSyncReplay(m_pnPlayerIndex[i]);
  680. m_pPlayerGameStatus[i].nGameStatus = PLAYER_PLAYING;
  681. g_DebugLog("[TRACE]Socket %d playing", i);
  682. }
  683. break;
  684. default:
  685. break;
  686. }
  687. m_pPlayerGameStatus[i].sMutex.Unlock();
  688. }
  690. void KSwordOnLineSever::SetNetStatus(const unsigned long lnID, NetStatus nStatus)
  691. {
  692. if (lnID >= m_nMaxPlayer)
  693. return;
  695. // m_pNetConnectStatus[lnID].sMutex.Lock();
  697. if (nStatus == NET_UNCONNECT)
  698. {
  699. g_ClearOutOfDateDBMsgInList(lnID);
  700. // int nIndex = m_pCoreServerShell->GetPlayerIndex(lnID);
  701. KIndexNode* pNode = new KIndexNode;
  702. pNode->m_nIndex = lnID;
  703. g_PlayerRemoveList.Lock();
  704. g_PlayerRemoveList.AddTail(pNode);
  705. g_PlayerRemoveList.Unlock();
  706. }
  708. if (nStatus == NET_CONNECTED)
  709. {
  710. m_pPlayerGameStatus[lnID].sMutex.Lock();
  711. m_pPlayerGameStatus[lnID].nGameStatus = PLAYER_BEGIN;
  712. m_pnPlayerIndex[lnID] = 0;
  713. m_pPlayerGameStatus[lnID].sMutex.Unlock();
  714. }
  716. ::InterlockedExchange( &( m_pNetConnectStatus[lnID].nNetStatus ), nStatus );
  717. // m_pNetConnectStatus[lnID].nNetStatus = nStatus;
  719. // m_pNetConnectStatus[lnID].sMutex.Unlock();
  720. }
  722. int KSwordOnLineSever::GetNetStatus(const unsigned long lnID)
  723. {
  724. if (lnID >= m_nMaxPlayer)
  725. return NET_UNCONNECT;
  727. int nStatus;
  728. // m_pNetConnectStatus[lnID].sMutex.Lock();
  729. nStatus = ::InterlockedExchange( &( m_pNetConnectStatus[lnID].nNetStatus ), 
  730. m_pNetConnectStatus[lnID].nNetStatus );
  731. //nStatus = m_pNetConnectStatus[lnID].nNetStatus;
  732. // m_pNetConnectStatus[lnID].sMutex.Unlock();
  733. return nStatus;
  734. }