diff --git a/daemon/logger/ring.go b/daemon/logger/ring.go index 887f2ea18ad0b903a8160c1de248445bb1bcaa46..c675c1e83c5915f5933689a360c84341a25a8b0c 100644 --- a/daemon/logger/ring.go +++ b/daemon/logger/ring.go @@ -150,7 +150,7 @@ func newRing(maxBytes int64) *messageRing { } // Enqueue adds a message to the buffer queue -// If the message is too big for the buffer it drops the oldest messages to make room +// If the message is too big for the buffer it drops the new message. // If there are no messages in the queue and the message is still too big, it adds the message anyway. func (r *messageRing) Enqueue(m *Message) error { mSize := int64(len(m.Line)) diff --git a/daemon/logger/ring_test.go b/daemon/logger/ring_test.go index e774535feeb83e1d73be86279b941f497990f213..a2289cc667592679c2eb1e98ad94a457cc69ef2d 100644 --- a/daemon/logger/ring_test.go +++ b/daemon/logger/ring_test.go @@ -58,7 +58,7 @@ func TestRingCap(t *testing.T) { } } - // should have messages in the queue for "5" to "10" + // should have messages in the queue for "0" to "4" for i := 0; i < 5; i++ { m, err := r.Dequeue() if err != nil {