diff options
| author | Mikulas Patocka <mpatocka@redhat.com> | 2018-07-03 14:13:26 -0400 |
|---|---|---|
| committer | Mike Snitzer <snitzer@redhat.com> | 2018-07-27 15:24:21 -0400 |
| commit | 518748b1a744c496a657a5a7923e49e002a6f259 (patch) | |
| tree | 64cf093f45adc886b3f337d1c875b23bc2528b51 /drivers/md/dm-integrity.c | |
| parent | c21b16392701543d61e366dca84e15fe7f0cf0cf (diff) | |
dm integrity: decouple common code in dm_integrity_map_continue()
Decouple how dm_integrity_map_continue() responds to being out of free
sectors and when add_new_range() fails.
This has no functional change, but helps prepare for the next commit.
Signed-off-by: Mikulas Patocka <mpatocka@redhat.com>
Signed-off-by: Mike Snitzer <snitzer@redhat.com>
Diffstat (limited to 'drivers/md/dm-integrity.c')
| -rw-r--r-- | drivers/md/dm-integrity.c | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/drivers/md/dm-integrity.c b/drivers/md/dm-integrity.c index 0a8a4c2aa3ea..0829f18d91a3 100644 --- a/drivers/md/dm-integrity.c +++ b/drivers/md/dm-integrity.c | |||
| @@ -1599,8 +1599,12 @@ retry: | |||
| 1599 | 1599 | ||
| 1600 | dio->range.n_sectors = min(dio->range.n_sectors, | 1600 | dio->range.n_sectors = min(dio->range.n_sectors, |
| 1601 | ic->free_sectors << ic->sb->log2_sectors_per_block); | 1601 | ic->free_sectors << ic->sb->log2_sectors_per_block); |
| 1602 | if (unlikely(!dio->range.n_sectors)) | 1602 | if (unlikely(!dio->range.n_sectors)) { |
| 1603 | goto sleep; | 1603 | if (from_map) |
| 1604 | goto offload_to_thread; | ||
| 1605 | sleep_on_endio_wait(ic); | ||
| 1606 | goto retry; | ||
| 1607 | } | ||
| 1604 | range_sectors = dio->range.n_sectors >> ic->sb->log2_sectors_per_block; | 1608 | range_sectors = dio->range.n_sectors >> ic->sb->log2_sectors_per_block; |
| 1605 | ic->free_sectors -= range_sectors; | 1609 | ic->free_sectors -= range_sectors; |
| 1606 | journal_section = ic->free_section; | 1610 | journal_section = ic->free_section; |
| @@ -1660,8 +1664,8 @@ retry: | |||
| 1660 | * stall bios on current->bio_list. | 1664 | * stall bios on current->bio_list. |
| 1661 | * So, we offload the bio to a workqueue if we have to sleep. | 1665 | * So, we offload the bio to a workqueue if we have to sleep. |
| 1662 | */ | 1666 | */ |
| 1663 | sleep: | ||
| 1664 | if (from_map) { | 1667 | if (from_map) { |
| 1668 | offload_to_thread: | ||
| 1665 | spin_unlock_irq(&ic->endio_wait.lock); | 1669 | spin_unlock_irq(&ic->endio_wait.lock); |
| 1666 | INIT_WORK(&dio->work, integrity_bio_wait); | 1670 | INIT_WORK(&dio->work, integrity_bio_wait); |
| 1667 | queue_work(ic->wait_wq, &dio->work); | 1671 | queue_work(ic->wait_wq, &dio->work); |
