Home
last modified time | relevance | path

Searched refs:flags (Results 1 – 25 of 114) sorted by relevance

12345

/libuv/src/win/
H A Dtcp.c143 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()
298 if (flags & UV_TCP_REUSEPORT) in uv__tcp_try_bind()
481 DWORD bytes, flags; in uv__tcp_queue_read() local
500 flags = 0; in uv__tcp_queue_read()
505 &flags, in uv__tcp_queue_read()
984 DWORD bytes, flags, err; in uv__process_tcp_read_req() local
1051 flags = 0; in uv__process_tcp_read_req()
1056 &flags, in uv__process_tcp_read_req()
[all …]
H A Dudp.c114 handle->flags |= UV_HANDLE_IPV6; in uv__udp_set_socket()
125 unsigned flags, in uv__udp_init_ex() argument
206 if (flags & UV_UDP_REUSEPORT) in uv__udp_maybe_bind()
227 if (flags & UV_UDP_REUSEADDR) { in uv__udp_maybe_bind()
271 DWORD bytes, flags; in uv__udp_queue_recv() local
284 flags = MSG_PEEK; in uv__udp_queue_recv()
447 DWORD bytes, err, flags; in uv__process_udp_recv_req() local
468 flags = 0; in uv__process_udp_recv_req()
474 &flags, in uv__process_udp_recv_req()
613 if ((handle->flags & UV_HANDLE_BOUND) && !(handle->flags & UV_HANDLE_IPV6)) in uv__udp_set_membership6()
[all …]
H A Dhandle-inl.h35 !((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 Dpipe.c75 uint32_t flags; member
412 if (flags & UV_READABLE_PIPE) { in uv__create_stdio_pipe_pair()
419 if (flags & UV_WRITABLE_PIPE) { in uv__create_stdio_pipe_pair()
445 if (flags & UV_READABLE_PIPE) in uv__create_stdio_pipe_pair()
447 if (flags & UV_WRITABLE_PIPE) in uv__create_stdio_pipe_pair()
535 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()
1448 handle->flags |= UV_HANDLE_READING; in uv__pipe_read_start()
[all …]
H A Dstream.c97 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 Dsignal.c98 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 Dtty.c250 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 Dwinsock.c289 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 Dasync.c32 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 Dfs.c389 req->flags = 0; in uv__fs_req_init()
413 fd_info.flags = flags; in fs__open()
419 flags = (flags & ~UV_FS_O_WRONLY) | UV_FS_O_RDWR; in fs__open()
426 flags |= UV_FS_O_RDWR; in fs__open()
1949 DWORD flags; in fs__stat_impl_from_path() local
2148 if (fd_info.flags) { in fs__ftruncate()
2158 if (fd_info.flags) { in fs__ftruncate()
2189 int flags; in fs__copyfile() local
2411 DWORD flags; in fs__utime_impl_from_path() local
2677 int flags; in fs__symlink() local
[all …]
H A Dhandle.c62 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/unix/
H A Dtcp.c78 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()
206 tcp->flags |= UV_HANDLE_BOUND; in uv__tcp_bind()
422 unsigned int flags; in uv__tcp_listen() local
428 flags = 0; in uv__tcp_listen()
434 flags |= UV_HANDLE_BOUND; in uv__tcp_listen()
634 int flags; in uv_socketpair() local
[all …]
H A Dpipe.c73 if (flags & ~UV_PIPE_NO_TRUNCATE) in uv_pipe_bind2()
90 if (flags & UV_PIPE_NO_TRUNCATE) in uv_pipe_bind2()
140 handle->flags |= UV_HANDLE_BOUND; in uv_pipe_bind2()
195 int flags; in uv_pipe_open() local
198 flags = 0; in uv_pipe_open()
222 flags |= UV_HANDLE_READABLE; in uv_pipe_open()
224 flags |= UV_HANDLE_WRITABLE; in uv_pipe_open()
277 if (flags & UV_PIPE_NO_TRUNCATE) in uv_pipe_connect2()
510 int flags = O_CLOEXEC; in uv_pipe() local
513 flags |= UV_FS_O_NONBLOCK; in uv_pipe()
[all …]
H A Dprocess.c124 process->flags &= ~UV_HANDLE_REAP; in uv__wait_children()
194 switch (container->flags & mask) { in uv__process_init_stdio()
207 if (container->flags & UV_INHERIT_FD) in uv__process_init_stdio()
227 int flags; in uv__process_open_stream() local
240 flags = 0; in uv__process_open_stream()
242 flags |= UV_HANDLE_READABLE; in uv__process_open_stream()
244 flags |= UV_HANDLE_WRITABLE; in uv__process_open_stream()
461 unsigned int flags; in uv__spawn_set_posix_spawn_attrs() local
490 flags = POSIX_SPAWN_CLOEXEC_DEFAULT | in uv__spawn_set_posix_spawn_attrs()
502 flags |= POSIX_SPAWN_SETSID; in uv__spawn_set_posix_spawn_attrs()
[all …]
H A Dstream.c256 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()
933 stream->flags |= UV_HANDLE_READ_EOF; in uv__stream_eof()
934 stream->flags &= ~UV_HANDLE_READING; in uv__stream_eof()
1166 stream->flags & UV_HANDLE_SHUT || in uv_shutdown()
1180 stream->flags &= ~UV_HANDLE_WRITABLE; in uv_shutdown()
1447 stream->flags |= UV_HANDLE_READING; in uv__read_start()
[all …]
H A Dudp.c158 int flags; in uv__udp_recvmmsg() local
197 flags = UV_UDP_MMSG_CHUNK; in uv__udp_recvmmsg()
199 flags |= UV_UDP_PARTIAL; in uv__udp_recvmmsg()
206 flags); in uv__udp_recvmmsg()
224 int flags; in uv__udp_recvmsg() local
270 flags = 0; in uv__udp_recvmsg()
272 flags |= UV_UDP_PARTIAL; in uv__udp_recvmsg()
546 if (flags & UV_UDP_REUSEADDR) { in uv__udp_bind()
552 if (flags & UV_UDP_REUSEPORT) { in uv__udp_bind()
558 if (flags & UV_UDP_IPV6ONLY) { in uv__udp_bind()
[all …]
H A Dgetnameinfo.c51 req->flags); in uv__getnameinfo_work()
85 int flags) { in uv_getnameinfo() argument
104 req->flags = flags; in uv_getnameinfo()
H A Dkqueue.c247 if (loop->flags & UV_LOOP_BLOCK_SIGPROF) { in uv__io_poll()
257 if (lfields->flags & UV_METRICS_IDLE_TIME) { in uv__io_poll()
311 if (loop->flags & UV_LOOP_REAP_CHILDREN) { in uv__io_poll()
312 loop->flags &= ~UV_LOOP_REAP_CHILDREN; in uv__io_poll()
344 process->flags |= UV_HANDLE_REAP; in uv__io_poll()
345 loop->flags |= UV_LOOP_REAP_CHILDREN; in uv__io_poll()
410 if (ev->flags & EV_ERROR) in uv__io_poll()
429 if (loop->flags & UV_LOOP_REAP_CHILDREN) { in uv__io_poll()
430 loop->flags &= ~UV_LOOP_REAP_CHILDREN; in uv__io_poll()
570 unsigned int flags) { in uv_fs_event_start() argument
[all …]
/libuv/src/
H A Duv-common.h154 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); \
288 if (((h)->flags & UV_HANDLE_ACTIVE) == 0) break; \
313 (((h)->flags & UV_HANDLE_REF) != 0)
[all …]
H A Duv-common.c326 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/test/
H A Dtest-fs-fd-hash.c46 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 Dtest-fs-open-flags.c38 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 Dtest-spawn.c172 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 Dmain.c84 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 Dmain.c32 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()

Completed in 120 milliseconds

12345