diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-05-06 03:31:40 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-05-06 03:31:40 -0700 |
| commit | 38f411219a759709b53101d3ecd3ed05c36a6efa (patch) | |
| tree | 3689968bdd7ad1a24fa0405c3423c4cf84e69a9d /weed/filesys/dirty_page.go | |
| parent | c899bdf0636488dc55c6788cc41ce2329f58a39f (diff) | |
| download | seaweedfs-38f411219a759709b53101d3ecd3ed05c36a6efa.tar.xz seaweedfs-38f411219a759709b53101d3ecd3ed05c36a6efa.zip | |
mount: skip local chunk cache if opened write only
Diffstat (limited to 'weed/filesys/dirty_page.go')
| -rw-r--r-- | weed/filesys/dirty_page.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/filesys/dirty_page.go b/weed/filesys/dirty_page.go index 8888cff96..1719d68e6 100644 --- a/weed/filesys/dirty_page.go +++ b/weed/filesys/dirty_page.go @@ -13,6 +13,7 @@ import ( type ContinuousDirtyPages struct { intervals *ContinuousIntervals f *File + fh *FileHandle writeWaitGroup sync.WaitGroup chunkAddLock sync.Mutex lastErr error @@ -94,7 +95,7 @@ func (pages *ContinuousDirtyPages) saveToStorage(reader io.Reader, offset int64, defer pages.writeWaitGroup.Done() reader = io.LimitReader(reader, size) - chunk, collection, replication, err := pages.f.wfs.saveDataAsChunk(pages.f.fullpath())(reader, pages.f.Name, offset) + chunk, collection, replication, err := pages.f.wfs.saveDataAsChunk(pages.f.fullpath(), pages.fh.writeOnly)(reader, pages.f.Name, offset) if err != nil { glog.V(0).Infof("%s saveToStorage [%d,%d): %v", pages.f.fullpath(), offset, offset+size, err) pages.lastErr = err |