From: Samuel Just Date: Mon, 25 Apr 2022 23:32:11 +0000 (-0700) Subject: crimson: rename WaitForActiveBlocker::on_active X-Git-Tag: v18.0.0~914^2~9 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=d41f37c8bd564eee547e8ab216ab50c929afb04e;p=ceph.git crimson: rename WaitForActiveBlocker::on_active We need to unblock this in cases other than on_active. Signed-off-by: Samuel Just --- diff --git a/src/crimson/osd/pg.cc b/src/crimson/osd/pg.cc index 4b0bdc0c8a93..5aded130e557 100644 --- a/src/crimson/osd/pg.cc +++ b/src/crimson/osd/pg.cc @@ -259,7 +259,7 @@ void PG::on_activate(interval_set) void PG::on_activate_complete() { - wait_for_active_blocker.on_active(); + wait_for_active_blocker.unblock(); if (peering_state.needs_recovery()) { logger().info("{}: requesting recovery", diff --git a/src/crimson/osd/pg_activation_blocker.cc b/src/crimson/osd/pg_activation_blocker.cc index 6230f9033888..48ffe3f84134 100644 --- a/src/crimson/osd/pg_activation_blocker.cc +++ b/src/crimson/osd/pg_activation_blocker.cc @@ -11,7 +11,7 @@ void PGActivationBlocker::dump_detail(Formatter *f) const f->dump_stream("pgid") << pg->get_pgid(); } -void PGActivationBlocker::on_active() +void PGActivationBlocker::unblock() { p.set_value(); p = {}; diff --git a/src/crimson/osd/pg_activation_blocker.h b/src/crimson/osd/pg_activation_blocker.h index 38b64203a89f..fd07d9b41410 100644 --- a/src/crimson/osd/pg_activation_blocker.h +++ b/src/crimson/osd/pg_activation_blocker.h @@ -26,7 +26,7 @@ public: static constexpr const char *type_name = "PGActivationBlocker"; PGActivationBlocker(PG *pg) : pg(pg) {} - void on_active(); + void unblock(); seastar::future<> wait(PGActivationBlocker::BlockingEvent::TriggerI&&); seastar::future<> stop(); };