Home
last modified time | relevance | path

Searched refs:req (Results 101 – 125 of 163) sorted by relevance

1234567

/libuv/docs/code/udp-dhcp/
H A Dmain.c17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsign… in on_read() argument
20 uv_close((uv_handle_t*) req, NULL); in on_read()
39 uv_udp_recv_stop(req); in on_read()
98 void on_send(uv_udp_send_t *req, int status) { in on_send() argument
/libuv/test/
H A Dtest-callback-stack.c62 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument
125 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
148 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
161 if (uv_write(&write_req, (uv_stream_t*)req->handle, &buf, 1, write_cb)) { in connect_cb()
H A Dtest-multiple-listen.c67 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
68 ASSERT_NOT_NULL(req); in connect_cb()
70 free(req); in connect_cb()
H A Dtest-ipc-heavy-traffic-deadlock-bug.c49 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
51 container_of(req, struct write_info, write_req); in write_cb()
57 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument
59 uv_close((uv_handle_t*) req->handle, NULL); in shutdown_cb()
H A Dbenchmark-multi-accept.c83 static void ipc_write_cb(uv_write_t* req, int status);
85 static void ipc_connect_cb(uv_connect_t* req, int status);
100 static void cl_connect_cb(uv_connect_t* req, int status);
139 static void ipc_write_cb(uv_write_t* req, int status) { in ipc_write_cb() argument
141 ctx = container_of(req, struct ipc_peer_ctx, write_req); in ipc_write_cb()
153 static void ipc_connect_cb(uv_connect_t* req, int status) { in ipc_connect_cb() argument
155 ctx = container_of(req, struct ipc_client_ctx, connect_req); in ipc_connect_cb()
330 static void cl_connect_cb(uv_connect_t* req, int status) { in cl_connect_cb() argument
331 struct client_ctx* ctx = container_of(req, struct client_ctx, connect_req); in cl_connect_cb()
H A Dtest-shutdown-eof.c74 static void shutdown_cb(uv_shutdown_t *req, int status) { in shutdown_cb() argument
75 ASSERT_PTR_EQ(req, &shutdown_req); in shutdown_cb()
87 static void connect_cb(uv_connect_t *req, int status) { in connect_cb() argument
89 ASSERT_PTR_EQ(req, &connect_req); in connect_cb()
H A Dtest-delayed-accept.c135 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
138 ASSERT_NOT_NULL(req); in connect_cb()
143 r = uv_read_start((uv_stream_t*)(req->handle), alloc_cb, read_cb); in connect_cb()
148 free(req); in connect_cb()
H A Dbenchmark-pound.c93 static void after_write(uv_write_t* req, int status) { in after_write() argument
96 uv_close((uv_handle_t*)req->handle, close_cb); in after_write()
103 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
112 uv_close((uv_handle_t*)req->handle, close_cb); in connect_cb()
117 ASSERT_NOT_NULL(req); in connect_cb()
120 conn = (conn_rec*)req->data; in connect_cb()
H A Dtest-udp-ipv6.c38 #define CHECK_REQ(req) \ argument
39 ASSERT_PTR_EQ((req), &req_);
81 static void send_cb(uv_udp_send_t* req, int status) { in send_cb() argument
82 CHECK_REQ(req); in send_cb()
83 CHECK_HANDLE(req->handle); in send_cb()
H A Dtest-tcp-alloc-cb-fail.c44 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
64 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
72 r = uv_write(&write_req, req->handle, &buf, 1, write_cb); in connect_cb()
H A Dtest-tcp-write-queue-order.c55 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
64 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
77 req->handle, in connect_cb()
H A Dblackhole-server.c38 static void shutdown_cb(uv_shutdown_t* req, int status);
88 static void shutdown_cb(uv_shutdown_t* req, int status) { in shutdown_cb() argument
89 conn_rec* conn = container_of(req, conn_rec, shutdown_req); in shutdown_cb()
H A Dtest-udp-send-immediate.c58 static void cl_send_cb(uv_udp_send_t* req, int status) { in cl_send_cb() argument
59 ASSERT_NOT_NULL(req); in cl_send_cb()
61 CHECK_HANDLE(req->handle); in cl_send_cb()
H A Dtest-tcp-connect-error.c52 uv_connect_t req; in TEST_IMPL() local
58 r = uv_tcp_connect(&req, in TEST_IMPL()
H A Dtest-connect-unspecified.c25 static void connect_4(uv_connect_t* req, int status) { in connect_4() argument
29 static void connect_6(uv_connect_t* req, int status) { in connect_6() argument
H A Dbenchmark-udp-pummel.c72 static void send_cb(uv_udp_send_t* req, int status) { in send_cb() argument
75 ASSERT_NOT_NULL(req); in send_cb()
85 s = container_of(req, struct sender_state, send_req); in send_cb()
86 ASSERT_PTR_EQ(req->handle, &s->udp_handle); in send_cb()
H A Dtest-tcp-create-socket-early.c34 static void on_connect(uv_connect_t* req, int status) { in on_connect() argument
36 uv_close((uv_handle_t*) req->handle, NULL); in on_connect()
77 static void tcp_connector(uv_loop_t* loop, uv_tcp_t* client, uv_connect_t* req) { in tcp_connector() argument
86 r = uv_tcp_connect(req, in tcp_connector()
H A Dtest-udp-open.c129 static void send_cb(uv_udp_send_t* req, int status) { in send_cb() argument
130 ASSERT_NOT_NULL(req); in send_cb()
134 uv_close((uv_handle_t*)req->handle, close_cb); in send_cb()
308 uv_udp_send_t req; in TEST_IMPL() local
334 r = uv_udp_send(&req, in TEST_IMPL()
H A Dtest-tcp-read-stop.c35 static void write_cb(uv_write_t* req, int status) { in write_cb() argument
52 static void connect_cb(uv_connect_t* req, int status) { in connect_cb() argument
H A Dtest-tcp-reuseport.c124 static void on_connect(uv_connect_t* req, int status) { in on_connect() argument
126 ASSERT_NOT_NULL(req->handle); in on_connect()
127 ASSERT_PTR_EQ(req->handle->loop, main_loop); in on_connect()
130 uv_close((uv_handle_t*) req->handle, NULL); in on_connect()
/libuv/docs/code/cgi/
H A Dmain.c11 void cleanup_handles(uv_process_t *req, int64_t exit_status, int term_signal) { in cleanup_handles() argument
13 uv_close((uv_handle_t*) req->data, NULL); in cleanup_handles()
14 uv_close((uv_handle_t*) req, NULL); in cleanup_handles()
/libuv/docs/code/spawn/
H A Dmain.c10 void on_exit(uv_process_t *req, int64_t exit_status, int term_signal) { in on_exit() argument
12 uv_close((uv_handle_t*) req, NULL); in on_exit()
/libuv/docs/code/tty/
H A Dmain.c10 uv_write_t req; in main() local
27 uv_write(&req, (uv_stream_t*) &tty, &buf, 1, NULL); in main()
/libuv/docs/code/idle-compute/
H A Dmain.c20 void on_type(uv_fs_t *req) { in on_type() argument
30 fprintf(stderr, "error opening file: %s\n", uv_strerror(req->result)); in on_type()
/libuv/docs/code/proc-streams/
H A Dmain.c11 void on_exit(uv_process_t *req, int64_t exit_status, int term_signal) { in on_exit() argument
13 uv_close((uv_handle_t*) req, NULL); in on_exit()

Completed in 40 milliseconds

1234567