Catch and recover from stats crashes

gameofpointers · Oct 25, 2023 · f28e60a · f28e60a
1 parent 4adbe9e
commit f28e60a
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/quaistats/quaistats.go b/quaistats/quaistats.go
@@ -244,6 +244,13 @@ func (s *Service) Stop() error {
 // loop keeps trying to connect to the netstats server, reporting chain events
 // until termination.
 func (s *Service) loop(chainHeadCh chan core.ChainHeadEvent, chainSideCh chan core.ChainSideEvent) {
+	defer func() {
+		if r := recover(); r != nil {
+			fmt.Println("Stats process crashed with error:", r)
+			go s.loop(chainHeadCh, chainSideCh)
+		}
+	}()
+
 	// Start a goroutine that exhausts the subscriptions to avoid events piling up
 	var (
 		quitCh = make(chan struct{})