diff --git a/txpool/fetch.go b/txpool/fetch.go index e19cb48e1..f7fd3d43a 100644 --- a/txpool/fetch.go +++ b/txpool/fetch.go @@ -84,7 +84,7 @@ func NewFetch(ctx context.Context, sentryClients: sentryClients, statusData: statusData, pool: pool, - logger: logger.Named("txpool.fetch"), + logger: logger.Named("[TxPool.Fetch]"), } } diff --git a/txpool/fetch_test.go b/txpool/fetch_test.go index 1a7dd8490..c10eaf21c 100644 --- a/txpool/fetch_test.go +++ b/txpool/fetch_test.go @@ -115,7 +115,5 @@ func TestSendTxPropagate(t *testing.T) { first := calls[0].OutboundMessageData require.Equal(t, sentry.MessageId_NEW_POOLED_TRANSACTION_HASHES_66, first.Id) require.Equal(t, 68, len(first.Data)) - t.Fail() }) - } diff --git a/txpool/send.go b/txpool/send.go index f5ff88547..9e8234f3a 100644 --- a/txpool/send.go +++ b/txpool/send.go @@ -43,7 +43,7 @@ func NewSend(ctx context.Context, sentryClients []sentry.SentryClient, pool Pool ctx: ctx, pool: pool, sentryClients: sentryClients, - logger: logger.Named("txpool.send"), + logger: logger.Named("[TxPool.Send]"), } } @@ -121,7 +121,6 @@ func (f *Send) BroadcastLocalPooledTxs(txs Hashes) (sentToPeers int) { return } avgPeersPerSent66 += len(peers.Peers) - f.logger.Warnf("yay: %d", avgPeersPerSent66) } } }