/libuv/test/ |
H A D | test-udp-multicast-join.c | 36 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 D | test-pipe-connect-error.c | 63 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 D | test-tcp-shutdown-after-write.c | 25 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 D | test-close-fd.c | 53 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 D | test-tcp-close-accept.c | 49 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 D | test-udp-send-unreachable.c | 62 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 D | test-udp-multicast-join6.c | 47 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 D | test-fork.c | 423 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 D | test-tcp-write-to-half-open-connection.c | 30 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 D | test-fs-event.c | 62 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 D | test-tcp-connect6-error.c | 51 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 D | test-tcp-write-after-connect.c | 34 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 D | test-tcp-close-reset.c | 49 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 D | test-tcp-connect-timeout.c | 35 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 D | test-udp-sendmmsg-error.c | 31 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 D | test-shutdown-simultaneous.c | 44 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 D | test-tcp-unexpected-read.c | 62 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 D | test-tcp-connect-error-after-write.c | 39 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 D | test-stdio-over-pipes.c | 84 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 D | fs-event.c | 41 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 D | request.rst | 68 .. 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 D | pipe.c | 230 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 D | fs-poll.c | 52 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 D | main.c | 10 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 D | main.c | 32 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()
|