diff options
| author | chrislu <chris.lu@gmail.com> | 2024-03-07 10:50:09 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-03-07 10:50:09 -0800 |
| commit | 34f2b600ac5d4850e5f4f6d9d0ce0273150542cf (patch) | |
| tree | 7c7592ea7415a85b0afba5ca00172156af041ca1 /weed/util/log_buffer/log_buffer.go | |
| parent | 62397f23715062b6e8e710568dc8f88b0bab50d8 (diff) | |
| download | seaweedfs-34f2b600ac5d4850e5f4f6d9d0ce0273150542cf.tar.xz seaweedfs-34f2b600ac5d4850e5f4f6d9d0ce0273150542cf.zip | |
each log function adds a "done" return parameter
Diffstat (limited to 'weed/util/log_buffer/log_buffer.go')
| -rw-r--r-- | weed/util/log_buffer/log_buffer.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go index 273df5593..cfd6c94cd 100644 --- a/weed/util/log_buffer/log_buffer.go +++ b/weed/util/log_buffer/log_buffer.go @@ -22,8 +22,8 @@ type dataToFlush struct { data *bytes.Buffer } -type EachLogEntryFuncType func(logEntry *filer_pb.LogEntry) error -type LogFlushFuncType func(startTime, stopTime time.Time, buf []byte) +type EachLogEntryFuncType func(logEntry *filer_pb.LogEntry) (isDone bool, err error) +type LogFlushFuncType func(logBuffer *LogBuffer, startTime, stopTime time.Time, buf []byte) type LogReadFromDiskFuncType func(startPosition MessagePosition, stopTsNs int64, eachLogEntryFn EachLogEntryFuncType) (lastReadPosition MessagePosition, isDone bool, err error) type LogBuffer struct { @@ -146,7 +146,7 @@ func (logBuffer *LogBuffer) loopFlush() { for d := range logBuffer.flushChan { if d != nil { // glog.V(4).Infof("%s flush [%v, %v] size %d", m.name, d.startTime, d.stopTime, len(d.data.Bytes())) - logBuffer.flushFn(d.startTime, d.stopTime, d.data.Bytes()) + logBuffer.flushFn(logBuffer, d.startTime, d.stopTime, d.data.Bytes()) d.releaseMemory() // local logbuffer is different from aggregate logbuffer here logBuffer.lastFlushTime = d.stopTime |