From 7b31349023ee5ac10c6214525e596b2a364d61c4 Mon Sep 17 00:00:00 2001 From: David Hill Date: Thu, 7 Apr 2016 13:33:43 -0400 Subject: [PATCH] Cleanup and optimize handleBroadcastMsg --- server.go | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/server.go b/server.go index e54b77310..195794b07 100644 --- a/server.go +++ b/server.go @@ -1253,19 +1253,17 @@ func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { // from the peerHandler goroutine. func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { state.forAllPeers(func(sp *serverPeer) { - excluded := false + if !sp.Connected() { + return + } + for _, ep := range bmsg.excludePeers { if sp == ep { - excluded = true + return } } - // Don't broadcast to still connecting outbound peers . - if !sp.Connected() { - excluded = true - } - if !excluded { - sp.QueueMessage(bmsg.message, nil) - } + + sp.QueueMessage(bmsg.message, nil) }) }