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") {