all: migrate code from netaddr.FromStdAddr to Go 1.18

With caveat https://github.com/golang/go/issues/53607#issuecomment-1203466984
that then requires a new wrapper. But a simpler one at least.

Updates #5162

Change-Id: I0a5265065bfcd7f21e8dd65b2bd74cae90d76090
Signed-off-by: Brad Fitzpatrick <bradfitz@tailscale.com>
This commit is contained in:
Brad Fitzpatrick 2022-08-02 21:48:56 -07:00 committed by Brad Fitzpatrick
parent 7c7e23d87a
commit 5f6abcfa6f
7 changed files with 36 additions and 35 deletions

View File

@ -493,8 +493,8 @@ func (pln *peerAPIListener) serve() {
logf("peerapi: unexpected RemoteAddr %#v", c.RemoteAddr()) logf("peerapi: unexpected RemoteAddr %#v", c.RemoteAddr())
continue continue
} }
ipp, ok := netaddr.FromStdAddr(ta.IP, ta.Port, "") ipp := netaddr.Unmap(ta.AddrPort())
if !ok { if !ipp.IsValid() {
logf("peerapi: bogus TCPAddr %#v", ta) logf("peerapi: bogus TCPAddr %#v", ta)
c.Close() c.Close()
continue continue

View File

@ -10,7 +10,6 @@
package netaddr package netaddr
import ( import (
"math"
"net" "net"
"net/netip" "net/netip"
) )
@ -20,6 +19,13 @@ func IPv4(a, b, c, d uint8) netip.Addr {
return netip.AddrFrom4([4]byte{a, b, c, d}) return netip.AddrFrom4([4]byte{a, b, c, d})
} }
// Unmap returns the provided AddrPort with its Addr IP component Unmap'ed.
//
// See https://github.com/golang/go/issues/53607#issuecomment-1203466984
func Unmap(ap netip.AddrPort) netip.AddrPort {
return netip.AddrPortFrom(ap.Addr().Unmap(), ap.Port())
}
// FromStdIPNet returns an IPPrefix from the standard library's IPNet type. // FromStdIPNet returns an IPPrefix from the standard library's IPNet type.
// If std is invalid, ok is false. // If std is invalid, ok is false.
func FromStdIPNet(std *net.IPNet) (prefix netip.Prefix, ok bool) { func FromStdIPNet(std *net.IPNet) (prefix netip.Prefix, ok bool) {
@ -42,21 +48,3 @@ func FromStdIPNet(std *net.IPNet) (prefix netip.Prefix, ok bool) {
return netip.PrefixFrom(ip, ones), true return netip.PrefixFrom(ip, ones), true
} }
// FromStdAddr maps the components of a standard library TCPAddr or
// UDPAddr into an IPPort.
func FromStdAddr(stdIP net.IP, port int, zone string) (_ netip.AddrPort, ok bool) {
ip, ok := netip.AddrFromSlice(stdIP)
if !ok || port < 0 || port > math.MaxUint16 {
return
}
ip = ip.Unmap()
if zone != "" {
if ip.Is4() {
ok = false
return
}
ip = ip.WithZone(zone)
}
return netip.AddrPortFrom(ip, uint16(port)), true
}

View File

@ -273,7 +273,8 @@ func (c *Client) ReceiveSTUNPacket(pkt []byte, src netip.AddrPort) {
} }
rs.mu.Unlock() rs.mu.Unlock()
if ok { if ok {
if ipp, ok := netaddr.FromStdAddr(addr, int(port), ""); ok { ta := net.TCPAddr{IP: addr, Port: int(port)}
if ipp := netaddr.Unmap(ta.AddrPort()); ipp.IsValid() {
onDone(ipp) onDone(ipp)
} }
} }
@ -516,8 +517,8 @@ func (c *Client) readPackets(ctx context.Context, pc net.PacketConn) {
if !stun.Is(pkt) { if !stun.Is(pkt) {
continue continue
} }
if ipp, ok := netaddr.FromStdAddr(ua.IP, ua.Port, ua.Zone); ok { if ap := netaddr.Unmap(ua.AddrPort()); ap.IsValid() {
c.ReceiveSTUNPacket(pkt, ipp) c.ReceiveSTUNPacket(pkt, ap)
} }
} }
} }

View File

@ -167,9 +167,8 @@ func (d *TestIGD) servePxP() {
} }
return return
} }
ua := a.(*net.UDPAddr) src := netaddr.Unmap(a.(*net.UDPAddr).AddrPort())
src, ok := netaddr.FromStdAddr(ua.IP, ua.Port, ua.Zone) if !src.IsValid() {
if !ok {
panic("bogus addr") panic("bogus addr")
} }
pkt := buf[:n] pkt := buf[:n]

