diff options
| author | chrislu <chris.lu@gmail.com> | 2021-12-22 16:05:38 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2021-12-22 16:05:38 -0800 |
| commit | 0ec7bc6710350dec395b33ba44589ee1875586c0 (patch) | |
| tree | f8a7ace7d77b7e84731ced5deddc0fdc14a6e39c | |
| parent | 4c1368d621d452232d5d9e0cad466760353ac443 (diff) | |
| download | seaweedfs-0ec7bc6710350dec395b33ba44589ee1875586c0.tar.xz seaweedfs-0ec7bc6710350dec395b33ba44589ee1875586c0.zip | |
detect non streaming mode on the first read
| -rw-r--r-- | weed/filer/reader_pattern.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/weed/filer/reader_pattern.go b/weed/filer/reader_pattern.go index 2bf18d141..5e6ea7348 100644 --- a/weed/filer/reader_pattern.go +++ b/weed/filer/reader_pattern.go @@ -11,7 +11,7 @@ type ReaderPattern struct { func NewReaderPattern() *ReaderPattern { return &ReaderPattern{ isStreaming: true, - lastReadOffset: 0, + lastReadOffset: -1, } } @@ -19,6 +19,11 @@ func (rp *ReaderPattern) MonitorReadAt(offset int64, size int) { if rp.lastReadOffset > offset { rp.isStreaming = false } + if rp.lastReadOffset == -1 { + if offset != 0 { + rp.isStreaming = false + } + } rp.lastReadOffset = offset } |
