diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-05 17:34:26 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-05 17:34:26 -0700 |
| commit | 78ea9376060654162a0f80d6ccff76e63ae35365 (patch) | |
| tree | 48544f3fb24a7072965b4a563df373149182894a | |
| parent | 53626734d4ac7724604ca434aaab7c892b22510d (diff) | |
| download | seaweedfs-78ea9376060654162a0f80d6ccff76e63ae35365.tar.xz seaweedfs-78ea9376060654162a0f80d6ccff76e63ae35365.zip | |
fix
| -rw-r--r-- | weed/queue/log_buffer.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/queue/log_buffer.go b/weed/queue/log_buffer.go index 0a8298be4..6925757a7 100644 --- a/weed/queue/log_buffer.go +++ b/weed/queue/log_buffer.go @@ -162,7 +162,7 @@ func (m *LogBuffer) ReadFromBuffer(lastReadTime time.Time) (ts time.Time, buffer fmt.Printf("l=%d, h=%d\n", l, h) */ - for { + for l <= h { mid := (l + h) / 2 pos := m.idx[mid] t := readTs(m.buf, m.idx[mid]) |