aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/utils.go
diff options
context:
space:
mode:
authorViktor Kuzmin <kvaster@gmail.com>2023-08-06 20:55:56 +0300
committerViktor Kuzmin <kvaster@gmail.com>2023-08-06 20:55:56 +0300
commiteca9cde95a899ab5645b00d8c0d547abd4bc7e8e (patch)
treee3c646e031c35b0299d58407994b10b5ed38a89a /pkg/driver/utils.go
parentcb920765f5d0b3b7a6a54b9bacf5e9be28b46102 (diff)
downloadseaweedfs-csi-driver-eca9cde95a899ab5645b00d8c0d547abd4bc7e8e.tar.xz
seaweedfs-csi-driver-eca9cde95a899ab5645b00d8c0d547abd4bc7e8e.zip
Use single instance of mount utility - mount.New is expensive
Diffstat (limited to 'pkg/driver/utils.go')
-rw-r--r--pkg/driver/utils.go7
1 files changed, 3 insertions, 4 deletions
diff --git a/pkg/driver/utils.go b/pkg/driver/utils.go
index ea83209..eee1825 100644
--- a/pkg/driver/utils.go
+++ b/pkg/driver/utils.go
@@ -70,8 +70,7 @@ func logGRPC(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, h
}
func checkMount(targetPath string) (bool, error) {
- mounter := mount.New("")
- isMnt, err := mounter.IsMountPoint(targetPath)
+ isMnt, err := mountutil.IsMountPoint(targetPath)
if err != nil {
if os.IsNotExist(err) {
if err = os.MkdirAll(targetPath, 0750); err != nil {
@@ -79,10 +78,10 @@ func checkMount(targetPath string) (bool, error) {
}
isMnt = false
} else if mount.IsCorruptedMnt(err) {
- if err := mounter.Unmount(targetPath); err != nil {
+ if err := mountutil.Unmount(targetPath); err != nil {
return false, err
}
- isMnt, err = mounter.IsMountPoint(targetPath)
+ isMnt, err = mountutil.IsMountPoint(targetPath)
} else {
return false, err
}