12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485 |
- package devmapper
- import (
- "fmt"
- "github.com/dotcloud/docker/archive"
- "github.com/dotcloud/docker/graphdriver"
- "os"
- "path"
- )
- func init() {
- graphdriver.Register("devicemapper", Init)
- }
- // Placeholder interfaces, to be replaced
- // at integration.
- // End of placeholder interfaces.
- type Driver struct {
- *DeviceSet
- home string
- }
- func Init(home string) (graphdriver.Driver, error) {
- d := &Driver{
- DeviceSet: NewDeviceSet(home),
- home: home,
- }
- if err := d.DeviceSet.ensureInit(); err != nil {
- return nil, err
- }
- return d, nil
- }
- func (d *Driver) String() string {
- return "devicemapper"
- }
- func (d *Driver) Cleanup() error {
- return d.DeviceSet.Shutdown()
- }
- func (d *Driver) Create(id string, parent string) error {
- return d.DeviceSet.AddDevice(id, parent)
- }
- func (d *Driver) Remove(id string) error {
- return d.DeviceSet.RemoveDevice(id)
- }
- func (d *Driver) Get(id string) (string, error) {
- mp := path.Join(d.home, "mnt", id)
- if err := d.mount(id, mp); err != nil {
- return "", err
- }
- return mp, nil
- }
- func (d *Driver) Diff(id string) (archive.Archive, error) {
- return nil, fmt.Errorf("Not implemented")
- }
- func (d *Driver) DiffSize(id string) (int64, error) {
- return -1, fmt.Errorf("Not implemented")
- }
- func (d *Driver) Changes(id string) ([]archive.Change, error) {
- return nil, fmt.Errorf("Not implemented")
- }
- func (d *Driver) mount(id, mp string) error {
- // Create the target directories if they don't exist
- if err := os.MkdirAll(mp, 0755); err != nil && !os.IsExist(err) {
- return err
- }
- // If mountpoint is already mounted, do nothing
- if mounted, err := Mounted(mp); err != nil {
- return fmt.Errorf("Error checking mountpoint: %s", err)
- } else if mounted {
- return nil
- }
- // Mount the device
- return d.DeviceSet.MountDevice(id, mp, false)
- }
|