Lines Matching refs:rr_pipe
202 if((ctx->rr_pipe = tube_create()) == NULL) { in ub_ctx_create()
277 while(tube_read_msg(ctx->rr_pipe, &msg, &len, 0)) { in ub_stop_bg()
329 if(ctx->rr_pipe->listen_com) in ub_ctx_delete()
330 ctx->rr_pipe->listen_com->event_added = 0; in ub_ctx_delete()
331 if(ctx->rr_pipe->res_com) in ub_ctx_delete()
332 ctx->rr_pipe->res_com->event_added = 0; in ub_ctx_delete()
383 tube_delete(ctx->rr_pipe); in ub_ctx_delete()
575 return tube_poll(ctx->rr_pipe); in ub_poll()
581 return tube_read_fd(ctx->rr_pipe); in ub_fd()
678 r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1); in ub_process()
721 r = tube_wait(ctx->rr_pipe); in ub_wait()
723 r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1); in ub_wait()