2013-11-04 01:54:51 +00:00
|
|
|
package graphdriver
|
2013-11-01 01:07:54 +00:00
|
|
|
|
2013-11-04 23:22:34 +00:00
|
|
|
import (
|
2014-03-27 16:41:06 +00:00
|
|
|
"errors"
|
2013-11-04 23:22:34 +00:00
|
|
|
"fmt"
|
2013-11-19 11:13:22 +00:00
|
|
|
"os"
|
2013-11-08 19:36:58 +00:00
|
|
|
"path"
|
2014-06-05 19:50:53 +00:00
|
|
|
|
|
|
|
"github.com/dotcloud/docker/archive"
|
|
|
|
"github.com/dotcloud/docker/pkg/mount"
|
2013-11-04 23:22:34 +00:00
|
|
|
)
|
|
|
|
|
2014-06-03 01:26:41 +00:00
|
|
|
type FsMagic uint64
|
|
|
|
|
|
|
|
const (
|
|
|
|
FsMagicBtrfs = FsMagic(0x9123683E)
|
|
|
|
FsMagicAufs = FsMagic(0x61756673)
|
|
|
|
)
|
|
|
|
|
2014-06-05 08:34:20 +00:00
|
|
|
type InitFunc func(root string, options []string) (Driver, error)
|
2013-11-05 04:51:12 +00:00
|
|
|
|
|
|
|
type Driver interface {
|
2013-11-15 09:24:48 +00:00
|
|
|
String() string
|
|
|
|
|
2014-04-17 23:47:27 +00:00
|
|
|
Create(id, parent string) error
|
2013-11-07 20:34:01 +00:00
|
|
|
Remove(id string) error
|
2013-11-05 04:51:12 +00:00
|
|
|
|
2014-04-17 23:47:27 +00:00
|
|
|
Get(id, mountLabel string) (dir string, err error)
|
2013-12-05 21:18:02 +00:00
|
|
|
Put(id string)
|
2013-11-19 10:32:08 +00:00
|
|
|
Exists(id string) bool
|
2013-11-05 04:51:12 +00:00
|
|
|
|
2013-11-15 10:04:02 +00:00
|
|
|
Status() [][2]string
|
|
|
|
|
2013-11-12 01:17:38 +00:00
|
|
|
Cleanup() error
|
|
|
|
}
|
|
|
|
|
|
|
|
type Differ interface {
|
2013-11-11 20:09:26 +00:00
|
|
|
Diff(id string) (archive.Archive, error)
|
2013-11-08 22:54:20 +00:00
|
|
|
Changes(id string) ([]archive.Change, error)
|
2014-02-14 11:41:46 +00:00
|
|
|
ApplyDiff(id string, diff archive.ArchiveReader) error
|
2013-11-19 09:36:54 +00:00
|
|
|
DiffSize(id string) (bytes int64, err error)
|
2013-11-11 15:47:36 +00:00
|
|
|
}
|
|
|
|
|
2013-11-04 23:22:34 +00:00
|
|
|
var (
|
2013-11-20 19:39:15 +00:00
|
|
|
DefaultDriver string
|
2013-11-04 23:22:34 +00:00
|
|
|
// All registred drivers
|
|
|
|
drivers map[string]InitFunc
|
|
|
|
// Slice of drivers that should be used in an order
|
|
|
|
priority = []string{
|
|
|
|
"aufs",
|
2014-03-24 14:15:04 +00:00
|
|
|
"btrfs",
|
2013-11-04 23:22:34 +00:00
|
|
|
"devicemapper",
|
2013-11-25 18:28:17 +00:00
|
|
|
"vfs",
|
2013-11-04 23:22:34 +00:00
|
|
|
}
|
2014-03-27 16:41:06 +00:00
|
|
|
|
2014-05-29 19:55:59 +00:00
|
|
|
ErrNotSupported = errors.New("driver not supported")
|
|
|
|
ErrPrerequisites = errors.New("prerequisites for driver not satisfied (wrong filesystem?)")
|
|
|
|
ErrIncompatibleFS = fmt.Errorf("backing file system is unsupported for this graph driver")
|
2013-11-04 23:22:34 +00:00
|
|
|
)
|
|
|
|
|
2013-11-07 20:31:50 +00:00
|
|
|
func init() {
|
|
|
|
drivers = make(map[string]InitFunc)
|
|
|
|
}
|
|
|
|
|
2013-11-04 23:22:34 +00:00
|
|
|
func Register(name string, initFunc InitFunc) error {
|
|
|
|
if _, exists := drivers[name]; exists {
|
|
|
|
return fmt.Errorf("Name already registered %s", name)
|
|
|
|
}
|
|
|
|
drivers[name] = initFunc
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-06-05 08:34:20 +00:00
|
|
|
func GetDriver(name, home string, options []string) (Driver, error) {
|
2013-11-08 02:49:32 +00:00
|
|
|
if initFunc, exists := drivers[name]; exists {
|
2014-06-05 08:34:20 +00:00
|
|
|
return initFunc(path.Join(home, name), options)
|
2013-11-08 02:49:32 +00:00
|
|
|
}
|
2014-03-27 16:41:06 +00:00
|
|
|
return nil, ErrNotSupported
|
2013-11-08 02:49:32 +00:00
|
|
|
}
|
|
|
|
|
2014-06-05 08:34:20 +00:00
|
|
|
func New(root string, options []string) (driver Driver, err error) {
|
2013-11-20 19:39:15 +00:00
|
|
|
for _, name := range []string{os.Getenv("DOCKER_DRIVER"), DefaultDriver} {
|
2013-11-19 11:13:22 +00:00
|
|
|
if name != "" {
|
2014-06-05 08:34:20 +00:00
|
|
|
return GetDriver(name, root, options)
|
2013-11-19 11:13:22 +00:00
|
|
|
}
|
2013-11-08 02:49:32 +00:00
|
|
|
}
|
2013-11-19 11:13:22 +00:00
|
|
|
|
2013-11-04 23:22:34 +00:00
|
|
|
// Check for priority drivers first
|
|
|
|
for _, name := range priority {
|
2014-06-05 08:34:20 +00:00
|
|
|
driver, err = GetDriver(name, root, options)
|
2014-03-27 16:41:06 +00:00
|
|
|
if err != nil {
|
2014-05-29 19:55:59 +00:00
|
|
|
if err == ErrNotSupported || err == ErrPrerequisites || err == ErrIncompatibleFS {
|
2014-03-27 16:41:06 +00:00
|
|
|
continue
|
|
|
|
}
|
|
|
|
return nil, err
|
2013-11-04 23:22:34 +00:00
|
|
|
}
|
2013-11-08 02:49:32 +00:00
|
|
|
return driver, nil
|
2013-11-04 23:22:34 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// Check all registered drivers if no priority driver is found
|
|
|
|
for _, initFunc := range drivers {
|
2014-06-05 08:34:20 +00:00
|
|
|
if driver, err = initFunc(root, options); err != nil {
|
2014-05-29 19:55:59 +00:00
|
|
|
if err == ErrNotSupported || err == ErrPrerequisites || err == ErrIncompatibleFS {
|
2014-03-27 16:41:06 +00:00
|
|
|
continue
|
|
|
|
}
|
|
|
|
return nil, err
|
2013-11-04 23:22:34 +00:00
|
|
|
}
|
|
|
|
return driver, nil
|
|
|
|
}
|
2014-03-27 16:41:06 +00:00
|
|
|
return nil, fmt.Errorf("No supported storage backend found")
|
2013-11-04 23:22:34 +00:00
|
|
|
}
|
2014-06-05 19:50:53 +00:00
|
|
|
|
|
|
|
func MakePrivate(mountPoint string) error {
|
|
|
|
mounted, err := mount.Mounted(mountPoint)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if !mounted {
|
|
|
|
if err := mount.Mount(mountPoint, mountPoint, "none", "bind,rw"); err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return mount.ForceMount("", mountPoint, "none", "private")
|
|
|
|
}
|