From 34a57c154c8261c0f0d999ec31b59e28724c68e5 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Thu, 19 Nov 2009 09:28:02 -0800
Subject: [PATCH] mds: do not send MMDSMap to ourselves

---
 src/mds/MDS.cc | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/mds/MDS.cc b/src/mds/MDS.cc
index 5806ef7ca120f..23425fcb1c856 100644
--- a/src/mds/MDS.cc
+++ b/src/mds/MDS.cc
@@ -302,7 +302,7 @@ MDSTableServer *MDS::get_table_server(int t)
 void MDS::send_message_mds(Message *m, int mds)
 {
   // send mdsmap first?
-  if (peer_mdsmap_epoch[mds] < mdsmap->get_epoch()) {
+  if (mds != whoami && peer_mdsmap_epoch[mds] < mdsmap->get_epoch()) {
     messenger->send_message(new MMDSMap(monc->get_fsid(), mdsmap), 
 			    mdsmap->get_inst(mds));
     peer_mdsmap_epoch[mds] = mdsmap->get_epoch();
@@ -314,6 +314,8 @@ void MDS::send_message_mds(Message *m, int mds)
 
 void MDS::forward_message_mds(Message *m, int mds)
 {
+  assert(mds != whoami);
+
   // client request?
   if (m->get_type() == CEPH_MSG_CLIENT_REQUEST &&
       ((MClientRequest*)m)->get_orig_source().is_client()) {
-- 
2.39.5