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

adjust runonce

Browse Source
This commit is contained in:
Cassandra Heart 2024-11-16 18:29:41 -06:00
parent 08e7dad8c9
commit 706ec2997d
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -71,9 +71,20 @@ func (e *DataClockConsensusEngine) runLoop() {
panic(err)
}
if runOnce {
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
dataFrame, err := e.dataTimeReel.Head()
if err != nil {
panic(err)
}
latestFrame = e.processFrame(latestFrame, dataFrame)
}
runOnce = false
}
select {
case dataFrame := <-dataFrameCh:
runOnce = false
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
if err = e.publishProof(dataFrame); err != nil {
e.logger.Error("could not publish", zap.Error(err))
@ -86,14 +97,10 @@ func (e *DataClockConsensusEngine) runLoop() {
}
latestFrame = e.processFrame(latestFrame, dataFrame)
case <-time.After(20 * time.Second):
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) && !runOnce {
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
continue
}
if runOnce {
runOnce = false
}
dataFrame, err := e.dataTimeReel.Head()
if err != nil {
panic(err)