onack, oncommit,
info->pobjver);
o->snapid = info->snap;
- o->resend_on_any_change = true;
if (info->session) {
int r = recalc_op_target(o);
}
osdmap->pg_to_acting_osds(pgid, acting);
- if (op->pgid != pgid || is_pg_changed(op->acting, acting,
- (op->resend_on_any_change ||
- op->used_replica))) {
+ if (op->pgid != pgid || is_pg_changed(op->acting, acting, op->used_replica)) {
op->pgid = pgid;
op->acting = acting;
ldout(cct, 10) << "recalc_op_target tid " << op->tid
pg_t pgid;
vector<int> acting;
bool used_replica;
- bool resend_on_any_change;
Connection *con; // for rx buffer only
int f, Context *ac, Context *co, eversion_t *ov) :
session(NULL), session_item(this), incarnation(0),
oid(o), oloc(ol),
- used_replica(false), resend_on_any_change(false), con(NULL),
+ used_replica(false), con(NULL),
snapid(CEPH_NOSNAP),
outbl(NULL),
flags(f), priority(0), onack(ac), oncommit(co),