aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/page_writer
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2021-12-21 17:28:55 -0800
committerchrislu <chris.lu@gmail.com>2021-12-21 17:28:55 -0800
commit9a73319b45eefb965e8ab8c19b8f82750a6dfc75 (patch)
treed961b9a72a7cf09f53b26dc7ae8e782f4b73c2e0 /weed/filesys/page_writer
parent4b8dcff448153dfc18b7ab49a8959f50d3bfc25f (diff)
downloadseaweedfs-9a73319b45eefb965e8ab8c19b8f82750a6dfc75.tar.xz
seaweedfs-9a73319b45eefb965e8ab8c19b8f82750a6dfc75.zip
mount: different write strategy for streaming write and random write
Diffstat (limited to 'weed/filesys/page_writer')
-rw-r--r--weed/filesys/page_writer/page_chunk.go1
-rw-r--r--weed/filesys/page_writer/writer_pattern.go31
2 files changed, 1 insertions, 31 deletions
diff --git a/weed/filesys/page_writer/page_chunk.go b/weed/filesys/page_writer/page_chunk.go
new file mode 100644
index 000000000..b21e6acca
--- /dev/null
+++ b/weed/filesys/page_writer/page_chunk.go
@@ -0,0 +1 @@
+package page_writer
diff --git a/weed/filesys/page_writer/writer_pattern.go b/weed/filesys/page_writer/writer_pattern.go
deleted file mode 100644
index c7641c37f..000000000
--- a/weed/filesys/page_writer/writer_pattern.go
+++ /dev/null
@@ -1,31 +0,0 @@
-package page_writer
-
-type WriterPattern struct {
- isStreaming bool
- lastWriteOffset int64
-}
-
-// For streaming write: only cache the first chunk
-// For random write: fall back to temp file approach
-
-func NewWriterPattern() *WriterPattern {
- return &WriterPattern{
- isStreaming: true,
- lastWriteOffset: 0,
- }
-}
-
-func (rp *WriterPattern) MonitorWriteAt(offset int64, size int) {
- if rp.lastWriteOffset > offset {
- rp.isStreaming = false
- }
- rp.lastWriteOffset = offset
-}
-
-func (rp *WriterPattern) IsStreamingMode() bool {
- return rp.isStreaming
-}
-
-func (rp *WriterPattern) IsRandomMode() bool {
- return !rp.isStreaming
-}