Lines Matching refs:pipe
147 uv_pipe_t* pipe; in on_read() local
151 pipe = (uv_pipe_t*) handle; in on_read()
171 pending = uv_pipe_pending_type(pipe); in on_read()
173 ASSERT_EQ(1, uv_pipe_pending_count(pipe)); in on_read()
184 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); in on_read()
196 r = uv_write(&write_req, (uv_stream_t*)pipe, &outbuf, 1, NULL); in on_read()
203 ASSERT_OK(uv_pipe_pending_count(pipe)); in on_read()
217 uv_pipe_t* pipe; in on_read_listen_after_bound_twice() local
220 pipe = (uv_pipe_t*) handle; in on_read_listen_after_bound_twice()
240 ASSERT_GT(uv_pipe_pending_count(pipe), 0); in on_read_listen_after_bound_twice()
241 pending = uv_pipe_pending_type(pipe); in on_read_listen_after_bound_twice()
253 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server); in on_read_listen_after_bound_twice()
264 r = uv_accept((uv_stream_t*)pipe, (uv_stream_t*)&tcp_server2); in on_read_listen_after_bound_twice()
272 ASSERT_OK(uv_pipe_pending_count(pipe)); in on_read_listen_after_bound_twice()
355 uv_pipe_t* pipe; in on_read_connection() local
358 pipe = (uv_pipe_t*) handle; in on_read_connection()
377 ASSERT_EQ(1, uv_pipe_pending_count(pipe)); in on_read_connection()
378 pending = uv_pipe_pending_type(pipe); in on_read_connection()