big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-11365. Log portnumber in PrivilegedNfsGatewayStarter. Contributed by Mukul Kumar Singh.

Browse Source
This commit is contained in:
Jitendra Pandey 2017-01-24 21:58:02 -08:00
parent 9c0a4d3e71
commit 5a5652098c
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
hadoop-hdfs-project/hadoop-hdfs-nfs/src/main/java/org/apache/hadoop/hdfs/nfs/nfs3/PrivilegedNfsGatewayStarter.java
View File

@ -18,9 +18,12 @@
import java.net.DatagramSocket; import java.net.DatagramSocket;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.net.SocketException;
import org.apache.commons.daemon.Daemon; import org.apache.commons.daemon.Daemon;
import org.apache.commons.daemon.DaemonContext; 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.NfsConfigKeys;
import org.apache.hadoop.hdfs.nfs.conf.NfsConfiguration; import org.apache.hadoop.hdfs.nfs.conf.NfsConfiguration;
@ -34,7 +37,7 @@
* Debian: https://bugs.debian.org/cgi-bin/bugreport.cgi?bug=594880 * Debian: https://bugs.debian.org/cgi-bin/bugreport.cgi?bug=594880
*/ */
public class PrivilegedNfsGatewayStarter implements Daemon { public class PrivilegedNfsGatewayStarter implements Daemon {
static final Log LOG = LogFactory.getLog(PrivilegedNfsGatewayStarter.class);
private String[] args = null; private String[] args = null;
private DatagramSocket registrationSocket = 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 " + NfsConfigKeys.DFS_NFS_REGISTRATION_PORT_KEY + "' configured to a " +
"privileged port."); "privileged port.");
} }
registrationSocket = new DatagramSocket(
new InetSocketAddress("localhost", clientPort)); try {
registrationSocket.setReuseAddress(true); 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(); args = context.getArguments();
} }