diff --git a/internal/blocksync/reactor.go b/internal/blocksync/reactor.go index 4a35c1ce7..5504f075e 100644 --- a/internal/blocksync/reactor.go +++ b/internal/blocksync/reactor.go @@ -559,7 +559,7 @@ func (r *Reactor) poolRoutine(ctx context.Context, stateSynced bool, blockSyncCh ) continue - case r.pool.IsCaughtUp() && r.previousMaxPeerHeight < r.pool.MaxPeerHeight(): + case r.pool.IsCaughtUp() && r.previousMaxPeerHeight <= r.pool.MaxPeerHeight(): r.logger.Info("switching to consensus reactor", "height", height) case time.Since(lastAdvance) > syncTimeout: