Searched refs:bqueue_t (Results 1 – 5 of 5) sorted by relevance
| /freebsd/sys/contrib/openzfs/include/sys/ |
| H A D | bqueue.h | 38 } bqueue_t; typedef 46 int bqueue_init(bqueue_t *, uint_t, size_t, size_t); 47 void bqueue_destroy(bqueue_t *); 48 void bqueue_enqueue(bqueue_t *, void *, size_t); 49 void bqueue_enqueue_flush(bqueue_t *, void *, size_t); 50 void *bqueue_dequeue(bqueue_t *);
|
| /freebsd/sys/contrib/openzfs/module/zfs/ |
| H A D | bqueue.c | 20 obj2node(bqueue_t *q, void *data) in obj2node() 49 bqueue_init(bqueue_t *q, uint_t fill_fraction, size_t size, size_t node_offset) in bqueue_init() 78 bqueue_destroy(bqueue_t *q) in bqueue_destroy() 94 bqueue_enqueue_impl(bqueue_t *q, void *data, size_t item_size, boolean_t flush) in bqueue_enqueue_impl() 124 bqueue_enqueue(bqueue_t *q, void *data, size_t item_size) in bqueue_enqueue() 138 bqueue_enqueue_flush(bqueue_t *q, void *data, size_t item_size) in bqueue_enqueue_flush() 148 bqueue_dequeue(bqueue_t *q) in bqueue_dequeue()
|
| H A D | dmu_redact.c | 74 bqueue_t q; 131 record_merge_enqueue(bqueue_t *q, struct redact_record **build, in record_merge_enqueue() 472 get_next_redact_record(bqueue_t *bq, struct redact_record *prev) in get_next_redact_record() 712 perform_thread_merge(bqueue_t *q, uint32_t num_threads, in perform_thread_merge() 821 bqueue_t q; 879 bqueue_t *q = &rmta->q; in perform_redaction()
|
| H A D | dmu_send.c | 110 bqueue_t q; 122 bqueue_t q; 131 bqueue_t q; 1160 bqueue_t *q; 1264 get_next_range_nofree(bqueue_t *bq, struct send_range *prev) in get_next_range_nofree() 1276 get_next_range(bqueue_t *bq, struct send_range *prev) in get_next_range() 1376 find_next_range(struct send_range **ranges, bqueue_t **qs, uint64_t *out_mask) in find_next_range() 1483 bqueue_t *queues[NUM_THREADS]; in send_merge_thread() 1553 bqueue_t q; 1662 enqueue_range(struct send_reader_thread_arg *srta, bqueue_t *q, dnode_t *dn, in enqueue_range() [all …]
|
| H A D | dmu_recv.c | 110 bqueue_t q;
|