]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mon: remove unnecessary error handling
authorKefu Chai <kchai@redhat.com>
Tue, 2 Jun 2015 04:22:26 +0000 (12:22 +0800)
committerNathan Cutler <ncutler@suse.com>
Fri, 10 Jul 2015 20:07:09 +0000 (22:07 +0200)
msg.get_session() should always return a non-zero pointer in
Monitor.dispatch()

Signed-off-by: Kefu Chai <kchai@redhat.com>
(cherry picked from commit 16e8e2cc82a90c49cd8aa3d0e3acc4694ba659a0)

Conflicts:
    src/mon/Monitor.cc
        Monitor::_ms_dispatch(Message *m) is bool in firefly

src/include/interval_set.h
src/mon/MDSMonitor.cc
src/mon/Monitor.cc

index 7affb87ab7d7173e9afb60296dd792c55eb2f009..9a7d2f2e104a636714dddd40a7be062c65a93318 100644 (file)
@@ -371,6 +371,7 @@ class interval_set {
   
   void erase(iterator &i) {
     _size -= i.get_len();
+    assert(_size >= 0);
     m.erase(i._iter);
   }
 
index 12755b7c45543312af33146bf0845f77ed3b6a45..342420fa8cd578108606a8c9795acecf2a52f26f 100644 (file)
@@ -208,8 +208,7 @@ bool MDSMonitor::preprocess_beacon(MMDSBeacon *m)
 
   // check privileges, ignore if fails
   MonSession *session = m->get_session();
-  if (!session)
-    goto out;
+  assert(session);
   if (!session->is_capable("mds", MON_CAP_X)) {
     dout(0) << "preprocess_beacon got MMDSBeacon from entity with insufficient privileges "
            << session->caps << dendl;
index c39faad23e27660a876b5c7e38494e95b75370d0..7be0f3e1dfbdf7b3b60f064ef47cc48d398ecccb 100644 (file)
@@ -2935,12 +2935,11 @@ bool Monitor::_ms_dispatch(Message *m)
     dout(20) << "ms_dispatch existing session " << s << " for " << s->inst << dendl;
   }
 
-  if (s) {
-    if (s->auth_handler) {
-      s->entity_name = s->auth_handler->get_entity_name();
-    }
-    dout(20) << " caps " << s->caps.get_str() << dendl;
+  assert(s);
+  if (s->auth_handler) {
+    s->entity_name = s->auth_handler->get_entity_name();
   }
+  dout(20) << " caps " << s->caps.get_str() << dendl;
 
   if (is_synchronizing() && !src_is_mon) {
     waitlist_or_zap_client(m);
@@ -2948,11 +2947,7 @@ bool Monitor::_ms_dispatch(Message *m)
   }
 
   ret = dispatch(s, m, src_is_mon);
-
-  if (s) {
-    s->put();
-  }
-
+  s->put();
   return ret;
 }