aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/nodeserver.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/driver/nodeserver.go')
-rw-r--r--pkg/driver/nodeserver.go6
1 files changed, 2 insertions, 4 deletions
diff --git a/pkg/driver/nodeserver.go b/pkg/driver/nodeserver.go
index d89919e..56d02c6 100644
--- a/pkg/driver/nodeserver.go
+++ b/pkg/driver/nodeserver.go
@@ -149,8 +149,7 @@ func (ns *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpu
glog.Warningf("volume %s hasn't been published", volumeID)
// make sure there is no any garbage
- mounter := mount.New("")
- _ = mount.CleanupMountPoint(targetPath, mounter, true)
+ _ = mount.CleanupMountPoint(targetPath, mountutil, true)
return &csi.NodeUnpublishVolumeResponse{}, nil
}
@@ -221,8 +220,7 @@ func (ns *NodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstag
glog.Warningf("volume %s hasn't been staged", volumeID)
// make sure there is no any garbage
- mounter := mount.New("")
- _ = mount.CleanupMountPoint(stagingTargetPath, mounter, true)
+ _ = mount.CleanupMountPoint(stagingTargetPath, mountutil, true)
} else {
if err := volume.(*Volume).Unstage(stagingTargetPath); err != nil {
return nil, status.Error(codes.Internal, err.Error())