]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
Merge PR #50503 into main
authorPatrick Donnelly <pdonnell@redhat.com>
Thu, 21 Sep 2023 15:51:31 +0000 (11:51 -0400)
committerPatrick Donnelly <pdonnell@redhat.com>
Thu, 21 Sep 2023 15:51:31 +0000 (11:51 -0400)
* refs/pull/50503/head:
mon: do not change pending if strategy is unchanged
mon/MonmapMonitor: do not propose on error in prepare_update
mon/MonmapMonitor: wait for commit before reply
mon: use wait_for_commit to reply
mon: add context list for commit wait
mon: remove unused method
test/mon: add commit benchmark script
mon/MonClient: provide config to target specific rank

Reviewed-by: Laura Flores <lflores@redhat.com>
Reviewed-by: Ramana Raja <rraja@redhat.com>
1  2 
src/common/options/global.yaml.in
src/mon/AuthMonitor.cc
src/mon/MDSMonitor.cc
src/mon/MgrMonitor.cc
src/mon/MonClient.cc
src/mon/OSDMonitor.cc

Simple merge
Simple merge
Simple merge
Simple merge
Simple merge
index 4e3f862b77eb3c3745757cb1f97d8807da54b115,3701ad9649ca037b725fef8b1c51f138dcaecfda..cb2e2f79dcb896a57ef93a0c2bc67da4ca8f40cd
@@@ -12549,10 -12553,10 +12549,10 @@@ bool OSDMonitor::prepare_command_impl(M
      if (err) {
        ss << "unable to parse 'weights' value '"
           << cmd_vartype_stringify(cmdmap.at("weights")) << "'";
 -      goto reply;
 +      goto reply_no_propose;
      }
      pending_inc.new_weight.insert(weights.begin(), weights.end());
-     wait_for_finished_proposal(
+     wait_for_commit(
        op,
        new Monitor::C_Command(mon, op, 0, rs, rdata, get_last_committed() + 1));
      return true;
      if (err == EEXIST) {
        // idempotent operation
        err = 0;
 -      goto reply;
 +      goto reply_no_propose;
      }
  
-     wait_for_finished_proposal(op,
+     wait_for_commit(op,
          new Monitor::C_Command(mon, op, 0, rs, rdata,
                                 get_last_committed() + 1));
      force_immediate_propose();
      if (err == -EAGAIN)
        goto wait;
      if (err < 0)
 -      goto reply;
 +      goto reply_no_propose;
  
      getline(ss, rs);
-     wait_for_finished_proposal(op, new Monitor::C_Command(mon, op, 0, rs,
+     wait_for_commit(op, new Monitor::C_Command(mon, op, 0, rs,
                                                   get_last_committed() + 1));
      return true;
    } else if (prefix == "osd tier add") {