diff options
| -rw-r--r-- | weed/filer/reader_pattern.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/weed/filer/reader_pattern.go b/weed/filer/reader_pattern.go index 5e6ea7348..b860bc577 100644 --- a/weed/filer/reader_pattern.go +++ b/weed/filer/reader_pattern.go @@ -16,15 +16,17 @@ func NewReaderPattern() *ReaderPattern { } func (rp *ReaderPattern) MonitorReadAt(offset int64, size int) { + isStreaming := true if rp.lastReadOffset > offset { - rp.isStreaming = false + isStreaming = false } if rp.lastReadOffset == -1 { if offset != 0 { - rp.isStreaming = false + isStreaming = false } } rp.lastReadOffset = offset + rp.isStreaming = isStreaming } func (rp *ReaderPattern) IsStreamingMode() bool { |