aboutsummaryrefslogtreecommitdiff
path: root/module/zfs/bqueue.c
diff options
context:
space:
mode:
authorDeHackEd <DeHackEd@users.noreply.github.com>2019-06-04 03:54:43 +0000
committerBrian Behlendorf <behlendorf1@llnl.gov>2019-06-04 03:54:43 +0000
commitdf24bcf00a60a5a9b1673f4012ee4cbea8c13a69 (patch)
treef58817491754c80072b6bec038287c0440b68d23 /module/zfs/bqueue.c
parenta3c98d5728701d455e036d7687e3f7dbbb6100e5 (diff)
downloadsrc-df24bcf00a60a5a9b1673f4012ee4cbea8c13a69.tar.gz
src-df24bcf00a60a5a9b1673f4012ee4cbea8c13a69.zip
Diffstat (limited to 'module/zfs/bqueue.c')
-rw-r--r--module/zfs/bqueue.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/module/zfs/bqueue.c b/module/zfs/bqueue.c
index f30253d24bfb..3fc7fcaaada7 100644
--- a/module/zfs/bqueue.c
+++ b/module/zfs/bqueue.c
@@ -73,7 +73,7 @@ bqueue_enqueue(bqueue_t *q, void *data, uint64_t item_size)
mutex_enter(&q->bq_lock);
obj2node(q, data)->bqn_size = item_size;
while (q->bq_size + item_size > q->bq_maxsize) {
- cv_wait(&q->bq_add_cv, &q->bq_lock);
+ cv_wait_sig(&q->bq_add_cv, &q->bq_lock);
}
q->bq_size += item_size;
list_insert_tail(&q->bq_list, data);
@@ -91,7 +91,7 @@ bqueue_dequeue(bqueue_t *q)
uint64_t item_size;
mutex_enter(&q->bq_lock);
while (q->bq_size == 0) {
- cv_wait(&q->bq_pop_cv, &q->bq_lock);
+ cv_wait_sig(&q->bq_pop_cv, &q->bq_lock);
}
ret = list_remove_head(&q->bq_list);
ASSERT3P(ret, !=, NULL);