diff options
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 -} |