fixed #34

adejoux · Mar 14, 2019 · d854a89 · d854a89
1 parent 8a64bfc
commit d854a89
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/agent/devices/nmon/nmonfile.go b/pkg/agent/devices/nmon/nmonfile.go
@@ -373,6 +373,9 @@ func (nf *NmonFile) ProcessPending(points *pointarray.PointArray, tags map[strin
 
 		} else {
 			nf.log.Errorf("ProcessPending: ERROR: first Pending data is not ZZZZZ (Time) section got this one [%s]", firstline)
+			if len(nf.PendingLines) > 1 {
+				nf.PendingLines = nf.PendingLines[1:]
+			}
 			//PENDING what to do if this happens?
 			return
 		}
@@ -396,7 +399,7 @@ func (nf *NmonFile) ProcessPending(points *pointarray.PointArray, tags map[strin
 		t, err := nf.convertTimeStamp(ts)
 		if err != nil {
 			nf.log.Errorf("ProcessPending: Error on Timestamp conversion %s", err)
-			continue
+			return
 		}
 		nf.ProcessChunk(points, tags, t, tsID, nmonChunk)
 		nf.LastTime = t