aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/reader_at.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-09-04 01:19:14 -0700
committerchrislu <chris.lu@gmail.com>2024-09-04 01:19:14 -0700
commit7367b976b05bfa69158a60f205dec970c48f50f0 (patch)
treeb2206ec7b05e34ed95c0255ceb6da5936efdc00b /weed/filer/reader_at.go
parent66ac82bb8f8a5c5f095387689a503f2bc0edd002 (diff)
downloadseaweedfs-7367b976b05bfa69158a60f205dec970c48f50f0.tar.xz
seaweedfs-7367b976b05bfa69158a60f205dec970c48f50f0.zip
weed mount, weed dav add option to force cache
Diffstat (limited to 'weed/filer/reader_at.go')
-rw-r--r--weed/filer/reader_at.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/filer/reader_at.go b/weed/filer/reader_at.go
index d475e6e11..3d9f50d0e 100644
--- a/weed/filer/reader_at.go
+++ b/weed/filer/reader_at.go
@@ -19,6 +19,7 @@ type ChunkReadAt struct {
fileSize int64
readerCache *ReaderCache
readerPattern *ReaderPattern
+ forceCache bool
lastChunkFid string
}
@@ -196,7 +197,9 @@ func (c *ChunkReadAt) readChunkSliceAt(buffer []byte, chunkView *ChunkView, next
if n > 0 {
return n, err
}
- return fetchChunkRange(buffer, c.readerCache.lookupFileIdFn, chunkView.FileId, chunkView.CipherKey, chunkView.IsGzipped, int64(offset))
+ if !c.forceCache {
+ return fetchChunkRange(buffer, c.readerCache.lookupFileIdFn, chunkView.FileId, chunkView.CipherKey, chunkView.IsGzipped, int64(offset))
+ }
}
n, err = c.readerCache.ReadChunkAt(buffer, chunkView.FileId, chunkView.CipherKey, chunkView.IsGzipped, int64(offset), int(chunkView.ChunkSize), chunkView.ViewOffset == 0)