}
}
-struct C_OnPushCommit : public Context {
- ReplicatedPG *pg;
- OpRequestRef op;
- C_OnPushCommit(ReplicatedPG *pg, OpRequestRef op) : pg(pg), op(op) {}
- void finish(int) {
- op->mark_event("committed");
- log_subop_stats(pg->osd->logger, op, l_osd_sop_push);
- }
-};
-
void ReplicatedBackend::handle_push(
pg_shard_t from, PushOp &pop, PushReplyOp *response,
ObjectStore::Transaction *t)
return true;
}
- friend struct C_OnPushCommit;
-
// projected object info
SharedLRU<hobject_t, ObjectContext> object_contexts;
// map from oid.snapdir() to SnapSetContext *