diff options
| author | chrislu <chris.lu@gmail.com> | 2021-12-21 17:28:55 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2021-12-21 17:28:55 -0800 |
| commit | 9a73319b45eefb965e8ab8c19b8f82750a6dfc75 (patch) | |
| tree | d961b9a72a7cf09f53b26dc7ae8e782f4b73c2e0 /weed/filesys/page_writer | |
| parent | 4b8dcff448153dfc18b7ab49a8959f50d3bfc25f (diff) | |
| download | seaweedfs-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.go | 1 | ||||
| -rw-r--r-- | weed/filesys/page_writer/writer_pattern.go | 31 |
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 -} |
