From: Haomai Wang <haomaiwang@gmail.com>
Date: Wed, 8 Oct 2014 03:57:49 +0000 (+0800)
Subject: AsyncConnection: Fix mark_down problem when calling send_message
X-Git-Tag: v0.88~37^2~4^2~5
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=79a12de849800cf40f47d78537b42aaf3bcc26ea;p=ceph.git

AsyncConnection: Fix mark_down problem when calling send_message

Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
---

diff --git a/src/msg/AsyncConnection.cc b/src/msg/AsyncConnection.cc
index 8c9b79959ee..31a99488c42 100644
--- a/src/msg/AsyncConnection.cc
+++ b/src/msg/AsyncConnection.cc
@@ -83,16 +83,6 @@ class C_handle_dispatch : public EventCallback {
   }
 };
 
-class C_handle_stop : public EventCallback {
-  AsyncConnectionRef conn;
-
- public:
-  C_handle_stop(AsyncConnection *c): conn(c) {}
-  void do_request(int id) {
-    conn->stop();
-  }
-};
-
 
 static void alloc_aligned_buffer(bufferlist& data, unsigned len, unsigned off)
 {
@@ -731,6 +721,7 @@ void AsyncConnection::process()
 
       case STATE_CLOSED:
         {
+          center->delete_file_event(sd, EVENT_READABLE);
           ldout(async_msgr->cct, 20) << __func__ << " socket closed" << dendl;
           break;
         }
@@ -806,8 +797,10 @@ int AsyncConnection::_process_connection()
 
         global_seq = async_msgr->get_global_seq();
         // close old socket.  this is safe because we stopped the reader thread above.
-        if (sd >= 0)
+        if (sd >= 0) {
+          center->delete_file_event(sd, EVENT_READABLE|EVENT_WRITABLE);
           ::close(sd);
+        }
 
         sd = net.connect(get_peer_addr());
         if (sd < 0) {
@@ -1800,7 +1793,7 @@ void AsyncConnection::was_session_reset()
   discard_out_queue();
   outcoming_bl.clear();
 
-  center->create_time_event(0, remote_reset_handler);
+  center->dispatch_event_external(remote_reset_handler);
 
   if (randomize_out_seq()) {
     lsubdout(async_msgr->cct,ms,15) << __func__ << " Could not get random bytes to set seq number for session reset; set seq number to " << out_seq << dendl;
@@ -1811,29 +1804,15 @@ void AsyncConnection::was_session_reset()
   in_seq_acked = 0;
 }
 
-void AsyncConnection::mark_down()
-{
-  Mutex::Locker l(lock);
-  state = STATE_CLOSED;
-  center->dispatch_event_external(EventCallbackRef(new C_handle_stop(this)));
-}
-
-// Who call "_stop():
-// 1. receive STATE_OPEN_TAG_CLOSE
-// 2. fault when policy.lossy
-// 3. mark_down
-// 4. caller from Messenger
 void AsyncConnection::_stop()
 {
   ldout(async_msgr->cct, 10) << __func__ << dendl;
-  center->create_time_event(0, reset_handler);
+  center->dispatch_event_external(reset_handler);
   shutdown_socket();
   discard_out_queue();
   outcoming_bl.clear();
   if (policy.lossy)
     was_session_reset();
-  if (sd >= 0)
-    center->delete_file_event(sd, EVENT_READABLE|EVENT_WRITABLE);
   open_write = false;
   state = STATE_CLOSED;
 }
diff --git a/src/msg/AsyncConnection.h b/src/msg/AsyncConnection.h
index 2a116b5b92e..3c025ff92ba 100644
--- a/src/msg/AsyncConnection.h
+++ b/src/msg/AsyncConnection.h
@@ -103,7 +103,10 @@ class AsyncConnection : public Connection {
   int send_message(Message *m);
 
   void send_keepalive();
-  void mark_down();
+  void mark_down() {
+    Mutex::Locker l(lock);
+    _stop();
+  }
   void mark_disposable() {
     Mutex::Locker l(lock);
     policy.lossy = true;
@@ -239,10 +242,6 @@ class AsyncConnection : public Connection {
   // used by eventcallback
   void handle_write();
   void process();
-  void stop() {
-    Mutex::Locker l(lock);
-    _stop();
-  }
 }; /* AsyncConnection */
 
 typedef boost::intrusive_ptr<AsyncConnection> AsyncConnectionRef;