diff options
Diffstat (limited to 'fs/btrfs/volumes.c')
| -rw-r--r-- | fs/btrfs/volumes.c | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/fs/btrfs/volumes.c b/fs/btrfs/volumes.c index fd0bedb07a64..bcd14ebccae1 100644 --- a/fs/btrfs/volumes.c +++ b/fs/btrfs/volumes.c | |||
| @@ -154,6 +154,7 @@ static noinline int run_scheduled_bios(struct btrfs_device *device) | |||
| 154 | loop: | 154 | loop: |
| 155 | spin_lock(&device->io_lock); | 155 | spin_lock(&device->io_lock); |
| 156 | 156 | ||
| 157 | loop_lock: | ||
| 157 | /* take all the bios off the list at once and process them | 158 | /* take all the bios off the list at once and process them |
| 158 | * later on (without the lock held). But, remember the | 159 | * later on (without the lock held). But, remember the |
| 159 | * tail and other pointers so the bios can be properly reinserted | 160 | * tail and other pointers so the bios can be properly reinserted |
| @@ -203,7 +204,7 @@ loop: | |||
| 203 | * is now congested. Back off and let other work structs | 204 | * is now congested. Back off and let other work structs |
| 204 | * run instead | 205 | * run instead |
| 205 | */ | 206 | */ |
| 206 | if (pending && bdi_write_congested(bdi) && | 207 | if (pending && bdi_write_congested(bdi) && num_run > 16 && |
| 207 | fs_info->fs_devices->open_devices > 1) { | 208 | fs_info->fs_devices->open_devices > 1) { |
| 208 | struct bio *old_head; | 209 | struct bio *old_head; |
| 209 | 210 | ||
| @@ -215,7 +216,8 @@ loop: | |||
| 215 | tail->bi_next = old_head; | 216 | tail->bi_next = old_head; |
| 216 | else | 217 | else |
| 217 | device->pending_bio_tail = tail; | 218 | device->pending_bio_tail = tail; |
| 218 | device->running_pending = 0; | 219 | |
| 220 | device->running_pending = 1; | ||
| 219 | 221 | ||
| 220 | spin_unlock(&device->io_lock); | 222 | spin_unlock(&device->io_lock); |
| 221 | btrfs_requeue_work(&device->work); | 223 | btrfs_requeue_work(&device->work); |
| @@ -224,6 +226,11 @@ loop: | |||
| 224 | } | 226 | } |
| 225 | if (again) | 227 | if (again) |
| 226 | goto loop; | 228 | goto loop; |
| 229 | |||
| 230 | spin_lock(&device->io_lock); | ||
| 231 | if (device->pending_bios) | ||
| 232 | goto loop_lock; | ||
| 233 | spin_unlock(&device->io_lock); | ||
| 227 | done: | 234 | done: |
| 228 | return 0; | 235 | return 0; |
| 229 | } | 236 | } |
