Looping on sync

c4dt · Feb 26, 2024 · 8cb97c8 · 8cb97c8
1 parent 5a677bb
commit 8cb97c8
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/core/ordering/cosipbft/cosipbft.go b/core/ordering/cosipbft/cosipbft.go
@@ -294,10 +294,16 @@ func NewServiceStart(s *Service) {
 			if err != nil {
 				panic("couldn't get roster of latest block: " + err.Error())
 			}
-			err = s.fsync.Sync(ctx, roster,
-				fastsync.Config{SplitMessageSize: DefaultFastSyncMessageSize})
-			if err != nil {
-				s.logger.Warn().Msgf("while syncing with other nodes: %+v", err)
+			// Loop to try to sync
+			for {
+				err := s.fsync.Sync(ctx, roster,
+					fastsync.Config{SplitMessageSize: DefaultFastSyncMessageSize})
+				if err == nil {
+					break
+				}
+				s.logger.Warn().Msgf("while syncing with other nodes - trying again in 10s: %+v",
+					err)
+				time.Sleep(10 * time.Second)
 			}
 			done()
 		}