moby--moby/devmapper/plugin.go

package devmapper

import (
	"fmt"
	"os"
	"path"
	"github.com/dotcloud/docker/archive"
)

// Placeholder interfaces, to be replaced
// at integration.

type Image interface {
	ID() string
	Parent() (Image, error)
	Path() string
}

type Change interface {

}

// End of placeholder interfaces.



type DMBackend struct {
	*DeviceSet
	home string
}

func Init(home string) (*DMBackend, error) {
	b := &DMBackend{
		DeviceSet: NewDeviceSet(home),
		home: home,
	}
	if err := b.DeviceSet.ensureInit(); err != nil {
		return nil, err
	}
	return b, nil
}

func (b *DMBackend) Cleanup() error {
	return b.DeviceSet.Shutdown()
}

func (b *DMBackend) OnCreate(img Image, layer archive.Archive) error {
	// Determine the source of the snapshot (parent id or init device)
	var parentID string
	if parent, err := img.Parent(); err != nil {
		return err
	} else if parent != nil {
		parentID = parent.ID()
	}
	// Create the device for this image by snapshotting source
	if err := b.DeviceSet.AddDevice(img.ID(), parentID); err != nil {
		return err
	}
	// Mount the device in rootfs
	mp := b.mountpoint(img.ID())
	if err := os.MkdirAll(mp, 0700); err != nil {
		return err
	}
	if err := b.DeviceSet.MountDevice(img.ID(), mp, false); err != nil {
		return err
	}
	// Apply the layer as a diff 
	if layer != nil {
		if err := archive.ApplyLayer(mp, layer); err != nil {
			return err
		}
	}
	return nil
}


func (b *DMBackend) mountpoint(id string) string {
	if b.home == "" {
		return ""
	}
	return path.Join(b.home, "mnt", id)
}

func (b *DMBackend) Changes(img *Image, dest string) ([]Change, error) {
	return nil, fmt.Errorf("Not implemented")
}

func (b *DMBackend) Layer(img *Image, dest string) (archive.Archive, error) {
	return nil, fmt.Errorf("Not implemented")
}