ctx->user_at_version = obc->obs.oi.user_version;
dout(30) << __func__ << " user_at_version " << ctx->user_at_version << dendl;
- // note my stats
- utime_t now = ceph_clock_now(cct);
-
if (op->may_read()) {
dout(10) << " taking ondisk_read_lock" << dendl;
obc->ondisk_read_lock();
repop->src_obc.swap(src_obc); // and src_obc.
- issue_repop(repop, now);
+ issue_repop(repop);
eval_repop(repop);
repop->put();
}
}
-void ReplicatedPG::issue_repop(RepGather *repop, utime_t now)
+void ReplicatedPG::issue_repop(RepGather *repop)
{
OpContext *ctx = repop->ctx;
const hobject_t& soid = ctx->obs->oi.soid;
void ReplicatedPG::simple_repop_submit(RepGather *repop)
{
dout(20) << __func__ << " " << repop << dendl;
- issue_repop(repop, repop->ctx->mtime);
+ issue_repop(repop);
eval_repop(repop);
repop->put();
}
void repop_all_applied(RepGather *repop);
void repop_all_committed(RepGather *repop);
void eval_repop(RepGather*);
- void issue_repop(RepGather *repop, utime_t now);
+ void issue_repop(RepGather *repop);
RepGather *new_repop(OpContext *ctx, ObjectContextRef obc, ceph_tid_t rep_tid);
void remove_repop(RepGather *repop);