aboutsummaryrefslogtreecommitdiffstats
path: root/eth
diff options
context:
space:
mode:
authorBas van Kervel <basvankervel@gmail.com>2016-04-28 18:33:42 +0800
committerBas van Kervel <basvankervel@gmail.com>2016-04-28 18:33:42 +0800
commit48cc36ce83efeb08c1de01c943d4e522f9c3b7ff (patch)
treea8f86c07d433aa2601fe4999753f447d5317f856 /eth
parent123aa659e4e2bdb9121f787ee8cd68acc9a4fe4c (diff)
downloadgo-tangerine-48cc36ce83efeb08c1de01c943d4e522f9c3b7ff.tar.gz
go-tangerine-48cc36ce83efeb08c1de01c943d4e522f9c3b7ff.tar.zst
go-tangerine-48cc36ce83efeb08c1de01c943d4e522f9c3b7ff.zip
eth/filters: ignore logs that don't match filter criteria on chain reorg
Diffstat (limited to 'eth')
-rw-r--r--eth/filters/filter_system.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/eth/filters/filter_system.go b/eth/filters/filter_system.go
index 29968530a..4343dfa21 100644
--- a/eth/filters/filter_system.go
+++ b/eth/filters/filter_system.go
@@ -164,7 +164,7 @@ func (fs *FilterSystem) filterLoop() {
fs.filterMu.RLock()
for _, filter := range fs.logFilters {
if filter.LogCallback != nil && !filter.created.After(event.Time) {
- for _, removedLog := range ev.Logs {
+ for _, removedLog := range filter.FilterLogs(ev.Logs) {
filter.LogCallback(removedLog, true)
}
}