aboutsummaryrefslogtreecommitdiff
path: root/include/sys/bqueue.h
diff options
context:
space:
mode:
authorPaul Dagnelie <pcd@delphix.com>2019-06-19 16:48:13 +0000
committerBrian Behlendorf <behlendorf1@llnl.gov>2019-06-19 16:48:12 +0000
commit30af21b02569ac192f52ce6e6511015f8a8d5729 (patch)
treee5f1091c2d3a6e511bbd2414782e490c18e0f59c /include/sys/bqueue.h
parentc1b5801bb5af0055e5f3d263beaa07026103e212 (diff)
downloadsrc-30af21b02569ac192f52ce6e6511015f8a8d5729.tar.gz
src-30af21b02569ac192f52ce6e6511015f8a8d5729.zip
Diffstat (limited to 'include/sys/bqueue.h')
-rw-r--r--include/sys/bqueue.h6
1 files changed, 4 insertions, 2 deletions
diff --git a/include/sys/bqueue.h b/include/sys/bqueue.h
index 63722df1bbf3..797aecd791a3 100644
--- a/include/sys/bqueue.h
+++ b/include/sys/bqueue.h
@@ -13,7 +13,7 @@
* CDDL HEADER END
*/
/*
- * Copyright (c) 2014 by Delphix. All rights reserved.
+ * Copyright (c) 2014, 2018 by Delphix. All rights reserved.
*/
#ifndef _BQUEUE_H
@@ -32,6 +32,7 @@ typedef struct bqueue {
kcondvar_t bq_pop_cv;
uint64_t bq_size;
uint64_t bq_maxsize;
+ uint64_t bq_fill_fraction;
size_t bq_node_offset;
} bqueue_t;
@@ -41,9 +42,10 @@ typedef struct bqueue_node {
} bqueue_node_t;
-int bqueue_init(bqueue_t *, uint64_t, size_t);
+int bqueue_init(bqueue_t *, uint64_t, uint64_t, size_t);
void bqueue_destroy(bqueue_t *);
void bqueue_enqueue(bqueue_t *, void *, uint64_t);
+void bqueue_enqueue_flush(bqueue_t *, void *, uint64_t);
void *bqueue_dequeue(bqueue_t *);
boolean_t bqueue_empty(bqueue_t *);