You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ji...@apache.org on 2013/11/16 02:00:43 UTC
svn commit: r1542438 -
/hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java
Author: jing9
Date: Sat Nov 16 01:00:42 2013
New Revision: 1542438
URL: http://svn.apache.org/r1542438
Log:
HDFS-5502. Fix HTTPS support in HsftpFileSystem. Contributed by Haohui Mai.
Modified:
hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java
Modified: hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java?rev=1542438&r1=1542437&r2=1542438&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java (original)
+++ hadoop/common/trunk/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/http/HttpServer.java Sat Nov 16 01:00:42 2013
@@ -85,6 +85,7 @@ import org.mortbay.jetty.webapp.WebAppCo
import org.mortbay.thread.QueuedThreadPool;
import org.mortbay.util.MultiException;
+import com.google.common.base.Preconditions;
import com.sun.jersey.spi.container.servlet.ServletContainer;
/**
@@ -717,6 +718,19 @@ public class HttpServer implements Filte
}
/**
+ * Get the port that corresponds to a particular connector. In the case of
+ * HDFS, the second connector corresponds to the HTTPS connector.
+ *
+ * @return the corresponding port for the connector, or -1 if there's no such
+ * connector.
+ */
+ public int getConnectorPort(int index) {
+ Preconditions.checkArgument(index >= 0);
+ return index < webServer.getConnectors().length ?
+ webServer.getConnectors()[index].getLocalPort() : -1;
+ }
+
+ /**
* Set the min, max number of worker threads (simultaneous connections).
*/
public void setThreads(int min, int max) {