RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-04-01 00:26:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

PG: update info.history even if lastmap is absent

Browse Source 
Previously, we did not update same_interval_since etc if
we do not have the previous map.

Signed-off-by: Samuel Just <samuel.just@dreamhost.com>
This commit is contained in:
Samuel Just 2011-11-09 17:16:57 -08:00
parent 023ff5903a
commit a3dd5bd67b
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/osd/PG.cc
View File

@ -3525,13 +3525,6 @@ void PG::start_peering_interval(const OSDMapRef lastmap,
i.acting = oldacting;
i.up = oldup;
if (oldacting != acting || oldup != up) {
info.history.same_interval_since = osdmap->get_epoch();
}
if (oldup != up) {
info.history.same_up_since = osdmap->get_epoch();
}
if (i.acting.size()) {
i.maybe_went_rw =
lastmap->get_up_thru(i.acting[0]) >= i.first &&
@ -3540,14 +3533,20 @@ void PG::start_peering_interval(const OSDMapRef lastmap,
i.maybe_went_rw = 0;
}
if (oldprimary != get_primary()) {
info.history.same_primary_since = osdmap->get_epoch();
}
dout(10) << " noting past " << i << dendl;
dirty_info = true;
}
if (oldacting != acting || oldup != up) {
info.history.same_interval_since = osdmap->get_epoch();
}
if (oldup != up) {
info.history.same_up_since = osdmap->get_epoch();
}
if (oldprimary != get_primary()) {
info.history.same_primary_since = osdmap->get_epoch();
}
dout(10) << " up " << oldup << " -> " << up
<< ", acting " << oldacting << " -> " << acting
<< ", role " << oldrole << " -> " << role << dendl;