aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/reader_at_test.go
diff options
context:
space:
mode:
authorEugeniy E. Mikhailov <evgmik@gmail.com>2024-09-12 00:09:20 -0400
committerGitHub <noreply@github.com>2024-09-11 21:09:20 -0700
commitdab0bb809766fd24fe243ff9abb2ff94c8076e41 (patch)
treed18066093fbddabb613a226e25e08b2657f13f1c /weed/filer/reader_at_test.go
parent151f2ff7a9f551e713ff9894348a9bac138d5247 (diff)
downloadseaweedfs-dab0bb809766fd24fe243ff9abb2ff94c8076e41.tar.xz
seaweedfs-dab0bb809766fd24fe243ff9abb2ff94c8076e41.zip
Feature limit caching to prescribed number of bytes per file (#6009)
* feature: we can check if a fileId is already in the cache We using this to protect cache from adding the same needle to the cache over and over. * fuse mount: Do not start dowloader if needle is already in the cache * added maxFilePartSizeInCache property to ChunkCache If file very large only first maxFilePartSizeInCache bytes are going to be put to the cache (subject to the needle size constrains). * feature: for large files put in cache no more than prescribed number of bytes Before this patch only the first needle of a large file was intended for caching. This patch uses maximum prescribed amount of bytes to be put in cache. This allows to bypass default 2MB maximum for a file part stored in the cache. * added dummy mock methods to satisfy interfaces of ChunkCache
Diffstat (limited to 'weed/filer/reader_at_test.go')
-rw-r--r--weed/filer/reader_at_test.go8
1 files changed, 8 insertions, 0 deletions
diff --git a/weed/filer/reader_at_test.go b/weed/filer/reader_at_test.go
index 8bc383184..0d95d1aad 100644
--- a/weed/filer/reader_at_test.go
+++ b/weed/filer/reader_at_test.go
@@ -31,6 +31,14 @@ func (m *mockChunkCache) ReadChunkAt(data []byte, fileId string, offset uint64)
func (m *mockChunkCache) SetChunk(fileId string, data []byte) {
}
+func (m *mockChunkCache) GetMaxFilePartSizeInCache() (uint64) {
+ return 0
+}
+
+func (m *mockChunkCache) IsInCache(fileId string, lockNeeded bool) (answer bool) {
+ return false
+}
+
func TestReaderAt(t *testing.T) {
visibles := NewIntervalList[*VisibleInterval]()