status-im/go-libp2p-pubsub
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

pushMsg should just call maybePublishMessage when it doesn't need validation

Browse Source
This commit is contained in:
vyzo 2018-01-13 21:56:57 +02:00
parent 473a5d2873
commit f6081fb061
1 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
floodsub.go
View File

@ -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