crimson::os::CollectionRef coll;
PGBackend* backend;
- struct PullInfo {
+ struct pull_info_t {
pg_shard_t from;
hobject_t soid;
ObjectRecoveryProgress recovery_progress;
static constexpr const char* type_name = "WaitForObjectRecovery";
crimson::osd::ObjectContextRef obc;
- std::optional<PullInfo> pi;
+ std::optional<pull_info_t> pi;
std::map<pg_shard_t, PushInfo> pushing;
seastar::future<> wait_for_readable() {
}
PullOp po;
auto& recovery_waiter = get_recovering(soid);
- recovery_waiter.pi = std::make_optional<RecoveryBackend::PullInfo>();
+ recovery_waiter.pi = std::make_optional<RecoveryBackend::pull_info_t>();
auto& pi = *recovery_waiter.pi;
prepare_pull(po, pi, soid, need);
auto msg = crimson::make_message<MOSDPGPull>();
});
}
-void ReplicatedRecoveryBackend::prepare_pull(PullOp& po, PullInfo& pi,
+void ReplicatedRecoveryBackend::prepare_pull(PullOp& po, pull_info_t& pi,
const hobject_t& soid,
eversion_t need) {
logger().debug("{}: {}, {}", __func__, soid, need);