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

state: optimize state snapshot address cache

Browse Source 
Signed-off-by: Jakub Sztandera <kubuxu@protocol.ai>
This commit is contained in:
Jakub Sztandera 2020-10-19 22:32:05 +02:00
parent 06c0444d45
commit be42dd824b
No known key found for this signature in database
GPG Key ID: 9A9AF56F8B3879BA
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
chain/state/statetree.go
View File

@ -35,7 +35,8 @@ type StateTree struct {
} }
type stateSnaps struct { type stateSnaps struct {
layers []*stateSnapLayer layers []*stateSnapLayer
lastMaybeNonEmptyResolveCache int
} }
type stateSnapLayer struct { type stateSnapLayer struct {
@ -67,7 +68,12 @@ func (ss *stateSnaps) addLayer() {
func (ss *stateSnaps) dropLayer() { func (ss *stateSnaps) dropLayer() {
ss.layers[len(ss.layers)-1] = nil // allow it to be GCed ss.layers[len(ss.layers)-1] = nil // allow it to be GCed
ss.layers = ss.layers[:len(ss.layers)-1] ss.layers = ss.layers[:len(ss.layers)-1]
if ss.lastMaybeNonEmptyResolveCache == len(ss.layers) {
ss.lastMaybeNonEmptyResolveCache = len(ss.layers) - 1
}
} }
func (ss *stateSnaps) mergeLastLayer() { func (ss *stateSnaps) mergeLastLayer() {
@ -86,7 +92,13 @@ func (ss *stateSnaps) mergeLastLayer() {
} }
func (ss *stateSnaps) resolveAddress(addr address.Address) (address.Address, bool) { func (ss *stateSnaps) resolveAddress(addr address.Address) (address.Address, bool) {
for i := len(ss.layers) - 1; i >= 0; i-- { for i := ss.lastMaybeNonEmptyResolveCache; i >= 0; i-- {
if len(ss.layers[i].resolveCache) == 0 {
if ss.lastMaybeNonEmptyResolveCache == i {
ss.lastMaybeNonEmptyResolveCache = i - 1
}
continue
}
resa, ok := ss.layers[i].resolveCache[addr] resa, ok := ss.layers[i].resolveCache[addr]
if ok { if ok {
return resa, true return resa, true
@ -97,6 +109,7 @@ func (ss *stateSnaps) resolveAddress(addr address.Address) (address.Address, boo
func (ss *stateSnaps) cacheResolveAddress(addr, resa address.Address) { func (ss *stateSnaps) cacheResolveAddress(addr, resa address.Address) {
ss.layers[len(ss.layers)-1].resolveCache[addr] = resa ss.layers[len(ss.layers)-1].resolveCache[addr] = resa
ss.lastMaybeNonEmptyResolveCache = len(ss.layers) - 1
} }
func (ss *stateSnaps) getActor(addr address.Address) (*types.Actor, error) { func (ss *stateSnaps) getActor(addr address.Address) (*types.Actor, error) {