Searched refs:rr_pipe (Results 1 – 3 of 3) sorted by relevance
202 if((ctx->rr_pipe = tube_create()) == NULL) { in ub_ctx_create()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()[all …]
345 tube_close_read(ctx->rr_pipe); in libworker_dobg()352 if(!tube_setup_bg_write(ctx->rr_pipe, w->base)) { in libworker_dobg()364 tube_remove_bg_write(w->ctx->rr_pipe); in libworker_dobg()366 (void)tube_write_msg(ctx->rr_pipe, (uint8_t*)&m, in libworker_dobg()371 tube_close_write(ctx->rr_pipe); in libworker_dobg()403 tube_close_read(ctx->rr_pipe); in libworker_bg()414 tube_close_write(ctx->rr_pipe); in libworker_bg()776 if(!tube_queue_item(w->ctx->rr_pipe, msg, len)) { in add_bg_result()
74 struct tube* rr_pipe; member