1 // Copyright (C) The Arvados Authors. All rights reserved.
3 // SPDX-License-Identifier: Apache-2.0
13 // pprof is only imported to register its HTTP handlers
17 "git.arvados.org/arvados.git/lib/cmd"
18 "git.arvados.org/arvados.git/sdk/go/arvados"
19 "git.arvados.org/arvados.git/sdk/go/arvadosclient"
20 "git.arvados.org/arvados.git/sdk/go/keepclient"
21 "github.com/arvados/cgofuse/fuse"
22 "github.com/ghodss/yaml"
25 var Command = &mountCommand{}
27 type mountCommand struct {
28 // ready, if non-nil, will be closed when the mount is
29 // initialized. If ready is non-nil, it RunCommand() should
30 // not be called more than once, or when ready is already
33 // It is safe to call Unmount only after ready has been
35 Unmount func() (ok bool)
38 // RunCommand implements the subcommand "mount <path> [fuse options]".
40 // The "-d" fuse option (and perhaps other features) ignores the
41 // stderr argument and prints to os.Stderr instead.
42 func (c *mountCommand) RunCommand(prog string, args []string, stdin io.Reader, stdout, stderr io.Writer) int {
43 logger := log.New(stderr, prog+" ", 0)
44 flags := flag.NewFlagSet(prog, flag.ContinueOnError)
45 ro := flags.Bool("ro", false, "read-only")
46 experimental := flags.Bool("experimental", false, "acknowledge this is an experimental command, and should not be used in production (required)")
47 cacheSizeStr := flags.String("cache-size", "0", "cache size as percent of home filesystem size (\"5%\") or size (\"10GiB\") or 0 for automatic")
48 pprof := flags.String("pprof", "", "serve Go profile data at `[addr]:port`")
49 if ok, code := cmd.ParseFlags(flags, prog, args, "[FUSE mount options]", stderr); !ok {
53 logger.Printf("error: experimental command %q used without --experimental flag", prog)
58 log.Println(http.ListenAndServe(*pprof, nil))
62 client := arvados.NewClientFromEnv()
63 if err := yaml.Unmarshal([]byte(*cacheSizeStr), &client.DiskCacheSize); err != nil {
64 logger.Printf("error parsing -cache-size argument: %s", err)
67 ac, err := arvadosclient.New(client)
72 kc, err := keepclient.MakeKeepClient(ac)
77 host := fuse.NewFileSystemHost(&keepFS{
85 c.Unmount = host.Unmount
86 ok := host.Mount("", flags.Args())