/libuv/src/win/ |
H A D | internal.h | 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); 114 void uv__udp_close(uv_loop_t* loop, uv_udp_t* handle); 121 int uv__create_stdio_pipe_pair(uv_loop_t* loop, 129 int uv__pipe_write(uv_loop_t* loop, 173 void uv__process_tty_shutdown_req(uv_loop_t* loop, 194 void uv__prepare_invoke(uv_loop_t* loop); 195 void uv__check_invoke(uv_loop_t* loop); 196 void uv__idle_invoke(uv_loop_t* loop); [all …]
|
H A D | core.c | 81 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() 124 uv_loop_t** new_loops; 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() 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() [all …]
|
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() 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 D | loop-watcher.c | 29 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 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() 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()
|
/libuv/src/unix/ |
H A D | internal.h | 267 int uv__io_fork(uv_loop_t* loop); 271 void uv__async_stop(uv_loop_t* loop); 272 int uv__async_fork(uv_loop_t* loop); 276 void uv__run_idle(uv_loop_t* loop); 277 void uv__run_check(uv_loop_t* loop); 278 void uv__run_prepare(uv_loop_t* loop); 309 int uv__signal_loop_fork(uv_loop_t* loop); 313 int uv__kqueue_init(uv_loop_t* loop); 317 int uv__process_init(uv_loop_t* loop); 335 void uv__wait_children(uv_loop_t* loop); [all …]
|
H A D | posix-poll.c | 36 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 D | async.c | 69 static void uv__async_send(uv_loop_t* loop); 70 static int uv__async_start(uv_loop_t* loop); 74 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) { 213 static void uv__async_send(uv_loop_t* loop) { 258 static int uv__async_start(uv_loop_t* loop) { 326 void uv__async_stop(uv_loop_t* loop) { 360 int uv__async_fork(uv_loop_t* loop) {
|
H A D | fs.c | 1792 int uv_fs_access(uv_loop_t* loop, in uv_fs_access() 1804 int uv_fs_chmod(uv_loop_t* loop, in uv_fs_chmod() 1816 int uv_fs_chown(uv_loop_t* loop, in uv_fs_chown() 1840 int uv_fs_fchmod(uv_loop_t* loop, in uv_fs_fchmod() 1852 int uv_fs_fchown(uv_loop_t* loop, in uv_fs_fchown() 1866 int uv_fs_lchown(uv_loop_t* loop, in uv_fs_lchown() 1962 int uv_fs_link(uv_loop_t* loop, in uv_fs_link() 1976 int uv_fs_mkdir(uv_loop_t* loop, in uv_fs_mkdir() 2015 int uv_fs_open(uv_loop_t* loop, in uv_fs_open() 2207 int uv_fs_utime(uv_loop_t* loop, in uv_fs_utime() [all …]
|
/libuv/include/ |
H A D | uv.h | 219 typedef struct uv_loop_s uv_loop_t; typedef 299 UV_EXTERN uv_loop_t* uv_loop_new(void); 305 UV_EXTERN void uv_loop_delete(uv_loop_t*); 312 UV_EXTERN void uv_stop(uv_loop_t*); 942 UV_EXTERN int uv_async_init(uv_loop_t*, 978 uv_loop_t* loop; 1001 uv_loop_t* loop; 1158 UV_EXTERN int uv_spawn(uv_loop_t* loop, 1171 uv_loop_t* loop; 1433 uv_loop_t* loop; [all …]
|
/libuv/docs/code/signal/ |
H A D | main.c | 6 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()
|
/libuv/docs/src/guide/ |
H A D | filesystem.rst | 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); 130 int uv_fs_unlink(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb); 136 int uv_fs_rmdir(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb); 140 int uv_fs_readdir(uv_loop_t* loop, uv_fs_t* req, uv_dir_t* dir, uv_fs_cb cb); 141 int uv_fs_closedir(uv_loop_t* loop, uv_fs_t* req, uv_dir_t* dir, uv_fs_cb cb); 142 int uv_fs_stat(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb); 143 int uv_fs_fstat(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb); 145 int uv_fs_fsync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb); 146 int uv_fs_fdatasync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb); [all …]
|
/libuv/src/ |
H A D | uv-common.c | 186 return sizeof(uv_loop_t); in uv_loop_size() 614 void uv_stop(uv_loop_t* loop) { in uv_stop() 619 uint64_t uv_now(const uv_loop_t* loop) { in uv_now() 819 static uv_loop_t default_loop_struct; 820 static uv_loop_t* default_loop_ptr; 823 uv_loop_t* uv_default_loop(void) { in uv_default_loop() 835 uv_loop_t* uv_loop_new(void) { in uv_loop_new() 836 uv_loop_t* loop; in uv_loop_new() 851 int uv_loop_close(uv_loop_t* loop) { in uv_loop_close() 881 void uv_loop_delete(uv_loop_t* loop) { in uv_loop_delete() [all …]
|
H A D | uv-common.h | 143 int uv__loop_configure(uv_loop_t* loop, uv_loop_option option, va_list ap); 145 void uv__loop_close(uv_loop_t* loop); 162 int uv__udp_init_ex(uv_loop_t* loop, 209 void uv__work_submit(uv_loop_t* loop, 225 int uv__next_timeout(const uv_loop_t* loop); 226 void uv__run_timers(uv_loop_t* loop); 396 void uv__metrics_update_idle_time(uv_loop_t* loop); 397 void uv__metrics_set_provider_entry_time(uv_loop_t* loop);
|
H A D | uv-data-getter-setters.c | 44 uv_loop_t* uv_handle_get_loop(const uv_handle_t* handle) { in uv_handle_get_loop() 113 void* uv_loop_get_data(const uv_loop_t* loop) { in uv_loop_get_data() 117 void uv_loop_set_data(uv_loop_t* loop, void* data) { in uv_loop_set_data()
|
H A D | timer.c | 29 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()
|
H A D | threadpool.c | 265 void uv__work_submit(uv_loop_t* loop, in uv__work_submit() 281 static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) { in uv__work_cancel() 310 uv_loop_t* loop; in uv__work_done() 316 loop = container_of(handle, uv_loop_t, wq_async); in uv__work_done() 368 int uv_queue_work(uv_loop_t* loop, in uv_queue_work() 390 uv_loop_t* loop; in uv_cancel()
|
/libuv/docs/src/ |
H A D | loop.rst | 4 :c:type:`uv_loop_t` --- Event loop 15 .. c:type:: uv_loop_t 52 .. c:member:: void* uv_loop_t.data 61 .. c:function:: int uv_loop_init(uv_loop_t* loop) 63 Initializes the given `uv_loop_t` structure. 96 .. c:function:: int uv_loop_close(uv_loop_t* loop) 103 .. c:function:: uv_loop_t* uv_default_loop(void) 142 .. c:function:: void uv_stop(uv_loop_t* loop) 172 .. c:function:: uint64_t uv_now(const uv_loop_t* loop) 185 .. c:function:: void uv_update_time(uv_loop_t* loop) [all …]
|
H A D | fs.rst | 21 again. In order to enable io_uring the :c:type:`uv_loop_t` instance must be 188 .. c:member:: uv_loop_t* uv_fs_t.loop 227 .. c:function:: int uv_fs_close(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) 250 .. c:function:: int uv_fs_unlink(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) 282 .. c:function:: int uv_fs_rmdir(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) 299 .. c:function:: int uv_fs_closedir(uv_loop_t* loop, uv_fs_t* req, uv_dir_t* dir, uv_fs_cb cb) 306 .. c:function:: int uv_fs_readdir(uv_loop_t* loop, uv_fs_t* req, uv_dir_t* dir, uv_fs_cb cb) 345 .. c:function:: int uv_fs_stat(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) 346 .. c:function:: int uv_fs_fstat(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) 347 .. c:function:: int uv_fs_lstat(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb) [all …]
|
/libuv/test/ |
H A D | test-tcp-reuseport.c | 34 uv_loop_t* loop; in TEST_IMPL() 71 static uv_loop_t* main_loop; 72 static uv_loop_t thread_loop1; 73 static uv_loop_t thread_loop2; 133 static void create_listener(uv_loop_t* loop, uv_tcp_t* handle) { in create_listener() 153 uv_loop_t* loop = (uv_loop_t*) arg; in run_event_loop()
|
H A D | test-udp-reuseport.c | 34 uv_loop_t* loop; in TEST_IMPL() 89 static uv_loop_t* main_loop; 90 static uv_loop_t thread_loop1; 91 static uv_loop_t thread_loop2; 164 static void bind_socket_and_prepare_recv(uv_loop_t* loop, uv_udp_t* handle) { in bind_socket_and_prepare_recv() 189 uv_loop_t* loop = (uv_loop_t*) arg; in run_event_loop()
|
H A D | test-fs-event.c | 520 uv_loop_t* loop; in TEST_IMPL() 584 uv_loop_t* loop; in TEST_IMPL() 682 uv_loop_t* loop; in TEST_IMPL() 732 uv_loop_t* loop; in TEST_IMPL() 754 uv_loop_t* loop; in TEST_IMPL() 806 uv_loop_t* loop; in TEST_IMPL() 925 uv_loop_t* loop; in TEST_IMPL() 949 uv_loop_t* loop; in TEST_IMPL() 983 uv_loop_t* loop; in TEST_IMPL() 1025 uv_loop_t* loop; in TEST_IMPL() [all …]
|
H A D | benchmark-loop-count.c | 67 uv_loop_t* loop = uv_default_loop(); in BENCHMARK_IMPL() 91 uv_loop_t* loop = uv_default_loop(); in BENCHMARK_IMPL() 112 uv_loop_t* loop = uv_default_loop(); in BENCHMARK_IMPL()
|
H A D | test-fs-poll.c | 47 static uv_loop_t* loop; 201 uv_loop_t loop; in TEST_IMPL() 220 uv_loop_t loop; in TEST_IMPL() 244 uv_loop_t loop; in TEST_IMPL() 269 uv_loop_t loop; in TEST_IMPL()
|
/libuv/docs/code/helloworld/ |
H A D | main.c | 6 uv_loop_t *loop = malloc(sizeof(uv_loop_t)); in main()
|