View File

@ -531,8 +531,8 @@ func (c *Client) createOrGetMapping(ctx context.Context) (external netip.AddrPor
return netip.AddrPort{}, NoMappingError{ErrNoPortMappingServices} return netip.AddrPort{}, NoMappingError{ErrNoPortMappingServices}
} }
srcu := srci.(*net.UDPAddr) srcu := srci.(*net.UDPAddr)
src, ok := netaddr.FromStdAddr(srcu.IP, srcu.Port, srcu.Zone) src := netaddr.Unmap(srcu.AddrPort())
if !ok { if !src.IsValid() {
continue continue
} }
if src == pxpAddr { if src == pxpAddr {

View File

@ -3037,8 +3037,8 @@ func (c *RebindingUDPConn) ReadFromNetaddr(b []byte) (n int, ipp netip.AddrPort,
return 0, netip.AddrPort{}, fmt.Errorf("RebindingUDPConn.ReadFromNetaddr: underlying connection returned address of type %T, want *netaddr.UDPAddr", addr) return 0, netip.AddrPort{}, fmt.Errorf("RebindingUDPConn.ReadFromNetaddr: underlying connection returned address of type %T, want *netaddr.UDPAddr", addr)
} }
if pAddr != nil { if pAddr != nil {
ipp, ok = netaddr.FromStdAddr(pAddr.IP, pAddr.Port, pAddr.Zone) ipp = netaddr.Unmap(pAddr.AddrPort())
if !ok { if !ipp.IsValid() {
return 0, netip.AddrPort{}, errors.New("netaddr.FromStdAddr failed") return 0, netip.AddrPort{}, errors.New("netaddr.FromStdAddr failed")
} }
} }

View File

@ -848,7 +848,7 @@ func (ns *Impl) forwardTCP(client *gonet.TCPConn, clientRemoteIP netip.Addr, wq
} }
defer server.Close() defer server.Close()
backendLocalAddr := server.LocalAddr().(*net.TCPAddr) backendLocalAddr := server.LocalAddr().(*net.TCPAddr)
backendLocalIPPort, _ := netaddr.FromStdAddr(backendLocalAddr.IP, backendLocalAddr.Port, backendLocalAddr.Zone) backendLocalIPPort := netaddr.Unmap(backendLocalAddr.AddrPort())
ns.e.RegisterIPPortIdentity(backendLocalIPPort, clientRemoteIP) ns.e.RegisterIPPortIdentity(backendLocalIPPort, clientRemoteIP)
defer ns.e.UnregisterIPPortIdentity(backendLocalIPPort) defer ns.e.UnregisterIPPortIdentity(backendLocalIPPort)
connClosed := make(chan error, 2) connClosed := make(chan error, 2)
@ -978,8 +978,9 @@ func (ns *Impl) forwardUDP(client *gonet.UDPConn, wq *waiter.Queue, clientAddr,
} }
} }
backendLocalAddr := backendConn.LocalAddr().(*net.UDPAddr) backendLocalAddr := backendConn.LocalAddr().(*net.UDPAddr)
backendLocalIPPort, ok := netaddr.FromStdAddr(backendListenAddr.IP, backendLocalAddr.Port, backendLocalAddr.Zone)
if !ok { backendLocalIPPort := netip.AddrPortFrom(backendListenAddr.AddrPort().Addr().Unmap().WithZone(backendLocalAddr.Zone), backendLocalAddr.AddrPort().Port())
if !backendLocalIPPort.IsValid() {
ns.logf("could not get backend local IP:port from %v:%v", backendLocalAddr.IP, backendLocalAddr.Port) ns.logf("could not get backend local IP:port from %v:%v", backendLocalAddr.IP, backendLocalAddr.Port)
} }
if isLocal { if isLocal {
@ -1061,5 +1062,17 @@ func stringifyTEI(tei stack.TransportEndpointID) string {
} }
func ipPortOfNetstackAddr(a tcpip.Address, port uint16) (ipp netip.AddrPort, ok bool) { func ipPortOfNetstackAddr(a tcpip.Address, port uint16) (ipp netip.AddrPort, ok bool) {
return netaddr.FromStdAddr(net.IP(a), int(port), "") // TODO(bradfitz): can do without allocs var a16 [16]byte
copy(a16[:], a)
switch len(a) {
case 4:
return netip.AddrPortFrom(
netip.AddrFrom4(*(*[4]byte)(a16[:4])).Unmap(),
port,
), true
case 16:
return netip.AddrPortFrom(netip.AddrFrom16(a16).Unmap(), port), true
default:
return ipp, false
}
} }