/libuv/test/ |
H A D | test-shutdown-simultaneous.c | 38 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_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() 92 ASSERT_EQ(UV_EINVAL, uv_read_start((uv_stream_t*)&tcp, alloc_cb, NULL)); in connect_cb()
|
H A D | test-shutdown-eof.c | 42 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_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() 98 ASSERT_EQ(UV_EINVAL, uv_read_start((uv_stream_t*)&tcp, alloc_cb, NULL)); in connect_cb()
|
H A D | test-close-fd.c | 30 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_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 | blackhole-server.c | 36 static void alloc_cb(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf); 58 r = uv_read_start((uv_stream_t*)&conn->handle, alloc_cb, read_cb); in connection_cb() 63 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function
|
H A D | test-osx-select.c | 33 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_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 | 33 static void alloc_cb(uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf); 57 r = uv_read_start((uv_stream_t*)&tcp_peer, alloc_cb, read_cb); in connection_cb() 68 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function
|
H A D | test-udp-send-and-recv.c | 44 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 97 r = uv_udp_recv_start(req->handle, alloc_cb, cl_recv_cb); in cl_send_cb() 174 r = uv_udp_recv_start(&server, alloc_cb, sv_recv_cb); in TEST_IMPL()
|
H A D | test-tcp-close-accept.c | 81 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_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-udp-send-unreachable.c | 44 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 134 r = uv_udp_recv_start(&client, alloc_cb, recv_cb); in TEST_IMPL() 167 r = uv_udp_recv_start(&client2, alloc_cb, recv_cb); in TEST_IMPL()
|
H A D | test-not-readable-nor-writable-on-read-error.c | 41 static void alloc_cb(uv_handle_t* handle, in alloc_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 | 39 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() function 65 ASSERT_OK(uv_read_start((uv_stream_t*) &tcp, alloc_cb, read_cb)); in connect_cb()
|
H A D | test-ping-pong.c | 55 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() function 209 alloc_cb, in pinger_on_connect() 338 alloc_cb, in socketpair_pinger_new() 341 alloc_cb, in socketpair_pinger_new() 374 ASSERT_OK(uv_read_start((uv_stream_t*) ponger, alloc_cb, pinger_read_cb)); in pipe2_pinger_new()
|
H A D | test-readable-on-eof.c | 41 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 65 r = uv_read_start((uv_stream_t*) &tcp_client, alloc_cb, read_cb); in read_cb()
|
H A D | test-watcher-cross-stop.c | 42 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() function 88 ASSERT_OK(uv_udp_recv_start(&sockets[i], alloc_cb, recv_cb)); in TEST_IMPL()
|
H A D | test-udp-recv-in-a-row.c | 40 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 96 ASSERT_OK(uv_udp_recv_start(&server, alloc_cb, sv_recv_cb)); in TEST_IMPL()
|
H A D | test-udp-open.c | 83 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 159 r = uv_udp_recv_start(&client, alloc_cb, recv_cb); in TEST_IMPL() 242 r = uv_udp_recv_start(&client, alloc_cb, recv_cb); in TEST_IMPL() 280 r = uv_udp_recv_start(&server, alloc_cb, recv_cb); in TEST_IMPL()
|
H A D | test-tcp-try-write.c | 70 static void alloc_cb(uv_handle_t* handle, size_t size, uv_buf_t* buf) { in alloc_cb() function 96 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
H A D | test-udp-try-send.c | 40 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 95 r = uv_udp_recv_start(&server, alloc_cb, sv_recv_cb); in TEST_IMPL()
|
H A D | test-tcp-shutdown-after-write.c | 52 static void alloc_cb(uv_handle_t* handle, in alloc_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 | 50 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 81 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
|
H A D | test-udp-send-immediate.c | 40 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 111 r = uv_udp_recv_start(&server, alloc_cb, sv_recv_cb); in TEST_IMPL()
|
H A D | test-tcp-open.c | 88 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 204 r = uv_read_start(stream, alloc_cb, read_cb); in connect_cb() 231 r = uv_read_start(stream, alloc_cb, read1_cb); in connect1_cb() 362 ASSERT_OK(uv_read_start((uv_stream_t*) &client, alloc_cb, read_cb)); in TEST_IMPL()
|
H A D | test-tcp-oob.c | 39 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 89 ASSERT_OK(uv_read_start((uv_stream_t*) &peer_handle, alloc_cb, read_cb)); in connection_cb()
|
H A D | test-udp-mmsg.c | 45 static void alloc_cb(uv_handle_t* handle, in alloc_cb() function 120 ASSERT_OK(uv_udp_recv_start(&recver, alloc_cb, recv_cb)); in TEST_IMPL()
|
/libuv/src/win/ |
H A D | stream.c | 71 uv_alloc_cb alloc_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()
|