X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/465cb9225cce74600349239a295b1360ce2b0fa6..23cc1183e500eb6fa22b611c1c6fc60de1aff9e7:/services/keepstore/keepstore.go?ds=sidebyside diff --git a/services/keepstore/keepstore.go b/services/keepstore/keepstore.go index 3dfdce20e3..53cf7be6ca 100644 --- a/services/keepstore/keepstore.go +++ b/services/keepstore/keepstore.go @@ -14,6 +14,7 @@ import ( "os" "os/signal" "strings" + "sync" "syscall" "time" ) @@ -132,10 +133,14 @@ func (vs *volumeSet) Set(value string) error { if _, err := os.Stat(value); err != nil { return err } + var locker sync.Locker + if flagSerializeIO { + locker = &sync.Mutex{} + } *vs = append(*vs, &UnixVolume{ - root: value, - serialize: flagSerializeIO, - readonly: flagReadonly, + root: value, + locker: locker, + readonly: flagReadonly, }) return nil }