diff options
author | DeHackEd <DeHackEd@users.noreply.github.com> | 2019-06-03 23:54:43 -0400 |
---|---|---|
committer | Brian Behlendorf <behlendorf1@llnl.gov> | 2019-06-03 20:54:43 -0700 |
commit | df24bcf00a60a5a9b1673f4012ee4cbea8c13a69 (patch) | |
tree | f58817491754c80072b6bec038287c0440b68d23 /module | |
parent | a3c98d5728701d455e036d7687e3f7dbbb6100e5 (diff) |
Wait in 'S' state when send/recv pipe is blocking
Reviewed-by: Paul Dagnelie <pcd@delphix.com>
Reviewed-by: Brian Behlendorf <behlendorf1@llnl.gov>
Reviewed-by: Tony Hutter <hutter2@llnl.gov>
Signed-off-by: DHE <git@dehacked.net>
Closes #8733
Closes #8752
Diffstat (limited to 'module')
-rw-r--r-- | module/zfs/bqueue.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/module/zfs/bqueue.c b/module/zfs/bqueue.c index f30253d24..3fc7fcaaa 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); |