Merge pull request #1234 from opensds/development

Merge development branch into master for v0.10.2 release

Author: skdwriting

client/client.go

@@ -130,6 +130,7 @@ func processListParam(args []interface{}) (string, error) {
 			if v == "" {
 				continue
 			}
+			v = strings.Replace(v, " ", "%20", -1)
 			urlParam = append(urlParam, k+"="+v)
 		}
 	}

contrib/connector/common.go

@@ -111,13 +111,6 @@ func Mount(device, mountpoint, fsType string, mountFlags []string) error {
 		return err
 	}
 
-	// Make sure the mount is not lost after the host reboots
-	cmd := fmt.Sprintf("echo \"%s %s %s defaults 0 0\" >> /etc/fstab", device, mountpoint, fsType)
-	_, err = ExecCmd("/bin/bash", "-c", cmd)
-	if err != nil {
-		return err
-	}
-
 	return nil
 }
 
@@ -131,11 +124,6 @@ func Umount(mountpoint string) error {
 		return err
 	}
 
-	cmd := fmt.Sprintf("cat -n /etc/fstab | grep -w '%s' | awk -F ' ' '{ print $1 }'| xargs -i sed -i '{}d' /etc/fstab", mountpoint)
-	_, err = ExecCmd("/bin/bash", "-c", cmd)
-	if err != nil {
-		return err
-	}
 	return nil
 }
 

contrib/connector/connector.go

@@ -42,7 +42,7 @@ const (
 type Connector interface {
 	Attach(map[string]interface{}) (string, error)
 	Detach(map[string]interface{}) error
-	GetInitiatorInfo() (string, error)
+	GetInitiatorInfo() ([]string, error)
 }
 
 var cnts = map[string]Connector{}

contrib/connector/fc/fc.go

@@ -41,6 +41,6 @@ func (f *FC) Detach(conn map[string]interface{}) error {
 }
 
 // GetInitiatorInfo ...
-func (f *FC) GetInitiatorInfo() (string, error) {
+func (f *FC) GetInitiatorInfo() ([]string, error) {
 	return getInitiatorInfo()
 }

contrib/connector/fc/fibreChannel.go

@@ -81,6 +81,14 @@ func connectVolume(connMap map[string]interface{}) (map[string]string, error) {
 		return nil, err
 	}
 
+	dmPath, err := getMultipathDevice(deviceWWN)
+	if err != nil {
+		return nil, err
+	}
+	if len(dmPath) > 0 {
+		devicePath = dmPath
+	}
+
 	return map[string]string{"scsi_wwn": deviceWWN, "path": devicePath}, nil
 }
 
@@ -227,22 +235,23 @@ func getFChbasInfo() ([]map[string]string, error) {
 	return hbasInfos, nil
 }
 
-func getInitiatorInfo() (string, error) {
+func getInitiatorInfo() ([]string, error) {
 	hbas, err := getFChbasInfo()
 	if err != nil {
-		return "", err
+		return nil, err
 	}
 
 	var initiatorInfo []string
-
 	for _, hba := range hbas {
 		if v, ok := hba[connector.PortName]; ok {
-			initiatorInfo = append(initiatorInfo, "port_name:"+v)
-		}
-		if v, ok := hba[connector.NodeName]; ok {
-			initiatorInfo = append(initiatorInfo, "node_name:"+v)
+			initiatorInfo = append(initiatorInfo, v)
 		}
 	}
 
-	return strings.Join(initiatorInfo, ","), nil
+	//Check for atleast one initiator
+	if (0 == len(initiatorInfo)){
+		return nil, errors.New("No initiator info found.")
+	}
+
+	return initiatorInfo, nil
 }

contrib/connector/fc/linuxfc.go

@@ -176,3 +176,28 @@ func trimDoubleQuotesInText(str string) string {
 	}
 	return str
 }
+
+func getMultipathDevice(deviceWWN string) (string, error) {
+	cmd := fmt.Sprintf("ls -l /dev/disk/by-id/ | grep %s", deviceWWN)
+	out, err := connector.ExecCmd("/bin/bash", "-c", cmd)
+	if err != nil {
+		msg := fmt.Sprintf("No DM of wwn %s exist", deviceWWN)
+		log.Println(msg)
+		return "", nil
+	}
+
+	lines := strings.Split(strings.TrimSpace(out), "\n")
+	for _, line := range lines {
+		splits := strings.Split(line, "../../")
+		if len(splits) == 2 {
+			name := splits[1]
+			if strings.HasPrefix(name, "dm") {
+				return fmt.Sprintf("/dev/%s", name), nil
+			}
+		}
+	}
+
+	msg := fmt.Sprintf("No DM of wwn %s exist", deviceWWN)
+	log.Println(msg)
+	return "", nil
+}

contrib/connector/iscsi/helper.go

@@ -372,19 +372,19 @@ func getTgtPortalAndTgtIQN() (string, string, error) {
 
 }
 
-func getInitiatorInfo() (string, error) {
+func getInitiatorInfo() ([]string, error) {
 	initiators, err := getInitiator()
 	if err != nil {
-		return "", err
+		return nil, err
 	}
 
 	if len(initiators) == 0 {
-		return "", errors.New("No iqn found")
+		return nil, errors.New("No iqn found")
 	}
 
 	if len(initiators) > 1 {
-		return "", errors.New("the number of iqn is wrong")
+		return nil, errors.New("the number of iqn is wrong")
 	}
 
-	return initiators[0], nil
+	return initiators, nil
 }

contrib/connector/iscsi/iscsi.go

@@ -33,6 +33,6 @@ func (isc *Iscsi) Detach(conn map[string]interface{}) error {
 }
 
 // GetInitiatorInfo implementation
-func (isc *Iscsi) GetInitiatorInfo() (string, error) {
+func (isc *Iscsi) GetInitiatorInfo() ([]string, error) {
 	return getInitiatorInfo()
 }

contrib/connector/nfs/helper.go

@@ -103,6 +103,6 @@ func disconnect(conn map[string]interface{}) error {
 	return errors.New("disconnect method of nfs is not implemented")
 }
 
-func getInitiatorInfo() (string, error) {
-	return "", errors.New("get initiator information method of nfs is not implemented")
+func getInitiatorInfo() ([]string, error) {
+	return nil, errors.New("get initiator information method of nfs is not implemented")
 }

contrib/connector/nfs/nfs.go

@@ -33,6 +33,6 @@ func (n *NFS) Detach(conn map[string]interface{}) error {
 }
 
 // GetInitiatorInfo implementation
-func (n *NFS) GetInitiatorInfo() (string, error) {
+func (n *NFS) GetInitiatorInfo() ([]string, error) {
 	return getInitiatorInfo()
 }