aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorFelföldi Zsolt <zsfelfoldi@gmail.com>2019-03-25 15:17:55 +0800
committerPéter Szilágyi <peterke@gmail.com>2019-03-25 15:17:55 +0800
commite852505acedf6d3728330852b2d816ebf12a2cfb (patch)
tree6460a78d53ec132567acafc1d358233db6918009
parent2f5b6cb442dd1ab20279603de938e5b60e3122fb (diff)
downloadgo-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.tar
go-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.tar.gz
go-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.tar.bz2
go-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.tar.lz
go-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.tar.xz
go-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.tar.zst
go-tangerine-e852505acedf6d3728330852b2d816ebf12a2cfb.zip
les: fix block announcements (#19322)
-rw-r--r--les/server.go3
1 files changed, 1 insertions, 2 deletions
diff --git a/les/server.go b/les/server.go
index 270640f02..3716685e1 100644
--- a/les/server.go
+++ b/les/server.go
@@ -280,8 +280,8 @@ func (pm *ProtocolManager) blockLoop() {
)
for _, p := range peers {
+ p := p
switch p.announceType {
-
case announceTypeSimple:
p.queueSend(func() { p.SendAnnounce(announce) })
case announceTypeSigned:
@@ -290,7 +290,6 @@ func (pm *ProtocolManager) blockLoop() {
signedAnnounce.sign(pm.server.privateKey)
signed = true
}
-
p.queueSend(func() { p.SendAnnounce(signedAnnounce) })
}
}