/libuv/docs/code/udp-dhcp/ |
H A D | main.c | 17 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 D | test-callback-stack.c | 62 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 D | test-multiple-listen.c | 67 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 D | test-ipc-heavy-traffic-deadlock-bug.c | 49 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 D | benchmark-multi-accept.c | 83 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 D | test-shutdown-eof.c | 74 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 D | test-delayed-accept.c | 135 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 D | benchmark-pound.c | 93 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 D | test-udp-ipv6.c | 38 #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 D | test-tcp-alloc-cb-fail.c | 44 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 D | test-tcp-write-queue-order.c | 55 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 D | blackhole-server.c | 38 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 D | test-udp-send-immediate.c | 58 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 D | test-tcp-connect-error.c | 52 uv_connect_t req; in TEST_IMPL() local 58 r = uv_tcp_connect(&req, in TEST_IMPL()
|
H A D | test-connect-unspecified.c | 25 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 D | benchmark-udp-pummel.c | 72 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 D | test-tcp-create-socket-early.c | 34 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 D | test-udp-open.c | 129 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 D | test-tcp-read-stop.c | 35 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 D | test-tcp-reuseport.c | 124 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 D | main.c | 11 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 D | main.c | 10 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 D | main.c | 10 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 D | main.c | 20 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 D | main.c | 11 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()
|