Skip to content

Commit 0400d54

Browse files
authored
remove debug messages in busy loop (#39)
1 parent 95a1dd5 commit 0400d54

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

message_processor.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,8 +99,6 @@ func (mg messageProcessor) sendMessage(l logger.Logger, buf *logdriver.LogEntry,
9999
// Only send if partial bit is not set or temp buffer size reached max or temp buffer timer expired
100100
// Check for temp buffer timer expiration
101101
if !buf.Partial || t.shouldFlush(time.Now()) {
102-
logrus.WithField("id", containerid).WithField("Buffer partial flag should be false:",
103-
buf.Partial).WithField("Temp buffer Length:", t.tBuf.Len()).Debug("Buffer details")
104102
msg.Line = t.tBuf.Bytes()
105103
msg.Source = buf.Source
106104
msg.Partial = buf.Partial

partial_message_buffer.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@ func (b *partialMsgBuffer) append(l *logdriver.LogEntry) (err error) {
5050

5151
func (b *partialMsgBuffer) reset() {
5252
if b.bufferReset {
53-
logrus.Debug("Resetting temp buffer")
5453
b.tBuf.Reset()
5554
b.bufferTimer = time.Now()
5655
}
@@ -67,4 +66,4 @@ func (b *partialMsgBuffer) hasLengthExceeded() bool {
6766

6867
func (b *partialMsgBuffer) shouldFlush(t time.Time) bool {
6968
return b.hasLengthExceeded() || b.hasHoldDurationExpired(t)
70-
}
69+
}

0 commit comments

Comments
 (0)