logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-03 13:23:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

the sendMsg channel should yield pointers for consistency

Browse Source
This commit is contained in:
vyzo 2018-01-13 20:47:28 +02:00
parent 5ef13c764e
commit bf2151ba5f
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
floodsub.go
View File

@ -59,7 +59,7 @@ type PubSub struct {
topics map[string]map[peer.ID]struct{}
// sendMsg handles messages that have been validated
sendMsg chan sendReq
sendMsg chan *sendReq
peers map[peer.ID]chan *RPC
seenMessages *timecache.TimeCache
@ -100,7 +100,7 @@ func NewFloodSub(ctx context.Context, h host.Host, opts ...Option) (*PubSub, err
getPeers: make(chan *listPeerReq),
addSub: make(chan *addSubReq),
getTopics: make(chan *topicReq),
sendMsg: make(chan sendReq),
sendMsg: make(chan *sendReq),
myTopics: make(map[string]map[*Subscription]struct{}),
topics: make(map[string]map[peer.ID]struct{}),
peers: make(map[peer.ID]chan *RPC),
@ -367,7 +367,7 @@ func (p *PubSub) pushMsg(subs []*Subscription, src peer.ID, msg *Message) {
return
}
sreq := sendReq{from: src, msg: msg}
sreq := &sendReq{from: src, msg: msg}
select {
case p.sendMsg <- sreq:
default:
@ -422,7 +422,7 @@ loop:
}
// all validators were successful, send the message
p.sendMsg <- sendReq{
p.sendMsg <- &sendReq{
from: src,
msg: msg,
}