Searched refs:bqueue_dequeue (Results 1 – 5 of 5) sorted by relevance
49 void *bqueue_dequeue(bqueue_t *);
130 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue() function
484 struct redact_record *next = bqueue_dequeue(bq); in get_next_redact_record()763 node->record = bqueue_dequeue(&targ->q); in perform_thread_merge()904 for (rec = bqueue_dequeue(q); !rec->eos_marker && err == 0; in perform_redaction()
1300 struct send_range *next = bqueue_dequeue(bq); in get_next_range_nofree()1529 bqueue_dequeue(&smt_arg->redact_arg->q); in send_merge_thread()1532 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q); in send_merge_thread()1534 front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q); in send_merge_thread()1743 struct send_range *range = bqueue_dequeue(inq); in send_reader_thread()2533 range = bqueue_dequeue(&srt_arg->q); in dmu_send_impl()
2797 for (rrd = bqueue_dequeue(&rwa->q); !rrd->eos_marker; in receive_writer_thread()2798 rrd = bqueue_dequeue(&rwa->q)) { in receive_writer_thread()