From 7f896889ba88e0e90dd8cbcdc55ba3384fa01b02 Mon Sep 17 00:00:00 2001 From: Bert Belder Date: Thu, 14 Jun 2012 21:18:12 +0200 Subject: [PATCH] uv: upgrade to b1649b6f --- deps/uv/src/win/tcp.c | 41 +++++++++++++++++++++++++++++------------ 1 file changed, 29 insertions(+), 12 deletions(-) diff --git a/deps/uv/src/win/tcp.c b/deps/uv/src/win/tcp.c index daef567..646ae2c 100644 --- a/deps/uv/src/win/tcp.c +++ b/deps/uv/src/win/tcp.c @@ -94,12 +94,6 @@ static int uv_tcp_set_socket(uv_loop_t* loop, uv_tcp_t* handle, return -1; } - /* Make the socket non-inheritable */ - if (!SetHandleInformation((HANDLE)socket, HANDLE_FLAG_INHERIT, 0)) { - uv__set_sys_error(loop, GetLastError()); - return -1; - } - /* Associate it with the I/O completion port. */ /* Use uv_handle_t pointer as completion key. */ if (CreateIoCompletionPort((HANDLE)socket, @@ -258,6 +252,13 @@ static int uv__bind(uv_tcp_t* handle, return -1; } + /* Make the socket non-inheritable */ + if (!SetHandleInformation((HANDLE) sock, HANDLE_FLAG_INHERIT, 0)) { + uv__set_sys_error(handle->loop, GetLastError()); + closesocket(sock); + return -1; + } + if (uv_tcp_set_socket(handle->loop, handle, sock, 0) == -1) { closesocket(sock); return -1; @@ -371,6 +372,15 @@ static void uv_tcp_queue_accept(uv_tcp_t* handle, uv_tcp_accept_t* req) { return; } + /* Make the socket non-inheritable */ + if (!SetHandleInformation((HANDLE) accept_socket, HANDLE_FLAG_INHERIT, 0)) { + SET_REQ_ERROR(req, GetLastError()); + uv_insert_pending_req(loop, (uv_req_t*)req); + handle->reqs_pending++; + closesocket(accept_socket); + return; + } + /* Prepare the overlapped structure. */ memset(&(req->overlapped), 0, sizeof(req->overlapped)); if (handle->flags & UV_HANDLE_EMULATE_IOCP) { @@ -1154,21 +1164,28 @@ int uv_tcp_import(uv_tcp_t* tcp, WSAPROTOCOL_INFOW* socket_protocol_info, return -1; } - tcp->flags |= UV_HANDLE_BOUND; - tcp->flags |= UV_HANDLE_SHARED_TCP_SOCKET; + if (!SetHandleInformation((HANDLE) socket, HANDLE_FLAG_INHERIT, 0)) { + uv__set_sys_error(tcp->loop, GetLastError()); + closesocket(socket); + return -1; + } + + if (uv_tcp_set_socket(tcp->loop, tcp, socket, 1) != 0) { + closesocket(socket); + return -1; + } if (tcp_connection) { uv_connection_init((uv_stream_t*)tcp); } + tcp->flags |= UV_HANDLE_BOUND; + tcp->flags |= UV_HANDLE_SHARED_TCP_SOCKET; + if (socket_protocol_info->iAddressFamily == AF_INET6) { tcp->flags |= UV_HANDLE_IPV6; } - if (uv_tcp_set_socket(tcp->loop, tcp, socket, 1) != 0) { - return -1; - } - tcp->loop->active_tcp_streams++; return 0; } -- 2.7.4