diff --git a/internal/statesync/reactor.go b/internal/statesync/reactor.go index c66b77793..0d8ab7f4c 100644 --- a/internal/statesync/reactor.go +++ b/internal/statesync/reactor.go @@ -1006,7 +1006,11 @@ func (r *Reactor) waitForEnoughPeers(ctx context.Context, numPeers int) error { startAt := time.Now() t := time.NewTicker(100 * time.Millisecond) defer t.Stop() + logT := time.NewTicker(time.Minute) + defer logT.Stop() + var iter int for r.peers.Len() < numPeers { + iter++ select { case <-ctx.Done(): return fmt.Errorf("operation canceled while waiting for peers after %s", time.Since(startAt)) @@ -1014,6 +1018,14 @@ func (r *Reactor) waitForEnoughPeers(ctx context.Context, numPeers int) error { return fmt.Errorf("shutdown while waiting for peers after %s", time.Since(startAt)) case <-t.C: continue + case <-logT.C: + r.Logger.Info("waiting for sufficient peers to start statesync", + "duration", time.Since(startAt).String(), + "target", numPeers, + "peers", r.peers.Len(), + "iters", iter, + ) + continue } } return nil