docker_experimental_network_test.go 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587
  1. // +build !windows
  2. package main
  3. import (
  4. "os/exec"
  5. "strings"
  6. "time"
  7. "github.com/docker/docker/pkg/integration/checker"
  8. icmd "github.com/docker/docker/pkg/integration/cmd"
  9. "github.com/docker/docker/pkg/parsers/kernel"
  10. "github.com/go-check/check"
  11. )
  12. func macvlanKernelSupport() bool {
  13. const macvlanKernelVer = 3 // minimum macvlan kernel support
  14. const macvlanMajorVer = 9 // minimum macvlan major kernel support
  15. kv, err := kernel.GetKernelVersion()
  16. if err != nil {
  17. return false
  18. }
  19. // ensure Kernel version is >= v3.9 for macvlan support
  20. if kv.Kernel < macvlanKernelVer || (kv.Kernel == macvlanKernelVer && kv.Major < macvlanMajorVer) {
  21. return false
  22. }
  23. return true
  24. }
  25. func ipvlanKernelSupport() bool {
  26. const ipvlanKernelVer = 4 // minimum ipvlan kernel support
  27. const ipvlanMajorVer = 2 // minimum ipvlan major kernel support
  28. kv, err := kernel.GetKernelVersion()
  29. if err != nil {
  30. return false
  31. }
  32. // ensure Kernel version is >= v4.2 for ipvlan support
  33. if kv.Kernel < ipvlanKernelVer || (kv.Kernel == ipvlanKernelVer && kv.Major < ipvlanMajorVer) {
  34. return false
  35. }
  36. return true
  37. }
  38. func (s *DockerNetworkSuite) TestDockerNetworkMacvlanPersistance(c *check.C) {
  39. // verify the driver automatically provisions the 802.1q link (dm-dummy0.60)
  40. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  41. // master dummy interface 'dm' abbreviation represents 'docker macvlan'
  42. master := "dm-dummy0"
  43. // simulate the master link the vlan tagged subinterface parent link will use
  44. out, err := createMasterDummy(c, master)
  45. c.Assert(err, check.IsNil, check.Commentf(out))
  46. // create a network specifying the desired sub-interface name
  47. dockerCmd(c, "network", "create", "--driver=macvlan", "-o", "parent=dm-dummy0.60", "dm-persist")
  48. assertNwIsAvailable(c, "dm-persist")
  49. // Restart docker daemon to test the config has persisted to disk
  50. s.d.Restart(c)
  51. // verify network is recreated from persistence
  52. assertNwIsAvailable(c, "dm-persist")
  53. // cleanup the master interface that also collects the slave dev
  54. deleteInterface(c, "dm-dummy0")
  55. }
  56. func (s *DockerNetworkSuite) TestDockerNetworkIpvlanPersistance(c *check.C) {
  57. // verify the driver automatically provisions the 802.1q link (di-dummy0.70)
  58. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  59. // master dummy interface 'di' notation represent 'docker ipvlan'
  60. master := "di-dummy0"
  61. // simulate the master link the vlan tagged subinterface parent link will use
  62. out, err := createMasterDummy(c, master)
  63. c.Assert(err, check.IsNil, check.Commentf(out))
  64. // create a network specifying the desired sub-interface name
  65. dockerCmd(c, "network", "create", "--driver=ipvlan", "-o", "parent=di-dummy0.70", "di-persist")
  66. assertNwIsAvailable(c, "di-persist")
  67. // Restart docker daemon to test the config has persisted to disk
  68. s.d.Restart(c)
  69. // verify network is recreated from persistence
  70. assertNwIsAvailable(c, "di-persist")
  71. // cleanup the master interface that also collects the slave dev
  72. deleteInterface(c, "di-dummy0")
  73. }
  74. func (s *DockerNetworkSuite) TestDockerNetworkMacvlanSubIntCreate(c *check.C) {
  75. // verify the driver automatically provisions the 802.1q link (dm-dummy0.50)
  76. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  77. // master dummy interface 'dm' abbreviation represents 'docker macvlan'
  78. master := "dm-dummy0"
  79. // simulate the master link the vlan tagged subinterface parent link will use
  80. out, err := createMasterDummy(c, master)
  81. c.Assert(err, check.IsNil, check.Commentf(out))
  82. // create a network specifying the desired sub-interface name
  83. dockerCmd(c, "network", "create", "--driver=macvlan", "-o", "parent=dm-dummy0.50", "dm-subinterface")
  84. assertNwIsAvailable(c, "dm-subinterface")
  85. // cleanup the master interface which also collects the slave dev
  86. deleteInterface(c, "dm-dummy0")
  87. }
  88. func (s *DockerNetworkSuite) TestDockerNetworkIpvlanSubIntCreate(c *check.C) {
  89. // verify the driver automatically provisions the 802.1q link (di-dummy0.50)
  90. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  91. // master dummy interface 'dm' abbreviation represents 'docker ipvlan'
  92. master := "di-dummy0"
  93. // simulate the master link the vlan tagged subinterface parent link will use
  94. out, err := createMasterDummy(c, master)
  95. c.Assert(err, check.IsNil, check.Commentf(out))
  96. // create a network specifying the desired sub-interface name
  97. dockerCmd(c, "network", "create", "--driver=ipvlan", "-o", "parent=di-dummy0.60", "di-subinterface")
  98. assertNwIsAvailable(c, "di-subinterface")
  99. // cleanup the master interface which also collects the slave dev
  100. deleteInterface(c, "di-dummy0")
  101. }
  102. func (s *DockerNetworkSuite) TestDockerNetworkMacvlanOverlapParent(c *check.C) {
  103. // verify the same parent interface cannot be used if already in use by an existing network
  104. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  105. // master dummy interface 'dm' abbreviation represents 'docker macvlan'
  106. master := "dm-dummy0"
  107. out, err := createMasterDummy(c, master)
  108. c.Assert(err, check.IsNil, check.Commentf(out))
  109. out, err = createVlanInterface(c, master, "dm-dummy0.40", "40")
  110. c.Assert(err, check.IsNil, check.Commentf(out))
  111. // create a network using an existing parent interface
  112. dockerCmd(c, "network", "create", "--driver=macvlan", "-o", "parent=dm-dummy0.40", "dm-subinterface")
  113. assertNwIsAvailable(c, "dm-subinterface")
  114. // attempt to create another network using the same parent iface that should fail
  115. out, _, err = dockerCmdWithError("network", "create", "--driver=macvlan", "-o", "parent=dm-dummy0.40", "dm-parent-net-overlap")
  116. // verify that the overlap returns an error
  117. c.Assert(err, check.NotNil)
  118. // cleanup the master interface which also collects the slave dev
  119. deleteInterface(c, "dm-dummy0")
  120. }
  121. func (s *DockerNetworkSuite) TestDockerNetworkIpvlanOverlapParent(c *check.C) {
  122. // verify the same parent interface cannot be used if already in use by an existing network
  123. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  124. // master dummy interface 'dm' abbreviation represents 'docker ipvlan'
  125. master := "di-dummy0"
  126. out, err := createMasterDummy(c, master)
  127. c.Assert(err, check.IsNil, check.Commentf(out))
  128. out, err = createVlanInterface(c, master, "di-dummy0.30", "30")
  129. c.Assert(err, check.IsNil, check.Commentf(out))
  130. // create a network using an existing parent interface
  131. dockerCmd(c, "network", "create", "--driver=ipvlan", "-o", "parent=di-dummy0.30", "di-subinterface")
  132. assertNwIsAvailable(c, "di-subinterface")
  133. // attempt to create another network using the same parent iface that should fail
  134. out, _, err = dockerCmdWithError("network", "create", "--driver=ipvlan", "-o", "parent=di-dummy0.30", "di-parent-net-overlap")
  135. // verify that the overlap returns an error
  136. c.Assert(err, check.NotNil)
  137. // cleanup the master interface which also collects the slave dev
  138. deleteInterface(c, "di-dummy0")
  139. }
  140. func (s *DockerNetworkSuite) TestDockerNetworkMacvlanMultiSubnet(c *check.C) {
  141. // create a dual stack multi-subnet Macvlan bridge mode network and validate connectivity between four containers, two on each subnet
  142. testRequires(c, DaemonIsLinux, IPv6, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  143. dockerCmd(c, "network", "create", "--driver=macvlan", "--ipv6", "--subnet=172.28.100.0/24", "--subnet=172.28.102.0/24", "--gateway=172.28.102.254",
  144. "--subnet=2001:db8:abc2::/64", "--subnet=2001:db8:abc4::/64", "--gateway=2001:db8:abc4::254", "dualstackbridge")
  145. // Ensure the network was created
  146. assertNwIsAvailable(c, "dualstackbridge")
  147. // start dual stack containers and verify the user specified --ip and --ip6 addresses on subnets 172.28.100.0/24 and 2001:db8:abc2::/64
  148. dockerCmd(c, "run", "-d", "--net=dualstackbridge", "--name=first", "--ip", "172.28.100.20", "--ip6", "2001:db8:abc2::20", "busybox", "top")
  149. dockerCmd(c, "run", "-d", "--net=dualstackbridge", "--name=second", "--ip", "172.28.100.21", "--ip6", "2001:db8:abc2::21", "busybox", "top")
  150. // Inspect and store the v4 address from specified container on the network dualstackbridge
  151. ip := inspectField(c, "first", "NetworkSettings.Networks.dualstackbridge.IPAddress")
  152. // Inspect and store the v6 address from specified container on the network dualstackbridge
  153. ip6 := inspectField(c, "first", "NetworkSettings.Networks.dualstackbridge.GlobalIPv6Address")
  154. // verify ipv4 connectivity to the explicit --ipv address second to first
  155. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", strings.TrimSpace(ip))
  156. c.Assert(err, check.IsNil)
  157. // verify ipv6 connectivity to the explicit --ipv6 address second to first
  158. c.Skip("Temporarily skipping while invesitigating sporadic v6 CI issues")
  159. _, _, err = dockerCmdWithError("exec", "second", "ping6", "-c", "1", strings.TrimSpace(ip6))
  160. c.Assert(err, check.IsNil)
  161. // start dual stack containers and verify the user specified --ip and --ip6 addresses on subnets 172.28.102.0/24 and 2001:db8:abc4::/64
  162. dockerCmd(c, "run", "-d", "--net=dualstackbridge", "--name=third", "--ip", "172.28.102.20", "--ip6", "2001:db8:abc4::20", "busybox", "top")
  163. dockerCmd(c, "run", "-d", "--net=dualstackbridge", "--name=fourth", "--ip", "172.28.102.21", "--ip6", "2001:db8:abc4::21", "busybox", "top")
  164. // Inspect and store the v4 address from specified container on the network dualstackbridge
  165. ip = inspectField(c, "third", "NetworkSettings.Networks.dualstackbridge.IPAddress")
  166. // Inspect and store the v6 address from specified container on the network dualstackbridge
  167. ip6 = inspectField(c, "third", "NetworkSettings.Networks.dualstackbridge.GlobalIPv6Address")
  168. // verify ipv4 connectivity to the explicit --ipv address from third to fourth
  169. _, _, err = dockerCmdWithError("exec", "fourth", "ping", "-c", "1", strings.TrimSpace(ip))
  170. c.Assert(err, check.IsNil)
  171. // verify ipv6 connectivity to the explicit --ipv6 address from third to fourth
  172. _, _, err = dockerCmdWithError("exec", "fourth", "ping6", "-c", "1", strings.TrimSpace(ip6))
  173. c.Assert(err, check.IsNil)
  174. // Inspect the v4 gateway to ensure the proper default GW was assigned
  175. ip4gw := inspectField(c, "first", "NetworkSettings.Networks.dualstackbridge.Gateway")
  176. c.Assert(strings.TrimSpace(ip4gw), check.Equals, "172.28.100.1")
  177. // Inspect the v6 gateway to ensure the proper default GW was assigned
  178. ip6gw := inspectField(c, "first", "NetworkSettings.Networks.dualstackbridge.IPv6Gateway")
  179. c.Assert(strings.TrimSpace(ip6gw), check.Equals, "2001:db8:abc2::1")
  180. // Inspect the v4 gateway to ensure the proper explicitly assigned default GW was assigned
  181. ip4gw = inspectField(c, "third", "NetworkSettings.Networks.dualstackbridge.Gateway")
  182. c.Assert(strings.TrimSpace(ip4gw), check.Equals, "172.28.102.254")
  183. // Inspect the v6 gateway to ensure the proper explicitly assigned default GW was assigned
  184. ip6gw = inspectField(c, "third", "NetworkSettings.Networks.dualstackbridge.IPv6Gateway")
  185. c.Assert(strings.TrimSpace(ip6gw), check.Equals, "2001:db8:abc4::254")
  186. }
  187. func (s *DockerNetworkSuite) TestDockerNetworkIpvlanL2MultiSubnet(c *check.C) {
  188. // create a dual stack multi-subnet Ipvlan L2 network and validate connectivity within the subnets, two on each subnet
  189. testRequires(c, DaemonIsLinux, IPv6, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  190. dockerCmd(c, "network", "create", "--driver=ipvlan", "--ipv6", "--subnet=172.28.200.0/24", "--subnet=172.28.202.0/24", "--gateway=172.28.202.254",
  191. "--subnet=2001:db8:abc8::/64", "--subnet=2001:db8:abc6::/64", "--gateway=2001:db8:abc6::254", "dualstackl2")
  192. // Ensure the network was created
  193. assertNwIsAvailable(c, "dualstackl2")
  194. // start dual stack containers and verify the user specified --ip and --ip6 addresses on subnets 172.28.200.0/24 and 2001:db8:abc8::/64
  195. dockerCmd(c, "run", "-d", "--net=dualstackl2", "--name=first", "--ip", "172.28.200.20", "--ip6", "2001:db8:abc8::20", "busybox", "top")
  196. dockerCmd(c, "run", "-d", "--net=dualstackl2", "--name=second", "--ip", "172.28.200.21", "--ip6", "2001:db8:abc8::21", "busybox", "top")
  197. // Inspect and store the v4 address from specified container on the network dualstackl2
  198. ip := inspectField(c, "first", "NetworkSettings.Networks.dualstackl2.IPAddress")
  199. // Inspect and store the v6 address from specified container on the network dualstackl2
  200. ip6 := inspectField(c, "first", "NetworkSettings.Networks.dualstackl2.GlobalIPv6Address")
  201. // verify ipv4 connectivity to the explicit --ipv address second to first
  202. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", strings.TrimSpace(ip))
  203. c.Assert(err, check.IsNil)
  204. // verify ipv6 connectivity to the explicit --ipv6 address second to first
  205. _, _, err = dockerCmdWithError("exec", "second", "ping6", "-c", "1", strings.TrimSpace(ip6))
  206. c.Assert(err, check.IsNil)
  207. // start dual stack containers and verify the user specified --ip and --ip6 addresses on subnets 172.28.202.0/24 and 2001:db8:abc6::/64
  208. dockerCmd(c, "run", "-d", "--net=dualstackl2", "--name=third", "--ip", "172.28.202.20", "--ip6", "2001:db8:abc6::20", "busybox", "top")
  209. dockerCmd(c, "run", "-d", "--net=dualstackl2", "--name=fourth", "--ip", "172.28.202.21", "--ip6", "2001:db8:abc6::21", "busybox", "top")
  210. // Inspect and store the v4 address from specified container on the network dualstackl2
  211. ip = inspectField(c, "third", "NetworkSettings.Networks.dualstackl2.IPAddress")
  212. // Inspect and store the v6 address from specified container on the network dualstackl2
  213. ip6 = inspectField(c, "third", "NetworkSettings.Networks.dualstackl2.GlobalIPv6Address")
  214. // verify ipv4 connectivity to the explicit --ipv address from third to fourth
  215. _, _, err = dockerCmdWithError("exec", "fourth", "ping", "-c", "1", strings.TrimSpace(ip))
  216. c.Assert(err, check.IsNil)
  217. // verify ipv6 connectivity to the explicit --ipv6 address from third to fourth
  218. _, _, err = dockerCmdWithError("exec", "fourth", "ping6", "-c", "1", strings.TrimSpace(ip6))
  219. c.Assert(err, check.IsNil)
  220. // Inspect the v4 gateway to ensure the proper default GW was assigned
  221. ip4gw := inspectField(c, "first", "NetworkSettings.Networks.dualstackl2.Gateway")
  222. c.Assert(strings.TrimSpace(ip4gw), check.Equals, "172.28.200.1")
  223. // Inspect the v6 gateway to ensure the proper default GW was assigned
  224. ip6gw := inspectField(c, "first", "NetworkSettings.Networks.dualstackl2.IPv6Gateway")
  225. c.Assert(strings.TrimSpace(ip6gw), check.Equals, "2001:db8:abc8::1")
  226. // Inspect the v4 gateway to ensure the proper explicitly assigned default GW was assigned
  227. ip4gw = inspectField(c, "third", "NetworkSettings.Networks.dualstackl2.Gateway")
  228. c.Assert(strings.TrimSpace(ip4gw), check.Equals, "172.28.202.254")
  229. // Inspect the v6 gateway to ensure the proper explicitly assigned default GW was assigned
  230. ip6gw = inspectField(c, "third", "NetworkSettings.Networks.dualstackl2.IPv6Gateway")
  231. c.Assert(strings.TrimSpace(ip6gw), check.Equals, "2001:db8:abc6::254")
  232. }
  233. func (s *DockerNetworkSuite) TestDockerNetworkIpvlanL3MultiSubnet(c *check.C) {
  234. // create a dual stack multi-subnet Ipvlan L3 network and validate connectivity between all four containers per L3 mode
  235. testRequires(c, DaemonIsLinux, IPv6, ipvlanKernelSupport, NotUserNamespace, NotArm, IPv6, ExperimentalDaemon)
  236. dockerCmd(c, "network", "create", "--driver=ipvlan", "--ipv6", "--subnet=172.28.10.0/24", "--subnet=172.28.12.0/24", "--gateway=172.28.12.254",
  237. "--subnet=2001:db8:abc9::/64", "--subnet=2001:db8:abc7::/64", "--gateway=2001:db8:abc7::254", "-o", "ipvlan_mode=l3", "dualstackl3")
  238. // Ensure the network was created
  239. assertNwIsAvailable(c, "dualstackl3")
  240. // start dual stack containers and verify the user specified --ip and --ip6 addresses on subnets 172.28.10.0/24 and 2001:db8:abc9::/64
  241. dockerCmd(c, "run", "-d", "--net=dualstackl3", "--name=first", "--ip", "172.28.10.20", "--ip6", "2001:db8:abc9::20", "busybox", "top")
  242. dockerCmd(c, "run", "-d", "--net=dualstackl3", "--name=second", "--ip", "172.28.10.21", "--ip6", "2001:db8:abc9::21", "busybox", "top")
  243. // Inspect and store the v4 address from specified container on the network dualstackl3
  244. ip := inspectField(c, "first", "NetworkSettings.Networks.dualstackl3.IPAddress")
  245. // Inspect and store the v6 address from specified container on the network dualstackl3
  246. ip6 := inspectField(c, "first", "NetworkSettings.Networks.dualstackl3.GlobalIPv6Address")
  247. // verify ipv4 connectivity to the explicit --ipv address second to first
  248. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", strings.TrimSpace(ip))
  249. c.Assert(err, check.IsNil)
  250. // verify ipv6 connectivity to the explicit --ipv6 address second to first
  251. _, _, err = dockerCmdWithError("exec", "second", "ping6", "-c", "1", strings.TrimSpace(ip6))
  252. c.Assert(err, check.IsNil)
  253. // start dual stack containers and verify the user specified --ip and --ip6 addresses on subnets 172.28.12.0/24 and 2001:db8:abc7::/64
  254. dockerCmd(c, "run", "-d", "--net=dualstackl3", "--name=third", "--ip", "172.28.12.20", "--ip6", "2001:db8:abc7::20", "busybox", "top")
  255. dockerCmd(c, "run", "-d", "--net=dualstackl3", "--name=fourth", "--ip", "172.28.12.21", "--ip6", "2001:db8:abc7::21", "busybox", "top")
  256. // Inspect and store the v4 address from specified container on the network dualstackl3
  257. ip = inspectField(c, "third", "NetworkSettings.Networks.dualstackl3.IPAddress")
  258. // Inspect and store the v6 address from specified container on the network dualstackl3
  259. ip6 = inspectField(c, "third", "NetworkSettings.Networks.dualstackl3.GlobalIPv6Address")
  260. // verify ipv4 connectivity to the explicit --ipv address from third to fourth
  261. _, _, err = dockerCmdWithError("exec", "fourth", "ping", "-c", "1", strings.TrimSpace(ip))
  262. c.Assert(err, check.IsNil)
  263. // verify ipv6 connectivity to the explicit --ipv6 address from third to fourth
  264. _, _, err = dockerCmdWithError("exec", "fourth", "ping6", "-c", "1", strings.TrimSpace(ip6))
  265. c.Assert(err, check.IsNil)
  266. // Inspect and store the v4 address from specified container on the network dualstackl3
  267. ip = inspectField(c, "second", "NetworkSettings.Networks.dualstackl3.IPAddress")
  268. // Inspect and store the v6 address from specified container on the network dualstackl3
  269. ip6 = inspectField(c, "second", "NetworkSettings.Networks.dualstackl3.GlobalIPv6Address")
  270. // Verify connectivity across disparate subnets which is unique to L3 mode only
  271. _, _, err = dockerCmdWithError("exec", "third", "ping", "-c", "1", strings.TrimSpace(ip))
  272. c.Assert(err, check.IsNil)
  273. _, _, err = dockerCmdWithError("exec", "third", "ping6", "-c", "1", strings.TrimSpace(ip6))
  274. c.Assert(err, check.IsNil)
  275. // Inspect the v4 gateway to ensure no next hop is assigned in L3 mode
  276. ip4gw := inspectField(c, "first", "NetworkSettings.Networks.dualstackl3.Gateway")
  277. c.Assert(strings.TrimSpace(ip4gw), check.Equals, "")
  278. // Inspect the v6 gateway to ensure the explicitly specified default GW is ignored per L3 mode enabled
  279. ip6gw := inspectField(c, "third", "NetworkSettings.Networks.dualstackl3.IPv6Gateway")
  280. c.Assert(strings.TrimSpace(ip6gw), check.Equals, "")
  281. }
  282. func (s *DockerNetworkSuite) TestDockerNetworkIpvlanAddressing(c *check.C) {
  283. // Ensure the default gateways, next-hops and default dev devices are properly set
  284. testRequires(c, DaemonIsLinux, IPv6, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  285. dockerCmd(c, "network", "create", "--driver=macvlan", "--ipv6", "--subnet=172.28.130.0/24",
  286. "--subnet=2001:db8:abca::/64", "--gateway=2001:db8:abca::254", "-o", "macvlan_mode=bridge", "dualstackbridge")
  287. assertNwIsAvailable(c, "dualstackbridge")
  288. dockerCmd(c, "run", "-d", "--net=dualstackbridge", "--name=first", "busybox", "top")
  289. // Validate macvlan bridge mode defaults gateway sets the default IPAM next-hop inferred from the subnet
  290. out, _, err := dockerCmdWithError("exec", "first", "ip", "route")
  291. c.Assert(err, check.IsNil)
  292. c.Assert(out, checker.Contains, "default via 172.28.130.1 dev eth0")
  293. // Validate macvlan bridge mode sets the v6 gateway to the user specified default gateway/next-hop
  294. out, _, err = dockerCmdWithError("exec", "first", "ip", "-6", "route")
  295. c.Assert(err, check.IsNil)
  296. c.Assert(out, checker.Contains, "default via 2001:db8:abca::254 dev eth0")
  297. // Verify ipvlan l2 mode sets the proper default gateway routes via netlink
  298. // for either an explicitly set route by the user or inferred via default IPAM
  299. dockerCmd(c, "network", "create", "--driver=ipvlan", "--ipv6", "--subnet=172.28.140.0/24", "--gateway=172.28.140.254",
  300. "--subnet=2001:db8:abcb::/64", "-o", "ipvlan_mode=l2", "dualstackl2")
  301. assertNwIsAvailable(c, "dualstackl2")
  302. dockerCmd(c, "run", "-d", "--net=dualstackl2", "--name=second", "busybox", "top")
  303. // Validate ipvlan l2 mode defaults gateway sets the default IPAM next-hop inferred from the subnet
  304. out, _, err = dockerCmdWithError("exec", "second", "ip", "route")
  305. c.Assert(err, check.IsNil)
  306. c.Assert(out, checker.Contains, "default via 172.28.140.254 dev eth0")
  307. // Validate ipvlan l2 mode sets the v6 gateway to the user specified default gateway/next-hop
  308. out, _, err = dockerCmdWithError("exec", "second", "ip", "-6", "route")
  309. c.Assert(err, check.IsNil)
  310. c.Assert(out, checker.Contains, "default via 2001:db8:abcb::1 dev eth0")
  311. // Validate ipvlan l3 mode sets the v4 gateway to dev eth0 and disregards any explicit or inferred next-hops
  312. dockerCmd(c, "network", "create", "--driver=ipvlan", "--ipv6", "--subnet=172.28.160.0/24", "--gateway=172.28.160.254",
  313. "--subnet=2001:db8:abcd::/64", "--gateway=2001:db8:abcd::254", "-o", "ipvlan_mode=l3", "dualstackl3")
  314. assertNwIsAvailable(c, "dualstackl3")
  315. dockerCmd(c, "run", "-d", "--net=dualstackl3", "--name=third", "busybox", "top")
  316. // Validate ipvlan l3 mode sets the v4 gateway to dev eth0 and disregards any explicit or inferred next-hops
  317. out, _, err = dockerCmdWithError("exec", "third", "ip", "route")
  318. c.Assert(err, check.IsNil)
  319. c.Assert(out, checker.Contains, "default dev eth0")
  320. // Validate ipvlan l3 mode sets the v6 gateway to dev eth0 and disregards any explicit or inferred next-hops
  321. out, _, err = dockerCmdWithError("exec", "third", "ip", "-6", "route")
  322. c.Assert(err, check.IsNil)
  323. c.Assert(out, checker.Contains, "default dev eth0")
  324. }
  325. func (s *DockerSuite) TestDockerNetworkMacVlanBridgeNilParent(c *check.C) {
  326. // macvlan bridge mode - dummy parent interface is provisioned dynamically
  327. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  328. dockerCmd(c, "network", "create", "--driver=macvlan", "dm-nil-parent")
  329. assertNwIsAvailable(c, "dm-nil-parent")
  330. // start two containers on the same subnet
  331. dockerCmd(c, "run", "-d", "--net=dm-nil-parent", "--name=first", "busybox", "top")
  332. c.Assert(waitRun("first"), check.IsNil)
  333. dockerCmd(c, "run", "-d", "--net=dm-nil-parent", "--name=second", "busybox", "top")
  334. c.Assert(waitRun("second"), check.IsNil)
  335. // intra-network communications should succeed
  336. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  337. c.Assert(err, check.IsNil)
  338. }
  339. func (s *DockerSuite) TestDockerNetworkMacVlanBridgeInternalMode(c *check.C) {
  340. // macvlan bridge mode --internal containers can communicate inside the network but not externally
  341. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  342. dockerCmd(c, "network", "create", "--driver=macvlan", "--internal", "dm-internal")
  343. assertNwIsAvailable(c, "dm-internal")
  344. nr := getNetworkResource(c, "dm-internal")
  345. c.Assert(nr.Internal, checker.True)
  346. // start two containers on the same subnet
  347. dockerCmd(c, "run", "-d", "--net=dm-internal", "--name=first", "busybox", "top")
  348. c.Assert(waitRun("first"), check.IsNil)
  349. dockerCmd(c, "run", "-d", "--net=dm-internal", "--name=second", "busybox", "top")
  350. c.Assert(waitRun("second"), check.IsNil)
  351. // access outside of the network should fail
  352. result := dockerCmdWithTimeout(time.Second, "exec", "first", "ping", "-c", "1", "-w", "1", "8.8.8.8")
  353. c.Assert(result, icmd.Matches, icmd.Expected{Timeout: true})
  354. // intra-network communications should succeed
  355. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  356. c.Assert(err, check.IsNil)
  357. }
  358. func (s *DockerSuite) TestDockerNetworkIpvlanL2NilParent(c *check.C) {
  359. // ipvlan l2 mode - dummy parent interface is provisioned dynamically
  360. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  361. dockerCmd(c, "network", "create", "--driver=ipvlan", "di-nil-parent")
  362. assertNwIsAvailable(c, "di-nil-parent")
  363. // start two containers on the same subnet
  364. dockerCmd(c, "run", "-d", "--net=di-nil-parent", "--name=first", "busybox", "top")
  365. c.Assert(waitRun("first"), check.IsNil)
  366. dockerCmd(c, "run", "-d", "--net=di-nil-parent", "--name=second", "busybox", "top")
  367. c.Assert(waitRun("second"), check.IsNil)
  368. // intra-network communications should succeed
  369. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  370. c.Assert(err, check.IsNil)
  371. }
  372. func (s *DockerSuite) TestDockerNetworkIpvlanL2InternalMode(c *check.C) {
  373. // ipvlan l2 mode --internal containers can communicate inside the network but not externally
  374. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  375. dockerCmd(c, "network", "create", "--driver=ipvlan", "--internal", "di-internal")
  376. assertNwIsAvailable(c, "di-internal")
  377. nr := getNetworkResource(c, "di-internal")
  378. c.Assert(nr.Internal, checker.True)
  379. // start two containers on the same subnet
  380. dockerCmd(c, "run", "-d", "--net=di-internal", "--name=first", "busybox", "top")
  381. c.Assert(waitRun("first"), check.IsNil)
  382. dockerCmd(c, "run", "-d", "--net=di-internal", "--name=second", "busybox", "top")
  383. c.Assert(waitRun("second"), check.IsNil)
  384. // access outside of the network should fail
  385. result := dockerCmdWithTimeout(time.Second, "exec", "first", "ping", "-c", "1", "-w", "1", "8.8.8.8")
  386. c.Assert(result, icmd.Matches, icmd.Expected{Timeout: true})
  387. // intra-network communications should succeed
  388. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  389. c.Assert(err, check.IsNil)
  390. }
  391. func (s *DockerSuite) TestDockerNetworkIpvlanL3NilParent(c *check.C) {
  392. // ipvlan l3 mode - dummy parent interface is provisioned dynamically
  393. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  394. dockerCmd(c, "network", "create", "--driver=ipvlan", "--subnet=172.28.230.0/24",
  395. "--subnet=172.28.220.0/24", "-o", "ipvlan_mode=l3", "di-nil-parent-l3")
  396. assertNwIsAvailable(c, "di-nil-parent-l3")
  397. // start two containers on separate subnets
  398. dockerCmd(c, "run", "-d", "--ip=172.28.220.10", "--net=di-nil-parent-l3", "--name=first", "busybox", "top")
  399. c.Assert(waitRun("first"), check.IsNil)
  400. dockerCmd(c, "run", "-d", "--ip=172.28.230.10", "--net=di-nil-parent-l3", "--name=second", "busybox", "top")
  401. c.Assert(waitRun("second"), check.IsNil)
  402. // intra-network communications should succeed
  403. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  404. c.Assert(err, check.IsNil)
  405. }
  406. func (s *DockerSuite) TestDockerNetworkIpvlanL3InternalMode(c *check.C) {
  407. // ipvlan l3 mode --internal containers can communicate inside the network but not externally
  408. testRequires(c, DaemonIsLinux, ipvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  409. dockerCmd(c, "network", "create", "--driver=ipvlan", "--subnet=172.28.230.0/24",
  410. "--subnet=172.28.220.0/24", "-o", "ipvlan_mode=l3", "--internal", "di-internal-l3")
  411. assertNwIsAvailable(c, "di-internal-l3")
  412. nr := getNetworkResource(c, "di-internal-l3")
  413. c.Assert(nr.Internal, checker.True)
  414. // start two containers on separate subnets
  415. dockerCmd(c, "run", "-d", "--ip=172.28.220.10", "--net=di-internal-l3", "--name=first", "busybox", "top")
  416. c.Assert(waitRun("first"), check.IsNil)
  417. dockerCmd(c, "run", "-d", "--ip=172.28.230.10", "--net=di-internal-l3", "--name=second", "busybox", "top")
  418. c.Assert(waitRun("second"), check.IsNil)
  419. // access outside of the network should fail
  420. result := dockerCmdWithTimeout(time.Second, "exec", "first", "ping", "-c", "1", "-w", "1", "8.8.8.8")
  421. c.Assert(result, icmd.Matches, icmd.Expected{Timeout: true})
  422. // intra-network communications should succeed
  423. _, _, err := dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  424. c.Assert(err, check.IsNil)
  425. }
  426. func (s *DockerSuite) TestDockerNetworkMacVlanExistingParent(c *check.C) {
  427. // macvlan bridge mode - empty parent interface containers can reach each other internally but not externally
  428. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  429. netName := "dm-parent-exists"
  430. out, err := createMasterDummy(c, "dm-dummy0")
  431. //out, err := createVlanInterface(c, "dm-parent", "dm-slave", "macvlan", "bridge")
  432. c.Assert(err, check.IsNil, check.Commentf(out))
  433. // create a network using an existing parent interface
  434. dockerCmd(c, "network", "create", "--driver=macvlan", "-o", "parent=dm-dummy0", netName)
  435. assertNwIsAvailable(c, netName)
  436. // delete the network while preserving the parent link
  437. dockerCmd(c, "network", "rm", netName)
  438. assertNwNotAvailable(c, netName)
  439. // verify the network delete did not delete the predefined link
  440. out, err = linkExists(c, "dm-dummy0")
  441. c.Assert(err, check.IsNil, check.Commentf(out))
  442. deleteInterface(c, "dm-dummy0")
  443. c.Assert(err, check.IsNil, check.Commentf(out))
  444. }
  445. func (s *DockerSuite) TestDockerNetworkMacVlanSubinterface(c *check.C) {
  446. // macvlan bridge mode - empty parent interface containers can reach each other internally but not externally
  447. testRequires(c, DaemonIsLinux, macvlanKernelSupport, NotUserNamespace, NotArm, ExperimentalDaemon)
  448. netName := "dm-subinterface"
  449. out, err := createMasterDummy(c, "dm-dummy0")
  450. c.Assert(err, check.IsNil, check.Commentf(out))
  451. out, err = createVlanInterface(c, "dm-dummy0", "dm-dummy0.20", "20")
  452. c.Assert(err, check.IsNil, check.Commentf(out))
  453. // create a network using an existing parent interface
  454. dockerCmd(c, "network", "create", "--driver=macvlan", "-o", "parent=dm-dummy0.20", netName)
  455. assertNwIsAvailable(c, netName)
  456. // start containers on 802.1q tagged '-o parent' sub-interface
  457. dockerCmd(c, "run", "-d", "--net=dm-subinterface", "--name=first", "busybox", "top")
  458. c.Assert(waitRun("first"), check.IsNil)
  459. dockerCmd(c, "run", "-d", "--net=dm-subinterface", "--name=second", "busybox", "top")
  460. c.Assert(waitRun("second"), check.IsNil)
  461. // verify containers can communicate
  462. _, _, err = dockerCmdWithError("exec", "second", "ping", "-c", "1", "first")
  463. c.Assert(err, check.IsNil)
  464. // remove the containers
  465. dockerCmd(c, "rm", "-f", "first")
  466. dockerCmd(c, "rm", "-f", "second")
  467. // delete the network while preserving the parent link
  468. dockerCmd(c, "network", "rm", netName)
  469. assertNwNotAvailable(c, netName)
  470. // verify the network delete did not delete the predefined sub-interface
  471. out, err = linkExists(c, "dm-dummy0.20")
  472. c.Assert(err, check.IsNil, check.Commentf(out))
  473. // delete the parent interface which also collects the slave
  474. deleteInterface(c, "dm-dummy0")
  475. c.Assert(err, check.IsNil, check.Commentf(out))
  476. }
  477. func createMasterDummy(c *check.C, master string) (string, error) {
  478. // ip link add <dummy_name> type dummy
  479. args := []string{"link", "add", master, "type", "dummy"}
  480. ipLinkCmd := exec.Command("ip", args...)
  481. out, _, err := runCommandWithOutput(ipLinkCmd)
  482. if err != nil {
  483. return out, err
  484. }
  485. // ip link set dummy_name up
  486. args = []string{"link", "set", master, "up"}
  487. ipLinkCmd = exec.Command("ip", args...)
  488. out, _, err = runCommandWithOutput(ipLinkCmd)
  489. if err != nil {
  490. return out, err
  491. }
  492. return out, err
  493. }
  494. func createVlanInterface(c *check.C, master, slave, id string) (string, error) {
  495. // ip link add link <master> name <master>.<VID> type vlan id <VID>
  496. args := []string{"link", "add", "link", master, "name", slave, "type", "vlan", "id", id}
  497. ipLinkCmd := exec.Command("ip", args...)
  498. out, _, err := runCommandWithOutput(ipLinkCmd)
  499. if err != nil {
  500. return out, err
  501. }
  502. // ip link set <sub_interface_name> up
  503. args = []string{"link", "set", slave, "up"}
  504. ipLinkCmd = exec.Command("ip", args...)
  505. out, _, err = runCommandWithOutput(ipLinkCmd)
  506. if err != nil {
  507. return out, err
  508. }
  509. return out, err
  510. }
  511. func linkExists(c *check.C, master string) (string, error) {
  512. // verify the specified link exists, ip link show <link_name>
  513. args := []string{"link", "show", master}
  514. ipLinkCmd := exec.Command("ip", args...)
  515. out, _, err := runCommandWithOutput(ipLinkCmd)
  516. if err != nil {
  517. return out, err
  518. }
  519. return out, err
  520. }