From: Samuel Just Date: Fri, 10 Feb 2023 05:10:30 +0000 (-0800) Subject: osd/scrubber/scrub_machine*: s/ActiveReplica/ReplicaBuildingMap/g X-Git-Tag: v19.0.0~1389^2~5 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=2176dfe32c512a68b77a9cdbec66bfdab4b2afaf;p=ceph.git osd/scrubber/scrub_machine*: s/ActiveReplica/ReplicaBuildingMap/g Signed-off-by: Samuel Just --- diff --git a/src/osd/scrubber/scrub_machine.cc b/src/osd/scrubber/scrub_machine.cc index 93164778c7c4..51857d2f1c55 100644 --- a/src/osd/scrubber/scrub_machine.cc +++ b/src/osd/scrubber/scrub_machine.cc @@ -629,7 +629,7 @@ sc::result ReplicaWaitUpdates::react(const ReplicaPushesUpd&) if (scrbr->pending_active_pushes() == 0) { // done waiting - return transit(); + return transit(); } return discard_event(); @@ -644,23 +644,23 @@ sc::result ReplicaWaitUpdates::react(const FullReset&) return transit(); } -// ----------------------- ActiveReplica ----------------------------------- +// ----------------------- ReplicaBuildingMap ----------------------------------- -ActiveReplica::ActiveReplica(my_context ctx) +ReplicaBuildingMap::ReplicaBuildingMap(my_context ctx) : my_base(ctx) - , NamedSimply(context().m_scrbr, "ActiveReplica") + , NamedSimply(context().m_scrbr, "ReplicaBuildingMap") { DECLARE_LOCALS; // 'scrbr' & 'pg_id' aliases - dout(10) << "-- state -->> ActiveReplica" << dendl; + dout(10) << "-- state -->> ReplicaBuildingMap" << dendl; // and as we might have skipped ReplicaWaitUpdates: scrbr->on_replica_init(); post_event(SchedReplica{}); } -sc::result ActiveReplica::react(const SchedReplica&) +sc::result ReplicaBuildingMap::react(const SchedReplica&) { DECLARE_LOCALS; // 'scrbr' & 'pg_id' aliases - dout(10) << "ActiveReplica::react(const SchedReplica&). is_preemptable? " + dout(10) << "ReplicaBuildingMap::react(const SchedReplica&). is_preemptable? " << scrbr->get_preemptor().is_preemptable() << dendl; if (scrbr->get_preemptor().was_preempted()) { @@ -683,9 +683,9 @@ sc::result ActiveReplica::react(const SchedReplica&) /** * the event poster is handling the scrubber reset */ -sc::result ActiveReplica::react(const FullReset&) +sc::result ReplicaBuildingMap::react(const FullReset&) { - dout(10) << "ActiveReplica::react(const FullReset&)" << dendl; + dout(10) << "ReplicaBuildingMap::react(const FullReset&)" << dendl; return transit(); } diff --git a/src/osd/scrubber/scrub_machine.h b/src/osd/scrubber/scrub_machine.h index a346f09b0e15..45af1dc8d0f6 100644 --- a/src/osd/scrubber/scrub_machine.h +++ b/src/osd/scrubber/scrub_machine.h @@ -145,7 +145,7 @@ struct ReservingReplicas; ///< securing scrub resources from replicas' OSDs struct ActiveScrubbing; ///< the active state for a Primary. A sub-machine. struct ReplicaWaitUpdates; ///< an active state for a replica. Waiting for all ///< active operations to finish. -struct ActiveReplica; ///< an active state for a replica. +struct ReplicaBuildingMap; ///< an active state for a replica. class ScrubMachine : public sc::state_machine { @@ -311,7 +311,7 @@ struct NotActive : sc::state, NamedSimply { // a scrubbing that was initiated at recovery completion: sc::custom_reaction, sc::transition, - sc::transition>; + sc::transition>; sc::result react(const StartScrub&); sc::result react(const AfterRepairScrub&); }; @@ -528,8 +528,8 @@ struct ReplicaWaitUpdates : sc::state, }; -struct ActiveReplica : sc::state, NamedSimply { - explicit ActiveReplica(my_context ctx); +struct ReplicaBuildingMap : sc::state, NamedSimply { + explicit ReplicaBuildingMap(my_context ctx); using reactions = mpl::list, sc::custom_reaction>;