cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

arc cache is threadsafe

Browse Source
This commit is contained in:
whyrusleeping 2019-10-09 21:50:07 +09:00
parent b333247fab
commit bb974d23e6
1 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chain/badtscache.go
View File

@ -1,14 +1,11 @@
package chain package chain
import ( import (
"sync"
lru "github.com/hashicorp/golang-lru" lru "github.com/hashicorp/golang-lru"
"github.com/ipfs/go-cid" "github.com/ipfs/go-cid"
) )
type BadBlockCache struct { type BadBlockCache struct {
lk sync.Mutex
badBlocks *lru.ARCCache badBlocks *lru.ARCCache
} }
@ -24,13 +21,9 @@ func NewBadBlockCache() *BadBlockCache {
} }
func (bts *BadBlockCache) Add(c cid.Cid) { func (bts *BadBlockCache) Add(c cid.Cid) {
bts.lk.Lock()
defer bts.lk.Unlock()
bts.badBlocks.Add(c, nil) bts.badBlocks.Add(c, nil)
} }
func (bts *BadBlockCache) Has(c cid.Cid) bool { func (bts *BadBlockCache) Has(c cid.Cid) bool {
bts.lk.Lock()
defer bts.lk.Unlock()
return bts.badBlocks.Contains(c) return bts.badBlocks.Contains(c)
} }