HDFS-11533. reuseAddress option should be used for child channels in Portmap and SimpleTcpServer. Contributed by Mukul Kumar Singh.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/09ad8eff Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/09ad8eff Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/09ad8eff Branch: refs/heads/HADOOP-13345 Commit: 09ad8effb825eddbf0ee2ef591a0d16a58468f56 Parents: 79ede40 Author: Jitendra Pandey <[email protected]> Authored: Thu Mar 16 11:40:12 2017 -0700 Committer: Jitendra Pandey <[email protected]> Committed: Thu Mar 16 12:20:46 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/oncrpc/SimpleTcpServer.java | 1 + .../hadoop-nfs/src/main/java/org/apache/hadoop/portmap/Portmap.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/09ad8eff/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/SimpleTcpServer.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/SimpleTcpServer.java b/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/SimpleTcpServer.java index f7ab52e..bd48b15 100644 --- a/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/SimpleTcpServer.java +++ b/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/oncrpc/SimpleTcpServer.java @@ -81,6 +81,7 @@ public class SimpleTcpServer { }); server.setOption("child.tcpNoDelay", true); server.setOption("child.keepAlive", true); + server.setOption("child.reuseAddress", true); server.setOption("reuseAddress", true); // Listen to TCP port http://git-wip-us.apache.org/repos/asf/hadoop/blob/09ad8eff/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/Portmap.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/Portmap.java b/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/Portmap.java index 94d76d0..7586fda 100644 --- a/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/Portmap.java +++ b/hadoop-common-project/hadoop-nfs/src/main/java/org/apache/hadoop/portmap/Portmap.java @@ -110,6 +110,7 @@ final class Portmap { } }); tcpServer.setOption("reuseAddress", true); + tcpServer.setOption("child.reuseAddress", true); udpServer = new ConnectionlessBootstrap(new NioDatagramChannelFactory( Executors.newCachedThreadPool())); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
