Searched refs:bqueue_t (Results 1 – 5 of 5) sorted by relevance
| /f-stack/freebsd/contrib/openzfs/include/sys/ |
| H A D | bqueue.h | 37 } bqueue_t; typedef
45 int bqueue_init(bqueue_t *, uint64_t, uint64_t, size_t);
46 void bqueue_destroy(bqueue_t *);
47 void bqueue_enqueue(bqueue_t *, void *, uint64_t);
48 void bqueue_enqueue_flush(bqueue_t *, void *, uint64_t);
49 void *bqueue_dequeue(bqueue_t *);
50 boolean_t bqueue_empty(bqueue_t *);
|
| /f-stack/freebsd/contrib/openzfs/module/zfs/ |
| H A D | bqueue.c | 23 obj2node(bqueue_t *q, void *data) in obj2node()
45 bqueue_init(bqueue_t *q, uint64_t fill_fraction, uint64_t size, in bqueue_init()
69 bqueue_destroy(bqueue_t *q) in bqueue_destroy()
81 bqueue_enqueue_impl(bqueue_t *q, void *data, uint64_t item_size, in bqueue_enqueue_impl()
106 bqueue_enqueue(bqueue_t *q, void *data, uint64_t item_size) in bqueue_enqueue()
120 bqueue_enqueue_flush(bqueue_t *q, void *data, uint64_t item_size) in bqueue_enqueue_flush()
130 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue()
152 bqueue_empty(bqueue_t *q) in bqueue_empty()
|
| H A D | dmu_redact.c | 82 bqueue_t q;
139 record_merge_enqueue(bqueue_t *q, struct redact_record **build, in record_merge_enqueue()
482 get_next_redact_record(bqueue_t *bq, struct redact_record *prev) in get_next_redact_record()
720 perform_thread_merge(bqueue_t *q, uint32_t num_threads, in perform_thread_merge()
830 bqueue_t q;
888 bqueue_t *q = &rmta->q; in perform_redaction()
|
| H A D | dmu_send.c | 119 bqueue_t q;
131 bqueue_t q;
140 bqueue_t q;
1194 bqueue_t *q;
1298 get_next_range_nofree(bqueue_t *bq, struct send_range *prev) in get_next_range_nofree()
1310 get_next_range(bqueue_t *bq, struct send_range *prev) in get_next_range()
1517 bqueue_t *queues[NUM_THREADS]; in send_merge_thread()
1589 bqueue_t q;
1695 enqueue_range(struct send_reader_thread_arg *srta, bqueue_t *q, dnode_t *dn, in enqueue_range()
1739 bqueue_t *inq = &smta->q; in send_reader_thread()
[all …]
|
| H A D | dmu_recv.c | 95 bqueue_t q;
|