diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2019-02-05 14:19:03 +0100 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2019-02-05 14:19:03 +0100 |
| commit | 766d9df0a739de08af048b0289cc1454eb011d1a (patch) | |
| tree | 2fbfe794f32b3c680e1dc7bfa707fb4b795d14cc /cpp/src/Ice/Selector.cpp | |
| parent | Added TypeScript (diff) | |
| download | ice-766d9df0a739de08af048b0289cc1454eb011d1a.tar.bz2 ice-766d9df0a739de08af048b0289cc1454eb011d1a.tar.xz ice-766d9df0a739de08af048b0289cc1454eb011d1a.zip | |
Windows support for transport without file descriptor
Diffstat (limited to 'cpp/src/Ice/Selector.cpp')
| -rw-r--r-- | cpp/src/Ice/Selector.cpp | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/cpp/src/Ice/Selector.cpp b/cpp/src/Ice/Selector.cpp index a2982ef4343..16bcf641f1f 100644 --- a/cpp/src/Ice/Selector.cpp +++ b/cpp/src/Ice/Selector.cpp @@ -69,10 +69,16 @@ Selector::initialize(EventHandler* handler) } #ifdef ICE_USE_IOCP - HANDLE socket = reinterpret_cast<HANDLE>(handler->getNativeInfo()->fd()); - if(CreateIoCompletionPort(socket, _handle, reinterpret_cast<ULONG_PTR>(handler), 0) == ICE_NULLPTR) + SOCKET socket = handler->getNativeInfo()->fd(); + if (socket != INVALID_SOCKET) { - throw Ice::SocketException(__FILE__, __LINE__, GetLastError()); + if (CreateIoCompletionPort(reinterpret_cast<HANDLE>(socket), + _handle, + reinterpret_cast<ULONG_PTR>(handler), + 0) == ICE_NULLPTR) + { + throw Ice::SocketException(__FILE__, __LINE__, GetLastError()); + } } handler->getNativeInfo()->initialize(_handle, reinterpret_cast<ULONG_PTR>(handler)); #else |