From: Sage Weil Date: Wed, 10 Jul 2013 17:17:45 +0000 (-0700) Subject: mon: do not populate MMonCommand paxos version field X-Git-Tag: v0.67-rc1~120 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=5c8a5634633a0015aa1bb71ece6f2623bdc5daba;p=ceph.git mon: do not populate MMonCommand paxos version field The field is not used or useful since the monitor does not even look at it (in Monitor::handle_command()). Avoid populating it and the subsequent confusion for poor developers. Signed-off-by: Sage Weil --- diff --git a/src/messages/MMonCommand.h b/src/messages/MMonCommand.h index 2798280935e..2b79465cfbd 100644 --- a/src/messages/MMonCommand.h +++ b/src/messages/MMonCommand.h @@ -26,9 +26,10 @@ class MMonCommand : public PaxosServiceMessage { vector cmd; MMonCommand() : PaxosServiceMessage(MSG_MON_COMMAND, 0) {} - MMonCommand(const uuid_d &f, version_t v) : - PaxosServiceMessage(MSG_MON_COMMAND, v), - fsid(f) { } + MMonCommand(const uuid_d &f) + : PaxosServiceMessage(MSG_MON_COMMAND, 0), + fsid(f) + { } private: ~MMonCommand() {} diff --git a/src/mon/MDSMonitor.cc b/src/mon/MDSMonitor.cc index eafb1f04f10..80254660b49 100644 --- a/src/mon/MDSMonitor.cc +++ b/src/mon/MDSMonitor.cc @@ -638,7 +638,7 @@ bool MDSMonitor::preprocess_command(MMonCommand *m) i != mds_info.end(); ++i) { m->cmd = args_vec; - mon->send_command(i->second.get_inst(), m->cmd, get_last_committed()); + mon->send_command(i->second.get_inst(), m->cmd); r = 0; } if (r == -ENOENT) { @@ -652,7 +652,7 @@ bool MDSMonitor::preprocess_command(MMonCommand *m) if (!errno && who >= 0) { if (mdsmap.is_up(who)) { m->cmd = args_vec; - mon->send_command(mdsmap.get_inst(who), m->cmd, get_last_committed()); + mon->send_command(mdsmap.get_inst(who), m->cmd); r = 0; ss << "ok"; } else { diff --git a/src/mon/MonClient.cc b/src/mon/MonClient.cc index f47b5c0ef16..57f30063fa7 100644 --- a/src/mon/MonClient.cc +++ b/src/mon/MonClient.cc @@ -726,8 +726,6 @@ int MonClient::wait_auth_rotating(double timeout) void MonClient::_send_command(MonCommand *r) { - version_t last_seen_version = 0; - if (r->target_rank >= 0 && r->target_rank != monmap.get_rank(cur_mon)) { ldout(cct, 10) << "_send_command " << r->tid << " " << r->cmd @@ -759,7 +757,7 @@ void MonClient::_send_command(MonCommand *r) } ldout(cct, 10) << "_send_command " << r->tid << " " << r->cmd << dendl; - MMonCommand *m = new MMonCommand(monmap.fsid, last_seen_version); + MMonCommand *m = new MMonCommand(monmap.fsid); m->set_tid(r->tid); m->cmd = r->cmd; m->set_data(r->inbl); diff --git a/src/mon/Monitor.cc b/src/mon/Monitor.cc index a78ad741ede..aef9acc0a17 100644 --- a/src/mon/Monitor.cc +++ b/src/mon/Monitor.cc @@ -2440,10 +2440,10 @@ void Monitor::remove_all_sessions() } void Monitor::send_command(const entity_inst_t& inst, - const vector& com, version_t version) + const vector& com) { dout(10) << "send_command " << inst << "" << com << dendl; - MMonCommand *c = new MMonCommand(monmap->fsid, version); + MMonCommand *c = new MMonCommand(monmap->fsid); c->cmd = com; try_send_message(c, inst); } diff --git a/src/mon/Monitor.h b/src/mon/Monitor.h index cbc91529c21..863f4e5de38 100644 --- a/src/mon/Monitor.h +++ b/src/mon/Monitor.h @@ -634,7 +634,7 @@ public: void waitlist_or_zap_client(Message *m); void send_command(const entity_inst_t& inst, - const vector& com, version_t version); + const vector& com); public: struct C_Command : public Context { diff --git a/src/osdc/Objecter.cc b/src/osdc/Objecter.cc index 45b4573bbb1..a5a023cb33e 100644 --- a/src/osdc/Objecter.cc +++ b/src/osdc/Objecter.cc @@ -2361,7 +2361,7 @@ void Objecter::blacklist_self(bool set) ss << messenger->get_myaddr(); cmd.push_back("\"addr\":\"" + ss.str() + "\""); - MMonCommand *m = new MMonCommand(monc->get_fsid(), last_seen_osdmap_version); + MMonCommand *m = new MMonCommand(monc->get_fsid()); m->cmd = cmd; monc->send_mon_message(m);