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

switch validators to sync

Browse Source
This commit is contained in:
Cassandra Heart 2024-11-17 16:00:51 -06:00
parent 063102eab2
commit 5d1b572035
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -315,9 +315,9 @@ func (e *DataClockConsensusEngine) Start() <-chan error {
go e.runInfoMessageHandler()
e.logger.Info("subscribing to pubsub messages")
e.pubSub.RegisterValidator(e.frameFilter, e.validateFrameMessage, false)
e.pubSub.RegisterValidator(e.txFilter, e.validateTxMessage, false)
e.pubSub.RegisterValidator(e.infoFilter, e.validateInfoMessage, false)
e.pubSub.RegisterValidator(e.frameFilter, e.validateFrameMessage, true)
e.pubSub.RegisterValidator(e.txFilter, e.validateTxMessage, true)
e.pubSub.RegisterValidator(e.infoFilter, e.validateInfoMessage, true)
e.pubSub.Subscribe(e.frameFilter, e.handleFrameMessage)
e.pubSub.Subscribe(e.txFilter, e.handleTxMessage)
e.pubSub.Subscribe(e.infoFilter, e.handleInfoMessage)