libnetwork_test.go 36 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688
  1. package libnetwork_test
  2. import (
  3. "bytes"
  4. "flag"
  5. "fmt"
  6. "io/ioutil"
  7. "net"
  8. "net/http"
  9. "net/http/httptest"
  10. "os"
  11. "runtime"
  12. "strconv"
  13. "sync"
  14. "testing"
  15. log "github.com/Sirupsen/logrus"
  16. "github.com/docker/docker/pkg/plugins"
  17. "github.com/docker/docker/pkg/reexec"
  18. "github.com/docker/libnetwork"
  19. "github.com/docker/libnetwork/datastore"
  20. "github.com/docker/libnetwork/driverapi"
  21. "github.com/docker/libnetwork/netlabel"
  22. "github.com/docker/libnetwork/netutils"
  23. "github.com/docker/libnetwork/options"
  24. "github.com/docker/libnetwork/types"
  25. "github.com/vishvananda/netlink"
  26. "github.com/vishvananda/netns"
  27. )
  28. const (
  29. bridgeNetType = "bridge"
  30. bridgeName = "docker0"
  31. )
  32. var controller libnetwork.NetworkController
  33. func TestMain(m *testing.M) {
  34. if reexec.Init() {
  35. return
  36. }
  37. if err := createController(); err != nil {
  38. os.Exit(1)
  39. }
  40. option := options.Generic{
  41. "EnableIPForwarding": true,
  42. }
  43. genericOption := make(map[string]interface{})
  44. genericOption[netlabel.GenericData] = option
  45. err := controller.ConfigureNetworkDriver(bridgeNetType, genericOption)
  46. if err != nil {
  47. //m.Fatal(err)
  48. os.Exit(1)
  49. }
  50. libnetwork.SetTestDataStore(controller, datastore.NewCustomDataStore(datastore.NewMockStore()))
  51. os.Exit(m.Run())
  52. }
  53. func createController() error {
  54. var err error
  55. controller, err = libnetwork.New("")
  56. if err != nil {
  57. return err
  58. }
  59. return nil
  60. }
  61. func createTestNetwork(networkType, networkName string, netOption options.Generic) (libnetwork.Network, error) {
  62. network, err := controller.NewNetwork(networkType, networkName,
  63. libnetwork.NetworkOptionGeneric(netOption))
  64. if err != nil {
  65. return nil, err
  66. }
  67. return network, nil
  68. }
  69. func getEmptyGenericOption() map[string]interface{} {
  70. genericOption := make(map[string]interface{})
  71. genericOption[netlabel.GenericData] = options.Generic{}
  72. return genericOption
  73. }
  74. func getPortMapping() []types.PortBinding {
  75. return []types.PortBinding{
  76. types.PortBinding{Proto: types.TCP, Port: uint16(230), HostPort: uint16(23000)},
  77. types.PortBinding{Proto: types.UDP, Port: uint16(200), HostPort: uint16(22000)},
  78. types.PortBinding{Proto: types.TCP, Port: uint16(120), HostPort: uint16(12000)},
  79. }
  80. }
  81. func TestNull(t *testing.T) {
  82. network, err := createTestNetwork("null", "testnetwork", options.Generic{})
  83. if err != nil {
  84. t.Fatal(err)
  85. }
  86. ep, err := network.CreateEndpoint("testep")
  87. if err != nil {
  88. t.Fatal(err)
  89. }
  90. err = ep.Join("null_container",
  91. libnetwork.JoinOptionHostname("test"),
  92. libnetwork.JoinOptionDomainname("docker.io"),
  93. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  94. if err != nil {
  95. t.Fatal(err)
  96. }
  97. err = ep.Leave("null_container")
  98. if err != nil {
  99. t.Fatal(err)
  100. }
  101. if err := ep.Delete(); err != nil {
  102. t.Fatal(err)
  103. }
  104. if err := network.Delete(); err != nil {
  105. t.Fatal(err)
  106. }
  107. }
  108. func TestHost(t *testing.T) {
  109. network, err := createTestNetwork("host", "testnetwork", options.Generic{})
  110. if err != nil {
  111. t.Fatal(err)
  112. }
  113. ep1, err := network.CreateEndpoint("testep1")
  114. if err != nil {
  115. t.Fatal(err)
  116. }
  117. err = ep1.Join("host_container1",
  118. libnetwork.JoinOptionHostname("test1"),
  119. libnetwork.JoinOptionDomainname("docker.io"),
  120. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"),
  121. libnetwork.JoinOptionUseDefaultSandbox())
  122. if err != nil {
  123. t.Fatal(err)
  124. }
  125. ep2, err := network.CreateEndpoint("testep2")
  126. if err != nil {
  127. t.Fatal(err)
  128. }
  129. err = ep2.Join("host_container2",
  130. libnetwork.JoinOptionHostname("test2"),
  131. libnetwork.JoinOptionDomainname("docker.io"),
  132. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"),
  133. libnetwork.JoinOptionUseDefaultSandbox())
  134. if err != nil {
  135. t.Fatal(err)
  136. }
  137. err = ep1.Leave("host_container1")
  138. if err != nil {
  139. t.Fatal(err)
  140. }
  141. err = ep2.Leave("host_container2")
  142. if err != nil {
  143. t.Fatal(err)
  144. }
  145. if err := ep1.Delete(); err != nil {
  146. t.Fatal(err)
  147. }
  148. if err := ep2.Delete(); err != nil {
  149. t.Fatal(err)
  150. }
  151. // Try to create another host endpoint and join/leave that.
  152. ep3, err := network.CreateEndpoint("testep3")
  153. if err != nil {
  154. t.Fatal(err)
  155. }
  156. err = ep3.Join("host_container3",
  157. libnetwork.JoinOptionHostname("test3"),
  158. libnetwork.JoinOptionDomainname("docker.io"),
  159. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"),
  160. libnetwork.JoinOptionUseDefaultSandbox())
  161. if err != nil {
  162. t.Fatal(err)
  163. }
  164. err = ep3.Leave("host_container3")
  165. if err != nil {
  166. t.Fatal(err)
  167. }
  168. if err := ep3.Delete(); err != nil {
  169. t.Fatal(err)
  170. }
  171. if err := network.Delete(); err != nil {
  172. t.Fatal(err)
  173. }
  174. }
  175. func TestBridge(t *testing.T) {
  176. if !netutils.IsRunningInContainer() {
  177. defer netutils.SetupTestNetNS(t)()
  178. }
  179. ip, subnet, err := net.ParseCIDR("192.168.100.1/24")
  180. if err != nil {
  181. t.Fatal(err)
  182. }
  183. subnet.IP = ip
  184. ip, cidr, err := net.ParseCIDR("192.168.100.2/28")
  185. if err != nil {
  186. t.Fatal(err)
  187. }
  188. cidr.IP = ip
  189. ip, cidrv6, err := net.ParseCIDR("fe90::1/96")
  190. if err != nil {
  191. t.Fatal(err)
  192. }
  193. cidrv6.IP = ip
  194. log.Debug("Adding a bridge")
  195. netOption := options.Generic{
  196. netlabel.GenericData: options.Generic{
  197. "BridgeName": bridgeName,
  198. "AddressIPv4": subnet,
  199. "FixedCIDR": cidr,
  200. "FixedCIDRv6": cidrv6,
  201. "EnableIPv6": true,
  202. "EnableIPTables": true,
  203. "EnableIPMasquerade": true,
  204. "EnableICC": true,
  205. "AllowNonDefaultBridge": true,
  206. },
  207. }
  208. network, err := createTestNetwork(bridgeNetType, "testnetwork", netOption)
  209. if err != nil {
  210. t.Fatal(err)
  211. }
  212. ep, err := network.CreateEndpoint("testep", libnetwork.CreateOptionPortMapping(getPortMapping()))
  213. if err != nil {
  214. t.Fatal(err)
  215. }
  216. epInfo, err := ep.DriverInfo()
  217. if err != nil {
  218. t.Fatal(err)
  219. }
  220. pmd, ok := epInfo[netlabel.PortMap]
  221. if !ok {
  222. t.Fatalf("Could not find expected info in endpoint data")
  223. }
  224. pm, ok := pmd.([]types.PortBinding)
  225. if !ok {
  226. t.Fatalf("Unexpected format for port mapping in endpoint operational data")
  227. }
  228. if len(pm) != 3 {
  229. t.Fatalf("Incomplete data for port mapping in endpoint operational data: %d", len(pm))
  230. }
  231. if err := ep.Delete(); err != nil {
  232. t.Fatal(err)
  233. }
  234. if err := network.Delete(); err != nil {
  235. t.Fatal(err)
  236. }
  237. }
  238. func TestUnknownDriver(t *testing.T) {
  239. if !netutils.IsRunningInContainer() {
  240. defer netutils.SetupTestNetNS(t)()
  241. }
  242. _, err := createTestNetwork("unknowndriver", "testnetwork", options.Generic{})
  243. if err == nil {
  244. t.Fatal("Expected to fail. But instead succeeded")
  245. }
  246. if _, ok := err.(types.NotFoundError); !ok {
  247. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  248. }
  249. }
  250. func TestNilRemoteDriver(t *testing.T) {
  251. _, err := controller.NewNetwork("framerelay", "dummy",
  252. libnetwork.NetworkOptionGeneric(getEmptyGenericOption()))
  253. if err == nil {
  254. t.Fatal("Expected to fail. But instead succeeded")
  255. }
  256. if _, ok := err.(types.NotFoundError); !ok {
  257. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  258. }
  259. }
  260. func TestDuplicateNetwork(t *testing.T) {
  261. if !netutils.IsRunningInContainer() {
  262. defer netutils.SetupTestNetNS(t)()
  263. }
  264. n, err := controller.NewNetwork(bridgeNetType, "testnetwork", nil)
  265. if err != nil {
  266. t.Fatal(err)
  267. }
  268. defer func() {
  269. if err := n.Delete(); err != nil {
  270. t.Fatal(err)
  271. }
  272. }()
  273. _, err = controller.NewNetwork(bridgeNetType, "testnetwork")
  274. if err == nil {
  275. t.Fatal("Expected to fail. But instead succeeded")
  276. }
  277. if _, ok := err.(libnetwork.NetworkNameError); !ok {
  278. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  279. }
  280. }
  281. func TestNetworkName(t *testing.T) {
  282. if !netutils.IsRunningInContainer() {
  283. defer netutils.SetupTestNetNS(t)()
  284. }
  285. _, err := createTestNetwork(bridgeNetType, "", options.Generic{})
  286. if err == nil {
  287. t.Fatal("Expected to fail. But instead succeeded")
  288. }
  289. if _, ok := err.(libnetwork.ErrInvalidName); !ok {
  290. t.Fatalf("Expected to fail with ErrInvalidName error. Got %v", err)
  291. }
  292. networkName := "testnetwork"
  293. n, err := createTestNetwork(bridgeNetType, networkName, options.Generic{})
  294. if err != nil {
  295. t.Fatal(err)
  296. }
  297. defer func() {
  298. if err := n.Delete(); err != nil {
  299. t.Fatal(err)
  300. }
  301. }()
  302. if n.Name() != networkName {
  303. t.Fatalf("Expected network name %s, got %s", networkName, n.Name())
  304. }
  305. }
  306. func TestNetworkType(t *testing.T) {
  307. if !netutils.IsRunningInContainer() {
  308. defer netutils.SetupTestNetNS(t)()
  309. }
  310. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{})
  311. if err != nil {
  312. t.Fatal(err)
  313. }
  314. defer func() {
  315. if err := n.Delete(); err != nil {
  316. t.Fatal(err)
  317. }
  318. }()
  319. if n.Type() != bridgeNetType {
  320. t.Fatalf("Expected network type %s, got %s", bridgeNetType, n.Type())
  321. }
  322. }
  323. func TestNetworkID(t *testing.T) {
  324. if !netutils.IsRunningInContainer() {
  325. defer netutils.SetupTestNetNS(t)()
  326. }
  327. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{})
  328. if err != nil {
  329. t.Fatal(err)
  330. }
  331. defer func() {
  332. if err := n.Delete(); err != nil {
  333. t.Fatal(err)
  334. }
  335. }()
  336. if n.ID() == "" {
  337. t.Fatal("Expected non-empty network id")
  338. }
  339. }
  340. func TestDeleteNetworkWithActiveEndpoints(t *testing.T) {
  341. if !netutils.IsRunningInContainer() {
  342. defer netutils.SetupTestNetNS(t)()
  343. }
  344. netOption := options.Generic{
  345. "BridgeName": bridgeName,
  346. "AllowNonDefaultBridge": true}
  347. option := options.Generic{
  348. netlabel.GenericData: netOption,
  349. }
  350. network, err := createTestNetwork(bridgeNetType, "testnetwork", option)
  351. if err != nil {
  352. t.Fatal(err)
  353. }
  354. ep, err := network.CreateEndpoint("testep")
  355. if err != nil {
  356. t.Fatal(err)
  357. }
  358. err = network.Delete()
  359. if err == nil {
  360. t.Fatal("Expected to fail. But instead succeeded")
  361. }
  362. if _, ok := err.(*libnetwork.ActiveEndpointsError); !ok {
  363. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  364. }
  365. // Done testing. Now cleanup.
  366. if err := ep.Delete(); err != nil {
  367. t.Fatal(err)
  368. }
  369. if err := network.Delete(); err != nil {
  370. t.Fatal(err)
  371. }
  372. }
  373. func TestUnknownNetwork(t *testing.T) {
  374. if !netutils.IsRunningInContainer() {
  375. defer netutils.SetupTestNetNS(t)()
  376. }
  377. netOption := options.Generic{
  378. "BridgeName": bridgeName,
  379. "AllowNonDefaultBridge": true}
  380. option := options.Generic{
  381. netlabel.GenericData: netOption,
  382. }
  383. network, err := createTestNetwork(bridgeNetType, "testnetwork", option)
  384. if err != nil {
  385. t.Fatal(err)
  386. }
  387. err = network.Delete()
  388. if err != nil {
  389. t.Fatal(err)
  390. }
  391. err = network.Delete()
  392. if err == nil {
  393. t.Fatal("Expected to fail. But instead succeeded")
  394. }
  395. if _, ok := err.(*libnetwork.UnknownNetworkError); !ok {
  396. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  397. }
  398. }
  399. func TestUnknownEndpoint(t *testing.T) {
  400. if !netutils.IsRunningInContainer() {
  401. defer netutils.SetupTestNetNS(t)()
  402. }
  403. ip, subnet, err := net.ParseCIDR("192.168.100.1/24")
  404. if err != nil {
  405. t.Fatal(err)
  406. }
  407. subnet.IP = ip
  408. netOption := options.Generic{
  409. "BridgeName": bridgeName,
  410. "AddressIPv4": subnet,
  411. "AllowNonDefaultBridge": true}
  412. option := options.Generic{
  413. netlabel.GenericData: netOption,
  414. }
  415. network, err := createTestNetwork(bridgeNetType, "testnetwork", option)
  416. if err != nil {
  417. t.Fatal(err)
  418. }
  419. _, err = network.CreateEndpoint("")
  420. if err == nil {
  421. t.Fatal("Expected to fail. But instead succeeded")
  422. }
  423. if _, ok := err.(libnetwork.ErrInvalidName); !ok {
  424. t.Fatalf("Expected to fail with ErrInvalidName error. Actual error: %v", err)
  425. }
  426. ep, err := network.CreateEndpoint("testep")
  427. if err != nil {
  428. t.Fatal(err)
  429. }
  430. err = ep.Delete()
  431. if err != nil {
  432. t.Fatal(err)
  433. }
  434. err = ep.Delete()
  435. if err == nil {
  436. t.Fatal("Expected to fail. But instead succeeded")
  437. }
  438. if _, ok := err.(*libnetwork.UnknownEndpointError); !ok {
  439. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  440. }
  441. // Done testing. Now cleanup
  442. if err := network.Delete(); err != nil {
  443. t.Fatal(err)
  444. }
  445. }
  446. func TestNetworkEndpointsWalkers(t *testing.T) {
  447. if !netutils.IsRunningInContainer() {
  448. defer netutils.SetupTestNetNS(t)()
  449. }
  450. // Create network 1 and add 2 endpoint: ep11, ep12
  451. net1, err := controller.NewNetwork(bridgeNetType, "network1")
  452. if err != nil {
  453. t.Fatal(err)
  454. }
  455. defer func() {
  456. if err := net1.Delete(); err != nil {
  457. t.Fatal(err)
  458. }
  459. }()
  460. ep11, err := net1.CreateEndpoint("ep11")
  461. if err != nil {
  462. t.Fatal(err)
  463. }
  464. defer func() {
  465. if err := ep11.Delete(); err != nil {
  466. t.Fatal(err)
  467. }
  468. }()
  469. ep12, err := net1.CreateEndpoint("ep12")
  470. if err != nil {
  471. t.Fatal(err)
  472. }
  473. defer func() {
  474. if err := ep12.Delete(); err != nil {
  475. t.Fatal(err)
  476. }
  477. }()
  478. // Test list methods on net1
  479. epList1 := net1.Endpoints()
  480. if len(epList1) != 2 {
  481. t.Fatalf("Endpoints() returned wrong number of elements: %d instead of 2", len(epList1))
  482. }
  483. // endpoint order is not guaranteed
  484. for _, e := range epList1 {
  485. if e != ep11 && e != ep12 {
  486. t.Fatal("Endpoints() did not return all the expected elements")
  487. }
  488. }
  489. // Test Endpoint Walk method
  490. var epName string
  491. var epWanted libnetwork.Endpoint
  492. wlk := func(ep libnetwork.Endpoint) bool {
  493. if ep.Name() == epName {
  494. epWanted = ep
  495. return true
  496. }
  497. return false
  498. }
  499. // Look for ep1 on network1
  500. epName = "ep11"
  501. net1.WalkEndpoints(wlk)
  502. if epWanted == nil {
  503. t.Fatal(err)
  504. }
  505. if ep11 != epWanted {
  506. t.Fatal(err)
  507. }
  508. // Test Network Walk method
  509. var netName string
  510. var netWanted libnetwork.Network
  511. nwWlk := func(nw libnetwork.Network) bool {
  512. if nw.Name() == netName {
  513. netWanted = nw
  514. return true
  515. }
  516. return false
  517. }
  518. // Look for network named "network1"
  519. netName = "network1"
  520. controller.WalkNetworks(nwWlk)
  521. if netWanted == nil {
  522. t.Fatal(err)
  523. }
  524. if net1 != netWanted {
  525. t.Fatal(err)
  526. }
  527. }
  528. func TestControllerQuery(t *testing.T) {
  529. if !netutils.IsRunningInContainer() {
  530. defer netutils.SetupTestNetNS(t)()
  531. }
  532. // Create network 1
  533. net1, err := controller.NewNetwork(bridgeNetType, "network1")
  534. if err != nil {
  535. t.Fatal(err)
  536. }
  537. defer func() {
  538. if err := net1.Delete(); err != nil {
  539. t.Fatal(err)
  540. }
  541. }()
  542. _, err = controller.NetworkByName("")
  543. if err == nil {
  544. t.Fatalf("NetworkByName() succeeded with invalid target name")
  545. }
  546. if _, ok := err.(libnetwork.ErrInvalidName); !ok {
  547. t.Fatalf("Expected NetworkByName() to fail with ErrInvalidName error. Got: %v", err)
  548. }
  549. _, err = controller.NetworkByID("")
  550. if err == nil {
  551. t.Fatalf("NetworkByID() succeeded with invalid target id")
  552. }
  553. if _, ok := err.(libnetwork.ErrInvalidID); !ok {
  554. t.Fatalf("NetworkByID() failed with unexpected error: %v", err)
  555. }
  556. g, err := controller.NetworkByID("network1")
  557. if err == nil {
  558. t.Fatalf("Unexpected success for NetworkByID(): %v", g)
  559. }
  560. if _, ok := err.(libnetwork.ErrNoSuchNetwork); !ok {
  561. t.Fatalf("NetworkByID() failed with unexpected error: %v", err)
  562. }
  563. g, err = controller.NetworkByName("network1")
  564. if err != nil {
  565. t.Fatalf("Unexpected failure for NetworkByName(): %v", err)
  566. }
  567. if g == nil {
  568. t.Fatalf("NetworkByName() did not find the network")
  569. }
  570. if g != net1 {
  571. t.Fatalf("NetworkByName() returned the wrong network")
  572. }
  573. g, err = controller.NetworkByID(net1.ID())
  574. if err != nil {
  575. t.Fatalf("Unexpected failure for NetworkByID(): %v", err)
  576. }
  577. if net1 != g {
  578. t.Fatalf("NetworkByID() returned unexpected element: %v", g)
  579. }
  580. }
  581. func TestNetworkQuery(t *testing.T) {
  582. if !netutils.IsRunningInContainer() {
  583. defer netutils.SetupTestNetNS(t)()
  584. }
  585. // Create network 1 and add 2 endpoint: ep11, ep12
  586. net1, err := controller.NewNetwork(bridgeNetType, "network1")
  587. if err != nil {
  588. t.Fatal(err)
  589. }
  590. defer func() {
  591. if err := net1.Delete(); err != nil {
  592. t.Fatal(err)
  593. }
  594. }()
  595. ep11, err := net1.CreateEndpoint("ep11")
  596. if err != nil {
  597. t.Fatal(err)
  598. }
  599. defer func() {
  600. if err := ep11.Delete(); err != nil {
  601. t.Fatal(err)
  602. }
  603. }()
  604. ep12, err := net1.CreateEndpoint("ep12")
  605. if err != nil {
  606. t.Fatal(err)
  607. }
  608. defer func() {
  609. if err := ep12.Delete(); err != nil {
  610. t.Fatal(err)
  611. }
  612. }()
  613. e, err := net1.EndpointByName("ep11")
  614. if err != nil {
  615. t.Fatal(err)
  616. }
  617. if ep11 != e {
  618. t.Fatalf("EndpointByName() returned %v instead of %v", e, ep11)
  619. }
  620. e, err = net1.EndpointByName("")
  621. if err == nil {
  622. t.Fatalf("EndpointByName() succeeded with invalid target name")
  623. }
  624. if _, ok := err.(libnetwork.ErrInvalidName); !ok {
  625. t.Fatalf("Expected EndpointByName() to fail with ErrInvalidName error. Got: %v", err)
  626. }
  627. e, err = net1.EndpointByName("IamNotAnEndpoint")
  628. if err == nil {
  629. t.Fatalf("EndpointByName() succeeded with unknown target name")
  630. }
  631. if _, ok := err.(libnetwork.ErrNoSuchEndpoint); !ok {
  632. t.Fatal(err)
  633. }
  634. if e != nil {
  635. t.Fatalf("EndpointByName(): expected nil, got %v", e)
  636. }
  637. e, err = net1.EndpointByID(ep12.ID())
  638. if err != nil {
  639. t.Fatal(err)
  640. }
  641. if ep12 != e {
  642. t.Fatalf("EndpointByID() returned %v instead of %v", e, ep12)
  643. }
  644. e, err = net1.EndpointByID("")
  645. if err == nil {
  646. t.Fatalf("EndpointByID() succeeded with invalid target id")
  647. }
  648. if _, ok := err.(libnetwork.ErrInvalidID); !ok {
  649. t.Fatalf("EndpointByID() failed with unexpected error: %v", err)
  650. }
  651. }
  652. const containerID = "valid_container"
  653. func checkSandbox(t *testing.T, info libnetwork.EndpointInfo) {
  654. origns, err := netns.Get()
  655. if err != nil {
  656. t.Fatalf("Could not get the current netns: %v", err)
  657. }
  658. defer origns.Close()
  659. key := info.SandboxKey()
  660. f, err := os.OpenFile(key, os.O_RDONLY, 0)
  661. if err != nil {
  662. t.Fatalf("Failed to open network namespace path %q: %v", key, err)
  663. }
  664. defer f.Close()
  665. runtime.LockOSThread()
  666. defer runtime.UnlockOSThread()
  667. nsFD := f.Fd()
  668. if err = netns.Set(netns.NsHandle(nsFD)); err != nil {
  669. t.Fatalf("Setting to the namespace pointed to by the sandbox %s failed: %v", key, err)
  670. }
  671. defer netns.Set(origns)
  672. _, err = netlink.LinkByName("eth0")
  673. if err != nil {
  674. t.Fatalf("Could not find the interface eth0 inside the sandbox: %v", err)
  675. }
  676. _, err = netlink.LinkByName("eth1")
  677. if err != nil {
  678. t.Fatalf("Could not find the interface eth1 inside the sandbox: %v", err)
  679. }
  680. }
  681. func TestEndpointJoin(t *testing.T) {
  682. if !netutils.IsRunningInContainer() {
  683. defer netutils.SetupTestNetNS(t)()
  684. }
  685. n1, err := createTestNetwork(bridgeNetType, "testnetwork1", options.Generic{})
  686. if err != nil {
  687. t.Fatal(err)
  688. }
  689. defer func() {
  690. if err := n1.Delete(); err != nil {
  691. t.Fatal(err)
  692. }
  693. }()
  694. ep1, err := n1.CreateEndpoint("ep1")
  695. if err != nil {
  696. t.Fatal(err)
  697. }
  698. defer func() {
  699. if err := ep1.Delete(); err != nil {
  700. t.Fatal(err)
  701. }
  702. }()
  703. // Validate if ep.Info() only gives me IP address info and not names and gateway during CreateEndpoint()
  704. info := ep1.Info()
  705. for _, iface := range info.InterfaceList() {
  706. if iface.Address().IP.To4() == nil {
  707. t.Fatalf("Invalid IP address returned: %v", iface.Address())
  708. }
  709. }
  710. if info.Gateway().To4() != nil {
  711. t.Fatalf("Expected empty gateway for an empty endpoint. Instead found a gateway: %v", info.Gateway())
  712. }
  713. if info.SandboxKey() != "" {
  714. t.Fatalf("Expected an empty sandbox key for an empty endpoint. Instead found a non-empty sandbox key: %s", info.SandboxKey())
  715. }
  716. err = ep1.Join(containerID,
  717. libnetwork.JoinOptionHostname("test"),
  718. libnetwork.JoinOptionDomainname("docker.io"),
  719. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  720. if err != nil {
  721. t.Fatal(err)
  722. }
  723. defer func() {
  724. err = ep1.Leave(containerID)
  725. if err != nil {
  726. t.Fatal(err)
  727. }
  728. }()
  729. // Validate if ep.Info() only gives valid gateway and sandbox key after has container has joined.
  730. info = ep1.Info()
  731. if info.Gateway().To4() == nil {
  732. t.Fatalf("Expected a valid gateway for a joined endpoint. Instead found an invalid gateway: %v", info.Gateway())
  733. }
  734. if info.SandboxKey() == "" {
  735. t.Fatalf("Expected an non-empty sandbox key for a joined endpoint. Instead found a empty sandbox key")
  736. }
  737. // Now test the container joining another network
  738. n2, err := createTestNetwork(bridgeNetType, "testnetwork2",
  739. options.Generic{
  740. netlabel.GenericData: options.Generic{
  741. "BridgeName": "secondary",
  742. "AllowNonDefaultBridge": true,
  743. },
  744. })
  745. if err != nil {
  746. t.Fatal(err)
  747. }
  748. defer func() {
  749. if err := n2.Delete(); err != nil {
  750. t.Fatal(err)
  751. }
  752. }()
  753. ep2, err := n2.CreateEndpoint("ep2")
  754. if err != nil {
  755. t.Fatal(err)
  756. }
  757. defer func() {
  758. if err := ep2.Delete(); err != nil {
  759. t.Fatal(err)
  760. }
  761. }()
  762. err = ep2.Join(containerID)
  763. if err != nil {
  764. t.Fatal(err)
  765. }
  766. defer func() {
  767. err = ep2.Leave(containerID)
  768. if err != nil {
  769. t.Fatal(err)
  770. }
  771. }()
  772. checkSandbox(t, info)
  773. }
  774. func TestEndpointJoinInvalidContainerId(t *testing.T) {
  775. if !netutils.IsRunningInContainer() {
  776. defer netutils.SetupTestNetNS(t)()
  777. }
  778. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{})
  779. if err != nil {
  780. t.Fatal(err)
  781. }
  782. defer func() {
  783. if err := n.Delete(); err != nil {
  784. t.Fatal(err)
  785. }
  786. }()
  787. ep, err := n.CreateEndpoint("ep1")
  788. if err != nil {
  789. t.Fatal(err)
  790. }
  791. defer func() {
  792. if err := ep.Delete(); err != nil {
  793. t.Fatal(err)
  794. }
  795. }()
  796. err = ep.Join("")
  797. if err == nil {
  798. t.Fatal("Expected to fail join with empty container id string")
  799. }
  800. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  801. t.Fatalf("Failed for unexpected reason: %v", err)
  802. }
  803. }
  804. func TestEndpointDeleteWithActiveContainer(t *testing.T) {
  805. if !netutils.IsRunningInContainer() {
  806. defer netutils.SetupTestNetNS(t)()
  807. }
  808. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{})
  809. if err != nil {
  810. t.Fatal(err)
  811. }
  812. defer func() {
  813. if err := n.Delete(); err != nil {
  814. t.Fatal(err)
  815. }
  816. }()
  817. ep, err := n.CreateEndpoint("ep1")
  818. if err != nil {
  819. t.Fatal(err)
  820. }
  821. err = ep.Join(containerID,
  822. libnetwork.JoinOptionHostname("test"),
  823. libnetwork.JoinOptionDomainname("docker.io"),
  824. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  825. if err != nil {
  826. t.Fatal(err)
  827. }
  828. defer func() {
  829. err = ep.Leave(containerID)
  830. if err != nil {
  831. t.Fatal(err)
  832. }
  833. err = ep.Delete()
  834. if err != nil {
  835. t.Fatal(err)
  836. }
  837. }()
  838. err = ep.Delete()
  839. if err == nil {
  840. t.Fatal("Expected to fail. But instead succeeded")
  841. }
  842. if _, ok := err.(*libnetwork.ActiveContainerError); !ok {
  843. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  844. }
  845. }
  846. func TestEndpointMultipleJoins(t *testing.T) {
  847. if !netutils.IsRunningInContainer() {
  848. defer netutils.SetupTestNetNS(t)()
  849. }
  850. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{})
  851. if err != nil {
  852. t.Fatal(err)
  853. }
  854. defer func() {
  855. if err := n.Delete(); err != nil {
  856. t.Fatal(err)
  857. }
  858. }()
  859. ep, err := n.CreateEndpoint("ep1")
  860. if err != nil {
  861. t.Fatal(err)
  862. }
  863. defer func() {
  864. if err := ep.Delete(); err != nil {
  865. t.Fatal(err)
  866. }
  867. }()
  868. err = ep.Join(containerID,
  869. libnetwork.JoinOptionHostname("test"),
  870. libnetwork.JoinOptionDomainname("docker.io"),
  871. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  872. if err != nil {
  873. t.Fatal(err)
  874. }
  875. defer func() {
  876. err = ep.Leave(containerID)
  877. if err != nil {
  878. t.Fatal(err)
  879. }
  880. }()
  881. err = ep.Join("container2")
  882. if err == nil {
  883. t.Fatal("Expected to fail multiple joins for the same endpoint")
  884. }
  885. if _, ok := err.(libnetwork.ErrInvalidJoin); !ok {
  886. t.Fatalf("Failed for unexpected reason: %v", err)
  887. }
  888. }
  889. func TestEndpointInvalidLeave(t *testing.T) {
  890. if !netutils.IsRunningInContainer() {
  891. defer netutils.SetupTestNetNS(t)()
  892. }
  893. n, err := createTestNetwork(bridgeNetType, "testnetwork", options.Generic{})
  894. if err != nil {
  895. t.Fatal(err)
  896. }
  897. defer func() {
  898. if err := n.Delete(); err != nil {
  899. t.Fatal(err)
  900. }
  901. }()
  902. ep, err := n.CreateEndpoint("ep1")
  903. if err != nil {
  904. t.Fatal(err)
  905. }
  906. defer func() {
  907. if err := ep.Delete(); err != nil {
  908. t.Fatal(err)
  909. }
  910. }()
  911. err = ep.Leave(containerID)
  912. if err == nil {
  913. t.Fatal("Expected to fail leave from an endpoint which has no active join")
  914. }
  915. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  916. if _, ok := err.(libnetwork.ErrNoContainer); !ok {
  917. t.Fatalf("Failed for unexpected reason: %v", err)
  918. }
  919. }
  920. err = ep.Join(containerID,
  921. libnetwork.JoinOptionHostname("test"),
  922. libnetwork.JoinOptionDomainname("docker.io"),
  923. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  924. if err != nil {
  925. t.Fatal(err)
  926. }
  927. defer func() {
  928. err = ep.Leave(containerID)
  929. if err != nil {
  930. t.Fatal(err)
  931. }
  932. }()
  933. err = ep.Leave("")
  934. if err == nil {
  935. t.Fatal("Expected to fail leave with empty container id")
  936. }
  937. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  938. t.Fatalf("Failed for unexpected reason: %v", err)
  939. }
  940. err = ep.Leave("container2")
  941. if err == nil {
  942. t.Fatal("Expected to fail leave with wrong container id")
  943. }
  944. if _, ok := err.(libnetwork.InvalidContainerIDError); !ok {
  945. t.Fatalf("Failed for unexpected reason: %v", err)
  946. }
  947. }
  948. func TestEndpointUpdateParent(t *testing.T) {
  949. if !netutils.IsRunningInContainer() {
  950. defer netutils.SetupTestNetNS(t)()
  951. }
  952. n, err := createTestNetwork("bridge", "testnetwork", options.Generic{})
  953. if err != nil {
  954. t.Fatal(err)
  955. }
  956. defer func() {
  957. if err := n.Delete(); err != nil {
  958. t.Fatal(err)
  959. }
  960. }()
  961. ep1, err := n.CreateEndpoint("ep1")
  962. if err != nil {
  963. t.Fatal(err)
  964. }
  965. defer func() {
  966. if err := ep1.Delete(); err != nil {
  967. t.Fatal(err)
  968. }
  969. }()
  970. err = ep1.Join(containerID,
  971. libnetwork.JoinOptionHostname("test1"),
  972. libnetwork.JoinOptionDomainname("docker.io"),
  973. libnetwork.JoinOptionExtraHost("web", "192.168.0.1"))
  974. if err != nil {
  975. t.Fatal(err)
  976. }
  977. defer func() {
  978. err = ep1.Leave(containerID)
  979. if err != nil {
  980. t.Fatal(err)
  981. }
  982. }()
  983. ep2, err := n.CreateEndpoint("ep2")
  984. if err != nil {
  985. t.Fatal(err)
  986. }
  987. defer func() {
  988. if err := ep2.Delete(); err != nil {
  989. t.Fatal(err)
  990. }
  991. }()
  992. err = ep2.Join("container2",
  993. libnetwork.JoinOptionHostname("test2"),
  994. libnetwork.JoinOptionDomainname("docker.io"),
  995. libnetwork.JoinOptionHostsPath("/var/lib/docker/test_network/container2/hosts"),
  996. libnetwork.JoinOptionParentUpdate(ep1.ID(), "web", "192.168.0.2"))
  997. if err != nil {
  998. t.Fatal(err)
  999. }
  1000. defer func() {
  1001. err = ep2.Leave("container2")
  1002. if err != nil {
  1003. t.Fatal(err)
  1004. }
  1005. }()
  1006. }
  1007. func TestEnableIPv6(t *testing.T) {
  1008. if !netutils.IsRunningInContainer() {
  1009. defer netutils.SetupTestNetNS(t)()
  1010. }
  1011. tmpResolvConf := []byte("search pommesfrites.fr\nnameserver 12.34.56.78\nnameserver 2001:4860:4860::8888")
  1012. //take a copy of resolv.conf for restoring after test completes
  1013. resolvConfSystem, err := ioutil.ReadFile("/etc/resolv.conf")
  1014. if err != nil {
  1015. t.Fatal(err)
  1016. }
  1017. //cleanup
  1018. defer func() {
  1019. if err := ioutil.WriteFile("/etc/resolv.conf", resolvConfSystem, 0644); err != nil {
  1020. t.Fatal(err)
  1021. }
  1022. }()
  1023. ip, cidrv6, err := net.ParseCIDR("fe80::1/64")
  1024. if err != nil {
  1025. t.Fatal(err)
  1026. }
  1027. cidrv6.IP = ip
  1028. netOption := options.Generic{
  1029. netlabel.EnableIPv6: true,
  1030. netlabel.GenericData: options.Generic{
  1031. "FixedCIDRv6": cidrv6,
  1032. },
  1033. }
  1034. n, err := createTestNetwork("bridge", "testnetwork", netOption)
  1035. if err != nil {
  1036. t.Fatal(err)
  1037. }
  1038. defer func() {
  1039. if err := n.Delete(); err != nil {
  1040. t.Fatal(err)
  1041. }
  1042. }()
  1043. ep1, err := n.CreateEndpoint("ep1")
  1044. if err != nil {
  1045. t.Fatal(err)
  1046. }
  1047. defer func() {
  1048. if err := ep1.Delete(); err != nil {
  1049. t.Fatal(err)
  1050. }
  1051. }()
  1052. if err := ioutil.WriteFile("/etc/resolv.conf", tmpResolvConf, 0644); err != nil {
  1053. t.Fatal(err)
  1054. }
  1055. resolvConfPath := "/tmp/libnetwork_test/resolv.conf"
  1056. defer os.Remove(resolvConfPath)
  1057. err = ep1.Join(containerID,
  1058. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  1059. if err != nil {
  1060. t.Fatal(err)
  1061. }
  1062. defer func() {
  1063. err = ep1.Leave(containerID)
  1064. if err != nil {
  1065. t.Fatal(err)
  1066. }
  1067. }()
  1068. content, err := ioutil.ReadFile(resolvConfPath)
  1069. if err != nil {
  1070. t.Fatal(err)
  1071. }
  1072. if !bytes.Equal(content, tmpResolvConf) {
  1073. t.Fatalf("Expected %s, Got %s", string(tmpResolvConf), string(content))
  1074. }
  1075. if err != nil {
  1076. t.Fatal(err)
  1077. }
  1078. }
  1079. func TestResolvConf(t *testing.T) {
  1080. if !netutils.IsRunningInContainer() {
  1081. defer netutils.SetupTestNetNS(t)()
  1082. }
  1083. tmpResolvConf1 := []byte("search pommesfrites.fr\nnameserver 12.34.56.78\nnameserver 2001:4860:4860::8888")
  1084. expectedResolvConf1 := []byte("search pommesfrites.fr\nnameserver 12.34.56.78\n")
  1085. tmpResolvConf2 := []byte("search pommesfrites.fr\nnameserver 112.34.56.78\nnameserver 2001:4860:4860::8888")
  1086. expectedResolvConf2 := []byte("search pommesfrites.fr\nnameserver 112.34.56.78\n")
  1087. tmpResolvConf3 := []byte("search pommesfrites.fr\nnameserver 113.34.56.78\n")
  1088. //take a copy of resolv.conf for restoring after test completes
  1089. resolvConfSystem, err := ioutil.ReadFile("/etc/resolv.conf")
  1090. if err != nil {
  1091. t.Fatal(err)
  1092. }
  1093. //cleanup
  1094. defer func() {
  1095. if err := ioutil.WriteFile("/etc/resolv.conf", resolvConfSystem, 0644); err != nil {
  1096. t.Fatal(err)
  1097. }
  1098. }()
  1099. n, err := createTestNetwork("bridge", "testnetwork", options.Generic{})
  1100. if err != nil {
  1101. t.Fatal(err)
  1102. }
  1103. defer func() {
  1104. if err := n.Delete(); err != nil {
  1105. t.Fatal(err)
  1106. }
  1107. }()
  1108. ep1, err := n.CreateEndpoint("ep1")
  1109. if err != nil {
  1110. t.Fatal(err)
  1111. }
  1112. defer func() {
  1113. if err := ep1.Delete(); err != nil {
  1114. t.Fatal(err)
  1115. }
  1116. }()
  1117. if err := ioutil.WriteFile("/etc/resolv.conf", tmpResolvConf1, 0644); err != nil {
  1118. t.Fatal(err)
  1119. }
  1120. resolvConfPath := "/tmp/libnetwork_test/resolv.conf"
  1121. defer os.Remove(resolvConfPath)
  1122. err = ep1.Join(containerID,
  1123. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  1124. if err != nil {
  1125. t.Fatal(err)
  1126. }
  1127. defer func() {
  1128. err = ep1.Leave(containerID)
  1129. if err != nil {
  1130. t.Fatal(err)
  1131. }
  1132. }()
  1133. finfo, err := os.Stat(resolvConfPath)
  1134. if err != nil {
  1135. t.Fatal(err)
  1136. }
  1137. fmode := (os.FileMode)(0644)
  1138. if finfo.Mode() != fmode {
  1139. t.Fatalf("Expected file mode %s, got %s", fmode.String(), finfo.Mode().String())
  1140. }
  1141. content, err := ioutil.ReadFile(resolvConfPath)
  1142. if err != nil {
  1143. t.Fatal(err)
  1144. }
  1145. if !bytes.Equal(content, expectedResolvConf1) {
  1146. t.Fatalf("Expected %s, Got %s", string(expectedResolvConf1), string(content))
  1147. }
  1148. err = ep1.Leave(containerID)
  1149. if err != nil {
  1150. t.Fatal(err)
  1151. }
  1152. if err := ioutil.WriteFile("/etc/resolv.conf", tmpResolvConf2, 0644); err != nil {
  1153. t.Fatal(err)
  1154. }
  1155. err = ep1.Join(containerID,
  1156. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  1157. if err != nil {
  1158. t.Fatal(err)
  1159. }
  1160. content, err = ioutil.ReadFile(resolvConfPath)
  1161. if err != nil {
  1162. t.Fatal(err)
  1163. }
  1164. if !bytes.Equal(content, expectedResolvConf2) {
  1165. t.Fatalf("Expected %s, Got %s", string(expectedResolvConf2), string(content))
  1166. }
  1167. if err := ioutil.WriteFile(resolvConfPath, tmpResolvConf3, 0644); err != nil {
  1168. t.Fatal(err)
  1169. }
  1170. err = ep1.Leave(containerID)
  1171. if err != nil {
  1172. t.Fatal(err)
  1173. }
  1174. err = ep1.Join(containerID,
  1175. libnetwork.JoinOptionResolvConfPath(resolvConfPath))
  1176. if err != nil {
  1177. t.Fatal(err)
  1178. }
  1179. content, err = ioutil.ReadFile(resolvConfPath)
  1180. if err != nil {
  1181. t.Fatal(err)
  1182. }
  1183. if !bytes.Equal(content, tmpResolvConf3) {
  1184. t.Fatalf("Expected %s, Got %s", string(tmpResolvConf3), string(content))
  1185. }
  1186. }
  1187. func TestInvalidRemoteDriver(t *testing.T) {
  1188. if !netutils.IsRunningInContainer() {
  1189. t.Skip("Skipping test when not running inside a Container")
  1190. }
  1191. mux := http.NewServeMux()
  1192. server := httptest.NewServer(mux)
  1193. if server == nil {
  1194. t.Fatal("Failed to start a HTTP Server")
  1195. }
  1196. defer server.Close()
  1197. type pluginRequest struct {
  1198. name string
  1199. }
  1200. mux.HandleFunc("/Plugin.Activate", func(w http.ResponseWriter, r *http.Request) {
  1201. w.Header().Set("Content-Type", "application/vnd.docker.plugins.v1+json")
  1202. fmt.Fprintln(w, `{"Implements": ["InvalidDriver"]}`)
  1203. })
  1204. if err := os.MkdirAll("/usr/share/docker/plugins", 0755); err != nil {
  1205. t.Fatal(err)
  1206. }
  1207. defer func() {
  1208. if err := os.RemoveAll("/usr/share/docker/plugins"); err != nil {
  1209. t.Fatal(err)
  1210. }
  1211. }()
  1212. if err := ioutil.WriteFile("/usr/share/docker/plugins/invalid-network-driver.spec", []byte(server.URL), 0644); err != nil {
  1213. t.Fatal(err)
  1214. }
  1215. controller, err := libnetwork.New("")
  1216. if err != nil {
  1217. t.Fatal(err)
  1218. }
  1219. _, err = controller.NewNetwork("invalid-network-driver", "dummy",
  1220. libnetwork.NetworkOptionGeneric(getEmptyGenericOption()))
  1221. if err == nil {
  1222. t.Fatal("Expected to fail. But instead succeeded")
  1223. }
  1224. if err != plugins.ErrNotImplements {
  1225. t.Fatalf("Did not fail with expected error. Actual error: %v", err)
  1226. }
  1227. }
  1228. func TestValidRemoteDriver(t *testing.T) {
  1229. if !netutils.IsRunningInContainer() {
  1230. t.Skip("Skipping test when not running inside a Container")
  1231. }
  1232. mux := http.NewServeMux()
  1233. server := httptest.NewServer(mux)
  1234. if server == nil {
  1235. t.Fatal("Failed to start a HTTP Server")
  1236. }
  1237. defer server.Close()
  1238. type pluginRequest struct {
  1239. name string
  1240. }
  1241. mux.HandleFunc("/Plugin.Activate", func(w http.ResponseWriter, r *http.Request) {
  1242. w.Header().Set("Content-Type", "application/vnd.docker.plugins.v1+json")
  1243. fmt.Fprintf(w, `{"Implements": ["%s"]}`, driverapi.NetworkPluginEndpointType)
  1244. })
  1245. mux.HandleFunc(fmt.Sprintf("/%s.CreateNetwork", driverapi.NetworkPluginEndpointType), func(w http.ResponseWriter, r *http.Request) {
  1246. w.Header().Set("Content-Type", "application/vnd.docker.plugins.v1+json")
  1247. fmt.Fprintf(w, "null")
  1248. })
  1249. if err := os.MkdirAll("/usr/share/docker/plugins", 0755); err != nil {
  1250. t.Fatal(err)
  1251. }
  1252. defer func() {
  1253. if err := os.RemoveAll("/usr/share/docker/plugins"); err != nil {
  1254. t.Fatal(err)
  1255. }
  1256. }()
  1257. if err := ioutil.WriteFile("/usr/share/docker/plugins/valid-network-driver.spec", []byte(server.URL), 0644); err != nil {
  1258. t.Fatal(err)
  1259. }
  1260. n, err := controller.NewNetwork("valid-network-driver", "dummy",
  1261. libnetwork.NetworkOptionGeneric(getEmptyGenericOption()))
  1262. if err != nil {
  1263. // Only fail if we could not find the plugin driver
  1264. if _, ok := err.(types.NotFoundError); ok {
  1265. t.Fatal(err)
  1266. }
  1267. return
  1268. }
  1269. defer func() {
  1270. if err := n.Delete(); err != nil {
  1271. t.Fatal(err)
  1272. }
  1273. }()
  1274. }
  1275. var (
  1276. once sync.Once
  1277. start = make(chan struct{})
  1278. done = make(chan chan struct{}, numThreads-1)
  1279. origns = netns.None()
  1280. testns = netns.None()
  1281. )
  1282. const (
  1283. iterCnt = 25
  1284. numThreads = 3
  1285. first = 1
  1286. last = numThreads
  1287. debug = false
  1288. )
  1289. func createGlobalInstance(t *testing.T) {
  1290. var err error
  1291. defer close(start)
  1292. origns, err = netns.Get()
  1293. if err != nil {
  1294. t.Fatal(err)
  1295. }
  1296. if netutils.IsRunningInContainer() {
  1297. testns = origns
  1298. } else {
  1299. testns, err = netns.New()
  1300. if err != nil {
  1301. t.Fatal(err)
  1302. }
  1303. }
  1304. net, err := controller.NewNetwork(bridgeNetType, "network1")
  1305. if err != nil {
  1306. t.Fatal("new network")
  1307. }
  1308. _, err = net.CreateEndpoint("ep1")
  1309. if err != nil {
  1310. t.Fatal("createendpoint")
  1311. }
  1312. }
  1313. func debugf(format string, a ...interface{}) (int, error) {
  1314. if debug {
  1315. return fmt.Printf(format, a...)
  1316. }
  1317. return 0, nil
  1318. }
  1319. func parallelJoin(t *testing.T, ep libnetwork.Endpoint, thrNumber int) {
  1320. debugf("J%d.", thrNumber)
  1321. err := ep.Join("racing_container")
  1322. runtime.LockOSThread()
  1323. if err != nil {
  1324. if _, ok := err.(libnetwork.ErrNoContainer); !ok {
  1325. if _, ok := err.(libnetwork.ErrInvalidJoin); !ok {
  1326. t.Fatal(err)
  1327. }
  1328. }
  1329. debugf("JE%d(%v).", thrNumber, err)
  1330. }
  1331. debugf("JD%d.", thrNumber)
  1332. }
  1333. func parallelLeave(t *testing.T, ep libnetwork.Endpoint, thrNumber int) {
  1334. debugf("L%d.", thrNumber)
  1335. err := ep.Leave("racing_container")
  1336. runtime.LockOSThread()
  1337. if err != nil {
  1338. if _, ok := err.(libnetwork.ErrNoContainer); !ok {
  1339. if _, ok := err.(libnetwork.ErrInvalidJoin); !ok {
  1340. t.Fatal(err)
  1341. }
  1342. }
  1343. debugf("LE%d(%v).", thrNumber, err)
  1344. }
  1345. debugf("LD%d.", thrNumber)
  1346. }
  1347. func runParallelTests(t *testing.T, thrNumber int) {
  1348. var err error
  1349. t.Parallel()
  1350. pTest := flag.Lookup("test.parallel")
  1351. if pTest == nil {
  1352. t.Skip("Skipped because test.parallel flag not set;")
  1353. }
  1354. numParallel, err := strconv.Atoi(pTest.Value.String())
  1355. if err != nil {
  1356. t.Fatal(err)
  1357. }
  1358. if numParallel < numThreads {
  1359. t.Skip("Skipped because t.parallel was less than ", numThreads)
  1360. }
  1361. runtime.LockOSThread()
  1362. defer runtime.UnlockOSThread()
  1363. if thrNumber == first {
  1364. createGlobalInstance(t)
  1365. }
  1366. if thrNumber != first {
  1367. select {
  1368. case <-start:
  1369. }
  1370. thrdone := make(chan struct{})
  1371. done <- thrdone
  1372. defer close(thrdone)
  1373. if thrNumber == last {
  1374. defer close(done)
  1375. }
  1376. err = netns.Set(testns)
  1377. if err != nil {
  1378. t.Fatal(err)
  1379. }
  1380. }
  1381. defer netns.Set(origns)
  1382. net, err := controller.NetworkByName("network1")
  1383. if err != nil {
  1384. t.Fatal(err)
  1385. }
  1386. if net == nil {
  1387. t.Fatal("Could not find network1")
  1388. }
  1389. ep, err := net.EndpointByName("ep1")
  1390. if err != nil {
  1391. t.Fatal(err)
  1392. }
  1393. if ep == nil {
  1394. t.Fatal("Got nil ep with no error")
  1395. }
  1396. for i := 0; i < iterCnt; i++ {
  1397. parallelJoin(t, ep, thrNumber)
  1398. parallelLeave(t, ep, thrNumber)
  1399. }
  1400. debugf("\n")
  1401. if thrNumber == first {
  1402. for thrdone := range done {
  1403. select {
  1404. case <-thrdone:
  1405. }
  1406. }
  1407. testns.Close()
  1408. err = ep.Delete()
  1409. if err != nil {
  1410. t.Fatal(err)
  1411. }
  1412. if err := net.Delete(); err != nil {
  1413. t.Fatal(err)
  1414. }
  1415. }
  1416. }
  1417. func TestParallel1(t *testing.T) {
  1418. runParallelTests(t, 1)
  1419. }
  1420. func TestParallel2(t *testing.T) {
  1421. runParallelTests(t, 2)
  1422. }
  1423. func TestParallel3(t *testing.T) {
  1424. runParallelTests(t, 3)
  1425. }