From 92e6c423d8d2c1d81d0a935061f91df6120cfefc Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Tue, 22 Sep 2009 15:11:25 -0700
Subject: [PATCH] uclient: pass reset events to objecter, with proper locking

---
 src/client/Client.cc | 32 ++++----------------------------
 1 file changed, 4 insertions(+), 28 deletions(-)

diff --git a/src/client/Client.cc b/src/client/Client.cc
index b51995dce6b6e..cf09afafb3cc1 100644
--- a/src/client/Client.cc
+++ b/src/client/Client.cc
@@ -5794,38 +5794,14 @@ void Client::ms_handle_failure(Connection *con, Message *m, const entity_addr_t&
 bool Client::ms_handle_reset(Connection *con, const entity_addr_t& addr) 
 {
   dout(0) << "ms_handle_reset on " << addr << dendl;
+  Mutex::Locker l(client_lock);
+  objecter->ms_handle_reset(addr);
   return false;
 }
 
-
 void Client::ms_handle_remote_reset(Connection *con, const entity_addr_t& addr) 
 {
   dout(0) << "ms_handle_remote_reset on " << addr << dendl;
-#if 0
-  if (last.is_mds()) {
-    int mds = last.num();
-    dout(0) << "ms_handle_remote_reset on " << last << ", " << mds_sessions[mds].num_caps
-	    << " caps, kicking requests" << dendl;
-
-    mds_sessions.erase(mds); // "kill" session
-
-    // reopen if caps
-    if (mds_sessions[mds].num_caps > 0) {
-      waiting_for_session[mds].size();  // make sure entry exists
-      messenger->send_message(new MClientSession(CEPH_SESSION_REQUEST_OPEN),
-			      mdsmap->get_inst(mds));
-      
-      /*
-       * FIXME: actually, we need to do a reconnect or similar to reestablish
-       * our caps (where possible)
-       */
-      dout(0) << "FIXME: client needs to reconnect to restablish existing caps ****" << dendl;
-    }
-
-    // or requests
-    //kick_requests(mds, false);
-  }
-  else 
-    objecter->ms_handle_remote_reset(addr, last);
-#endif
+  Mutex::Locker l(client_lock);
+  objecter->ms_handle_remote_reset(addr);
 }
-- 
2.39.5