Lines Matching refs:server_handle
49 handle_storage_t server_handle; member
61 uv_stream_t* server_handle; member
68 handle_storage_t server_handle; member
94 static void sv_connection_cb(uv_stream_t* server_handle, int status);
131 (uv_stream_t*) &sc->server_handle, in ipc_connection_cb()
188 ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) ctx->server_handle)); in ipc_read_cb()
190 ASSERT_OK(uv_pipe_init(loop, (uv_pipe_t*) ctx->server_handle, 0)); in ipc_read_cb()
194 ASSERT_OK(uv_accept(handle, ctx->server_handle)); in ipc_read_cb()
214 ASSERT_OK(uv_tcp_init(loop, (uv_tcp_t*) &ctx.server_handle)); in send_listen_handles()
215 ASSERT_OK(uv_tcp_bind((uv_tcp_t*) &ctx.server_handle, in send_listen_handles()
234 uv_close((uv_handle_t*) &ctx.server_handle, NULL); in send_listen_handles()
242 static void get_listen_handle(uv_loop_t* loop, uv_stream_t* server_handle) { in get_listen_handle() argument
245 ctx.server_handle = server_handle; in get_listen_handle()
246 ctx.server_handle->data = "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()
285 uv_close((uv_handle_t*) &ctx->server_handle, NULL); in sv_async_cb()
290 static void sv_connection_cb(uv_stream_t* server_handle, int status) { in sv_connection_cb() argument
294 ctx = container_of(server_handle, struct server_ctx, server_handle); in sv_connection_cb()
300 if (server_handle->type == UV_TCP) in sv_connection_cb()
301 ASSERT_OK(uv_tcp_init(server_handle->loop, (uv_tcp_t*) storage)); in sv_connection_cb()
302 else if (server_handle->type == UV_NAMED_PIPE) in sv_connection_cb()
303 ASSERT_OK(uv_pipe_init(server_handle->loop, (uv_pipe_t*) storage, 0)); in sv_connection_cb()
307 ASSERT_OK(uv_accept(server_handle, (uv_stream_t*) storage)); in sv_connection_cb()
