From: Sage Weil Date: Tue, 9 Sep 2014 23:07:13 +0000 (-0700) Subject: osd: drop dead shutdown message handler X-Git-Tag: v0.86~31^2~4 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=5d37850cf7b4e5a56d8342c3c98679d54b2a8701;p=ceph.git osd: drop dead shutdown message handler There is no code anywhere in the code base that generates a MSG_SHUTDOWN. Kill this. The get_priv() logic here looks pretty dodgey anyway. Signed-off-by: Sage Weil Reviewed-by: Greg Farnum --- diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc index 56b085175879..c230651fb4f6 100644 --- a/src/osd/OSD.cc +++ b/src/osd/OSD.cc @@ -5717,7 +5717,8 @@ void OSD::dispatch_op(OpRequestRef op) } } -bool OSD::dispatch_op_fast(OpRequestRef& op, OSDMapRef& osdmap) { +bool OSD::dispatch_op_fast(OpRequestRef& op, OSDMapRef& osdmap) +{ if (is_stopping()) { // we're shutting down, so drop the op return true; @@ -5786,7 +5787,6 @@ void OSD::_dispatch(Message *m) { assert(osd_lock.is_locked()); dout(20) << "_dispatch " << m << " " << *m << dendl; - Session *session = NULL; logger->set(l_osd_buf, buffer::get_total_alloc()); @@ -5806,19 +5806,6 @@ void OSD::_dispatch(Message *m) break; // osd - case CEPH_MSG_SHUTDOWN: - session = static_cast(m->get_connection()->get_priv()); - if (!session || - session->entity_name.is_mon() || - session->entity_name.is_osd()) - shutdown(); - else dout(0) << "shutdown message from connection with insufficient privs!" - << m->get_connection() << dendl; - m->put(); - if (session) - session->put(); - break; - case MSG_PGSTATSACK: handle_pg_stats_ack(static_cast(m)); break;