7 flog "github.com/anacrolix/log"
9 "github.com/syncthing/syncthing/lib/nat"
10 "github.com/syncthing/syncthing/lib/upnp"
13 func addPortMapping(d nat.Device, proto nat.Protocol, internalPort int, debug bool) {
14 externalPort, err := d.AddPortMapping(proto, internalPort, internalPort, "anacrolix/torrent", 0)
16 log.Printf("error adding %s port mapping: %s", proto, err)
17 } else if externalPort != internalPort {
18 log.Printf("external port %d does not match internal port %d in port mapping", externalPort, internalPort)
20 log.Printf("forwarded external %s port %d", proto, externalPort)
24 func (cl *Client) forwardPort() {
27 if cl.config.NoDefaultPortForwarding {
31 ds := upnp.Discover(0, 2*time.Second)
33 flog.Default.Handle(flog.Fmsg("discovered %d upnp devices", len(ds)))
34 port := cl.incomingPeerPort()
36 for _, d := range ds {
37 go addPortMapping(d, nat.TCP, port, cl.config.Debug)
38 go addPortMapping(d, nat.UDP, port, cl.config.Debug)