PG::interruptible_future<> PG::handle_rep_op(Ref<MOSDRepOp> req)
{
- logger().debug("{}: {}", __func__, *req);
+ LOG_PREFIX(PG::handle_rep_op);
+ DEBUGDPP("{}", *this, *req);
if (can_discard_replica_op(*req)) {
return seastar::now();
}
!txn.empty(),
txn,
false);
- logger().debug("PG::handle_rep_op: do_transaction...");
+ DEBUGDPP("{} do_transaction", *this, *req);
return interruptor::make_interruptible(shard_services.get_store().do_transaction(
coll_ref, std::move(txn))).then_interruptible(
[req, lcod=peering_state.get_info().last_complete, this] {