Lines Matching defs:socket
40 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) {
41 if (setsockopt(socket,
52 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) {
53 if (setsockopt(socket,
61 if (enable && setsockopt(socket,
75 SOCKET socket,
82 if (handle->socket != INVALID_SOCKET)
85 /* Set the socket to nonblocking mode */
86 if (ioctlsocket(socket, FIONBIO, &yes) == SOCKET_ERROR) {
90 /* Make the socket non-inheritable */
91 if (!SetHandleInformation((HANDLE) socket, HANDLE_FLAG_INHERIT, 0))
96 if (CreateIoCompletionPort((HANDLE)socket,
98 (ULONG_PTR)socket,
116 if (!SetFileCompletionNotificationModes((HANDLE) socket, sfcnm_flags))
122 err = uv__tcp_nodelay(handle, socket, 1);
129 err = uv__tcp_keepalive(handle, socket, 1, 60);
134 handle->socket = socket;
160 handle->socket = INVALID_SOCKET;
175 sock = socket(domain, SOCK_STREAM, 0);
215 else if (shutdown(stream->socket, SD_SEND) == SOCKET_ERROR)
234 assert(handle->socket == INVALID_SOCKET);
277 * socket in TIME_WAIT state.
289 if (handle->socket == INVALID_SOCKET) {
292 /* Cannot set IPv6-only mode on non-IPv6 socket. */
296 sock = socket(addr->sa_family, SOCK_STREAM, 0);
317 setsockopt(handle->socket,
325 r = bind(handle->socket, addr, addrlen);
398 /* Open a socket for the accepted connection. */
399 accept_socket = socket(family, SOCK_STREAM, 0);
407 /* Make the socket non-inheritable */
423 success = handle->tcp.serv.func_acceptex(handle->socket,
454 /* Destroy the preallocated client socket. */
489 result = WSARecv(handle->socket,
529 if (0 != setsockopt(handle->socket, SOL_SOCKET, SO_LINGER, (const char*)&l, sizeof(l)))
568 if (!uv__get_acceptex_function(handle->socket, &handle->tcp.serv.func_acceptex)) {
575 listen(handle->socket, backlog) == SOCKET_ERROR) {
659 /* AcceptEx() implicitly binds the accepted socket. */
791 if (!uv__get_connectex_function(handle->socket, &handle->tcp.conn.func_connectex)) {
804 WSAIoctl(handle->socket,
830 success = handle->tcp.conn.func_connectex(handle->socket,
903 result = WSASend(handle->socket,
955 result = WSASend(handle->socket,
1040 if (WSARecv(handle->socket,
1133 closesocket(handle->socket);
1134 handle->socket = INVALID_SOCKET;
1153 /* If handle->accepted_socket is not a valid socket, then uv_queue_accept
1170 (char*)&handle->socket,
1171 sizeof(handle->socket)) == 0) {
1180 /* Error related to accepted socket is ignored because the server socket
1181 * may still be healthy. If the server socket is broken uv_queue_accept
1214 } else if (setsockopt(handle->socket,
1241 /* We're about to share the socket with another process. Because this is a
1242 * listening socket, we assume that the other process will be accepting
1243 * connections on it. Thus, before sharing the socket with another process,
1250 listen(handle->socket, SOMAXCONN) == SOCKET_ERROR) {
1256 if (WSADuplicateSocketW(handle->socket, target_pid, &xfer_info->socket_info))
1261 * friendly to the process(es) that we share the socket with. */
1272 SOCKET socket;
1277 socket = WSASocketW(FROM_PROTOCOL_INFO,
1284 if (socket == INVALID_SOCKET) {
1289 tcp->loop, tcp, socket, xfer_info->socket_info.iAddressFamily, 1);
1291 closesocket(socket);
1310 if (handle->socket != INVALID_SOCKET) {
1311 err = uv__tcp_nodelay(handle, handle->socket, enable);
1329 if (handle->socket != INVALID_SOCKET) {
1330 err = uv__tcp_keepalive(handle, handle->socket, enable, delay);
1341 /* TODO: Store delay if handle->socket isn't created yet. */
1380 SOCKET socket;
1385 socket = tcp->socket;
1394 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped);
1396 CancelIo((HANDLE) socket);
1402 /* If there are non-ifs LSPs then try to obtain a base handle for the socket.
1406 if (WSAIoctl(socket,
1410 &socket,
1411 sizeof socket,
1420 assert(socket != 0 && socket != INVALID_SOCKET);
1422 if (socket != tcp->socket) {
1424 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped);
1426 CancelIo((HANDLE) socket);
1468 closesocket(tcp->socket);
1469 tcp->socket = INVALID_SOCKET;
1484 /* Detect the address family of the socket. */
1503 /* Support already active socket. */