From 5a5652098c0c717fee045e12bcaf7cf5a72635ea Mon Sep 17 00:00:00 2001
From: Jitendra Pandey <jitendra@apache.org>
Date: Tue, 24 Jan 2017 21:58:02 -0800
Subject: [PATCH] HDFS-11365. Log portnumber in PrivilegedNfsGatewayStarter.
 Contributed by Mukul Kumar Singh.

---
 .../nfs/nfs3/PrivilegedNfsGatewayStarter.java   | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/hadoop-hdfs-project/hadoop-hdfs-nfs/src/main/java/org/apache/hadoop/hdfs/nfs/nfs3/PrivilegedNfsGatewayStarter.java b/hadoop-hdfs-project/hadoop-hdfs-nfs/src/main/java/org/apache/hadoop/hdfs/nfs/nfs3/PrivilegedNfsGatewayStarter.java
index 3934d7c494..695cbc3a3a 100644
--- a/hadoop-hdfs-project/hadoop-hdfs-nfs/src/main/java/org/apache/hadoop/hdfs/nfs/nfs3/PrivilegedNfsGatewayStarter.java
+++ b/hadoop-hdfs-project/hadoop-hdfs-nfs/src/main/java/org/apache/hadoop/hdfs/nfs/nfs3/PrivilegedNfsGatewayStarter.java
@@ -18,9 +18,12 @@
 
 import java.net.DatagramSocket;
 import java.net.InetSocketAddress;
+import java.net.SocketException;
 
 import org.apache.commons.daemon.Daemon;
 import org.apache.commons.daemon.DaemonContext;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.hdfs.nfs.conf.NfsConfigKeys;
 import org.apache.hadoop.hdfs.nfs.conf.NfsConfiguration;
 
@@ -34,7 +37,7 @@
  * Debian: https://bugs.debian.org/cgi-bin/bugreport.cgi?bug=594880
  */
 public class PrivilegedNfsGatewayStarter implements Daemon {
-	
+  static final Log LOG = LogFactory.getLog(PrivilegedNfsGatewayStarter.class);
   private String[] args = null;
   private DatagramSocket registrationSocket = null;
 
@@ -49,9 +52,15 @@ public void init(DaemonContext context) throws Exception {
           NfsConfigKeys.DFS_NFS_REGISTRATION_PORT_KEY + "' configured to a " +
           "privileged port.");
     }
-    registrationSocket = new DatagramSocket(
-        new InetSocketAddress("localhost", clientPort));
-    registrationSocket.setReuseAddress(true);
+
+    try {
+      registrationSocket = new DatagramSocket(
+                    new InetSocketAddress("localhost", clientPort));
+      registrationSocket.setReuseAddress(true);
+    } catch (SocketException e) {
+      LOG.error("Init failed for port=" + clientPort, e);
+      throw e;
+    }
     args = context.getArguments();
   }