docker_api_network_test.go 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335
  1. package main
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "net"
  6. "net/http"
  7. "net/url"
  8. "strings"
  9. "github.com/docker/docker/pkg/integration/checker"
  10. "github.com/docker/engine-api/types"
  11. "github.com/docker/engine-api/types/filters"
  12. "github.com/docker/engine-api/types/network"
  13. "github.com/go-check/check"
  14. )
  15. func (s *DockerSuite) TestApiNetworkGetDefaults(c *check.C) {
  16. testRequires(c, DaemonIsLinux)
  17. // By default docker daemon creates 3 networks. check if they are present
  18. defaults := []string{"bridge", "host", "none"}
  19. for _, nn := range defaults {
  20. c.Assert(isNetworkAvailable(c, nn), checker.Equals, true)
  21. }
  22. }
  23. func (s *DockerSuite) TestApiNetworkCreateDelete(c *check.C) {
  24. testRequires(c, DaemonIsLinux)
  25. // Create a network
  26. name := "testnetwork"
  27. config := types.NetworkCreate{
  28. Name: name,
  29. CheckDuplicate: true,
  30. }
  31. id := createNetwork(c, config, true)
  32. c.Assert(isNetworkAvailable(c, name), checker.Equals, true)
  33. // delete the network and make sure it is deleted
  34. deleteNetwork(c, id, true)
  35. c.Assert(isNetworkAvailable(c, name), checker.Equals, false)
  36. }
  37. func (s *DockerSuite) TestApiNetworkCreateCheckDuplicate(c *check.C) {
  38. testRequires(c, DaemonIsLinux)
  39. name := "testcheckduplicate"
  40. configOnCheck := types.NetworkCreate{
  41. Name: name,
  42. CheckDuplicate: true,
  43. }
  44. configNotCheck := types.NetworkCreate{
  45. Name: name,
  46. CheckDuplicate: false,
  47. }
  48. // Creating a new network first
  49. createNetwork(c, configOnCheck, true)
  50. c.Assert(isNetworkAvailable(c, name), checker.Equals, true)
  51. // Creating another network with same name and CheckDuplicate must fail
  52. createNetwork(c, configOnCheck, false)
  53. // Creating another network with same name and not CheckDuplicate must succeed
  54. createNetwork(c, configNotCheck, true)
  55. }
  56. func (s *DockerSuite) TestApiNetworkFilter(c *check.C) {
  57. testRequires(c, DaemonIsLinux)
  58. nr := getNetworkResource(c, getNetworkIDByName(c, "bridge"))
  59. c.Assert(nr.Name, checker.Equals, "bridge")
  60. }
  61. func (s *DockerSuite) TestApiNetworkInspect(c *check.C) {
  62. testRequires(c, DaemonIsLinux)
  63. // Inspect default bridge network
  64. nr := getNetworkResource(c, "bridge")
  65. c.Assert(nr.Name, checker.Equals, "bridge")
  66. // run a container and attach it to the default bridge network
  67. out, _ := dockerCmd(c, "run", "-d", "--name", "test", "busybox", "top")
  68. containerID := strings.TrimSpace(out)
  69. containerIP := findContainerIP(c, "test", "bridge")
  70. // inspect default bridge network again and make sure the container is connected
  71. nr = getNetworkResource(c, nr.ID)
  72. c.Assert(nr.Driver, checker.Equals, "bridge")
  73. c.Assert(nr.Scope, checker.Equals, "local")
  74. c.Assert(nr.IPAM.Driver, checker.Equals, "default")
  75. c.Assert(len(nr.Containers), checker.Equals, 1)
  76. c.Assert(nr.Containers[containerID], checker.NotNil)
  77. ip, _, err := net.ParseCIDR(nr.Containers[containerID].IPv4Address)
  78. c.Assert(err, checker.IsNil)
  79. c.Assert(ip.String(), checker.Equals, containerIP)
  80. // IPAM configuration inspect
  81. ipam := network.IPAM{
  82. Driver: "default",
  83. Config: []network.IPAMConfig{{Subnet: "172.28.0.0/16", IPRange: "172.28.5.0/24", Gateway: "172.28.5.254"}},
  84. }
  85. config := types.NetworkCreate{
  86. Name: "br0",
  87. Driver: "bridge",
  88. IPAM: ipam,
  89. Options: map[string]string{"foo": "bar", "opts": "dopts"},
  90. }
  91. id0 := createNetwork(c, config, true)
  92. c.Assert(isNetworkAvailable(c, "br0"), checker.Equals, true)
  93. nr = getNetworkResource(c, id0)
  94. c.Assert(len(nr.IPAM.Config), checker.Equals, 1)
  95. c.Assert(nr.IPAM.Config[0].Subnet, checker.Equals, "172.28.0.0/16")
  96. c.Assert(nr.IPAM.Config[0].IPRange, checker.Equals, "172.28.5.0/24")
  97. c.Assert(nr.IPAM.Config[0].Gateway, checker.Equals, "172.28.5.254")
  98. c.Assert(nr.Options["foo"], checker.Equals, "bar")
  99. c.Assert(nr.Options["opts"], checker.Equals, "dopts")
  100. // delete the network and make sure it is deleted
  101. deleteNetwork(c, id0, true)
  102. c.Assert(isNetworkAvailable(c, "br0"), checker.Equals, false)
  103. }
  104. func (s *DockerSuite) TestApiNetworkConnectDisconnect(c *check.C) {
  105. testRequires(c, DaemonIsLinux)
  106. // Create test network
  107. name := "testnetwork"
  108. config := types.NetworkCreate{
  109. Name: name,
  110. }
  111. id := createNetwork(c, config, true)
  112. nr := getNetworkResource(c, id)
  113. c.Assert(nr.Name, checker.Equals, name)
  114. c.Assert(nr.ID, checker.Equals, id)
  115. c.Assert(len(nr.Containers), checker.Equals, 0)
  116. // run a container
  117. out, _ := dockerCmd(c, "run", "-d", "--name", "test", "busybox", "top")
  118. containerID := strings.TrimSpace(out)
  119. // connect the container to the test network
  120. connectNetwork(c, nr.ID, containerID)
  121. // inspect the network to make sure container is connected
  122. nr = getNetworkResource(c, nr.ID)
  123. c.Assert(len(nr.Containers), checker.Equals, 1)
  124. c.Assert(nr.Containers[containerID], checker.NotNil)
  125. // check if container IP matches network inspect
  126. ip, _, err := net.ParseCIDR(nr.Containers[containerID].IPv4Address)
  127. c.Assert(err, checker.IsNil)
  128. containerIP := findContainerIP(c, "test", "testnetwork")
  129. c.Assert(ip.String(), checker.Equals, containerIP)
  130. // disconnect container from the network
  131. disconnectNetwork(c, nr.ID, containerID)
  132. nr = getNetworkResource(c, nr.ID)
  133. c.Assert(nr.Name, checker.Equals, name)
  134. c.Assert(len(nr.Containers), checker.Equals, 0)
  135. // delete the network
  136. deleteNetwork(c, nr.ID, true)
  137. }
  138. func (s *DockerSuite) TestApiNetworkIpamMultipleBridgeNetworks(c *check.C) {
  139. testRequires(c, DaemonIsLinux)
  140. // test0 bridge network
  141. ipam0 := network.IPAM{
  142. Driver: "default",
  143. Config: []network.IPAMConfig{{Subnet: "192.178.0.0/16", IPRange: "192.178.128.0/17", Gateway: "192.178.138.100"}},
  144. }
  145. config0 := types.NetworkCreate{
  146. Name: "test0",
  147. Driver: "bridge",
  148. IPAM: ipam0,
  149. }
  150. id0 := createNetwork(c, config0, true)
  151. c.Assert(isNetworkAvailable(c, "test0"), checker.Equals, true)
  152. ipam1 := network.IPAM{
  153. Driver: "default",
  154. Config: []network.IPAMConfig{{Subnet: "192.178.128.0/17", Gateway: "192.178.128.1"}},
  155. }
  156. // test1 bridge network overlaps with test0
  157. config1 := types.NetworkCreate{
  158. Name: "test1",
  159. Driver: "bridge",
  160. IPAM: ipam1,
  161. }
  162. createNetwork(c, config1, false)
  163. c.Assert(isNetworkAvailable(c, "test1"), checker.Equals, false)
  164. ipam2 := network.IPAM{
  165. Driver: "default",
  166. Config: []network.IPAMConfig{{Subnet: "192.169.0.0/16", Gateway: "192.169.100.100"}},
  167. }
  168. // test2 bridge network does not overlap
  169. config2 := types.NetworkCreate{
  170. Name: "test2",
  171. Driver: "bridge",
  172. IPAM: ipam2,
  173. }
  174. createNetwork(c, config2, true)
  175. c.Assert(isNetworkAvailable(c, "test2"), checker.Equals, true)
  176. // remove test0 and retry to create test1
  177. deleteNetwork(c, id0, true)
  178. createNetwork(c, config1, true)
  179. c.Assert(isNetworkAvailable(c, "test1"), checker.Equals, true)
  180. // for networks w/o ipam specified, docker will choose proper non-overlapping subnets
  181. createNetwork(c, types.NetworkCreate{Name: "test3"}, true)
  182. c.Assert(isNetworkAvailable(c, "test3"), checker.Equals, true)
  183. createNetwork(c, types.NetworkCreate{Name: "test4"}, true)
  184. c.Assert(isNetworkAvailable(c, "test4"), checker.Equals, true)
  185. createNetwork(c, types.NetworkCreate{Name: "test5"}, true)
  186. c.Assert(isNetworkAvailable(c, "test5"), checker.Equals, true)
  187. for i := 1; i < 6; i++ {
  188. deleteNetwork(c, fmt.Sprintf("test%d", i), true)
  189. }
  190. }
  191. func (s *DockerSuite) TestApiCreateDeletePredefinedNetworks(c *check.C) {
  192. testRequires(c, DaemonIsLinux)
  193. createDeletePredefinedNetwork(c, "bridge")
  194. createDeletePredefinedNetwork(c, "none")
  195. createDeletePredefinedNetwork(c, "host")
  196. }
  197. func createDeletePredefinedNetwork(c *check.C, name string) {
  198. // Create pre-defined network
  199. config := types.NetworkCreate{
  200. Name: name,
  201. CheckDuplicate: true,
  202. }
  203. shouldSucceed := false
  204. createNetwork(c, config, shouldSucceed)
  205. deleteNetwork(c, name, shouldSucceed)
  206. }
  207. func isNetworkAvailable(c *check.C, name string) bool {
  208. status, body, err := sockRequest("GET", "/networks", nil)
  209. c.Assert(status, checker.Equals, http.StatusOK)
  210. c.Assert(err, checker.IsNil)
  211. nJSON := []types.NetworkResource{}
  212. err = json.Unmarshal(body, &nJSON)
  213. c.Assert(err, checker.IsNil)
  214. for _, n := range nJSON {
  215. if n.Name == name {
  216. return true
  217. }
  218. }
  219. return false
  220. }
  221. func getNetworkIDByName(c *check.C, name string) string {
  222. var (
  223. v = url.Values{}
  224. filterArgs = filters.NewArgs()
  225. )
  226. filterArgs.Add("name", name)
  227. filterJSON, err := filters.ToParam(filterArgs)
  228. c.Assert(err, checker.IsNil)
  229. v.Set("filters", filterJSON)
  230. status, body, err := sockRequest("GET", "/networks?"+v.Encode(), nil)
  231. c.Assert(status, checker.Equals, http.StatusOK)
  232. c.Assert(err, checker.IsNil)
  233. nJSON := []types.NetworkResource{}
  234. err = json.Unmarshal(body, &nJSON)
  235. c.Assert(err, checker.IsNil)
  236. c.Assert(len(nJSON), checker.Equals, 1)
  237. return nJSON[0].ID
  238. }
  239. func getNetworkResource(c *check.C, id string) *types.NetworkResource {
  240. _, obj, err := sockRequest("GET", "/networks/"+id, nil)
  241. c.Assert(err, checker.IsNil)
  242. nr := types.NetworkResource{}
  243. err = json.Unmarshal(obj, &nr)
  244. c.Assert(err, checker.IsNil)
  245. return &nr
  246. }
  247. func createNetwork(c *check.C, config types.NetworkCreate, shouldSucceed bool) string {
  248. status, resp, err := sockRequest("POST", "/networks/create", config)
  249. if !shouldSucceed {
  250. c.Assert(status, checker.Not(checker.Equals), http.StatusCreated)
  251. return ""
  252. }
  253. c.Assert(status, checker.Equals, http.StatusCreated)
  254. c.Assert(err, checker.IsNil)
  255. var nr types.NetworkCreateResponse
  256. err = json.Unmarshal(resp, &nr)
  257. c.Assert(err, checker.IsNil)
  258. return nr.ID
  259. }
  260. func connectNetwork(c *check.C, nid, cid string) {
  261. config := types.NetworkConnect{
  262. Container: cid,
  263. }
  264. status, _, err := sockRequest("POST", "/networks/"+nid+"/connect", config)
  265. c.Assert(status, checker.Equals, http.StatusOK)
  266. c.Assert(err, checker.IsNil)
  267. }
  268. func disconnectNetwork(c *check.C, nid, cid string) {
  269. config := types.NetworkConnect{
  270. Container: cid,
  271. }
  272. status, _, err := sockRequest("POST", "/networks/"+nid+"/disconnect", config)
  273. c.Assert(status, checker.Equals, http.StatusOK)
  274. c.Assert(err, checker.IsNil)
  275. }
  276. func deleteNetwork(c *check.C, id string, shouldSucceed bool) {
  277. status, _, err := sockRequest("DELETE", "/networks/"+id, nil)
  278. if !shouldSucceed {
  279. c.Assert(status, checker.Not(checker.Equals), http.StatusOK)
  280. return
  281. }
  282. c.Assert(status, checker.Equals, http.StatusOK)
  283. c.Assert(err, checker.IsNil)
  284. }