aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2021-12-22 17:20:44 -0800
committerchrislu <chris.lu@gmail.com>2021-12-22 17:20:44 -0800
commitc2aad1c7ff4f210a1c773691c21e9fdad6b468e1 (patch)
tree3cdaed4000c1c92c080ab385ab732b29a5acc062
parentb541e39a2c182d8f98f5900b35f9f025825f71f6 (diff)
downloadseaweedfs-c2aad1c7ff4f210a1c773691c21e9fdad6b468e1.tar.xz
seaweedfs-c2aad1c7ff4f210a1c773691c21e9fdad6b468e1.zip
detect non streaming mode on first write request
-rw-r--r--weed/filesys/page_writer_pattern.go9
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
}