Lines Matching refs:flags
107 handle->flags |= UV_HANDLE_EMULATE_IOCP; in uv__tcp_set_socket()
119 if (!(handle->flags & UV_HANDLE_EMULATE_IOCP) && !non_ifs_lsp) { in uv__tcp_set_socket()
124 handle->flags |= UV_HANDLE_SYNC_BYPASS_IOCP; in uv__tcp_set_socket()
127 if (handle->flags & UV_HANDLE_TCP_NODELAY) { in uv__tcp_set_socket()
134 if (handle->flags & UV_HANDLE_TCP_KEEPALIVE) { in uv__tcp_set_socket()
143 handle->flags |= UV_HANDLE_IPV6; in uv__tcp_set_socket()
145 assert(!(handle->flags & UV_HANDLE_IPV6)); in uv__tcp_set_socket()
152 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* handle, unsigned int flags) { in uv_tcp_init_ex() argument
156 domain = flags & 0xFF; in uv_tcp_init_ex()
160 if (flags & ~0xFF) in uv_tcp_init_ex()
211 assert(!(stream->flags & UV_HANDLE_SHUT)); in uv__process_tcp_shutdown_req()
212 assert(stream->flags & UV_HANDLE_CONNECTION); in uv__process_tcp_shutdown_req()
218 if (stream->flags & UV_HANDLE_CLOSING) in uv__process_tcp_shutdown_req()
224 stream->flags |= UV_HANDLE_SHUT; in uv__process_tcp_shutdown_req()
237 assert(handle->flags & UV_HANDLE_CLOSING); in uv__tcp_endgame()
239 assert(!(handle->flags & UV_HANDLE_CLOSED)); in uv__tcp_endgame()
242 if (!(handle->flags & UV_HANDLE_CONNECTION) && handle->tcp.serv.accept_reqs) { in uv__tcp_endgame()
243 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_endgame()
261 if (handle->flags & UV_HANDLE_CONNECTION && in uv__tcp_endgame()
262 handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_endgame()
291 unsigned int flags) { in uv__tcp_try_bind() argument
298 if (flags & UV_TCP_REUSEPORT) in uv__tcp_try_bind()
305 if ((flags & UV_TCP_IPV6ONLY) && addr->sa_family != AF_INET6) in uv__tcp_try_bind()
324 on = (flags & UV_TCP_IPV6ONLY) != 0; in uv__tcp_try_bind()
349 handle->flags |= UV_HANDLE_BOUND; in uv__tcp_try_bind()
400 assert(handle->flags & UV_HANDLE_LISTENING); in uv__tcp_queue_accept()
404 if (handle->flags & UV_HANDLE_IPV6) { in uv__tcp_queue_accept()
430 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_queue_accept()
453 if (handle->flags & UV_HANDLE_EMULATE_IOCP && in uv__tcp_queue_accept()
469 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_queue_accept()
481 DWORD bytes, flags; in uv__tcp_queue_read() local
483 assert(handle->flags & UV_HANDLE_READING); in uv__tcp_queue_read()
484 assert(!(handle->flags & UV_HANDLE_READ_PENDING)); in uv__tcp_queue_read()
489 handle->flags |= UV_HANDLE_ZERO_READ; in uv__tcp_queue_read()
495 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_queue_read()
500 flags = 0; in uv__tcp_queue_read()
505 &flags, in uv__tcp_queue_read()
509 handle->flags |= UV_HANDLE_READ_PENDING; in uv__tcp_queue_read()
518 if (handle->flags & UV_HANDLE_EMULATE_IOCP && in uv__tcp_queue_read()
556 if (handle->flags & UV_HANDLE_LISTENING) { in uv__tcp_listen()
560 if (handle->flags & UV_HANDLE_READING) { in uv__tcp_listen()
568 if (!(handle->flags & UV_HANDLE_BOUND)) { in uv__tcp_listen()
586 if (!(handle->flags & UV_HANDLE_SHARED_TCP_SOCKET) && in uv__tcp_listen()
591 handle->flags |= UV_HANDLE_LISTENING; in uv__tcp_listen()
595 simultaneous_accepts = handle->flags & UV_HANDLE_TCP_SINGLE_ACCEPT ? 1 in uv__tcp_listen()
612 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_listen()
656 if (server->flags & UV_HANDLE_IPV6) { in uv__tcp_accept()
672 client->flags |= UV_HANDLE_BOUND | UV_HANDLE_READABLE | UV_HANDLE_WRITABLE; in uv__tcp_accept()
680 if (!(server->flags & UV_HANDLE_CLOSING)) { in uv__tcp_accept()
682 if (!(server->flags & UV_HANDLE_TCP_ACCEPT_STATE_CHANGING)) { in uv__tcp_accept()
686 assert(server->flags & UV_HANDLE_TCP_SINGLE_ACCEPT); in uv__tcp_accept()
697 server->flags &= ~UV_HANDLE_TCP_ACCEPT_STATE_CHANGING; in uv__tcp_accept()
698 server->flags |= UV_HANDLE_TCP_SINGLE_ACCEPT; in uv__tcp_accept()
711 handle->flags |= UV_HANDLE_READING; in uv__tcp_read_start()
718 if (!(handle->flags & UV_HANDLE_READ_PENDING)) { in uv__tcp_read_start()
719 if (handle->flags & UV_HANDLE_EMULATE_IOCP && in uv__tcp_read_start()
787 if (!(handle->flags & UV_HANDLE_BOUND)) { in uv__tcp_try_connect()
906 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__tcp_write()
937 if (handle->flags & UV_HANDLE_EMULATE_IOCP && in uv__tcp_write()
984 DWORD bytes, flags, err; in uv__process_tcp_read_req() local
990 handle->flags &= ~UV_HANDLE_READ_PENDING; in uv__process_tcp_read_req()
994 if ((handle->flags & UV_HANDLE_READING) || in uv__process_tcp_read_req()
995 !(handle->flags & UV_HANDLE_ZERO_READ)) { in uv__process_tcp_read_req()
996 handle->flags &= ~UV_HANDLE_READING; in uv__process_tcp_read_req()
998 buf = (handle->flags & UV_HANDLE_ZERO_READ) ? in uv__process_tcp_read_req()
1008 handle->flags &= ~(UV_HANDLE_READABLE | UV_HANDLE_WRITABLE); in uv__process_tcp_read_req()
1015 if (!(handle->flags & UV_HANDLE_ZERO_READ)) { in uv__process_tcp_read_req()
1028 if (handle->flags & UV_HANDLE_READING) { in uv__process_tcp_read_req()
1029 handle->flags &= ~UV_HANDLE_READING; in uv__process_tcp_read_req()
1042 while ((handle->flags & UV_HANDLE_READING) && (count-- > 0)) { in uv__process_tcp_read_req()
1051 flags = 0; in uv__process_tcp_read_req()
1056 &flags, in uv__process_tcp_read_req()
1068 handle->flags &= ~UV_HANDLE_READING; in uv__process_tcp_read_req()
1081 handle->flags &= ~UV_HANDLE_READING; in uv__process_tcp_read_req()
1089 handle->flags &= ~(UV_HANDLE_READABLE | UV_HANDLE_WRITABLE); in uv__process_tcp_read_req()
1101 if ((handle->flags & UV_HANDLE_READING) && in uv__process_tcp_read_req()
1102 !(handle->flags & UV_HANDLE_READ_PENDING)) { in uv__process_tcp_read_req()
1122 if (handle->flags & UV_HANDLE_EMULATE_IOCP) { in uv__process_tcp_write_req()
1144 if (handle->flags & UV_HANDLE_CLOSING) { in uv__process_tcp_write_req()
1169 if (handle->flags & UV_HANDLE_LISTENING) { in uv__process_tcp_accept_req()
1170 handle->flags &= ~UV_HANDLE_LISTENING; in uv__process_tcp_accept_req()
1197 if (handle->flags & UV_HANDLE_LISTENING) { in uv__process_tcp_accept_req()
1223 if (handle->flags & UV_HANDLE_CLOSING) { in uv__process_tcp_connect_req()
1232 handle->flags |= UV_HANDLE_READABLE | UV_HANDLE_WRITABLE; in uv__process_tcp_connect_req()
1249 if (handle->flags & UV_HANDLE_CONNECTION) { in uv__tcp_xfer_export()
1257 if (!(handle->flags & UV_HANDLE_LISTENING)) { in uv__tcp_xfer_export()
1258 if (!(handle->flags & UV_HANDLE_BOUND)) { in uv__tcp_xfer_export()
1274 handle->flags |= UV_HANDLE_SHARED_TCP_SOCKET; in uv__tcp_xfer_export()
1308 tcp->flags |= UV_HANDLE_BOUND | UV_HANDLE_SHARED_TCP_SOCKET; in uv__tcp_xfer_import()
1312 tcp->flags |= UV_HANDLE_READABLE | UV_HANDLE_WRITABLE; in uv__tcp_xfer_import()
1329 handle->flags |= UV_HANDLE_TCP_NODELAY; in uv_tcp_nodelay()
1331 handle->flags &= ~UV_HANDLE_TCP_NODELAY; in uv_tcp_nodelay()
1348 handle->flags |= UV_HANDLE_TCP_KEEPALIVE; in uv_tcp_keepalive()
1350 handle->flags &= ~UV_HANDLE_TCP_KEEPALIVE; in uv_tcp_keepalive()
1360 if (handle->flags & UV_HANDLE_CONNECTION) { in uv_tcp_simultaneous_accepts()
1365 if ((enable && !(handle->flags & UV_HANDLE_TCP_SINGLE_ACCEPT)) || in uv_tcp_simultaneous_accepts()
1366 (!enable && handle->flags & UV_HANDLE_TCP_SINGLE_ACCEPT)) { in uv_tcp_simultaneous_accepts()
1376 if (handle->flags & UV_HANDLE_TCP_ACCEPT_STATE_CHANGING) { in uv_tcp_simultaneous_accepts()
1380 handle->flags |= UV_HANDLE_TCP_SINGLE_ACCEPT; in uv_tcp_simultaneous_accepts()
1383 if (handle->flags & UV_HANDLE_LISTENING) { in uv_tcp_simultaneous_accepts()
1384 handle->flags |= UV_HANDLE_TCP_ACCEPT_STATE_CHANGING; in uv_tcp_simultaneous_accepts()
1398 reading = tcp->flags & UV_HANDLE_READ_PENDING; in uv__tcp_try_cancel_reqs()
1411 non_ifs_lsp = (tcp->flags & UV_HANDLE_IPV6) ? uv_tcp_non_ifs_lsp_ipv6 : in uv__tcp_try_cancel_reqs()
1444 if (tcp->flags & UV_HANDLE_CONNECTION) { in uv__tcp_close()
1445 if (tcp->flags & UV_HANDLE_READING) { in uv__tcp_close()
1462 assert(!(tcp->flags & UV_HANDLE_READING)); in uv__tcp_close()
1465 if (tcp->flags & UV_HANDLE_LISTENING) { in uv__tcp_close()
1466 tcp->flags &= ~UV_HANDLE_LISTENING; in uv__tcp_close()
1470 tcp->flags &= ~(UV_HANDLE_READABLE | UV_HANDLE_WRITABLE); in uv__tcp_close()
1478 if (!(tcp->flags & UV_HANDLE_CONNECTION) || in uv__tcp_close()
1519 handle->flags |= UV_HANDLE_BOUND; in uv_tcp_open()
1524 handle->flags |= UV_HANDLE_READABLE | UV_HANDLE_WRITABLE; in uv_tcp_open()
1538 unsigned int flags) { in uv__tcp_bind() argument
1541 err = uv__tcp_try_bind(handle, addr, addrlen, flags); in uv__tcp_bind()
1578 DWORD flags; in uv_socketpair() local
1633 while (!WSAGetOverlappedResult(client1, &overlap, &bytes, FALSE, &flags)) { in uv_socketpair()
