diff options
author | obscuren <geffobscura@gmail.com> | 2015-06-19 22:48:55 +0800 |
---|---|---|
committer | Jeffrey Wilcke <geffobscura@gmail.com> | 2015-06-30 00:51:49 +0800 |
commit | 6ca3a446383bafc9510b36c88629ca7d876fb258 (patch) | |
tree | e9f6a20ffe3a00d670da4808ee40f9da501360ec /core/chain_manager.go | |
parent | 4460dc9d1a7e12f1f0583538c7df852cd64c4fed (diff) | |
download | dexon-6ca3a446383bafc9510b36c88629ca7d876fb258.tar.gz dexon-6ca3a446383bafc9510b36c88629ca7d876fb258.tar.zst dexon-6ca3a446383bafc9510b36c88629ca7d876fb258.zip |
core: switched to proper LRU
Diffstat (limited to 'core/chain_manager.go')
-rw-r--r-- | core/chain_manager.go | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/core/chain_manager.go b/core/chain_manager.go index a0f945020..e67439bb6 100644 --- a/core/chain_manager.go +++ b/core/chain_manager.go @@ -21,7 +21,7 @@ import ( "github.com/ethereum/go-ethereum/params" "github.com/ethereum/go-ethereum/pow" "github.com/ethereum/go-ethereum/rlp" - "github.com/golang/groupcache/lru" + "github.com/hashicorp/golang-lru" "github.com/syndtr/goleveldb/leveldb" ) @@ -121,13 +121,14 @@ type ChainManager struct { } func NewChainManager(genesis *types.Block, blockDb, stateDb common.Database, pow pow.PoW, mux *event.TypeMux) (*ChainManager, error) { + cache, _ := lru.New(blockCacheLimit) bc := &ChainManager{ blockDb: blockDb, stateDb: stateDb, genesisBlock: GenesisBlock(42, stateDb), eventMux: mux, quit: make(chan struct{}), - cache: lru.New(blockCacheLimit), + cache: cache, pow: pow, } // Check the genesis block given to the chain manager. If the genesis block mismatches block number 0 @@ -172,7 +173,7 @@ func (bc *ChainManager) SetHead(head *types.Block) { bc.removeBlock(block) } - bc.cache = lru.New(blockCacheLimit) + bc.cache, _ = lru.New(blockCacheLimit) bc.currentBlock = head bc.makeCache() @@ -260,9 +261,7 @@ func (bc *ChainManager) setLastState() { } func (bc *ChainManager) makeCache() { - if bc.cache == nil { - bc.cache = lru.New(blockCacheLimit) - } + bc.cache, _ = lru.New(blockCacheLimit) // load in last `blockCacheLimit` - 1 blocks. Last block is the current. ancestors := bc.GetAncestors(bc.currentBlock, blockCacheLimit-1) ancestors = append(ancestors, bc.currentBlock) @@ -279,9 +278,7 @@ func (bc *ChainManager) Reset() { bc.removeBlock(block) } - if bc.cache == nil { - bc.cache = lru.New(blockCacheLimit) - } + bc.cache, _ = lru.New(blockCacheLimit) // Prepare the genesis block bc.write(bc.genesisBlock) |