// already booted?
if (osdmap.is_up(from) &&
- osdmap.get_inst(from) == m->get_orig_source_inst() &&
+ osdmap.get_addrs(from) == m->get_orig_source_addrs() &&
osdmap.get_cluster_addr(from) == m->cluster_addr) {
// yup.
- dout(7) << "preprocess_boot dup from " << m->get_orig_source_inst()
- << " == " << osdmap.get_inst(from) << dendl;
+ dout(7) << "preprocess_boot dup from " << m->get_orig_source()
+ << " " << m->get_orig_source_addrs()
+ << " == " << osdmap.get_addrs(from) << dendl;
_booted(op, false);
return true;
}
// already up? mark down first?
if (osdmap.is_up(from)) {
- dout(7) << __func__ << " was up, first marking down "
- << osdmap.get_inst(from) << dendl;
+ dout(7) << __func__ << " was up, first marking down osd." << from << " "
+ << osdmap.get_addrs(from) << dendl;
// preprocess should have caught these; if not, assert.
- assert(osdmap.get_inst(from) != m->get_orig_source_inst() ||
+ assert(osdmap.get_addrs(from) != m->get_orig_source_addrs() ||
osdmap.get_cluster_addr(from) != m->cluster_addr);
assert(osdmap.get_uuid(from) == m->sb.osd_fsid);
if ((!osdmap.is_up(from) &&
osdmap.get_most_recent_addrs(from) == m->get_orig_source_addrs()) ||
(osdmap.is_up(from) &&
- osdmap.get_inst(from) != m->get_orig_source_inst())) {
+ osdmap.get_addrs(from) != m->get_orig_source_addrs())) {
dout(7) << __func__ << " ignoring full message from down "
<< m->get_orig_source_inst() << dendl;
goto ignore;
}
if (!osdmap.is_up(from) ||
- osdmap.get_inst(from) != m->get_orig_source_inst()) {
- dout(7) << "preprocess_alive ignoring alive message from down " << m->get_orig_source_inst() << dendl;
+ osdmap.get_addrs(from) != m->get_orig_source_addrs()) {
+ dout(7) << "preprocess_alive ignoring alive message from down "
+ << m->get_orig_source() << " " << m->get_orig_source_addrs()
+ << dendl;
goto ignore;
}
auto from = src.num();
if (!src.is_osd() ||
!mon->osdmon()->osdmap.is_up(from) ||
- m->get_orig_source_inst() != mon->osdmon()->osdmap.get_inst(from)) {
+ m->get_orig_source_addrs() != mon->osdmon()->osdmap.get_addrs(from)) {
dout(1) << __func__ << " ignoring stats from non-active osd." << dendl;
return false;
}
}
if (!osdmap.is_up(from) ||
- osdmap.get_inst(from) != m->get_orig_source_inst()) {
- dout(7) << "ignoring pgtemp message from down " << m->get_orig_source_inst() << dendl;
+ osdmap.get_addrs(from) != m->get_orig_source_addrs()) {
+ dout(7) << "ignoring pgtemp message from down "
+ << m->get_orig_source() << " " << m->get_orig_source_addrs()
+ << dendl;
goto ignore;
}
if (!src.is_osd() ||
!osdmap.is_up(from) ||
- beacon->get_orig_source_inst() != osdmap.get_inst(from)) {
+ beacon->get_orig_source_addrs() != osdmap.get_addrs(from)) {
dout(1) << " ignoring beacon from non-active osd." << from << dendl;
return false;
}