mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-01 00:31:21 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

encode txs

Browse Source
This commit is contained in:
alex.sharov 2021-07-26 09:39:37 +07:00
parent 3bf11f8ad3
commit 334058cf5d
3 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
txpool/fetch.go
View File

@ -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]"),
}
}

2
txpool/fetch_test.go
View File

@ -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()
})
}

3
txpool/send.go
View File

@ -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)
}
}
}