RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-03 09:32:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

osd/PG: avoid updating missing_loc_sources multiple times

Browse Source 
Signed-off-by: xie xingguo <xie.xingguo@zte.com.cn>
This commit is contained in:
xie xingguo 2017-10-09 15:53:53 +08:00
parent d9b9b075ff
commit b650e91519
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/osd/PG.cc
View File

@ -598,6 +598,7 @@ void PG::MissingLoc::add_batch_sources_info(
ldout(pg->cct, 10) << __func__ << ": adding sources in batch "
<< sources.size() << dendl;
unsigned loop = 0;
bool sources_updated = false;
for (map<hobject_t, pg_missing_item>::const_iterator i = needs_recovery_map.begin();
i != needs_recovery_map.end();
++i) {
@ -608,7 +609,10 @@ void PG::MissingLoc::add_batch_sources_info(
if (i->second.is_delete())
continue;
missing_loc[i->first].insert(sources.begin(), sources.end());
missing_loc_sources.insert(sources.begin(), sources.end());
if (!sources_updated) {
missing_loc_sources.insert(sources.begin(), sources.end());
sources_updated = true;
}
}
}
@ -620,6 +624,7 @@ bool PG::MissingLoc::add_source_info(
{
bool found_missing = false;
unsigned loop = 0;
bool sources_updated = false;
// found items?
for (map<hobject_t,pg_missing_item>::const_iterator p = needs_recovery_map.begin();
p != needs_recovery_map.end();
@ -673,7 +678,10 @@ bool PG::MissingLoc::add_source_info(
<< " is on osd." << fromosd << dendl;
missing_loc[soid].insert(fromosd);
missing_loc_sources.insert(fromosd);
if (!sources_updated) {
missing_loc_sources.insert(fromosd);
sources_updated = true;
}
found_missing = true;
}