Lines Matching refs:uv_stream_t
61 uv_stream_t* server_handle;
82 static void ipc_connection_cb(uv_stream_t* ipc_pipe, int status);
86 static void ipc_read_cb(uv_stream_t* handle,
94 static void sv_connection_cb(uv_stream_t* server_handle, int status);
95 static void sv_read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf);
107 static void ipc_connection_cb(uv_stream_t* ipc_pipe, int status) { in ipc_connection_cb()
126 ASSERT_OK(uv_accept(ipc_pipe, (uv_stream_t*) &pc->peer_handle)); in ipc_connection_cb()
128 (uv_stream_t*) &pc->peer_handle, in ipc_connection_cb()
131 (uv_stream_t*) &sc->server_handle, in ipc_connection_cb()
157 ASSERT_OK(uv_read_start((uv_stream_t*) &ctx->ipc_pipe, in ipc_connect_cb()
173 static void ipc_read_cb(uv_stream_t* handle, in ipc_read_cb()
228 ASSERT_OK(uv_listen((uv_stream_t*) &ctx.ipc_pipe, 128, ipc_connection_cb)); in send_listen_handles()
242 static void get_listen_handle(uv_loop_t* loop, uv_stream_t* server_handle) { in get_listen_handle()
269 get_listen_handle(&loop, (uv_stream_t*) &ctx->server_handle); in server_cb()
273 ASSERT_OK(uv_listen((uv_stream_t*) &ctx->server_handle, in server_cb()
290 static void sv_connection_cb(uv_stream_t* server_handle, int status) { in sv_connection_cb()
307 ASSERT_OK(uv_accept(server_handle, (uv_stream_t*) storage)); in sv_connection_cb()
308 ASSERT_OK(uv_read_start((uv_stream_t*) storage, sv_alloc_cb, sv_read_cb)); in sv_connection_cb()
322 static void sv_read_cb(uv_stream_t* handle, in sv_read_cb()
