| /libuv/src/win/ |
| H A D | handle-inl.h | 32 #define DECREASE_ACTIVE_COUNT(loop, handle) \ argument
42 #define INCREASE_ACTIVE_COUNT(loop, handle) \ argument
51 #define DECREASE_PENDING_REQ_COUNT(handle) \ argument
63 #define uv__handle_closing(handle) \ argument
76 #define uv__handle_close(handle) \ argument
88 INLINE static void uv__want_endgame(uv_loop_t* loop, uv_handle_t* handle) { in uv__want_endgame()
99 uv_handle_t* handle; in uv__process_endgames() local
173 HANDLE handle; in uv__get_osfhandle() local
|
| H A D | async.c | 31 void uv__async_endgame(uv_loop_t* loop, uv_async_t* handle) { in uv__async_endgame()
40 int uv_async_init(uv_loop_t* loop, uv_async_t* handle, uv_async_cb async_cb) { in uv_async_init()
57 void uv__async_close(uv_loop_t* loop, uv_async_t* handle) { in uv__async_close()
66 int uv_async_send(uv_async_t* handle) { in uv_async_send()
86 void uv__process_async_wakeup_req(uv_loop_t* loop, uv_async_t* handle, in uv__process_async_wakeup_req()
|
| H A D | signal.c | 82 uv_signal_t* handle; in RB_GENERATE_STATIC() local
147 int uv_signal_init(uv_loop_t* loop, uv_signal_t* handle) { in uv_signal_init()
160 int uv_signal_stop(uv_signal_t* handle) { in uv_signal_stop()
181 int uv_signal_start(uv_signal_t* handle, uv_signal_cb signal_cb, int signum) { in uv_signal_start()
186 int uv_signal_start_oneshot(uv_signal_t* handle, in uv_signal_start_oneshot()
193 int uv__signal_start(uv_signal_t* handle, in uv__signal_start()
234 void uv__process_signal_req(uv_loop_t* loop, uv_signal_t* handle, in uv__process_signal_req()
262 void uv__signal_close(uv_loop_t* loop, uv_signal_t* handle) { in uv__signal_close()
272 void uv__signal_endgame(uv_loop_t* loop, uv_signal_t* handle) { in uv__signal_endgame()
|
| H A D | udp.c | 34 int uv_udp_getpeername(const uv_udp_t* handle, in uv_udp_getpeername()
46 int uv_udp_getsockname(const uv_udp_t* handle, in uv_udp_getsockname()
124 uv_udp_t* handle, in uv__udp_init_ex()
344 int uv__udp_recv_stop(uv_udp_t* handle) { in uv__udp_recv_stop()
355 uv_udp_t* handle, in uv__send()
768 int uv_udp_set_membership(uv_udp_t* handle, in uv_udp_set_membership()
899 int uv__udp_is_bound(uv_udp_t* handle) { in uv__udp_is_bound()
1016 int uv__udp_connect(uv_udp_t* handle, in uv__udp_connect()
1045 int uv__udp_disconnect(uv_udp_t* handle) { in uv__udp_disconnect()
1064 uv_udp_t* handle, in uv__udp_send()
[all …]
|
| H A D | tcp.c | 80 uv_tcp_t* handle, in uv__tcp_set_socket()
288 static int uv__tcp_try_bind(uv_tcp_t* handle, in uv__tcp_try_bind()
357 uv_tcp_t* handle; in post_completion() local
376 uv_tcp_t* handle; in post_write_completion() local
867 int uv_tcp_getsockname(const uv_tcp_t* handle, in uv_tcp_getsockname()
879 int uv_tcp_getpeername(const uv_tcp_t* handle, in uv_tcp_getpeername()
893 uv_tcp_t* handle, in uv__tcp_write()
958 int uv__tcp_try_write(uv_tcp_t* handle, in uv__tcp_try_write()
1245 int uv__tcp_xfer_export(uv_tcp_t* handle, in uv__tcp_xfer_export()
1535 int uv__tcp_bind(uv_tcp_t* handle, in uv__tcp_bind()
[all …]
|
| H A D | handle.c | 32 HANDLE handle; in uv_guess_handle() local
61 int uv_is_active(const uv_handle_t* handle) { in uv_is_active()
67 void uv_close(uv_handle_t* handle, uv_close_cb cb) { in uv_close()
151 int uv_is_closing(const uv_handle_t* handle) { in uv_is_closing()
|
| H A D | poll.c | 77 static void uv__fast_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) { in uv__fast_poll_submit_poll_req()
139 static void uv__fast_poll_process_poll_req(uv_loop_t* loop, uv_poll_t* handle, in uv__fast_poll_process_poll_req()
271 uv_poll_t* handle = (uv_poll_t*) req->data; in uv__slow_poll_thread_proc() local
368 static void uv__slow_poll_process_poll_req(uv_loop_t* loop, uv_poll_t* handle, in uv__slow_poll_process_poll_req()
410 int uv_poll_init(uv_loop_t* loop, uv_poll_t* handle, int fd) { in uv_poll_init()
415 int uv_poll_init_socket(uv_loop_t* loop, uv_poll_t* handle, in uv_poll_init_socket()
487 static int uv__poll_set(uv_poll_t* handle, int events, uv_poll_cb cb) { in uv__poll_set()
518 int uv_poll_start(uv_poll_t* handle, int events, uv_poll_cb cb) { in uv_poll_start()
523 int uv_poll_stop(uv_poll_t* handle) { in uv_poll_stop()
537 int uv__poll_close(uv_loop_t* loop, uv_poll_t* handle) { in uv__poll_close()
[all …]
|
| H A D | stream.c | 70 int uv__read_start(uv_stream_t* handle, in uv__read_start()
94 int uv_read_stop(uv_stream_t* handle) { in uv_read_stop()
115 uv_stream_t* handle, in uv_write()
147 uv_stream_t* handle, in uv_write2()
203 int uv_shutdown(uv_shutdown_t* req, uv_stream_t* handle, uv_shutdown_cb cb) { in uv_shutdown()
232 int uv_is_readable(const uv_stream_t* handle) { in uv_is_readable()
237 int uv_is_writable(const uv_stream_t* handle) { in uv_is_writable()
242 int uv_stream_set_blocking(uv_stream_t* handle, int blocking) { in uv_stream_set_blocking()
|
| H A D | pipe.c | 575 uv_pipe_t* handle; in pipe_shutdown_thread_proc() local
709 int uv_pipe_bind2(uv_pipe_t* handle, in uv_pipe_bind2()
816 uv_pipe_t* handle; in pipe_connect_thread_proc() local
857 uv_pipe_t* handle, in uv_pipe_connect()
877 uv_pipe_t* handle, in uv_pipe_connect2()
1343 uv_tcp_t* handle; in post_completion_read_wait() local
1362 uv_tcp_t* handle; in post_completion_write_wait() local
1443 int uv__pipe_read_start(uv_pipe_t* handle, in uv__pipe_read_start()
1748 uv_pipe_t* handle, in uv__pipe_write_ipc()
1850 uv_pipe_t* handle, in uv__pipe_write()
[all …]
|
| /libuv/src/ |
| H A D | timer.c | 58 int uv_timer_init(uv_loop_t* loop, uv_timer_t* handle) { in uv_timer_init()
68 int uv_timer_start(uv_timer_t* handle, in uv_timer_start()
98 int uv_timer_stop(uv_timer_t* handle) { in uv_timer_stop()
113 int uv_timer_again(uv_timer_t* handle) { in uv_timer_again()
126 void uv_timer_set_repeat(uv_timer_t* handle, uint64_t repeat) { in uv_timer_set_repeat()
131 uint64_t uv_timer_get_repeat(const uv_timer_t* handle) { in uv_timer_get_repeat()
136 uint64_t uv_timer_get_due_in(const uv_timer_t* handle) { in uv_timer_get_due_in()
146 const uv_timer_t* handle; in uv__next_timeout() local
167 uv_timer_t* handle; in uv__run_timers() local
198 void uv__timer_close(uv_timer_t* handle) { in uv__timer_close()
|
| H A D | fs-poll.c | 59 int uv_fs_poll_init(uv_loop_t* loop, uv_fs_poll_t* handle) { in uv_fs_poll_init()
66 int uv_fs_poll_start(uv_fs_poll_t* handle, in uv_fs_poll_start()
116 int uv_fs_poll_stop(uv_fs_poll_t* handle) { in uv_fs_poll_stop()
138 int uv_fs_poll_getpath(uv_fs_poll_t* handle, char* buffer, size_t* size) { in uv_fs_poll_getpath()
164 void uv__fs_poll_close(uv_fs_poll_t* handle) { in uv__fs_poll_close()
189 uv_fs_poll_t* handle; in poll_cb() local
238 uv_fs_poll_t* handle; in timer_close_cb() local
281 void uv__fs_poll_endgame(uv_loop_t* loop, uv_fs_poll_t* handle) { in uv__fs_poll_endgame()
|
| H A D | uv-data-getter-setters.c | 36 uv_handle_type uv_handle_get_type(const uv_handle_t* handle) { in uv_handle_get_type()
40 void* uv_handle_get_data(const uv_handle_t* handle) { in uv_handle_get_data()
44 uv_loop_t* uv_handle_get_loop(const uv_handle_t* handle) { in uv_handle_get_loop()
48 void uv_handle_set_data(uv_handle_t* handle, void* data) { in uv_handle_set_data()
81 size_t uv_udp_get_send_queue_size(const uv_udp_t* handle) { in uv_udp_get_send_queue_size()
85 size_t uv_udp_get_send_queue_count(const uv_udp_t* handle) { in uv_udp_get_send_queue_count()
|
| /libuv/test/ |
| H A D | test-timer.c | 41 static void once_close_cb(uv_handle_t* handle) { in once_close_cb()
51 static void once_cb(uv_timer_t* handle) { in once_cb()
65 static void twice_close_cb(uv_handle_t* handle) { in twice_close_cb()
74 static void twice_cb(uv_timer_t* handle) { in twice_cb()
96 static void repeat_cb(uv_timer_t* handle) { in repeat_cb()
110 static void never_cb(uv_timer_t* handle) { in never_cb()
185 uv_timer_t handle; in TEST_IMPL() local
197 static void order_cb_a(uv_timer_t *handle) { in order_cb_a()
202 static void order_cb_b(uv_timer_t *handle) { in order_cb_b()
353 uv_timer_t handle; in TEST_IMPL() local
[all …]
|
| H A D | test-loop-handles.c | 110 static void timer_cb(uv_timer_t* handle) { in timer_cb()
115 static void idle_2_close_cb(uv_handle_t* handle) { in idle_2_close_cb()
128 static void idle_2_cb(uv_idle_t* handle) { in idle_2_cb()
140 static void idle_1_cb(uv_idle_t* handle) { in idle_1_cb()
169 static void idle_1_close_cb(uv_handle_t* handle) { in idle_1_close_cb()
179 static void prepare_1_close_cb(uv_handle_t* handle) { in prepare_1_close_cb()
188 static void check_close_cb(uv_handle_t* handle) { in check_close_cb()
197 static void prepare_2_close_cb(uv_handle_t* handle) { in prepare_2_close_cb()
206 static void check_cb(uv_check_t* handle) { in check_cb()
242 static void prepare_2_cb(uv_prepare_t* handle) { in prepare_2_cb()
[all …]
|
| H A D | test-idle.c | 36 static void close_cb(uv_handle_t* handle) { in close_cb()
41 static void timer_cb(uv_timer_t* handle) { in timer_cb()
54 static void idle_cb(uv_idle_t* handle) { in idle_cb()
63 static void check_cb(uv_check_t* handle) { in check_cb()
102 static void idle_stop(uv_idle_t* handle) { in idle_stop()
|
| H A D | test-tcp-unexpected-read.c | 36 static void check_cb(uv_check_t* handle) { in check_cb()
41 static void timer_cb(uv_timer_t* handle) { in timer_cb()
50 static void alloc_cb(uv_handle_t* handle, in alloc_cb()
57 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb()
74 static void connection_cb(uv_stream_t* handle, int status) { in connection_cb()
|
| H A D | test-timer-from-check.c | 34 static void prepare_cb(uv_prepare_t* handle) { in prepare_cb()
43 static void timer_cb(uv_timer_t* handle) { in timer_cb()
52 static void check_cb(uv_check_t* handle) { in check_cb()
|
| H A D | test-udp-try-send.c | 29 #define CHECK_HANDLE(handle) \ argument
40 static void alloc_cb(uv_handle_t* handle, in alloc_cb()
51 static void close_cb(uv_handle_t* handle) { in close_cb()
58 static void sv_recv_cb(uv_udp_t* handle, in sv_recv_cb()
|
| H A D | test-close-order.c | 34 static void close_cb(uv_handle_t* handle) { in close_cb()
41 static void check_cb(uv_check_t* handle) { in check_cb()
51 static void timer_cb(uv_timer_t* handle) { in timer_cb()
|
| H A D | test-fs-event.c | 53 static void fs_event_fail(uv_fs_event_t* handle, in fs_event_fail()
121 static void close_cb(uv_handle_t* handle) { in close_cb()
126 static void fail_cb(uv_fs_event_t* handle, in fail_cb()
148 static void fs_event_cb_del_dir(uv_fs_event_t* handle, in fs_event_cb_del_dir()
170 static void fs_event_create_files(uv_timer_t* handle) { in fs_event_create_files()
184 static void fs_event_del_dir(uv_timer_t* handle) { in fs_event_del_dir()
193 static void fs_event_unlink_files(uv_timer_t* handle) { in fs_event_unlink_files()
380 static void timer_cb_file(uv_timer_t* handle) { in timer_cb_file()
397 static void timer_cb_exact(uv_timer_t* handle) { in timer_cb_exact()
419 static void fs_event_cb_close(uv_fs_event_t* handle, in fs_event_cb_close()
[all …]
|
| /libuv/src/unix/ |
| H A D | poll.c | 31 uv_poll_t* handle; in uv__poll_io() local
68 int uv_poll_init(uv_loop_t* loop, uv_poll_t* handle, int fd) { in uv_poll_init()
97 int uv_poll_init_socket(uv_loop_t* loop, uv_poll_t* handle, in uv_poll_init_socket()
103 static void uv__poll_stop(uv_poll_t* handle) { in uv__poll_stop()
112 int uv_poll_stop(uv_poll_t* handle) { in uv_poll_stop()
119 int uv_poll_start(uv_poll_t* handle, int pevents, uv_poll_cb poll_cb) { in uv_poll_start()
158 void uv__poll_close(uv_poll_t* handle) { in uv__poll_close()
|
| H A D | udp.c | 52 void uv__udp_close(uv_udp_t* handle) { in uv__udp_close()
63 void uv__udp_finish_close(uv_udp_t* handle) { in uv__udp_finish_close()
136 uv_udp_t* handle; in uv__udp_io() local
514 int uv__udp_bind(uv_udp_t* handle, in uv__udp_bind()
625 int uv__udp_connect(uv_udp_t* handle, in uv__udp_connect()
678 int uv__udp_disconnect(uv_udp_t* handle) { in uv__udp_disconnect()
722 uv_udp_t* handle, in uv__udp_send()
787 int uv__udp_try_send(uv_udp_t* handle, in uv__udp_try_send()
1027 uv_udp_t* handle, in uv__udp_init_ex()
1368 int uv__udp_recv_start(uv_udp_t* handle, in uv__udp_recv_start()
[all …]
|
| H A D | pipe.c | 46 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
56 int uv_pipe_bind(uv_pipe_t* handle, const char* name) { in uv_pipe_bind()
61 int uv_pipe_bind2(uv_pipe_t* handle, in uv_pipe_bind2()
177 void uv__pipe_close(uv_pipe_t* handle) { in uv__pipe_close()
194 int uv_pipe_open(uv_pipe_t* handle, uv_file fd) { in uv_pipe_open()
231 uv_pipe_t* handle, in uv_pipe_connect()
254 uv_pipe_t* handle, in uv_pipe_connect2()
348 static int uv__pipe_getsockpeername(const uv_pipe_t* handle, in uv__pipe_getsockpeername()
416 int uv_pipe_pending_count(uv_pipe_t* handle) { in uv_pipe_pending_count()
433 uv_handle_type uv_pipe_pending_type(uv_pipe_t* handle) { in uv_pipe_pending_type()
[all …]
|
| H A D | no-fsevents.c | 27 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) { in uv_fs_event_init()
31 int uv_fs_event_start(uv_fs_event_t* handle, uv_fs_event_cb cb, in uv_fs_event_start()
36 int uv_fs_event_stop(uv_fs_event_t* handle) { in uv_fs_event_stop()
40 void uv__fs_event_close(uv_fs_event_t* handle) { in uv__fs_event_close()
|
| H A D | signal.c | 36 uv_signal_t* handle; member
168 uv_signal_t* handle; in uv__signal_first_handle() local
185 uv_signal_t* handle; in uv__signal_handler() local
293 uv_handle_t* handle = uv__queue_data(q, uv_handle_t, handle_queue); in uv__signal_loop_fork() local
336 int uv_signal_init(uv_loop_t* loop, uv_signal_t* handle) { in uv_signal_init()
352 void uv__signal_close(uv_signal_t* handle) { in uv__signal_close()
362 int uv_signal_start_oneshot(uv_signal_t* handle, in uv_signal_start_oneshot()
369 static int uv__signal_start(uv_signal_t* handle, in uv__signal_start()
437 uv_signal_t* handle; in uv__signal_event() local
530 int uv_signal_stop(uv_signal_t* handle) { in uv_signal_stop()
[all …]
|
