diff options
| author | chrislu <chris.lu@gmail.com> | 2021-12-22 17:20:44 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2021-12-22 17:20:44 -0800 |
| commit | c2aad1c7ff4f210a1c773691c21e9fdad6b468e1 (patch) | |
| tree | 3cdaed4000c1c92c080ab385ab732b29a5acc062 | |
| parent | b541e39a2c182d8f98f5900b35f9f025825f71f6 (diff) | |
| download | seaweedfs-c2aad1c7ff4f210a1c773691c21e9fdad6b468e1.tar.xz seaweedfs-c2aad1c7ff4f210a1c773691c21e9fdad6b468e1.zip | |
detect non streaming mode on first write request
| -rw-r--r-- | weed/filesys/page_writer_pattern.go | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/weed/filesys/page_writer_pattern.go b/weed/filesys/page_writer_pattern.go index 42ca3d969..44b69cda7 100644 --- a/weed/filesys/page_writer_pattern.go +++ b/weed/filesys/page_writer_pattern.go @@ -14,18 +14,21 @@ type WriterPattern struct { func NewWriterPattern(fileName string, chunkSize int64) *WriterPattern { return &WriterPattern{ isStreaming: true, - lastWriteOffset: 0, + lastWriteOffset: -1, chunkSize: chunkSize, fileName: fileName, } } func (rp *WriterPattern) MonitorWriteAt(offset int64, size int) { - if rp.lastWriteOffset == 0 { - } if rp.lastWriteOffset > offset { rp.isStreaming = false } + if rp.lastWriteOffset == -1 { + if offset != 0 { + rp.isStreaming = false + } + } rp.lastWriteOffset = offset } |
