}
in_progress_client_reads.clear();
shard_to_read_map.clear();
- clear_state();
+ clear_recovery_state();
}
-void ECBackend::clear_state()
+void ECBackend::clear_recovery_state()
{
recovery_ops.clear();
}
void check_recovery_sources(const OSDMapRef osdmap);
void on_change();
- void clear_state();
+ void clear_recovery_state();
void on_flushed();
* won't be called after on_change()
*/
virtual void on_change() = 0;
- virtual void clear_state() = 0;
+ virtual void clear_recovery_state() = 0;
virtual void on_flushed() = 0;
return false;
}
-void ReplicatedBackend::clear_state()
+void ReplicatedBackend::clear_recovery_state()
{
// clear pushing/pulling maps
pushing.clear();
if (i->second.on_applied)
delete i->second.on_applied;
}
- clear_state();
+ clear_recovery_state();
}
void ReplicatedBackend::on_flushed()
);
void on_change();
- void clear_state();
+ void clear_recovery_state();
void on_flushed();
class RPCRecPred : public IsRecoverablePredicate {
assert(backfills_in_flight.empty());
pending_backfill_updates.clear();
recovering.clear();
- pgbackend->clear_state();
+ pgbackend->clear_recovery_state();
}
void ReplicatedPG::cancel_pull(const hobject_t &soid)