diff --git a/pkg/volume/iscsi/iscsi.go b/pkg/volume/iscsi/iscsi.go index 9c75334348a..492f9175bfc 100644 --- a/pkg/volume/iscsi/iscsi.go +++ b/pkg/volume/iscsi/iscsi.go @@ -95,10 +95,7 @@ func (plugin *iscsiPlugin) newBuilderInternal(spec *volume.Spec, podUID types.UI } lun := strconv.Itoa(iscsi.Lun) - portal := iscsi.TargetPortal - if !strings.Contains(portal, ":") { - portal = iscsi.TargetPortal + ":3260" - } + portal := portalBuilder(iscsi.TargetPortal) return &iscsiDiskBuilder{ iscsiDisk: &iscsiDisk{ @@ -193,3 +190,10 @@ func (c *iscsiDiskCleaner) TearDown() error { func (c *iscsiDiskCleaner) TearDownAt(dir string) error { return diskTearDown(c.manager, *c, dir, c.mounter) } + +func portalBuilder(portal string) string { + if !strings.Contains(portal, ":") { + portal = portal + ":3260" + } + return portal +} diff --git a/pkg/volume/iscsi/iscsi_test.go b/pkg/volume/iscsi/iscsi_test.go index 9ee8eef9769..2025d922c75 100644 --- a/pkg/volume/iscsi/iscsi_test.go +++ b/pkg/volume/iscsi/iscsi_test.go @@ -250,3 +250,12 @@ func TestPersistentClaimReadOnlyFlag(t *testing.T) { t.Errorf("Expected true for builder.IsReadOnly") } } + +func TestPortalBuilder(t *testing.T) { + if portal := portalBuilder("127.0.0.1"); portal != "127.0.0.1:3260" { + t.Errorf("wrong portal: %s", portal) + } + if portal := portalBuilder("127.0.0.1:3260"); portal != "127.0.0.1:3260" { + t.Errorf("wrong portal: %s", portal) + } +}