From 857efae5e79e335cce6f9d24eab2f896684e429e Mon Sep 17 00:00:00 2001 From: agnusmor Date: Thu, 18 Jul 2024 12:53:10 +0200 Subject: [PATCH] Wait the state to be synced when starting --- aggregator/aggregator.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/aggregator/aggregator.go b/aggregator/aggregator.go index 751ade1ff7..0e41d796de 100644 --- a/aggregator/aggregator.go +++ b/aggregator/aggregator.go @@ -124,6 +124,12 @@ func (a *Aggregator) Start(ctx context.Context) error { return fmt.Errorf("failed to initialize proofs cache %w", err) } + for !a.isSynced(ctx, nil) { + log.Info("Waiting for synchronizer to sync...") + time.Sleep(a.cfg.RetryTime.Duration) + continue + } + address := fmt.Sprintf("%s:%d", a.cfg.Host, a.cfg.Port) lis, err := net.Listen("tcp", address) if err != nil {