in logger/buffered_logger.go [365:377]
func (b *ringBuffer) Flush() []*dockerlogger.Message {
b.lock.Lock()
defer b.lock.Unlock()
if len(b.queue) == 0 {
return make([]*dockerlogger.Message, 0)
}
messages := b.queue
b.queue = make([]*dockerlogger.Message, 0)
return messages
}