| /libuv/test/ |
| H A D | test-shutdown-simultaneous.c | 52 static void read_cb(uv_stream_t* t, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
86 ASSERT_OK(uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb)); in connect_cb()
89 ASSERT_EQ(UV_EALREADY, uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb)); in connect_cb()
90 ASSERT_EQ(UV_EINVAL, uv_read_start(NULL, alloc_cb, read_cb)); in connect_cb()
91 ASSERT_EQ(UV_EINVAL, uv_read_start((uv_stream_t*)&tcp, NULL, read_cb)); in connect_cb()
|
| H A D | test-shutdown-eof.c | 48 static void read_cb(uv_stream_t* t, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
92 ASSERT_OK(uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb)); in connect_cb()
95 ASSERT_EQ(UV_EALREADY, uv_read_start((uv_stream_t*)&tcp, alloc_cb, read_cb)); in connect_cb()
96 ASSERT_EQ(UV_EINVAL, uv_read_start(NULL, alloc_cb, read_cb)); in connect_cb()
97 ASSERT_EQ(UV_EINVAL, uv_read_start((uv_stream_t*)&tcp, NULL, read_cb)); in connect_cb()
|
| H A D | test-close-fd.c | 36 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
73 ASSERT_OK(uv_read_start((uv_stream_t *) &pipe_handle, alloc_cb, read_cb)); in TEST_IMPL()
77 ASSERT_OK(uv_read_start((uv_stream_t *) &pipe_handle, alloc_cb, read_cb)); in TEST_IMPL()
|
| H A D | test-readable-on-eof.c | 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
65 r = uv_read_start((uv_stream_t*) &tcp_client, alloc_cb, read_cb); in read_cb()
77 read_cb((uv_stream_t*) &tcp_client, UV_EOF, NULL); in connect_cb()
|
| H A D | blackhole-server.c | 37 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
58 r = uv_read_start((uv_stream_t*)&conn->handle, alloc_cb, read_cb); in connection_cb()
72 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
|
| H A D | test-osx-select.c | 40 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
67 uv_read_start((uv_stream_t*) &tty, alloc_cb, read_cb); in TEST_IMPL()
120 r = uv_read_start((uv_stream_t*) &tty, alloc_cb, read_cb); in TEST_IMPL()
|
| 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);
57 r = uv_read_start((uv_stream_t*)&tcp_peer, alloc_cb, read_cb); in connection_cb()
77 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
|
| H A D | test-tcp-close-accept.c | 87 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
114 ASSERT_OK(uv_read_start((uv_stream_t*) &tcp_check, alloc_cb, read_cb)); in read_cb()
138 ASSERT_OK(uv_read_start((uv_stream_t*) incoming, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-not-readable-nor-writable-on-read-error.c | 53 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
70 r = uv_read_start((uv_stream_t*) &tcp_client, alloc_cb, read_cb); in connect_cb()
|
| H A D | test-tcp-rst.c | 46 static void read_cb(uv_stream_t* t, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
65 ASSERT_OK(uv_read_start((uv_stream_t*) &tcp, alloc_cb, read_cb)); in connect_cb()
|
| H A D | test-tcp-try-write.c | 78 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
96 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-tcp-shutdown-after-write.c | 76 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
86 r = uv_read_start((uv_stream_t*)&conn, alloc_cb, read_cb); in connect_cb()
|
| H A D | test-tcp-unexpected-read.c | 57 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
81 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-tcp-oob.c | 58 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
89 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-tcp-write-in-a-row.c | 93 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {} in read_cb() function
101 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
| H A D | test-callback-stack.c | 70 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
114 if (uv_read_start((uv_stream_t*)&client, alloc_cb, read_cb)) { in timer_cb()
|
| H A D | test-ipc-heavy-traffic-deadlock-bug.c | 93 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
123 r = uv_read_start(handle, alloc_cb, read_cb); in do_writes_and_reads()
|
| H A D | test-tcp-writealot.c | 84 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
142 r = uv_read_start(stream, alloc_cb, read_cb); in connect_cb()
|
| H A D | test-delayed-accept.c | 118 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
143 r = uv_read_start((uv_stream_t*)(req->handle), alloc_cb, read_cb); in connect_cb()
|
| H A D | benchmark-pound.c | 80 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
127 r = uv_read_start(&conn->stream, alloc_cb, read_cb); in connect_cb()
138 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
|
| H A D | test-pipe-sendmsg.c | 73 static void read_cb(uv_stream_t* handle, in read_cb() function
149 ASSERT_OK(uv_read_start((uv_stream_t*) &p, alloc_cb, read_cb)); in TEST_IMPL()
|
| H A D | test-tcp-open.c | 113 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
204 r = uv_read_start(stream, alloc_cb, read_cb); in connect_cb()
362 ASSERT_OK(uv_read_start((uv_stream_t*) &client, alloc_cb, read_cb)); in TEST_IMPL()
|
| /libuv/src/win/ |
| H A D | stream.c | 72 uv_read_cb read_cb) { in uv__read_start() argument
78 err = uv__tcp_read_start((uv_tcp_t*)handle, alloc_cb, read_cb); in uv__read_start()
81 err = uv__pipe_read_start((uv_pipe_t*)handle, alloc_cb, read_cb); in uv__read_start()
84 err = uv__tty_read_start((uv_tty_t*) handle, alloc_cb, read_cb); in uv__read_start()
|
| H A D | tty.c | 349 uv_read_cb read_cb; in uv_tty_set_mode() local
377 read_cb = tty->read_cb; in uv_tty_set_mode()
385 read_cb = NULL; in uv_tty_set_mode()
591 handle->read_cb((uv_stream_t*) handle, in uv__tty_queue_read_line()
713 handle->read_cb((uv_stream_t*)handle, in uv_process_tty_read_raw_req()
724 handle->read_cb((uv_stream_t*)handle, in uv_process_tty_read_raw_req()
745 handle->read_cb((uv_stream_t*) handle, in uv_process_tty_read_raw_req()
850 handle->read_cb((uv_stream_t*) handle, in uv_process_tty_read_raw_req()
967 handle->read_cb((uv_stream_t*) handle, in uv_process_tty_read_line_req()
1008 uv_read_cb read_cb) { in uv__tty_read_start() argument
[all …]
|
| /libuv/src/unix/ |
| H A D | stream.c | 88 stream->read_cb = NULL; in uv__stream_init()
938 stream->read_cb(stream, UV_EOF, buf); in uv__stream_eof()
1046 while (stream->read_cb in uv__read()
1055 stream->read_cb(stream, UV_ENOBUFS, &buf); in uv__read()
1092 stream->read_cb(stream, 0, &buf); in uv__read()
1120 stream->read_cb(stream, err, &buf); in uv__read()
1140 stream->read_cb(stream, err, &buf); in uv__read()
1148 stream->read_cb(stream, nread, &buf); in uv__read()
1441 uv_read_cb read_cb) { in uv__read_start() argument
1454 stream->read_cb = read_cb; in uv__read_start()
[all …]
|
