| /third_party/libuv/test/ |
| 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()
|
| 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()
|
| 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()
|
| 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()
|
| 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()
|
| 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()
|
| 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()
|
| 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()
215 const uv_buf_t* buf) { in on_read_listen_after_bound_twice()
331 uv_buf_t* buf) { in on_read_alloc()
337 static void on_tcp_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in on_tcp_read()
352 const uv_buf_t* buf) { in on_read_connection()
354 uv_buf_t outbuf; in on_read_connection()
411 const uv_buf_t* buf) { in on_read_send_zero()
572 const uv_buf_t* buf) { in on_tcp_child_process_read()
[all …]
|
| 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()
|
| 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()
|
| 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()
|
| 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);
80 const uv_buf_t* buf) { in after_read()
153 uv_buf_t* buf) { in echo_alloc()
160 uv_buf_t* buf) { in slab_alloc()
229 const uv_buf_t* rcvbuf, in on_recv()
232 uv_buf_t sndbuf; in on_recv()
|
| 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()
|
| /third_party/node/src/ |
| D | spawn_sync.h | 46 inline void OnAlloc(size_t suggested_size, uv_buf_t* buf) const;
47 inline void OnRead(const uv_buf_t* buf, size_t nread);
79 uv_buf_t input_buffer);
100 inline void OnAlloc(size_t suggested_size, uv_buf_t* buf);
101 inline void OnRead(const uv_buf_t* buf, ssize_t nread);
110 uv_buf_t* buf);
113 const uv_buf_t* buf);
122 uv_buf_t input_buffer_;
185 uv_buf_t input_buffer);
|
| D | stream_base.h | 133 virtual uv_buf_t OnStreamAlloc(size_t suggested_size) = 0;
142 const uv_buf_t& buf) = 0;
199 uv_buf_t OnStreamAlloc(size_t suggested_size) override;
200 void OnStreamRead(ssize_t nread, const uv_buf_t& buf) override;
208 uv_buf_t OnStreamAlloc(size_t suggested_size) override;
209 void OnStreamRead(ssize_t nread, const uv_buf_t& buf) override;
212 explicit CustomBufferJSListener(uv_buf_t buffer) : buffer_(buffer) {} in CustomBufferJSListener()
215 uv_buf_t buffer_;
246 virtual int DoTryWrite(uv_buf_t** bufs, size_t* count);
261 uv_buf_t* bufs,
[all …]
|
| D | udp_wrap.h | 45 virtual uv_buf_t OnAlloc(size_t suggested_size) = 0;
51 const uv_buf_t& buf,
95 virtual ssize_t Send(uv_buf_t* bufs,
153 uv_buf_t OnAlloc(size_t suggested_size) override;
155 const uv_buf_t& buf,
164 ssize_t Send(uv_buf_t* bufs,
205 uv_buf_t* buf);
208 const uv_buf_t* buf,
|
| D | stream_pipe.h | 53 uv_buf_t OnStreamAlloc(size_t suggested_size) override;
54 void OnStreamRead(ssize_t nread, const uv_buf_t& buf) override;
60 uv_buf_t OnStreamAlloc(size_t suggested_size) override;
61 void OnStreamRead(ssize_t nread, const uv_buf_t& buf) override;
|
| D | stream_wrap.h | 54 int DoTryWrite(uv_buf_t** bufs, size_t* count) override;
56 uv_buf_t* bufs,
107 void OnUvAlloc(size_t suggested_size, uv_buf_t* buf);
108 v8::Maybe<void> OnUvRead(ssize_t nread, const uv_buf_t* buf);
|
| /third_party/node/deps/uv/include/uv/ |
| D | unix.h | 121 typedef struct uv_buf_t { struct
124 } uv_buf_t; typedef
263 uv_buf_t* bufs; \
266 uv_buf_t bufsml[4]; \
277 uv_buf_t* bufs; \
280 uv_buf_t bufsml[4]; \
365 uv_buf_t* bufs; \
372 uv_buf_t bufsml[4]; \
|
| D | win.h | 233 typedef struct uv_buf_t { struct
236 } uv_buf_t; typedef
391 uv_buf_t write_buffer; \
449 uv_buf_t read_buffer; \
465 uv_buf_t recv_buffer; \
509 uv_buf_t read_line_buffer; \
630 uv_buf_t* bufs; \
632 uv_buf_t bufsml[4]; \
|
| /third_party/libuv/include/uv/ |
| D | unix.h | 121 typedef struct uv_buf_t { struct
124 } uv_buf_t; argument
264 uv_buf_t* bufs; \
267 uv_buf_t bufsml[4]; \
278 uv_buf_t* bufs; \
281 uv_buf_t bufsml[4]; \
366 uv_buf_t* bufs; \
373 uv_buf_t bufsml[4]; \
|
| /third_party/libuv/docs/code/udp-dhcp/ |
| 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()
|
| /third_party/libuv/docs/src/ |
| 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) {
|
| /third_party/libuv/docs/code/uvtee/ |
| 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()
|
| /third_party/libuv/docs/code/multi-echo-server/ |
| 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()
|