Lines Matching defs:stream
49 } stream;
74 if (handle == (uv_handle_t*) &pinger->stream.tcp) {
77 uv_close((uv_handle_t*) &pinger->stream.tcp, ponger_on_close);
93 uv_stream_t* stream;
98 stream = (uv_stream_t*) &pinger->stream.tcp;
115 ASSERT_OK(uv_write(req, stream, bufs, nbufs, pinger_after_write));
121 static void pinger_read_cb(uv_stream_t* stream,
127 pinger = (pinger_t*) stream->data;
135 uv_close((uv_handle_t*) stream, pinger_on_close);
154 uv_close((uv_handle_t*) stream, pinger_on_close);
163 static void ponger_read_cb(uv_stream_t* stream,
176 uv_close((uv_handle_t*) stream, ponger_on_close);
191 ASSERT_OK(uv_write(req, stream, &writebuf, 1, pinger_after_write));
230 r = uv_tcp_init(uv_default_loop(), &pinger->stream.tcp);
231 pinger->stream.tcp.data = pinger;
237 &pinger->stream.tcp,
261 r = uv_tcp_init(uv_default_loop(), &pinger->stream.tcp);
262 pinger->stream.tcp.data = pinger;
268 &pinger->stream.tcp,
290 r = uv_pipe_init(uv_default_loop(), &pinger->stream.pipe, 0);
291 pinger->stream.pipe.data = pinger;
296 uv_pipe_connect(&pinger->connect_req, &pinger->stream.pipe, TEST_PIPENAME,
325 ASSERT_OK(uv_tcp_init(uv_default_loop(), &pinger->stream.tcp));
326 pinger->stream.pipe.data = pinger;
327 ASSERT_OK(uv_tcp_open(&pinger->stream.tcp, fds[1]));
337 ASSERT_OK(uv_read_start((uv_stream_t*) &pinger->stream.tcp,
367 ASSERT_OK(uv_pipe_init(uv_default_loop(), &pinger->stream.pipe, 0));
368 ASSERT_OK(uv_pipe_open(&pinger->stream.pipe, fds[1]));
369 pinger->stream.pipe.data = pinger; /* record for close_cb */