{
OpContext *ctx = repop->ctx;
const hobject_t& soid = ctx->obs->oi.soid;
- MOSDOp *m = (MOSDOp *)ctx->op->request;
dout(7) << "issue_repop rep_tid " << repop->rep_tid
<< " o " << soid
false, acks_wanted,
get_osdmap()->get_epoch(),
repop->rep_tid, repop->ctx->at_version);
-
- if (m && m->get_flags() & CEPH_OSD_FLAG_PARALLELEXEC) {
+ if (ctx->op &&
+ (((MOSDOp *)ctx->op->request)->get_flags() & CEPH_OSD_FLAG_PARALLELEXEC)) {
// replicate original op for parallel execution on replica
assert(0 == "broken implementation, do not use");
wr->oloc = repop->ctx->obs->oi.oloc;