HomeSort by: relevance | last modified time | path
    Searched refs:rr_pipe (Results 1 - 3 of 3) sorted by relevancy

  /src/external/bsd/unbound/dist/libunbound/
libunbound.c 202 if((ctx->rr_pipe = tube_create()) == NULL) {
277 while(tube_read_msg(ctx->rr_pipe, &msg, &len, 0)) {
329 if(ctx->rr_pipe->listen_com)
330 ctx->rr_pipe->listen_com->event_added = 0;
331 if(ctx->rr_pipe->res_com)
332 ctx->rr_pipe->res_com->event_added = 0;
383 tube_delete(ctx->rr_pipe);
577 return tube_poll(ctx->rr_pipe);
585 return tube_read_fd(ctx->rr_pipe);
684 r = tube_read_msg(ctx->rr_pipe, &msg, &len, 1)
    [all...]
context.h 74 struct tube* rr_pipe; member in struct:ub_ctx
libworker.c 354 tube_close_read(ctx->rr_pipe);
361 if(!tube_setup_bg_write(ctx->rr_pipe, w->base)) {
373 tube_remove_bg_write(w->ctx->rr_pipe);
375 (void)tube_write_msg(ctx->rr_pipe, (uint8_t*)&m,
380 tube_close_write(ctx->rr_pipe);
412 tube_close_read(ctx->rr_pipe);
423 tube_close_write(ctx->rr_pipe);
789 if(!tube_queue_item(w->ctx->rr_pipe, msg, len)) {

Completed in 101 milliseconds