diff options
| author | DeHackEd <[email protected]> | 2019-06-03 23:54:43 -0400 |
|---|---|---|
| committer | Brian Behlendorf <[email protected]> | 2019-06-03 20:54:43 -0700 |
| commit | df24bcf00a60a5a9b1673f4012ee4cbea8c13a69 (patch) | |
| tree | f58817491754c80072b6bec038287c0440b68d23 /module/zfs/bqueue.c | |
| parent | a3c98d5728701d455e036d7687e3f7dbbb6100e5 (diff) | |
Wait in 'S' state when send/recv pipe is blocking
Reviewed-by: Paul Dagnelie <[email protected]>
Reviewed-by: Brian Behlendorf <[email protected]>
Reviewed-by: Tony Hutter <[email protected]>
Signed-off-by: DHE <[email protected]>
Closes #8733
Closes #8752
Diffstat (limited to 'module/zfs/bqueue.c')
| -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); |