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

Fix tipset coalescing in case of repeated blocks

Browse Source 
Signed-off-by: Jakub Sztandera <kubuxu@protocol.ai>
This commit is contained in:
Jakub Sztandera 2020-10-27 21:23:16 +01:00
parent 16d2cb6309
commit 2b82e5a118
No known key found for this signature in database
GPG Key ID: 9A9AF56F8B3879BA
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
chain/sync_manager.go
View File

@ -7,6 +7,7 @@ import (
"strings" "strings"
"sync" "sync"
"github.com/filecoin-project/go-address"
"github.com/filecoin-project/lotus/build" "github.com/filecoin-project/lotus/build"
"github.com/filecoin-project/lotus/chain/types" "github.com/filecoin-project/lotus/chain/types"
@ -480,9 +481,23 @@ func (stb *syncTargetBucket) add(ts *types.TipSet) {
} }
if coalesceTipsets && t.Height() == ts.Height() && if coalesceTipsets && t.Height() == ts.Height() &&
types.CidArrsEqual(t.Blocks()[0].Parents, ts.Blocks()[0].Parents) { types.CidArrsEqual(t.Blocks()[0].Parents, ts.Blocks()[0].Parents) {
miners := make(map[address.Address]struct{})
newTs := []*types.BlockHeader{}
for _, b := range t.Blocks() {
_, have := miners[b.Miner]
if !have {
newTs = append(newTs, b)
miners[b.Miner] = struct{}{}
}
}
for _, b := range ts.Blocks() {
_, have := miners[b.Miner]
if !have {
newTs = append(newTs, b)
miners[b.Miner] = struct{}{}
}
}
newTs := append([]*types.BlockHeader{}, ts.Blocks()...)
newTs = append(newTs, t.Blocks()...)
ts2, err := types.NewTipSet(newTs) ts2, err := types.NewTipSet(newTs)
if err != nil { if err != nil {
log.Warnf("error while trying to recombine a tipset in a bucket: %+v", err) log.Warnf("error while trying to recombine a tipset in a bucket: %+v", err)