diff --git a/txpool/fetch.go b/txpool/fetch.go index d2169d0f4..7c53e84f5 100644 --- a/txpool/fetch.go +++ b/txpool/fetch.go @@ -17,6 +17,7 @@ package txpool import ( + "bytes" "context" "errors" "fmt" @@ -315,6 +316,13 @@ func (f *Fetch) handleInboundMessage(ctx context.Context, req *sentry.InboundMes if len(txs.txs) == 0 { return nil } + if ASSERT { + for i := 0; i < txs.senders.Len(); i++ { + if bytes.Equal(txs.senders.At(i), EmptyAddr[:]) { + panic("here") + } + } + } return f.pool.OnNewTxs(ctx, f.coreDB, txs, f.senders) default: //defer log.Info("dropped", "id", req.Id)