Searched refs:bqueue_dequeue (Results 1 – 5 of 5) sorted by relevance
54 void *bqueue_dequeue(bqueue_t *);
152 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue() function
488 struct redact_record *next = bqueue_dequeue(bq); in get_next_redact_record()765 node->record = bqueue_dequeue(&targ->q); in perform_thread_merge()907 for (rec = bqueue_dequeue(q); !rec->eos_marker && err == 0; in perform_redaction()
1276 struct send_range *next = bqueue_dequeue(bq); in get_next_range_nofree()1505 bqueue_dequeue(&smt_arg->redact_arg->q); in send_merge_thread()1508 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q); in send_merge_thread()1510 front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q); in send_merge_thread()1761 struct send_range *range = bqueue_dequeue(inq); in send_reader_thread()2569 range = bqueue_dequeue(&srt_arg->q); in dmu_send_impl()
3225 for (rrd = bqueue_dequeue(&rwa->q); !rrd->eos_marker; in receive_writer_thread()3226 rrd = bqueue_dequeue(&rwa->q)) { in receive_writer_thread()