Bug 1996 - multihomed hostnames

3 files changed, 81 insertions, 4 deletions

diff --git a/java/src/IceInternal/Network.java b/java/src/IceInternal/Network.java
index 92a1547d234..cfa52fa0e4c 100644
--- a/java/src/IceInternal/Network.java
+++ b/java/src/IceInternal/Network.java
@@ -654,6 +654,41 @@ public final class Network
     }
 
     public static java.util.ArrayList
+    getHosts(String host)
+    {
+        java.util.ArrayList hosts = new java.util.ArrayList();
+        try
+        {
+            java.net.InetAddress[] addrs = java.net.InetAddress.getAllByName(host);
+            for(int i = 0; i < addrs.length; ++i)
+            {
+                if(addrs[i] instanceof java.net.Inet4Address)
+                {
+                    hosts.add(addrs[i].getHostAddress());
+                }
+            }
+        }
+        catch(java.net.UnknownHostException ex)
+        {
+            Ice.DNSException e = new Ice.DNSException();
+            e.host = host;
+            throw e;
+        }
+
+        //
+        // No Inet4Address available.
+        //
+        if(hosts.size() == 0)
+        {
+            Ice.DNSException e = new Ice.DNSException();
+            e.host = host;
+            throw e;
+        }
+
+        return hosts;
+    }
+
+    public static java.util.ArrayList
     getLocalHosts()
     {
         java.util.ArrayList hosts = new java.util.ArrayList();
diff --git a/java/src/IceInternal/TcpEndpointI.java b/java/src/IceInternal/TcpEndpointI.java
index 21eb90d067c..e83c38ac416 100644
--- a/java/src/IceInternal/TcpEndpointI.java
+++ b/java/src/IceInternal/TcpEndpointI.java
@@ -388,8 +388,29 @@ final class TcpEndpointI extends EndpointI
         }
         else
         {
-            calcHashValue();
-            endps.add(this);
+            if(!server)
+            {
+                java.util.ArrayList hosts = Network.getHosts(_host);
+                if(hosts.size() > 1)
+                {
+                    java.util.Iterator iter = hosts.iterator();
+                    while(iter.hasNext())
+                    {
+                        String host = (String)iter.next();
+                        endps.add(new TcpEndpointI(_instance, host, _port, _timeout, _connectionId, _compress, true));
+                    }
+                }
+                else
+                {
+                    calcHashValue();
+                    endps.add(this);
+                }
+            }
+            else
+            {
+                calcHashValue();
+                endps.add(this);
+            }
         }
         return endps;
     }
diff --git a/java/src/IceInternal/UdpEndpointI.java b/java/src/IceInternal/UdpEndpointI.java
index 6207a0499b8..44f3a01b5c0 100644
--- a/java/src/IceInternal/UdpEndpointI.java
+++ b/java/src/IceInternal/UdpEndpointI.java
@@ -523,8 +523,29 @@ final class UdpEndpointI extends EndpointI
         }
         else
         {
-            calcHashValue();
-            endps.add(this);
+            if(!server)
+            {
+                java.util.ArrayList hosts = Network.getHosts(_host);
+                if(hosts.size() > 1)
+                {
+                    java.util.Iterator iter = hosts.iterator();
+                    while(iter.hasNext())
+                    {
+                        String host = (String)iter.next();
+                        endps.add(new UdpEndpointI(_instance, host, _port, _connect, _connectionId, _compress, true));
+                    }
+                }
+                else
+                {
+                    calcHashValue();
+                    endps.add(this);
+                }
+            }
+            else
+            {
+                calcHashValue();
+                endps.add(this);
+            }
         }
         return endps;
     }