code: func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) {
  	state.forAllPeers(func(sp *serverPeer) {
  		if !sp.Connected() {
  			return
  		}
  
  		for _, ep := range bmsg.excludePeers {
  			if sp == ep {
  				return
  			}
  		}
  
  		sp.QueueMessage(bmsg.message, nil)
  	})
  }
docs: // handleBroadcastMsg deals with broadcasting messages to peers.  It is invoked
  // from the peerHandler goroutine.