Alexander Larsson
5e0d1fa18e
On systems that supports reflinking (i.e. btrfs) this means the dummy backend is much faster at copying files and will be sharing file data in a CoW fashion. On my (btrfs) system this makes "docker run ubuntu echo hello world" go from about 3 seconds to about 1 second. Not instant, but clearly better. cp --reflink=auto is availible since coreutils 7.5 (around 2009), so this seems pretty ok to rely on. cp is also better at preserving file metadata than tar, so for instance it will copy xattrs. Upstream-commit: 242fd4b3ef32b5a20135d6031040bcf099b5df4e Component: engine
91 lines
1.6 KiB
Go
91 lines
1.6 KiB
Go
package dummy
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/dotcloud/docker/graphdriver"
|
|
"os"
|
|
"os/exec"
|
|
"path"
|
|
)
|
|
|
|
func init() {
|
|
graphdriver.Register("dummy", Init)
|
|
}
|
|
|
|
func Init(home string) (graphdriver.Driver, error) {
|
|
d := &Driver{
|
|
home: home,
|
|
}
|
|
return d, nil
|
|
}
|
|
|
|
type Driver struct {
|
|
home string
|
|
}
|
|
|
|
func (d *Driver) String() string {
|
|
return "dummy"
|
|
}
|
|
|
|
func (d *Driver) Status() [][2]string {
|
|
return nil
|
|
}
|
|
|
|
func (d *Driver) Cleanup() error {
|
|
return nil
|
|
}
|
|
|
|
func copyDir(src, dst string) error {
|
|
cmd := exec.Command("cp", "-aT", "--reflink=auto", src, dst)
|
|
if err := cmd.Run(); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (d *Driver) Create(id string, parent string) error {
|
|
dir := d.dir(id)
|
|
if err := os.MkdirAll(path.Dir(dir), 0700); err != nil {
|
|
return err
|
|
}
|
|
if err := os.Mkdir(dir, 0700); err != nil {
|
|
return err
|
|
}
|
|
if parent == "" {
|
|
return nil
|
|
}
|
|
parentDir, err := d.Get(parent)
|
|
if err != nil {
|
|
return fmt.Errorf("%s: %s", parent, err)
|
|
}
|
|
if err := copyDir(parentDir, dir); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (d *Driver) dir(id string) string {
|
|
return path.Join(d.home, "dir", path.Base(id))
|
|
}
|
|
|
|
func (d *Driver) Remove(id string) error {
|
|
if _, err := os.Stat(d.dir(id)); err != nil {
|
|
return err
|
|
}
|
|
return os.RemoveAll(d.dir(id))
|
|
}
|
|
|
|
func (d *Driver) Get(id string) (string, error) {
|
|
dir := d.dir(id)
|
|
if st, err := os.Stat(dir); err != nil {
|
|
return "", err
|
|
} else if !st.IsDir() {
|
|
return "", fmt.Errorf("%s: not a directory", dir)
|
|
}
|
|
return dir, nil
|
|
}
|
|
|
|
func (d *Driver) Size(id string) (int64, error) {
|
|
return -1, fmt.Errorf("Not implemented")
|
|
}
|