fallback to /dev/mapper device if metadata device is not set in docker info
This commit is contained in:
parent
267066c0f9
commit
f3bca888f8
@ -16,6 +16,7 @@ package docker
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
dockertypes "github.com/docker/engine-api/types"
|
dockertypes "github.com/docker/engine-api/types"
|
||||||
@ -50,8 +51,19 @@ func DockerThinPoolName(info dockertypes.Info) (string, error) {
|
|||||||
|
|
||||||
func DockerMetadataDevice(info dockertypes.Info) (string, error) {
|
func DockerMetadataDevice(info dockertypes.Info) (string, error) {
|
||||||
metadataDevice := DriverStatusValue(info.DriverStatus, DriverStatusMetadataFile)
|
metadataDevice := DriverStatusValue(info.DriverStatus, DriverStatusMetadataFile)
|
||||||
if len(metadataDevice) == 0 {
|
if len(metadataDevice) != 0 {
|
||||||
return "", fmt.Errorf("Could not get the devicemapper metadata device")
|
return metadataDevice, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
poolName, err := DockerThinPoolName(info)
|
||||||
|
if err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
metadataDevice = fmt.Sprintf("/dev/mapper/%s_tmeta", poolName)
|
||||||
|
|
||||||
|
if _, err := os.Stat(metadataDevice); err != nil {
|
||||||
|
return "", err
|
||||||
}
|
}
|
||||||
|
|
||||||
return metadataDevice, nil
|
return metadataDevice, nil
|
||||||
|
Loading…
Reference in New Issue
Block a user