Skip to content

Commit 48cc36c

Browse files
committed
eth/filters: ignore logs that don't match filter criteria on chain reorg
1 parent 123aa65 commit 48cc36c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

eth/filters/filter_system.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ func (fs *FilterSystem) filterLoop() {
164164
fs.filterMu.RLock()
165165
for _, filter := range fs.logFilters {
166166
if filter.LogCallback != nil && !filter.created.After(event.Time) {
167-
for _, removedLog := range ev.Logs {
167+
for _, removedLog := range filter.FilterLogs(ev.Logs) {
168168
filter.LogCallback(removedLog, true)
169169
}
170170
}

0 commit comments

Comments
 (0)