docker_experimental_network_test.go 31 KB

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