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

use up to date info

Browse Source
This commit is contained in:
Cassandra Heart 2024-11-06 14:46:04 -06:00
parent e230764474
commit 5679b19fdb
No known key found for this signature in database
GPG Key ID: 6352152859385958
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -559,11 +559,6 @@ func (e *DataClockConsensusEngine) Start() <-chan error {
continue
}
if nextFrame.Timestamp < time.Now().UnixMilli()-30000 {
time.Sleep(1 * time.Second)
continue
}
frame = nextFrame
_, triesAtFrame, err := e.clockStore.GetDataClockFrame(
e.filter,

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

@ -92,6 +92,9 @@ func (e *DataClockConsensusEngine) processFrame(
if e.latestFrameReceived < latestFrame.FrameNumber {
e.latestFrameReceived = latestFrame.FrameNumber
}
e.frameProverTriesMx.Lock()
e.frameProverTries = e.dataTimeReel.GetFrameProverTries()
e.frameProverTriesMx.Unlock()
trie := e.GetFrameProverTries()[0]
selBI, _ := dataFrame.GetSelector()
@ -118,8 +121,7 @@ func (e *DataClockConsensusEngine) processFrame(
return nextFrame
} else {
e.announcedJoin++
if e.announcedJoin < 5 && !e.IsInProverTrie(e.pubSub.GetPeerID()) &&
if !e.IsInProverTrie(e.pubSub.GetPeerID()) &&
dataFrame.Timestamp > time.Now().UnixMilli()-30000 {
e.logger.Info("announcing prover join")
e.announceProverJoin()