diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-06-27 05:54:06 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-06-27 05:54:16 -0700 |
| commit | c764596f96545c28793de6dd7e930fe0919584fb (patch) | |
| tree | 05822aac00af1c76f723eba324d8bee0b7f48ebb | |
| parent | cc7714fdbe4cce0eb8fd37915fa986064ffabdc1 (diff) | |
| download | seaweedfs-c764596f96545c28793de6dd7e930fe0919584fb.tar.xz seaweedfs-c764596f96545c28793de6dd7e930fe0919584fb.zip | |
filer: slow metadata topic read may lose some change events
fix https://github.com/chrislusf/seaweedfs/issues/2117
| -rw-r--r-- | weed/util/log_buffer/log_buffer.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go index e3153fddd..12840a88a 100644 --- a/weed/util/log_buffer/log_buffer.go +++ b/weed/util/log_buffer/log_buffer.go @@ -164,6 +164,10 @@ func (m *LogBuffer) copyToFlush() *dataToFlush { stopTime: m.stopTime, data: copiedBytes(m.buf[:m.pos]), } + // glog.V(4).Infof("%s flushing [0,%d) with %d entries [%v, %v]", m.name, m.pos, len(m.idx), m.startTime, m.stopTime) + } else { + // glog.V(4).Infof("%s removed from memory [0,%d) with %d entries [%v, %v]", m.name, m.pos, len(m.idx), m.startTime, m.stopTime) + m.lastFlushTime = m.stopTime } m.buf = m.prevBuffers.SealBuffer(m.startTime, m.stopTime, m.buf, m.pos) m.pos = 0 |