Lines Matching defs:channel
29 void spawn_helper(uv_pipe_t* channel,
44 uv_pipe_t channel;
57 uv_pipe_t channel;
99 ASSERT_PTR_EQ(pipe, &ctx.channel);
124 r = uv_pipe_init(ctx.channel.loop, &recv->pipe, 0);
126 r = uv_tcp_init(ctx.channel.loop, &recv->tcp);
138 uv_close((uv_handle_t*)&ctx.channel, NULL);
151 (uv_stream_t*)&ctx.channel,
162 (uv_stream_t*)&ctx.channel,
168 r = uv_read_start((uv_stream_t*)&ctx.channel, alloc_cb, recv_cb);
183 r = uv_pipe_init(uv_default_loop(), &ctx.channel, 1);
186 uv_pipe_connect(&ctx.connect_req, &ctx.channel, TEST_PIPENAME_3, connect_cb);
188 spawn_helper(&ctx.channel, &process, "ipc_send_recv_helper");
296 uv_close((uv_handle_t*)&ctx2.channel, NULL);
320 ASSERT_PTR_EQ(pipe, &ctx2.channel);
335 r = uv_pipe_init(ctx2.channel.loop, &recv->pipe, 0);
337 r = uv_tcp_init(ctx2.channel.loop, &recv->tcp);
347 (uv_stream_t*)&ctx2.channel,
358 ASSERT_EQ(1, uv_is_readable((uv_stream_t*)&ctx2.channel));
359 ASSERT_EQ(1, uv_is_writable((uv_stream_t*)&ctx2.channel));
360 ASSERT_OK(uv_is_closing((uv_handle_t*)&ctx2.channel));
362 r = uv_read_start((uv_stream_t*)&ctx2.channel, alloc_cb, read_cb);
371 r = uv_accept((uv_stream_t*)&ctx2.listen, (uv_stream_t*)&ctx2.channel);
387 r = uv_pipe_init(loop, &ctx2.channel, 1);
397 r = uv_pipe_open(&ctx2.channel, 0);
410 /* stdin is a duplex channel over which a handle is sent.