| /third_party/libuv/test/ |
| 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_EQ(0, 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()
|
| 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_EQ(0, 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()
|
| 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(0 == uv_read_start((uv_stream_t *) &pipe_handle, alloc_cb, read_cb)); in TEST_IMPL()
77 ASSERT(0 == uv_read_start((uv_stream_t *) &pipe_handle, alloc_cb, read_cb)); in TEST_IMPL()
|
| 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()
|
| 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
|
| 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()
|
| 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
|
| 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(0 == uv_read_start((uv_stream_t*) &tcp_check, alloc_cb, read_cb)); in read_cb()
138 ASSERT(0 == uv_read_start((uv_stream_t*) incoming, alloc_cb, read_cb)); in connection_cb()
|
| 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()
|
| 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(0 == uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
| 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(0 == uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
|
| 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()
|
| 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(0 == uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
|
| 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
|
| 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()
|
| 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()
|
| 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()
|
| 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()
|
| D | test-pipe-sendmsg.c | 73 static void read_cb(uv_stream_t* handle, in read_cb() function
149 ASSERT(0 == uv_read_start((uv_stream_t*) &p, alloc_cb, read_cb)); in TEST_IMPL()
|
| 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()
356 ASSERT(0 == uv_read_start((uv_stream_t*) &client, alloc_cb, read_cb)); in TEST_IMPL()
|
| /third_party/libuv/src/win/ |
| D | stream.c | 70 uv_read_cb read_cb) { in uv__read_start() argument
76 err = uv__tcp_read_start((uv_tcp_t*)handle, alloc_cb, read_cb); in uv__read_start()
79 err = uv__pipe_read_start((uv_pipe_t*)handle, alloc_cb, read_cb); in uv__read_start()
82 err = uv__tty_read_start((uv_tty_t*) handle, alloc_cb, read_cb); in uv__read_start()
|
| D | tty.c | 354 uv_read_cb read_cb; in uv_tty_set_mode() local
382 read_cb = tty->read_cb; in uv_tty_set_mode()
390 read_cb = NULL; in uv_tty_set_mode()
407 err = uv__tty_read_start(tty, alloc_cb, read_cb); in uv_tty_set_mode()
597 handle->read_cb((uv_stream_t*) handle, in uv__tty_queue_read_line()
719 handle->read_cb((uv_stream_t*)handle, in uv_process_tty_read_raw_req()
730 handle->read_cb((uv_stream_t*)handle, in uv_process_tty_read_raw_req()
751 handle->read_cb((uv_stream_t*) handle, in uv_process_tty_read_raw_req()
861 handle->read_cb((uv_stream_t*) handle, in uv_process_tty_read_raw_req()
912 handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, &buf); in uv_process_tty_read_raw_req()
[all …]
|
| D | tcp.c | 494 handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, &handle->tcp.conn.read_buffer); in uv__tcp_queue_read()
723 uv_read_cb read_cb) { in uv__tcp_read_start() argument
727 handle->read_cb = read_cb; in uv__tcp_read_start()
1025 handle->read_cb((uv_stream_t*)handle, in uv__process_tcp_read_req()
1034 handle->read_cb((uv_stream_t*)handle, in uv__process_tcp_read_req()
1050 handle->read_cb((uv_stream_t*)handle, UV_EOF, &handle->tcp.conn.read_buffer); in uv__process_tcp_read_req()
1061 handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, &buf); in uv__process_tcp_read_req()
1076 handle->read_cb((uv_stream_t*)handle, bytes, &buf); in uv__process_tcp_read_req()
1086 handle->read_cb((uv_stream_t*)handle, UV_EOF, &buf); in uv__process_tcp_read_req()
1093 handle->read_cb((uv_stream_t*)handle, 0, &buf); in uv__process_tcp_read_req()
[all …]
|
| /third_party/pulseaudio/src/tests/ |
| D | lo-latency-test.c | 79 static void read_cb(pa_stream *s, size_t nbytes, void *userdata) { in read_cb() function
151 test_ctx.read_cb = read_cb; in START_TEST()
|
| /third_party/libuv/src/unix/ |
| D | stream.c | 77 stream->read_cb = NULL; in uv__stream_init()
1016 stream->read_cb(stream, UV_EOF, buf); in uv__stream_eof()
1145 while (stream->read_cb in uv__read()
1154 stream->read_cb(stream, UV_ENOBUFS, &buf); in uv__read()
1191 stream->read_cb(stream, 0, &buf); in uv__read()
1200 stream->read_cb(stream, UV__ERR(errno), &buf); in uv__read()
1219 stream->read_cb(stream, err, &buf); in uv__read()
1239 stream->read_cb(stream, err, &buf); in uv__read()
1247 stream->read_cb(stream, nread, &buf); in uv__read()
1548 uv_read_cb read_cb) { in uv__read_start() argument
[all …]
|