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

mon: automatically incorporate new incompat features into mdsmap

Browse Source
This commit is contained in:
Sage Weil 2010-08-05 16:49:07 -07:00
parent 846e979cbb
commit d97e42e1aa
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/mon/MDSMonitor.cc
View File

@ -175,8 +175,15 @@ bool MDSMonitor::preprocess_beacon(MMDSBeacon *m)
dout(12) << "preprocess_beacon " << *m
<< " from " << m->get_orig_source_inst()
<< " " << m->get_compat()
<< dendl;
// check compat
if (!m->get_compat().writeable(mdsmap.compat)) {
dout(1) << " mds " << m->get_source_inst() << " can't write to mdsmap " << mdsmap.compat << dendl;
goto out;
}
// fw to leader?
if (!mon->is_leader())
return false;
@ -326,6 +333,14 @@ bool MDSMonitor::prepare_beacon(MMDSBeacon *m)
last_beacon[gid].stamp = g_clock.now();
last_beacon[gid].seq = seq;
// new incompat?
if (!pending_mdsmap.compat.writeable(m->get_compat())) {
dout(10) << " mdsmap " << pending_mdsmap.compat << " can't write to new mds' " << m->get_compat()
<< ", updating mdsmap and killing old mds's"
<< dendl;
pending_mdsmap.compat = m->get_compat();
}
} else {
// state change
MDSMap::mds_info_t& info = pending_mdsmap.get_info_gid(gid);