Home
last modified time | relevance | path

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

/freebsd/contrib/unbound/libunbound/
H A Dlibunbound.c202 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()
[all …]
H A Dlibworker.c345 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()
H A Dcontext.h74 struct tube* rr_pipe; member