Lines Matching refs:uv_stream_t
64 r = uv_write(&write_reqs[i], (uv_stream_t*) handle, &buf, 1, write_cb); in do_write()
76 (uv_stream_t*) handle, in do_close()
92 ASSERT_EQ(UV_ENOTCONN, uv_shutdown(&shutdown_req, (uv_stream_t*) handle, in do_close()
105 static void read_cb2(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb2()
114 uv_read_start((uv_stream_t*) &tcp_client, alloc_cb, read_cb2); in connect_cb()
124 ASSERT_PTR_EQ(req->handle, (uv_stream_t*)&tcp_client); in write_cb()
140 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &tcp_client); in shutdown_cb()
142 ASSERT_PTR_EQ(req->handle, (uv_stream_t*) &tcp_accepted); in shutdown_cb()
148 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb()
160 static void connection_cb(uv_stream_t* server, int status) { in connection_cb()
164 ASSERT_OK(uv_accept(server, (uv_stream_t*) &tcp_accepted)); in connection_cb()
166 uv_read_start((uv_stream_t*) &tcp_accepted, alloc_cb, read_cb); in connection_cb()
182 r = uv_listen((uv_stream_t*)handle, 128, connection_cb); in start_server()
