Home
last modified time | relevance | path

Searched refs:read_cb (Results 1 – 25 of 46) sorted by relevance

12

/netbsd-src/external/bsd/libarchive/dist/libarchive/test/
H A Dtest_archive_read_open2.c35 read_cb(struct archive *a, void *client, const void **buff) in read_cb() function
83 test(1, open_cb, read_cb, NULL, NULL, in DEFINE_TEST()
85 test(1, open_cb, read_cb, skip_cb, NULL, in DEFINE_TEST()
87 test(1, open_cb, read_cb, skip_cb, close_cb, in DEFINE_TEST()
89 test(1, NULL, read_cb, skip_cb, close_cb, in DEFINE_TEST()
91 test(1, open_cb, read_cb, skip_cb, NULL, in DEFINE_TEST()
93 test(1, NULL, read_cb, skip_cb, NULL, in DEFINE_TEST()
95 test(1, NULL, read_cb, NULL, NULL, in DEFINE_TEST()
102 test(0, open_cb, read_cb, NULL, NULL, in DEFINE_TEST()
104 test(0, open_cb, read_cb, skip_cb, NULL, in DEFINE_TEST()
[all …]
/netbsd-src/external/mit/libuv/dist/test/
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_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()
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_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()
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(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()
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 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-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 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
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(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()
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_EQ(0, uv_read_start((uv_stream_t*) &tcp, alloc_cb, read_cb)); in connect_cb()
H A Dtest-tcp-try-write.c78 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()
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-tcp-unexpected-read.c57 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()
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(0 == uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
H A Dbenchmark-pound.c80 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 Dtest-callback-stack.c70 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()
/netbsd-src/external/mpl/bind/dist/bin/tests/
H A Dtest_server.c50 read_cb(isc_nmhandle_t *handle, isc_result_t eresult, isc_region_t *region,
199 read_cb(isc_nmhandle_t *handle, isc_result_t eresult, isc_region_t *region, in teardown()
250 read_cb, NULL, &sock); in send_cb()
254 &sockaddr, read_cb, NULL,
262 netmgr, ISC_NM_LISTEN_ALL, &sockaddr, read_cb, NULL, in accept_cb()
277 eps, ISC_NM_HTTP_DEFAULT_PATH, read_cb, NULL); in run()
221 read_cb(isc_nmhandle_t *handle, isc_result_t eresult, isc_region_t *region, read_cb() function
/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress_et.c67 read_cb(evutil_socket_t fd, short event, void *arg) in read_cb() function
110 ev = event_new(base, xpair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
157 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
159 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
H A Dtest-eof.c60 read_cb(evutil_socket_t fd, short event, void *arg) in read_cb() function
112 event_set(&ev, pair[1], EV_READ | EV_TIMEOUT, read_cb, &ev); in main()
H A Dbench_cascade.c70 read_cb(evutil_socket_t fd, short which, void *arg) in read_cb() function
114 event_set(&events[i], cp[0], EV_READ, read_cb, in run_once()
/netbsd-src/external/mit/libuv/dist/src/win/
H A Dstream.c72 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 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_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 …]
H A Dtcp.c497 handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, &handle->tcp.conn.read_buffer); in uv__tcp_queue_read()
726 uv_read_cb read_cb) { in uv__tcp_read_start() argument
730 handle->read_cb = read_cb; in uv__tcp_read_start()
1028 handle->read_cb((uv_stream_t*)handle, in uv__process_tcp_read_req()
1037 handle->read_cb((uv_stream_t*)handle, in uv__process_tcp_read_req()
1053 handle->read_cb((uv_stream_t*)handle, UV_EOF, &handle->tcp.conn.read_buffer); in uv__process_tcp_read_req()
1064 handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, &buf); in uv__process_tcp_read_req()
1079 handle->read_cb((uv_stream_t*)handle, bytes, &buf); in uv__process_tcp_read_req()
1089 handle->read_cb((uv_stream_t*)handle, UV_EOF, &buf); in uv__process_tcp_read_req()
1096 handle->read_cb((uv_stream_t*)handle, 0, &buf); in uv__process_tcp_read_req()
[all …]
/netbsd-src/external/mit/libuv/dist/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()
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(stream, nread, &buf); in uv__read()
1503 uv_read_cb read_cb) { in uv__read_start() argument
[all …]

12