/libuv/test/ |
H A D | benchmark-ping-pongs.c | 41 uv_buf_t uv_buf_t; member 56 static void buf_alloc(uv_handle_t* tcp, size_t size, uv_buf_t* buf) { in buf_alloc() 64 ab->uv_buf_t.len = size; in buf_alloc() 65 ab->uv_buf_t.base = (char*) (ab + 1); in buf_alloc() 68 *buf = ab->uv_buf_t; in buf_alloc() 72 static void buf_free(const uv_buf_t* buf) { in buf_free() 101 uv_buf_t buf; in pinger_write_ping() 126 const uv_buf_t* buf) { in pinger_read_cb()
|
H A D | benchmark-ping-udp.c | 39 uv_buf_t uv_buf_t; member 52 static void buf_alloc(uv_handle_t* tcp, size_t size, uv_buf_t* buf) { in buf_alloc() 59 static void buf_free(const uv_buf_t* buf) { in buf_free() 78 uv_buf_t buf; in pinger_write_ping() 90 const uv_buf_t* buf, in pinger_read_cb()
|
H A D | test-udp-alloc-cb-fail.c | 46 uv_buf_t* buf) { in sv_alloc_cb() 56 uv_buf_t* buf) { in cl_alloc_cb() 70 const uv_buf_t* buf, in cl_recv_cb() 111 const uv_buf_t* rcvbuf, in sv_recv_cb() 115 uv_buf_t sndbuf; in sv_recv_cb() 152 uv_buf_t buf; in TEST_IMPL()
|
H A D | benchmark-pump.c | 44 static void buf_alloc(uv_handle_t* handle, size_t size, uv_buf_t* buf); 45 static void buf_free(const uv_buf_t* buf); 171 static void read_cb(uv_stream_t* stream, ssize_t bytes, const uv_buf_t* buf) { in read_cb() 204 uv_buf_t buf; in do_write() 345 uv_buf_t uv_buf_t; member 353 static void buf_alloc(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in buf_alloc() 361 ab->uv_buf_t.len = size; in buf_alloc() 362 ab->uv_buf_t.base = (char*) (ab + 1); in buf_alloc() 365 *buf = ab->uv_buf_t; in buf_alloc() 369 static void buf_free(const uv_buf_t* buf) { in buf_free()
|
H A D | test-tcp-close-after-read-timeout.c | 38 uv_buf_t* buf); 41 const uv_buf_t* buf); 60 uv_buf_t* buf) { in on_client_alloc() 68 const uv_buf_t* buf) { in on_client_read() 85 uv_buf_t* buf) { in on_connection_alloc() 94 const uv_buf_t* buf) { in on_connection_read()
|
H A D | test-tcp-read-stop-start.c | 33 static void on_read2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf); 50 uv_buf_t buf; in do_write() 58 uv_buf_t* buf) { in on_alloc() 64 static void on_read1(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in on_read1() 79 static void on_read2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in on_read2()
|
H A D | test-tcp-write-to-half-open-connection.c | 32 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf); 33 static void alloc_cb(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf); 46 uv_buf_t buf; in connection_cb() 70 uv_buf_t* buf) { in alloc_cb() 77 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
H A D | test-udp-send-and-recv.c | 46 uv_buf_t* buf) { in alloc_cb() 64 const uv_buf_t* buf, in cl_recv_cb() 118 const uv_buf_t* rcvbuf, in sv_recv_cb() 122 uv_buf_t sndbuf; in sv_recv_cb() 163 uv_buf_t buf; in TEST_IMPL()
|
H A D | blackhole-server.c | 36 static void alloc_cb(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf); 37 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf); 65 uv_buf_t* buf) { in alloc_cb() 72 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
H A D | test-ipc.c | 102 uv_buf_t* buf) { in on_alloc() 145 const uv_buf_t* buf) { in on_read() 149 uv_buf_t outbuf; in on_read() 331 uv_buf_t* buf) { in on_read_alloc() 354 uv_buf_t outbuf; in on_read_connection() 573 uv_buf_t outbuf; in on_tcp_child_process_read() 611 uv_buf_t buf; in ipc_on_connection() 646 uv_buf_t buf; in ipc_on_connection_tcp_conn() 683 uv_buf_t buf; in ipc_helper() 788 uv_buf_t buf; in ipc_helper_bind_twice() [all …]
|
H A D | test-close-fd.c | 30 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() 36 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() 54 uv_buf_t bufs[1]; in TEST_IMPL()
|
H A D | test-not-readable-nor-writable-on-read-error.c | 43 uv_buf_t* buf) { in alloc_cb() 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() 65 uv_buf_t reset_me; in connect_cb()
|
H A D | benchmark-multi-accept.c | 88 const uv_buf_t* buf); 91 uv_buf_t* buf); 95 static void sv_read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf); 98 uv_buf_t* buf); 111 uv_buf_t buf; in ipc_connection_cb() 165 uv_buf_t* buf) { in ipc_alloc_cb() 175 const uv_buf_t* buf) { in ipc_read_cb() 315 uv_buf_t* buf) { in sv_alloc_cb() 324 const uv_buf_t* buf) { in sv_read_cb()
|
H A D | test-tcp-rst.c | 27 static uv_buf_t qbuf; 39 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() 46 static void read_cb(uv_stream_t* t, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
H A D | echo-server.c | 29 uv_buf_t buf; 43 static void after_read(uv_stream_t*, ssize_t nread, const uv_buf_t* buf); 82 const uv_buf_t* buf) { in after_read() 155 uv_buf_t* buf) { in echo_alloc() 162 uv_buf_t* buf) { in slab_alloc() 231 const uv_buf_t* rcvbuf, in on_recv() 234 uv_buf_t sndbuf; in on_recv()
|
H A D | test-tcp-open.c | 90 uv_buf_t* buf) { in alloc_cb() 113 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() 127 static void read1_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read1_cb() 155 uv_buf_t buf; in write1_cb() 186 uv_buf_t buf = uv_buf_init("PING", 4); in connect_cb() 210 uv_buf_t buf; in connect1_cb() 339 uv_buf_t buf = uv_buf_init("PING", 4); in TEST_IMPL()
|
H A D | test-stdio-over-pipes.c | 78 uv_buf_t* buf) { in on_alloc() 97 static void on_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* rdbuf) { in on_read() 99 uv_buf_t wrbuf; in on_read() 181 static void on_pipe_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* buf) { in on_pipe_read() 200 uv_buf_t* buf) { in on_read_alloc() 219 uv_buf_t buf[ARRAY_SIZE(buffers)]; in stdio_over_pipes_helper()
|
H A D | test-readable-on-eof.c | 43 uv_buf_t* buf) { in alloc_cb() 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() 72 uv_buf_t close_me; in connect_cb()
|
H A D | test-watcher-cross-stop.c | 42 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() 50 const uv_buf_t* buf, in recv_cb() 74 uv_buf_t buf; in TEST_IMPL()
|
H A D | test-iouring-pollhup.c | 44 uv_buf_t* buf) { in alloc_buffer() 51 const uv_buf_t* buf) { in read_data2() 80 const uv_buf_t* buf) { in read_data()
|
/libuv/docs/code/udp-dhcp/ |
H A D | main.c | 12 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in alloc_buffer() 17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsign… in on_read() 42 uv_buf_t make_discover_msg() { in make_discover_msg() 43 uv_buf_t buffer; in make_discover_msg() 121 uv_buf_t discover_msg = make_discover_msg(); in main()
|
/libuv/include/uv/ |
H A D | unix.h | 120 typedef struct uv_buf_t { struct 123 } uv_buf_t; typedef 262 uv_buf_t* bufs; \ 265 uv_buf_t bufsml[4]; \ 276 uv_buf_t* bufs; \ 279 uv_buf_t bufsml[4]; \ 367 uv_buf_t* bufs; \ 374 uv_buf_t bufsml[4]; \
|
/libuv/docs/code/multi-echo-server/ |
H A D | worker.c | 13 uv_buf_t buf; 22 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in alloc_buffer() 34 void echo_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in echo_read() 51 void on_new_connection(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf) { in on_new_connection()
|
/libuv/docs/code/uvtee/ |
H A D | main.c | 10 uv_buf_t buf; 18 void alloc_buffer(uv_handle_t *handle, size_t suggested_size, uv_buf_t *buf) { in alloc_buffer() 36 void write_data(uv_stream_t *dest, size_t size, uv_buf_t buf, uv_write_cb cb) { in write_data() 43 void read_stdin(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) { in read_stdin()
|
/libuv/docs/src/ |
H A D | migration_010_100.rst | 90 In libuv 0.10 the callback had to return a filled :c:type:`uv_buf_t` by value: 94 uv_buf_t alloc_cb(uv_handle_t* handle, size_t size) { 103 void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { 147 The streams and UDP data receive callbacks now get a pointer to a :c:type:`uv_buf_t` buffer, 156 uv_buf_t buf) { 162 uv_buf_t buf, 174 const uv_buf_t* buf) { 180 const uv_buf_t* buf, 198 uv_buf_t buf, 211 const uv_buf_t* buf) {
|