51   uv_pipe_t ipc_pipe;  member
62   uv_pipe_t ipc_pipe;  member
82 static void ipc_connection_cb(uv_stream_t* ipc_pipe, int status);
107 static void ipc_connection_cb(uv_stream_t* ipc_pipe, int status) {  in ipc_connection_cb()  argument
113   loop = ipc_pipe->loop;  in ipc_connection_cb()
115   sc = container_of(ipc_pipe, struct ipc_server_ctx, ipc_pipe);  in ipc_connection_cb()
119   if (ipc_pipe->type == UV_TCP)  in ipc_connection_cb()
121   else if (ipc_pipe->type == UV_NAMED_PIPE)  in ipc_connection_cb()
126   ASSERT(0 == uv_accept(ipc_pipe, (uv_stream_t*) &pc->peer_handle));  in ipc_connection_cb()
135     uv_close((uv_handle_t*) ipc_pipe, NULL);  in ipc_connection_cb()
157   ASSERT(0 == uv_read_start((uv_stream_t*) &ctx->ipc_pipe,  in ipc_connect_cb()
167   ctx = container_of(handle, struct ipc_client_ctx, ipc_pipe);  in ipc_alloc_cb()
179   uv_pipe_t* ipc_pipe;  in ipc_read_cb()  local
181   ipc_pipe = (uv_pipe_t*) handle;  in ipc_read_cb()
182   ctx = container_of(ipc_pipe, struct ipc_client_ctx, ipc_pipe);  in ipc_read_cb()
183   loop = ipc_pipe->loop;  in ipc_read_cb()
185   ASSERT(1 == uv_pipe_pending_count(ipc_pipe));  in ipc_read_cb()
186   type = uv_pipe_pending_type(ipc_pipe);  in ipc_read_cb()
195   uv_close((uv_handle_t*) &ctx->ipc_pipe, NULL);  in ipc_read_cb()
226   ASSERT(0 == uv_pipe_init(loop, &ctx.ipc_pipe, 0));  in send_listen_handles()
227   ASSERT(0 == uv_pipe_bind(&ctx.ipc_pipe, IPC_PIPE_NAME));  in send_listen_handles()
228   ASSERT(0 == uv_listen((uv_stream_t*) &ctx.ipc_pipe, 128, ipc_connection_cb));  in send_listen_handles()
248   ASSERT(0 == uv_pipe_init(loop, &ctx.ipc_pipe, 1));  in get_listen_handle()
250                   &ctx.ipc_pipe,  in get_listen_handle()