wire up logger to mempool reactor (#9885)

This commit is contained in:
Callum Waters
2022-12-15 23:49:57 +01:00
committed by GitHub
parent 189d120c9f
commit 1a5d5ed63b

View File

@@ -226,6 +226,7 @@ func createMempoolAndMempoolReactor(
memplMetrics *mempl.Metrics,
logger log.Logger,
) (mempl.Mempool, p2p.Reactor) {
logger = logger.With("module", "mempool")
switch config.Mempool.Version {
case cfg.MempoolV1:
mp := mempoolv1.NewTxMempool(
@@ -245,6 +246,7 @@ func createMempoolAndMempoolReactor(
if config.Consensus.WaitForTxs() {
mp.EnableTxsAvailable()
}
reactor.SetLogger(logger)
return mp, reactor
@@ -267,6 +269,7 @@ func createMempoolAndMempoolReactor(
if config.Consensus.WaitForTxs() {
mp.EnableTxsAvailable()
}
reactor.SetLogger(logger)
return mp, reactor