Remove metrics from the buffer on write (influxdata#5052)

librato · Nov 29, 2018 · 0a506a9 · 0a506a9
1 parent 9b3452a
commit 0a506a9
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/internal/models/buffer.go b/internal/models/buffer.go
@@ -175,9 +175,10 @@ func (b *Buffer) Accept(batch []telegraf.Metric) {
 		b.metricWritten(m)
 	}
 
-	if b.batchSize > 0 {
-		b.size -= b.batchSize
-		b.first += b.batchSize
+	b.size -= b.batchSize
+	for i := 0; i < b.batchSize; i++ {
+		b.buf[b.first] = nil
+		b.first++
 		b.first %= b.cap
 	}