Home
last modified time | relevance | path

Searched defs:loop (Results 1 – 25 of 162) sorted by relevance

1234567

/libuv/src/unix/
H A Dposix-poll.c36 int uv__platform_loop_init(uv_loop_t* loop) { in uv__platform_loop_init()
44 void uv__platform_loop_delete(uv_loop_t* loop) { in uv__platform_loop_delete()
49 int uv__io_fork(uv_loop_t* loop) { in uv__io_fork()
55 static void uv__pollfds_maybe_resize(uv_loop_t* loop) { in uv__pollfds_maybe_resize()
78 static void uv__pollfds_swap(uv_loop_t* loop, size_t l, size_t r) { in uv__pollfds_swap()
86 static void uv__pollfds_add(uv_loop_t* loop, uv__io_t* w) { in uv__pollfds_add()
107 static void uv__pollfds_del(uv_loop_t* loop, int fd) { in uv__pollfds_del()
134 void uv__io_poll(uv_loop_t* loop, int timeout) { in uv__io_poll()
347 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) { in uv__platform_invalidate_fd()
367 int uv__io_check_fd(uv_loop_t* loop, int fd) { in uv__io_check_fd()
H A Dloop.c30 int uv_loop_init(uv_loop_t* loop) { in uv_loop_init()
132 int uv_loop_fork(uv_loop_t* loop) { in uv_loop_fork()
165 void uv__loop_close(uv_loop_t* loop) { in uv__loop_close()
211 int uv__loop_configure(uv_loop_t* loop, uv_loop_option option, va_list ap) { in uv__loop_configure()
H A Dasync.c74 int uv_async_init(uv_loop_t* loop, uv_async_t* handle, uv_async_cb async_cb) { in uv_async_init()
160 static void uv__async_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) {
217 static void uv__async_send(uv_loop_t* loop) {
275 static int uv__async_start(uv_loop_t* loop) {
343 void uv__async_stop(uv_loop_t* loop) {
377 int uv__async_fork(uv_loop_t* loop) {
H A Dfs.c1787 int uv_fs_access(uv_loop_t* loop, in uv_fs_access()
1799 int uv_fs_chmod(uv_loop_t* loop, in uv_fs_chmod()
1811 int uv_fs_chown(uv_loop_t* loop, in uv_fs_chown()
1835 int uv_fs_fchmod(uv_loop_t* loop, in uv_fs_fchmod()
1847 int uv_fs_fchown(uv_loop_t* loop, in uv_fs_fchown()
1861 int uv_fs_lchown(uv_loop_t* loop, in uv_fs_lchown()
1954 int uv_fs_link(uv_loop_t* loop, in uv_fs_link()
1968 int uv_fs_mkdir(uv_loop_t* loop, in uv_fs_mkdir()
2007 int uv_fs_open(uv_loop_t* loop, in uv_fs_open()
2199 int uv_fs_utime(uv_loop_t* loop, in uv_fs_utime()
[all …]
H A Dkqueue.c54 int uv__kqueue_init(uv_loop_t* loop) { in uv__kqueue_init()
69 int uv__io_fork(uv_loop_t* loop) { in uv__io_fork()
99 int uv__io_check_fd(uv_loop_t* loop, int fd) { in uv__io_check_fd()
165 void uv__io_poll(uv_loop_t* loop, int timeout) { in uv__io_poll()
485 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) { in uv__platform_invalidate_fd()
505 static void uv__fs_event(uv_loop_t* loop, uv__io_t* w, unsigned int fflags) { in uv__fs_event()
567 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) { in uv_fs_event_init()
H A Dpoll.c30 static void uv__poll_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__poll_io()
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()
H A Dinternal.h364 #define uv__iou_fs_close(loop, req) 0 argument
365 #define uv__iou_fs_fsync_or_fdatasync(loop, req, fsync_flags) 0 argument
366 #define uv__iou_fs_link(loop, req) 0 argument
367 #define uv__iou_fs_mkdir(loop, req) 0 argument
368 #define uv__iou_fs_open(loop, req) 0 argument
369 #define uv__iou_fs_read_or_write(loop, req, is_read) 0 argument
370 #define uv__iou_fs_rename(loop, req) 0 argument
371 #define uv__iou_fs_statx(loop, req, is_fstat, is_lstat) 0 argument
372 #define uv__iou_fs_symlink(loop, req) 0 argument
373 #define uv__iou_fs_unlink(loop, req) 0 argument
[all …]
/libuv/src/win/
H A Dasync.c31 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()
67 uv_loop_t* loop = handle->loop; in uv_async_send() local
86 void uv__process_async_wakeup_req(uv_loop_t* loop, uv_async_t* handle, in uv__process_async_wakeup_req()
H A Dcore.c93 static int uv__loops_add(uv_loop_t* loop) { in uv__loops_add()
121 static void uv__loops_remove(uv_loop_t* loop) { in uv__loops_remove()
167 uv_loop_t* loop; in uv__wake_all_loops() local
227 int uv_loop_init(uv_loop_t* loop) { in uv_loop_init()
325 void uv_update_time(uv_loop_t* loop) { in uv_update_time()
337 void uv__loop_close(uv_loop_t* loop) { in uv__loop_close()
391 int uv_backend_fd(const uv_loop_t* loop) { in uv_backend_fd()
396 int uv_loop_fork(uv_loop_t* loop) { in uv_loop_fork()
409 int uv_loop_alive(const uv_loop_t* loop) { in uv_loop_alive()
414 int uv_backend_timeout(const uv_loop_t* loop) { in uv_backend_timeout()
[all …]
H A Dhandle-inl.h32 #define DECREASE_ACTIVE_COUNT(loop, handle) \ argument
42 #define INCREASE_ACTIVE_COUNT(loop, handle) \ argument
88 INLINE static void uv__want_endgame(uv_loop_t* loop, uv_handle_t* handle) { in uv__want_endgame()
98 INLINE static void uv__process_endgames(uv_loop_t* loop) { in uv__process_endgames()
H A Dreq-inl.h56 #define REGISTER_HANDLE_REQ(loop, handle) \ argument
62 #define UNREGISTER_HANDLE_REQ(loop, handle) \ argument
76 #define POST_COMPLETION_FOR_REQ(loop, req) \ argument
90 INLINE static void uv__insert_pending_req(uv_loop_t* loop, uv_req_t* req) { in uv__insert_pending_req()
114 #define DELEGATE_STREAM_REQ(loop, req, method, handle_at) \ argument
141 INLINE static void uv__process_reqs(uv_loop_t* loop) { in uv__process_reqs()
H A Dpoll.c77 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()
238 static SOCKET uv__fast_poll_get_peer_socket(uv_loop_t* loop, in uv__fast_poll_get_peer_socket()
338 static void uv__slow_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) { in uv__slow_poll_submit_poll_req()
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()
528 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle, uv_req_t* req) { in uv__process_poll_req()
537 int uv__poll_close(uv_loop_t* loop, uv_poll_t* handle) { in uv__poll_close()
578 void uv__poll_endgame(uv_loop_t* loop, uv_poll_t* handle) { in uv__poll_endgame()
H A Dpipe.c574 uv_loop_t* loop; in pipe_shutdown_thread_proc() local
713 uv_loop_t* loop = handle->loop; in uv_pipe_bind2() local
815 uv_loop_t* loop; in pipe_connect_thread_proc() local
860 uv_loop_t* loop; in uv_pipe_connect() local
882 uv_loop_t* loop; in uv_pipe_connect2() local
1144 uv_loop_t* loop = server->loop; in uv__pipe_accept() local
1204 uv_loop_t* loop = handle->loop; in uv__pipe_listen() local
1245 uv_loop_t* loop = handle->loop; in uv_pipe_zero_readfile_thread_proc() local
1320 uv_loop_t* loop = handle->loop; in uv_pipe_writefile_thread_proc() local
1446 uv_loop_t* loop = handle->loop; in uv__pipe_read_start() local
[all …]
H A Dfs-event.c36 static void uv__fs_event_queue_readdirchanges(uv_loop_t* loop, in uv__fs_event_queue_readdirchanges()
140 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) { in uv_fs_event_init()
416 void uv__process_fs_event_req(uv_loop_t* loop, uv_req_t* req, in uv__process_fs_event_req()
593 void uv__fs_event_close(uv_loop_t* loop, uv_fs_event_t* handle) { in uv__fs_event_close()
605 void uv__fs_event_endgame(uv_loop_t* loop, uv_fs_event_t* handle) { in uv__fs_event_endgame()
H A Dtcp.c79 static int uv__tcp_set_socket(uv_loop_t* loop, in uv__tcp_set_socket()
201 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* handle) { in uv_tcp_init()
233 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle) { in uv__tcp_endgame()
394 uv_loop_t* loop = handle->loop; in uv__tcp_queue_accept() local
477 static void uv__tcp_queue_read(uv_loop_t* loop, uv_tcp_t* handle) { in uv__tcp_queue_read()
709 uv_loop_t* loop = handle->loop; in uv__tcp_read_start() local
772 uv_loop_t* loop = handle->loop; in uv__tcp_try_connect() local
891 int uv__tcp_write(uv_loop_t* loop, in uv__tcp_write()
982 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, in uv__process_tcp_read_req()
1111 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle, in uv__process_tcp_write_req()
[all …]
H A Dsignal.c147 int uv_signal_init(uv_loop_t* loop, uv_signal_t* handle) { in uv_signal_init()
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()
/libuv/test/
H A Dtest-signal.c53 uv_loop_t* loop; in TEST_IMPL() local
133 static void start_watcher(uv_loop_t* loop, in start_watcher()
148 static void start_timer(uv_loop_t* loop, int signum, struct timer_ctx* ctx) { in start_timer()
159 uv_loop_t* loop; in TEST_IMPL() local
191 uv_loop_t* loop; in TEST_IMPL() local
216 uv_loop_t* loop; in TEST_IMPL() local
245 uv_loop_t* loop; in TEST_IMPL() local
H A Dtest-fs-event.c584 uv_loop_t* loop; in TEST_IMPL() local
682 uv_loop_t* loop; in TEST_IMPL() local
732 uv_loop_t* loop; in TEST_IMPL() local
754 uv_loop_t* loop; in TEST_IMPL() local
806 uv_loop_t* loop; in TEST_IMPL() local
925 uv_loop_t* loop; in TEST_IMPL() local
949 uv_loop_t* loop; in TEST_IMPL() local
983 uv_loop_t* loop; in TEST_IMPL() local
1025 uv_loop_t* loop; in TEST_IMPL() local
1064 uv_loop_t* loop; in TEST_IMPL() local
[all …]
H A Dtest-tty.c48 uv_loop_t* loop = uv_default_loop(); in TEST_IMPL() local
169 uv_loop_t* loop = uv_default_loop(); in TEST_IMPL() local
224 uv_loop_t* loop; in TEST_IMPL() local
270 uv_loop_t* loop; in TEST_IMPL() local
347 uv_loop_t loop; in TEST_IMPL() local
436 uv_loop_t loop; in TEST_IMPL() local
H A Dtest-queue-foreach-delete.c102 #define INIT_AND_START(name, loop) \ argument
138 static void init_and_start_fs_events(uv_loop_t* loop) { in init_and_start_fs_events()
171 uv_loop_t* loop; in TEST_IMPL() local
H A Dtest-fs-poll.c47 static uv_loop_t* loop; variable
201 uv_loop_t loop; in TEST_IMPL() local
220 uv_loop_t loop; in TEST_IMPL() local
244 uv_loop_t loop; in TEST_IMPL() local
269 uv_loop_t loop; in TEST_IMPL() local
H A Dbenchmark-loop-count.c67 uv_loop_t* loop = uv_default_loop(); in BENCHMARK_IMPL() local
91 uv_loop_t* loop = uv_default_loop(); in BENCHMARK_IMPL() local
112 uv_loop_t* loop = uv_default_loop(); in BENCHMARK_IMPL() local
H A Dtest-udp-bind.c32 uv_loop_t* loop; in TEST_IMPL() local
65 uv_loop_t* loop; in TEST_IMPL() local
H A Dtest-loop-close.c35 uv_loop_t loop; in TEST_IMPL() local
68 static uv_loop_t loop; in TEST_IMPL() local
/libuv/src/
H A Dtimer.c29 static struct heap *timer_heap(const uv_loop_t* loop) { in timer_heap()
58 int uv_timer_init(uv_loop_t* loop, uv_timer_t* handle) { in uv_timer_init()
144 int uv__next_timeout(const uv_loop_t* loop) { in uv__next_timeout()
165 void uv__run_timers(uv_loop_t* loop) { in uv__run_timers()

Completed in 67 milliseconds

1234567