Lines Matching refs:stream
48 uv_stream_t stream; member
56 uv_tcp_t stream; member
64 uv_pipe_t stream; member
80 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
127 r = uv_read_start(&conn->stream, alloc_cb, read_cb); in connect_cb()
133 r = uv_write(&conn->write_req, &conn->stream, &buf, 1, after_write); in connect_cb()
138 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
140 ASSERT_NOT_NULL(stream); in read_cb()
146 uv_close((uv_handle_t*)stream, close_cb); in read_cb()
202 r = uv_tcp_init(loop, (uv_tcp_t*)&p->stream); in tcp_make_connect()
208 (uv_tcp_t*) &p->stream, in tcp_make_connect()
222 p->stream.data = p; in tcp_make_connect()
229 r = uv_pipe_init(loop, (uv_pipe_t*)&p->stream, 0); in pipe_make_connect()
233 (uv_pipe_t*) &p->stream, in pipe_make_connect()
243 p->stream.data = p; in pipe_make_connect()
