File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
pkg/coordinator/tasks/tx_pool_throughput_analysis Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -218,14 +218,14 @@ func (t *Task) Execute(ctx context.Context) error {
218218
219219 // Add a timeout of 180 seconds for reading transaction messages
220220 readChan := make (chan struct {
221- txs * eth.TransactionsPacket
221+ p2pTxs * eth.TransactionsPacket
222222 err error
223223 })
224224
225225 go func () {
226226 txs , err := conn .ReadTransactionMessages ()
227227 readChan <- struct {
228- txs * eth.TransactionsPacket
228+ p2pTxs * eth.TransactionsPacket
229229 err error
230230 }{txs , err }
231231 }()
@@ -237,7 +237,7 @@ func (t *Task) Execute(ctx context.Context) error {
237237 t .ctx .SetResult (types .TaskResultFailure )
238238 return nil
239239 }
240- gotTx += len (* result .txs )
240+ gotTx += len (* result .p2pTxs )
241241 case <- time .After (180 * time .Second ):
242242 t .logger .Warnf ("Timeout after 180 seconds while reading transaction messages. Re-sending transactions..." )
243243
You can’t perform that action at this time.
0 commit comments