Home
last modified time | relevance | path

Searched refs:req (Results 76 – 100 of 163) sorted by relevance

1234567

/libuv/test/
H A Dtest-udp-multicast-join.c36 static uv_udp_send_t req; variable
62 static void sv_send_cb(uv_udp_send_t* req, int status) { in sv_send_cb() argument
63 ASSERT_NOT_NULL(req); in sv_send_cb()
65 CHECK_HANDLE(req->handle); in sv_send_cb()
70 uv_close((uv_handle_t*) req->handle, close_cb); in sv_send_cb()
168 r = do_send(&req); in TEST_IMPL()
H A Dtest-pipe-connect-error.c63 uv_connect_t req; in TEST_IMPL() local
68 uv_pipe_connect(&req, &client, BAD_PIPENAME, connect_cb); in TEST_IMPL()
83 uv_connect_t req; in TEST_IMPL() local
88 uv_pipe_connect(&req, &client, path, connect_cb_file); in TEST_IMPL()
H A Dtest-tcp-shutdown-after-write.c25 static void write_cb(uv_write_t* req, int status);
26 static void shutdown_cb(uv_shutdown_t* req, int status);
80 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
91 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
97 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument
H A Dtest-close-fd.c53 uv_fs_t req; in TEST_IMPL() local
64 ASSERT_EQ(1, uv_fs_write(NULL, &req, fd[1], bufs, 1, -1, NULL)); in TEST_IMPL()
65 ASSERT_EQ(1, req.result); in TEST_IMPL()
66 uv_fs_req_cleanup(&req); in TEST_IMPL()
H A Dtest-tcp-close-accept.c49 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
54 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
59 if (req == &tcp_check_req) { in connect_cb()
72 ASSERT_LE(connect_reqs, req); in connect_cb()
73 ASSERT_LE(req, connect_reqs + ARRAY_SIZE(connect_reqs)); in connect_cb()
74 i = req - connect_reqs; in connect_cb()
H A Dtest-udp-send-unreachable.c62 static void send_cb(uv_udp_send_t* req, int status) { in send_cb() argument
63 ASSERT_NOT_NULL(req); in send_cb()
66 CHECK_HANDLE(req->handle); in send_cb()
70 static void send_cb_recverr(uv_udp_send_t* req, int status) { in send_cb_recverr() argument
71 ASSERT_PTR_NE(req, NULL); in send_cb_recverr()
73 CHECK_HANDLE(req->handle); in send_cb_recverr()
H A Dtest-udp-multicast-join6.c47 static uv_udp_send_t req; variable
73 static void sv_send_cb(uv_udp_send_t* req, int status) { in sv_send_cb() argument
74 ASSERT_NOT_NULL(req); in sv_send_cb()
76 CHECK_HANDLE(req->handle); in sv_send_cb()
81 uv_close((uv_handle_t*) req->handle, close_cb); in sv_send_cb()
207 r = do_send(&req); in TEST_IMPL()
H A Dtest-fork.c423 uv_fs_t req; in create_file() local
428 uv_fs_req_cleanup(&req); in create_file()
429 r = uv_fs_close(NULL, &req, file, NULL); in create_file()
431 uv_fs_req_cleanup(&req); in create_file()
438 uv_fs_t req; in touch_file() local
441 r = uv_fs_open(NULL, &req, name, O_RDWR, 0, NULL); in touch_file()
444 uv_fs_req_cleanup(&req); in touch_file()
449 uv_fs_req_cleanup(&req); in touch_file()
451 r = uv_fs_close(NULL, &req, file, NULL); in touch_file()
453 uv_fs_req_cleanup(&req); in touch_file()
[all …]
H A Dtest-tcp-write-to-half-open-connection.c30 static void connect_cb(uv_connect_t* req, int status);
31 static void write_cb(uv_write_t* req, int status);
90 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
91 ASSERT_PTR_EQ(req, &connect_req); in connect_cb()
99 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
H A Dtest-fs-event.c62 uv_fs_t req; in create_dir() local
65 uv_fs_req_cleanup(&req); in create_dir()
71 uv_fs_t req; in create_file() local
78 uv_fs_req_cleanup(&req); in create_file()
81 uv_fs_req_cleanup(&req); in create_file()
86 uv_fs_t req; in delete_dir() local
88 uv_fs_req_cleanup(&req); in delete_dir()
94 uv_fs_t req; in delete_file() local
96 uv_fs_req_cleanup(&req); in delete_file()
103 uv_fs_t req; in touch_file() local
[all …]
H A Dtest-tcp-connect6-error.c51 uv_connect_t req; in TEST_IMPL() local
60 r = uv_tcp_connect(&req, in TEST_IMPL()
82 uv_connect_t req; in TEST_IMPL() local
119 ASSERT_OK(uv_tcp_connect(&req, in TEST_IMPL()
H A Dtest-tcp-write-after-connect.c34 static void write_cb(uv_write_t *req, int status) { in write_cb() argument
36 uv_close((uv_handle_t*) req->handle, NULL); in write_cb()
40 static void connect_cb(uv_connect_t *req, int status) { in connect_cb() argument
H A Dtest-tcp-close-reset.c49 static void connect_cb(uv_connect_t* req, int status);
50 static void write_cb(uv_write_t* req, int status);
52 static void shutdown_cb(uv_shutdown_t* req, int status);
121 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
124 ASSERT_PTR_EQ(req->handle, (uv_stream_t*)&tcp_client); in write_cb()
138 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument
140 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &tcp_client); in shutdown_cb()
142 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &tcp_accepted); in shutdown_cb()
H A Dtest-tcp-connect-timeout.c35 static void connect_cb(uv_connect_t* req, int status);
40 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
41 ASSERT_PTR_EQ(req, &connect_req); in connect_cb()
97 static void connect_local_cb(uv_connect_t* req, int status) { in connect_local_cb() argument
98 ASSERT_PTR_EQ(req, &connect_req); in connect_local_cb()
H A Dtest-udp-sendmmsg-error.c31 static uv_udp_send_t req[DATAGRAMS]; variable
44 static void send_cb(uv_udp_send_t* req, int status) { in send_cb() argument
64 ASSERT_OK(uv_udp_send(&req[i], &client, &buf, 1, NULL, send_cb)); in TEST_IMPL()
H A Dtest-shutdown-simultaneous.c44 static void shutdown_cb(uv_shutdown_t *req, int status) { in shutdown_cb() argument
45 ASSERT_PTR_EQ(req, &shutdown_req); in shutdown_cb()
81 static void connect_cb(uv_connect_t *req, int status) { in connect_cb() argument
83 ASSERT_PTR_EQ(req, &connect_req); in connect_cb()
H A Dtest-tcp-unexpected-read.c62 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
63 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &client_handle); in connect_cb()
68 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
69 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &peer_handle); in write_cb()
H A Dtest-tcp-connect-error-after-write.c39 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
42 uv_close((uv_handle_t*)req->handle, close_cb); in connect_cb()
46 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
H A Dtest-stdio-over-pipes.c84 static void after_write(uv_write_t* req, int status) { in after_write() argument
91 free(req); in after_write()
98 uv_write_t* req; in on_read() local
109 req = malloc(sizeof(*req)); in on_read()
110 r = uv_write(req, (uv_stream_t*) &in, &wrbuf, 1, after_write); in on_read()
192 static void after_pipe_write(uv_write_t* req, int status) { in after_pipe_write() argument
/libuv/src/win/
H A Dfs-event.c41 memset(&(handle->req.u.io.overlapped), 0, in uv__fs_event_queue_readdirchanges()
42 sizeof(handle->req.u.io.overlapped)); in uv__fs_event_queue_readdirchanges()
59 SET_REQ_ERROR(&handle->req, GetLastError()); in uv__fs_event_queue_readdirchanges()
149 UV_REQ_INIT(&handle->req, UV_FS_EVENT_REQ); in uv_fs_event_init()
150 handle->req.data = handle; in uv_fs_event_init()
295 memset(&(handle->req.u.io.overlapped), 0, in uv_fs_event_start()
296 sizeof(handle->req.u.io.overlapped)); in uv_fs_event_start()
425 assert(req->type == UV_FS_EVENT_REQ); in uv__process_fs_event_req()
442 if (REQ_SUCCESS(req)) { in uv__process_fs_event_req()
443 if (req->u.io.overlapped.InternalHigh > 0) { in uv__process_fs_event_req()
[all …]
/libuv/docs/src/
H A Drequest.rst68 .. c:function:: int uv_cancel(uv_req_t* req)
85 * A :c:type:`uv_fs_t` request has its req->result field set to `UV_ECANCELED`.
96 .. c:function:: void* uv_req_get_data(const uv_req_t* req)
98 Returns `req->data`.
102 .. c:function:: void uv_req_set_data(uv_req_t* req, void* data)
104 Sets `req->data` to `data`.
108 .. c:function:: uv_req_type uv_req_get_type(const uv_req_t* req)
110 Returns `req->type`.
/libuv/src/unix/
H A Dpipe.c230 void uv_pipe_connect(uv_connect_t* req, in uv_pipe_connect() argument
240 handle->connect_req = req; in uv_pipe_connect()
243 req->handle = (uv_stream_t*) handle; in uv_pipe_connect()
244 req->cb = cb; in uv_pipe_connect()
245 uv__queue_init(&req->queue); in uv_pipe_connect()
253 int uv_pipe_connect2(uv_connect_t* req, in uv_pipe_connect2() argument
333 handle->connect_req = req; in uv_pipe_connect2()
335 uv__req_init(handle->loop, req, UV_CONNECT); in uv_pipe_connect2()
336 req->handle = (uv_stream_t*) handle; in uv_pipe_connect2()
337 req->cb = cb; in uv_pipe_connect2()
[all …]
/libuv/src/
H A Dfs-poll.c52 static void poll_cb(uv_fs_t* req);
185 static void poll_cb(uv_fs_t* req) { in poll_cb() argument
191 ctx = container_of(req, struct poll_ctx, fs_req); in poll_cb()
197 if (req->result != 0) { in poll_cb()
198 if (ctx->busy_polling != req->result) { in poll_cb()
200 req->result, in poll_cb()
203 ctx->busy_polling = req->result; in poll_cb()
208 statbuf = &req->statbuf; in poll_cb()
218 uv_fs_req_cleanup(req); in poll_cb()
/libuv/docs/code/multi-echo-server/
H A Dmain.c10 uv_process_t req; member
21 void close_process_handle(uv_process_t *req, int64_t exit_status, int term_signal) { in close_process_handle() argument
23 uv_close((uv_handle_t*) req, NULL); in close_process_handle()
92 uv_spawn(loop, &worker->req, &worker->options); in setup_workers()
93 fprintf(stderr, "Started worker %d\n", worker->req.pid); in setup_workers()
/libuv/docs/code/dns/
H A Dmain.c32 void on_connect(uv_connect_t *req, int status) { in on_connect() argument
35 free(req); in on_connect()
39 uv_read_start((uv_stream_t*) req->handle, alloc_buffer, on_read); in on_connect()
40 free(req); in on_connect()

Completed in 61 milliseconds

1234567