docker_cli_volume_test.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624
  1. package main
  2. import (
  3. "context"
  4. "fmt"
  5. "io/ioutil"
  6. "os"
  7. "os/exec"
  8. "path/filepath"
  9. "strings"
  10. "github.com/docker/docker/api/types/container"
  11. "github.com/docker/docker/api/types/mount"
  12. "github.com/docker/docker/api/types/network"
  13. "github.com/docker/docker/client"
  14. "github.com/docker/docker/integration-cli/checker"
  15. "github.com/docker/docker/integration-cli/cli/build"
  16. "github.com/go-check/check"
  17. "gotest.tools/assert"
  18. "gotest.tools/icmd"
  19. )
  20. func (s *DockerSuite) TestVolumeCLICreate(c *check.C) {
  21. dockerCmd(c, "volume", "create")
  22. _, _, err := dockerCmdWithError("volume", "create", "-d", "nosuchdriver")
  23. assert.ErrorContains(c, err, "")
  24. // test using hidden --name option
  25. out, _ := dockerCmd(c, "volume", "create", "--name=test")
  26. name := strings.TrimSpace(out)
  27. c.Assert(name, check.Equals, "test")
  28. out, _ = dockerCmd(c, "volume", "create", "test2")
  29. name = strings.TrimSpace(out)
  30. c.Assert(name, check.Equals, "test2")
  31. }
  32. func (s *DockerSuite) TestVolumeCLIInspect(c *check.C) {
  33. c.Assert(
  34. exec.Command(dockerBinary, "volume", "inspect", "doesnotexist").Run(),
  35. check.Not(check.IsNil),
  36. check.Commentf("volume inspect should error on non-existent volume"),
  37. )
  38. out, _ := dockerCmd(c, "volume", "create")
  39. name := strings.TrimSpace(out)
  40. out, _ = dockerCmd(c, "volume", "inspect", "--format={{ .Name }}", name)
  41. c.Assert(strings.TrimSpace(out), check.Equals, name)
  42. dockerCmd(c, "volume", "create", "test")
  43. out, _ = dockerCmd(c, "volume", "inspect", "--format={{ .Name }}", "test")
  44. c.Assert(strings.TrimSpace(out), check.Equals, "test")
  45. }
  46. func (s *DockerSuite) TestVolumeCLIInspectMulti(c *check.C) {
  47. dockerCmd(c, "volume", "create", "test1")
  48. dockerCmd(c, "volume", "create", "test2")
  49. dockerCmd(c, "volume", "create", "test3")
  50. result := dockerCmdWithResult("volume", "inspect", "--format={{ .Name }}", "test1", "test2", "doesnotexist", "test3")
  51. result.Assert(c, icmd.Expected{
  52. ExitCode: 1,
  53. Err: "No such volume: doesnotexist",
  54. })
  55. out := result.Stdout()
  56. c.Assert(out, checker.Contains, "test1")
  57. c.Assert(out, checker.Contains, "test2")
  58. c.Assert(out, checker.Contains, "test3")
  59. }
  60. func (s *DockerSuite) TestVolumeCLILs(c *check.C) {
  61. prefix, _ := getPrefixAndSlashFromDaemonPlatform()
  62. dockerCmd(c, "volume", "create", "aaa")
  63. dockerCmd(c, "volume", "create", "test")
  64. dockerCmd(c, "volume", "create", "soo")
  65. dockerCmd(c, "run", "-v", "soo:"+prefix+"/foo", "busybox", "ls", "/")
  66. out, _ := dockerCmd(c, "volume", "ls", "-q")
  67. assertVolumesInList(c, out, []string{"aaa", "soo", "test"})
  68. }
  69. func (s *DockerSuite) TestVolumeLsFormat(c *check.C) {
  70. dockerCmd(c, "volume", "create", "aaa")
  71. dockerCmd(c, "volume", "create", "test")
  72. dockerCmd(c, "volume", "create", "soo")
  73. out, _ := dockerCmd(c, "volume", "ls", "--format", "{{.Name}}")
  74. assertVolumesInList(c, out, []string{"aaa", "soo", "test"})
  75. }
  76. func (s *DockerSuite) TestVolumeLsFormatDefaultFormat(c *check.C) {
  77. dockerCmd(c, "volume", "create", "aaa")
  78. dockerCmd(c, "volume", "create", "test")
  79. dockerCmd(c, "volume", "create", "soo")
  80. config := `{
  81. "volumesFormat": "{{ .Name }} default"
  82. }`
  83. d, err := ioutil.TempDir("", "integration-cli-")
  84. assert.NilError(c, err)
  85. defer os.RemoveAll(d)
  86. err = ioutil.WriteFile(filepath.Join(d, "config.json"), []byte(config), 0644)
  87. assert.NilError(c, err)
  88. out, _ := dockerCmd(c, "--config", d, "volume", "ls")
  89. assertVolumesInList(c, out, []string{"aaa default", "soo default", "test default"})
  90. }
  91. func assertVolumesInList(c *check.C, out string, expected []string) {
  92. lines := strings.Split(strings.TrimSpace(string(out)), "\n")
  93. for _, expect := range expected {
  94. found := false
  95. for _, v := range lines {
  96. found = v == expect
  97. if found {
  98. break
  99. }
  100. }
  101. assert.Assert(c, found, "Expected volume not found: %v, got: %v", expect, lines)
  102. }
  103. }
  104. func (s *DockerSuite) TestVolumeCLILsFilterDangling(c *check.C) {
  105. prefix, _ := getPrefixAndSlashFromDaemonPlatform()
  106. dockerCmd(c, "volume", "create", "testnotinuse1")
  107. dockerCmd(c, "volume", "create", "testisinuse1")
  108. dockerCmd(c, "volume", "create", "testisinuse2")
  109. // Make sure both "created" (but not started), and started
  110. // containers are included in reference counting
  111. dockerCmd(c, "run", "--name", "volume-test1", "-v", "testisinuse1:"+prefix+"/foo", "busybox", "true")
  112. dockerCmd(c, "create", "--name", "volume-test2", "-v", "testisinuse2:"+prefix+"/foo", "busybox", "true")
  113. out, _ := dockerCmd(c, "volume", "ls")
  114. // No filter, all volumes should show
  115. c.Assert(out, checker.Contains, "testnotinuse1\n", check.Commentf("expected volume 'testnotinuse1' in output"))
  116. c.Assert(out, checker.Contains, "testisinuse1\n", check.Commentf("expected volume 'testisinuse1' in output"))
  117. c.Assert(out, checker.Contains, "testisinuse2\n", check.Commentf("expected volume 'testisinuse2' in output"))
  118. out, _ = dockerCmd(c, "volume", "ls", "--filter", "dangling=false")
  119. // Explicitly disabling dangling
  120. c.Assert(out, check.Not(checker.Contains), "testnotinuse1\n", check.Commentf("expected volume 'testnotinuse1' in output"))
  121. c.Assert(out, checker.Contains, "testisinuse1\n", check.Commentf("expected volume 'testisinuse1' in output"))
  122. c.Assert(out, checker.Contains, "testisinuse2\n", check.Commentf("expected volume 'testisinuse2' in output"))
  123. out, _ = dockerCmd(c, "volume", "ls", "--filter", "dangling=true")
  124. // Filter "dangling" volumes; only "dangling" (unused) volumes should be in the output
  125. c.Assert(out, checker.Contains, "testnotinuse1\n", check.Commentf("expected volume 'testnotinuse1' in output"))
  126. c.Assert(out, check.Not(checker.Contains), "testisinuse1\n", check.Commentf("volume 'testisinuse1' in output, but not expected"))
  127. c.Assert(out, check.Not(checker.Contains), "testisinuse2\n", check.Commentf("volume 'testisinuse2' in output, but not expected"))
  128. out, _ = dockerCmd(c, "volume", "ls", "--filter", "dangling=1")
  129. // Filter "dangling" volumes; only "dangling" (unused) volumes should be in the output, dangling also accept 1
  130. c.Assert(out, checker.Contains, "testnotinuse1\n", check.Commentf("expected volume 'testnotinuse1' in output"))
  131. c.Assert(out, check.Not(checker.Contains), "testisinuse1\n", check.Commentf("volume 'testisinuse1' in output, but not expected"))
  132. c.Assert(out, check.Not(checker.Contains), "testisinuse2\n", check.Commentf("volume 'testisinuse2' in output, but not expected"))
  133. out, _ = dockerCmd(c, "volume", "ls", "--filter", "dangling=0")
  134. // dangling=0 is same as dangling=false case
  135. c.Assert(out, check.Not(checker.Contains), "testnotinuse1\n", check.Commentf("expected volume 'testnotinuse1' in output"))
  136. c.Assert(out, checker.Contains, "testisinuse1\n", check.Commentf("expected volume 'testisinuse1' in output"))
  137. c.Assert(out, checker.Contains, "testisinuse2\n", check.Commentf("expected volume 'testisinuse2' in output"))
  138. out, _ = dockerCmd(c, "volume", "ls", "--filter", "name=testisin")
  139. c.Assert(out, check.Not(checker.Contains), "testnotinuse1\n", check.Commentf("expected volume 'testnotinuse1' in output"))
  140. c.Assert(out, checker.Contains, "testisinuse1\n", check.Commentf("expected volume 'testisinuse1' in output"))
  141. c.Assert(out, checker.Contains, "testisinuse2\n", check.Commentf("expected volume 'testisinuse2' in output"))
  142. }
  143. func (s *DockerSuite) TestVolumeCLILsErrorWithInvalidFilterName(c *check.C) {
  144. out, _, err := dockerCmdWithError("volume", "ls", "-f", "FOO=123")
  145. assert.ErrorContains(c, err, "")
  146. c.Assert(out, checker.Contains, "Invalid filter")
  147. }
  148. func (s *DockerSuite) TestVolumeCLILsWithIncorrectFilterValue(c *check.C) {
  149. out, _, err := dockerCmdWithError("volume", "ls", "-f", "dangling=invalid")
  150. assert.ErrorContains(c, err, "")
  151. c.Assert(out, checker.Contains, "Invalid filter")
  152. }
  153. func (s *DockerSuite) TestVolumeCLIRm(c *check.C) {
  154. prefix, _ := getPrefixAndSlashFromDaemonPlatform()
  155. out, _ := dockerCmd(c, "volume", "create")
  156. id := strings.TrimSpace(out)
  157. dockerCmd(c, "volume", "create", "test")
  158. dockerCmd(c, "volume", "rm", id)
  159. dockerCmd(c, "volume", "rm", "test")
  160. volumeID := "testing"
  161. dockerCmd(c, "run", "-v", volumeID+":"+prefix+"/foo", "--name=test", "busybox", "sh", "-c", "echo hello > /foo/bar")
  162. icmd.RunCommand(dockerBinary, "volume", "rm", "testing").Assert(c, icmd.Expected{
  163. ExitCode: 1,
  164. Error: "exit status 1",
  165. })
  166. out, _ = dockerCmd(c, "run", "--volumes-from=test", "--name=test2", "busybox", "sh", "-c", "cat /foo/bar")
  167. c.Assert(strings.TrimSpace(out), check.Equals, "hello")
  168. dockerCmd(c, "rm", "-fv", "test2")
  169. dockerCmd(c, "volume", "inspect", volumeID)
  170. dockerCmd(c, "rm", "-f", "test")
  171. out, _ = dockerCmd(c, "run", "--name=test2", "-v", volumeID+":"+prefix+"/foo", "busybox", "sh", "-c", "cat /foo/bar")
  172. c.Assert(strings.TrimSpace(out), check.Equals, "hello", check.Commentf("volume data was removed"))
  173. dockerCmd(c, "rm", "test2")
  174. dockerCmd(c, "volume", "rm", volumeID)
  175. c.Assert(
  176. exec.Command("volume", "rm", "doesnotexist").Run(),
  177. check.Not(check.IsNil),
  178. check.Commentf("volume rm should fail with non-existent volume"),
  179. )
  180. }
  181. // FIXME(vdemeester) should be a unit test in cli/command/volume package
  182. func (s *DockerSuite) TestVolumeCLINoArgs(c *check.C) {
  183. out, _ := dockerCmd(c, "volume")
  184. // no args should produce the cmd usage output
  185. usage := "Usage: docker volume COMMAND"
  186. c.Assert(out, checker.Contains, usage)
  187. // invalid arg should error and show the command usage on stderr
  188. icmd.RunCommand(dockerBinary, "volume", "somearg").Assert(c, icmd.Expected{
  189. ExitCode: 1,
  190. Error: "exit status 1",
  191. Err: usage,
  192. })
  193. // invalid flag should error and show the flag error and cmd usage
  194. result := icmd.RunCommand(dockerBinary, "volume", "--no-such-flag")
  195. result.Assert(c, icmd.Expected{
  196. ExitCode: 125,
  197. Error: "exit status 125",
  198. Err: usage,
  199. })
  200. c.Assert(result.Stderr(), checker.Contains, "unknown flag: --no-such-flag")
  201. }
  202. func (s *DockerSuite) TestVolumeCLIInspectTmplError(c *check.C) {
  203. out, _ := dockerCmd(c, "volume", "create")
  204. name := strings.TrimSpace(out)
  205. out, exitCode, err := dockerCmdWithError("volume", "inspect", "--format='{{ .FooBar }}'", name)
  206. c.Assert(err, checker.NotNil, check.Commentf("Output: %s", out))
  207. c.Assert(exitCode, checker.Equals, 1, check.Commentf("Output: %s", out))
  208. c.Assert(out, checker.Contains, "Template parsing error")
  209. }
  210. func (s *DockerSuite) TestVolumeCLICreateWithOpts(c *check.C) {
  211. testRequires(c, DaemonIsLinux)
  212. dockerCmd(c, "volume", "create", "-d", "local", "test", "--opt=type=tmpfs", "--opt=device=tmpfs", "--opt=o=size=1m,uid=1000")
  213. out, _ := dockerCmd(c, "run", "-v", "test:/foo", "busybox", "mount")
  214. mounts := strings.Split(out, "\n")
  215. var found bool
  216. for _, m := range mounts {
  217. if strings.Contains(m, "/foo") {
  218. found = true
  219. info := strings.Fields(m)
  220. // tmpfs on <path> type tmpfs (rw,relatime,size=1024k,uid=1000)
  221. c.Assert(info[0], checker.Equals, "tmpfs")
  222. c.Assert(info[2], checker.Equals, "/foo")
  223. c.Assert(info[4], checker.Equals, "tmpfs")
  224. c.Assert(info[5], checker.Contains, "uid=1000")
  225. c.Assert(info[5], checker.Contains, "size=1024k")
  226. break
  227. }
  228. }
  229. c.Assert(found, checker.Equals, true)
  230. }
  231. func (s *DockerSuite) TestVolumeCLICreateLabel(c *check.C) {
  232. testVol := "testvolcreatelabel"
  233. testLabel := "foo"
  234. testValue := "bar"
  235. _, _, err := dockerCmdWithError("volume", "create", "--label", testLabel+"="+testValue, testVol)
  236. assert.NilError(c, err)
  237. out, _ := dockerCmd(c, "volume", "inspect", "--format={{ .Labels."+testLabel+" }}", testVol)
  238. c.Assert(strings.TrimSpace(out), check.Equals, testValue)
  239. }
  240. func (s *DockerSuite) TestVolumeCLICreateLabelMultiple(c *check.C) {
  241. testVol := "testvolcreatelabel"
  242. testLabels := map[string]string{
  243. "foo": "bar",
  244. "baz": "foo",
  245. }
  246. args := []string{
  247. "volume",
  248. "create",
  249. testVol,
  250. }
  251. for k, v := range testLabels {
  252. args = append(args, "--label", k+"="+v)
  253. }
  254. _, _, err := dockerCmdWithError(args...)
  255. assert.NilError(c, err)
  256. for k, v := range testLabels {
  257. out, _ := dockerCmd(c, "volume", "inspect", "--format={{ .Labels."+k+" }}", testVol)
  258. c.Assert(strings.TrimSpace(out), check.Equals, v)
  259. }
  260. }
  261. func (s *DockerSuite) TestVolumeCLILsFilterLabels(c *check.C) {
  262. testVol1 := "testvolcreatelabel-1"
  263. _, _, err := dockerCmdWithError("volume", "create", "--label", "foo=bar1", testVol1)
  264. assert.NilError(c, err)
  265. testVol2 := "testvolcreatelabel-2"
  266. _, _, err = dockerCmdWithError("volume", "create", "--label", "foo=bar2", testVol2)
  267. assert.NilError(c, err)
  268. out, _ := dockerCmd(c, "volume", "ls", "--filter", "label=foo")
  269. // filter with label=key
  270. c.Assert(out, checker.Contains, "testvolcreatelabel-1\n", check.Commentf("expected volume 'testvolcreatelabel-1' in output"))
  271. c.Assert(out, checker.Contains, "testvolcreatelabel-2\n", check.Commentf("expected volume 'testvolcreatelabel-2' in output"))
  272. out, _ = dockerCmd(c, "volume", "ls", "--filter", "label=foo=bar1")
  273. // filter with label=key=value
  274. c.Assert(out, checker.Contains, "testvolcreatelabel-1\n", check.Commentf("expected volume 'testvolcreatelabel-1' in output"))
  275. c.Assert(out, check.Not(checker.Contains), "testvolcreatelabel-2\n", check.Commentf("expected volume 'testvolcreatelabel-2 in output"))
  276. out, _ = dockerCmd(c, "volume", "ls", "--filter", "label=non-exist")
  277. outArr := strings.Split(strings.TrimSpace(out), "\n")
  278. c.Assert(len(outArr), check.Equals, 1, check.Commentf("\n%s", out))
  279. out, _ = dockerCmd(c, "volume", "ls", "--filter", "label=foo=non-exist")
  280. outArr = strings.Split(strings.TrimSpace(out), "\n")
  281. c.Assert(len(outArr), check.Equals, 1, check.Commentf("\n%s", out))
  282. }
  283. func (s *DockerSuite) TestVolumeCLILsFilterDrivers(c *check.C) {
  284. // using default volume driver local to create volumes
  285. testVol1 := "testvol-1"
  286. _, _, err := dockerCmdWithError("volume", "create", testVol1)
  287. assert.NilError(c, err)
  288. testVol2 := "testvol-2"
  289. _, _, err = dockerCmdWithError("volume", "create", testVol2)
  290. assert.NilError(c, err)
  291. // filter with driver=local
  292. out, _ := dockerCmd(c, "volume", "ls", "--filter", "driver=local")
  293. c.Assert(out, checker.Contains, "testvol-1\n", check.Commentf("expected volume 'testvol-1' in output"))
  294. c.Assert(out, checker.Contains, "testvol-2\n", check.Commentf("expected volume 'testvol-2' in output"))
  295. // filter with driver=invaliddriver
  296. out, _ = dockerCmd(c, "volume", "ls", "--filter", "driver=invaliddriver")
  297. outArr := strings.Split(strings.TrimSpace(out), "\n")
  298. c.Assert(len(outArr), check.Equals, 1, check.Commentf("\n%s", out))
  299. // filter with driver=loca
  300. out, _ = dockerCmd(c, "volume", "ls", "--filter", "driver=loca")
  301. outArr = strings.Split(strings.TrimSpace(out), "\n")
  302. c.Assert(len(outArr), check.Equals, 1, check.Commentf("\n%s", out))
  303. // filter with driver=
  304. out, _ = dockerCmd(c, "volume", "ls", "--filter", "driver=")
  305. outArr = strings.Split(strings.TrimSpace(out), "\n")
  306. c.Assert(len(outArr), check.Equals, 1, check.Commentf("\n%s", out))
  307. }
  308. func (s *DockerSuite) TestVolumeCLIRmForceUsage(c *check.C) {
  309. out, _ := dockerCmd(c, "volume", "create")
  310. id := strings.TrimSpace(out)
  311. dockerCmd(c, "volume", "rm", "-f", id)
  312. dockerCmd(c, "volume", "rm", "--force", "nonexist")
  313. }
  314. func (s *DockerSuite) TestVolumeCLIRmForce(c *check.C) {
  315. testRequires(c, testEnv.IsLocalDaemon, DaemonIsLinux)
  316. name := "test"
  317. out, _ := dockerCmd(c, "volume", "create", name)
  318. id := strings.TrimSpace(out)
  319. c.Assert(id, checker.Equals, name)
  320. out, _ = dockerCmd(c, "volume", "inspect", "--format", "{{.Mountpoint}}", name)
  321. assert.Assert(c, strings.TrimSpace(out) != "")
  322. // Mountpoint is in the form of "/var/lib/docker/volumes/.../_data", removing `/_data`
  323. path := strings.TrimSuffix(strings.TrimSpace(out), "/_data")
  324. icmd.RunCommand("rm", "-rf", path).Assert(c, icmd.Success)
  325. dockerCmd(c, "volume", "rm", "-f", name)
  326. out, _ = dockerCmd(c, "volume", "ls")
  327. c.Assert(out, checker.Not(checker.Contains), name)
  328. dockerCmd(c, "volume", "create", name)
  329. out, _ = dockerCmd(c, "volume", "ls")
  330. c.Assert(out, checker.Contains, name)
  331. }
  332. // TestVolumeCLIRmForceInUse verifies that repeated `docker volume rm -f` calls does not remove a volume
  333. // if it is in use. Test case for https://github.com/docker/docker/issues/31446
  334. func (s *DockerSuite) TestVolumeCLIRmForceInUse(c *check.C) {
  335. name := "testvolume"
  336. out, _ := dockerCmd(c, "volume", "create", name)
  337. id := strings.TrimSpace(out)
  338. c.Assert(id, checker.Equals, name)
  339. prefix, slash := getPrefixAndSlashFromDaemonPlatform()
  340. out, _ = dockerCmd(c, "create", "-v", "testvolume:"+prefix+slash+"foo", "busybox")
  341. cid := strings.TrimSpace(out)
  342. _, _, err := dockerCmdWithError("volume", "rm", "-f", name)
  343. assert.ErrorContains(c, err, "")
  344. assert.ErrorContains(c, err, "volume is in use")
  345. out, _ = dockerCmd(c, "volume", "ls")
  346. c.Assert(out, checker.Contains, name)
  347. // The original issue did not _remove_ the volume from the list
  348. // the first time. But a second call to `volume rm` removed it.
  349. // Calling `volume rm` a second time to confirm it's not removed
  350. // when calling twice.
  351. _, _, err = dockerCmdWithError("volume", "rm", "-f", name)
  352. assert.ErrorContains(c, err, "")
  353. assert.ErrorContains(c, err, "volume is in use")
  354. out, _ = dockerCmd(c, "volume", "ls")
  355. c.Assert(out, checker.Contains, name)
  356. // Verify removing the volume after the container is removed works
  357. _, e := dockerCmd(c, "rm", cid)
  358. c.Assert(e, check.Equals, 0)
  359. _, e = dockerCmd(c, "volume", "rm", "-f", name)
  360. c.Assert(e, check.Equals, 0)
  361. out, e = dockerCmd(c, "volume", "ls")
  362. c.Assert(e, check.Equals, 0)
  363. c.Assert(out, checker.Not(checker.Contains), name)
  364. }
  365. func (s *DockerSuite) TestVolumeCliInspectWithVolumeOpts(c *check.C) {
  366. testRequires(c, DaemonIsLinux)
  367. // Without options
  368. name := "test1"
  369. dockerCmd(c, "volume", "create", "-d", "local", name)
  370. out, _ := dockerCmd(c, "volume", "inspect", "--format={{ .Options }}", name)
  371. c.Assert(strings.TrimSpace(out), checker.Contains, "map[]")
  372. // With options
  373. name = "test2"
  374. k1, v1 := "type", "tmpfs"
  375. k2, v2 := "device", "tmpfs"
  376. k3, v3 := "o", "size=1m,uid=1000"
  377. dockerCmd(c, "volume", "create", "-d", "local", name, "--opt", fmt.Sprintf("%s=%s", k1, v1), "--opt", fmt.Sprintf("%s=%s", k2, v2), "--opt", fmt.Sprintf("%s=%s", k3, v3))
  378. out, _ = dockerCmd(c, "volume", "inspect", "--format={{ .Options }}", name)
  379. c.Assert(strings.TrimSpace(out), checker.Contains, fmt.Sprintf("%s:%s", k1, v1))
  380. c.Assert(strings.TrimSpace(out), checker.Contains, fmt.Sprintf("%s:%s", k2, v2))
  381. c.Assert(strings.TrimSpace(out), checker.Contains, fmt.Sprintf("%s:%s", k3, v3))
  382. }
  383. // Test case (1) for 21845: duplicate targets for --volumes-from
  384. func (s *DockerSuite) TestDuplicateMountpointsForVolumesFrom(c *check.C) {
  385. testRequires(c, DaemonIsLinux)
  386. image := "vimage"
  387. buildImageSuccessfully(c, image, build.WithDockerfile(`
  388. FROM busybox
  389. VOLUME ["/tmp/data"]`))
  390. dockerCmd(c, "run", "--name=data1", image, "true")
  391. dockerCmd(c, "run", "--name=data2", image, "true")
  392. out, _ := dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "data1")
  393. data1 := strings.TrimSpace(out)
  394. c.Assert(data1, checker.Not(checker.Equals), "")
  395. out, _ = dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "data2")
  396. data2 := strings.TrimSpace(out)
  397. c.Assert(data2, checker.Not(checker.Equals), "")
  398. // Both volume should exist
  399. out, _ = dockerCmd(c, "volume", "ls", "-q")
  400. c.Assert(strings.TrimSpace(out), checker.Contains, data1)
  401. c.Assert(strings.TrimSpace(out), checker.Contains, data2)
  402. out, _, err := dockerCmdWithError("run", "--name=app", "--volumes-from=data1", "--volumes-from=data2", "-d", "busybox", "top")
  403. c.Assert(err, checker.IsNil, check.Commentf("Out: %s", out))
  404. // Only the second volume will be referenced, this is backward compatible
  405. out, _ = dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "app")
  406. assert.Equal(c, strings.TrimSpace(out), data2)
  407. dockerCmd(c, "rm", "-f", "-v", "app")
  408. dockerCmd(c, "rm", "-f", "-v", "data1")
  409. dockerCmd(c, "rm", "-f", "-v", "data2")
  410. // Both volume should not exist
  411. out, _ = dockerCmd(c, "volume", "ls", "-q")
  412. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data1)
  413. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data2)
  414. }
  415. // Test case (2) for 21845: duplicate targets for --volumes-from and -v (bind)
  416. func (s *DockerSuite) TestDuplicateMountpointsForVolumesFromAndBind(c *check.C) {
  417. testRequires(c, DaemonIsLinux)
  418. image := "vimage"
  419. buildImageSuccessfully(c, image, build.WithDockerfile(`
  420. FROM busybox
  421. VOLUME ["/tmp/data"]`))
  422. dockerCmd(c, "run", "--name=data1", image, "true")
  423. dockerCmd(c, "run", "--name=data2", image, "true")
  424. out, _ := dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "data1")
  425. data1 := strings.TrimSpace(out)
  426. c.Assert(data1, checker.Not(checker.Equals), "")
  427. out, _ = dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "data2")
  428. data2 := strings.TrimSpace(out)
  429. c.Assert(data2, checker.Not(checker.Equals), "")
  430. // Both volume should exist
  431. out, _ = dockerCmd(c, "volume", "ls", "-q")
  432. c.Assert(strings.TrimSpace(out), checker.Contains, data1)
  433. c.Assert(strings.TrimSpace(out), checker.Contains, data2)
  434. // /tmp/data is automatically created, because we are not using the modern mount API here
  435. out, _, err := dockerCmdWithError("run", "--name=app", "--volumes-from=data1", "--volumes-from=data2", "-v", "/tmp/data:/tmp/data", "-d", "busybox", "top")
  436. c.Assert(err, checker.IsNil, check.Commentf("Out: %s", out))
  437. // No volume will be referenced (mount is /tmp/data), this is backward compatible
  438. out, _ = dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "app")
  439. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data1)
  440. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data2)
  441. dockerCmd(c, "rm", "-f", "-v", "app")
  442. dockerCmd(c, "rm", "-f", "-v", "data1")
  443. dockerCmd(c, "rm", "-f", "-v", "data2")
  444. // Both volume should not exist
  445. out, _ = dockerCmd(c, "volume", "ls", "-q")
  446. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data1)
  447. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data2)
  448. }
  449. // Test case (3) for 21845: duplicate targets for --volumes-from and `Mounts` (API only)
  450. func (s *DockerSuite) TestDuplicateMountpointsForVolumesFromAndMounts(c *check.C) {
  451. testRequires(c, testEnv.IsLocalDaemon, DaemonIsLinux)
  452. image := "vimage"
  453. buildImageSuccessfully(c, image, build.WithDockerfile(`
  454. FROM busybox
  455. VOLUME ["/tmp/data"]`))
  456. dockerCmd(c, "run", "--name=data1", image, "true")
  457. dockerCmd(c, "run", "--name=data2", image, "true")
  458. out, _ := dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "data1")
  459. data1 := strings.TrimSpace(out)
  460. c.Assert(data1, checker.Not(checker.Equals), "")
  461. out, _ = dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "data2")
  462. data2 := strings.TrimSpace(out)
  463. c.Assert(data2, checker.Not(checker.Equals), "")
  464. // Both volume should exist
  465. out, _ = dockerCmd(c, "volume", "ls", "-q")
  466. c.Assert(strings.TrimSpace(out), checker.Contains, data1)
  467. c.Assert(strings.TrimSpace(out), checker.Contains, data2)
  468. err := os.MkdirAll("/tmp/data", 0755)
  469. assert.NilError(c, err)
  470. // Mounts is available in API
  471. cli, err := client.NewClientWithOpts(client.FromEnv)
  472. assert.NilError(c, err)
  473. defer cli.Close()
  474. config := container.Config{
  475. Cmd: []string{"top"},
  476. Image: "busybox",
  477. }
  478. hostConfig := container.HostConfig{
  479. VolumesFrom: []string{"data1", "data2"},
  480. Mounts: []mount.Mount{
  481. {
  482. Type: "bind",
  483. Source: "/tmp/data",
  484. Target: "/tmp/data",
  485. },
  486. },
  487. }
  488. _, err = cli.ContainerCreate(context.Background(), &config, &hostConfig, &network.NetworkingConfig{}, "app")
  489. assert.NilError(c, err)
  490. // No volume will be referenced (mount is /tmp/data), this is backward compatible
  491. out, _ = dockerCmd(c, "inspect", "--format", "{{(index .Mounts 0).Name}}", "app")
  492. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data1)
  493. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data2)
  494. dockerCmd(c, "rm", "-f", "-v", "app")
  495. dockerCmd(c, "rm", "-f", "-v", "data1")
  496. dockerCmd(c, "rm", "-f", "-v", "data2")
  497. // Both volume should not exist
  498. out, _ = dockerCmd(c, "volume", "ls", "-q")
  499. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data1)
  500. c.Assert(strings.TrimSpace(out), checker.Not(checker.Contains), data2)
  501. }