Lines Matching refs:socket
48 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) { in uv__tcp_nodelay() argument
49 if (setsockopt(socket, in uv__tcp_nodelay()
60 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) { in uv__tcp_keepalive() argument
61 if (setsockopt(socket, in uv__tcp_keepalive()
69 if (enable && setsockopt(socket, in uv__tcp_keepalive()
83 SOCKET socket, in uv__tcp_set_socket() argument
90 if (handle->socket != INVALID_SOCKET) in uv__tcp_set_socket()
94 if (ioctlsocket(socket, FIONBIO, &yes) == SOCKET_ERROR) { in uv__tcp_set_socket()
99 if (!SetHandleInformation((HANDLE) socket, HANDLE_FLAG_INHERIT, 0)) in uv__tcp_set_socket()
104 if (CreateIoCompletionPort((HANDLE)socket, in uv__tcp_set_socket()
106 (ULONG_PTR)socket, in uv__tcp_set_socket()
124 if (!SetFileCompletionNotificationModes((HANDLE) socket, sfcnm_flags)) in uv__tcp_set_socket()
130 err = uv__tcp_nodelay(handle, socket, 1); in uv__tcp_set_socket()
137 err = uv__tcp_keepalive(handle, socket, 1, 60); in uv__tcp_set_socket()
142 handle->socket = socket; in uv__tcp_set_socket()
168 handle->socket = INVALID_SOCKET; in uv_tcp_init_ex()
183 sock = socket(domain, SOCK_STREAM, 0); in uv_tcp_init_ex()
224 else if (shutdown(stream->socket, SD_SEND) == SOCKET_ERROR) in uv__process_tcp_shutdown_req()
243 assert(handle->socket == INVALID_SOCKET); in uv__tcp_endgame()
299 if (handle->socket == INVALID_SOCKET) { in uv__tcp_try_bind()
306 sock = socket(addr->sa_family, SOCK_STREAM, 0); in uv__tcp_try_bind()
327 setsockopt(handle->socket, in uv__tcp_try_bind()
335 r = bind(handle->socket, addr, addrlen); in uv__tcp_try_bind()
409 accept_socket = socket(family, SOCK_STREAM, 0); in uv__tcp_queue_accept()
433 success = handle->tcp.serv.func_acceptex(handle->socket, in uv__tcp_queue_accept()
516 result = WSARecv(handle->socket, in uv__tcp_queue_read()
556 if (0 != setsockopt(handle->socket, SOL_SOCKET, SO_LINGER, (const char*)&l, sizeof(l))) in uv_tcp_close_reset()
595 if (!uv__get_acceptex_function(handle->socket, &handle->tcp.serv.func_acceptex)) { in uv__tcp_listen()
602 listen(handle->socket, backlog) == SOCKET_ERROR) { in uv__tcp_listen()
821 if (!uv__get_connectex_function(handle->socket, &handle->tcp.conn.func_connectex)) { in uv__tcp_try_connect()
834 WSAIoctl(handle->socket, in uv__tcp_try_connect()
860 success = handle->tcp.conn.func_connectex(handle->socket, in uv__tcp_try_connect()
933 result = WSASend(handle->socket, in uv__tcp_write()
985 result = WSASend(handle->socket, in uv__tcp_try_write()
1070 if (WSARecv(handle->socket, in uv__process_tcp_read_req()
1163 closesocket(handle->socket); in uv__process_tcp_write_req()
1164 handle->socket = INVALID_SOCKET; in uv__process_tcp_write_req()
1200 (char*)&handle->socket, in uv__process_tcp_accept_req()
1201 sizeof(handle->socket)) == 0) { in uv__process_tcp_accept_req()
1244 } else if (setsockopt(handle->socket, in uv__process_tcp_connect_req()
1281 listen(handle->socket, SOMAXCONN) == SOCKET_ERROR) { in uv__tcp_xfer_export()
1287 if (WSADuplicateSocketW(handle->socket, target_pid, &xfer_info->socket_info)) in uv__tcp_xfer_export()
1303 SOCKET socket; in uv__tcp_xfer_import() local
1308 socket = WSASocketW(FROM_PROTOCOL_INFO, in uv__tcp_xfer_import()
1315 if (socket == INVALID_SOCKET) { in uv__tcp_xfer_import()
1320 tcp->loop, tcp, socket, xfer_info->socket_info.iAddressFamily, 1); in uv__tcp_xfer_import()
1322 closesocket(socket); in uv__tcp_xfer_import()
1342 if (handle->socket != INVALID_SOCKET) { in uv_tcp_nodelay()
1343 err = uv__tcp_nodelay(handle, handle->socket, enable); in uv_tcp_nodelay()
1361 if (handle->socket != INVALID_SOCKET) { in uv_tcp_keepalive()
1362 err = uv__tcp_keepalive(handle, handle->socket, enable, delay); in uv_tcp_keepalive()
1412 SOCKET socket; in uv__tcp_try_cancel_reqs() local
1417 socket = tcp->socket; in uv__tcp_try_cancel_reqs()
1426 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped); in uv__tcp_try_cancel_reqs()
1428 CancelIo((HANDLE) socket); in uv__tcp_try_cancel_reqs()
1438 if (WSAIoctl(socket, in uv__tcp_try_cancel_reqs()
1442 &socket, in uv__tcp_try_cancel_reqs()
1443 sizeof socket, in uv__tcp_try_cancel_reqs()
1452 assert(socket != 0 && socket != INVALID_SOCKET); in uv__tcp_try_cancel_reqs()
1454 if (socket != tcp->socket) { in uv__tcp_try_cancel_reqs()
1456 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped); in uv__tcp_try_cancel_reqs()
1458 CancelIo((HANDLE) socket); in uv__tcp_try_cancel_reqs()
1500 closesocket(tcp->socket); in uv__tcp_close()
1501 tcp->socket = INVALID_SOCKET; in uv__tcp_close()