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

rename queueGossip() to enqueueGossip().

Browse Source
This commit is contained in:
Raúl Kripalani 2019-10-12 21:50:20 +09:00
parent 2a90debb89
commit 8d7838b031
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.
for _, p := range gpeers {
gs.queueGossip(p, &pb.ControlIHave{TopicID: &topic, MessageIDs: mids})
gs.enqueueGossip(p, &pb.ControlIHave{TopicID: &topic, MessageIDs: mids})
}
}
@ -555,7 +555,7 @@ func (gs *GossipSubRouter) flush() {
}
}
func (gs *GossipSubRouter) queueGossip(p peer.ID, ihave *pb.ControlIHave) {
func (gs *GossipSubRouter) enqueueGossip(p peer.ID, ihave *pb.ControlIHave) {
gossip := gs.gossip[p]
gossip = append(gossip, ihave)
gs.gossip[p] = gossip