apps/peerguard
1
0
Fork 0
mirror of https://github.com/rkonfj/peerguard.git synced 2024-08-11 11:00:25 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

disco: keep all hard NATed public addrs

Browse Source
This commit is contained in:
rkonfj 2024-08-02 20:14:49 +08:00
parent 77b8312131
commit be4c2ab5c9
No known key found for this signature in database
GPG Key ID: 9595E3A991503741
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
disco/udp.go
View File

@ -359,7 +359,6 @@ func (c *UDPConn) runSTUNEventLoop() {
}
tx.addrs = append(tx.addrs, addr.String())
natAddrFound := func(t NATType) {
c.stunSessionManager.Remove(string(txid[:]))
if tx.peerID == "" {
c.natType = t
slog.Log(context.Background(), -1, "NATAddrFound", "addr", addr, "type", t)
@ -368,11 +367,19 @@ func (c *UDPConn) runSTUNEventLoop() {
c.udpAddrSends <- &PeerUDPAddr{ID: tx.peerID, Addr: addr, Type: t}
}
if len(tx.addrs) == 1 {
tx.timer = time.AfterFunc(3*time.Second, func() { natAddrFound(Unknown) })
tx.timer = time.AfterFunc(3*time.Second, func() {
c.stunSessionManager.Remove(string(txid[:]))
if len(tx.addrs) > 1 {
natAddrFound(Hard)
return
}
natAddrFound(Unknown)
})
continue
}
tx.timer.Stop()
if len(slices.Compact(tx.addrs)) == 1 {
tx.timer.Stop()
c.stunSessionManager.Remove(string(txid[:]))
natAddrFound(Easy)
continue
}