Searched refs:bqueue_dequeue (Results 1 – 5 of 5) sorted by relevance
53 void *bqueue_dequeue(bqueue_t *);
151 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue() function
487 struct redact_record *next = bqueue_dequeue(bq); in get_next_redact_record() 764 node->record = bqueue_dequeue(&targ->q); in perform_thread_merge() 906 for (rec = bqueue_dequeue(q); !rec->eos_marker && err == 0; in perform_redaction()
1275 struct send_range *next = bqueue_dequeue(bq); in send_range_after() 1504 bqueue_dequeue(&smt_arg->redact_arg->q); in find_next_range() 1507 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q); in find_next_range() 1509 front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q); in find_next_range() 1760 struct send_range *range = bqueue_dequeue(inq); in send_reader_thread() 2568 range = bqueue_dequeue(&srt_arg->q); in dmu_send_impl()
3221 for (rrd = bqueue_dequeue(&rwa->q); !rrd->eos_marker; in receive_writer_thread() 3222 rrd = bqueue_dequeue(&rwa->q)) { in receive_writer_thread()