delete t;
}
-void ReplicatedPG::recover_primary_got(hobject_t oid, eversion_t v)
+void ReplicatedPG::recover_got(hobject_t oid, eversion_t v)
{
if (missing.is_missing(oid, v)) {
dout(10) << "got missing " << oid << " v " << v << dendl;
}
}
- recover_primary_got(soid, v);
+ recover_got(soid, v);
// update pg
write_info(*t);
obc->obs.oi.encode(b2);
t->setattr(coll, soid, OI_ATTR, b2);
- recover_primary_got(soid, latest->version);
+ recover_got(soid, latest->version);
osd->store->queue_transaction(&osr, t,
new C_OSD_AppliedPushedObject(this, t, obc),
void sub_op_modify_reply(MOSDSubOpReply *reply);
void _applied_pushed_object(ObjectStore::Transaction *t, ObjectContext *obc);
void _committed_pushed_object(MOSDSubOp *op, epoch_t same_since, eversion_t lc);
- void recover_primary_got(hobject_t oid, eversion_t v);
+ void recover_got(hobject_t oid, eversion_t v);
void sub_op_push(MOSDSubOp *op);
void _failed_push(MOSDSubOp *op);
void sub_op_push_reply(MOSDSubOpReply *reply);