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

simplify circular buffer code

Browse Source 
we don't care about order of checks!
This commit is contained in:
vyzo 2020-10-28 00:02:08 +02:00
parent ab7a66b90d
commit fc1ac3e752
1 changed files with 5 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
chain/sync_manager.go
View File

@ -374,7 +374,7 @@ func isHeavier(a, b *types.TipSet) bool {
// sync buffer -- this is a circular buffer of recently synced tipsets
type syncBuffer struct {
buf []*types.TipSet
next int64
next int
}
func newSyncBuffer(size int) *syncBuffer {
@ -382,29 +382,14 @@ func newSyncBuffer(size int) *syncBuffer {
}
func (sb *syncBuffer) Push(ts *types.TipSet) {
i := int(sb.next % int64(len(sb.buf)))
sb.buf[i] = ts
sb.buf[sb.next] = ts
sb.next++
sb.next %= len(sb.buf)
}
func (sb *syncBuffer) Synced(ts *types.TipSet) bool {
synced := func(a, b *types.TipSet) bool {
return a.Equals(b) || isHeavier(a, b)
}
if sb.next < int64(len(sb.buf)) {
for i := int(sb.next - 1); i >= 0; i-- {
if synced(sb.buf[i], ts) {
return true
}
}
return false
}
for j := 1; j < len(sb.buf); j++ {
i := int((sb.next - int64(j)) % int64(len(sb.buf)))
if synced(sb.buf[i], ts) {
for _, rts := range sb.buf {
if rts != nil && (rts.Equals(ts) || isHeavier(rts, ts)) {
return true
}
}