/libuv/src/win/ |
H A D | tcp.c | 143 handle->flags |= UV_HANDLE_IPV6; in uv__tcp_set_socket() 156 domain = flags & 0xFF; in uv_tcp_init_ex() 160 if (flags & ~0xFF) in uv_tcp_init_ex() 343 handle->flags |= UV_HANDLE_BOUND; in uv__tcp_try_bind() 475 DWORD bytes, flags; in uv__tcp_queue_read() local 494 flags = 0; in uv__tcp_queue_read() 499 &flags, in uv__tcp_queue_read() 978 DWORD bytes, flags, err; in uv__process_tcp_read_req() local 1045 flags = 0; in uv__process_tcp_read_req() 1050 &flags, in uv__process_tcp_read_req() [all …]
|
H A D | udp.c | 114 handle->flags |= UV_HANDLE_IPV6; in uv__udp_set_socket() 125 unsigned flags, in uv__udp_init_ex() argument 221 if (flags & UV_UDP_REUSEADDR) { in uv__udp_maybe_bind() 256 handle->flags |= UV_HANDLE_BOUND; in uv__udp_maybe_bind() 265 DWORD bytes, flags; in uv__udp_queue_recv() local 278 flags = MSG_PEEK; in uv__udp_queue_recv() 441 DWORD bytes, err, flags; in uv__process_udp_recv_req() local 462 flags = 0; in uv__process_udp_recv_req() 468 &flags, in uv__process_udp_recv_req() 607 if ((handle->flags & UV_HANDLE_BOUND) && !(handle->flags & UV_HANDLE_IPV6)) in uv__udp_set_membership6() [all …]
|
H A D | handle-inl.h | 35 !((handle)->flags & UV_HANDLE_CLOSING)) { \ 56 if (handle->flags & UV_HANDLE_CLOSING && \ 65 assert(!((handle)->flags & UV_HANDLE_CLOSING)); \ 67 if (!(((handle)->flags & UV_HANDLE_ACTIVE) && \ 68 ((handle)->flags & UV_HANDLE_REF))) \ 71 (handle)->flags |= UV_HANDLE_CLOSING; \ 72 (handle)->flags &= ~UV_HANDLE_ACTIVE; \ 81 (handle)->flags |= UV_HANDLE_CLOSED; \ 89 if (!(handle->flags & UV_HANDLE_ENDGAME_QUEUED)) { in uv__want_endgame() 90 handle->flags |= UV_HANDLE_ENDGAME_QUEUED; in uv__want_endgame() [all …]
|
H A D | pipe.c | 75 uint32_t flags; member 407 if (flags & UV_READABLE_PIPE) { in uv__create_stdio_pipe_pair() 414 if (flags & UV_WRITABLE_PIPE) { in uv__create_stdio_pipe_pair() 440 if (flags & UV_READABLE_PIPE) in uv__create_stdio_pipe_pair() 442 if (flags & UV_WRITABLE_PIPE) in uv__create_stdio_pipe_pair() 530 handle->flags |= duplex_flags; in uv__set_pipe_handle() 718 if (flags & ~UV_PIPE_NO_TRUNCATE) { in uv_pipe_bind2() 799 handle->flags |= UV_HANDLE_BOUND; in uv_pipe_bind2() 897 if (flags & ~UV_PIPE_NO_TRUNCATE) { in uv_pipe_connect2() 1449 handle->flags |= UV_HANDLE_READING; in uv__pipe_read_start() [all …]
|
H A D | stream.c | 97 if (!(handle->flags & UV_HANDLE_READING)) in uv_read_stop() 106 handle->flags &= ~UV_HANDLE_READING; in uv_read_stop() 122 if (!(handle->flags & UV_HANDLE_WRITABLE)) { in uv_write() 174 if (stream->flags & UV_HANDLE_CLOSING) in uv_try_write() 176 if (!(stream->flags & UV_HANDLE_WRITABLE)) in uv_try_write() 206 if (!(handle->flags & UV_HANDLE_WRITABLE) || in uv_shutdown() 216 handle->flags &= ~UV_HANDLE_WRITABLE; in uv_shutdown() 233 return !!(handle->flags & UV_HANDLE_READABLE); in uv_is_readable() 238 return !!(handle->flags & UV_HANDLE_WRITABLE); in uv_is_writable() 247 handle->flags |= UV_HANDLE_BLOCKING_WRITES; in uv_stream_set_blocking() [all …]
|
H A D | signal.c | 98 if (handle->flags & UV_SIGNAL_ONE_SHOT_DISPATCHED) in RB_GENERATE_STATIC() 106 if (handle->flags & UV_SIGNAL_ONE_SHOT) in RB_GENERATE_STATIC() 107 handle->flags |= UV_SIGNAL_ONE_SHOT_DISPATCHED; in RB_GENERATE_STATIC() 221 handle->flags |= UV_SIGNAL_ONE_SHOT; in uv__signal_start() 251 if (handle->flags & UV_SIGNAL_ONE_SHOT) in uv__process_signal_req() 254 if (handle->flags & UV_HANDLE_CLOSING) { in uv__process_signal_req() 273 assert(handle->flags & UV_HANDLE_CLOSING); in uv__signal_endgame() 274 assert(!(handle->flags & UV_HANDLE_CLOSED)); in uv__signal_endgame() 279 handle->flags |= UV_HANDLE_CLOSED; in uv__signal_endgame()
|
H A D | tty.c | 250 tty->flags |= UV_HANDLE_BOUND; in uv_tty_init() 267 tty->flags |= UV_HANDLE_WRITABLE; in uv_tty_init() 346 DWORD flags; in uv_tty_set_mode() local 365 flags = ENABLE_WINDOW_INPUT; in uv_tty_set_mode() 374 if (tty->flags & UV_HANDLE_READING) { in uv_tty_set_mode() 397 tty->flags &= ~UV_HANDLE_TTY_RAW; in uv_tty_set_mode() 476 handle->flags |= UV_HANDLE_READ_PENDING; in uv__tty_queue_read_raw() 722 handle->flags &= ~UV_HANDLE_READING; in uv_process_tty_read_raw_req() 1015 handle->flags |= UV_HANDLE_READING; in uv__tty_read_start() 1047 handle->flags &= ~UV_HANDLE_READING; in uv__tty_read_stop() [all …]
|
H A D | winsock.c | 289 if (*flags & MSG_PEEK) { in uv__wsarecv_workaround() 293 if (*flags & MSG_PARTIAL) { in uv__wsarecv_workaround() 317 *flags = 0; in uv__wsarecv_workaround() 335 *flags = MSG_OOB; in uv__wsarecv_workaround() 340 *flags = MSG_PARTIAL | MSG_OOB; in uv__wsarecv_workaround() 345 *flags = MSG_PARTIAL; in uv__wsarecv_workaround() 387 if (*flags & MSG_PEEK) { in uv__wsarecvfrom_workaround() 391 if (*flags & MSG_PARTIAL) { in uv__wsarecvfrom_workaround() 415 *flags = 0; in uv__wsarecvfrom_workaround() 433 *flags = MSG_OOB; in uv__wsarecvfrom_workaround() [all …]
|
H A D | async.c | 32 if (handle->flags & UV_HANDLE_CLOSING && in uv__async_endgame() 34 assert(!(handle->flags & UV_HANDLE_CLOSED)); in uv__async_endgame() 76 assert(!(handle->flags & UV_HANDLE_CLOSING)); in uv_async_send() 93 if (handle->flags & UV_HANDLE_CLOSING) { in uv__process_async_wakeup_req()
|
H A D | fs.c | 367 req->flags = 0; in uv__fs_req_init() 391 fd_info.flags = flags; in fs__open() 397 flags = (flags & ~UV_FS_O_WRONLY) | UV_FS_O_RDWR; in fs__open() 404 flags |= UV_FS_O_RDWR; in fs__open() 1817 DWORD flags; in fs__stat_impl_from_path() local 2005 if (fd_info.flags) { in fs__ftruncate() 2015 if (fd_info.flags) { in fs__ftruncate() 2046 int flags; in fs__copyfile() local 2268 DWORD flags; in fs__utime_impl_from_path() local 2533 int flags; in fs__symlink() local [all …]
|
H A D | handle.c | 62 return (handle->flags & UV_HANDLE_ACTIVE) && in uv_is_active() 63 !(handle->flags & UV_HANDLE_CLOSING); in uv_is_active() 70 if (handle->flags & UV_HANDLE_CLOSING) { in uv_close() 152 return !!(handle->flags & (UV_HANDLE_CLOSING | UV_HANDLE_CLOSED)); in uv_is_closing()
|
/libuv/src/ |
H A D | uv-common.h | 154 unsigned int flags); 164 unsigned flags, 170 unsigned int flags); 265 (((h)->flags & UV_HANDLE_ACTIVE) != 0) 268 (((h)->flags & (UV_HANDLE_CLOSING | UV_HANDLE_CLOSED)) != 0) 280 if (((h)->flags & UV_HANDLE_ACTIVE) != 0) break; \ 281 (h)->flags |= UV_HANDLE_ACTIVE; \ 282 if (((h)->flags & UV_HANDLE_REF) != 0) uv__active_handle_add(h); \ 313 (((h)->flags & UV_HANDLE_REF) != 0) 418 uint32_t flags; member [all …]
|
H A D | uv-common.c | 326 unsigned int flags) { in uv_tcp_bind() argument 351 domain = flags & 0xFF; in uv_udp_init_ex() 356 extra_flags = flags & ~0xFF; in uv_udp_init_ex() 364 handle->flags |= UV_HANDLE_UDP_RECVMMSG; in uv_udp_init_ex() 377 unsigned int flags) { in uv_udp_bind() argument 435 if (handle->flags & UV_HANDLE_UDP_CONNECTED) in uv_udp_connect() 580 "R-"[!(h->flags & UV_HANDLE_REF)], in uv__print_handles() 863 if (!(h->flags & UV_HANDLE_INTERNAL)) in uv_loop_close() 901 if (stream->flags & UV_HANDLE_CLOSING) in uv_read_start() 904 if (stream->flags & UV_HANDLE_READING) in uv_read_start() [all …]
|
/libuv/src/unix/ |
H A D | tcp.c | 78 if (flags & UV_HANDLE_BOUND) in new_socket() 96 if (!(flags & UV_HANDLE_BOUND)) in maybe_new_socket() 108 handle->flags |= flags; in maybe_new_socket() 118 domain = flags & 0xFF; in uv_tcp_init_ex() 122 if (flags & ~0xFF) in uv_tcp_init_ex() 200 tcp->flags |= UV_HANDLE_BOUND; in uv__tcp_bind() 416 unsigned int flags; in uv__tcp_listen() local 422 flags = 0; in uv__tcp_listen() 428 flags |= UV_HANDLE_BOUND; in uv__tcp_listen() 614 int flags; in uv_socketpair() local [all …]
|
H A D | pipe.c | 73 if (flags & ~UV_PIPE_NO_TRUNCATE) in uv_pipe_bind2() 85 if (flags & UV_PIPE_NO_TRUNCATE) in uv_pipe_bind2() 135 handle->flags |= UV_HANDLE_BOUND; in uv_pipe_bind2() 190 int flags; in uv_pipe_open() local 193 flags = 0; in uv_pipe_open() 217 flags |= UV_HANDLE_READABLE; in uv_pipe_open() 219 flags |= UV_HANDLE_WRITABLE; in uv_pipe_open() 491 int flags = O_CLOEXEC; in uv_pipe() local 494 flags |= UV_FS_O_NONBLOCK; in uv_pipe() 496 if (pipe2(temp, flags)) in uv_pipe() [all …]
|
H A D | process.c | 123 process->flags &= ~UV_HANDLE_REAP; in uv__wait_children() 193 switch (container->flags & mask) { in uv__process_init_stdio() 206 if (container->flags & UV_INHERIT_FD) in uv__process_init_stdio() 226 int flags; in uv__process_open_stream() local 239 flags = 0; in uv__process_open_stream() 241 flags |= UV_HANDLE_READABLE; in uv__process_open_stream() 243 flags |= UV_HANDLE_WRITABLE; in uv__process_open_stream() 460 unsigned int flags; in uv__spawn_set_posix_spawn_attrs() local 489 flags = POSIX_SPAWN_CLOEXEC_DEFAULT | in uv__spawn_set_posix_spawn_attrs() 501 flags |= POSIX_SPAWN_SETSID; in uv__spawn_set_posix_spawn_attrs() [all …]
|
H A D | stream.c | 256 if (stream->flags & UV_HANDLE_CLOSING) in uv__stream_osx_select_cb() 350 s->async.flags |= UV_HANDLE_INTERNAL; in uv__stream_try_select() 412 stream->flags |= flags; in uv__stream_open() 569 client->flags |= UV_HANDLE_BOUND; in uv_accept() 654 stream->flags |= UV_HANDLE_SHUT; in uv__drain() 932 stream->flags |= UV_HANDLE_READ_EOF; in uv__stream_eof() 933 stream->flags &= ~UV_HANDLE_READING; in uv__stream_eof() 1165 stream->flags & UV_HANDLE_SHUT || in uv_shutdown() 1179 stream->flags &= ~UV_HANDLE_WRITABLE; in uv_shutdown() 1446 stream->flags |= UV_HANDLE_READING; in uv__read_start() [all …]
|
H A D | udp.c | 158 int flags; in uv__udp_recvmmsg() local 190 flags = UV_UDP_MMSG_CHUNK; in uv__udp_recvmmsg() 192 flags |= UV_UDP_PARTIAL; in uv__udp_recvmmsg() 199 flags); in uv__udp_recvmmsg() 217 int flags; in uv__udp_recvmsg() local 263 flags = 0; in uv__udp_recvmsg() 265 flags |= UV_UDP_PARTIAL; in uv__udp_recvmsg() 529 if (flags & UV_UDP_REUSEADDR) { in uv__udp_bind() 535 if (flags & UV_UDP_IPV6ONLY) { in uv__udp_bind() 560 handle->flags |= UV_HANDLE_BOUND; in uv__udp_bind() [all …]
|
H A D | getnameinfo.c | 51 req->flags); in uv__getnameinfo_work() 85 int flags) { in uv_getnameinfo() argument 104 req->flags = flags; in uv_getnameinfo()
|
H A D | kqueue.c | 220 if (loop->flags & UV_LOOP_BLOCK_SIGPROF) { in uv__io_poll() 230 if (lfields->flags & UV_METRICS_IDLE_TIME) { in uv__io_poll() 284 if (loop->flags & UV_LOOP_REAP_CHILDREN) { in uv__io_poll() 285 loop->flags &= ~UV_LOOP_REAP_CHILDREN; in uv__io_poll() 317 process->flags |= UV_HANDLE_REAP; in uv__io_poll() 318 loop->flags |= UV_LOOP_REAP_CHILDREN; in uv__io_poll() 372 if (ev->flags & EV_ERROR) in uv__io_poll() 391 if (loop->flags & UV_LOOP_REAP_CHILDREN) { in uv__io_poll() 392 loop->flags &= ~UV_LOOP_REAP_CHILDREN; in uv__io_poll() 532 unsigned int flags) { in uv_fs_event_start() argument [all …]
|
/libuv/test/ |
H A D | test-fs-fd-hash.c | 46 ASSERT_EQ(info.flags, fd + FD_DIFF); in assert_existent() 52 info.flags = fd + FD_DIFF; in assert_insertion() 61 ASSERT_EQ(info.flags, fd + FD_DIFF); in assert_removal() 103 info.flags = FD_DIFF + FD_DIFF; in TEST_IMPL() 109 ASSERT_EQ(info.flags, FD_DIFF + FD_DIFF); in TEST_IMPL() 114 info.flags = FD_DIFF; in TEST_IMPL()
|
H A D | test-fs-open-flags.c | 38 static int flags; variable 277 flags = add_flags | UV_FS_O_RDONLY; in fs_open_flags() 287 flags = add_flags | UV_FS_O_RDONLY | UV_FS_O_SYNC; in fs_open_flags() 297 flags = add_flags | UV_FS_O_RDWR; in fs_open_flags() 307 flags = add_flags | UV_FS_O_RDWR | UV_FS_O_SYNC; in fs_open_flags() 317 flags = add_flags | UV_FS_O_TRUNC | UV_FS_O_CREAT | UV_FS_O_WRONLY; in fs_open_flags() 336 flags = add_flags | UV_FS_O_TRUNC | UV_FS_O_CREAT | UV_FS_O_RDWR; in fs_open_flags() 346 flags = add_flags | UV_FS_O_TRUNC | UV_FS_O_CREAT | UV_FS_O_RDWR | in fs_open_flags() 387 flags = add_flags | UV_FS_O_APPEND | UV_FS_O_CREAT | UV_FS_O_RDWR; in fs_open_flags() 398 flags = add_flags | UV_FS_O_APPEND | UV_FS_O_CREAT | UV_FS_O_RDWR | in fs_open_flags() [all …]
|
H A D | test-spawn.c | 172 options.flags = 0; in init_process_options() 292 options.stdio[0].flags = UV_IGNORE; in TEST_IMPL() 336 options.stdio[0].flags = UV_IGNORE; in TEST_IMPL() 390 options.stdio[0].flags = UV_IGNORE; in TEST_IMPL() 452 options.stdio[0].flags = UV_IGNORE; in TEST_IMPL() 529 options.stdio[0].flags = UV_IGNORE; in TEST_IMPL() 635 options.stdio[0].flags = UV_IGNORE; in TEST_IMPL() 636 options.stdio[1].flags = UV_IGNORE; in TEST_IMPL() 637 options.stdio[2].flags = UV_IGNORE; in TEST_IMPL() 1976 options.flags = 0; in TEST_IMPL() [all …]
|
/libuv/docs/code/uvwget/ |
H A D | main.c | 84 int flags = 0; in curl_perform() local 85 if (status < 0) flags = CURL_CSELECT_ERR; in curl_perform() 86 if (!status && events & UV_READABLE) flags |= CURL_CSELECT_IN; in curl_perform() 87 if (!status && events & UV_WRITABLE) flags |= CURL_CSELECT_OUT; in curl_perform() 93 curl_multi_socket_action(curl_handle, context->sockfd, flags, &running_handles); in curl_perform()
|
/libuv/docs/code/proc-streams/ |
H A D | main.c | 32 child_stdio[0].flags = UV_IGNORE; in main() 33 child_stdio[1].flags = UV_IGNORE; in main() 34 child_stdio[2].flags = UV_INHERIT_FD; in main()
|