aboutsummaryrefslogtreecommitdiff
path: root/weed/util/log_buffer/log_buffer_test.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-06-27 05:51:28 -0700
committerChris Lu <chris.lu@gmail.com>2021-06-27 05:54:16 -0700
commitcc7714fdbe4cce0eb8fd37915fa986064ffabdc1 (patch)
treebb0f94df840baa38185f8b79ebd26a8a2dd05059 /weed/util/log_buffer/log_buffer_test.go
parentfacaa36d2209062d362ae410d591840aec97bae8 (diff)
downloadseaweedfs-cc7714fdbe4cce0eb8fd37915fa986064ffabdc1.tar.xz
seaweedfs-cc7714fdbe4cce0eb8fd37915fa986064ffabdc1.zip
logging changes to debug
Diffstat (limited to 'weed/util/log_buffer/log_buffer_test.go')
-rw-r--r--weed/util/log_buffer/log_buffer_test.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/util/log_buffer/log_buffer_test.go b/weed/util/log_buffer/log_buffer_test.go
index 3d77afb18..7dcfe5f52 100644
--- a/weed/util/log_buffer/log_buffer_test.go
+++ b/weed/util/log_buffer/log_buffer_test.go
@@ -10,7 +10,7 @@ import (
)
func TestNewLogBufferFirstBuffer(t *testing.T) {
- lb := NewLogBuffer(time.Minute, func(startTime, stopTime time.Time, buf []byte) {
+ lb := NewLogBuffer("test", time.Minute, func(startTime, stopTime time.Time, buf []byte) {
}, func() {
@@ -27,7 +27,7 @@ func TestNewLogBufferFirstBuffer(t *testing.T) {
}
receivedmessageCount := 0
- lb.LoopProcessLogData(startTime, func() bool {
+ lb.LoopProcessLogData("test", startTime, func() bool {
// stop if no more messages
return false
}, func(logEntry *filer_pb.LogEntry) error {