1 /*
2  * CDDL HEADER START
3  *
4  * This file and its contents are supplied under the terms of the
5  * Common Development and Distribution License ("CDDL"), version 1.0.
6  * You may only use this file in accordance with the terms of version
7  * 1.0 of the CDDL.
8  *
9  * A full copy of the text of the CDDL should have accompanied this
10  * source.  A copy of the CDDL is also available via the Internet at
11  * http://www.illumos.org/license/CDDL.
12  *
13  * CDDL HEADER END
14  */
15 /*
16  * Copyright (c) 2014, 2018 by Delphix. All rights reserved.
17  */
18 
19 #ifndef	_BQUEUE_H
20 #define	_BQUEUE_H
21 
22 #ifdef	__cplusplus
23 extern "C" {
24 #endif
25 
26 #include	<sys/zfs_context.h>
27 
28 typedef struct bqueue {
29 	list_t bq_list;
30 	kmutex_t bq_lock;
31 	kcondvar_t bq_add_cv;
32 	kcondvar_t bq_pop_cv;
33 	uint64_t bq_size;
34 	uint64_t bq_maxsize;
35 	uint64_t bq_fill_fraction;
36 	size_t bq_node_offset;
37 } bqueue_t;
38 
39 typedef struct bqueue_node {
40 	list_node_t bqn_node;
41 	uint64_t bqn_size;
42 } bqueue_node_t;
43 
44 
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 *);
51 
52 #ifdef	__cplusplus
53 }
54 #endif
55 
56 #endif	/* _BQUEUE_H */
57