From 3484b844030eb1d1f714377561e3bac73d6b8208 Mon Sep 17 00:00:00 2001 From: Greg Farnum Date: Mon, 19 Apr 2010 14:22:23 -0700 Subject: [PATCH] mds: Add new Connection-based send_message_client that uses inc_push_seq too --- src/mds/MDS.cc | 9 ++++++++- src/mds/MDS.h | 1 + 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/src/mds/MDS.cc b/src/mds/MDS.cc index 7deac9382d622..bcaaf0ad853fc 100644 --- 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 8264790e58782..12a2821731587 100644 --- 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 -- 2.39.5