}
}
-bool Monitor::_ms_dispatch(Message *m)
+void Monitor::_ms_dispatch(Message *m)
{
- bool ret = true;
-
if (is_shutdown()) {
m->put();
- return true;
+ return;
}
ConnectionRef connection = m->get_connection();
dout(1) << __func__ << " dropping stray message " << *m
<< " from " << m->get_source_inst() << dendl;
m->put();
- return true;
+ return;
}
if (!exited_quorum.is_zero() && !src_is_mon) {
waitlist_or_zap_client(m);
- return true;
+ return;
}
dout(10) << "do not have session, making new one" << dendl;
if (is_synchronizing() && !src_is_mon) {
waitlist_or_zap_client(m);
- return true;
+ return;
}
- ret = dispatch(s, m, src_is_mon);
+ dispatch(s, m, src_is_mon);
if (s) {
s->put();
}
- return ret;
+ return;
}
-bool Monitor::dispatch(MonSession *s, Message *m, const bool src_is_mon)
+void Monitor::dispatch(MonSession *s, Message *m, const bool src_is_mon)
{
- bool ret = true;
-
assert(m != NULL);
switch (m->get_type()) {
m->put();
break;
}
-
- return ret;
}
void Monitor::handle_ping(MPing *m)
//ms_dispatch handles a lot of logic and we want to reuse it
//on forwarded messages, so we create a non-locking version for this class
- bool _ms_dispatch(Message *m);
+ void _ms_dispatch(Message *m);
bool ms_dispatch(Message *m) {
lock.Lock();
- bool ret = _ms_dispatch(m);
+ _ms_dispatch(m);
lock.Unlock();
- return ret;
+ return true;
}
// dissociate message handling from session and connection logic
- bool dispatch(MonSession *s, Message *m, const bool src_is_mon);
+ void dispatch(MonSession *s, Message *m, const bool src_is_mon);
//mon_caps is used for un-connected messages from monitors
MonCap * mon_caps;
bool ms_get_authorizer(int dest_type, AuthAuthorizer **authorizer, bool force_new);