if ((get_parent()->pgb_is_primary())) {
assert(recovery_ops.count(op.soid));
assert(recovery_ops[op.soid].obc);
- object_stat_sum_t stats;
- stats.num_objects_recovered = 1;
- stats.num_bytes_recovered = recovery_ops[op.soid].obc->obs.oi.size;
get_parent()->on_local_recover(
op.soid,
- stats,
op.recovery_info,
recovery_ops[op.soid].obc,
- m->t);
+ &m->t);
} else {
get_parent()->on_local_recover(
op.soid,
- object_stat_sum_t(),
op.recovery_info,
ObjectContextRef(),
- m->t);
+ &m->t);
}
}
m->push_replies[get_parent()->primary_shard()].push_back(PushReplyOp());