{
Mutex::Locker l(lock);
- ldout(cct, 20) << *m << dendl;
switch(m->get_type()) {
case MSG_MGR_MAP:
return handle_mgr_map(static_cast<MMgrMap*>(m));
return false;
}
default:
- ldout(cct, 10) << "Not handling " << *m << dendl;
+ ldout(cct, 30) << "Not handling " << *m << dendl;
return false;
}
}
{
assert(lock.is_locked_by_me());
+ ldout(cct, 20) << *m << dendl;
+
map = m->get_map();
ldout(cct, 4) << "Got map version " << map.epoch << dendl;
m->put();
{
assert(lock.is_locked_by_me());
+ ldout(cct, 20) << *m << dendl;
+
if (session == nullptr) {
lderr(cct) << "dropping unexpected configure message" << dendl;
m->put();
{
assert(lock.is_locked_by_me());
+ ldout(cct, 20) << *m << dendl;
+
const auto tid = m->get_tid();
const auto op = command_table.get_command(tid);
if (op == nullptr) {