func()

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
}