/libuv/src/unix/ |
H A D | fs.c | 1761 req->cb(req); in uv__fs_done() 1816 if (cb != NULL) in uv_fs_close() 1866 if (cb != NULL) in uv_fs_fdatasync() 1876 if (cb != NULL) in uv_fs_fstat() 1886 if (cb != NULL) in uv_fs_fsync() 1935 if (cb != NULL) in uv_fs_lstat() 1949 if (cb != NULL) in uv_fs_link() 1964 if (cb != NULL) in uv_fs_mkdir() 2005 if (cb != NULL) in uv_fs_open() 2028 if (cb == NULL) in uv_fs_read() [all …]
|
H A D | stream.c | 656 if (req->cb != NULL) in uv__drain() 657 req->cb(req, err); in uv__drain() 925 if (req->cb) in uv__write_callbacks() 926 req->cb(req, req->error); in uv__write_callbacks() 1177 req->cb = cb; in uv_shutdown() 1281 if (req->cb) in uv__stream_connect() 1282 req->cb(req, error); in uv__stream_connect() 1337 uv_write_cb cb) { in uv_write2() argument 1355 req->cb = cb; in uv_write2() 1408 uv_write_cb cb) { in uv_write() argument [all …]
|
H A D | tcp.c | 275 uv_connect_cb cb) { in uv__tcp_connect() argument 332 req->cb = cb; in uv__tcp_connect() 415 int uv__tcp_listen(uv_tcp_t* tcp, int backlog, uv_connection_cb cb) { in uv__tcp_listen() argument 437 tcp->connection_cb = cb; in uv__tcp_listen() 441 tcp->io_watcher.cb = uv__server_io; in uv__tcp_listen()
|
H A D | linux.c | 1183 req->cb(req); in uv__poll_io_uring() 1535 w->cb(loop, w, pe->events); in uv__io_poll() 1551 loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN); in uv__io_poll() 2488 err = uv_fs_event_start(handle, handle->cb, tmp_path, 0); in uv__inotify_fork() 2582 h->cb(h, path, events, 0); in uv__inotify_read() 2599 uv_fs_event_cb cb, in uv_fs_event_start() argument 2650 handle->cb = cb; in uv_fs_event_start()
|
H A D | fsevents.c | 178 (handle)->cb((handle), NULL, 0, err); \ 183 static void uv__fsevents_cb(uv_async_t* cb) { in uv__fsevents_cb() argument 186 handle = cb->data; in uv__fsevents_cb() 189 handle->cb(handle, event->path[0] ? event->path : NULL, event->events, 0); in uv__fsevents_cb()
|
H A D | core.c | 842 w->cb(loop, w, POLLOUT); in uv__run_pending() 893 void uv__io_init(uv__io_t* w, uv__io_cb cb, int fd) { in uv__io_init() argument 894 assert(cb != NULL); in uv__io_init() 898 w->cb = cb; in uv__io_init()
|
H A D | internal.h | 250 void uv__io_init(uv__io_t* w, uv__io_cb cb, int fd); 286 int uv__tcp_listen(uv_tcp_t* tcp, int backlog, uv_connection_cb cb); 291 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb);
|
H A D | kqueue.c | 180 if (w->cb == uv__fs_event) { in uv__io_poll() 341 w->cb(loop, w, ev->fflags); /* XXX always uv__fs_event() */ in uv__io_poll() 385 w->cb(loop, w, revents); in uv__io_poll() 405 loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN); in uv__io_poll() 507 handle->cb(handle, path, events, 0); in uv__fs_event() 530 uv_fs_event_cb cb, in uv_fs_event_start() argument 541 handle->cb = cb; in uv_fs_event_start()
|
H A D | pipe.c | 146 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { in uv__pipe_listen() argument 165 handle->connection_cb = cb; in uv__pipe_listen() 166 handle->io_watcher.cb = uv__server_io; in uv__pipe_listen() 228 uv_connect_cb cb) { in uv_pipe_connect() argument 231 err = uv_pipe_connect2(req, handle, name, strlen(name), 0, cb); in uv_pipe_connect() 239 req->cb = cb; in uv_pipe_connect() 253 uv_connect_cb cb) { in uv_pipe_connect2() argument 332 req->cb = cb; in uv_pipe_connect2()
|
/libuv/docs/src/guide/ |
H A D | processes.rst | 319 void uv_pipe_connect(uv_connect_t *req, uv_pipe_t *handle, const char *name, uv_connect_cb cb);
|
/libuv/src/win/ |
H A D | tcp.c | 226 if (req->cb) in uv__process_tcp_shutdown_req() 227 req->cb(req, err); in uv__process_tcp_shutdown_req() 551 handle->stream.serv.connection_cb = cb; in uv__tcp_listen() 586 handle->stream.serv.connection_cb = cb; in uv__tcp_listen() 825 req->cb = cb; in uv__tcp_try_connect() 890 uv_write_cb cb) { in uv__tcp_write() argument 896 req->cb = cb; in uv__tcp_write() 1127 if (req->cb) { in uv__process_tcp_write_req() 1133 req->cb(req, err); in uv__process_tcp_write_req() 1233 req->cb(req, uv_translate_sys_error(err)); in uv__process_tcp_connect_req() [all …]
|
H A D | process.c | 1009 startup.cb = sizeof(startup); in uv_spawn()
|
H A D | pipe.c | 859 uv_connect_cb cb) { in uv_pipe_connect() argument 881 uv_connect_cb cb) { in uv_pipe_connect2() argument 892 req->cb = cb; in uv_pipe_connect2() 1595 req->cb = cb; in uv__pipe_write_data() 1753 uv_write_cb cb) { in uv__pipe_write_ipc() argument 1855 uv_write_cb cb) { in uv__pipe_write() argument 2159 if (req->cb) { in uv__process_pipe_write_req() 2238 if (req->cb) in uv__process_pipe_connect_req() 2239 req->cb(req, err); in uv__process_pipe_connect_req() 2282 if (req->cb) in uv__process_pipe_shutdown_req() [all …]
|
H A D | fs.c | 373 req->cb = cb; in uv__fs_req_init() 2840 req->cb(req); in uv__fs_done() 2877 int mode, uv_fs_cb cb) { in uv_fs_open() argument 2906 uv_fs_cb cb) { in uv_fs_read() argument 2967 uv_fs_cb cb) { in uv_fs_unlink() argument 2982 uv_fs_cb cb) { in uv_fs_mkdir() argument 3046 uv_fs_cb cb) { in uv_fs_scandir() argument 3137 uv_fs_cb cb) { in uv_fs_readlink() argument 3152 uv_fs_cb cb) { in uv_fs_realpath() argument 3341 uv_fs_cb cb) { in uv_fs_chmod() argument [all …]
|
H A D | tty.c | 2177 uv_write_cb cb) { argument 2182 req->cb = cb; 2224 if (req->cb) { 2226 req->cb(req, uv_translate_sys_error(err)); 2269 if (req->cb) { 2271 req->cb(req, UV_ECANCELED); 2273 req->cb(req, 0);
|
H A D | fs-event.c | 157 uv_fs_event_cb cb, in uv_fs_event_start() argument 172 handle->cb = cb; in uv_fs_event_start() 542 handle->cb(handle, filename, UV_RENAME, 0); in uv__process_fs_event_req() 546 handle->cb(handle, filename, UV_CHANGE, 0); in uv__process_fs_event_req() 560 handle->cb(handle, NULL, UV_CHANGE, 0); in uv__process_fs_event_req() 564 handle->cb(handle, NULL, 0, uv_translate_sys_error(err)); in uv__process_fs_event_req()
|
/libuv/include/uv/ |
H A D | win.h | 655 uv_fs_event_cb cb; \
|
/libuv/docs/src/ |
H A D | tcp.rst | 107 … uv_tcp_connect(uv_connect_t* req, uv_tcp_t* handle, const struct sockaddr* addr, uv_connect_cb cb)
|
/libuv/ |
H A D | ChangeLog | 1063 * doc,poll: add notes (repeated cb & cancel pending cb) (Elad Nachmias) 4770 * unix: guarantee write queue cb execution order in streams (Andrius Bentkus)
|
H A D | Makefile.am | 160 test/test-async-null-cb.c \ 263 test/test-tcp-alloc-cb-fail.c \ 306 test/test-udp-alloc-cb-fail.c \
|
H A D | CMakeLists.txt | 527 test/test-async-null-cb.c 630 test/test-tcp-alloc-cb-fail.c 673 test/test-udp-alloc-cb-fail.c
|
/libuv/src/ |
H A D | timer.c | 69 uv_timer_cb cb, in uv_timer_start() argument 74 if (uv__is_closing(handle) || cb == NULL) in uv_timer_start() 83 handle->timer_cb = cb; in uv_timer_start()
|
/libuv/include/ |
H A D | uv.h | 456 uv_shutdown_cb cb; member 552 uv_write_cb cb); 570 uv_write_cb cb; member 628 uv_connect_cb cb; member 707 uv_udp_send_cb cb; member 1405 uv_fs_cb cb; member 1430 uv_fs_cb cb); 1437 uv_fs_cb cb); 1512 uv_fs_cb cb); 1578 uv_fs_cb cb); [all …]
|
/libuv/test/ |
H A D | test-fs.c | 1205 static int test_sendfile(void (*setup)(int), uv_fs_cb cb, size_t expected_size) { in test_sendfile() argument 1239 1, 131072, cb); in test_sendfile()
|
H A D | runner-win.c | 145 si.cb = sizeof(si); in process_start()
|