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