mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
77 lines
1.5 KiB
Go
77 lines
1.5 KiB
Go
package devmapper
|
|
|
|
import (
|
|
"fmt"
|
|
"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) {
|
|
deviceSet, err := NewDeviceSet(home);
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
d := &Driver{
|
|
DeviceSet: deviceSet,
|
|
home: home,
|
|
}
|
|
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) Size(id string) (int64, error) {
|
|
return -1, 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)
|
|
}
|