diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-16 10:51:16 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-16 10:51:16 -0700 |
| commit | 059df3957ddaa37fbfc0e84b2fd63811fec46bee (patch) | |
| tree | 0f491b561f97c531f704caa90d9de8b812315198 | |
| parent | 1b5c547cfeb4bdaccb6f7bc4f87542e5bfd1f682 (diff) | |
| download | seaweedfs-059df3957ddaa37fbfc0e84b2fd63811fec46bee.tar.xz seaweedfs-059df3957ddaa37fbfc0e84b2fd63811fec46bee.zip | |
rename to lastFlushDataTime
| -rw-r--r-- | weed/util/log_buffer/log_buffer.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go index 7709a43e9..02d2a6579 100644 --- a/weed/util/log_buffer/log_buffer.go +++ b/weed/util/log_buffer/log_buffer.go @@ -35,9 +35,9 @@ type LogBuffer struct { idx []int pos int startTime time.Time - stopTime time.Time - lastFlushTime time.Time - sizeBuf []byte + stopTime time.Time + lastFlushDataTime time.Time + sizeBuf []byte flushInterval time.Duration flushFn LogFlushFuncType ReadFromDiskFn LogReadFromDiskFuncType @@ -151,7 +151,7 @@ func (logBuffer *LogBuffer) loopFlush() { logBuffer.flushFn(logBuffer, d.startTime, d.stopTime, d.data.Bytes()) d.releaseMemory() // local logbuffer is different from aggregate logbuffer here - logBuffer.lastFlushTime = d.stopTime + logBuffer.lastFlushDataTime = d.stopTime } } } @@ -188,7 +188,7 @@ func (logBuffer *LogBuffer) copyToFlush() *dataToFlush { // 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) - logBuffer.lastFlushTime = logBuffer.stopTime + logBuffer.lastFlushDataTime = logBuffer.stopTime } logBuffer.buf = logBuffer.prevBuffers.SealBuffer(logBuffer.startTime, logBuffer.stopTime, logBuffer.buf, logBuffer.pos, logBuffer.batchIndex) logBuffer.startTime = time.Unix(0, 0) @@ -245,8 +245,8 @@ func (logBuffer *LogBuffer) ReadFromBuffer(lastReadPosition MessagePosition) (bu println("2.2 no data") return nil, -2, nil } else if lastReadPosition.Before(tsMemory) && lastReadPosition.BatchIndex+1 < tsBatchIndex { // case 2.3 - if !logBuffer.lastFlushTime.IsZero() { - glog.V(0).Infof("resume with last flush time: %v", logBuffer.lastFlushTime) + if !logBuffer.lastFlushDataTime.IsZero() { + glog.V(0).Infof("resume with last flush time: %v", logBuffer.lastFlushDataTime) return nil, -2, ResumeFromDiskError } } |