coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-03-09 10:17:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Move time triggered synchronization to dedicated goroutine (#359)

Browse Source
This commit is contained in:
petricadaipegsp 2024-11-17 09:18:55 +01:00 committed by GitHub
parent 889fcac721
commit 0b499c649c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -50,6 +50,17 @@ func (e *DataClockConsensusEngine) runSync() {
if _, err := e.collect(enqueuedFrame); err != nil {
e.logger.Error("could not collect", zap.Error(err))
}
case <-time.After(20 * time.Second):
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
continue
}
head, err := e.dataTimeReel.Head()
if err != nil {
panic(err)
}
if _, err := e.collect(head); err != nil {
e.logger.Error("could not collect", zap.Error(err))
}
}
}
}
@ -84,6 +95,8 @@ func (e *DataClockConsensusEngine) runLoop() {
}
select {
case <-e.ctx.Done():
return
case dataFrame := <-dataFrameCh:
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
if err = e.publishProof(dataFrame); err != nil {
@ -95,17 +108,6 @@ func (e *DataClockConsensusEngine) runLoop() {
e.stateMx.Unlock()
}
}
latestFrame = e.processFrame(latestFrame, dataFrame)
case <-time.After(20 * time.Second):
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
continue
}
dataFrame, err := e.dataTimeReel.Head()
if err != nil {
panic(err)
}
latestFrame = e.processFrame(latestFrame, dataFrame)
}
}