Home
last modified time | relevance | path

Searched refs:bqueue_t (Results 1 – 5 of 5) sorted by relevance

/freebsd/sys/contrib/openzfs/include/sys/
H A Dbqueue.h42 } bqueue_t; typedef
50 int bqueue_init(bqueue_t *, uint_t, size_t, size_t);
51 void bqueue_destroy(bqueue_t *);
52 void bqueue_enqueue(bqueue_t *, void *, size_t);
53 void bqueue_enqueue_flush(bqueue_t *, void *, size_t);
54 void *bqueue_dequeue(bqueue_t *);
/freebsd/sys/contrib/openzfs/module/zfs/
H A Dbqueue.c24 obj2node(bqueue_t *q, void *data) in obj2node()
53 bqueue_init(bqueue_t *q, uint_t fill_fraction, size_t size, size_t node_offset) in bqueue_init()
82 bqueue_destroy(bqueue_t *q) in bqueue_destroy()
98 bqueue_enqueue_impl(bqueue_t *q, void *data, size_t item_size, boolean_t flush) in bqueue_enqueue_impl()
128 bqueue_enqueue(bqueue_t *q, void *data, size_t item_size) in bqueue_enqueue()
142 bqueue_enqueue_flush(bqueue_t *q, void *data, size_t item_size) in bqueue_enqueue_flush()
152 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue()
H A Ddmu_redact.c84 bqueue_t q;
141 record_merge_enqueue(bqueue_t *q, struct redact_record **build, in record_merge_enqueue()
486 get_next_redact_record(bqueue_t *bq, struct redact_record *prev) in get_next_redact_record()
724 perform_thread_merge(bqueue_t *q, uint32_t num_threads, in perform_thread_merge()
833 bqueue_t q;
891 bqueue_t *q = &rmta->q; in perform_redaction()
H A Ddmu_send.c120 bqueue_t q;
132 bqueue_t q;
141 bqueue_t q;
1170 bqueue_t *q;
1274 get_next_range_nofree(bqueue_t *bq, struct send_range *prev) in get_next_range_nofree()
1286 get_next_range(bqueue_t *bq, struct send_range *prev) in get_next_range()
1386 find_next_range(struct send_range **ranges, bqueue_t **qs, uint64_t *out_mask) in find_next_range()
1493 bqueue_t *queues[NUM_THREADS]; in send_merge_thread()
1563 bqueue_t q;
1672 enqueue_range(struct send_reader_thread_arg *srta, bqueue_t *q, dnode_t *dn, in enqueue_range()
[all …]
H A Ddmu_recv.c108 bqueue_t q;