func()

in internal/proxy/proxy_other.go [168:186]


func (c *Client) serveFuse(ctx context.Context, notify func()) error {
	srv, err := fs.Mount(c.fuseDir, c, &fs.Options{
		MountOptions: fuse.MountOptions{AllowOther: true},
	})
	if err != nil {
		return fmt.Errorf("FUSE mount failed: %q: %v", c.fuseDir, err)
	}
	c.fuseServerMu.Lock()
	c.fuseServer = srv
	c.fuseExitCh = make(chan error)
	c.fuseServerMu.Unlock()
	notify()
	select {
	case err = <-c.fuseExitCh:
		return err
	case <-ctx.Done():
		return ctx.Err()
	}
}