As follows:
for (auto i = callbacks_for_degraded_object.begin(); i != callbacks_for_degraded_object.end();) {
finish_degraded_object((i++)->first);
}
void PrimaryLogPG::finish_degraded_object(const hobject_t oid)
{
if (callbacks_for_degraded_object.count(oid)) {
contexts.swap(callbacks_for_degraded_object[oid]);
callbacks_for_degraded_object.erase(oid); // Release
}
map<hobject_t, snapid_t>::iterator i = objects_blocked_on_degraded_snap.find(
oid.get_head()); // Access
...
}
Fixes: https://tracker.ceph.com/issues/41250
Signed-off-by: Tao Ning <ningtao@sangfor.com.cn>
ceph_assert(r == 0);
}
-void PrimaryLogPG::finish_degraded_object(const hobject_t& oid)
+void PrimaryLogPG::finish_degraded_object(const hobject_t oid)
{
dout(10) << __func__ << " " << oid << dendl;
if (callbacks_for_degraded_object.count(oid)) {
PGBackend::RecoveryHandle *h,
bool *work_started);
- void finish_degraded_object(const hobject_t& oid);
+ void finish_degraded_object(const hobject_t oid);
// Cancels/resets pulls from peer
void check_recovery_sources(const OSDMapRef& map) override ;