RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-04-29 22:28:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #14897 from tchaikov/wip-19814

Browse Source 
mon/OSDMonitor: update creating_pgs using pending_creatings

Reviewed-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2017-05-01 20:31:43 -05:00 committed by GitHub
commit f36f0dbcdb
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/mon/OSDMonitor.cc
View File

@ -935,7 +935,7 @@ OSDMonitor::update_pending_pgs(const OSDMap::Incremental& inc)
assert(st != pgm.pg_stat.end()); assert(st != pgm.pg_stat.end());
auto created = make_pair(st->second.created, st->second.last_scrub_stamp); auto created = make_pair(st->second.created, st->second.last_scrub_stamp);
// no need to add the pg, if it already exists in creating_pgs // no need to add the pg, if it already exists in creating_pgs
creating_pgs.pgs.emplace(pgid, created); pending_creatings.pgs.emplace(pgid, created);
} }
} }
for (auto old_pool : inc.old_pools) { for (auto old_pool : inc.old_pools) {
@ -3233,6 +3233,7 @@ epoch_t OSDMonitor::send_pg_creates(int osd, Connection *con, epoch_t next)
{ {
dout(30) << __func__ << " osd." << osd << " next=" << next dout(30) << __func__ << " osd." << osd << " next=" << next
<< " " << creating_pgs_by_osd_epoch << dendl; << " " << creating_pgs_by_osd_epoch << dendl;
std::lock_guard<std::mutex> l(creating_pgs_lock);
auto creating_pgs_by_epoch = creating_pgs_by_osd_epoch.find(osd); auto creating_pgs_by_epoch = creating_pgs_by_osd_epoch.find(osd);
if (creating_pgs_by_epoch == creating_pgs_by_osd_epoch.end()) if (creating_pgs_by_epoch == creating_pgs_by_osd_epoch.end())
return next; return next;