Home
last modified time | relevance | path

Searched refs:read_cb (Results 1 - 25 of 53) sorted by relevance

123

/third_party/libuv/test/
H A Dtest-shutdown-eof.c48 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 Dtest-shutdown-simultaneous.c52 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 Dtest-close-fd.c36 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 Dtest-readable-on-eof.c53 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 Dtest-osx-select.c40 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 Dblackhole-server.c37 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 Dtest-tcp-write-to-half-open-connection.c32 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
79 fprintf(stderr, "read_cb error: %s\n", uv_err_name(nread)); in read_cb()
H A Dtest-tcp-close-accept.c87 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 Dtest-not-readable-nor-writable-on-read-error.c53 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 Dtest-tcp-rst.c46 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 Dtest-tcp-oob.c58 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 Dtest-tcp-shutdown-after-write.c76 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 Dtest-ipc-heavy-traffic-deadlock-bug.c93 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 Dtest-callback-stack.c70 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb() function
71 ASSERT(nested == 0 && "read_cb must be called from a fresh stack"); in read_cb()
114 if (uv_read_start((uv_stream_t*)&client, alloc_cb, read_cb)) { in timer_cb()
136 * for the backend to use dirty stack for calling read_cb. */ in write_cb()
H A Dtest-delayed-accept.c118 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 Dtest-tcp-writealot.c84 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()
/third_party/libuv/src/win/
H A Dstream.c72 uv_read_cb read_cb) { in uv__read_start()
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()
70 uv__read_start(uv_stream_t* handle, uv_alloc_cb alloc_cb, uv_read_cb read_cb) uv__read_start() argument
H A Dtty.c349 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()
402 err = uv__tty_read_start(tty, alloc_cb, read_cb); 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_ in uv_process_tty_read_raw_req()
1007 uv__tty_read_start(uv_tty_t* handle, uv_alloc_cb alloc_cb, uv_read_cb read_cb) uv__tty_read_start() argument
[all...]
/third_party/node/deps/uv/src/win/
H A Dstream.c72 uv_read_cb read_cb) { in uv__read_start()
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()
70 uv__read_start(uv_stream_t* handle, uv_alloc_cb alloc_cb, uv_read_cb read_cb) uv__read_start() argument
H A Dtty.c354 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_ in uv_process_tty_read_raw_req()
1018 uv__tty_read_start(uv_tty_t* handle, uv_alloc_cb alloc_cb, uv_read_cb read_cb) uv__tty_read_start() argument
[all...]
/third_party/ffmpeg/libavutil/tests/
H A Dfifo.c33 static int read_cb(void *opaque, void *buf, size_t *nb_elems) in read_cb() function
172 ret = av_fifo_peek_to_cb(fifo, read_cb, &s, &nb_elems, s.offset); in main()
184 ret = av_fifo_read_to_cb(fifo, read_cb, &s, &nb_elems); in main()
/third_party/pulseaudio/src/tests/
H A Dlo-latency-test.c79 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/
H A Dstream.c88 stream->read_cb = NULL; in uv__stream_init()
937 stream->read_cb(stream, UV_EOF, buf); in uv__stream_eof()
1039 * tcp->read_cb is NULL or not? in uv__read()
1041 while (stream->read_cb in uv__read()
1050 stream->read_cb(stream, UV_ENOBUFS, &buf); in uv__read()
1087 stream->read_cb(stream, 0, &buf); in uv__read()
1096 stream->read_cb(stream, UV__ERR(errno), &buf); in uv__read()
1115 stream->read_cb(stream, err, &buf); in uv__read()
1135 stream->read_cb(stream, err, &buf); in uv__read()
1143 stream->read_cb(strea in uv__read()
1434 uv__read_start(uv_stream_t* stream, uv_alloc_cb alloc_cb, uv_read_cb read_cb) uv__read_start() argument
[all...]
/third_party/node/deps/uv/src/unix/
H A Dstream.c78 stream->read_cb = NULL; in uv__stream_init()
970 stream->read_cb(stream, UV_EOF, buf); in uv__stream_eof()
1097 * tcp->read_cb is NULL or not? in uv__read()
1099 while (stream->read_cb in uv__read()
1108 stream->read_cb(stream, UV_ENOBUFS, &buf); in uv__read()
1145 stream->read_cb(stream, 0, &buf); in uv__read()
1154 stream->read_cb(stream, UV__ERR(errno), &buf); in uv__read()
1173 stream->read_cb(stream, err, &buf); in uv__read()
1193 stream->read_cb(stream, err, &buf); in uv__read()
1201 stream->read_cb(strea in uv__read()
1501 uv__read_start(uv_stream_t* stream, uv_alloc_cb alloc_cb, uv_read_cb read_cb) uv__read_start() argument
[all...]
/third_party/ffmpeg/libavutil/
H A Dfifo.c150 AVFifoCB read_cb, void *opaque) in fifo_write_common()
166 if (read_cb) { in fifo_write_common()
167 ret = read_cb(opaque, wptr, &len); in fifo_write_common()
193 int av_fifo_write_from_cb(AVFifo *f, AVFifoCB read_cb, in av_fifo_write_from_cb() argument
196 return fifo_write_common(f, NULL, nb_elems, read_cb, opaque); in av_fifo_write_from_cb()
149 fifo_write_common(AVFifo *f, const uint8_t *buf, size_t *nb_elems, AVFifoCB read_cb, void *opaque) fifo_write_common() argument

Completed in 20 milliseconds

123