Category

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

Game Server Simulator

Development Platform:

C/C++

IOCompletionPort.cpp：Code Content
  1. #include "stdafx.h"
  2. #include "IOCompletionPort.h"
  3. #include "Win32Exception.h"
  4. #include "Macro.h"
  6. /*
  7.  * namespace OnlineGameLib::Win32
  8.  */
  10. namespace OnlineGameLib {
  11. namespace Win32 {
  13. CIOCompletionPort::CIOCompletionPort( size_t maxConcurrency )
  14. : m_iocp( ::CreateIoCompletionPort( INVALID_HANDLE_VALUE, NULL, 0, maxConcurrency ) )
  15. {
  16. if ( m_iocp == 0 )
  17. {
  18. throw CWin32Exception( _T("CIOCompletionPort::CIOCompletionPort() - CreateIoCompletionPort"), ::GetLastError() );
  19. }
  20. }
  22. CIOCompletionPort::~CIOCompletionPort() 
  23. {
  24. SAFE_CLOSEHANDLE( m_iocp );
  25. }
  27. void CIOCompletionPort::AssociateDevice( HANDLE hDevice, ULONG_PTR completionKey )
  28. {
  29. if ( m_iocp != ::CreateIoCompletionPort( hDevice,
  30. m_iocp, 
  31. completionKey, 
  32. 0 ) )
  33. {
  34. throw CWin32Exception( _T("CIOCompletionPort::AssociateDevice() - CreateIoCompletionPort"), ::GetLastError() );
  35. }
  36. }
  38. void CIOCompletionPort::PostStatus( ULONG_PTR completionKey, 
  39. DWORD dwNumBytes /* = 0 */, 
  40. OVERLAPPED *pOverlapped /* = 0 */) 
  41. {
  42. if ( 0 == ::PostQueuedCompletionStatus( m_iocp, 
  43. dwNumBytes, 
  44. completionKey, 
  45. pOverlapped ) )
  46. {
  47. throw CWin32Exception( _T("CIOCompletionPort::PostStatus() - PostQueuedCompletionStatus"), ::GetLastError() );
  48. }
  49. }
  51. DWORD CIOCompletionPort::GetStatus( ULONG_PTR *pCompletionKey, 
  52. PDWORD pdwNumBytes,
  53. OVERLAPPED **ppOverlapped )
  54. {
  55. if ( 0 == ::GetQueuedCompletionStatus( m_iocp, 
  56. pdwNumBytes, 
  57. pCompletionKey, 
  58. ppOverlapped, 
  59. INFINITE ) )
  60. {
  61. return ::GetLastError();
  62. }
  64. return S_OK;
  65. }
  67. DWORD CIOCompletionPort::GetStatus( ULONG_PTR *pCompletionKey, 
  68. PDWORD pdwNumBytes,
  69. OVERLAPPED **ppOverlapped, 
  70. DWORD dwMilliseconds)
  71. {
  72. if ( 0 == ::GetQueuedCompletionStatus( m_iocp, 
  73. pdwNumBytes, 
  74. pCompletionKey, 
  75. ppOverlapped, 
  76. dwMilliseconds ) )
  77. {
  78. DWORD lastError = ::GetLastError();
  80. if ( lastError != WAIT_TIMEOUT )
  81. {
  82. return lastError;
  83. }
  85. return S_FALSE;
  86. }
  88. return S_OK;
  89. }
  91. } // End of namespace OnlineGameLib
  92. } // End of namespace Win32