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

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

模拟服务器

开发平台：

C/C++

S3PRelockAccount.cpp：源码内容
  1. //-----------------------------------------//
  2. //                                         //
  3. //  File : S3PRelockAccount.h    //
  4. // Author : Yang Xiaodong            //
  5. // Modified : 8/28/2002                //
  6. //                                         //
  7. //-----------------------------------------//
  8. #include "S3PDBConnection.h"
  9. #include "S3PRow.h"
  10. #include "S3PAccountInfoDAO.h"
  11. #include "S3PDBConnector.h"
  13. #include "S3PRelockAccount.h"
  15. S3PRelockAccount* S3PRelockAccount::m_pInstance = NULL;
  16. HANDLE S3PRelockAccount::m_hEnable = NULL;
  17. DWORD S3PRelockAccount::m_dwCycle = 60000; // One minute
  19. S3PRelockAccount::S3PRelockAccount()
  20. {
  21. Init();
  22. }
  24. S3PRelockAccount::~S3PRelockAccount()
  25. {
  27. }
  29. S3PRelockAccount* S3PRelockAccount::Instance()
  30. {
  31. if ( NULL == m_pInstance )
  32. {
  33. m_pInstance = new S3PRelockAccount;
  34. }
  35. return m_pInstance;
  36. }
  38. void S3PRelockAccount::ReleaseInstance()
  39. {
  40. if ( NULL != m_pInstance )
  41. {
  42. delete m_pInstance;
  43. m_pInstance = NULL;
  44. }
  45. }
  47. static DWORD WINAPI Relock( LPVOID lpParam )
  48. {
  49. DWORD dwRet = 0;
  50. if ( NULL == lpParam )
  51. {
  52. return dwRet;
  53. }
  55. _LPRELOCKERPARAM lpRelocker = ( _LPRELOCKERPARAM )lpParam;
  56. if ( NULL == lpRelocker->hEnable )
  57. {
  58. return dwRet;
  59. }
  61. S3PDBConnection* pAccountCon =
  62. S3PDBConnector::Instance()->ApplyDBConnection( def_ACCOUNTDB );
  64. if ( NULL != pAccountCon )
  65. {
  66. while ( TRUE )
  67. {
  68. DWORD dwResult =
  69. KPIWaitForSingleObject( lpRelocker->hEnable, lpRelocker->dwCycle );
  70. if ( 1 == dwResult ) // The thread is commanded to exit.
  71. {
  72. break;
  73. }
  74. else if ( 2 == dwResult ) // Time out
  75. {
  76. // Relocks specified data section
  77. //------>BEGIN
  78. pAccountCon->Do( "update account_info set iGameId = 0 where iGameId <> 0 and iTimeCount = 0" );
  79. pAccountCon->Do( "update account_info set iTimeCount = 0 where iGameId <> 0 and iTimeCount <> 0" );
  80. //<------END
  81. }
  82. }
  83. pAccountCon->Close();
  84. }
  85. return dwRet;
  86. }
  88. HANDLE S3PRelockAccount::Start()
  89. {
  90. HANDLE hRet = NULL;
  91. if ( NULL != m_hRelocker ) // The thread has been running.
  92. {
  93. return hRet;
  94. }
  96. if ( NULL == m_hEnable )
  97. {
  98. m_hEnable = KPICreateEvent( NULL, TRUE, TRUE, def_RELOCKEVENTNAME );
  99. }
  100. if ( NULL != m_hEnable )
  101. {
  102. KPIResetEvent( m_hEnable );
  103. }
  105. m_param.dwCycle = m_dwCycle;
  106. m_param.hEnable = m_hEnable;
  107. m_hRelocker = KPICreateThread( Relock, &m_param, &m_dwRelockerID );
  108. hRet = m_hRelocker;
  110. return hRet;
  111. }
  113. BOOL S3PRelockAccount::Stop()
  114. {
  115. BOOL bRet = FALSE;
  117. if ( NULL == m_hRelocker )
  118. {
  119. return bRet;
  120. }
  122. KPISetEvent( m_hEnable );
  124. DWORD dwResult = KPIWaitForSingleObject( m_hRelocker, 3000 );
  125. if ( 0 == dwResult )
  126. {
  127. bRet = FALSE;
  128. }
  129. else if ( 1 == dwResult ) // The thread has ended.
  130. {
  131. m_hRelocker = NULL;
  132. bRet = TRUE;
  133. }
  134. else if ( 2 == dwResult ) // Time out.
  135. {
  136. if ( TRUE == KPITerminateThread( m_hRelocker, 0 ) )
  137. {
  138. m_hRelocker = NULL;
  139. bRet = TRUE;
  140. }
  141. else
  142. {
  143. bRet = FALSE;
  144. }
  145. }
  147. return bRet;
  148. }
  150. void S3PRelockAccount::Init()
  151. {
  152. m_hRelocker = NULL;
  153. m_param.dwCycle = m_dwCycle;
  154. m_param.hEnable = NULL;
  155. }