Release buffer back to pool earlier

This commit is contained in:
Daniel Nelson 2017-10-05 12:12:14 -07:00
parent fe40bcb92e
commit df4c24a01e
1 changed files with 1 additions and 1 deletions

View File

@ -427,13 +427,13 @@ func (s *Statsd) parser() error {
return nil
case buf := <-s.in:
lines := strings.Split(buf.String(), "\n")
s.bufPool.Put(buf)
for _, line := range lines {
line = strings.TrimSpace(line)
if line != "" {
s.parseStatsdLine(line)
}
}
s.bufPool.Put(buf)
}
}
}