From e5fbb3538f9fd987dea4aeeab17e97946fe92669 Mon Sep 17 00:00:00 2001 From: Jan Safranek Date: Thu, 27 Sep 2018 10:24:59 +0200 Subject: [PATCH] Unmount iSCSI device only if it's mounted. --- pkg/volume/iscsi/iscsi_util.go | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/pkg/volume/iscsi/iscsi_util.go b/pkg/volume/iscsi/iscsi_util.go index dda88d03c6f..d16aed16451 100644 --- a/pkg/volume/iscsi/iscsi_util.go +++ b/pkg/volume/iscsi/iscsi_util.go @@ -23,6 +23,7 @@ import ( "path" "path/filepath" "regexp" + "strconv" "strings" "time" @@ -34,7 +35,6 @@ import ( "k8s.io/kubernetes/pkg/volume" volumeutil "k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util/volumepathhandler" - "strconv" ) var ( @@ -553,10 +553,18 @@ func (util *ISCSIUtil) DetachDisk(c iscsiDiskUnmounter, mntPath string) error { glog.Warningf("Warning: Unmount skipped because path does not exist: %v", mntPath) return nil } - if err := c.mounter.Unmount(mntPath); err != nil { - glog.Errorf("iscsi detach disk: failed to unmount: %s\nError: %v", mntPath, err) + + notMnt, err := c.mounter.IsLikelyNotMountPoint(mntPath) + if err != nil { return err } + if !notMnt { + if err := c.mounter.Unmount(mntPath); err != nil { + glog.Errorf("iscsi detach disk: failed to unmount: %s\nError: %v", mntPath, err) + return err + } + } + // if device is no longer used, see if need to logout the target device, prefix, err := extractDeviceAndPrefix(mntPath) if err != nil {