les: fix block announcements

This commit is contained in:
Zsolt Felfoldi 2019-03-23 20:02:07 +01:00
parent 2f5b6cb442
commit 11914ce557

View file

@ -280,8 +280,8 @@ func (pm *ProtocolManager) blockLoop() {
) )
for _, p := range peers { for _, p := range peers {
p := p
switch p.announceType { switch p.announceType {
case announceTypeSimple: case announceTypeSimple:
p.queueSend(func() { p.SendAnnounce(announce) }) p.queueSend(func() { p.SendAnnounce(announce) })
case announceTypeSigned: case announceTypeSigned:
@ -290,7 +290,6 @@ func (pm *ProtocolManager) blockLoop() {
signedAnnounce.sign(pm.server.privateKey) signedAnnounce.sign(pm.server.privateKey)
signed = true signed = true
} }
p.queueSend(func() { p.SendAnnounce(signedAnnounce) }) p.queueSend(func() { p.SendAnnounce(signedAnnounce) })
} }
} }