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

chainwatch: reduce memory usage during large chain gaps

Browse Source
This commit is contained in:
Travis Person 2020-02-20 03:06:41 +00:00
parent 0fa362cc23
commit 28ec00500b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/lotus-chainwatch/sync.go
View File

@ -67,7 +67,6 @@ type actorInfo struct {
func syncHead(ctx context.Context, api api.FullNode, st *storage, ts *types.TipSet) { func syncHead(ctx context.Context, api api.FullNode, st *storage, ts *types.TipSet) {
addresses := map[address.Address]address.Address{} addresses := map[address.Address]address.Address{}
actors := map[address.Address]map[types.Actor]actorInfo{}
var alk sync.Mutex var alk sync.Mutex
log.Infof("Getting synced block list") log.Infof("Getting synced block list")
@ -114,6 +113,7 @@ func syncHead(ctx context.Context, api api.FullNode, st *storage, ts *types.TipS
} }
for len(allToSync) > 0 { for len(allToSync) > 0 {
actors := map[address.Address]map[types.Actor]actorInfo{}
minH := uint64(math.MaxUint64) minH := uint64(math.MaxUint64)
for _, header := range allToSync { for _, header := range allToSync {
@ -200,7 +200,7 @@ func syncHead(ctx context.Context, api api.FullNode, st *storage, ts *types.TipS
log.Error(err) log.Error(err)
return return
} }
ast, err := api.StateReadState(ctx, &act, ts.Key()) ast, err := api.StateReadState(ctx, &act, pts.Key())
if err != nil { if err != nil {
log.Error(err) log.Error(err)
return return