Skip to content

Commit d0b6e38

Browse files
committed
added fix for nvme failure
1 parent 525ada7 commit d0b6e38

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

service/node.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -718,14 +718,16 @@ func (s *service) NodePublishVolume(
718718

719719
var symlinkPath string
720720
var devicePath string
721-
if s.useNVMeTCP || s.arrayTransportProtocolMap[symID] == NvmeTCPTransportProtocol {
721+
if s.useNVMeTCP {
722+
log.Infof("Inside NVMETCP")
722723
symlinkPath, devicePath, err = gofsutil.WWNToDevicePathX(context.Background(), vol.NGUID)
723724
if err != nil || symlinkPath == "" {
724725
errmsg := fmt.Sprintf("Device path not found for WWN %s: %s", deviceWWN, err)
725726
log.Error(errmsg)
726727
return nil, status.Error(codes.NotFound, errmsg)
727728
}
728729
} else {
730+
log.Infof("Not Inside NVMETCP")
729731
symlinkPath, devicePath, err = gofsutil.WWNToDevicePathX(context.Background(), deviceWWN)
730732
if err != nil || symlinkPath == "" {
731733
errmsg := fmt.Sprintf("Device path not found for WWN %s: %s", deviceWWN, err)

0 commit comments

Comments
 (0)