summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJoao Eduardo Luis <joao.luis@inktank.com>2013-05-31 16:26:02 +0100
committerJoao Eduardo Luis <joao.luis@inktank.com>2013-05-31 16:26:02 +0100
commita8ab0390dc79b26f078b48ddb4ec154134e86a2a (patch)
treea3b0d049ad3fee150cab184e1e794343188f229e
parenta7e50fca4d1038db7b79181c9cf79aa6502df97b (diff)
downloadceph-a8ab0390dc79b26f078b48ddb4ec154134e86a2a.tar.gz
mon: Monitor: update PaxosService's cached values before update_from_paxoswip-mon-cache-first-last-committed
Signed-off-by: Joao Eduardo Luis <joao.luis@inktank.com>
-rw-r--r--src/mon/Monitor.cc2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mon/Monitor.cc b/src/mon/Monitor.cc
index 89048a17f9b..ee904b645bf 100644
--- a/src/mon/Monitor.cc
+++ b/src/mon/Monitor.cc
@@ -518,6 +518,7 @@ void Monitor::init_paxos()
// update paxos
for (int i = 0; i < PAXOS_NUM; ++i) {
if (paxos->is_consistent()) {
+ paxos_service[i]->update_cached_versions();
paxos_service[i]->update_from_paxos();
}
}
@@ -3321,6 +3322,7 @@ bool Monitor::_ms_dispatch(Message *m)
if (paxos->is_active()) {
vector<PaxosService*>::iterator service_it = paxos_service.begin();
for ( ; service_it != paxos_service.end(); ++service_it)
+ (*service_it)->update_cached_versions();
(*service_it)->update_from_paxos();
}
}