Home
last modified time | relevance | path

Searched refs:rr_pipe (Results 1 – 3 of 3) sorted by relevance

/freebsd-13.1/contrib/unbound/libunbound/
H A Dlibworker.c357 tube_close_read(ctx->rr_pipe); in libworker_dobg()
364 if(!tube_setup_bg_write(ctx->rr_pipe, w->base)) { in libworker_dobg()
376 tube_remove_bg_write(w->ctx->rr_pipe); in libworker_dobg()
378 (void)tube_write_msg(ctx->rr_pipe, (uint8_t*)&m, in libworker_dobg()
383 tube_close_write(ctx->rr_pipe); in libworker_dobg()
414 tube_close_read(ctx->rr_pipe); in libworker_bg()
425 tube_close_write(ctx->rr_pipe); in libworker_bg()
785 if(!tube_queue_item(w->ctx->rr_pipe, msg, len)) { in add_bg_result()
H A Dlibunbound.c197 if((ctx->rr_pipe = tube_create()) == NULL) { in ub_ctx_create()
270 while(tube_read_msg(ctx->rr_pipe, &msg, &len, 0)) { in ub_stop_bg()
337 tube_delete(ctx->rr_pipe); in ub_ctx_delete()
527 return tube_poll(ctx->rr_pipe); in ub_poll()
533 return tube_read_fd(ctx->rr_pipe); in ub_fd()
630 r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1); in ub_process()
673 r = tube_wait(ctx->rr_pipe); in ub_wait()
675 r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1); in ub_wait()
H A Dcontext.h74 struct tube* rr_pipe; member