mds: Add new Connection-based send_message_client that uses inc_push_seq too

diff --git a/src/mds/MDS.cc b/src/mds/MDS.cc
index 7deac9382d6225bb016b554b6d3c23729fa81b6b..bcaaf0ad853fc71a2d459d9dfee51b6ad68d6b66 100644 (file)
--- a/src/mds/MDS.cc
+++ b/src/mds/MDS.cc
@@ -387,7 +387,14 @@ void MDS::send_message_client(Message *m, entity_inst_t clientinst)
   messenger->send_message(m, clientinst);
 }
 
-
+void MDS::send_message_client(Message *m, Connection *con)
+{
+  Session *session = (Session *)con->get_priv();
+  version_t seq = session->inc_push_seq();
+  dout(10) << "send_message_client " << session->inst.name << " seq "
+          << seq << " " << *m << dendl;
+  messenger->send_message(m, con);
+}
 
 int MDS::init()
 {

diff --git a/src/mds/MDS.h b/src/mds/MDS.h
index 8264790e58782e919c11a14b3f6f7d11b1a2454a..12a28217315870db5e5684b636573c900c67145d 100644 (file)
--- a/src/mds/MDS.h
+++ b/src/mds/MDS.h
@@ -333,6 +333,7 @@ class MDS : public Dispatcher {
 
   void send_message_client(Message *m, client_t client);
   void send_message_client(Message *m, entity_inst_t clientinst);
+  void send_message_client(Message *m, Connection *con);
   void send_message(Message *m, Connection *c);
 
   // start up, shutdown