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

fix: announce peer based on leading frame, not initial frame; fix: looping bug

Browse Source
This commit is contained in:
Cassandra Heart 2024-10-20 23:45:16 -05:00
parent 23adc7e496
commit 11a357518a
No known key found for this signature in database
GPG Key ID: 6352152859385958
3 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/consensus/data/consensus_frames.go
View File

@ -302,11 +302,11 @@ func (e *DataClockConsensusEngine) sync(
}
func (e *DataClockConsensusEngine) collect(
currentFramePublished *protobufs.ClockFrame,
enqueuedFrame *protobufs.ClockFrame,
) (*protobufs.ClockFrame, error) {
e.logger.Info("collecting vdf proofs")
latest := currentFramePublished
latest := enqueuedFrame
for {
peerId, maxFrame, err := e.GetMostAheadPeer(latest.FrameNumber)

3
node/consensus/data/data_clock_consensus_engine.go
View File

@ -330,7 +330,8 @@ func (e *DataClockConsensusEngine) Start() <-chan error {
panic(err)
}
if frame.FrameNumber >= nextFrame.FrameNumber || frame.FrameNumber == 0 {
if frame.FrameNumber >= nextFrame.FrameNumber ||
nextFrame.FrameNumber == 0 {
time.Sleep(30 * time.Second)
continue
}

10
node/consensus/time/data_time_reel.go
View File

@ -606,7 +606,10 @@ func (d *DataTimeReel) setHead(frame *protobufs.ClockFrame, distance *big.Int) {
d.headDistance = distance
go func() {
d.newFrameCh <- frame
select {
case d.newFrameCh <- frame:
default:
}
}()
}
@ -906,7 +909,10 @@ func (d *DataTimeReel) forkChoice(
)
go func() {
d.newFrameCh <- frame
select {
case d.newFrameCh <- frame:
default:
}
}()
}