From f6081fb061b2a59227ed58a5678eb3c849c553c5 Mon Sep 17 00:00:00 2001 From: vyzo Date: Sat, 13 Jan 2018 21:56:57 +0200 Subject: [PATCH] pushMsg should just call maybePublishMessage when it doesn't need validation --- floodsub.go | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/floodsub.go b/floodsub.go index 8455dad..c3f6aa5 100644 --- a/floodsub.go +++ b/floodsub.go @@ -386,14 +386,7 @@ func (p *PubSub) pushMsg(subs []*Subscription, src peer.ID, msg *Message) { return } - sreq := &sendReq{from: src, msg: msg} - select { - case p.sendMsg <- sreq: - default: - go func() { - p.sendMsg <- sreq - }() - } + p.maybePublishMessage(src, msg.Message) } // validate performs validation and only sends the message if all validators succeed