summaryrefslogtreecommitdiffhomepage
path: root/wgengine
diff options
context:
space:
mode:
authorJosh Bleecher Snyder <josh@tailscale.com>2021-05-12 16:21:22 -0700
committerJosh Bleecher Snyder <josh@tailscale.com>2021-05-12 16:25:04 -0700
commit920145a836e8eace4697216be8a0f7e4755b08c8 (patch)
tree32409190cc130debb9cfb142fd0a25e860f2eaac /wgengine
parentebcd7ab89042fb660a96a75a360ce17140084435 (diff)
downloadtailscale-josh/NewIPPort.tar.xz
tailscale-josh/NewIPPort.zip
netaddr.NewIPPortjosh/NewIPPort
Diffstat (limited to 'wgengine')
-rw-r--r--wgengine/filter/filter_test.go8
-rw-r--r--wgengine/magicsock/magicsock.go11
-rw-r--r--wgengine/netstack/netstack.go4
3 files changed, 10 insertions, 13 deletions
diff --git a/wgengine/filter/filter_test.go b/wgengine/filter/filter_test.go
index ca807a5fd..8a4fab6eb 100644
--- a/wgengine/filter/filter_test.go
+++ b/wgengine/filter/filter_test.go
@@ -425,10 +425,10 @@ func TestLoggingPrivacy(t *testing.T) {
f.logIPs = logB.IPSet()
var (
- ts4 = netaddr.IPPort{IP: tsaddr.CGNATRange().IP.Next(), Port: 1234}
- internet4 = netaddr.IPPort{IP: netaddr.MustParseIP("8.8.8.8"), Port: 1234}
- ts6 = netaddr.IPPort{IP: tsaddr.TailscaleULARange().IP.Next(), Port: 1234}
- internet6 = netaddr.IPPort{IP: netaddr.MustParseIP("2001::1"), Port: 1234}
+ ts4 = netaddr.NewIPPort(tsaddr.CGNATRange().IP.Next(), 1234)
+ internet4 = netaddr.NewIPPort(netaddr.MustParseIP("8.8.8.8"), 1234)
+ ts6 = netaddr.NewIPPort(tsaddr.TailscaleULARange().IP.Next(), 1234)
+ internet6 = netaddr.NewIPPort(netaddr.MustParseIP("2001::1"), 1234)
)
tests := []struct {
diff --git a/wgengine/magicsock/magicsock.go b/wgengine/magicsock/magicsock.go
index 4291e13d9..0ee7e2fe8 100644
--- a/wgengine/magicsock/magicsock.go
+++ b/wgengine/magicsock/magicsock.go
@@ -965,7 +965,7 @@ func (c *Conn) goDerpConnect(node int) {
if node == 0 {
return
}
- go c.derpWriteChanOfAddr(netaddr.IPPort{IP: derpMagicIPAddr, Port: uint16(node)}, key.Public{})
+ go c.derpWriteChanOfAddr(netaddr.NewIPPort(derpMagicIPAddr, uint16(node)), key.Public{})
}
// determineEndpoints returns the machine's endpoint addresses. It
@@ -1037,7 +1037,7 @@ func (c *Conn) determineEndpoints(ctx context.Context) ([]tailcfg.Endpoint, erro
ips = loopback
}
for _, ip := range ips {
- addAddr(netaddr.IPPort{IP: ip, Port: uint16(localAddr.Port)}, tailcfg.EndpointLocal)
+ addAddr(netaddr.NewIPPort(ip, uint16(localAddr.Port)), tailcfg.EndpointLocal)
}
} else {
// Our local endpoint is bound to a particular address.
@@ -1676,7 +1676,7 @@ func (c *Conn) processDERPReadResult(dm derpReadResult, b []byte) (n int, ep con
return 0, nil
}
- ipp := netaddr.IPPort{IP: derpMagicIPAddr, Port: uint16(regionID)}
+ ipp := netaddr.NewIPPort(derpMagicIPAddr, uint16(regionID))
if c.handleDiscoMessage(b[:n], ipp) {
return 0, nil
}
@@ -3254,10 +3254,7 @@ func (de *discoEndpoint) initFakeUDPAddr() {
addr[0] = 0xfd
addr[1] = 0x00
binary.BigEndian.PutUint64(addr[2:], uint64(reflect.ValueOf(de).Pointer()))
- de.fakeWGAddr = netaddr.IPPort{
- IP: netaddr.IPFrom16(addr),
- Port: 12345,
- }
+ de.fakeWGAddr = netaddr.NewIPPort(netaddr.IPFrom16(addr), 12345)
}
// isFirstRecvActivityInAwhile notes that receive activity has occured for this
diff --git a/wgengine/netstack/netstack.go b/wgengine/netstack/netstack.go
index a8c9aa6bd..d8607876c 100644
--- a/wgengine/netstack/netstack.go
+++ b/wgengine/netstack/netstack.go
@@ -316,7 +316,7 @@ func (m DNSMap) Resolve(ctx context.Context, addr string) (netaddr.IPPort, error
// Try MagicDNS first, else otherwise a real DNS lookup.
ip := m[host]
if !ip.IsZero() {
- return netaddr.IPPort{IP: ip, Port: uint16(port16)}, nil
+ return netaddr.NewIPPort(ip, uint16(port16)), nil
}
// No MagicDNS name so try real DNS.
@@ -329,7 +329,7 @@ func (m DNSMap) Resolve(ctx context.Context, addr string) (netaddr.IPPort, error
return netaddr.IPPort{}, fmt.Errorf("DNS lookup returned no results for %q", host)
}
ip, _ = netaddr.FromStdIP(ips[0])
- return netaddr.IPPort{IP: ip, Port: uint16(port16)}, nil
+ return netaddr.NewIPPort(ip, uint16(port16)), nil
}
func (ns *Impl) DialContextTCP(ctx context.Context, addr string) (*gonet.TCPConn, error) {