coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 18:37:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: don't use iterator for frame directly until iterator is fixed

Browse Source
This commit is contained in:
Cassandra Heart 2024-10-24 22:31:17 -05:00
parent 6b3f42cc4b
commit 550ce3ec0c
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
node/consensus/data/main_data_loop.go
View File

@ -279,7 +279,7 @@ func (e *DataClockConsensusEngine) rebroadcastLoop() {
}
iter, err := e.clockStore.RangeDataClockFrames(e.filter, 1, 60840)
i := 0
i := uint64(0)
frames := []*protobufs.ClockFrame{}
sent := false
for iter.First(); iter.Valid(); iter.Next() {
@ -289,7 +289,7 @@ func (e *DataClockConsensusEngine) rebroadcastLoop() {
return
}
i++
frame, err := iter.Value()
frame, _, err := e.clockStore.GetDataClockFrame(e.filter, i, false)
if err != nil {
e.logger.Error("error while iterating", zap.Error(err))
}
@ -312,6 +312,7 @@ func (e *DataClockConsensusEngine) rebroadcastLoop() {
frames = []*protobufs.ClockFrame{}
}
}
iter.Close()
if !sent && len(frames) != 0 {
e.logger.Info(