test-ping-pong.c - OpenGrok cross reference for /libuv/test/test-ping-pong.c

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