aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--dex/peer.go17
1 files changed, 17 insertions, 0 deletions
diff --git a/dex/peer.go b/dex/peer.go
index 64798aaaf..d0b81a03e 100644
--- a/dex/peer.go
+++ b/dex/peer.go
@@ -201,7 +201,24 @@ func newPeer(version int, p *p2p.Peer, rw p2p.MsgReadWriter) *peer {
// transaction and notary node records broadcasts into the remote peer.
// The goal is to have an async writer that does not lock up node internals.
func (p *peer) broadcast() {
+ queuedVotes := make([]*coreTypes.Vote, 0, maxQueuedVotes)
for {
+ PriorityBroadcastVote:
+ for {
+ select {
+ case votes := <-p.queuedVotes:
+ queuedVotes = append(queuedVotes, votes...)
+ default:
+ break PriorityBroadcastVote
+ }
+ }
+ if len(queuedVotes) != 0 {
+ if err := p.SendVotes(queuedVotes); err != nil {
+ return
+ }
+ p.Log().Trace("Broadcast votes", "count", len(queuedVotes))
+ queuedVotes = queuedVotes[:0]
+ }
select {
case records := <-p.queuedRecords:
if err := p.SendNodeRecords(records); err != nil {