package devmapper
import "github.com/docker/docker/daemon/graphdriver/devmapper"
Index ¶
- Constants
- Variables
- func BlockDeviceDiscard(path string) error
- func DevmapperLogCallback(level C.int, file *C.char, line C.int, dm_errno_or_class C.int, message *C.char)
- func FindLoopDeviceFor(file *os.File) *os.File
- func GetBlockDeviceSize(file *os.File) (uint64, error)
- func GetLibraryVersion() (string, error)
- func Init(home string, options []string) (graphdriver.Driver, error)
- func LogInitVerbose(level int)
- func LoopbackSetCapacity(file *os.File) error
- func Mounted(mountpoint string) (bool, error)
- func ProbeFsType(device string) (string, error)
- func RemoveDevice(name string) error
- func SetDevDir(dir string) error
- func UdevWait(cookie uint) error
- type AddNodeType
- type CDmTask
- type CLoopInfo64
- type DevInfo
- type DevStatus
- type DeviceSet
- func NewDeviceSet(root string, doInit bool, options []string) (*DeviceSet, error)
- func (devices *DeviceSet) AddDevice(hash, baseHash string) error
- func (devices *DeviceSet) DeleteDevice(hash string) error
- func (devices *DeviceSet) GetDeviceStatus(hash string) (*DevStatus, error)
- func (devices *DeviceSet) HasActivatedDevice(hash string) bool
- func (devices *DeviceSet) HasDevice(hash string) bool
- func (devices *DeviceSet) List() []string
- func (devices *DeviceSet) MountDevice(hash, path, mountLabel string) error
- func (devices *DeviceSet) ResizePool(size int64) error
- func (devices *DeviceSet) Shutdown() error
- func (devices *DeviceSet) Status() *Status
- func (devices *DeviceSet) UnmountDevice(hash string) error
- type DevmapperLogger
- type DiskUsage
- type Driver
- func (d *Driver) Cleanup() error
- func (d *Driver) Create(id, parent string) error
- func (d *Driver) Exists(id string) bool
- func (d *Driver) Get(id, mountLabel string) (string, error)
- func (d *Driver) Put(id string)
- func (d *Driver) Remove(id string) error
- func (d *Driver) Status() [][2]string
- func (d *Driver) String() string
- type Info
- type LoopInfo64
- type MetaData
- type Status
- type Task
- func TaskCreate(tasktype TaskType) *Task
- func (t *Task) AddTarget(start, size uint64, ttype, params string) error
- func (t *Task) GetDriverVersion() (string, error)
- func (t *Task) GetInfo() (*Info, error)
- func (t *Task) GetNextTarget(next uintptr) (nextPtr uintptr, start uint64, length uint64, targetType string, params string)
- func (t *Task) Run() error
- func (t *Task) SetAddNode(addNode AddNodeType) error
- func (t *Task) SetCookie(cookie *uint, flags uint16) error
- func (t *Task) SetMessage(message string) error
- func (t *Task) SetName(name string) error
- func (t *Task) SetRo() error
- func (t *Task) SetSector(sector uint64) error
- type TaskType
Constants ¶
const ( BlkGetSize64 = C.BLKGETSIZE64 BlkDiscard = C.BLKDISCARD LoopSetFd = C.LOOP_SET_FD LoopCtlGetFree = C.LOOP_CTL_GET_FREE LoopGetStatus64 = C.LOOP_GET_STATUS64 LoopSetStatus64 = C.LOOP_SET_STATUS64 LoopClrFd = C.LOOP_CLR_FD LoopSetCapacity = C.LOOP_SET_CAPACITY )
IOCTL consts
const ( LoFlagsAutoClear = C.LO_FLAGS_AUTOCLEAR LoFlagsReadOnly = C.LO_FLAGS_READ_ONLY LoFlagsPartScan = C.LO_FLAGS_PARTSCAN LoKeySize = C.LO_KEY_SIZE LoNameSize = C.LO_NAME_SIZE )
Variables ¶
var ( DefaultDataLoopbackSize int64 = 100 * 1024 * 1024 * 1024 DefaultMetaDataLoopbackSize int64 = 2 * 1024 * 1024 * 1024 DefaultBaseFsSize uint64 = 10 * 1024 * 1024 * 1024 )
var ( ErrTaskRun = errors.New("dm_task_run failed") ErrTaskSetName = errors.New("dm_task_set_name failed") ErrTaskSetMessage = errors.New("dm_task_set_message failed") ErrTaskSetAddNode = errors.New("dm_task_set_add_node failed") ErrTaskSetRo = errors.New("dm_task_set_ro failed") ErrTaskAddTarget = errors.New("dm_task_add_target failed") ErrTaskSetSector = errors.New("dm_task_set_sector failed") ErrTaskGetInfo = errors.New("dm_task_get_info failed") ErrTaskGetDriverVersion = errors.New("dm_task_get_driver_version failed") ErrTaskSetCookie = errors.New("dm_task_set_cookie failed") ErrNilCookie = errors.New("cookie ptr can't be nil") ErrAttachLoopbackDevice = errors.New("loopback mounting failed") ErrGetBlockSize = errors.New("Can't get block size") ErrUdevWait = errors.New("wait on udev cookie failed") ErrSetDevDir = errors.New("dm_set_dev_dir failed") ErrGetLibraryVersion = errors.New("dm_get_library_version failed") ErrCreateRemoveTask = errors.New("Can't create task of type DeviceRemove") ErrRunRemoveDevice = errors.New("running removeDevice failed") ErrInvalidAddNode = errors.New("Invalide AddNoce type") ErrGetLoopbackBackingFile = errors.New("Unable to get loopback backing file") ErrLoopbackSetCapacity = errors.New("Unable set loopback capacity") ErrBusy = errors.New("Device is Busy") )
var ( DmGetLibraryVersion = dmGetLibraryVersionFct DmGetNextTarget = dmGetNextTargetFct DmLogInitVerbose = dmLogInitVerboseFct DmSetDevDir = dmSetDevDirFct DmTaskAddTarget = dmTaskAddTargetFct DmTaskCreate = dmTaskCreateFct DmTaskDestroy = dmTaskDestroyFct DmTaskGetInfo = dmTaskGetInfoFct DmTaskGetDriverVersion = dmTaskGetDriverVersionFct DmTaskRun = dmTaskRunFct DmTaskSetAddNode = dmTaskSetAddNodeFct DmTaskSetCookie = dmTaskSetCookieFct DmTaskSetMessage = dmTaskSetMessageFct DmTaskSetName = dmTaskSetNameFct DmTaskSetRo = dmTaskSetRoFct DmTaskSetSector = dmTaskSetSectorFct DmUdevWait = dmUdevWaitFct LogWithErrnoInit = logWithErrnoInitFct )
Functions ¶
func BlockDeviceDiscard ¶
func DevmapperLogCallback ¶
func DevmapperLogCallback(level C.int, file *C.char, line C.int, dm_errno_or_class C.int, message *C.char)
func FindLoopDeviceFor ¶
func GetBlockDeviceSize ¶
func GetLibraryVersion ¶
func Init ¶
func Init(home string, options []string) (graphdriver.Driver, error)
func LogInitVerbose ¶
func LogInitVerbose(level int)
func LoopbackSetCapacity ¶
func Mounted ¶
func ProbeFsType ¶
func RemoveDevice ¶
Useful helper for cleanup
func SetDevDir ¶
func UdevWait ¶
Types ¶
type AddNodeType ¶
type AddNodeType int
const ( AddNodeOnResume AddNodeType = iota AddNodeOnCreate )
type CDmTask ¶
type CDmTask C.struct_dm_task
type CLoopInfo64 ¶
type CLoopInfo64 C.struct_loop_info64
type DevInfo ¶
type DevInfo struct { Hash string `json:"-"` DeviceId int `json:"device_id"` Size uint64 `json:"size"` TransactionId uint64 `json:"transaction_id"` Initialized bool `json:"initialized"` // contains filtered or unexported fields }
func (*DevInfo) DevName ¶
func (*DevInfo) Name ¶
type DevStatus ¶
type DevStatus struct { DeviceId int Size uint64 TransactionId uint64 SizeInSectors uint64 MappedSectors uint64 HighestMappedSector uint64 }
type DeviceSet ¶
type DeviceSet struct { MetaData sync.Mutex // Protects Devices map and serializes calls into libdevmapper TransactionId uint64 NewTransactionId uint64 // contains filtered or unexported fields }
func NewDeviceSet ¶
func (*DeviceSet) AddDevice ¶
func (*DeviceSet) DeleteDevice ¶
func (*DeviceSet) GetDeviceStatus ¶
func (*DeviceSet) HasActivatedDevice ¶
func (*DeviceSet) HasDevice ¶
func (*DeviceSet) List ¶
func (*DeviceSet) MountDevice ¶
func (*DeviceSet) ResizePool ¶
func (*DeviceSet) Shutdown ¶
func (*DeviceSet) Status ¶
func (*DeviceSet) UnmountDevice ¶
type DevmapperLogger ¶
type DevmapperLogger interface {
// contains filtered or unexported methods
}
type DiskUsage ¶
type Driver ¶
type Driver struct { *DeviceSet // contains filtered or unexported fields }
func (*Driver) Cleanup ¶
func (*Driver) Create ¶
func (*Driver) Exists ¶
func (*Driver) Get ¶
func (*Driver) Put ¶
func (*Driver) Remove ¶
func (*Driver) Status ¶
func (*Driver) String ¶
type Info ¶
type Info struct { Exists int Suspended int LiveTable int InactiveTable int OpenCount int32 EventNr uint32 Major uint32 Minor uint32 ReadOnly int TargetCount int32 }
type LoopInfo64 ¶
type LoopInfo64 struct {
// contains filtered or unexported fields
}
type MetaData ¶
type MetaData struct { Devices map[string]*DevInfo `json:devices` // contains filtered or unexported fields }
type Status ¶
type Status struct { PoolName string DataLoopback string MetadataLoopback string Data DiskUsage Metadata DiskUsage SectorSize uint64 }
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
func TaskCreate ¶
func (*Task) AddTarget ¶
func (*Task) GetDriverVersion ¶
func (*Task) GetInfo ¶
func (*Task) GetNextTarget ¶
func (t *Task) GetNextTarget(next uintptr) (nextPtr uintptr, start uint64, length uint64, targetType string, params string)
func (*Task) Run ¶
func (*Task) SetAddNode ¶
func (t *Task) SetAddNode(addNode AddNodeType) error
func (*Task) SetCookie ¶
func (*Task) SetMessage ¶
func (*Task) SetName ¶
func (*Task) SetRo ¶
func (*Task) SetSector ¶
type TaskType ¶
type TaskType int
const ( DeviceCreate TaskType = iota DeviceReload DeviceRemove DeviceRemoveAll DeviceSuspend DeviceResume DeviceInfo DeviceDeps DeviceRename DeviceVersion DeviceStatus DeviceTable DeviceWaitevent DeviceList DeviceClear DeviceMknodes DeviceListVersions DeviceTargetMsg DeviceSetGeometry )
Source Files ¶
attach_loopback.go deviceset.go devmapper.go devmapper_doc.go devmapper_log.go devmapper_wrapper.go driver.go ioctl.go mount.go
- Version
- v1.0.0
- Published
- Jun 8, 2014
- Platform
- linux/amd64
- Imports
- 23 packages
- Last checked
- 38 minutes ago –
Tools for package owners.