Log correct sample count when appending to disk.

This commit is contained in:
Julius Volz 2013-06-21 12:23:27 +02:00
parent de8757f925
commit ba8c122147
1 changed files with 2 additions and 2 deletions

View File

@ -269,17 +269,17 @@ func (t *TieredStorage) flushMemory(ttl time.Duration) {
queueLength := len(t.appendToDiskQueue)
if queueLength > 0 {
log.Printf("Writing %d samples ...", queueLength)
samples := model.Samples{}
for i := 0; i < queueLength; i++ {
chunk := <-t.appendToDiskQueue
samples = append(samples, chunk...)
}
log.Printf("Writing %d samples...", len(samples))
t.DiskStorage.AppendSamples(samples)
}
log.Println("Done flushing...")
log.Println("Done flushing.")
}
func (t *TieredStorage) Close() {