diff options
| author | chrislu <chris.lu@gmail.com> | 2022-05-30 16:16:23 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-05-30 16:16:23 -0700 |
| commit | 968ca95b49525fa2be1009163df5a2c1c81fb96c (patch) | |
| tree | b630095971beac2019a4723b4602d1d42f263f41 /weed/util/log_buffer/log_read.go | |
| parent | f214dfb1f5ccfecfedd8a5d3b513508e27388467 (diff) | |
| download | seaweedfs-968ca95b49525fa2be1009163df5a2c1c81fb96c.tar.xz seaweedfs-968ca95b49525fa2be1009163df5a2c1c81fb96c.zip | |
filer.meta.tail: support untilTimeAgo for a range
Diffstat (limited to 'weed/util/log_buffer/log_read.go')
| -rw-r--r-- | weed/util/log_buffer/log_read.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/util/log_buffer/log_read.go b/weed/util/log_buffer/log_read.go index 36854cb74..99532b47b 100644 --- a/weed/util/log_buffer/log_read.go +++ b/weed/util/log_buffer/log_read.go @@ -40,6 +40,10 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startReadTime } // glog.V(4).Infof("%s ReadFromBuffer by %v", readerName, lastReadTime) if bytesBuf == nil { + if stopTsNs != 0 { + isDone = true + return + } if waitForDataFn() { continue } else { |