wip: +1 backlogWorker

algorand · Sep 16, 2024 · d8bd008 · d8bd008
1 parent 658b00a
commit d8bd008
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/data/txHandler.go b/data/txHandler.go
@@ -261,7 +261,8 @@ func (handler *TxHandler) Start() {
 		{Tag: protocol.TxnTag, MessageHandler: network.ValidateHandleFunc(handler.validateIncomingTxMessage)},
 	})
 
-	handler.backlogWg.Add(2)
+	handler.backlogWg.Add(3)
+	go handler.backlogWorker()
 	go handler.backlogWorker()
 	go handler.backlogGaugeThread()
 	handler.streamVerifier.Start(handler.ctx)