assert(!actingbackfill.empty());
assert(blocked_by.empty());
- // info.last_epoch_started is set during activate()
- info.history.last_epoch_started = info.last_epoch_started;
- state_clear(PG_STATE_CREATING);
-
- share_pg_info();
-
queue_peering_event(
CephPeeringEvtRef(
new CephPeeringEvt(
{
PG *pg = context< RecoveryMachine >().pg;
all_replicas_activated = true;
+
pg->state_clear(PG_STATE_ACTIVATING);
+ pg->state_clear(PG_STATE_CREATING);
pg->state_set(PG_STATE_ACTIVE);
+ // info.last_epoch_started is set during activate()
+ pg->info.history.last_epoch_started = pg->info.last_epoch_started;
+
+ pg->share_pg_info();
+ pg->publish_stats_to_osd();
+
pg->check_local();
// waiters