]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
AsyncConnection: Remove useless inject delay in _stop
authorHaomai Wang <haomaiwang@gmail.com>
Wed, 11 Feb 2015 09:46:02 +0000 (17:46 +0800)
committerHaomai Wang <haomaiwang@gmail.com>
Wed, 11 Feb 2015 09:48:28 +0000 (17:48 +0800)
Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
src/msg/async/AsyncConnection.cc

index 662b16df01e7e15835cfed435db88adab9d73669..cfef223e03b5f41584593205bedd0037a5743306 100644 (file)
@@ -2084,6 +2084,9 @@ void AsyncConnection::was_session_reset()
 void AsyncConnection::_stop()
 {
   assert(lock.is_locked());
+  if (state == STATE_CLOSED)
+    return ;
+
   ldout(async_msgr->cct, 10) << __func__ << dendl;
   if (sd >= 0)
     center->delete_file_event(sd, EVENT_READABLE|EVENT_WRITABLE);
@@ -2091,15 +2094,6 @@ void AsyncConnection::_stop()
   discard_out_queue();
   async_msgr->unregister_conn(this);
 
-  if (async_msgr->cct->_conf->ms_inject_internal_delays) {
-    ldout(msgr->cct, 10) << __func__ << " sleep for "
-                         << async_msgr->cct->_conf->ms_inject_internal_delays
-                         << dendl;
-    utime_t t;
-    t.set_from_double(async_msgr->cct->_conf->ms_inject_internal_delays);
-    t.sleep();
-  }
-
   state = STATE_CLOSED;
   open_write = false;
   state_offset = 0;