diff options
| author | chrislu <chris.lu@gmail.com> | 2022-06-07 22:33:35 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-06-07 22:33:35 -0700 |
| commit | ebd6097e6f7c60599e198e5444cdcb353b6328b7 (patch) | |
| tree | 76bd527a2bc895675a67c4384afd7b99ceb52265 | |
| parent | 666e620b63fef47bac70f2995f530ea307807c48 (diff) | |
| download | seaweedfs-ebd6097e6f7c60599e198e5444cdcb353b6328b7.tar.xz seaweedfs-ebd6097e6f7c60599e198e5444cdcb353b6328b7.zip | |
fix: sequence read rate is slow when use filer.ChunkReadAt.ReadAt #3074
related to https://github.com/chrislusf/seaweedfs/pull/3074
| -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 { |