| // Copyright 2018 The Fuchsia Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| //go:build !build_with_native_toolchain |
| |
| package fidlconv |
| |
| import ( |
| "fmt" |
| "syscall/zx" |
| |
| "fidl/fuchsia/net" |
| "fidl/fuchsia/net/multicast/admin" |
| "fidl/fuchsia/net/stack" |
| |
| "gvisor.dev/gvisor/pkg/tcpip" |
| "gvisor.dev/gvisor/pkg/tcpip/header" |
| "gvisor.dev/gvisor/pkg/tcpip/network/ipv4" |
| "gvisor.dev/gvisor/pkg/tcpip/network/ipv6" |
| tcpipstack "gvisor.dev/gvisor/pkg/tcpip/stack" |
| ) |
| |
| func ToTCPIPNetProto(v net.IpVersion) (tcpip.NetworkProtocolNumber, bool) { |
| switch v { |
| case net.IpVersionV4: |
| return header.IPv4ProtocolNumber, true |
| case net.IpVersionV6: |
| return header.IPv6ProtocolNumber, true |
| default: |
| return 0, false |
| } |
| } |
| |
| func ToTCPIPAddressAndProtocolNumber(addr net.IpAddress) (tcpip.Address, tcpip.NetworkProtocolNumber) { |
| switch tag := addr.Which(); tag { |
| case net.IpAddressIpv4: |
| return tcpip.Address(addr.Ipv4.Addr[:]), ipv4.ProtocolNumber |
| case net.IpAddressIpv6: |
| return tcpip.Address(addr.Ipv6.Addr[:]), ipv6.ProtocolNumber |
| default: |
| panic(fmt.Sprintf("invalid fuchsia.net/IpAddress tag %d", tag)) |
| } |
| } |
| |
| func ToTCPIPAddress(addr net.IpAddress) tcpip.Address { |
| a, _ := ToTCPIPAddressAndProtocolNumber(addr) |
| return a |
| } |
| |
| func ToNetIpAddress(addr tcpip.Address) net.IpAddress { |
| switch l := len(addr); l { |
| case header.IPv4AddressSize: |
| var v4 net.Ipv4Address |
| copy(v4.Addr[:], addr) |
| return net.IpAddressWithIpv4(v4) |
| case header.IPv6AddressSize: |
| var v6 net.Ipv6Address |
| copy(v6.Addr[:], addr) |
| return net.IpAddressWithIpv6(v6) |
| default: |
| panic(fmt.Sprintf("invalid IP address length = %d: %x", l, addr)) |
| } |
| } |
| |
| func ToNetSubnet(addressWithPrefix tcpip.AddressWithPrefix) net.Subnet { |
| return net.Subnet{ |
| Addr: ToNetIpAddress(addressWithPrefix.Address), |
| PrefixLen: uint8(addressWithPrefix.PrefixLen), |
| } |
| } |
| |
| func ToNetMacAddress(addr tcpip.LinkAddress) net.MacAddress { |
| if len(addr) != header.EthernetAddressSize { |
| panic(fmt.Sprintf("invalid link address length = %d: %x", len(addr), addr)) |
| } |
| var mac net.MacAddress |
| copy(mac.Octets[:], addr) |
| return mac |
| } |
| |
| func ToTCPIPLinkAddress(mac net.MacAddress) tcpip.LinkAddress { |
| return tcpip.LinkAddress(mac.Octets[:]) |
| } |
| |
| func ToNetSocketAddress(addr tcpip.FullAddress) net.SocketAddress { |
| var out net.SocketAddress |
| switch l := len(addr.Addr); l { |
| case header.IPv4AddressSize: |
| var v4 net.Ipv4Address |
| copy(v4.Addr[:], addr.Addr) |
| out.SetIpv4(net.Ipv4SocketAddress{ |
| Address: v4, |
| Port: addr.Port, |
| }) |
| case header.IPv6AddressSize: |
| var v6 net.Ipv6Address |
| copy(v6.Addr[:], addr.Addr) |
| |
| // Zone information should only be included for non-global addresses as the same |
| // address may be used across different zones. Note, there is only a single globally |
| // scoped zone where global addresses may only be used once so zone information is not |
| // needed for global addresses. See RFC 4007 section 6 for more details. |
| var zoneIdx uint64 |
| if header.IsV6LinkLocalUnicastAddress(addr.Addr) || header.IsV6LinkLocalMulticastAddress(addr.Addr) { |
| zoneIdx = uint64(addr.NIC) |
| } |
| out.SetIpv6(net.Ipv6SocketAddress{ |
| Address: v6, |
| Port: addr.Port, |
| ZoneIndex: zoneIdx, |
| }) |
| default: |
| panic(fmt.Sprintf("invalid IP address length = %d: %x", l, addr.Addr)) |
| } |
| return out |
| } |
| |
| // isLinkLocal determines if the given IPv6 address is link-local. This is the |
| // case when it has the fe80::/10 prefix. This check is used to determine when |
| // the NICID is relevant for a given IPv6 address. |
| func isLinkLocal(addr net.Ipv6Address) bool { |
| return addr.Addr[0] == 0xfe && addr.Addr[1]&0xc0 == 0x80 |
| } |
| |
| // ToNetSocketAddress converts a tcpip.FullAddress into a fidlnet.SocketAddress |
| // taking the protocol into consideration. If addr is unspecified, the |
| // unspecified address for the provided protocol is returned. |
| // |
| // Panics if protocol is neither IPv4 nor IPv6. |
| func ToNetSocketAddressWithProto(protocol tcpip.NetworkProtocolNumber, addr tcpip.FullAddress) net.SocketAddress { |
| switch protocol { |
| case ipv4.ProtocolNumber: |
| out := net.Ipv4SocketAddress{ |
| Port: addr.Port, |
| } |
| copy(out.Address.Addr[:], addr.Addr) |
| return net.SocketAddressWithIpv4(out) |
| case ipv6.ProtocolNumber: |
| out := net.Ipv6SocketAddress{ |
| Port: addr.Port, |
| } |
| if len(addr.Addr) == header.IPv4AddressSize { |
| // Copy address in v4-mapped format. |
| copy(out.Address.Addr[header.IPv6AddressSize-header.IPv4AddressSize:], addr.Addr) |
| out.Address.Addr[header.IPv6AddressSize-header.IPv4AddressSize-1] = 0xff |
| out.Address.Addr[header.IPv6AddressSize-header.IPv4AddressSize-2] = 0xff |
| } else { |
| copy(out.Address.Addr[:], addr.Addr) |
| if isLinkLocal(out.Address) { |
| out.ZoneIndex = uint64(addr.NIC) |
| } |
| } |
| return net.SocketAddressWithIpv6(out) |
| default: |
| panic(fmt.Sprintf("invalid protocol for conversion: %d", protocol)) |
| } |
| } |
| |
| func ToTCPIPAddressWithPrefix(sn net.Subnet) tcpip.AddressWithPrefix { |
| return tcpip.AddressWithPrefix{ |
| Address: ToTCPIPAddress(sn.Addr), |
| PrefixLen: int(sn.PrefixLen), |
| } |
| } |
| |
| func ToTCPIPSubnet(sn net.Subnet) tcpip.Subnet { |
| return ToTCPIPAddressWithPrefix(sn).Subnet() |
| } |
| |
| func ToTCPIPProtocolAddress(sn net.Subnet) tcpip.ProtocolAddress { |
| protocolAddr := tcpip.ProtocolAddress{ |
| AddressWithPrefix: ToTCPIPAddressWithPrefix(sn), |
| } |
| |
| switch typ := sn.Addr.Which(); typ { |
| case net.IpAddressIpv4: |
| protocolAddr.Protocol = ipv4.ProtocolNumber |
| case net.IpAddressIpv6: |
| protocolAddr.Protocol = ipv6.ProtocolNumber |
| default: |
| panic(fmt.Sprintf("unknown IpAddress type %d", typ)) |
| } |
| return protocolAddr |
| } |
| |
| func TCPIPRouteToForwardingEntry(route tcpip.Route) stack.ForwardingEntry { |
| forwardingEntry := stack.ForwardingEntry{ |
| Subnet: net.Subnet{ |
| Addr: ToNetIpAddress(route.Destination.ID()), |
| PrefixLen: uint8(route.Destination.Prefix()), |
| }, |
| DeviceId: uint64(route.NIC), |
| } |
| if len(route.Gateway) != 0 { |
| nextHop := ToNetIpAddress(route.Gateway) |
| forwardingEntry.NextHop = &nextHop |
| } |
| return forwardingEntry |
| } |
| |
| func ForwardingEntryToTCPIPRoute(forwardingEntry stack.ForwardingEntry) tcpip.Route { |
| route := tcpip.Route{ |
| Destination: ToTCPIPSubnet(forwardingEntry.Subnet), |
| NIC: tcpip.NICID(forwardingEntry.DeviceId), |
| } |
| if nextHop := forwardingEntry.NextHop; nextHop != nil { |
| route.Gateway = ToTCPIPAddress(*nextHop) |
| } |
| return route |
| } |
| |
| // ToStackMulticastRoute converts the provided route to a stack multicast |
| // route. |
| // |
| // Returns true if the provided route contains all required fields and the |
| // conversion was successful. Otherwise, returns false. |
| func ToStackMulticastRoute(route admin.Route) (tcpipstack.MulticastRoute, bool) { |
| if !route.HasExpectedInputInterface() || !route.HasAction() { |
| return tcpipstack.MulticastRoute{}, false |
| } |
| |
| outgoingInterfaces := make([]tcpipstack.MulticastRouteOutgoingInterface, 0, len(route.Action.OutgoingInterfaces)) |
| |
| for _, outgoingInterface := range route.Action.OutgoingInterfaces { |
| outgoingInterfaces = append(outgoingInterfaces, tcpipstack.MulticastRouteOutgoingInterface{ |
| ID: tcpip.NICID(outgoingInterface.Id), |
| MinTTL: outgoingInterface.MinTtl, |
| }) |
| } |
| |
| return tcpipstack.MulticastRoute{ |
| ExpectedInputInterface: tcpip.NICID(route.ExpectedInputInterface), |
| OutgoingInterfaces: outgoingInterfaces, |
| }, true |
| } |
| |
| // TODO(https://fxbug.dev/99434): Replace usages with `Clock.Elapsed` when available. |
| func ToZxTime(t tcpip.MonotonicTime) zx.Time { |
| return zx.Time(t.Sub(tcpip.MonotonicTime{})) |
| } |
| |
| func BytesToAddressDroppingUnspecified(b []uint8) tcpip.Address { |
| for _, e := range b { |
| if e != 0 { |
| return tcpip.Address(b) |
| } |
| } |
| return "" |
| } |
| |
| func ToTCPIPFullAddress(addr net.SocketAddress) tcpip.FullAddress { |
| switch w := addr.Which(); w { |
| case net.SocketAddressIpv4: |
| return tcpip.FullAddress{ |
| NIC: 0, |
| Addr: BytesToAddressDroppingUnspecified(addr.Ipv4.Address.Addr[:]), |
| Port: addr.Ipv4.Port, |
| } |
| case net.SocketAddressIpv6: |
| return tcpip.FullAddress{ |
| NIC: tcpip.NICID(addr.Ipv6.ZoneIndex), |
| Addr: BytesToAddressDroppingUnspecified(addr.Ipv6.Address.Addr[:]), |
| Port: addr.Ipv6.Port, |
| } |
| default: |
| panic(fmt.Sprintf("invalid fuchsia.net/SocketAddress variant: %d", w)) |
| } |
| } |
| |
| func ToTcpIpAddressDroppingUnspecifiedv4(fidl net.Ipv4Address) tcpip.Address { |
| return BytesToAddressDroppingUnspecified(fidl.Addr[:]) |
| } |
| |
| func ToTcpIpAddressDroppingUnspecifiedv6(fidl net.Ipv6Address) tcpip.Address { |
| return BytesToAddressDroppingUnspecified(fidl.Addr[:]) |
| } |
