/libuv/src/win/ |
H A D | stream.c | 30 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) { in uv_listen() argument 38 err = uv__tcp_listen((uv_tcp_t*)stream, backlog, cb); in uv_listen() 41 err = uv__pipe_listen((uv_pipe_t*)stream, backlog, cb); in uv_listen() 118 uv_write_cb cb) { in uv_write() argument 129 err = uv__tcp_write(loop, req, (uv_tcp_t*) handle, bufs, nbufs, cb); in uv_write() 133 loop, req, (uv_pipe_t*) handle, bufs, nbufs, NULL, cb); in uv_write() 136 err = uv__tty_write(loop, req, (uv_tty_t*) handle, bufs, nbufs, cb); in uv_write() 151 uv_write_cb cb) { in uv_write2() argument 156 return uv_write(req, handle, bufs, nbufs, cb); in uv_write2() 166 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2() [all …]
|
H A D | fs.c | 395 req->cb = cb; in uv__fs_req_init() 2984 req->cb(req); in uv__fs_done() 3021 int mode, uv_fs_cb cb) { in uv_fs_open() argument 3050 uv_fs_cb cb) { in uv_fs_read() argument 3111 uv_fs_cb cb) { in uv_fs_unlink() argument 3126 uv_fs_cb cb) { in uv_fs_mkdir() argument 3190 uv_fs_cb cb) { in uv_fs_scandir() argument 3281 uv_fs_cb cb) { in uv_fs_readlink() argument 3296 uv_fs_cb cb) { in uv_fs_realpath() argument 3485 uv_fs_cb cb) { in uv_fs_chmod() argument [all …]
|
H A D | loop-watcher.c | 46 int uv_##name##_start(uv_##name##_t* handle, uv_##name##_cb cb) { \ 55 if (cb == NULL) \ 69 handle->name##_cb = cb; \
|
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() 579 handle->cb(handle, filename, UV_RENAME, 0); in uv__process_fs_event_req() 581 handle->cb(handle, NULL, 0, uv_translate_sys_error(err)); in uv__process_fs_event_req()
|
H A D | internal.h | 75 int uv__tcp_listen(uv_tcp_t* handle, int backlog, uv_connection_cb cb); 80 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb); 124 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb); 135 uv_write_cb cb); 162 const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb);
|
H A D | handle.c | 67 void uv_close(uv_handle_t* handle, uv_close_cb cb) { in uv_close() argument 75 handle->close_cb = cb; in uv_close()
|
/libuv/include/ |
H A D | uv.h | 459 uv_shutdown_cb cb; member 555 uv_write_cb cb); 573 uv_write_cb cb; member 642 uv_connect_cb cb; member 736 uv_udp_send_cb cb; member 1434 uv_fs_cb cb; member 1459 uv_fs_cb cb); 1466 uv_fs_cb cb); 1541 uv_fs_cb cb); 1607 uv_fs_cb cb); [all …]
|
/libuv/src/unix/ |
H A D | fs.c | 1778 req->cb(req); in uv__fs_done() 1833 if (cb != NULL) in uv_fs_close() 1883 if (cb != NULL) in uv_fs_fdatasync() 1893 if (cb != NULL) in uv_fs_fstat() 1903 if (cb != NULL) in uv_fs_fsync() 1918 if (cb != NULL) in uv_fs_ftruncate() 1955 if (cb != NULL) in uv_fs_lstat() 1969 if (cb != NULL) in uv_fs_link() 1984 if (cb != NULL) in uv_fs_mkdir() 2025 if (cb != NULL) in uv_fs_open() [all …]
|
H A D | getaddrinfo.c | 133 if (req->cb) in uv__getaddrinfo_done() 134 req->cb(req, req->retcode, req->addrinfo); in uv__getaddrinfo_done() 140 uv_getaddrinfo_cb cb, in uv_getaddrinfo() argument 182 req->cb = cb; in uv_getaddrinfo() 205 if (cb) { in uv_getaddrinfo()
|
H A D | pipe.c | 151 int uv__pipe_listen(uv_pipe_t* handle, int backlog, uv_connection_cb cb) { in uv__pipe_listen() argument 170 handle->connection_cb = cb; in uv__pipe_listen() 171 handle->io_watcher.cb = uv__server_io; in uv__pipe_listen() 233 uv_connect_cb cb) { in uv_pipe_connect() argument 236 err = uv_pipe_connect2(req, handle, name, strlen(name), 0, cb); in uv_pipe_connect() 244 req->cb = cb; in uv_pipe_connect() 258 uv_connect_cb cb) { in uv_pipe_connect2() argument 337 req->cb = cb; in uv_pipe_connect2()
|
H A D | loop-watcher.c | 32 int uv_##name##_start(uv_##name##_t* handle, uv_##name##_cb cb) { \ 34 if (cb == NULL) return UV_EINVAL; \ 36 handle->name##_cb = cb; \
|
H A D | kqueue.c | 207 if (w->cb == uv__fs_event) { in uv__io_poll() 369 w->cb(loop, w, w->events); in uv__io_poll() 379 w->cb(loop, w, ev->fflags); /* XXX always uv__fs_event() */ in uv__io_poll() 423 w->cb(loop, w, revents); in uv__io_poll() 443 loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN); in uv__io_poll() 545 handle->cb(handle, path, events, 0); in uv__fs_event() 568 uv_fs_event_cb cb, in uv_fs_event_start() argument 579 handle->cb = cb; in uv_fs_event_start()
|
H A D | stream.c | 656 if (req->cb != NULL) in uv__drain() 657 req->cb(req, err); in uv__drain() 926 if (req->cb) in uv__write_callbacks() 927 req->cb(req, req->error); in uv__write_callbacks() 1178 req->cb = cb; in uv_shutdown() 1282 if (req->cb) in uv__stream_connect() 1283 req->cb(req, error); in uv__stream_connect() 1338 uv_write_cb cb) { in uv_write2() argument 1356 req->cb = cb; in uv_write2() 1409 uv_write_cb cb) { in uv_write() argument [all …]
|
H A D | tcp.c | 281 uv_connect_cb cb) { in uv__tcp_connect() argument 338 req->cb = cb; in uv__tcp_connect() 421 int uv__tcp_listen(uv_tcp_t* tcp, int backlog, uv_connection_cb cb) { in uv__tcp_listen() argument 443 tcp->connection_cb = cb; in uv__tcp_listen() 447 tcp->io_watcher.cb = uv__server_io; in uv__tcp_listen()
|
H A D | sunos.c | 310 w->cb(loop, w, pe->portev_events); in uv__io_poll() 332 loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN); in uv__io_poll() 497 handle->cb(handle, NULL, events, 0); in uv__fs_event_read() 502 handle->cb(handle, NULL, 0, r); in uv__fs_event_read() 516 uv_fs_event_cb cb, in uv_fs_event_start() argument 538 handle->cb = cb; in uv_fs_event_start() 605 uv_fs_event_cb cb, in uv_fs_event_start() argument
|
/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); 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); 154 int uv_fs_lstat(uv_loop_t* loop, uv_fs_t* req, const char* path, uv_fs_cb cb); [all …]
|
/libuv/src/ |
H A D | random.c | 90 req->cb(req, status, req->buf, req->buflen); in uv__random_done() 99 uv_random_cb cb) { in uv_random() argument 106 if (cb == NULL) in uv_random() 112 req->cb = cb; in uv_random()
|
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/docs/src/ |
H A D | fs.rst | 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) 271 .. c:function:: int uv_fs_mkdtemp(uv_loop_t* loop, uv_fs_t* req, const char* tpl, 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) 366 .. c:function:: int uv_fs_fsync(uv_loop_t* loop, uv_fs_t* req, uv_file file, uv_fs_cb cb) [all …]
|
H A D | prepare.rst | 40 .. c:function:: int uv_prepare_start(uv_prepare_t* prepare, uv_prepare_cb cb) 43 except when `cb` is `NULL`. 45 :returns: 0 on success, or `UV_EINVAL` when `cb == NULL`.
|
H A D | check.rst | 40 .. c:function:: int uv_check_start(uv_check_t* check, uv_check_cb cb) 43 except when `cb` is `NULL`. 45 :returns: 0 on success, or `UV_EINVAL` when `cb == NULL`.
|
H A D | idle.rst | 48 .. c:function:: int uv_idle_start(uv_idle_t* idle, uv_idle_cb cb) 51 except when `cb` is `NULL`. 53 :returns: 0 on success, or `UV_EINVAL` when `cb == NULL`.
|
H A D | stream.rst | 107 .. c:function:: int uv_shutdown(uv_shutdown_t* req, uv_stream_t* handle, uv_shutdown_cb cb) 111 `req` should be an uninitialized shutdown request struct. The `cb` is called 114 .. c:function:: int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) 159 …te(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_write_cb cb) 165 void cb(uv_write_t* req, int status) { 183 uv_write(&req1, stream, a, 2, cb); 184 uv_write(&req2, stream, b, 2, cb); 190 …eam_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb)
|
/libuv/test/ |
H A D | test-loop-time.c | 37 static void cb(uv_timer_t* timer) { in cb() function 59 r = uv_timer_start(&timer, cb, 1000, 0); /* 1 sec */ in TEST_IMPL()
|
/libuv/docs/code/uvtee/ |
H A D | main.c | 36 void write_data(uv_stream_t *dest, size_t size, uv_buf_t buf, uv_write_cb cb) { in write_data() argument 40 uv_write((uv_write_t*) req, (uv_stream_t*)dest, &req->buf, 1, cb); in write_data()
|