opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-30 01:52:26 +08:00
Code Issues Projects Releases Wiki Activity

blocks/blockstore: improve logic a bit

Browse Source 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
This commit is contained in:
Jakub Sztandera
2016-07-05 15:17:52 +02:00
parent 016d3d97ef
commit 61a3d127e7
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
blocks/blockstore/caching.go
View File

@ -26,6 +26,7 @@ func CachedBlockstore(bs GCBlockstore,
if ctx == nil { if ctx == nil {
ctx = context.TODO() // For tests ctx = context.TODO() // For tests
} }
cbs = bs
if opts.HasBloomFilterSize < 0 || opts.HasBloomFilterHashes < 0 || if opts.HasBloomFilterSize < 0 || opts.HasBloomFilterHashes < 0 ||
opts.HasARCCacheSize < 0 { opts.HasARCCacheSize < 0 {
@ -35,8 +36,10 @@ func CachedBlockstore(bs GCBlockstore,
if opts.HasBloomFilterSize != 0 && opts.HasBloomFilterHashes == 0 { if opts.HasBloomFilterSize != 0 && opts.HasBloomFilterHashes == 0 {
return nil, errors.New("bloom filter hash count can't be 0 when there is size set") return nil, errors.New("bloom filter hash count can't be 0 when there is size set")
} }
cbs, err = bloomCached(bs, ctx, opts.HasBloomFilterSize, opts.HasBloomFilterHashes, if opts.HasBloomFilterSize != 0 {
opts.HasARCCacheSize) cbs, err = bloomCached(cbs, ctx, opts.HasBloomFilterSize, opts.HasBloomFilterHashes,
opts.HasARCCacheSize)
}
return cbs, err return cbs, err
} }