From 0c20fffa06dd99f83c3de36470888862021baf71 Mon Sep 17 00:00:00 2001
From: derekwaynecarr <decarr@redhat.com>
Date: Thu, 11 Sep 2014 13:38:46 -0400
Subject: [PATCH] No DNS in vagrant cross minions, need explicit IP as host

---
 cluster/vagrant/config-default.sh         | 4 +++-
 cluster/vagrant/provision-minion.sh       | 1 +
 pkg/cloudprovider/vagrant/vagrant.go      | 7 ++++---
 pkg/cloudprovider/vagrant/vagrant_test.go | 8 ++++++--
 pkg/registry/pod/rest.go                  | 5 -----
 5 files changed, 14 insertions(+), 11 deletions(-)

diff --git a/cluster/vagrant/config-default.sh b/cluster/vagrant/config-default.sh
index d663675f3dafa..57180659aae9b 100755
--- a/cluster/vagrant/config-default.sh
+++ b/cluster/vagrant/config-default.sh
@@ -27,12 +27,14 @@ INSTANCE_PREFIX=kubernetes
 MASTER_NAME="${INSTANCE_PREFIX}-master"
 MASTER_TAG="${INSTANCE_PREFIX}-master"
 MINION_TAG="${INSTANCE_PREFIX}-minion"
-MINION_NAMES=($(eval echo ${INSTANCE_PREFIX}-minion-{1..${NUM_MINIONS}}))
+# Unable to use hostnames yet because DNS is not in cluster, so we revert external look-up name to use the minion IP
+#MINION_NAMES=($(eval echo ${INSTANCE_PREFIX}-minion-{1..${NUM_MINIONS}}))
 
 # IP LOCATIONS FOR INTERACTING WITH THE MINIONS
 MINION_IP_BASE="10.245.2."
 for (( i=0; i <${NUM_MINIONS}; i++)) do
   KUBE_MINION_IP_ADDRESSES[$i]="${MINION_IP_BASE}$[$i+2]"
   MINION_IP[$i]="${MINION_IP_BASE}$[$i+2]"
+  MINION_NAMES[$i]="${MINION_IP[$i]}"
   VAGRANT_MINION_NAMES[$i]="minion-$[$i+1]"
 done
diff --git a/cluster/vagrant/provision-minion.sh b/cluster/vagrant/provision-minion.sh
index b99bfb9e53a01..e7e859ee7c57c 100755
--- a/cluster/vagrant/provision-minion.sh
+++ b/cluster/vagrant/provision-minion.sh
@@ -50,6 +50,7 @@ grains:
   roles:
     - kubernetes-pool
   cbr-cidr: $MINION_IP_RANGE
+  minion_ip: $MINION_IP
 EOF
 
 # we will run provision to update code each time we test, so we do not want to do salt install each time
diff --git a/pkg/cloudprovider/vagrant/vagrant.go b/pkg/cloudprovider/vagrant/vagrant.go
index f0a0295fe45a9..cdf1b5c14ff81 100644
--- a/pkg/cloudprovider/vagrant/vagrant.go
+++ b/pkg/cloudprovider/vagrant/vagrant.go
@@ -106,8 +106,8 @@ func (v *VagrantCloud) IPAddress(instance string) (net.IP, error) {
 	}
 	filteredMinions := v.saltMinionsByRole(minions, "kubernetes-pool")
 	for _, minion := range filteredMinions {
-		fmt.Println("Minion: ", minion.Host, " , ", instance, " IP: ", minion.IP)
-		if minion.Host == instance {
+		// Due to vagrant not running with a dedicated DNS setup, we return the IP address of a minion as its hostname at this time
+		if minion.IP == instance {
 			return net.ParseIP(minion.IP), nil
 		}
 	}
@@ -203,7 +203,8 @@ func (v *VagrantCloud) List(filter string) ([]string, error) {
 	filteredMinions := v.saltMinionsByRole(minions, "kubernetes-pool")
 	var instances []string
 	for _, instance := range filteredMinions {
-		instances = append(instances, instance.Host)
+		// With no dedicated DNS setup in cluster, IP address is used as hostname
+		instances = append(instances, instance.IP)
 	}
 
 	return instances, nil
diff --git a/pkg/cloudprovider/vagrant/vagrant_test.go b/pkg/cloudprovider/vagrant/vagrant_test.go
index 273bef9a78c15..3ed9f0037c219 100644
--- a/pkg/cloudprovider/vagrant/vagrant_test.go
+++ b/pkg/cloudprovider/vagrant/vagrant_test.go
@@ -73,7 +73,11 @@ func TestVagrantCloud(t *testing.T) {
 		t.Fatalf("Incorrect number of instances returned")
 	}
 
-	if instances[0] != "kubernetes-minion-1" {
+	// no DNS in vagrant cluster, so we return IP as hostname
+	expectedInstanceHost := "10.245.2.2"
+	expectedInstanceIP := "10.245.2.2"
+
+	if instances[0] != expectedInstanceHost {
 		t.Fatalf("Invalid instance returned")
 	}
 
@@ -82,7 +86,7 @@ func TestVagrantCloud(t *testing.T) {
 		t.Fatalf("Unexpected error, should have returned a valid IP address: %s", err)
 	}
 
-	if ip.String() != "10.245.2.2" {
+	if ip.String() != expectedInstanceIP {
 		t.Fatalf("Invalid IP address returned")
 	}
 }
diff --git a/pkg/registry/pod/rest.go b/pkg/registry/pod/rest.go
index 9058459df4efc..136197d5dd562 100644
--- a/pkg/registry/pod/rest.go
+++ b/pkg/registry/pod/rest.go
@@ -18,7 +18,6 @@ package pod
 
 import (
 	"fmt"
-	"strings"
 	"sync"
 	"time"
 
@@ -195,10 +194,6 @@ func getInstanceIP(cloud cloudprovider.Interface, host string) string {
 	if instances == nil || !ok {
 		return ""
 	}
-	ix := strings.Index(host, ".")
-	if ix != -1 {
-		host = host[:ix]
-	}
 	addr, err := instances.IPAddress(host)
 	if err != nil {
 		glog.Errorf("Error getting instance IP: %#v", err)