diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-11 07:55:26 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-11 07:55:26 -0800 |
| commit | 188f471a24e5633a9a6a5d4a9703596bb97dce00 (patch) | |
| tree | 532bc93f7d62afc4382ff80adf97954b5f5f6c9f /weed/util/log_buffer/log_buffer.go | |
| parent | 6a7a67913708ba20fc9311e3da1a35eb958c213d (diff) | |
| download | seaweedfs-188f471a24e5633a9a6a5d4a9703596bb97dce00.tar.xz seaweedfs-188f471a24e5633a9a6a5d4a9703596bb97dce00.zip | |
logging
Diffstat (limited to 'weed/util/log_buffer/log_buffer.go')
| -rw-r--r-- | weed/util/log_buffer/log_buffer.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go index 567d660ef..dc61e44ce 100644 --- a/weed/util/log_buffer/log_buffer.go +++ b/weed/util/log_buffer/log_buffer.go @@ -104,7 +104,7 @@ func (logBuffer *LogBuffer) AddToBuffer(partitionKey, data []byte, processingTsN } if logBuffer.startTime.Add(logBuffer.flushInterval).Before(ts) || len(logBuffer.buf)-logBuffer.pos < size+4 { - glog.V(0).Infof("%s copyToFlush1 batch:%d start time %v, ts %v, remaining %d bytes", logBuffer.name, logBuffer.batchIndex, logBuffer.startTime, ts, len(logBuffer.buf)-logBuffer.pos) + glog.V(0).Infof("%s copyToFlush1 batch:%d count:%d start time %v, ts %v, remaining %d bytes", logBuffer.name, logBuffer.batchIndex, len(logBuffer.idx), logBuffer.startTime, ts, len(logBuffer.buf)-logBuffer.pos) toFlush = logBuffer.copyToFlush() logBuffer.startTime = ts if len(logBuffer.buf) < size+4 { |