});
}
-osd_op_params_t&& PG::fill_op_params_bump_pg_version(
- osd_op_params_t&& osd_op_p,
+void PG::fill_op_params_bump_pg_version(
+ osd_op_params_t& osd_op_p,
Ref<MOSDOp> m,
const bool user_modify)
{
if (user_modify) {
osd_op_p.user_at_version = osd_op_p.at_version.version;
}
- return std::move(osd_op_p);
}
seastar::future<Ref<MOSDOpReply>> PG::handle_failed_op(
"do_osd_ops: {} - object {} submitting txn",
*m,
obc->obs.oi.soid);
- auto filled_osd_op_p = fill_op_params_bump_pg_version(
- std::move(osd_op_p),
- std::move(m),
- user_modify);
+ fill_op_params_bump_pg_version(osd_op_p, std::move(m), user_modify);
return submit_transaction(
op_info,
- filled_osd_op_p.req->ops,
+ osd_op_p.req->ops,
std::move(obc),
std::move(txn),
- std::move(filled_osd_op_p));
+ std::move(osd_op_p));
});
}).safe_then([this, m, obc, rvec = op_info.allows_returnvec()] {
// TODO: should stop at the first op which returns a negative retval,
void do_peering_event(
const boost::statechart::event_base &evt,
PeeringCtx &rctx);
- osd_op_params_t&& fill_op_params_bump_pg_version(
- osd_op_params_t&& osd_op_p,
+ void fill_op_params_bump_pg_version(
+ osd_op_params_t& osd_op_p,
Ref<MOSDOp> m,
const bool user_modify);
seastar::future<Ref<MOSDOpReply>> handle_failed_op(