docker_cli_volume_test.go 23 KB

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