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

envelope (#518)

Browse Source
This commit is contained in:
Giulio rebuffo 2022-07-08 16:25:51 +02:00 committed by GitHub
parent 95e361fa1e
commit cf57648d7d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
txpool/fetch.go
View File

@ -444,7 +444,7 @@ func (f *Fetch) handleStateChanges(ctx context.Context, client StateChangesClien
for i := range change.Txs { for i := range change.Txs {
minedTxs.Txs[i] = &types2.TxSlot{} minedTxs.Txs[i] = &types2.TxSlot{}
if err = f.threadSafeParseStateChangeTxn(func(parseContext *types2.TxParseContext) error { if err = f.threadSafeParseStateChangeTxn(func(parseContext *types2.TxParseContext) error {
_, err := parseContext.ParseTransaction(change.Txs[i], 0, minedTxs.Txs[i], minedTxs.Senders.At(i), true /* hasEnvelope */, nil) _, err := parseContext.ParseTransaction(change.Txs[i], 0, minedTxs.Txs[i], minedTxs.Senders.At(i), false /* hasEnvelope */, nil)
return err return err
}); err != nil { }); err != nil {
log.Warn("stream.Recv", "err", err) log.Warn("stream.Recv", "err", err)
@ -457,7 +457,7 @@ func (f *Fetch) handleStateChanges(ctx context.Context, client StateChangesClien
for i := range change.Txs { for i := range change.Txs {
unwindTxs.Txs[i] = &types2.TxSlot{} unwindTxs.Txs[i] = &types2.TxSlot{}
if err = f.threadSafeParseStateChangeTxn(func(parseContext *types2.TxParseContext) error { if err = f.threadSafeParseStateChangeTxn(func(parseContext *types2.TxParseContext) error {
_, err = parseContext.ParseTransaction(change.Txs[i], 0, unwindTxs.Txs[i], unwindTxs.Senders.At(i), true /* hasEnvelope */, nil) _, err = parseContext.ParseTransaction(change.Txs[i], 0, unwindTxs.Txs[i], unwindTxs.Senders.At(i), false /* hasEnvelope */, nil)
return err return err
}); err != nil { }); err != nil {
log.Warn("stream.Recv", "err", err) log.Warn("stream.Recv", "err", err)