Lines Matching refs:pipe
38 uv_pipe_t pipe; member
92 uv_pipe_t* pipe; in recv_cb() local
98 pipe = (uv_pipe_t*) handle; in recv_cb()
99 ASSERT_PTR_EQ(pipe, &ctx.channel); in recv_cb()
118 ASSERT_GT(uv_pipe_pending_count(pipe), 0); in recv_cb()
120 pending = uv_pipe_pending_type(pipe); in recv_cb()
124 r = uv_pipe_init(ctx.channel.loop, &recv->pipe, 0); in recv_cb()
134 } while (uv_pipe_pending_count(pipe) > 0); in recv_cb()
211 r = uv_pipe_init(uv_default_loop(), &ctx.send.pipe, 1); in run_ipc_send_recv_pipe()
214 r = uv_pipe_bind(&ctx.send.pipe, TEST_PIPENAME); in run_ipc_send_recv_pipe()
217 r = uv_pipe_init(uv_default_loop(), &ctx.send2.pipe, 1); in run_ipc_send_recv_pipe()
220 r = uv_pipe_bind(&ctx.send2.pipe, TEST_PIPENAME_2); in run_ipc_send_recv_pipe()
305 uv_pipe_t* pipe; in read_cb() local
319 pipe = (uv_pipe_t*) handle; in read_cb()
320 ASSERT_PTR_EQ(pipe, &ctx2.channel); in read_cb()
322 while (uv_pipe_pending_count(pipe) > 0) { in read_cb()
331 pending = uv_pipe_pending_type(pipe); in read_cb()
335 r = uv_pipe_init(ctx2.channel.loop, &recv->pipe, 0); in read_cb()