libnetwork_test.go 28 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319
  1. package libnetwork_test
  2. import (
  3. "bytes"
  4. "flag"
  5. "fmt"
  6. "io/ioutil"
  7. "net"
  8. "os"
  9. "runtime"
  10. "strconv"
  11. "sync"
  12. "testing"
  13. log "github.com/Sirupsen/logrus"
  14. "github.com/docker/docker/pkg/reexec"
  15. "github.com/docker/libnetwork"
  16. "github.com/docker/libnetwork/netutils"
  17. "github.com/docker/libnetwork/pkg/netlabel"
  18. "github.com/docker/libnetwork/pkg/options"
  19. "github.com/vishvananda/netns"
  20. )
  21. const (
  22. bridgeNetType = "bridge"
  23. bridgeName = "docker0"
  24. )
  25. func TestMain(m *testing.M) {
  26. if reexec.Init() {
  27. return
  28. }
  29. os.Exit(m.Run())
  30. }
  31. func createTestNetwork(networkType, networkName string, option options.Generic, netOption options.Generic) (libnetwork.Network, error) {
  32. controller, err := libnetwork.New()
  33. if err != nil {
  34. return nil, err
  35. }
  36. genericOption := make(map[string]interface{})
  37. genericOption[netlabel.GenericData] = option
  38. err = controller.ConfigureNetworkDriver(networkType, genericOption)
  39. if err != nil {
  40. return nil, err
  41. }
  42. network, err := controller.NewNetwork(networkType, networkName,
  43. libnetwork.NetworkOptionGeneric(netOption))
  44. if err != nil {
  45. return nil, err
  46. }
  47. return network, nil
  48. }
  49. func getEmptyGenericOption() map[string]interface{} {
  50. genericOption := make(map[string]interface{})
  51. genericOption[netlabel.GenericData] = options.Generic{}
  52. return genericOption
  53. }
  54. func getPortMapping() []netutils.PortBinding {
  55. return []netutils.PortBinding{
  56. netutils.PortBinding{Proto: netutils.TCP, Port: uint16(230), HostPort: uint16(23000)},
  57. netutils.PortBinding{Proto: netutils.UDP, Port: uint16(200), HostPort: uint16(22000)},
  58. netutils.PortBinding{Proto: netutils.TCP, Port: uint16(120), HostPort: uint16(12000)},
  59. }
  60. }
  61. func TestNull(t *testing.T) {
  62. network, err := createTestNetwork("null", "testnetwork", options.Generic{},
  63. options.Generic{})
  64. if err != nil {
  65. t.Fatal(err)
  66. }
  67. ep, err := network.CreateEndpoint("testep")
  68. if err != nil {
  69. t.Fatal(err)
  70. }
  71. _, err = ep.Join("null_container",
  72. libnetwork.JoinOptionHostname("test"),
  73. libnetwork.JoinOptionDomainname("docker.io"),
  74. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  75. if err != nil {
  76. t.Fatal(err)
  77. }
  78. err = ep.Leave("null_container")
  79. if err != nil {
  80. t.Fatal(err)
  81. }
  82. if err := ep.Delete(); err != nil {
  83. t.Fatal(err)
  84. }
  85. if err := network.Delete(); err != nil {
  86. t.Fatal(err)
  87. }
  88. }
  89. func TestHost(t *testing.T) {
  90. network, err := createTestNetwork("host", "testnetwork", options.Generic{}, options.Generic{})
  91. if err != nil {
  92. t.Fatal(err)
  93. }
  94. ep, err := network.CreateEndpoint("testep")
  95. if err != nil {
  96. t.Fatal(err)
  97. }
  98. _, err = ep.Join("host_container",
  99. libnetwork.JoinOptionHostname("test"),
  100. libnetwork.JoinOptionDomainname("docker.io"),
  101. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"),
  102. libnetwork.JoinOptionUseDefaultSandbox())
  103. if err != nil {
  104. t.Fatal(err)
  105. }
  106. err = ep.Leave("host_container")
  107. if err != nil {
  108. t.Fatal(err)
  109. }
  110. if err := ep.Delete(); err != nil {
  111. t.Fatal(err)
  112. }
  113. if err := network.Delete(); err != nil {
  114. t.Fatal(err)
  115. }
  116. }
  117. func TestBridge(t *testing.T) {
  118. if !netutils.IsRunningInContainer() {
  119. defer netutils.SetupTestNetNS(t)()
  120. }
  121. ip, subnet, err := net.ParseCIDR("192.168.100.1/24")
  122. if err != nil {
  123. t.Fatal(err)
  124. }
  125. subnet.IP = ip
  126. ip, cidr, err := net.ParseCIDR("192.168.100.2/28")
  127. if err != nil {
  128. t.Fatal(err)
  129. }
  130. cidr.IP = ip
  131. ip, cidrv6, err := net.ParseCIDR("fe90::1/96")
  132. if err != nil {
  133. t.Fatal(err)
  134. }
  135. cidrv6.IP = ip
  136. log.Debug("Adding a bridge")
  137. option := options.Generic{
  138. "EnableIPForwarding": true,
  139. }
  140. netOption := options.Generic{
  141. "BridgeName": bridgeName,
  142. "AddressIPv4": subnet,
  143. "FixedCIDR": cidr,
  144. "FixedCIDRv6": cidrv6,
  145. "EnableIPv6": true,
  146. "EnableIPTables": true,
  147. "EnableIPMasquerade": true,
  148. "EnableICC": true,
  149. "AllowNonDefaultBridge": true}
  150. network, err := createTestNetwork(bridgeNetType, "testnetwork", option, netOption)
  151. if err != nil {
  152. t.Fatal(err)
  153. }
  154. ep, err := network.CreateEndpoint("testep", libnetwork.CreateOptionPortMapping(getPortMapping()))
  155. if err != nil {
  156. t.Fatal(err)
  157. }
  158. epInfo, err := ep.Info()
  159. if err != nil {
  160. t.Fatal(err)
  161. }
  162. pmd, ok := epInfo[netlabel.PortMap]
  163. if !ok {
  164. t.Fatalf("Could not find expected info in endpoint data")
  165. }
  166. pm, ok := pmd.([]netutils.PortBinding)
  167. if !ok {
  168. t.Fatalf("Unexpected format for port mapping in endpoint operational data")
  169. }
  170. if len(pm) != 3 {
  171. t.Fatalf("Incomplete data for port mapping in endpoint operational data: %d", len(pm))
  172. }
  173. if err := ep.Delete(); err != nil {
  174. t.Fatal(err)
  175. }
  176. if err := network.Delete(); err != nil {
  177. t.Fatal(err)
  178. }
  179. }
  180. func TestUnknownDriver(t *testing.T) {
  181. if !netutils.IsRunningInContainer() {
  182. defer netutils.SetupTestNetNS(t)()
  183. }
  184. _, err := createTestNetwork("unknowndriver", "testnetwork", options.Generic{}, options.Generic{})
  185. if err == nil {
  186. t.Fatal("Expected to fail. But instead succeeded")
  187. }
  188. if _, ok := err.(libnetwork.NetworkTypeError); !ok {
  189. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  190. }
  191. }
  192. func TestNilDriver(t *testing.T) {
  193. controller, err := libnetwork.New()
  194. if err != nil {
  195. t.Fatal(err)
  196. }
  197. _, err = controller.NewNetwork("framerelay", "dummy",
  198. libnetwork.NetworkOptionGeneric(getEmptyGenericOption()))
  199. if err == nil {
  200. t.Fatal("Expected to fail. But instead succeeded")
  201. }
  202. if err != libnetwork.ErrInvalidNetworkDriver {
  203. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  204. }
  205. }
  206. func TestNoInitDriver(t *testing.T) {
  207. controller, err := libnetwork.New()
  208. if err != nil {
  209. t.Fatal(err)
  210. }
  211. _, err = controller.NewNetwork("ppp", "dummy",
  212. libnetwork.NetworkOptionGeneric(getEmptyGenericOption()))
  213. if err == nil {
  214. t.Fatal("Expected to fail. But instead succeeded")
  215. }
  216. if err != libnetwork.ErrInvalidNetworkDriver {
  217. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  218. }
  219. }
  220. func TestDuplicateNetwork(t *testing.T) {
  221. if !netutils.IsRunningInContainer() {
  222. defer netutils.SetupTestNetNS(t)()
  223. }
  224. controller, err := libnetwork.New()
  225. if err != nil {
  226. t.Fatal(err)
  227. }
  228. genericOption := make(map[string]interface{})
  229. genericOption[netlabel.GenericData] = options.Generic{}
  230. err = controller.ConfigureNetworkDriver(bridgeNetType, genericOption)
  231. if err != nil {
  232. t.Fatal(err)
  233. }
  234. _, err = controller.NewNetwork(bridgeNetType, "testnetwork",
  235. libnetwork.NetworkOptionGeneric(genericOption))
  236. if err != nil {
  237. t.Fatal(err)
  238. }
  239. _, err = controller.NewNetwork(bridgeNetType, "testnetwork")
  240. if err == nil {
  241. t.Fatal("Expected to fail. But instead succeeded")
  242. }
  243. if _, ok := err.(libnetwork.NetworkNameError); !ok {
  244. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  245. }
  246. }
  247. func TestNetworkName(t *testing.T) {
  248. if !netutils.IsRunningInContainer() {
  249. defer netutils.SetupTestNetNS(t)()
  250. }
  251. _, err := createTestNetwork(bridgeNetType, "", options.Generic{}, options.Generic{})
  252. if err == nil {
  253. t.Fatal("Expected to fail. But instead succeeded")
  254. }
  255. if err != libnetwork.ErrInvalidName {
  256. t.Fatal("Expected to fail with ErrInvalidName error")
  257. }
  258. networkName := "testnetwork"
  259. n, err := createTestNetwork(bridgeNetType, networkName, options.Generic{}, options.Generic{})
  260. if err != nil {
  261. t.Fatal(err)
  262. }
  263. if n.Name() != networkName {
  264. t.Fatalf("Expected network name %s, got %s", networkName, n.Name())
  265. }
  266. }
  267. func TestNetworkType(t *testing.T) {
  268. if !netutils.IsRunningInContainer() {
  269. defer netutils.SetupTestNetNS(t)()
  270. }
  271. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  272. if err != nil {
  273. t.Fatal(err)
  274. }
  275. if n.Type() != bridgeNetType {
  276. t.Fatalf("Expected network type %s, got %s", bridgeNetType, n.Type())
  277. }
  278. }
  279. func TestNetworkID(t *testing.T) {
  280. if !netutils.IsRunningInContainer() {
  281. defer netutils.SetupTestNetNS(t)()
  282. }
  283. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  284. if err != nil {
  285. t.Fatal(err)
  286. }
  287. if n.ID() == "" {
  288. t.Fatal("Expected non-empty network id")
  289. }
  290. }
  291. func TestDeleteNetworkWithActiveEndpoints(t *testing.T) {
  292. if !netutils.IsRunningInContainer() {
  293. defer netutils.SetupTestNetNS(t)()
  294. }
  295. option := options.Generic{
  296. "BridgeName": bridgeName,
  297. "AllowNonDefaultBridge": true}
  298. network, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, option)
  299. if err != nil {
  300. t.Fatal(err)
  301. }
  302. ep, err := network.CreateEndpoint("testep")
  303. if err != nil {
  304. t.Fatal(err)
  305. }
  306. err = network.Delete()
  307. if err == nil {
  308. t.Fatal("Expected to fail. But instead succeeded")
  309. }
  310. if _, ok := err.(*libnetwork.ActiveEndpointsError); !ok {
  311. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  312. }
  313. // Done testing. Now cleanup.
  314. if err := ep.Delete(); err != nil {
  315. t.Fatal(err)
  316. }
  317. if err := network.Delete(); err != nil {
  318. t.Fatal(err)
  319. }
  320. }
  321. func TestUnknownNetwork(t *testing.T) {
  322. if !netutils.IsRunningInContainer() {
  323. defer netutils.SetupTestNetNS(t)()
  324. }
  325. option := options.Generic{
  326. "BridgeName": bridgeName,
  327. "AllowNonDefaultBridge": true}
  328. network, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, option)
  329. if err != nil {
  330. t.Fatal(err)
  331. }
  332. err = network.Delete()
  333. if err != nil {
  334. t.Fatal(err)
  335. }
  336. err = network.Delete()
  337. if err == nil {
  338. t.Fatal("Expected to fail. But instead succeeded")
  339. }
  340. if _, ok := err.(*libnetwork.UnknownNetworkError); !ok {
  341. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  342. }
  343. }
  344. func TestUnknownEndpoint(t *testing.T) {
  345. if !netutils.IsRunningInContainer() {
  346. defer netutils.SetupTestNetNS(t)()
  347. }
  348. ip, subnet, err := net.ParseCIDR("192.168.100.1/24")
  349. if err != nil {
  350. t.Fatal(err)
  351. }
  352. subnet.IP = ip
  353. option := options.Generic{
  354. "BridgeName": bridgeName,
  355. "AddressIPv4": subnet,
  356. "AllowNonDefaultBridge": true}
  357. network, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, option)
  358. if err != nil {
  359. t.Fatal(err)
  360. }
  361. _, err = network.CreateEndpoint("")
  362. if err == nil {
  363. t.Fatal("Expected to fail. But instead succeeded")
  364. }
  365. if err != libnetwork.ErrInvalidName {
  366. t.Fatal("Expected to fail with ErrInvalidName error")
  367. }
  368. ep, err := network.CreateEndpoint("testep")
  369. if err != nil {
  370. t.Fatal(err)
  371. }
  372. err = ep.Delete()
  373. if err != nil {
  374. t.Fatal(err)
  375. }
  376. err = ep.Delete()
  377. if err == nil {
  378. t.Fatal("Expected to fail. But instead succeeded")
  379. }
  380. if _, ok := err.(*libnetwork.UnknownEndpointError); !ok {
  381. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  382. }
  383. // Done testing. Now cleanup
  384. if err := network.Delete(); err != nil {
  385. t.Fatal(err)
  386. }
  387. }
  388. func TestNetworkEndpointsWalkers(t *testing.T) {
  389. if !netutils.IsRunningInContainer() {
  390. defer netutils.SetupTestNetNS(t)()
  391. }
  392. controller, err := libnetwork.New()
  393. if err != nil {
  394. t.Fatal(err)
  395. }
  396. err = controller.ConfigureNetworkDriver(bridgeNetType, getEmptyGenericOption())
  397. if err != nil {
  398. t.Fatal(err)
  399. }
  400. // Create network 1 and add 2 endpoint: ep11, ep12
  401. net1, err := controller.NewNetwork(bridgeNetType, "network1")
  402. if err != nil {
  403. t.Fatal(err)
  404. }
  405. ep11, err := net1.CreateEndpoint("ep11")
  406. if err != nil {
  407. t.Fatal(err)
  408. }
  409. ep12, err := net1.CreateEndpoint("ep12")
  410. if err != nil {
  411. t.Fatal(err)
  412. }
  413. // Test list methods on net1
  414. epList1 := net1.Endpoints()
  415. if len(epList1) != 2 {
  416. t.Fatalf("Endpoints() returned wrong number of elements: %d instead of 2", len(epList1))
  417. }
  418. // endpoint order is not guaranteed
  419. for _, e := range epList1 {
  420. if e != ep11 && e != ep12 {
  421. t.Fatal("Endpoints() did not return all the expected elements")
  422. }
  423. }
  424. // Test Endpoint Walk method
  425. var epName string
  426. var epWanted libnetwork.Endpoint
  427. wlk := func(ep libnetwork.Endpoint) bool {
  428. if ep.Name() == epName {
  429. epWanted = ep
  430. return true
  431. }
  432. return false
  433. }
  434. // Look for ep1 on network1
  435. epName = "ep11"
  436. net1.WalkEndpoints(wlk)
  437. if epWanted == nil {
  438. t.Fatal(err)
  439. }
  440. if ep11 != epWanted {
  441. t.Fatal(err)
  442. }
  443. // Test Network Walk method
  444. var netName string
  445. var netWanted libnetwork.Network
  446. nwWlk := func(nw libnetwork.Network) bool {
  447. if nw.Name() == netName {
  448. netWanted = nw
  449. return true
  450. }
  451. return false
  452. }
  453. // Look for network named "network1"
  454. netName = "network1"
  455. controller.WalkNetworks(nwWlk)
  456. if netWanted == nil {
  457. t.Fatal(err)
  458. }
  459. if net1 != netWanted {
  460. t.Fatal(err)
  461. }
  462. }
  463. func TestControllerQuery(t *testing.T) {
  464. if !netutils.IsRunningInContainer() {
  465. defer netutils.SetupTestNetNS(t)()
  466. }
  467. controller, err := libnetwork.New()
  468. if err != nil {
  469. t.Fatal(err)
  470. }
  471. err = controller.ConfigureNetworkDriver(bridgeNetType, getEmptyGenericOption())
  472. if err != nil {
  473. t.Fatal(err)
  474. }
  475. // Create network 1
  476. net1, err := controller.NewNetwork(bridgeNetType, "network1")
  477. if err != nil {
  478. t.Fatal(err)
  479. }
  480. _, err = controller.NetworkByName("")
  481. if err == nil {
  482. t.Fatalf("NetworkByName() succeeded with invalid target name")
  483. }
  484. if err != libnetwork.ErrInvalidName {
  485. t.Fatalf("NetworkByName() failed with unexpected error: %v", err)
  486. }
  487. _, err = controller.NetworkByID("")
  488. if err == nil {
  489. t.Fatalf("NetworkByID() succeeded with invalid target id")
  490. }
  491. if err != libnetwork.ErrInvalidID {
  492. t.Fatalf("NetworkByID() failed with unexpected error: %v", err)
  493. }
  494. g, err := controller.NetworkByID("network1")
  495. if err == nil {
  496. t.Fatalf("Unexpected success for NetworkByID(): %g", g)
  497. }
  498. if err != libnetwork.ErrNoSuchNetwork {
  499. t.Fatalf("NetworkByID() failed with unexpected error: %v", err)
  500. }
  501. g, err = controller.NetworkByName("network1")
  502. if err != nil {
  503. t.Fatalf("Unexpected failure for NetworkByName(): %v", err)
  504. }
  505. if g == nil {
  506. t.Fatalf("NetworkByName() did not find the network")
  507. }
  508. if g != net1 {
  509. t.Fatalf("NetworkByName() returned the wrong network")
  510. }
  511. g, err = controller.NetworkByID(net1.ID())
  512. if err != nil {
  513. t.Fatalf("Unexpected failure for NetworkByID(): %v", err)
  514. }
  515. if net1 != g {
  516. t.Fatalf("NetworkByID() returned unexpected element: %v", g)
  517. }
  518. }
  519. func TestNetworkQuery(t *testing.T) {
  520. if !netutils.IsRunningInContainer() {
  521. defer netutils.SetupTestNetNS(t)()
  522. }
  523. controller, err := libnetwork.New()
  524. if err != nil {
  525. t.Fatal(err)
  526. }
  527. err = controller.ConfigureNetworkDriver(bridgeNetType, getEmptyGenericOption())
  528. if err != nil {
  529. t.Fatal(err)
  530. }
  531. // Create network 1 and add 2 endpoint: ep11, ep12
  532. net1, err := controller.NewNetwork(bridgeNetType, "network1")
  533. if err != nil {
  534. t.Fatal(err)
  535. }
  536. ep11, err := net1.CreateEndpoint("ep11")
  537. if err != nil {
  538. t.Fatal(err)
  539. }
  540. ep12, err := net1.CreateEndpoint("ep12")
  541. if err != nil {
  542. t.Fatal(err)
  543. }
  544. e, err := net1.EndpointByName("ep11")
  545. if err != nil {
  546. t.Fatal(err)
  547. }
  548. if ep11 != e {
  549. t.Fatalf("EndpointByName() returned %v instead of %v", e, ep11)
  550. }
  551. e, err = net1.EndpointByName("")
  552. if err == nil {
  553. t.Fatalf("EndpointByName() succeeded with invalid target name")
  554. }
  555. if err != libnetwork.ErrInvalidName {
  556. t.Fatalf("EndpointByName() failed with unexpected error: %v", err)
  557. }
  558. e, err = net1.EndpointByName("IamNotAnEndpoint")
  559. if err == nil {
  560. t.Fatalf("EndpointByName() succeeded with unknown target name")
  561. }
  562. if err != libnetwork.ErrNoSuchEndpoint {
  563. t.Fatal(err)
  564. }
  565. if e != nil {
  566. t.Fatalf("EndpointByName(): expected nil, got %v", e)
  567. }
  568. e, err = net1.EndpointByID(ep12.ID())
  569. if err != nil {
  570. t.Fatal(err)
  571. }
  572. if ep12 != e {
  573. t.Fatalf("EndpointByID() returned %v instead of %v", e, ep12)
  574. }
  575. e, err = net1.EndpointByID("")
  576. if err == nil {
  577. t.Fatalf("EndpointByID() succeeded with invalid target id")
  578. }
  579. if err != libnetwork.ErrInvalidID {
  580. t.Fatalf("EndpointByID() failed with unexpected error: %v", err)
  581. }
  582. }
  583. const containerID = "valid_container"
  584. func TestEndpointJoin(t *testing.T) {
  585. if !netutils.IsRunningInContainer() {
  586. defer netutils.SetupTestNetNS(t)()
  587. }
  588. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  589. if err != nil {
  590. t.Fatal(err)
  591. }
  592. ep, err := n.CreateEndpoint("ep1")
  593. if err != nil {
  594. t.Fatal(err)
  595. }
  596. _, err = ep.Join(containerID,
  597. libnetwork.JoinOptionHostname("test"),
  598. libnetwork.JoinOptionDomainname("docker.io"),
  599. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  600. if err != nil {
  601. t.Fatal(err)
  602. }
  603. defer func() {
  604. err = ep.Leave(containerID)
  605. if err != nil {
  606. t.Fatal(err)
  607. }
  608. }()
  609. }
  610. func TestEndpointJoinInvalidContainerId(t *testing.T) {
  611. if !netutils.IsRunningInContainer() {
  612. defer netutils.SetupTestNetNS(t)()
  613. }
  614. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  615. if err != nil {
  616. t.Fatal(err)
  617. }
  618. ep, err := n.CreateEndpoint("ep1")
  619. if err != nil {
  620. t.Fatal(err)
  621. }
  622. _, err = ep.Join("")
  623. if err == nil {
  624. t.Fatal("Expected to fail join with empty container id string")
  625. }
  626. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  627. t.Fatalf("Failed for unexpected reason: %v", err)
  628. }
  629. }
  630. func TestEndpointDeleteWithActiveContainer(t *testing.T) {
  631. if !netutils.IsRunningInContainer() {
  632. defer netutils.SetupTestNetNS(t)()
  633. }
  634. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  635. if err != nil {
  636. t.Fatal(err)
  637. }
  638. ep, err := n.CreateEndpoint("ep1")
  639. if err != nil {
  640. t.Fatal(err)
  641. }
  642. _, err = ep.Join(containerID,
  643. libnetwork.JoinOptionHostname("test"),
  644. libnetwork.JoinOptionDomainname("docker.io"),
  645. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  646. if err != nil {
  647. t.Fatal(err)
  648. }
  649. defer func() {
  650. err = ep.Leave(containerID)
  651. if err != nil {
  652. t.Fatal(err)
  653. }
  654. err = ep.Delete()
  655. if err != nil {
  656. t.Fatal(err)
  657. }
  658. }()
  659. err = ep.Delete()
  660. if err == nil {
  661. t.Fatal("Expected to fail. But instead succeeded")
  662. }
  663. if _, ok := err.(*libnetwork.ActiveContainerError); !ok {
  664. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  665. }
  666. }
  667. func TestEndpointMultipleJoins(t *testing.T) {
  668. if !netutils.IsRunningInContainer() {
  669. defer netutils.SetupTestNetNS(t)()
  670. }
  671. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  672. if err != nil {
  673. t.Fatal(err)
  674. }
  675. ep, err := n.CreateEndpoint("ep1")
  676. if err != nil {
  677. t.Fatal(err)
  678. }
  679. _, err = ep.Join(containerID,
  680. libnetwork.JoinOptionHostname("test"),
  681. libnetwork.JoinOptionDomainname("docker.io"),
  682. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  683. if err != nil {
  684. t.Fatal(err)
  685. }
  686. defer func() {
  687. err = ep.Leave(containerID)
  688. if err != nil {
  689. t.Fatal(err)
  690. }
  691. }()
  692. _, err = ep.Join("container2")
  693. if err == nil {
  694. t.Fatal("Expected to fail multiple joins for the same endpoint")
  695. }
  696. if err != libnetwork.ErrInvalidJoin {
  697. t.Fatalf("Failed for unexpected reason: %v", err)
  698. }
  699. }
  700. func TestEndpointInvalidLeave(t *testing.T) {
  701. if !netutils.IsRunningInContainer() {
  702. defer netutils.SetupTestNetNS(t)()
  703. }
  704. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{}, options.Generic{})
  705. if err != nil {
  706. t.Fatal(err)
  707. }
  708. ep, err := n.CreateEndpoint("ep1")
  709. if err != nil {
  710. t.Fatal(err)
  711. }
  712. err = ep.Leave(containerID)
  713. if err == nil {
  714. t.Fatal("Expected to fail leave from an endpoint which has no active join")
  715. }
  716. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  717. if err != libnetwork.ErrNoContainer {
  718. t.Fatalf("Failed for unexpected reason: %v", err)
  719. }
  720. }
  721. _, err = ep.Join(containerID,
  722. libnetwork.JoinOptionHostname("test"),
  723. libnetwork.JoinOptionDomainname("docker.io"),
  724. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  725. if err != nil {
  726. t.Fatal(err)
  727. }
  728. defer func() {
  729. err = ep.Leave(containerID)
  730. if err != nil {
  731. t.Fatal(err)
  732. }
  733. }()
  734. err = ep.Leave("")
  735. if err == nil {
  736. t.Fatal("Expected to fail leave with empty container id")
  737. }
  738. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  739. t.Fatalf("Failed for unexpected reason: %v", err)
  740. }
  741. err = ep.Leave("container2")
  742. if err == nil {
  743. t.Fatal("Expected to fail leave with wrong container id")
  744. }
  745. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  746. t.Fatalf("Failed for unexpected reason: %v", err)
  747. }
  748. }
  749. func TestEndpointUpdateParent(t *testing.T) {
  750. if !netutils.IsRunningInContainer() {
  751. defer netutils.SetupTestNetNS(t)()
  752. }
  753. n, err := createTestNetwork("bridge", "testnetwork", options.Generic{}, options.Generic{})
  754. if err != nil {
  755. t.Fatal(err)
  756. }
  757. ep1, err := n.CreateEndpoint("ep1", nil)
  758. if err != nil {
  759. t.Fatal(err)
  760. }
  761. _, err = ep1.Join(containerID,
  762. libnetwork.JoinOptionHostname("test1"),
  763. libnetwork.JoinOptionDomainname("docker.io"),
  764. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  765. if err != nil {
  766. t.Fatal(err)
  767. }
  768. defer func() {
  769. err = ep1.Leave(containerID)
  770. if err != nil {
  771. t.Fatal(err)
  772. }
  773. }()
  774. ep2, err := n.CreateEndpoint("ep2", nil)
  775. if err != nil {
  776. t.Fatal(err)
  777. }
  778. _, err = ep2.Join("container2",
  779. libnetwork.JoinOptionHostname("test2"),
  780. libnetwork.JoinOptionDomainname("docker.io"),
  781. libnetwork.JoinOptionHostsPath("/var/lib/docker/test_network/container2/hosts"),
  782. libnetwork.JoinOptionParentUpdate(ep1.ID(), "web", "192.168.0.2"))
  783. if err != nil {
  784. t.Fatal(err)
  785. }
  786. defer func() {
  787. err = ep2.Leave("container2")
  788. if err != nil {
  789. t.Fatal(err)
  790. }
  791. }()
  792. }
  793. func TestEnableIPv6(t *testing.T) {
  794. if !netutils.IsRunningInContainer() {
  795. defer netutils.SetupTestNetNS(t)()
  796. }
  797. tmpResolvConf := []byte("search pommesfrites.fr\nnameserver 12.34.56.78\nnameserver 2001:4860:4860::8888")
  798. //take a copy of resolv.conf for restoring after test completes
  799. resolvConfSystem, err := ioutil.ReadFile("/etc/resolv.conf")
  800. if err != nil {
  801. t.Fatal(err)
  802. }
  803. //cleanup
  804. defer func() {
  805. if err := ioutil.WriteFile("/etc/resolv.conf", resolvConfSystem, 0644); err != nil {
  806. t.Fatal(err)
  807. }
  808. }()
  809. ip, cidrv6, err := net.ParseCIDR("fe80::1/64")
  810. if err != nil {
  811. t.Fatal(err)
  812. }
  813. cidrv6.IP = ip
  814. netOption := options.Generic{
  815. netlabel.EnableIPv6: true,
  816. netlabel.GenericData: options.Generic{
  817. "FixedCIDRv6": cidrv6,
  818. },
  819. }
  820. n, err := createTestNetwork("bridge", "testnetwork", options.Generic{}, netOption)
  821. if err != nil {
  822. t.Fatal(err)
  823. }
  824. ep1, err := n.CreateEndpoint("ep1", nil)
  825. if err != nil {
  826. t.Fatal(err)
  827. }
  828. if err := ioutil.WriteFile("/etc/resolv.conf", tmpResolvConf, 0644); err != nil {
  829. t.Fatal(err)
  830. }
  831. resolvConfPath := "/tmp/libnetwork_test/resolv.conf"
  832. defer os.Remove(resolvConfPath)
  833. _, err = ep1.Join(containerID,
  834. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  835. if err != nil {
  836. t.Fatal(err)
  837. }
  838. defer func() {
  839. err = ep1.Leave(containerID)
  840. if err != nil {
  841. t.Fatal(err)
  842. }
  843. }()
  844. content, err := ioutil.ReadFile(resolvConfPath)
  845. if err != nil {
  846. t.Fatal(err)
  847. }
  848. if !bytes.Equal(content, tmpResolvConf) {
  849. t.Fatalf("Expected %s, Got %s", string(tmpResolvConf), string(content))
  850. }
  851. if err != nil {
  852. t.Fatal(err)
  853. }
  854. }
  855. func TestResolvConf(t *testing.T) {
  856. if !netutils.IsRunningInContainer() {
  857. defer netutils.SetupTestNetNS(t)()
  858. }
  859. tmpResolvConf1 := []byte("search pommesfrites.fr\nnameserver 12.34.56.78\nnameserver 2001:4860:4860::8888")
  860. expectedResolvConf1 := []byte("search pommesfrites.fr\nnameserver 12.34.56.78\n")
  861. tmpResolvConf2 := []byte("search pommesfrites.fr\nnameserver 112.34.56.78\nnameserver 2001:4860:4860::8888")
  862. expectedResolvConf2 := []byte("search pommesfrites.fr\nnameserver 112.34.56.78\n")
  863. tmpResolvConf3 := []byte("search pommesfrites.fr\nnameserver 113.34.56.78\n")
  864. //take a copy of resolv.conf for restoring after test completes
  865. resolvConfSystem, err := ioutil.ReadFile("/etc/resolv.conf")
  866. if err != nil {
  867. t.Fatal(err)
  868. }
  869. //cleanup
  870. defer func() {
  871. if err := ioutil.WriteFile("/etc/resolv.conf", resolvConfSystem, 0644); err != nil {
  872. t.Fatal(err)
  873. }
  874. }()
  875. n, err := createTestNetwork("bridge", "testnetwork", options.Generic{}, options.Generic{})
  876. if err != nil {
  877. t.Fatal(err)
  878. }
  879. ep1, err := n.CreateEndpoint("ep1", nil)
  880. if err != nil {
  881. t.Fatal(err)
  882. }
  883. if err := ioutil.WriteFile("/etc/resolv.conf", tmpResolvConf1, 0644); err != nil {
  884. t.Fatal(err)
  885. }
  886. resolvConfPath := "/tmp/libnetwork_test/resolv.conf"
  887. defer os.Remove(resolvConfPath)
  888. _, err = ep1.Join(containerID,
  889. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  890. if err != nil {
  891. t.Fatal(err)
  892. }
  893. defer func() {
  894. err = ep1.Leave(containerID)
  895. if err != nil {
  896. t.Fatal(err)
  897. }
  898. }()
  899. content, err := ioutil.ReadFile(resolvConfPath)
  900. if err != nil {
  901. t.Fatal(err)
  902. }
  903. if !bytes.Equal(content, expectedResolvConf1) {
  904. t.Fatalf("Expected %s, Got %s", string(expectedResolvConf1), string(content))
  905. }
  906. err = ep1.Leave(containerID)
  907. if err != nil {
  908. t.Fatal(err)
  909. }
  910. if err := ioutil.WriteFile("/etc/resolv.conf", tmpResolvConf2, 0644); err != nil {
  911. t.Fatal(err)
  912. }
  913. _, err = ep1.Join(containerID,
  914. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  915. if err != nil {
  916. t.Fatal(err)
  917. }
  918. content, err = ioutil.ReadFile(resolvConfPath)
  919. if err != nil {
  920. t.Fatal(err)
  921. }
  922. if !bytes.Equal(content, expectedResolvConf2) {
  923. t.Fatalf("Expected %s, Got %s", string(expectedResolvConf2), string(content))
  924. }
  925. if err := ioutil.WriteFile(resolvConfPath, tmpResolvConf3, 0644); err != nil {
  926. t.Fatal(err)
  927. }
  928. err = ep1.Leave(containerID)
  929. if err != nil {
  930. t.Fatal(err)
  931. }
  932. _, err = ep1.Join(containerID,
  933. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  934. if err != nil {
  935. t.Fatal(err)
  936. }
  937. content, err = ioutil.ReadFile(resolvConfPath)
  938. if err != nil {
  939. t.Fatal(err)
  940. }
  941. if !bytes.Equal(content, tmpResolvConf3) {
  942. t.Fatalf("Expected %s, Got %s", string(tmpResolvConf3), string(content))
  943. }
  944. }
  945. var (
  946. once sync.Once
  947. ctrlr libnetwork.NetworkController
  948. start = make(chan struct{})
  949. done = make(chan chan struct{}, numThreads-1)
  950. origns = netns.None()
  951. testns = netns.None()
  952. )
  953. const (
  954. iterCnt = 25
  955. numThreads = 3
  956. first = 1
  957. last = numThreads
  958. debug = false
  959. )
  960. func createGlobalInstance(t *testing.T) {
  961. var err error
  962. defer close(start)
  963. origns, err = netns.Get()
  964. if err != nil {
  965. t.Fatal(err)
  966. }
  967. if netutils.IsRunningInContainer() {
  968. testns = origns
  969. } else {
  970. testns, err = netns.New()
  971. if err != nil {
  972. t.Fatal(err)
  973. }
  974. }
  975. ctrlr, err = libnetwork.New()
  976. if err != nil {
  977. t.Fatal(err)
  978. }
  979. err = ctrlr.ConfigureNetworkDriver(bridgeNetType, getEmptyGenericOption())
  980. if err != nil {
  981. t.Fatal("configure driver")
  982. }
  983. net, err := ctrlr.NewNetwork(bridgeNetType, "network1")
  984. if err != nil {
  985. t.Fatal("new network")
  986. }
  987. _, err = net.CreateEndpoint("ep1")
  988. if err != nil {
  989. t.Fatal("createendpoint")
  990. }
  991. }
  992. func debugf(format string, a ...interface{}) (int, error) {
  993. if debug {
  994. return fmt.Printf(format, a...)
  995. }
  996. return 0, nil
  997. }
  998. func parallelJoin(t *testing.T, ep libnetwork.Endpoint, thrNumber int) {
  999. debugf("J%d.", thrNumber)
  1000. _, err := ep.Join("racing_container")
  1001. runtime.LockOSThread()
  1002. if err != nil {
  1003. if err != libnetwork.ErrNoContainer && err != libnetwork.ErrInvalidJoin {
  1004. t.Fatal(err)
  1005. }
  1006. debugf("JE%d(%v).", thrNumber, err)
  1007. }
  1008. debugf("JD%d.", thrNumber)
  1009. }
  1010. func parallelLeave(t *testing.T, ep libnetwork.Endpoint, thrNumber int) {
  1011. debugf("L%d.", thrNumber)
  1012. err := ep.Leave("racing_container")
  1013. runtime.LockOSThread()
  1014. if err != nil {
  1015. if err != libnetwork.ErrNoContainer && err != libnetwork.ErrInvalidJoin {
  1016. t.Fatal(err)
  1017. }
  1018. debugf("LE%d(%v).", thrNumber, err)
  1019. }
  1020. debugf("LD%d.", thrNumber)
  1021. }
  1022. func runParallelTests(t *testing.T, thrNumber int) {
  1023. var err error
  1024. t.Parallel()
  1025. pTest := flag.Lookup("test.parallel")
  1026. if pTest == nil {
  1027. t.Skip("Skipped because test.parallel flag not set;")
  1028. }
  1029. numParallel, err := strconv.Atoi(pTest.Value.String())
  1030. if err != nil {
  1031. t.Fatal(err)
  1032. }
  1033. if numParallel < numThreads {
  1034. t.Skip("Skipped because t.parallel was less than ", numThreads)
  1035. }
  1036. runtime.LockOSThread()
  1037. defer runtime.UnlockOSThread()
  1038. if thrNumber == first {
  1039. createGlobalInstance(t)
  1040. }
  1041. if thrNumber != first {
  1042. select {
  1043. case <-start:
  1044. }
  1045. thrdone := make(chan struct{})
  1046. done <- thrdone
  1047. defer close(thrdone)
  1048. if thrNumber == last {
  1049. defer close(done)
  1050. }
  1051. err = netns.Set(testns)
  1052. if err != nil {
  1053. t.Fatal(err)
  1054. }
  1055. }
  1056. defer netns.Set(origns)
  1057. net, err := ctrlr.NetworkByName("network1")
  1058. if err != nil {
  1059. t.Fatal(err)
  1060. }
  1061. if net == nil {
  1062. t.Fatal("Could not find network1")
  1063. }
  1064. ep, err := net.EndpointByName("ep1")
  1065. if err != nil {
  1066. t.Fatal(err)
  1067. }
  1068. if ep == nil {
  1069. t.Fatal("Got nil ep with no error")
  1070. }
  1071. for i := 0; i < iterCnt; i++ {
  1072. parallelJoin(t, ep, thrNumber)
  1073. parallelLeave(t, ep, thrNumber)
  1074. }
  1075. debugf("\n")
  1076. if thrNumber == first {
  1077. for thrdone := range done {
  1078. select {
  1079. case <-thrdone:
  1080. }
  1081. }
  1082. testns.Close()
  1083. err = ep.Delete()
  1084. if err != nil {
  1085. t.Fatal(err)
  1086. }
  1087. }
  1088. }
  1089. func TestParallel1(t *testing.T) {
  1090. runParallelTests(t, 1)
  1091. }
  1092. func TestParallel2(t *testing.T) {
  1093. runParallelTests(t, 2)
  1094. }
  1095. func TestParallel3(t *testing.T) {
  1096. runParallelTests(t, 3)
  1097. }