forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-27 15:16:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Add pending logs back

Browse source
This commit is contained in:
Jerry 2024-09-13 10:54:47 -07:00
parent b43fb1bf04
commit bb47bdaa4e
No known key found for this signature in database
GPG key ID: 5B33FA23CB103211
1 changed files with 16 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
eth/filters/filter_system.go
View file

@ -188,7 +188,7 @@ const (
// logsChanSize is the size of channel listening to LogsEvent. // logsChanSize is the size of channel listening to LogsEvent.
// Updated to fix TestEth2NeBlock testcase, as the feed was unable to send // Updated to fix TestEth2NeBlock testcase, as the feed was unable to send
// logs to the channel. todo: @anshalshukla // logs to the channel. todo: @anshalshukla
logsChanSize = 100 logsChanSize = 10
// chainEvChanSize is the size of channel listening to ChainEvent. // chainEvChanSize is the size of channel listening to ChainEvent.
chainEvChanSize = 10 chainEvChanSize = 10
// stateEvChanSize is the size of channel listening to StateSyncEvent. // stateEvChanSize is the size of channel listening to StateSyncEvent.
@ -427,6 +427,19 @@ func (es *EventSystem) handleLogs(filters filterIndex, ev []*types.Log) {
} }
} }
func (es *EventSystem) handlePendingLogs(filters filterIndex, ev []*types.Log) {
if len(ev) == 0 {
return
}
for _, f := range filters[PendingLogsSubscription] {
matchedLogs := filterLogs(ev, nil, f.logsCrit.ToBlock, f.logsCrit.Addresses, f.logsCrit.Topics)
if len(matchedLogs) > 0 {
f.logs <- matchedLogs
}
}
}
func (es *EventSystem) handleTxsEvent(filters filterIndex, ev core.NewTxsEvent) { func (es *EventSystem) handleTxsEvent(filters filterIndex, ev core.NewTxsEvent) {
for _, f := range filters[PendingTransactionsSubscription] { for _, f := range filters[PendingTransactionsSubscription] {
f.txs <- ev.Txs f.txs <- ev.Txs
@ -464,6 +477,8 @@ func (es *EventSystem) eventLoop() {
es.handleLogs(index, ev) es.handleLogs(index, ev)
case ev := <-es.rmLogsCh: case ev := <-es.rmLogsCh:
es.handleLogs(index, ev.Logs) es.handleLogs(index, ev.Logs)
case ev := <-es.pendingLogsCh:
es.handlePendingLogs(index, ev)
case ev := <-es.chainCh: case ev := <-es.chainCh:
es.handleChainEvent(index, ev) es.handleChainEvent(index, ev)
case ev := <-es.stateSyncCh: case ev := <-es.stateSyncCh: