support device with multiple targets

Signed-off-by: Lou <[email protected]>

Author: Lou

iscsi/iscsi.go

@@ -32,22 +32,25 @@ type iscsiSession struct {
 	Name     string
 }
 
+type TargetInfo struct {
+	Iqn, Portal string
+}
+
 //Connector provides a struct to hold all of the needed parameters to make our iscsi connection
 type Connector struct {
-	VolumeName       string   `json:"volume_name"`
-	TargetIqn        string   `json:"target_iqn"`
-	TargetPortals    []string `json:"target_portals"`
-	Port             string   `json:"port"`
-	Lun              int32    `json:"lun"`
-	AuthType         string   `json:"auth_type"`
-	DiscoverySecrets Secrets  `json:"discovery_secrets"`
-	SessionSecrets   Secrets  `json:"session_secrets"`
-	Interface        string   `json:"interface"`
-	Multipath        bool     `json:"multipath"`
-	RetryCount       int32    `json:"retry_count"`
-	CheckInterval    int32    `json:"check_interval"`
-	DoDiscovery      bool     `json:"do_discovery"`
-	DoCHAPDiscovery  bool     `json:"do_chap_discovery"`
+	VolumeName       string       `json:"volume_name"`
+	Targets          []TargetInfo `json:"targets"`
+	Port             string       `json:"port"`
+	Lun              int32        `json:"lun"`
+	AuthType         string       `json:"auth_type"`
+	DiscoverySecrets Secrets      `json:"discovery_secrets"`
+	SessionSecrets   Secrets      `json:"session_secrets"`
+	Interface        string       `json:"interface"`
+	Multipath        bool         `json:"multipath"`
+	RetryCount       int32        `json:"retry_count"`
+	CheckInterval    int32        `json:"check_interval"`
+	DoDiscovery      bool         `json:"do_discovery"`
+	DoCHAPDiscovery  bool         `json:"do_chap_discovery"`
 }
 
 func init() {
@@ -248,9 +251,9 @@ func Connect(c Connector) (string, error) {
 	}
 	iscsiTransport := extractTransportName(out)
 
-	for _, p := range c.TargetPortals {
-		debug.Printf("process portal: %s\n", p)
-		baseArgs := []string{"-m", "node", "-T", c.TargetIqn, "-p", p}
+	for _, target := range c.Targets {
+		debug.Printf("process targetIqn: %s, portal: %s\n", target.Iqn, target.Portal)
+		baseArgs := []string{"-m", "node", "-T", target.Iqn, "-target.Portal", target.Portal}
 		// Rescan sessions to discover newly mapped LUNs. Do not specify the interface when rescanning
 		// to avoid establishing additional sessions to the same target.
 		if _, err := iscsiCmd(append(baseArgs, []string{"-R"}...)...); err != nil {
@@ -259,14 +262,14 @@ func Connect(c Connector) (string, error) {
 
 		// create our devicePath that we'll be looking for based on the transport being used
 		if c.Port != "" {
-			p = strings.Join([]string{p, c.Port}, ":")
+			target.Portal = strings.Join([]string{target.Portal, c.Port}, ":")
 		}
-		devicePath := strings.Join([]string{"/dev/disk/by-path/ip", p, "iscsi", c.TargetIqn, "lun", fmt.Sprint(c.Lun)}, "-")
+		devicePath := strings.Join([]string{"/dev/disk/by-path/ip", target.Portal, "iscsi", target.Iqn, "lun", fmt.Sprint(c.Lun)}, "-")
 		if iscsiTransport != "tcp" {
-			devicePath = strings.Join([]string{"/dev/disk/by-path/pci", "*", "ip", p, "iscsi", c.TargetIqn, "lun", fmt.Sprint(c.Lun)}, "-")
+			devicePath = strings.Join([]string{"/dev/disk/by-path/pci", "*", "ip", target.Portal, "iscsi", target.Iqn, "lun", fmt.Sprint(c.Lun)}, "-")
 		}
 
-		exists, _ := sessionExists(p, c.TargetIqn)
+		exists, _ := sessionExists(target.Portal, target.Iqn)
 		if exists {
 			if exists, err := waitForPathToExist(&devicePath, 1, 1, iscsiTransport); exists {
 				debug.Printf("Appending device path: %s", devicePath)
@@ -279,22 +282,22 @@ func Connect(c Connector) (string, error) {
 
 		if c.DoDiscovery {
 			// build discoverydb and discover iscsi target
-			if err := Discovery(p, iFace, c.DiscoverySecrets, c.DoCHAPDiscovery); err != nil {
+			if err := Discovery(target.Portal, iFace, c.DiscoverySecrets, c.DoCHAPDiscovery); err != nil {
 				debug.Printf("Error in discovery of the target: %s\n", err.Error())
 				lastErr = err
 				continue
 			}
 		}
 
 		// Make sure we don't log the secrets
-		err := CreateDBEntry(c.TargetIqn, p, iFace, c.DiscoverySecrets, c.SessionSecrets, c.DoCHAPDiscovery)
+		err := CreateDBEntry(target.Iqn, target.Portal, iFace, c.DiscoverySecrets, c.SessionSecrets, c.DoCHAPDiscovery)
 		if err != nil {
 			debug.Printf("Error creating db entry: %s\n", err.Error())
 			continue
 		}
 
 		// perform the login
-		err = Login(c.TargetIqn, p)
+		err = Login(target.Iqn, target.Portal)
 		if err != nil {
 			debug.Printf("failed to login, err: %v", err)
 			lastErr = err