[ARVADOS] updated: f987de07f96595851187ed2a4e0212fa0e10e999
Git user
git at public.curoverse.com
Thu Dec 15 16:39:35 EST 2016
Summary of changes:
services/crunch-run/crunchrun.go | 2 +-
services/crunch-run/crunchrun_test.go | 29 +++++++++++++++++++++++------
2 files changed, 24 insertions(+), 7 deletions(-)
via f987de07f96595851187ed2a4e0212fa0e10e999 (commit)
from 08e03489e053779f7bbc168677deeebd86d6249c (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit f987de07f96595851187ed2a4e0212fa0e10e999
Author: Peter Amstutz <peter.amstutz at curoverse.com>
Date: Thu Dec 15 16:39:23 2016 -0500
10684: Only bind mount certificate when API access is indicated.
diff --git a/services/crunch-run/crunchrun.go b/services/crunch-run/crunchrun.go
index 7983335..b14fa2c 100644
--- a/services/crunch-run/crunchrun.go
+++ b/services/crunch-run/crunchrun.go
@@ -359,7 +359,7 @@ func (runner *ContainerRunner) SetupMounts() (err error) {
return fmt.Errorf("Output path does not correspond to a writable mount point")
}
- if needCertMount {
+ if wantAPI := runner.Container.RuntimeConstraints.API; needCertMount && wantAPI != nil && *wantAPI {
for _, certfile := range arvadosclient.CertFiles {
_, err := os.Stat(certfile)
if err == nil {
diff --git a/services/crunch-run/crunchrun_test.go b/services/crunch-run/crunchrun_test.go
index 5b9b213..b9856ac 100644
--- a/services/crunch-run/crunchrun_test.go
+++ b/services/crunch-run/crunchrun_test.go
@@ -812,9 +812,28 @@ func (s *TestSuite) TestSetupMounts(c *C) {
err := cr.SetupMounts()
c.Check(err, IsNil)
c.Check(am.Cmd, DeepEquals, []string{"--foreground", "--allow-other", "--read-write", "--mount-by-pdh", "by_id", realTemp + "/keep1"})
+ c.Check(cr.Binds, DeepEquals, []string{realTemp + "/2:/tmp"})
+ cr.CleanupDirs()
+ checkEmpty()
+ }
+
+ {
+ i = 0
+ cr.Container.Mounts = make(map[string]arvados.Mount)
+ cr.Container.Mounts["/tmp"] = arvados.Mount{Kind: "tmp"}
+ cr.OutputPath = "/tmp"
+
+ apiflag := true
+ cr.Container.RuntimeConstraints.API = &apiflag
+
+ err := cr.SetupMounts()
+ c.Check(err, IsNil)
+ c.Check(am.Cmd, DeepEquals, []string{"--foreground", "--allow-other", "--read-write", "--mount-by-pdh", "by_id", realTemp + "/keep1"})
c.Check(cr.Binds, DeepEquals, []string{realTemp + "/2:/tmp", stubCertPath + ":/etc/arvados/ca-certificates.crt:ro"})
cr.CleanupDirs()
checkEmpty()
+
+ apiflag = false
}
{
@@ -829,7 +848,7 @@ func (s *TestSuite) TestSetupMounts(c *C) {
err := cr.SetupMounts()
c.Check(err, IsNil)
c.Check(am.Cmd, DeepEquals, []string{"--foreground", "--allow-other", "--read-write", "--mount-tmp", "tmp0", "--mount-by-pdh", "by_id", realTemp + "/keep1"})
- c.Check(cr.Binds, DeepEquals, []string{realTemp + "/keep1/tmp0:/keeptmp", stubCertPath + ":/etc/arvados/ca-certificates.crt:ro"})
+ c.Check(cr.Binds, DeepEquals, []string{realTemp + "/keep1/tmp0:/keeptmp"})
cr.CleanupDirs()
checkEmpty()
}
@@ -850,8 +869,7 @@ func (s *TestSuite) TestSetupMounts(c *C) {
c.Check(am.Cmd, DeepEquals, []string{"--foreground", "--allow-other", "--read-write", "--mount-tmp", "tmp0", "--mount-by-pdh", "by_id", realTemp + "/keep1"})
sort.StringSlice(cr.Binds).Sort()
c.Check(cr.Binds, DeepEquals, []string{realTemp + "/keep1/by_id/59389a8f9ee9d399be35462a0f92541c+53:/keepinp:ro",
- realTemp + "/keep1/tmp0:/keepout",
- stubCertPath + ":/etc/arvados/ca-certificates.crt:ro"})
+ realTemp + "/keep1/tmp0:/keepout"})
cr.CleanupDirs()
checkEmpty()
}
@@ -873,8 +891,7 @@ func (s *TestSuite) TestSetupMounts(c *C) {
c.Check(am.Cmd, DeepEquals, []string{"--foreground", "--allow-other", "--read-write", "--file-cache", "512", "--mount-tmp", "tmp0", "--mount-by-pdh", "by_id", realTemp + "/keep1"})
sort.StringSlice(cr.Binds).Sort()
c.Check(cr.Binds, DeepEquals, []string{realTemp + "/keep1/by_id/59389a8f9ee9d399be35462a0f92541c+53:/keepinp:ro",
- realTemp + "/keep1/tmp0:/keepout",
- stubCertPath + ":/etc/arvados/ca-certificates.crt:ro"})
+ realTemp + "/keep1/tmp0:/keepout"})
cr.CleanupDirs()
checkEmpty()
}
@@ -894,7 +911,7 @@ func (s *TestSuite) TestSetupMounts(c *C) {
err := cr.SetupMounts()
c.Check(err, IsNil)
sort.StringSlice(cr.Binds).Sort()
- c.Check(cr.Binds, DeepEquals, []string{realTemp + "/2/mountdata.json:/mnt/test.json:ro", stubCertPath + ":/etc/arvados/ca-certificates.crt:ro"})
+ c.Check(cr.Binds, DeepEquals, []string{realTemp + "/2/mountdata.json:/mnt/test.json:ro"})
content, err := ioutil.ReadFile(realTemp + "/2/mountdata.json")
c.Check(err, IsNil)
c.Check(content, DeepEquals, []byte(test.out))
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list