aboutsummaryrefslogtreecommitdiffstats
path: root/eth/handler.go
diff options
context:
space:
mode:
authorMiya Chen <miyatlchen@gmail.com>2017-10-10 16:53:05 +0800
committerPéter Szilágyi <peterke@gmail.com>2017-10-10 16:53:05 +0800
commit40a3856af9d28fce6550509a01cf926525da5d22 (patch)
tree453bc3d073c053f555741a9a0126f7dee7597e76 /eth/handler.go
parent89860f4197cb9bd2249c9ac4d854f3bc401a7926 (diff)
downloadgo-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.tar
go-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.tar.gz
go-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.tar.bz2
go-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.tar.lz
go-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.tar.xz
go-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.tar.zst
go-tangerine-40a3856af9d28fce6550509a01cf926525da5d22.zip
eth/fetcher: check the origin of filter tasks (#14975)
* eth/fetcher: check the origin of filter task * eth/fetcher: add some details to fetcher logs
Diffstat (limited to 'eth/handler.go')
-rw-r--r--eth/handler.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/eth/handler.go b/eth/handler.go
index cee719ddb..bec5126dc 100644
--- a/eth/handler.go
+++ b/eth/handler.go
@@ -450,7 +450,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
return nil
}
// Irrelevant of the fork checks, send the header to the fetcher just in case
- headers = pm.fetcher.FilterHeaders(headers, time.Now())
+ headers = pm.fetcher.FilterHeaders(p.id, headers, time.Now())
}
if len(headers) > 0 || !filter {
err := pm.downloader.DeliverHeaders(p.id, headers)
@@ -503,7 +503,7 @@ func (pm *ProtocolManager) handleMsg(p *peer) error {
// Filter out any explicitly requested bodies, deliver the rest to the downloader
filter := len(trasactions) > 0 || len(uncles) > 0
if filter {
- trasactions, uncles = pm.fetcher.FilterBodies(trasactions, uncles, time.Now())
+ trasactions, uncles = pm.fetcher.FilterBodies(p.id, trasactions, uncles, time.Now())
}
if len(trasactions) > 0 || len(uncles) > 0 || !filter {
err := pm.downloader.DeliverBodies(p.id, trasactions, uncles)