]> git.apps.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)
committerAbhishek Lekshmanan <abhishek.lekshmanan@ril.com>
Wed, 1 Jul 2015 17:56:51 +0000 (23:26 +0530)
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)

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 a9044ae2422432dd47ecae5bfa4276a17fbec096..fc2143610160942207674909d5ca483375827dd6 100644 (file)
@@ -246,8 +246,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 70cb7981cb6d333e15a1a6c9d0e06db1481c81a9..db7c9f3a87a66ea25a7da495b0c8e416a6131f61 100644 (file)
@@ -3361,12 +3361,11 @@ void 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);
@@ -3374,11 +3373,7 @@ void Monitor::_ms_dispatch(Message *m)
   }
 
   dispatch(s, m, src_is_mon);
-
-  if (s) {
-    s->put();
-  }
-
+  s->put();
   return;
 }