Browse Source

ZOOKEEPER-4728: force to re-resolve hostname into IP when binding. (#2040)

* ZOOKEEPER-4728: force to re-resolve hostname into IP when binding

* ZOOKEEPER-4708: add test
Luke Chen 1 year ago
parent
commit
40aed41793

+ 5 - 1
zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Leader.java

@@ -309,6 +309,10 @@ public class Leader extends LearnerMaster {
         this.zk = zk;
         this.zk = zk;
     }
     }
 
 
+    InetSocketAddress recreateInetSocketAddr(String hostString, int port) {
+        return new InetSocketAddress(hostString, port);
+    }
+
     Optional<ServerSocket> createServerSocket(InetSocketAddress address, boolean portUnification, boolean sslQuorum) {
     Optional<ServerSocket> createServerSocket(InetSocketAddress address, boolean portUnification, boolean sslQuorum) {
         ServerSocket serverSocket;
         ServerSocket serverSocket;
         try {
         try {
@@ -318,7 +322,7 @@ public class Leader extends LearnerMaster {
                 serverSocket = new ServerSocket();
                 serverSocket = new ServerSocket();
             }
             }
             serverSocket.setReuseAddress(true);
             serverSocket.setReuseAddress(true);
-            serverSocket.bind(address);
+            serverSocket.bind(recreateInetSocketAddr(address.getHostString(), address.getPort()));
             return Optional.of(serverSocket);
             return Optional.of(serverSocket);
         } catch (IOException e) {
         } catch (IOException e) {
             LOG.error("Couldn't bind to {}", address.toString(), e);
             LOG.error("Couldn't bind to {}", address.toString(), e);

+ 11 - 0
zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/LeaderBeanTest.java

@@ -25,6 +25,7 @@ import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyString;
 import static org.mockito.ArgumentMatchers.anyString;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.when;
 import static org.mockito.Mockito.when;
 import java.io.File;
 import java.io.File;
 import java.io.IOException;
 import java.io.IOException;
@@ -47,6 +48,7 @@ import org.apache.zookeeper.txn.TxnHeader;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
 import org.mockito.invocation.InvocationOnMock;
 import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 import org.mockito.stubbing.Answer;
 
 
@@ -92,6 +94,15 @@ public class LeaderBeanTest {
         fileTxnSnapLog.close();
         fileTxnSnapLog.close();
     }
     }
 
 
+    @Test
+    public void testCreateServerSocketWillRecreateInetSocketAddr() {
+        Leader spyLeader = Mockito.spy(leader);
+        InetSocketAddress addr = new InetSocketAddress("localhost", PortAssignment.unique());
+        spyLeader.createServerSocket(addr, false, false);
+        // make sure the address to be bound will be recreated with expected hostString and port
+        Mockito.verify(spyLeader, times(1)).recreateInetSocketAddr(addr.getHostString(), addr.getPort());
+    }
+
     @Test
     @Test
     public void testGetName() {
     public void testGetName() {
         assertEquals("Leader", leaderBean.getName());
         assertEquals("Leader", leaderBean.getName());