Home
last modified time | relevance | path

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

/netbsd-src/external/bsd/unbound/dist/libunbound/
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()
322 if(ctx->rr_pipe->listen_com) in ub_ctx_delete()
323 ctx->rr_pipe->listen_com->event_added = 0; in ub_ctx_delete()
324 if(ctx->rr_pipe->res_com) in ub_ctx_delete()
325 ctx->rr_pipe->res_com->event_added = 0; in ub_ctx_delete()
374 tube_delete(ctx->rr_pipe); in ub_ctx_delete()
564 return tube_poll(ctx->rr_pipe); in ub_poll()
570 return tube_read_fd(ctx->rr_pipe); in ub_fd()
667 r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1); in ub_process()
[all …]
H A Dlibworker.c359 tube_close_read(ctx->rr_pipe); in libworker_dobg()
366 if(!tube_setup_bg_write(ctx->rr_pipe, w->base)) { in libworker_dobg()
378 tube_remove_bg_write(w->ctx->rr_pipe); in libworker_dobg()
380 (void)tube_write_msg(ctx->rr_pipe, (uint8_t*)&m, in libworker_dobg()
385 tube_close_write(ctx->rr_pipe); in libworker_dobg()
417 tube_close_read(ctx->rr_pipe); in libworker_bg()
428 tube_close_write(ctx->rr_pipe); in libworker_bg()
790 if(!tube_queue_item(w->ctx->rr_pipe, msg, len)) { in add_bg_result()
H A Dcontext.h74 struct tube* rr_pipe; member