/libuv/src/win/ |
H A D | poll.c | 78 uv_req_t* req; in uv__fast_poll_submit_poll_req() local 84 req = &handle->poll_req_1; in uv__fast_poll_submit_poll_req() 90 req = &handle->poll_req_2; in uv__fast_poll_submit_poll_req() 125 memset(&req->u.io.overlapped, 0, sizeof req->u.io.overlapped); in uv__fast_poll_submit_poll_req() 140 uv_req_t* req) { in uv__fast_poll_process_poll_req() argument 158 if (!REQ_SUCCESS(req)) { in uv__fast_poll_process_poll_req() 330 SET_REQ_SUCCESS(req); in uv__slow_poll_thread_proc() 339 uv_req_t* req; in uv__slow_poll_submit_poll_req() local 343 req = &handle->poll_req_1; in uv__slow_poll_submit_poll_req() 369 uv_req_t* req) { in uv__slow_poll_process_poll_req() argument [all …]
|
H A D | internal.h | 86 uv_write_t* req); 88 uv_req_t* req); 90 uv_connect_t* req); 139 uv_req_t* req); 141 uv_write_t* req); 145 uv_connect_t* req); 168 uv_req_t* req); 170 uv_write_t* req); 183 uv_req_t* req); 208 uv_req_t* req); [all …]
|
H A D | stream.c | 114 int uv_write(uv_write_t* req, in uv_write() argument 133 loop, req, (uv_pipe_t*) handle, bufs, nbufs, NULL, cb); in uv_write() 146 int uv_write2(uv_write_t* req, 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() 212 UV_REQ_INIT(req, UV_SHUTDOWN); in uv_shutdown() 213 req->handle = handle; in uv_shutdown() 214 req->cb = cb; in uv_shutdown() 217 handle->stream.conn.shutdown_req = req; in uv_shutdown() 223 uv__pipe_shutdown(loop, (uv_pipe_t*) handle, req); in uv_shutdown() [all …]
|
/libuv/docs/code/pipe-echo-server/ |
H A D | main.c | 15 uv_write_t req; member 19 void free_write_req(uv_write_t *req) { in free_write_req() argument 20 write_req_t *wr = (write_req_t*) req; in free_write_req() 30 void echo_write(uv_write_t *req, int status) { in echo_write() argument 34 free_write_req(req); in echo_write() 39 write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t)); in echo_read() local 40 req->buf = uv_buf_init(buf->base, nread); in echo_read() 41 uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write); in echo_read() 71 uv_fs_t req; in remove_sock() local 72 uv_fs_unlink(loop, &req, PIPENAME, NULL); in remove_sock()
|
/libuv/src/unix/ |
H A D | udp.c | 64 uv_udp_send_t* req; in uv__udp_finish_close() local 92 uv_udp_send_t* req; in uv__udp_run_completed() local 105 handle->send_queue_size -= uv__count_bufs(req->bufs, req->nbufs); in uv__udp_run_completed() 108 if (req->bufs != req->bufsml) in uv__udp_run_completed() 110 req->bufs = NULL; in uv__udp_run_completed() 119 req->send_cb(req, 0); in uv__udp_run_completed() 121 req->send_cb(req, req->status); in uv__udp_run_completed() 340 uv_udp_send_t* req; in uv__udp_sendmsg_many() local 408 req->status = req->bufs[0].len; in uv__udp_sendmsg_many() 755 req->bufs = req->bufsml; in uv__udp_send() [all …]
|
H A D | internal.h | 348 uv_fs_t* req, 354 uv_fs_t* req, 358 uv_fs_t* req, 364 #define uv__iou_fs_close(loop, req) 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 370 #define uv__iou_fs_rename(loop, req) 0 argument 372 #define uv__iou_fs_symlink(loop, req) 0 argument 373 #define uv__iou_fs_unlink(loop, req) 0 argument [all …]
|
/libuv/test/ |
H A D | benchmark-pump.c | 193 req_free((uv_req_t*) req); in write_cb() 203 uv_write_t* req; in do_write() local 245 uv_connect_t* req; in maybe_connect_some() local 319 req_list_t* req; in req_alloc() local 321 req = req_freelist; in req_alloc() 322 if (req != NULL) { in req_alloc() 324 return (uv_req_t*) req; in req_alloc() 327 req = (req_list_t*) malloc(sizeof *req); in req_alloc() 328 return (uv_req_t*) req; in req_alloc() 335 req->next = req_freelist; in req_free() [all …]
|
H A D | test-tcp-close.c | 36 static void connect_cb(uv_connect_t* req, int status); 37 static void write_cb(uv_write_t* req, int status); 42 uv_write_t* req; in connect_cb() local 48 req = malloc(sizeof *req); in connect_cb() 49 ASSERT_NOT_NULL(req); in connect_cb() 51 r = uv_write(req, (uv_stream_t*)&tcp_handle, &buf, 1, write_cb); in connect_cb() 59 static void write_cb(uv_write_t* req, int status) { in write_cb() argument 62 ASSERT_PTR_EQ(req->handle, (uv_stream_t*)&tcp_handle); in write_cb() 64 free(req); in write_cb()
|
H A D | test-metrics.c | 156 static void close_cb(uv_fs_t* req) { in close_cb() argument 163 uv_fs_req_cleanup(req); in close_cb() 168 static void write_cb(uv_fs_t* req) { in write_cb() argument 176 uv_fs_req_cleanup(req); in write_cb() 192 ASSERT_GE(req->result, 0); in create_cb() 194 uv_fs_req_cleanup(req); in create_cb() 200 req->result, in create_cb() 262 uv_fs_req_cleanup(req); in fs_stat_cb() 272 free(req); in fs_after_work_cb() 282 uv_fs_req_cleanup(req); in fs_write_cb() [all …]
|
H A D | test-shutdown-close.c | 39 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument 40 ASSERT_PTR_EQ(req, &shutdown_req); in shutdown_cb() 51 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument 54 ASSERT_PTR_EQ(req, &connect_req); in connect_cb() 57 r = uv_shutdown(&shutdown_req, req->handle, shutdown_cb); in connect_cb() 59 ASSERT_OK(uv_is_closing((uv_handle_t*) req->handle)); in connect_cb() 60 uv_close((uv_handle_t*) req->handle, close_cb); in connect_cb() 61 ASSERT_EQ(1, uv_is_closing((uv_handle_t*) req->handle)); in connect_cb()
|
H A D | test-ping-pong.c | 87 free(req->data); in pinger_after_write() 88 free(req); in pinger_after_write() 94 uv_write_t* req; in pinger_write_ping() local 112 req = malloc(sizeof(*req)); in pinger_write_ping() 113 ASSERT_NOT_NULL(req); in pinger_write_ping() 114 req->data = NULL; in pinger_write_ping() 167 uv_write_t* req; in ponger_read_cb() local 188 req = malloc(sizeof(*req)); in ponger_read_cb() 189 ASSERT_NOT_NULL(req); in ponger_read_cb() 190 req->data = buf->base; in ponger_read_cb() [all …]
|
H A D | test-getaddrinfo.c | 39 static void getaddrinfo_fail_cb(uv_getaddrinfo_t* req, in getaddrinfo_fail_cb() argument 90 uv_getaddrinfo_t req; in TEST_IMPL() local 93 &req, in TEST_IMPL() 101 &req, in TEST_IMPL() 119 uv_getaddrinfo_t req; in TEST_IMPL() local 123 &req, in TEST_IMPL() 128 uv_freeaddrinfo(req.addrinfo); in TEST_IMPL() 166 uv_getaddrinfo_t req; in TEST_IMPL() local 169 &req, in TEST_IMPL() 174 uv_freeaddrinfo(req.addrinfo); in TEST_IMPL()
|
H A D | test-tcp-read-stop-start.c | 35 static void on_write_close_immediately(uv_write_t* req, int status) { in on_write_close_immediately() argument 38 uv_close((uv_handle_t*)req->handle, NULL); /* Close immediately */ in on_write_close_immediately() 39 free(req); in on_write_close_immediately() 42 static void on_write(uv_write_t* req, int status) { in on_write() argument 45 free(req); in on_write() 49 uv_write_t* req = malloc(sizeof(*req)); in do_write() local 53 ASSERT_OK(uv_write(req, stream, &buf, 1, cb)); in do_write() 98 static void on_connect(uv_connect_t* req, int status) { in on_connect() argument
|
H A D | test-threadpool.c | 31 static void work_cb(uv_work_t* req) { in work_cb() argument 32 ASSERT_PTR_EQ(req, &work_req); in work_cb() 33 ASSERT_PTR_EQ(req->data, &data); in work_cb() 38 static void after_work_cb(uv_work_t* req, int status) { in after_work_cb() argument 40 ASSERT_PTR_EQ(req, &work_req); in after_work_cb() 41 ASSERT_PTR_EQ(req->data, &data); in after_work_cb()
|
H A D | benchmark-queue-work.c | 35 static void work_cb(uv_work_t* req) { in work_cb() argument 36 req->data = &result; in work_cb() 37 *(unsigned*)req->data = fastrand(); in work_cb() 40 static void after_work_cb(uv_work_t* req, int status) { in after_work_cb() argument 43 ASSERT_OK(uv_queue_work(req->loop, req, work_cb, after_work_cb)); in after_work_cb()
|
H A D | test-shutdown-twice.c | 39 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument 40 ASSERT_PTR_EQ(req, &req1); in shutdown_cb() 43 uv_close((uv_handle_t*) req->handle, close_cb); in shutdown_cb() 46 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument 51 r = uv_shutdown(&req1, req->handle, shutdown_cb); in connect_cb() 53 r = uv_shutdown(&req2, req->handle, shutdown_cb); in connect_cb()
|
H A D | test-udp-dgram-too-big.c | 32 #define CHECK_REQ(req) \ argument 33 ASSERT_PTR_EQ((req), &req_); 48 static void send_cb(uv_udp_send_t* req, int status) { in send_cb() argument 49 CHECK_REQ(req); in send_cb() 50 CHECK_HANDLE(req->handle); in send_cb() 54 uv_close((uv_handle_t*)req->handle, close_cb); in send_cb()
|
H A D | benchmark-ping-pongs.c | 92 static void pinger_write_cb(uv_write_t* req, int status) { in pinger_write_cb() argument 95 free(req); in pinger_write_cb() 100 uv_write_t* req; in pinger_write_ping() local 105 req = malloc(sizeof *req); in pinger_write_ping() 106 if (uv_write(req, (uv_stream_t*) &pinger->tcp, &buf, 1, pinger_write_cb)) { in pinger_write_ping() 112 static void pinger_shutdown_cb(uv_shutdown_t* req, int status) { in pinger_shutdown_cb() argument 166 static void pinger_connect_cb(uv_connect_t* req, int status) { in pinger_connect_cb() argument 167 pinger_t *pinger = (pinger_t*)req->handle->data; in pinger_connect_cb() 173 if (uv_read_start(req->handle, buf_alloc, pinger_read_cb)) { in pinger_connect_cb()
|
H A D | test-getnameinfo.c | 35 static uv_getnameinfo_t req; variable 60 &req, in TEST_IMPL() 82 &req, in TEST_IMPL() 86 ASSERT_NE(req.host[0], '\0'); in TEST_IMPL() 87 ASSERT_NE(req.service[0], '\0'); in TEST_IMPL() 106 &req, in TEST_IMPL()
|
H A D | test-udp-multicast-ttl.c | 45 static void sv_send_cb(uv_udp_send_t* req, int status) { in sv_send_cb() argument 46 ASSERT_NOT_NULL(req); in sv_send_cb() 48 CHECK_HANDLE(req->handle); in sv_send_cb() 52 uv_close((uv_handle_t*) req->handle, close_cb); in sv_send_cb() 58 uv_udp_send_t req; in TEST_IMPL() local 75 r = uv_udp_send(&req, in TEST_IMPL()
|
/libuv/docs/code/queue-work/ |
H A D | main.c | 17 void fib(uv_work_t *req) { in fib() argument 18 int n = *(int *) req->data; in fib() 27 void after_fib(uv_work_t *req, int status) { in after_fib() argument 28 fprintf(stderr, "Done calculating %dth fibonacci\n", *(int *) req->data); in after_fib() 35 uv_work_t req[FIB_UNTIL]; in main() local 39 req[i].data = (void *) &data[i]; in main() 40 uv_queue_work(loop, &req[i], fib, after_fib); in main()
|
/libuv/docs/code/multi-echo-server/ |
H A D | worker.c | 12 uv_write_t req; member 16 void free_write_req(uv_write_t *req) { in free_write_req() argument 17 write_req_t *wr = (write_req_t*) req; in free_write_req() 27 void echo_write(uv_write_t *req, int status) { in echo_write() argument 31 free_write_req(req); in echo_write() 36 write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t)); in echo_read() local 37 req->buf = uv_buf_init(buf->base, nread); in echo_read() 38 uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write); in echo_read()
|
/libuv/docs/code/tcp-echo-server/ |
H A D | main.c | 13 uv_write_t req; member 17 void free_write_req(uv_write_t *req) { in free_write_req() argument 18 write_req_t *wr = (write_req_t*) req; in free_write_req() 32 void echo_write(uv_write_t *req, int status) { in echo_write() argument 36 free_write_req(req); in echo_write() 41 write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t)); in echo_read() local 42 req->buf = uv_buf_init(buf->base, nread); in echo_read() 43 uv_write((uv_write_t*) req, client, &req->buf, 1, echo_write); in echo_read()
|
/libuv/docs/code/progress/ |
H A D | main.c | 12 void fake_download(uv_work_t *req) { in fake_download() argument 13 int size = *((int*) req->data); in fake_download() 26 void after(uv_work_t *req, int status) { in after() argument 39 uv_work_t req; in main() local 41 req.data = (void*) &size; in main() 44 uv_queue_work(loop, &req, fake_download, after); in main()
|
/libuv/docs/code/queue-cancel/ |
H A D | main.c | 18 void fib(uv_work_t *req) { in fib() argument 19 int n = *(int *) req->data; in fib() 28 void after_fib(uv_work_t *req, int status) { in after_fib() argument 30 fprintf(stderr, "Calculation of %d cancelled.\n", *(int *) req->data); in after_fib() 33 void signal_handler(uv_signal_t *req, int signum) in signal_handler() argument 40 uv_signal_stop(req); in signal_handler()
|