You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hdfs-commits@hadoop.apache.org by um...@apache.org on 2012/06/02 21:41:34 UTC
svn commit: r1345563 - in
/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src:
main/java/org/apache/hadoop/hdfs/server/datanode/DatanodeJspHelper.java
test/java/org/apache/hadoop/hdfs/server/datanode/TestDatanodeJsp.java
Author: umamahesh
Date: Sat Jun 2 19:41:33 2012
New Revision: 1345563
URL: http://svn.apache.org/viewvc?rev=1345563&view=rev
Log:
HDFS-2025. Go Back to File View link is not working in tail.jsp. Contributed by Ashish and Sravan.
Modified:
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DatanodeJspHelper.java
hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDatanodeJsp.java
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DatanodeJspHelper.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DatanodeJspHelper.java?rev=1345563&r1=1345562&r2=1345563&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DatanodeJspHelper.java (original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DatanodeJspHelper.java Sat Jun 2 19:41:33 2012
@@ -21,6 +21,7 @@ import java.io.File;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
+import java.net.URL;
import java.net.URLEncoder;
import java.security.PrivilegedExceptionAction;
import java.text.SimpleDateFormat;
@@ -616,9 +617,12 @@ public class DatanodeJspHelper {
Configuration conf
) throws IOException,
InterruptedException {
- final String referrer = JspHelper.validateURL(req.getParameter("referrer"));
+ String referrer = null;
boolean noLink = false;
- if (referrer == null) {
+ try {
+ referrer = new URL(req.getParameter("referrer")).toString();
+ } catch (IOException e) {
+ referrer = null;
noLink = true;
}
Modified: hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDatanodeJsp.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDatanodeJsp.java?rev=1345563&r1=1345562&r2=1345563&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDatanodeJsp.java (original)
+++ hadoop/common/trunk/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestDatanodeJsp.java Sat Jun 2 19:41:33 2012
@@ -18,16 +18,20 @@
package org.apache.hadoop.hdfs.server.datanode;
import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.URL;
import java.net.URLEncoder;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.jsp.JspWriter;
+import org.apache.commons.lang.StringEscapeUtils;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.DFSTestUtil;
@@ -44,9 +48,10 @@ public class TestDatanodeJsp {
private static final String FILE_DATA = "foo bar baz biz buz";
private static final HdfsConfiguration CONF = new HdfsConfiguration();
+ private static String viewFilePage;
- private static void testViewingFile(MiniDFSCluster cluster, String filePath,
- boolean doTail) throws IOException {
+ private static void testViewingFile(MiniDFSCluster cluster, String filePath)
+ throws IOException {
FileSystem fs = cluster.getFileSystem();
Path testPath = new Path(filePath);
@@ -58,23 +63,46 @@ public class TestDatanodeJsp {
InetSocketAddress nnHttpAddress = cluster.getNameNode().getHttpAddress();
int dnInfoPort = cluster.getDataNodes().get(0).getInfoPort();
- String jspName = doTail ? "tail.jsp" : "browseDirectory.jsp";
- String fileParamName = doTail ? "filename" : "dir";
+ URL url = new URL("http://localhost:" + dnInfoPort + "/"
+ + "browseDirectory.jsp" + JspHelper.getUrlParam("dir",
+ URLEncoder.encode(testPath.toString(), "UTF-8"), true)
+ + JspHelper.getUrlParam("namenodeInfoPort", Integer
+ .toString(nnHttpAddress.getPort())) + JspHelper
+ .getUrlParam("nnaddr", "localhost:" + nnIpcAddress.getPort()));
- URL url = new URL("http://localhost:" + dnInfoPort + "/" + jspName +
- JspHelper.getUrlParam(fileParamName, URLEncoder.encode(testPath.toString(), "UTF-8"), true) +
- JspHelper.getUrlParam("namenodeInfoPort", Integer.toString(nnHttpAddress.getPort())) +
- JspHelper.getUrlParam("nnaddr", "localhost:" + nnIpcAddress.getPort()));
-
- String viewFilePage = DFSTestUtil.urlGet(url);
+ viewFilePage = StringEscapeUtils.unescapeHtml(DFSTestUtil.urlGet(url));
assertTrue("page should show preview of file contents, got: " + viewFilePage,
viewFilePage.contains(FILE_DATA));
- if (!doTail) {
- assertTrue("page should show link to download file", viewFilePage
- .contains("/streamFile" + ServletUtil.encodePath(testPath.toString()) +
- "?nnaddr=localhost:" + nnIpcAddress.getPort()));
+ assertTrue("page should show link to download file", viewFilePage
+ .contains("/streamFile" + ServletUtil.encodePath(filePath)
+ + "?nnaddr=localhost:" + nnIpcAddress.getPort()));
+
+ // check whether able to tail the file
+ String regex = "<a.+href=\"(.+?)\">Tail\\s*this\\s*file\\<\\/a\\>";
+ assertFileContents(regex, "Tail this File");
+
+ // check whether able to 'Go Back to File View' after tailing the file
+ regex = "<a.+href=\"(.+?)\">Go\\s*Back\\s*to\\s*File\\s*View\\<\\/a\\>";
+ assertFileContents(regex, "Go Back to File View");
+ }
+
+ private static void assertFileContents(String regex, String text)
+ throws IOException {
+ Pattern compile = Pattern.compile(regex);
+ Matcher matcher = compile.matcher(viewFilePage);
+ URL hyperlink = null;
+ if (matcher.find()) {
+ // got hyperlink for Tail this file
+ hyperlink = new URL(matcher.group(1));
+ viewFilePage = StringEscapeUtils.unescapeHtml(DFSTestUtil
+ .urlGet(hyperlink));
+ assertTrue("page should show preview of file contents", viewFilePage
+ .contains(FILE_DATA));
+ } else {
+ fail(text + " hyperlink should be there in the page content : "
+ + viewFilePage);
}
}
@@ -97,8 +125,8 @@ public class TestDatanodeJsp {
"/foo\">bar/foo\">bar"
};
for (String p : paths) {
- testViewingFile(cluster, p, false);
- testViewingFile(cluster, p, true);
+ testViewingFile(cluster, p);
+ testViewingFile(cluster, p);
}
} finally {
if (cluster != null) {