From 81872b6be0b8a441ff72e627476d4a44ca01e6e0 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Thu, 30 Jul 2009 13:37:52 -0700
Subject: [PATCH] mds: process session msgs during clientreplay

---
 src/mds/MDS.cc    | 2 +-
 src/mds/Server.cc | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/mds/MDS.cc b/src/mds/MDS.cc
index d8063fe65a960..e5e4d940a95e7 100644
--- a/src/mds/MDS.cc
+++ b/src/mds/MDS.cc
@@ -447,7 +447,7 @@ void MDS::tick()
   }
 
   // ...
-  if (is_active() || is_stopping()) {
+  if (is_clientreplay() || is_active() || is_stopping()) {
     locker->scatter_tick();
     server->find_idle_sessions();
   }
diff --git a/src/mds/Server.cc b/src/mds/Server.cc
index b3da592f98358..36e389a39a5e8 100644
--- a/src/mds/Server.cc
+++ b/src/mds/Server.cc
@@ -108,8 +108,9 @@ void Server::dispatch(Message *m)
       mds->enqueue_replay(new C_MDS_RetryMessage(mds, m));
       return;
     } else if (mds->is_clientreplay() &&
-	       m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
-	       ((MClientRequest*)m)->is_replay()) {
+	       (m->get_type() == CEPH_MSG_CLIENT_SESSION ||
+		(m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
+		 ((MClientRequest*)m)->is_replay()))) {
       // replaying!
     } else {
       dout(3) << "not active yet, waiting" << dendl;
-- 
2.39.5