Be tolerant to a few errors from ipfix parser

calmh · Aug 9, 2013 · dbacaa0 · dbacaa0
1 parent 5a3c3ec
commit dbacaa0
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/main.go b/main.go
@@ -28,11 +28,20 @@ type myInterpretedField struct {
 func messagesGenerator(s *ipfix.Session) <-chan []InterpretedRecord {
 	c := make(chan []InterpretedRecord)
 
+	errors := 0
 	go func() {
 		for {
 			msg, err := s.ReadMessage()
 			if err != nil {
-				panic(err)
+				errors++
+				if errors > 3 {
+					panic(err)
+				} else {
+					log.Println(err)
+				}
+				continue
+			} else {
+				errors = 0
 			}
 
 			irecs := make([]InterpretedRecord, len(msg.DataRecords))