RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-21 18:17:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd: update clone_overlap even the clone have been evicted

Browse Source 
the clone_overlap is difference of range between head and clones.
if the clone have been evicted, the clone_overlap is still exist in the
snapset, so we should update the clone_overlap to make it sense.

Signed-off-by: Yunchuan Wen <yunchuan.wen@kylin-cloud.com>
This commit is contained in:
Yunchuan Wen 2018-06-15 13:59:30 +08:00
parent 70ba58e9e8
commit 56c8e126a6
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/osd/PrimaryLogPG.cc
View File

@ -8075,18 +8075,21 @@ void PrimaryLogPG::make_writeable(OpContext *ctx)
// update most recent clone_overlap and usage stats // update most recent clone_overlap and usage stats
if (ctx->new_snapset.clones.size() > 0) { if (ctx->new_snapset.clones.size() > 0) {
// the clone_overlap is difference of range between head and clones.
// we need to check whether the most recent clone exists, if it's // we need to check whether the most recent clone exists, if it's
// been evicted, it's not included in the stats // been evicted, it's not included in the stats, but the clone_overlap
// is still exist in the snapset, so we should update the
// clone_overlap to make it sense.
hobject_t last_clone_oid = soid; hobject_t last_clone_oid = soid;
last_clone_oid.snap = ctx->new_snapset.clone_overlap.rbegin()->first; last_clone_oid.snap = ctx->new_snapset.clone_overlap.rbegin()->first;
interval_set<uint64_t> &newest_overlap =
ctx->new_snapset.clone_overlap.rbegin()->second;
ctx->modified_ranges.intersection_of(newest_overlap);
if (is_present_clone(last_clone_oid)) { if (is_present_clone(last_clone_oid)) {
interval_set<uint64_t> &newest_overlap =
ctx->new_snapset.clone_overlap.rbegin()->second;
ctx->modified_ranges.intersection_of(newest_overlap);
// modified_ranges is still in use by the clone // modified_ranges is still in use by the clone
ctx->delta_stats.num_bytes += ctx->modified_ranges.size(); ctx->delta_stats.num_bytes += ctx->modified_ranges.size();
newest_overlap.subtract(ctx->modified_ranges);
} }
newest_overlap.subtract(ctx->modified_ranges);
} }
if (snapc.seq > ctx->new_snapset.seq) { if (snapc.seq > ctx->new_snapset.seq) {