Index: hbase-server/src/test/java/org/apache/hadoop/hbase/rest/TestRowResource.java =================================================================== --- hbase-server/src/test/java/org/apache/hadoop/hbase/rest/TestRowResource.java (revision 1540878) +++ hbase-server/src/test/java/org/apache/hadoop/hbase/rest/TestRowResource.java (working copy) @@ -52,6 +52,7 @@ import org.apache.hadoop.hbase.security.User; import org.apache.hadoop.hbase.test.MetricsAssertHelper; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.hadoop.http.HttpConfig; import org.apache.hadoop.security.UserGroupInformation; import org.junit.After; import org.junit.AfterClass; @@ -587,7 +588,7 @@ @Test public void testURLEncodedKey() throws IOException, JAXBException { - String urlKey = "http://example.com/foo"; + String urlKey = HttpConfig.getSchemePrefix() + "example.com/foo"; StringBuilder path = new StringBuilder(); path.append('/'); path.append(TABLE); Index: hbase-server/src/test/java/org/apache/hadoop/hbase/TestInfoServers.java =================================================================== --- hbase-server/src/test/java/org/apache/hadoop/hbase/TestInfoServers.java (revision 1540878) +++ hbase-server/src/test/java/org/apache/hadoop/hbase/TestInfoServers.java (working copy) @@ -28,6 +28,7 @@ import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.hadoop.http.HttpConfig; import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; @@ -67,11 +68,11 @@ // give the cluster time to start up new HTable(UTIL.getConfiguration(), TableName.META_TABLE_NAME).close(); int port = UTIL.getHBaseCluster().getMaster().getInfoServer().getPort(); - assertContainsContent(new URL("http://localhost:" + port + + assertContainsContent(new URL(HttpConfig.getSchemePrefix() + "localhost:" + port + "/index.html"), "master-status"); port = UTIL.getHBaseCluster().getRegionServerThreads().get(0).getRegionServer(). getInfoServer().getPort(); - assertContainsContent(new URL("http://localhost:" + port + + assertContainsContent(new URL(HttpConfig.getSchemePrefix() + "localhost:" + port + "/index.html"), "rs-status"); } @@ -87,11 +88,11 @@ // give the cluster time to start up new HTable(UTIL.getConfiguration(), TableName.META_TABLE_NAME).close(); int port = UTIL.getHBaseCluster().getMaster().getInfoServer().getPort(); - assertContainsContent(new URL("http://localhost:" + port + + assertContainsContent(new URL(HttpConfig.getSchemePrefix() + "localhost:" + port + "/master-status"), "meta"); port = UTIL.getHBaseCluster().getRegionServerThreads().get(0).getRegionServer(). getInfoServer().getPort(); - assertContainsContent(new URL("http://localhost:" + port + + assertContainsContent(new URL(HttpConfig.getSchemePrefix() + "localhost:" + port + "/rs-status"), "meta"); } @@ -104,10 +105,10 @@ new HTable(UTIL.getConfiguration(), tableName).close(); int port = UTIL.getHBaseCluster().getMaster().getInfoServer().getPort(); assertDoesNotContainContent( - new URL("http://localhost:" + port + "/table.jsp?name=" + sTableName + "&action=split&key="), - "Table action request accepted"); + new URL(HttpConfig.getSchemePrefix() + "localhost:" + port + "/table.jsp?name=" + + sTableName + "&action=split&key="), "Table action request accepted"); assertDoesNotContainContent( - new URL("http://localhost:" + port + "/table.jsp?name=" + sTableName), + new URL(HttpConfig.getSchemePrefix() + "localhost:" + port + "/table.jsp?name=" + sTableName), "Actions:"); } Index: hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/Client.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/Client.java (revision 1540878) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/rest/client/Client.java (working copy) @@ -42,6 +42,7 @@ import org.apache.commons.logging.LogFactory; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.classification.InterfaceStability; +import org.apache.hadoop.http.HttpConfig; /** * A wrapper around HttpClient which provides some useful function and @@ -155,7 +156,7 @@ cluster.lastHost = cluster.nodes.get(i); try { StringBuilder sb = new StringBuilder(); - sb.append("http://"); + sb.append(HttpConfig.getSchemePrefix()); sb.append(cluster.lastHost); sb.append(path); URI uri = new URI(sb.toString(), true); Index: hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RSStatusTmpl.jamon =================================================================== --- hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RSStatusTmpl.jamon (revision 1540878) +++ hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/regionserver/RSStatusTmpl.jamon (working copy) @@ -31,6 +31,7 @@ org.apache.hadoop.hbase.protobuf.ProtobufUtil; org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ServerInfo; org.apache.hadoop.hbase.protobuf.generated.ClusterStatusProtos.RegionLoad; +org.apache.hadoop.http.*; <%if format.equals("json") %> <& ../common/TaskMonitorTmpl; filter = filter; format = "json" &> @@ -149,7 +150,7 @@ <%else> <%java> String host = regionServer.getMasterAddressManager().getMasterAddress().getHostname() + ":" + masterInfoPort; - String url = "http://" + host + "/"; + String url = HttpConfig.getSchemePrefix() + host + "/"; <% host %> Index: hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon =================================================================== --- hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon (revision 1540878) +++ hbase-server/src/main/jamon/org/apache/hadoop/hbase/tmpl/master/MasterStatusTmpl.jamon (working copy) @@ -48,6 +48,7 @@ org.apache.hadoop.hbase.HBaseConfiguration; org.apache.hadoop.hbase.TableName; org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescription; +org.apache.hadoop.http.*; org.apache.hadoop.hbase.master.DeadServer; org.apache.hadoop.hbase.protobuf.ProtobufUtil; Index: hbase-server/src/main/resources/hbase-webapps/master/table.jsp =================================================================== --- hbase-server/src/main/resources/hbase-webapps/master/table.jsp (revision 1540878) +++ hbase-server/src/main/resources/hbase-webapps/master/table.jsp (working copy) @@ -21,6 +21,7 @@ import="static org.apache.commons.lang.StringEscapeUtils.escapeXml" import="java.util.HashMap" import="java.util.Map" + import="org.apache.hadoop.http.*" import="org.apache.hadoop.conf.Configuration" import="org.apache.hadoop.hbase.client.HTable" import="org.apache.hadoop.hbase.client.HBaseAdmin" @@ -200,7 +201,7 @@ HRegionInfo meta = HRegionInfo.FIRST_META_REGIONINFO; ServerName metaLocation = master.getCatalogTracker().waitForMeta(1); for (int i = 0; i < 1; i++) { - String url = "http://" + metaLocation.getHostname() + ":" + infoPort + "/"; + String url = HttpConfig.getSchemePrefix() + metaLocation.getHostname() + ":" + infoPort + "/"; %> <%= escapeXml(meta.getRegionNameAsString()) %> @@ -273,7 +274,7 @@ } // This port might be wrong if RS actually ended up using something else. urlRegionServer = - "http://" + addr.getHostname().toString() + ":" + infoPort + "/"; + HttpConfig.getSchemePrefix() + addr.getHostname().toString() + ":" + infoPort + "/"; Integer i = regDistribution.get(urlRegionServer); if (null == i) i = Integer.valueOf(0); regDistribution.put(urlRegionServer, i+1); Index: hbase-common/src/test/java/org/apache/hadoop/hbase/util/TestBytes.java =================================================================== --- hbase-common/src/test/java/org/apache/hadoop/hbase/util/TestBytes.java (revision 1540878) +++ hbase-common/src/test/java/org/apache/hadoop/hbase/util/TestBytes.java (working copy) @@ -30,6 +30,7 @@ import junit.framework.TestCase; import org.apache.hadoop.hbase.SmallTests; +import org.apache.hadoop.http.HttpConfig; import org.junit.Assert; import org.junit.experimental.categories.Category; @@ -70,9 +71,9 @@ public void testSplit2() throws Exception { // More split tests. - byte [] lowest = Bytes.toBytes("http://A"); - byte [] highest = Bytes.toBytes("http://z"); - byte [] middle = Bytes.toBytes("http://]"); + byte [] lowest = Bytes.toBytes(HttpConfig.getSchemePrefix() + "A"); + byte [] highest = Bytes.toBytes(HttpConfig.getSchemePrefix() + "z"); + byte [] middle = Bytes.toBytes(HttpConfig.getSchemePrefix() + "]"); byte [][] parts = Bytes.split(lowest, highest, 1); for (int i = 0; i < parts.length; i++) { System.out.println(Bytes.toString(parts[i]));