]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mon: Monitor: add is_noforward() helper to MonCommand
authorJoao Eduardo Luis <joao@suse.de>
Fri, 8 May 2015 18:05:00 +0000 (19:05 +0100)
committerJoao Eduardo Luis <joao@suse.de>
Thu, 16 Jul 2015 11:20:02 +0000 (12:20 +0100)
Signed-off-by: Joao Eduardo Luis <joao@suse.de>
src/mon/Monitor.cc
src/mon/Monitor.h

index 298624e6228b588244ae528b50d24189bc8914f2..9d6f1079f91b7777fa1344d9ff2e21c03802894e 100644 (file)
@@ -2611,7 +2611,7 @@ void Monitor::handle_command(MMonCommand *m)
                                               ARRAY_SIZE(mon_commands));
   if (!is_leader()) {
     if (!mon_cmd) {
-      if (leader_cmd->has_flag(MonCommand::FLAG_NOFORWARD)) {
+      if (leader_cmd->is_noforward()) {
        reply_command(m, -EINVAL,
                      "command not locally supported and not allowed to forward",
                      0);
@@ -2622,7 +2622,7 @@ void Monitor::handle_command(MMonCommand *m)
       forward_request_leader(m);
       return;
     } else if (!mon_cmd->is_compat(leader_cmd)) {
-      if (mon_cmd->has_flag(MonCommand::FLAG_NOFORWARD)) {
+      if (mon_cmd->is_noforward()) {
        reply_command(m, -EINVAL,
                      "command not compatible with leader and not allowed to forward",
                      0);
@@ -2642,7 +2642,7 @@ void Monitor::handle_command(MMonCommand *m)
     return;
   }
 
-  if (session->proxy_con && mon_cmd->has_flag(MonCommand::FLAG_NOFORWARD)) {
+  if (session->proxy_con && mon_cmd->is_noforward()) {
     dout(10) << "Got forward for noforward command " << m << dendl;
     reply_command(m, -EINVAL, "forward for noforward command", rdata, 0);
     return;
index 585e8f3f1bf866f7e1bef88dc76e38f10474006c..879bdc00f403367f1cebec599d9ace6198b167cb 100644 (file)
@@ -979,6 +979,10 @@ struct MonCommand {
        availability == o->availability;
   }
 
+  bool is_noforward() const {
+    return has_flag(MonCommand::FLAG_NOFORWARD);
+  }
+
   bool is_obsolete() const {
     return has_flag(MonCommand::FLAG_OBSOLETE);
   }