status-im
/
go-libp2p
mirror of https://github.com/status-im/go-libp2p.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

some tweaks 

- select 25 of 50 relays instead of 20
- increase connect timeout to 30s
This commit is contained in:
vyzo 2019-04-20 11:17:10 +03:00
parent f9e182f747
commit 4629431a12
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
p2p/host/relay/autorelay.go
View File

@ -162,7 +162,7 @@ again:
log.Debugf("discovered %d relays", len(pis)) log.Debugf("discovered %d relays", len(pis))
pis = ar.selectRelays(ctx, pis, 20, 50) pis = ar.selectRelays(ctx, pis, 25, 50)
update := 0 update := 0
for _, pi := range pis { for _, pi := range pis {
@ -173,7 +173,7 @@ again:
} }
ar.mx.Unlock() ar.mx.Unlock()
cctx, cancel := context.WithTimeout(ctx, 15*time.Second) cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
err = ar.host.Connect(cctx, pi) err = ar.host.Connect(cctx, pi)
cancel() cancel()
if err != nil { if err != nil {
@ -254,6 +254,8 @@ func (ar *AutoRelay) selectRelays(ctx context.Context, pis []pstore.PeerInfo, co
resultCh <- queryResult{pi: pstore.PeerInfo{ID: pi.ID, Addrs: addrs}, err: nil} resultCh <- queryResult{pi: pstore.PeerInfo{ID: pi.ID, Addrs: addrs}, err: nil}
continue continue
} }
// no known addrs, do a query
go func(p peer.ID) { go func(p peer.ID) {
pi, err := ar.router.FindPeer(qctx, p) pi, err := ar.router.FindPeer(qctx, p)
if err != nil { if err != nil {