We need to unblock this in cases other than on_active.
Signed-off-by: Samuel Just <sjust@redhat.com>
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",
f->dump_stream("pgid") << pg->get_pgid();
}
-void PGActivationBlocker::on_active()
+void PGActivationBlocker::unblock()
{
p.set_value();
p = {};
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();
};