Category

Development Platform
Home > SourceCode/Document > Game Program > Game Server Simulator > View Code
EventSelect.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++

EventSelect.cpp：Code Content
  1. #include "EventSelect.h"
  3. /*
  4.  * namespace OnlineGameLib::Win32
  5.  */
  7. namespace OnlineGameLib {
  8. namespace Win32 {
  10. CEventSelect::CEventSelect()
  11. : m_event(WSA_INVALID_EVENT)
  12. {
  13. memset( &m_networkEvents, 0, sizeof( WSANETWORKEVENTS ) );
  14. }
  16. CEventSelect::~CEventSelect()
  17. {
  18. if ( WSA_INVALID_EVENT != m_event )
  19. {
  20. ::WSACloseEvent( m_event );
  21. m_event = WSA_INVALID_EVENT;
  22. }
  23. }
  25. void CEventSelect::AssociateEvent( SOCKET s, long lNetworkEvents )
  26. {
  27. if ( WSA_INVALID_EVENT == ( m_event = ::WSACreateEvent() ) )
  28. {
  29. throw CWin32Exception( _T("CEventSelect::AssociateEvent() - WSACreateEvent"), ::WSAGetLastError() );
  30. }
  32. if ( SOCKET_ERROR == ::WSAEventSelect( s, m_event, lNetworkEvents ) )
  33. {
  34. throw CWin32Exception( _T("CEventSelect::AssociateEvent() - WSAEventSelect"), ::WSAGetLastError() );
  35. }
  36. }
  38. bool CEventSelect::WaitForEnumEvent( SOCKET s, DWORD dwTimeout )
  39. {
  40. /*
  41.  * Clear the older network events and wait to update
  42.  */
  43. memset( &m_networkEvents, 0, sizeof( WSANETWORKEVENTS ) );
  45. DWORD dwRet = ::WSAWaitForMultipleEvents(
  46. 1,
  47. &m_event,
  48. FALSE,
  49. dwTimeout,
  50. FALSE );
  52. if ( WSA_WAIT_TIMEOUT == dwRet || WSA_WAIT_FAILED == dwRet )
  53. {
  54. return false;
  55. }
  57. ::WSAEnumNetworkEvents(
  58. s,
  59. m_event,
  60. &m_networkEvents );
  62. return true;
  63. }
  65. bool CEventSelect::IsRead()
  66. {
  67. if ( m_networkEvents.lNetworkEvents & FD_READ )
  68. {
  69. if ( m_networkEvents.iErrorCode[FD_READ_BIT] != 0 )
  70. {
  71. throw CWin32Exception( _T("CEventSelect : FD_READ failed with error "), 
  72. m_networkEvents.iErrorCode[FD_READ_BIT] );
  73. }
  75. return true;
  76. }
  78. return false;
  79. }
  81. bool CEventSelect::IsWrite()
  82. {
  83. if ( m_networkEvents.lNetworkEvents & FD_WRITE )
  84. {
  85. if ( m_networkEvents.iErrorCode[FD_WRITE_BIT] != 0 )
  86. {
  87. throw CWin32Exception( _T("CEventSelect : FD_WRITE failed with error "), 
  88. m_networkEvents.iErrorCode[FD_WRITE_BIT] );
  89. }
  91. return true;
  92. }
  94. return false;
  95. }
  97. bool CEventSelect::IsConnect()
  98. {
  99. if ( m_networkEvents.lNetworkEvents & FD_CONNECT )
  100. {
  101. if ( m_networkEvents.iErrorCode[FD_CONNECT_BIT] != 0 )
  102. {
  103. throw CWin32Exception( _T("CEventSelect : FD_CONNECT failed with error "), 
  104. m_networkEvents.iErrorCode[FD_CONNECT_BIT] );
  105. }
  107. return true;
  108. }
  110. return false;
  111. }
  113. bool CEventSelect::IsClose()
  114. {
  115. if ( m_networkEvents.lNetworkEvents & FD_CLOSE )
  116. {
  117. if ( m_networkEvents.iErrorCode[FD_CLOSE_BIT] != 0 )
  118. {
  119. throw CWin32Exception( _T("CEventSelect : FD_CLOSE failed with error "), 
  120. m_networkEvents.iErrorCode[FD_CLOSE_BIT] );
  121. }
  123. return true;
  124. }
  126. return false;
  127. }
  129. } // End of namespace OnlineGameLib
  130. } // End of namespace Win32