Home
last modified time | relevance | path

Searched refs:uv_buf_t (Results 1 - 25 of 169) sorted by relevance

1234567

/third_party/libuv/test/
H A Dbenchmark-ping-pongs.c41 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 Dbenchmark-pump.c44 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()
[all...]
H A Dbenchmark-ping-udp.c39 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 Dtest-udp-alloc-cb-fail.c46 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 Dtest-tcp-close-after-read-timeout.c38 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 Dtest-tcp-read-stop-start.c33 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 Dtest-tcp-write-to-half-open-connection.c32 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 Dtest-udp-send-and-recv.c46 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 Dtest-ipc.c102 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* bu in on_tcp_child_process_read()
[all...]
H A Dtest-tcp-open.c90 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 Decho-server.c29 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 Dblackhole-server.c36 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 Dbenchmark-multi-accept.c88 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 Dtest-not-readable-nor-writable-on-read-error.c43 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 Dtest-tcp-rst.c27 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()
/third_party/node/src/
H A Dspawn_sync.h46 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);
H A Dudp_wrap.h45 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,
H A Dstream_base.h133 virtual uv_buf_t OnStreamAlloc(size_t suggested_size) = 0;
137 // The `buf` argument is the return value of `uv_buf_t`, or may be a buffer
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** buf
[all...]
H A Dstream_pipe.h53 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;
H A Dstream_wrap.h54 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/libuv/docs/code/udp-dhcp/
H A Dmain.c12 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, unsigned flags) { 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/include/uv/
H A Dunix.h120 typedef struct uv_buf_t { struct
123 } 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]; \
/third_party/node/deps/uv/include/uv/
H A Dunix.h121 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]; \
/third_party/libuv/docs/code/multi-echo-server/
H A Dworker.c13 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()
/third_party/libuv/docs/code/uvtee/
H A Dmain.c10 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()

Completed in 21 milliseconds

1234567