boost/asio
2
0
Fork 0
mirror of https://github.com/boostorg/asio.git synced 2026-01-28 06:42:08 +00:00
Code Issues Projects Releases Wiki Activity

Replace win_iocp_io_service::register_socket() with register_handle() to

Browse Source 
allow it to be used with other Windows kernel objects.


[SVN r36311]
This commit is contained in:
Christopher Kohlhoff
2006-12-09 22:31:44 +00:00
parent e3f0c76fce
commit 5cded59aef
2 changed files with 13 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
include/boost/asio/detail/win_iocp_io_service.hpp
View File

@@ -94,11 +94,10 @@ public:
}
}
// Register a socket with the IO completion port.
void register_socket(socket_type sock)
// Register a handle with the IO completion port.
void register_handle(HANDLE handle)
{
HANDLE sock_as_handle = reinterpret_cast<HANDLE>(sock);
::CreateIoCompletionPort(sock_as_handle, iocp_.handle, 0, 0);
::CreateIoCompletionPort(handle, iocp_.handle, 0, 0);
}
// Run the event loop until interrupted or no more work.

14
include/boost/asio/detail/win_iocp_socket_service.hpp
View File

@@ -92,6 +92,11 @@ public:
return socket_;
}
HANDLE as_handle() const
{
return reinterpret_cast<HANDLE>(socket_);
}
bool have_remote_endpoint() const
{
return have_remote_endpoint_;
@@ -262,7 +267,8 @@ public:
if (sock.get() == invalid_socket)
return ec;
iocp_service_.register_socket(sock.get());
HANDLE sock_as_handle = reinterpret_cast<HANDLE>(sock.get());
iocp_service_.register_handle(sock_as_handle);
impl.socket_ = sock.release();
impl.cancel_token_.reset(static_cast<void*>(0), noop_deleter());
@@ -279,7 +285,7 @@ public:
boost::system::error_code ignored_ec;
close(impl, ignored_ec);
iocp_service_.register_socket(native_socket);
iocp_service_.register_handle(native_socket.as_handle());
impl.socket_ = native_socket;
impl.cancel_token_.reset(static_cast<void*>(0), noop_deleter());
@@ -1862,7 +1868,7 @@ public:
impl.socket_ = socket_ops::socket(family, type, proto, ec);
if (impl.socket_ == invalid_socket)
return ec;
iocp_service_.register_socket(impl.socket_);
iocp_service_.register_handle(impl.socket_.as_handle());
}
// Perform the connect operation.
@@ -1987,7 +1993,7 @@ public:
io_service().post(bind_handler(handler, ec));
return;
}
iocp_service_.register_socket(impl.socket_);
iocp_service_.register_handle(impl.socket_.as_handle());
}
// Mark the socket as non-blocking so that the connection will take place