From 5d1b572035e444761c61029be6a243df9e831081 Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Sun, 17 Nov 2024 16:00:51 -0600 Subject: [PATCH] switch validators to sync --- node/consensus/data/data_clock_consensus_engine.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/node/consensus/data/data_clock_consensus_engine.go b/node/consensus/data/data_clock_consensus_engine.go index 910c327..65afc91 100644 --- a/node/consensus/data/data_clock_consensus_engine.go +++ b/node/consensus/data/data_clock_consensus_engine.go @@ -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)