docker_cli_volume_test.go 24 KB

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