Lines Matching refs:stream
171 static void read_cb(uv_stream_t* stream, ssize_t bytes, const uv_buf_t* buf) { in read_cb() argument
179 uv_close((uv_handle_t*)stream, read_sockets_close_cb); in read_cb()
202 static void do_write(uv_stream_t* stream) { in do_write() argument
211 r = uv_write(req, stream, &buf, 1, write_cb); in do_write()
278 uv_stream_t* stream; in connection_cb() local
285 stream = (uv_stream_t*)malloc(sizeof(uv_tcp_t)); in connection_cb()
286 r = uv_tcp_init(loop, (uv_tcp_t*)stream); in connection_cb()
289 stream = (uv_stream_t*)malloc(sizeof(uv_pipe_t)); in connection_cb()
290 r = uv_pipe_init(loop, (uv_pipe_t*)stream, 0); in connection_cb()
294 r = uv_accept(s, stream); in connection_cb()
297 r = uv_read_start(stream, buf_alloc, read_cb); in connection_cb()
