Change influxdb stats to not count points written on error (influxdat…

…a#803)
Mic92 · Aug 10, 2016 · 6ce1a61 · 6ce1a61
1 parent 7365249
commit 6ce1a61
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/influxdb_out.go b/influxdb_out.go
@@ -233,7 +233,6 @@ func (w *writeBuffer) writeAll() {
 	for bpc, bp := range w.buffer {
 		err := w.write(bp)
 		if err != nil {
-			w.i.writeErrors.Add(1)
 			w.i.logger.Println("E! failed to write points to InfluxDB:", err)
 		}
 		delete(w.buffer, bpc)
@@ -249,9 +248,15 @@ func (w *writeBuffer) write(bp influxdb.BatchPoints) error {
 			w.conn, err = w.i.et.tm.InfluxDBService.NewDefaultClient()
 		}
 		if err != nil {
+			w.i.writeErrors.Add(1)
 			return err
 		}
 	}
+	err = w.conn.Write(bp)
+	if err != nil {
+		w.i.writeErrors.Add(1)
+		return err
+	}
 	w.i.pointsWritten.Add(int64(len(bp.Points())))
-	return w.conn.Write(bp)
+	return nil
 }