HADOOP-2974. IPC unit tests used "0.0.0.0" to connect to server, which

is not always supported. (rangadi)


git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/trunk@636621 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -181,6 +181,9 @@ Trunk (unreleased changes)
     HADOOP-2657. A flush call on the DFSOutputStream flushes the last
     partial CRC chunk too.  (dhruba)
 
+    HADOOP-2974. IPC unit tests used "0.0.0.0" to connect to server, which
+    is not always supported. (rangadi)
+
 Release 0.16.1 - 2008-03-13
 
   INCOMPATIBLE CHANGES

src/java/org/apache/hadoop/net/NetUtils.java

@@ -32,6 +32,7 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.ipc.Server;
 import org.apache.hadoop.ipc.VersionedProtocol;
 import org.apache.hadoop.util.ReflectionUtils;
 
@@ -229,6 +230,23 @@ public class NetUtils {
     }
   }
   
+  /**
+   * Returns InetSocketAddress that a client can use to 
+   * connect to the server. Server.getListenerAddress() is not correct when
+   * the server binds to "0.0.0.0". This returns "127.0.0.1:port" when
+   * the getListenerAddress() returns "0.0.0.0:port".
+   * 
+   * @param server
+   * @return socket address that a client can use to connect to the server.
+   */
+  public static InetSocketAddress getConnectAddress(Server server) {
+    InetSocketAddress addr = server.getListenerAddress();
+    if (addr.getAddress().getHostAddress().equals("0.0.0.0")) {
+      addr = new InetSocketAddress("127.0.0.1", addr.getPort());
+    }
+    return addr;
+  }
+  
   /**
    * Same as getInputStream(socket, socket.getSoTimeout()).<br><br>
    * 

src/test/org/apache/hadoop/ipc/TestIPC.java

@@ -22,6 +22,7 @@ import org.apache.commons.logging.*;
 
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.LongWritable;
+import org.apache.hadoop.net.NetUtils;
 
 import java.util.Random;
 import java.io.IOException;
@@ -140,7 +141,7 @@ public class TestIPC extends TestCase {
                          int clientCount, int callerCount, int callCount)
     throws Exception {
     Server server = new TestServer(handlerCount, handlerSleep);
-    InetSocketAddress addr = server.getListenerAddress();
+    InetSocketAddress addr = NetUtils.getConnectAddress(server);
     server.start();
 
     Client[] clients = new Client[clientCount];
@@ -179,7 +180,7 @@ public class TestIPC extends TestCase {
 
     InetSocketAddress[] addresses = new InetSocketAddress[addressCount];
     for (int i = 0; i < addressCount; i++) {
-      addresses[i] = servers[i%serverCount].getListenerAddress();
+      addresses[i] = NetUtils.getConnectAddress(servers[i%serverCount]);
     }
 
     Client[] clients = new Client[clientCount];

src/test/org/apache/hadoop/ipc/TestIPCServerResponder.java

@@ -29,6 +29,7 @@ import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.BytesWritable;
 import org.apache.hadoop.io.Writable;
+import org.apache.hadoop.net.NetUtils;
 
 /**
  * This test provokes partial writes in the server, which is 
@@ -127,7 +128,7 @@ public class TestIPCServerResponder extends TestCase {
     Server server = new TestServer(handlerCount, handlerSleep);
     server.start();
 
-    InetSocketAddress address = server.getListenerAddress();
+    InetSocketAddress address = NetUtils.getConnectAddress(server);
     Client[] clients = new Client[clientCount];
     for (int i = 0; i < clientCount; i++) {
       clients[i] = new Client(BytesWritable.class, conf);

src/test/org/apache/hadoop/ipc/TestRPC.java

@@ -33,6 +33,7 @@ import org.apache.hadoop.io.UTF8;
 import org.apache.hadoop.io.Writable;
 
 import org.apache.hadoop.ipc.VersionedProtocol;
+import org.apache.hadoop.net.NetUtils;
 
 /** Unit tests for RPC. */
 public class TestRPC extends TestCase {
@@ -190,7 +191,7 @@ public class TestRPC extends TestCase {
     try {
     server.start();
 
-    InetSocketAddress addr = server.getListenerAddress();
+    InetSocketAddress addr = NetUtils.getConnectAddress(server);
 
     // create a client
     proxy = (TestProtocol)RPC.getProxy(
@@ -231,7 +232,7 @@ public class TestRPC extends TestCase {
     try {
     server.start();
 
-    InetSocketAddress addr = server.getListenerAddress();
+    InetSocketAddress addr = NetUtils.getConnectAddress(server);
     proxy = (TestProtocol)RPC.getProxy(
         TestProtocol.class, TestProtocol.versionID, addr, conf);