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

retry dropped ANNOUNCE messages

Browse Source 
they are very important for correct topic state in the protocol, esp gossipsub
This commit is contained in:
vyzo 2018-02-22 10:58:58 +02:00 committed by Steven Allen
parent af061f5040
commit bfb0664581
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pubsub.go
View File

@ -4,6 +4,7 @@ import (
"context"
"encoding/binary"
"fmt"
"math/rand"
"sync/atomic"
"time"
@ -330,9 +331,18 @@ func (p *PubSub) announce(topic string, sub bool) {
select {
case peer <- out:
default:
// TODO this needs to be reliable, schedule it for piggybacking
// in a subsequent message or retry later
log.Infof("dropping announce message to peer %s: queue full", pid)
log.Infof("Can't send announce message to peer %s: queue full; scheduling retry", pid)
go p.announceRetry(topic, sub)
}
}
}
func (p *PubSub) announceRetry(topic string, sub bool) {
time.Sleep(time.Duration(1+rand.Intn(1000)) * time.Millisecond)
p.eval <- func() {
_, ok := p.myTopics[topic]
if (ok && sub) || (!ok && !sub) {
p.announce(topic, sub)
}
}
}