}
}
+namespace crimson::osd {
+
ECRecoveryBackend::ECRecoveryBackend(
crimson::osd::PG& pg,
crimson::osd::ShardServices& shard_services,
crimson::os::CollectionRef coll,
ECBackend* backend)
-: ::RecoveryBackend(pg, shard_services, coll, backend),
+: ::crimson::osd::RecoveryBackend(pg, shard_services, coll, backend),
::ECCommon::RecoveryBackend(
shard_services.get_cct(),
coll->get_cid(),
std::map<int, MOSDPGPushReply*> replies)
{
std::ignore = shard_services.get_store().do_transaction(
- ::RecoveryBackend::coll, std::move(txn)
+ crimson::osd::RecoveryBackend::coll, std::move(txn)
).then([replies=std::move(replies), this]() mutable {
if (auto msgit = replies.find(get_parent()->whoami_shard().osd);
msgit != std::end(replies)) {
boost::static_pointer_cast<MOSDPGPushReply>(m));
default:
// delegate backfill messages to parent class
- return handle_backfill_op(std::move(m), conn);
+ return ::crimson::osd::RecoveryBackend::handle_recovery_op(std::move(m), conn);
}
}
+
+} // namespace crimson::osd
#include "osd/recovery_types.h"
#include "osd/osd_types.h"
-namespace crimson::osd{
- class PG;
-}
-
class PGBackend;
-class ECRecoveryBackend : public RecoveryBackend,
+namespace crimson::osd {
+class PG;
+
+class ECRecoveryBackend : public crimson::osd::RecoveryBackend,
private ECCommon::RecoveryBackend {
public:
ECRecoveryBackend(crimson::osd::PG& pg,
interruptible_future<> handle_push_reply(
Ref<MOSDPGPushReply> m);
};
+
+} // namespace crimson::osd