|
@@ -895,8 +895,8 @@ static void migration_success_pre_commit(struct dm_cache_migration *mg)
|
|
|
struct cache *cache = mg->cache;
|
|
|
|
|
|
if (mg->writeback) {
|
|
|
- cell_defer(cache, mg->old_ocell, false);
|
|
|
clear_dirty(cache, mg->old_oblock, mg->cblock);
|
|
|
+ cell_defer(cache, mg->old_ocell, false);
|
|
|
cleanup_migration(mg);
|
|
|
return;
|
|
|
|
|
@@ -951,13 +951,13 @@ static void migration_success_post_commit(struct dm_cache_migration *mg)
|
|
|
}
|
|
|
|
|
|
} else {
|
|
|
+ clear_dirty(cache, mg->new_oblock, mg->cblock);
|
|
|
if (mg->requeue_holder)
|
|
|
cell_defer(cache, mg->new_ocell, true);
|
|
|
else {
|
|
|
bio_endio(mg->new_ocell->holder, 0);
|
|
|
cell_defer(cache, mg->new_ocell, false);
|
|
|
}
|
|
|
- clear_dirty(cache, mg->new_oblock, mg->cblock);
|
|
|
cleanup_migration(mg);
|
|
|
}
|
|
|
}
|