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

shift the message history window at the end of the heartbeat

Browse Source
This commit is contained in:
vyzo 2018-02-21 10:59:00 +02:00 committed by Steven Allen
parent 64cdbbabbc
commit 599ccffecd
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
gossipsub.go
View File

@ -324,8 +324,6 @@ func (gs *GossipSubRouter) heartbeatTimer() {
} }
func (gs *GossipSubRouter) heartbeat() { func (gs *GossipSubRouter) heartbeat() {
gs.mcache.Shift()
// flush pending control message from retries and gossip // flush pending control message from retries and gossip
// that hasn't been piggybacked since the last heartbeat // that hasn't been piggybacked since the last heartbeat
gs.flush() gs.flush()
@ -441,6 +439,9 @@ func (gs *GossipSubRouter) heartbeat() {
} }
} }
} }
// advance the message history window
gs.mcache.Shift()
} }
func (gs *GossipSubRouter) flush() { func (gs *GossipSubRouter) flush() {