aboutsummaryrefslogtreecommitdiff
path: root/weed
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-05-16 18:47:41 -0700
committerChris Lu <chris.lu@gmail.com>2020-05-16 18:47:41 -0700
commit759cda0fe297770847b3a2db640bbcaba324f38d (patch)
tree82161ce7770051e751f3534abec7e372f934fb14 /weed
parentb0de01ff3b91cf28edbbaa536eed0e02db4d492c (diff)
downloadseaweedfs-759cda0fe297770847b3a2db640bbcaba324f38d.tar.xz
seaweedfs-759cda0fe297770847b3a2db640bbcaba324f38d.zip
log
Diffstat (limited to 'weed')
-rw-r--r--weed/util/log_buffer/log_read.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/util/log_buffer/log_read.go b/weed/util/log_buffer/log_read.go
index a2345acfb..2b73a8064 100644
--- a/weed/util/log_buffer/log_read.go
+++ b/weed/util/log_buffer/log_read.go
@@ -30,6 +30,7 @@ func (logBuffer *LogBuffer) LoopProcessLogData(
logBuffer.ReleaseMeory(bytesBuf)
}
bytesBuf = logBuffer.ReadFromBuffer(lastReadTime)
+ // fmt.Printf("ReadFromBuffer by %v\n", lastReadTime)
if bytesBuf == nil {
if waitForDataFn() {
continue
@@ -39,6 +40,7 @@ func (logBuffer *LogBuffer) LoopProcessLogData(
}
buf := bytesBuf.Bytes()
+ // fmt.Printf("ReadFromBuffer by %v size %d\n", lastReadTime, len(buf))
batchSize := 0
var startReadTime time.Time