utils_linux.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. //go:build linux
  2. // +build linux
  3. // Network utility functions.
  4. package netutils
  5. import (
  6. "net"
  7. "os"
  8. "github.com/docker/docker/libnetwork/ns"
  9. "github.com/docker/docker/libnetwork/resolvconf"
  10. "github.com/docker/docker/libnetwork/types"
  11. "github.com/pkg/errors"
  12. "github.com/vishvananda/netlink"
  13. )
  14. var networkGetRoutesFct func(netlink.Link, int) ([]netlink.Route, error)
  15. // CheckRouteOverlaps checks whether the passed network overlaps with any existing routes
  16. func CheckRouteOverlaps(toCheck *net.IPNet) error {
  17. networkGetRoutesFct := networkGetRoutesFct
  18. if networkGetRoutesFct == nil {
  19. networkGetRoutesFct = ns.NlHandle().RouteList
  20. }
  21. networks, err := networkGetRoutesFct(nil, netlink.FAMILY_V4)
  22. if err != nil {
  23. return err
  24. }
  25. for _, network := range networks {
  26. if network.Dst != nil && network.Scope == netlink.SCOPE_LINK && NetworkOverlaps(toCheck, network.Dst) {
  27. return ErrNetworkOverlaps
  28. }
  29. }
  30. return nil
  31. }
  32. // GenerateIfaceName returns an interface name using the passed in
  33. // prefix and the length of random bytes. The api ensures that the
  34. // there are is no interface which exists with that name.
  35. func GenerateIfaceName(nlh *netlink.Handle, prefix string, len int) (string, error) {
  36. linkByName := netlink.LinkByName
  37. if nlh != nil {
  38. linkByName = nlh.LinkByName
  39. }
  40. for i := 0; i < 3; i++ {
  41. name, err := GenerateRandomName(prefix, len)
  42. if err != nil {
  43. return "", err
  44. }
  45. _, err = linkByName(name)
  46. if err != nil {
  47. if errors.As(err, &netlink.LinkNotFoundError{}) {
  48. return name, nil
  49. }
  50. return "", err
  51. }
  52. }
  53. return "", types.InternalErrorf("could not generate interface name")
  54. }
  55. // FindAvailableNetwork returns a network from the passed list which does not
  56. // overlap with existing interfaces in the system
  57. func FindAvailableNetwork(list []*net.IPNet) (*net.IPNet, error) {
  58. // We don't check for an error here, because we don't really care if we
  59. // can't read /etc/resolv.conf. So instead we skip the append if resolvConf
  60. // is nil. It either doesn't exist, or we can't read it for some reason.
  61. var nameservers []string
  62. if rc, err := os.ReadFile(resolvconf.Path()); err == nil {
  63. nameservers = resolvconf.GetNameserversAsCIDR(rc)
  64. }
  65. for _, nw := range list {
  66. if err := CheckNameserverOverlaps(nameservers, nw); err == nil {
  67. if err := CheckRouteOverlaps(nw); err == nil {
  68. return nw, nil
  69. }
  70. }
  71. }
  72. return nil, errors.New("no available network")
  73. }