diff options
| -rw-r--r-- | weed/util/log_buffer/log_read.go | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/weed/util/log_buffer/log_read.go b/weed/util/log_buffer/log_read.go index d7ca47155..0354f0e7f 100644 --- a/weed/util/log_buffer/log_read.go +++ b/weed/util/log_buffer/log_read.go @@ -66,16 +66,20 @@ func (logBuffer *LogBuffer) LoopProcessLogData(readerName string, startPosition isDone = true return } - if waitForDataFn() { - continue - } else { - isDone = true - return + lastTsNs := logBuffer.LastTsNs + for lastTsNs == logBuffer.LastTsNs { + if waitForDataFn() { + continue + } else { + isDone = true + return + } } if logBuffer.IsStopping() { isDone = true return } + continue } buf := bytesBuf.Bytes() |