aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2021-12-22 16:05:38 -0800
committerchrislu <chris.lu@gmail.com>2021-12-22 16:05:38 -0800
commit0ec7bc6710350dec395b33ba44589ee1875586c0 (patch)
treef8a7ace7d77b7e84731ced5deddc0fdc14a6e39c
parent4c1368d621d452232d5d9e0cad466760353ac443 (diff)
downloadseaweedfs-0ec7bc6710350dec395b33ba44589ee1875586c0.tar.xz
seaweedfs-0ec7bc6710350dec395b33ba44589ee1875586c0.zip
detect non streaming mode on the first read
-rw-r--r--weed/filer/reader_pattern.go7
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
}