From 2ac19f2157e77cb632dc02bf63cecb6840d7bf67 Mon Sep 17 00:00:00 2001 From: Garrett Thornburg Date: Fri, 1 Sep 2017 23:10:06 -0400 Subject: [PATCH] Drop announce messages to peers when their buffer is full --- floodsub.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/floodsub.go b/floodsub.go index cb98445..c6f67c1 100644 --- a/floodsub.go +++ b/floodsub.go @@ -230,8 +230,12 @@ func (p *PubSub) announce(topic string, sub bool) { } out := rpcWithSubs(subopt) - for _, peer := range p.peers { - peer <- out + for pid, peer := range p.peers { + select { + case peer <- out: + default: + log.Infof("dropping announce message to peer %s: queue full", pid) + } } }