Home
last modified time | relevance | path

Searched refs:req (Results 26 – 50 of 163) sorted by relevance

1234567

/libuv/src/win/
H A Dpoll.c78 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 Dinternal.h86 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 Dstream.c114 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 Dmain.c15 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 Dudp.c64 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 Dinternal.h348 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 Dbenchmark-pump.c193 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 Dtest-tcp-close.c36 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 Dtest-metrics.c156 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 Dtest-shutdown-close.c39 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 Dtest-ping-pong.c87 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 Dtest-getaddrinfo.c39 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 Dtest-tcp-read-stop-start.c35 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 Dtest-threadpool.c31 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 Dbenchmark-queue-work.c35 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 Dtest-shutdown-twice.c39 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 Dtest-udp-dgram-too-big.c32 #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 Dbenchmark-ping-pongs.c92 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 Dtest-getnameinfo.c35 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 Dtest-udp-multicast-ttl.c45 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 Dmain.c17 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 Dworker.c12 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 Dmain.c13 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 Dmain.c12 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 Dmain.c18 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()

Completed in 64 milliseconds

1234567