diff options
Diffstat (limited to 'logtail/buffer.go')
| -rw-r--r-- | logtail/buffer.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/logtail/buffer.go b/logtail/buffer.go index 82c9b4610..aef508aad 100644 --- a/logtail/buffer.go +++ b/logtail/buffer.go @@ -28,9 +28,11 @@ type Buffer interface { } func NewMemoryBuffer(numEntries int) Buffer { - return &memBuffer{ + mb := &memBuffer{ pending: make(chan qentry, numEntries), } + syncs.RegisterMutex(&mb.dropMu, "logtail.memBuffer.dropMu") + return mb } type memBuffer struct { |