| /src/external/mit/libuv/dist/test/ |
| test-tcp-write-in-a-row.c | 48 ASSERT_OK(uv_stream_get_write_queue_size((uv_stream_t*) &client));
70 r = uv_write(&small_write, (uv_stream_t*) &client, &buf, 1, write_cb);
74 write_queue_size0 = uv_stream_get_write_queue_size((uv_stream_t*) &client);
79 r = uv_write(&big_write, (uv_stream_t*) &client, &buf, 1, write_cb);
82 write_queue_size1 = uv_stream_get_write_queue_size((uv_stream_t*) &client);
93 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {}
95 static void connection_cb(uv_stream_t* tcp, int status) {
100 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming));
101 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb));
111 ASSERT_OK(uv_listen((uv_stream_t*) &server, 128, connection_cb))
[all...] |
| test-tcp-read-stop-start.c | 33 static void on_read2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
48 static void do_write(uv_stream_t* stream, uv_write_cb cb) {
64 static void on_read1(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
79 static void on_read2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
88 static void on_connection(uv_stream_t* server, int status) {
93 ASSERT_OK(uv_accept(server, (uv_stream_t* )&connection));
95 ASSERT_OK(uv_read_start((uv_stream_t*)&connection, on_alloc, on_read1));
101 do_write((uv_stream_t*)&client, on_write_close_immediately);
116 ASSERT_OK(uv_listen((uv_stream_t*)&server, 10, on_connection));
|
| test-tcp-write-to-half-open-connection.c | 29 static void connection_cb(uv_stream_t* server, int status);
32 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
44 static void connection_cb(uv_stream_t* server, int status) {
48 ASSERT_PTR_EQ(server, (uv_stream_t*)&tcp_server);
54 r = uv_accept(server, (uv_stream_t*)&tcp_peer);
57 r = uv_read_start((uv_stream_t*)&tcp_peer, alloc_cb, read_cb);
63 r = uv_write(&write_req, (uv_stream_t*)&tcp_peer, &buf, 1, write_cb);
77 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
121 r = uv_listen((uv_stream_t*)&tcp_server, 1, connection_cb);
|
| blackhole-server.c | 35 static void connection_cb(uv_stream_t* stream, int status);
37 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
42 static void connection_cb(uv_stream_t* stream, int status) {
47 ASSERT_PTR_EQ(stream, (uv_stream_t*)&tcp_server);
55 r = uv_accept(stream, (uv_stream_t*)&conn->handle);
58 r = uv_read_start((uv_stream_t*)&conn->handle, alloc_cb, read_cb);
72 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
114 r = uv_listen((uv_stream_t*)&tcp_server, 128, connection_cb);
|
| test-pipe-pending-instances.c | 27 static void connection_cb(uv_stream_t* server, int status) {
49 r = uv_listen((uv_stream_t*)&pipe_handle, 128, connection_cb);
|
| test-tcp-oob.c | 58 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) {
78 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &client_handle);
83 static void connection_cb(uv_stream_t* handle, int status) {
88 ASSERT_OK(uv_accept(handle, (uv_stream_t*) &peer_handle));
89 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb));
94 ASSERT_OK(uv_stream_set_blocking((uv_stream_t*) &client_handle, 1));
109 ASSERT_OK(uv_stream_set_blocking((uv_stream_t*) &client_handle, 0));
125 ASSERT_OK(uv_listen((uv_stream_t*) &server_handle, 1, connection_cb));
|
| test-tcp-unexpected-read.c | 57 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) {
63 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &client_handle);
69 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &peer_handle);
74 static void connection_cb(uv_stream_t* handle, int status) {
80 ASSERT_OK(uv_accept(handle, (uv_stream_t*) &peer_handle));
81 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb));
82 ASSERT_OK(uv_write(&write_req, (uv_stream_t*) &peer_handle,
102 ASSERT_OK(uv_listen((uv_stream_t*) &server_handle, 1, connection_cb));
|
| test-tty.c | 99 ASSERT(uv_is_readable((uv_stream_t*) &tty_in));
100 ASSERT(!uv_is_writable((uv_stream_t*) &tty_in));
104 ASSERT(!uv_is_readable((uv_stream_t*) &tty_out));
105 ASSERT(uv_is_writable((uv_stream_t*) &tty_out));
155 static void tty_raw_read(uv_stream_t* tty_in, ssize_t nread, const uv_buf_t* buf) {
189 ASSERT(uv_is_readable((uv_stream_t*) &tty_in));
190 ASSERT(!uv_is_writable((uv_stream_t*) &tty_in));
192 r = uv_read_start((uv_stream_t*)&tty_in, tty_raw_alloc, tty_raw_read);
247 ASSERT(!uv_is_readable((uv_stream_t*) &tty_out));
248 ASSERT(uv_is_writable((uv_stream_t*) &tty_out))
[all...] |
| test-shutdown-simultaneous.c | 52 static void read_cb(uv_stream_t* t, ssize_t nread, const uv_buf_t* buf) {
68 uv_shutdown(&shutdown_req, (uv_stream_t*) &tcp, shutdown_cb);
86 ASSERT_OK(uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb));
89 ASSERT_EQ(UV_EALREADY, uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb));
91 ASSERT_EQ(UV_EINVAL, uv_read_start((uv_stream_t*)&tcp, NULL, read_cb));
92 ASSERT_EQ(UV_EINVAL, uv_read_start((uv_stream_t*)&tcp, alloc_cb, NULL));
98 ASSERT_EQ(qbuf.len, uv_try_write((uv_stream_t*) &tcp, &qbuf, 1));
|
| test-tcp-try-write.c | 54 r = uv_try_write((uv_stream_t*) &client, &buf, 1);
64 r = uv_try_write((uv_stream_t*) &client, &buf, 1);
78 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {
89 static void connection_cb(uv_stream_t* tcp, int status) {
93 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming));
96 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb));
107 ASSERT_OK(uv_listen((uv_stream_t*) &server, 128, connection_cb));
|
| test-tcp-close-after-read-timeout.c | 33 static void on_connection(uv_stream_t* server, int status);
39 static void on_client_read(uv_stream_t* stream,
50 r = uv_read_start((uv_stream_t*) &client, on_client_alloc, on_client_read);
67 static void on_client_read(uv_stream_t* stream, ssize_t nread,
77 uv_read_stop((uv_stream_t*) &client);
92 static void on_connection_read(uv_stream_t* stream,
101 static void on_connection(uv_stream_t* server, int status) {
105 ASSERT_OK(uv_accept(server, (uv_stream_t*) &connection));
107 r = uv_read_start((uv_stream_t*) &connection,
134 r = uv_listen((uv_stream_t*) handle, 128, on_connection)
[all...] |
| test-tcp-alloc-cb-fail.c | 52 static void conn_read_cb(uv_stream_t* stream,
77 static void connection_cb(uv_stream_t* tcp, int status) {
81 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming));
82 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming,
97 ASSERT_OK(uv_listen((uv_stream_t*) &server, 128, connection_cb));
|
| test-tcp-close-accept.c | 57 uv_stream_t* outgoing;
77 outgoing = (uv_stream_t*) &tcp_outgoing[i];
87 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
114 ASSERT_OK(uv_read_start((uv_stream_t*) &tcp_check, alloc_cb, read_cb));
117 static void connection_cb(uv_stream_t* server, int status) {
121 ASSERT_PTR_EQ(server, (uv_stream_t*) &tcp_server);
130 ASSERT_OK(uv_accept(server, (uv_stream_t*) incoming));
138 ASSERT_OK(uv_read_start((uv_stream_t*) incoming, alloc_cb, read_cb));
169 ASSERT_OK(uv_listen((uv_stream_t*) &tcp_server,
|
| test-tcp-close-reset.c | 64 r = uv_write(&write_reqs[i], (uv_stream_t*) handle, &buf, 1, write_cb);
76 (uv_stream_t*) handle,
92 ASSERT_EQ(UV_ENOTCONN, uv_shutdown(&shutdown_req, (uv_stream_t*) handle,
105 static void read_cb2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
114 uv_read_start((uv_stream_t*) &tcp_client, alloc_cb, read_cb2);
124 ASSERT_PTR_EQ(req->handle, (uv_stream_t*)&tcp_client);
140 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &tcp_client);
142 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &tcp_accepted);
148 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
160 static void connection_cb(uv_stream_t* server, int status)
[all...] |
| test-ipc.c | 65 static void on_connection(uv_stream_t* server, int status) {
79 r = uv_accept(server, (uv_stream_t*)conn);
143 static void on_read(uv_stream_t* handle,
184 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server);
187 r = uv_listen((uv_stream_t*)&tcp_server, BACKLOG, on_connection);
196 r = uv_write(&write_req, (uv_stream_t*)pipe, &outbuf, 1, NULL);
213 static void on_read_listen_after_bound_twice(uv_stream_t* handle,
253 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server)
[all...] |
| test-iouring-pollhup.c | 49 static void read_data2(uv_stream_t* stream,
70 ASSERT_OK(uv_read_start((uv_stream_t*) &p2, alloc_buffer, read_data2));
78 static void read_data(uv_stream_t* stream,
101 ASSERT_OK(uv_read_start((uv_stream_t*) &p1, alloc_buffer, read_data));
|
| test-readable-on-eof.c | 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) {
65 r = uv_read_start((uv_stream_t*) &tcp_client, alloc_cb, read_cb);
77 read_cb((uv_stream_t*) &tcp_client, UV_EOF, NULL);
82 (uv_stream_t*) &tcp_client,
|
| /src/external/mit/libuv/dist/src/win/ |
| stream-inl.h | 34 uv_stream_t* handle,
49 INLINE static void uv__connection_init(uv_stream_t* handle) {
|
| stream.c | 30 int uv_listen(uv_stream_t* stream, int backlog, uv_connection_cb cb) {
51 int uv_accept(uv_stream_t* server, uv_stream_t* client) {
70 int uv__read_start(uv_stream_t* handle,
94 int uv_read_stop(uv_stream_t* handle) {
115 uv_stream_t* handle,
147 uv_stream_t* handle,
150 uv_stream_t* send_handle,
171 int uv_try_write(uv_stream_t* stream,
193 int uv_try_write2(uv_stream_t* stream
[all...] |
| /src/external/mit/libuv/dist/docs/code/pipe-echo-server/ |
| main.c | 37 void echo_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) {
54 void on_new_connection(uv_stream_t *server, int status) {
62 if (uv_accept(server, (uv_stream_t*) client) == 0) {
63 uv_read_start((uv_stream_t*) client, alloc_buffer, echo_read);
89 if ((r = uv_listen((uv_stream_t*) &server, 128, on_new_connection))) {
|
| /src/external/mit/libuv/dist/docs/code/tcp-echo-server/ |
| main.c | 39 void echo_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) {
55 void on_new_connection(uv_stream_t *server, int status) {
64 if (uv_accept(server, (uv_stream_t*) client) == 0) {
65 uv_read_start((uv_stream_t*) client, alloc_buffer, echo_read);
81 int r = uv_listen((uv_stream_t*) &server, DEFAULT_BACKLOG, on_new_connection);
|
| /src/external/mit/libuv/dist/docs/code/multi-echo-server/ |
| main.c | 31 void on_new_connection(uv_stream_t *server, int status) {
39 if (uv_accept(server, (uv_stream_t*) client) == 0) {
43 uv_write2(write_req, (uv_stream_t*) &worker->pipe, &dummy_buf, 1, (uv_stream_t*) client, NULL);
80 child_stdio[0].data.stream = (uv_stream_t*) &worker->pipe;
109 if ((r = uv_listen((uv_stream_t*) &server, 128, on_new_connection))) {
|
| /src/external/mit/libuv/dist/docs/code/uvtee/ |
| main.c | 36 void write_data(uv_stream_t *dest, size_t size, uv_buf_t buf, uv_write_cb cb) {
40 uv_write((uv_write_t*) req, (uv_stream_t*)dest, &req->buf, 1, cb);
43 void read_stdin(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) {
52 write_data((uv_stream_t *)&stdout_pipe, nread, *buf, on_stdout_write);
53 write_data((uv_stream_t *)&file_pipe, nread, *buf, on_file_write);
75 uv_read_start((uv_stream_t*)&stdin_pipe, alloc_buffer, read_stdin);
|
| /src/external/mit/libuv/dist/docs/code/tty/ |
| main.c | 22 uv_write(&req1, (uv_stream_t*) &tty, &buf1, 1, NULL);
27 uv_write(&req, (uv_stream_t*) &tty, &buf, 1, NULL);
|
| /src/external/mit/libuv/dist/docs/code/cgi/ |
| main.c | 33 child_stdio[1].data.stream = (uv_stream_t*) client;
50 void on_new_connection(uv_stream_t *server, int status) {
58 if (uv_accept(server, (uv_stream_t*) client) == 0) {
75 int r = uv_listen((uv_stream_t*) &server, 128, on_new_connection);
|
