Lines Matching defs:socket
48 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) {
49 if (setsockopt(socket,
60 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) {
61 if (setsockopt(socket,
69 if (enable && setsockopt(socket,
83 SOCKET socket,
90 if (handle->socket != INVALID_SOCKET)
93 /* Set the socket to nonblocking mode */
94 if (ioctlsocket(socket, FIONBIO, &yes) == SOCKET_ERROR) {
98 /* Make the socket non-inheritable */
99 if (!SetHandleInformation((HANDLE) socket, HANDLE_FLAG_INHERIT, 0))
104 if (CreateIoCompletionPort((HANDLE)socket,
106 (ULONG_PTR)socket,
124 if (!SetFileCompletionNotificationModes((HANDLE) socket, sfcnm_flags))
130 err = uv__tcp_nodelay(handle, socket, 1);
137 err = uv__tcp_keepalive(handle, socket, 1, 60);
142 handle->socket = socket;
168 handle->socket = INVALID_SOCKET;
183 sock = socket(domain, SOCK_STREAM, 0);
224 else if (shutdown(stream->socket, SD_SEND) == SOCKET_ERROR)
243 assert(handle->socket == INVALID_SOCKET);
287 * socket in TIME_WAIT state.
299 if (handle->socket == INVALID_SOCKET) {
302 /* Cannot set IPv6-only mode on non-IPv6 socket. */
306 sock = socket(addr->sa_family, SOCK_STREAM, 0);
327 setsockopt(handle->socket,
335 r = bind(handle->socket, addr, addrlen);
408 /* Open a socket for the accepted connection. */
409 accept_socket = socket(family, SOCK_STREAM, 0);
417 /* Make the socket non-inheritable */
433 success = handle->tcp.serv.func_acceptex(handle->socket,
464 /* Destroy the preallocated client socket. */
516 result = WSARecv(handle->socket,
556 if (0 != setsockopt(handle->socket, SOL_SOCKET, SO_LINGER, (const char*)&l, sizeof(l)))
595 if (!uv__get_acceptex_function(handle->socket, &handle->tcp.serv.func_acceptex)) {
602 listen(handle->socket, backlog) == SOCKET_ERROR) {
687 /* AcceptEx() implicitly binds the accepted socket. */
821 if (!uv__get_connectex_function(handle->socket, &handle->tcp.conn.func_connectex)) {
834 WSAIoctl(handle->socket,
860 success = handle->tcp.conn.func_connectex(handle->socket,
933 result = WSASend(handle->socket,
985 result = WSASend(handle->socket,
1070 if (WSARecv(handle->socket,
1163 closesocket(handle->socket);
1164 handle->socket = INVALID_SOCKET;
1183 /* If handle->accepted_socket is not a valid socket, then uv_queue_accept
1200 (char*)&handle->socket,
1201 sizeof(handle->socket)) == 0) {
1210 /* Error related to accepted socket is ignored because the server socket
1211 * may still be healthy. If the server socket is broken uv_queue_accept
1244 } else if (setsockopt(handle->socket,
1272 /* We're about to share the socket with another process. Because this is a
1273 * listening socket, we assume that the other process will be accepting
1274 * connections on it. Thus, before sharing the socket with another process,
1281 listen(handle->socket, SOMAXCONN) == SOCKET_ERROR) {
1287 if (WSADuplicateSocketW(handle->socket, target_pid, &xfer_info->socket_info))
1292 * friendly to the process(es) that we share the socket with. */
1303 SOCKET socket;
1308 socket = WSASocketW(FROM_PROTOCOL_INFO,
1315 if (socket == INVALID_SOCKET) {
1320 tcp->loop, tcp, socket, xfer_info->socket_info.iAddressFamily, 1);
1322 closesocket(socket);
1342 if (handle->socket != INVALID_SOCKET) {
1343 err = uv__tcp_nodelay(handle, handle->socket, enable);
1361 if (handle->socket != INVALID_SOCKET) {
1362 err = uv__tcp_keepalive(handle, handle->socket, enable, delay);
1373 /* TODO: Store delay if handle->socket isn't created yet. */
1412 SOCKET socket;
1417 socket = tcp->socket;
1426 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped);
1428 CancelIo((HANDLE) socket);
1434 /* If there are non-ifs LSPs then try to obtain a base handle for the socket.
1438 if (WSAIoctl(socket,
1442 &socket,
1443 sizeof socket,
1452 assert(socket != 0 && socket != INVALID_SOCKET);
1454 if (socket != tcp->socket) {
1456 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped);
1458 CancelIo((HANDLE) socket);
1500 closesocket(tcp->socket);
1501 tcp->socket = INVALID_SOCKET;
1516 /* Detect the address family of the socket. */
1535 /* Support already active socket. */