get_parent()->on_failed_pull(fl, hoid, v);
}
-struct RecoveryMessages {
- std::map<hobject_t, ECCommon::read_request_t> recovery_reads;
-
- void recovery_read(const hobject_t &hoid,
- const ECCommon::read_request_t &read_request) {
- ceph_assert(!recovery_reads.count(hoid));
- recovery_reads.insert(std::make_pair(hoid, read_request));
- }
-
- std::map<pg_shard_t, std::vector<PushOp>> pushes;
- std::map<pg_shard_t, std::vector<PushReplyOp>> push_replies;
- ceph::os::Transaction t;
-};
-
void ECBackend::handle_recovery_push(
const PushOp &op,
RecoveryMessages *m,
};
+struct RecoveryMessages {
+ std::map<hobject_t, ECCommon::read_request_t> recovery_reads;
+
+ void recovery_read(const hobject_t &hoid,
+ const ECCommon::read_request_t &read_request) {
+ ceph_assert(!recovery_reads.count(hoid));
+ recovery_reads.insert(std::make_pair(hoid, read_request));
+ }
+
+ std::map<pg_shard_t, std::vector<PushOp>> pushes;
+ std::map<pg_shard_t, std::vector<PushReplyOp>> push_replies;
+ ceph::os::Transaction t;
+};
+
+template <>
+struct fmt::formatter<ECCommon::read_request_t> : fmt::ostream_formatter {};
+
+template <>
+struct fmt::formatter<ECCommon::read_result_t> : fmt::ostream_formatter {};
+
+template <>
+struct fmt::formatter<ECCommon::ReadOp> : fmt::ostream_formatter {};
+
+template <>
+struct fmt::formatter<ECCommon::RMWPipeline::Op> : fmt::ostream_formatter {};
+
+
template <class F, class G>
void ECCommon::ReadPipeline::check_recovery_sources(
const OSDMapRef &osdmap,
on_schedule_recovery(op);
}
}
-
-template <>
-struct fmt::formatter<ECCommon::read_request_t> : fmt::ostream_formatter {};
-
-template <>
-struct fmt::formatter<ECCommon::read_result_t> : fmt::ostream_formatter {};
-
-template <>
-struct fmt::formatter<ECCommon::ReadOp> : fmt::ostream_formatter {};
-
-template <>
-struct fmt::formatter<ECCommon::RMWPipeline::Op> : fmt::ostream_formatter {};