Home
last modified time | relevance | path

Searched refs:uv_loop_t (Results 1 – 25 of 187) sorted by relevance

12345678

/netbsd-src/external/mit/libuv/dist/src/win/
H A Dinternal.h79 int uv__tcp_write(uv_loop_t* loop, uv_write_t* req, uv_tcp_t* handle,
84 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle, uv_req_t* req);
85 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle,
87 void uv__process_tcp_accept_req(uv_loop_t* loop, uv_tcp_t* handle,
89 void uv__process_tcp_connect_req(uv_loop_t* loop, uv_tcp_t* handle,
91 void uv__process_tcp_shutdown_req(uv_loop_t* loop,
95 void uv__tcp_close(uv_loop_t* loop, uv_tcp_t* tcp);
96 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle);
110 void uv__process_udp_recv_req(uv_loop_t* loop, uv_udp_t* handle, uv_req_t* req);
111 void uv__process_udp_send_req(uv_loop_t* loop, uv_udp_t* handle,
[all …]
H A Dcore.c81 static uv_loop_t** uv__loops;
93 static int uv__loops_add(uv_loop_t* loop) { in uv__loops_add()
94 uv_loop_t** new_loops; in uv__loops_add()
101 new_loops = uv__realloc(uv__loops, sizeof(uv_loop_t*) * new_capacity); in uv__loops_add()
121 static void uv__loops_remove(uv_loop_t* loop) { in uv__loops_remove()
124 uv_loop_t** new_loops; in uv__loops_remove()
155 new_loops = uv__realloc(uv__loops, sizeof(uv_loop_t*) * smaller_capacity); in uv__loops_remove()
167 uv_loop_t* loop; in uv__wake_all_loops()
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()
[all …]
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()
86 void uv__process_async_wakeup_req(uv_loop_t* loop, uv_async_t* handle, in uv__process_async_wakeup_req()
H A Dloop-watcher.c29 void uv__loop_watcher_endgame(uv_loop_t* loop, uv_handle_t* handle) { in uv__loop_watcher_endgame()
39 int uv_##name##_init(uv_loop_t* loop, uv_##name##_t* handle) { \
47 uv_loop_t* loop = handle->loop; \
77 uv_loop_t* loop = handle->loop; \
107 void uv__##name##_invoke(uv_loop_t* loop) { \
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()
529 void uv__process_poll_req(uv_loop_t* loop, uv_poll_t* handle, uv_req_t* req) { in uv__process_poll_req()
538 int uv__poll_close(uv_loop_t* loop, uv_poll_t* handle) { in uv__poll_close()
579 void uv__poll_endgame(uv_loop_t* loop, uv_poll_t* handle) { in uv__poll_endgame()
H A Dpipe.c106 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init()
381 int uv__create_stdio_pipe_pair(uv_loop_t* loop, in uv__create_stdio_pipe_pair()
450 static int uv__set_pipe_handle(uv_loop_t* loop, in uv__set_pipe_handle()
528 static int pipe_alloc_accept(uv_loop_t* loop, uv_pipe_t* handle, in pipe_alloc_accept()
561 uv_loop_t* loop; in pipe_shutdown_thread_proc()
581 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t *req) { in uv__pipe_shutdown()
631 void uv__pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle) { in uv__pipe_endgame()
697 uv_loop_t* loop = handle->loop; in uv_pipe_bind()
780 uv_loop_t* loop; in pipe_connect_thread_proc()
821 uv_loop_t* loop = handle->loop; in uv_pipe_connect()
[all …]
/netbsd-src/external/mit/libuv/dist/src/unix/
H A Dinternal.h210 void uv__io_start(uv_loop_t* loop, uv__io_t* w, unsigned int events);
211 void uv__io_stop(uv_loop_t* loop, uv__io_t* w, unsigned int events);
212 void uv__io_close(uv_loop_t* loop, uv__io_t* w);
213 void uv__io_feed(uv_loop_t* loop, uv__io_t* w);
215 int uv__io_check_fd(uv_loop_t* loop, int fd);
216 void uv__io_poll(uv_loop_t* loop, int timeout); /* in milliseconds or -1 */
217 int uv__io_fork(uv_loop_t* loop);
218 int uv__fd_exists(uv_loop_t* loop, int fd);
221 void uv__async_stop(uv_loop_t* loop);
222 int uv__async_fork(uv_loop_t* loop);
[all …]
H A Dasync.c41 static void uv__async_send(uv_loop_t* loop);
42 static int uv__async_start(uv_loop_t* loop);
45 int uv_async_init(uv_loop_t* loop, uv_async_t* handle, uv_async_cb async_cb) { in uv_async_init()
122 static void uv__async_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__async_io()
168 static void uv__async_send(uv_loop_t* loop) { in uv__async_send()
202 static int uv__async_start(uv_loop_t* loop) { in uv__async_start()
230 int uv__async_fork(uv_loop_t* loop) { in uv__async_fork()
240 void uv__async_stop(uv_loop_t* loop) { in uv__async_stop()
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()
336 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) { in uv__platform_invalidate_fd()
356 int uv__io_check_fd(uv_loop_t* loop, int fd) { in uv__io_check_fd()
H A Dlinux-inotify.c61 static void uv__inotify_read(uv_loop_t* loop,
66 uv_loop_t* loop);
68 static int init_inotify(uv_loop_t* loop) { in init_inotify()
86 int uv__inotify_fork(uv_loop_t* loop, void* old_watchers) { in uv__inotify_fork()
151 static struct watcher_list* find_watcher(uv_loop_t* loop, int wd) { in find_watcher()
157 static void maybe_free_watcher_list(struct watcher_list* w, uv_loop_t* loop) { in maybe_free_watcher_list()
167 static void uv__inotify_read(uv_loop_t* loop, in uv__inotify_read()
243 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) { in uv_fs_event_init()
H A Dfs.c1784 int uv_fs_access(uv_loop_t* loop, in uv_fs_access()
1796 int uv_fs_chmod(uv_loop_t* loop, in uv_fs_chmod()
1808 int uv_fs_chown(uv_loop_t* loop, in uv_fs_chown()
1822 int uv_fs_close(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_close()
1829 int uv_fs_fchmod(uv_loop_t* loop, in uv_fs_fchmod()
1841 int uv_fs_fchown(uv_loop_t* loop, in uv_fs_fchown()
1855 int uv_fs_lchown(uv_loop_t* loop, in uv_fs_lchown()
1869 int uv_fs_fdatasync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_fdatasync()
1876 int uv_fs_fstat(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_fstat()
1883 int uv_fs_fsync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) { in uv_fs_fsync()
[all …]
H A Dkqueue.c48 static void uv__fs_event(uv_loop_t* loop, uv__io_t* w, unsigned int fflags);
51 int uv__kqueue_init(uv_loop_t* loop) { in uv__kqueue_init()
66 int uv__io_fork(uv_loop_t* loop) { in uv__io_fork()
94 int uv__io_check_fd(uv_loop_t* loop, int fd) { in uv__io_check_fd()
112 void uv__io_poll(uv_loop_t* loop, int timeout) { in uv__io_poll()
444 void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) { in uv__platform_invalidate_fd()
464 static void uv__fs_event(uv_loop_t* loop, uv__io_t* w, unsigned int fflags) { in uv__fs_event()
506 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) { in uv_fs_event_init()
/netbsd-src/external/mit/libuv/dist/include/
H A Duv.h213 typedef struct uv_loop_s uv_loop_t; typedef
280 UV_EXTERN uv_loop_t* uv_default_loop(void);
281 UV_EXTERN int uv_loop_init(uv_loop_t* loop);
282 UV_EXTERN int uv_loop_close(uv_loop_t* loop);
288 UV_EXTERN uv_loop_t* uv_loop_new(void);
294 UV_EXTERN void uv_loop_delete(uv_loop_t*);
296 UV_EXTERN int uv_loop_alive(const uv_loop_t* loop);
297 UV_EXTERN int uv_loop_configure(uv_loop_t* loop, uv_loop_option option, ...);
298 UV_EXTERN int uv_loop_fork(uv_loop_t* loop);
300 UV_EXTERN int uv_run(uv_loop_t*, uv_run_mode mode);
[all …]
/netbsd-src/external/mit/libuv/dist/docs/src/guide/
H A Dfilesystem.rst33 … int uv_fs_open(uv_loop_t* loop, uv_fs_t* req, const char* path, int flags, int mode, uv_fs_cb cb)
43 int uv_fs_close(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb)
127 int uv_fs_close(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb);
128 … int uv_fs_open(uv_loop_t* loop, uv_fs_t* req, const char* path, int flags, int mode, uv_fs_cb cb);
129 …int uv_fs_read(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int nb…
130 int uv_fs_unlink(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb);
131 …int uv_fs_write(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], unsigned int n…
132 …int uv_fs_copyfile(uv_loop_t* loop, uv_fs_t* req, const char* path, const char* new_path, int flag…
133 int uv_fs_mkdir(uv_loop_t* loop, uv_fs_t* req, const char* path, int mode, uv_fs_cb cb);
134 int uv_fs_mkdtemp(uv_loop_t* loop, uv_fs_t* req, const char* tpl, uv_fs_cb cb);
[all …]
/netbsd-src/external/mit/libuv/dist/docs/code/signal/
H A Dmain.c6 uv_loop_t* create_loop() in create_loop()
8 uv_loop_t *loop = malloc(sizeof(uv_loop_t)); in create_loop()
24 uv_loop_t *loop1 = create_loop(); in thread1_worker()
39 uv_loop_t *loop2 = create_loop(); in thread2_worker()
40 uv_loop_t *loop3 = create_loop(); in thread2_worker()
/netbsd-src/external/mit/libuv/dist/docs/src/
H A Dloop.rst4 :c:type:`uv_loop_t` --- Event loop
15 .. c:type:: uv_loop_t
39 .. c:member:: void* uv_loop_t.data
48 .. c:function:: int uv_loop_init(uv_loop_t* loop)
50 Initializes the given `uv_loop_t` structure.
52 .. c:function:: int uv_loop_configure(uv_loop_t* loop, uv_loop_option option, ...)
78 .. c:function:: int uv_loop_close(uv_loop_t* loop)
85 .. c:function:: uv_loop_t* uv_default_loop(void)
99 .. c:function:: int uv_run(uv_loop_t* loop, uv_run_mode mode)
119 .. c:function:: int uv_loop_alive(const uv_loop_t* loop)
[all …]
H A Dfs.rst167 .. c:member:: uv_loop_t* uv_fs_t.loop
206 .. c:function:: int uv_fs_close(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb)
210 .. c:function:: int uv_fs_open(uv_loop_t* loop, uv_fs_t* req, const char* path, int flags, int mode…
219 .. c:function:: int uv_fs_read(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[], …
228 .. c:function:: int uv_fs_unlink(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb)
232 .. c:function:: int uv_fs_write(uv_loop_t* loop, uv_fs_t* req, uv_file file, const uv_buf_t bufs[],…
241 .. c:function:: int uv_fs_mkdir(uv_loop_t* loop, uv_fs_t* req, const char* path, int mode, uv_fs_cb…
248 .. c:function:: int uv_fs_mkdtemp(uv_loop_t* loop, uv_fs_t* req, const char* tpl, uv_fs_cb cb)
252 .. c:function:: int uv_fs_mkstemp(uv_loop_t* loop, uv_fs_t* req, const char* tpl, uv_fs_cb cb)
259 .. c:function:: int uv_fs_rmdir(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb)
[all …]
/netbsd-src/external/mit/libuv/dist/src/
H A Duv-common.c153 return sizeof(uv_loop_t); in uv_loop_size()
312 int uv_udp_init_ex(uv_loop_t* loop, uv_udp_t* handle, unsigned flags) { in uv_udp_init_ex()
337 int uv_udp_init(uv_loop_t* loop, uv_udp_t* handle) { in uv_udp_init()
502 void uv_walk(uv_loop_t* loop, uv_walk_cb walk_cb, void* arg) { in uv_walk()
521 static void uv__print_handles(uv_loop_t* loop, int only_active, FILE* stream) { in uv__print_handles()
553 void uv_print_all_handles(uv_loop_t* loop, FILE* stream) { in uv_print_all_handles()
558 void uv_print_active_handles(uv_loop_t* loop, FILE* stream) { in uv_print_active_handles()
578 void uv_stop(uv_loop_t* loop) { in uv_stop()
583 uint64_t uv_now(const uv_loop_t* loop) { in uv_now()
762 int uv_loop_configure(uv_loop_t* loop, uv_loop_option option, ...) { in uv_loop_configure()
[all …]
H A Duv-common.h139 int uv__loop_configure(uv_loop_t* loop, uv_loop_option option, va_list ap);
141 void uv__loop_close(uv_loop_t* loop);
158 int uv__udp_init_ex(uv_loop_t* loop,
205 void uv__work_submit(uv_loop_t* loop,
221 int uv__next_timeout(const uv_loop_t* loop);
222 void uv__run_timers(uv_loop_t* loop);
368 void uv__metrics_update_idle_time(uv_loop_t* loop);
369 void uv__metrics_set_provider_entry_time(uv_loop_t* loop);
H A Dthreadpool.c261 void uv__work_submit(uv_loop_t* loop, in uv__work_submit()
274 static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) { in uv__work_cancel()
302 uv_loop_t* loop; in uv__work_done()
307 loop = container_of(handle, uv_loop_t, wq_async); in uv__work_done()
343 int uv_queue_work(uv_loop_t* loop, in uv_queue_work()
365 uv_loop_t* loop; in uv_cancel()
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()
142 int uv__next_timeout(const uv_loop_t* loop) { in uv__next_timeout()
163 void uv__run_timers(uv_loop_t* loop) { in uv__run_timers()
/netbsd-src/external/mit/libuv/dist/test/
H A Dtest-fs-event.c414 uv_loop_t* loop = uv_default_loop(); in TEST_IMPL()
451 uv_loop_t* loop; in TEST_IMPL()
515 uv_loop_t* loop; in TEST_IMPL()
568 uv_loop_t* loop = uv_default_loop(); in TEST_IMPL()
613 uv_loop_t* loop; in TEST_IMPL()
663 uv_loop_t* loop; in TEST_IMPL()
685 uv_loop_t* loop; in TEST_IMPL()
737 uv_loop_t* loop; in TEST_IMPL()
767 uv_loop_t* loop = uv_default_loop(); in TEST_IMPL()
805 uv_loop_t* loop = uv_default_loop(); in TEST_IMPL()
[all …]
H A Dtest-signal.c53 uv_loop_t* loop; in TEST_IMPL()
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()
191 uv_loop_t* loop; in TEST_IMPL()
216 uv_loop_t* loop; in TEST_IMPL()
245 uv_loop_t* loop; in TEST_IMPL()
H A Dtest-threadpool-cancel.c64 uv_loop_t* loop; in saturate_threadpool()
168 uv_loop_t* loop; in TEST_IMPL()
201 uv_loop_t* loop; in TEST_IMPL()
235 uv_loop_t* loop; in TEST_IMPL()
259 uv_loop_t* loop; in TEST_IMPL()
283 uv_loop_t* loop; in TEST_IMPL()
335 uv_loop_t* loop; in TEST_IMPL()
H A Dtest-fs-poll.c47 static uv_loop_t* loop;
201 uv_loop_t loop; in TEST_IMPL()
222 uv_loop_t loop; in TEST_IMPL()
248 uv_loop_t loop; in TEST_IMPL()
275 uv_loop_t loop; in TEST_IMPL()

12345678