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/sdk/go/arvados"
18 "git.arvados.org/arvados.git/sdk/go/arvadosclient"
19 "git.arvados.org/arvados.git/sdk/go/keepclient"
20 "github.com/arvados/cgofuse/fuse"
26 // ready, if non-nil, will be closed when the mount is
27 // initialized. If ready is non-nil, it RunCommand() should
28 // not be called more than once, or when ready is already
31 // It is safe to call Unmount only after ready has been
33 Unmount func() (ok bool)
36 // RunCommand implements the subcommand "mount <path> [fuse options]".
38 // The "-d" fuse option (and perhaps other features) ignores the
39 // stderr argument and prints to os.Stderr instead.
40 func (c *cmd) RunCommand(prog string, args []string, stdin io.Reader, stdout, stderr io.Writer) int {
41 logger := log.New(stderr, prog+" ", 0)
42 flags := flag.NewFlagSet(prog, flag.ContinueOnError)
43 ro := flags.Bool("ro", false, "read-only")
44 experimental := flags.Bool("experimental", false, "acknowledge this is an experimental command, and should not be used in production (required)")
45 blockCache := flags.Int("block-cache", 4, "read cache size (number of 64MiB blocks)")
46 pprof := flags.String("pprof", "", "serve Go profile data at `[addr]:port`")
47 err := flags.Parse(args)
53 logger.Printf("error: experimental command %q used without --experimental flag", prog)
58 log.Println(http.ListenAndServe(*pprof, nil))
62 client := arvados.NewClientFromEnv()
63 ac, err := arvadosclient.New(client)
68 kc, err := keepclient.MakeKeepClient(ac)
73 kc.BlockCache = &keepclient.BlockCache{MaxBlocks: *blockCache}
74 host := fuse.NewFileSystemHost(&keepFS{
82 c.Unmount = host.Unmount
83 ok := host.Mount("", flags.Args())