github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

Change getDeviceMajorMinor to use unix.Stat

Browse Source
This commit is contained in:
Masaki Kimura 2019-11-12 15:50:16 +00:00
parent aee875a855
commit 8a09460c2f
2 changed files with 20 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/volume/util/volumepathhandler/BUILD
View File

@ -13,7 +13,15 @@ go_library(
"//pkg/util/mount:go_default_library",
"//staging/src/k8s.io/apimachinery/pkg/types:go_default_library",
"//vendor/k8s.io/klog:go_default_library",
],
] + select({
"@io_bazel_rules_go//go/platform:android": [
"//vendor/golang.org/x/sys/unix:go_default_library",
],
"@io_bazel_rules_go//go/platform:linux": [
"//vendor/golang.org/x/sys/unix:go_default_library",
],
"//conditions:default": [],
}),
)
filegroup(

24
pkg/volume/util/volumepathhandler/volume_path_handler_linux.go
View File

@ -27,6 +27,8 @@ import (
"path/filepath"
"strings"
"golang.org/x/sys/unix"
"k8s.io/apimachinery/pkg/types"
"k8s.io/klog"
)
@ -220,24 +222,20 @@ func compareBindMountAndSymlinks(global, pod string) (bool, error) {
return false, nil
}
// getDeviceMajorMinor returns major/minor number for the path with belwo format:
// getDeviceMajorMinor returns major/minor number for the path with below format:
// major:minor (in hex)
// ex)
// fc:10
func getDeviceMajorMinor(path string) (string, error) {
args := []string{"-c", "%t:%T", path}
cmd := exec.Command(statPath, args...)
out, err := cmd.CombinedOutput()
if err != nil {
klog.V(2).Infof("Failed to stat path: %s %v %s ", path, err, out)
return "", fmt.Errorf("stat -c %%t:%%T %s failed: %v", path, err)
var stat unix.Stat_t
if err := unix.Stat(path, &stat); err != nil {
return "", fmt.Errorf("failed to stat path %s: %v", path, err)
}
// stat -c "%t:%T" {path} outputs following format(major:minor in hex):
// fc:10
if len(out) == 0 {
return "", errors.New(ErrDeviceNotFound)
}
devNumber := uint64(stat.Rdev)
major := unix.Major(devNumber)
minor := unix.Minor(devNumber)
return strings.TrimSpace(string(out)), nil
return fmt.Sprintf("%x:%x", major, minor), nil
}