logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-05-28 11:29:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

rename pushGossip to queueGossip for accuracy.

Browse Source
This commit is contained in:
Raúl Kripalani 2019-10-06 18:53:05 +09:00
parent 9103afa349
commit 2a90debb89
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gossipsub.go
View File

@ -535,7 +535,7 @@ func (gs *GossipSubRouter) emitGossip(topic string, exclude map[peer.ID]struct{}
// Emit the IHAVE gossip to the selected peers. // Emit the IHAVE gossip to the selected peers.
for _, p := range gpeers { for _, p := range gpeers {
gs.pushGossip(p, &pb.ControlIHave{TopicID: &topic, MessageIDs: mids}) gs.queueGossip(p, &pb.ControlIHave{TopicID: &topic, MessageIDs: mids})
} }
} }
@ -555,7 +555,7 @@ func (gs *GossipSubRouter) flush() {
} }
} }
func (gs *GossipSubRouter) pushGossip(p peer.ID, ihave *pb.ControlIHave) { func (gs *GossipSubRouter) queueGossip(p peer.ID, ihave *pb.ControlIHave) {
gossip := gs.gossip[p] gossip := gs.gossip[p]
gossip = append(gossip, ihave) gossip = append(gossip, ihave)
gs.gossip[p] = gossip gs.gossip[p] = gossip