浏览代码

HADOOP-6496. HttpServer sends wrong content-type for CSS files. Backported by Ivan Mitic.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-1@1399127 13f79535-47bb-0310-9956-ffa450edef68
Suresh Srinivas 12 年之前
父节点
当前提交
5b9d5fb725
共有 3 个文件被更改,包括 55 次插入5 次删除
  1. 3 0
      CHANGES.txt
  2. 27 5
      src/core/org/apache/hadoop/http/HttpServer.java
  3. 25 0
      src/test/org/apache/hadoop/http/TestHttpServer.java

+ 3 - 0
CHANGES.txt

@@ -254,6 +254,9 @@ Release 1.2.0 - unreleased
     HADOOP-8882. Uppercase namenode host name causes fsck to fail when 
     HADOOP-8882. Uppercase namenode host name causes fsck to fail when 
     useKsslAuth is on. (Arpit Gupta via suresh)
     useKsslAuth is on. (Arpit Gupta via suresh)
 
 
+    HADOOP-6496. HttpServer sends wrong content-type for CSS files.
+    (Todd Lipcon, Backport by Ivan Mitic via suresh).
+
 Release 1.1.0 - unreleased
 Release 1.1.0 - unreleased
 
 
   INCOMPATIBLE CHANGES
   INCOMPATIBLE CHANGES

+ 27 - 5
src/core/org/apache/hadoop/http/HttpServer.java

@@ -51,9 +51,12 @@ import org.apache.hadoop.security.Krb5AndCertsSslSocketConnector.MODE;
 import org.apache.hadoop.security.UserGroupInformation;
 import org.apache.hadoop.security.UserGroupInformation;
 import org.apache.hadoop.security.authorize.AccessControlList;
 import org.apache.hadoop.security.authorize.AccessControlList;
 import org.apache.hadoop.util.ReflectionUtils;
 import org.apache.hadoop.util.ReflectionUtils;
+import org.mortbay.io.Buffer;
 import org.mortbay.jetty.Connector;
 import org.mortbay.jetty.Connector;
 import org.mortbay.jetty.Handler;
 import org.mortbay.jetty.Handler;
+import org.mortbay.jetty.MimeTypes;
 import org.mortbay.jetty.Server;
 import org.mortbay.jetty.Server;
+import org.mortbay.jetty.handler.ContextHandler;
 import org.mortbay.jetty.handler.ContextHandlerCollection;
 import org.mortbay.jetty.handler.ContextHandlerCollection;
 import org.mortbay.jetty.nio.SelectChannelConnector;
 import org.mortbay.jetty.nio.SelectChannelConnector;
 import org.mortbay.jetty.security.SslSocketConnector;
 import org.mortbay.jetty.security.SslSocketConnector;
@@ -763,6 +766,7 @@ public class HttpServer implements FilterContainer {
    * all of the servlets resistant to cross-site scripting attacks.
    * all of the servlets resistant to cross-site scripting attacks.
    */
    */
   public static class QuotingInputFilter implements Filter {
   public static class QuotingInputFilter implements Filter {
+    private FilterConfig config;
 
 
     public static class RequestQuoter extends HttpServletRequestWrapper {
     public static class RequestQuoter extends HttpServletRequestWrapper {
       private final HttpServletRequest rawRequest;
       private final HttpServletRequest rawRequest;
@@ -850,6 +854,7 @@ public class HttpServer implements FilterContainer {
 
 
     @Override
     @Override
     public void init(FilterConfig config) throws ServletException {
     public void init(FilterConfig config) throws ServletException {
+      this.config = config;
     }
     }
 
 
     @Override
     @Override
@@ -863,12 +868,29 @@ public class HttpServer implements FilterContainer {
                          ) throws IOException, ServletException {
                          ) throws IOException, ServletException {
       HttpServletRequestWrapper quoted = 
       HttpServletRequestWrapper quoted = 
         new RequestQuoter((HttpServletRequest) request);
         new RequestQuoter((HttpServletRequest) request);
-      final HttpServletResponse httpResponse = (HttpServletResponse) response;
-      // set the default to UTF-8 so that we don't need to worry about IE7
-      // choosing to interpret the special characters as UTF-7
-      httpResponse.setContentType("text/html;charset=utf-8");
-      chain.doFilter(quoted, response);
+      HttpServletResponse httpResponse = (HttpServletResponse) response;
+
+      String mime = inferMimeType(request);
+      if (mime == null || mime.equals("text/html")) {
+        // no extension or HTML with unspecified encoding, we want to
+        // force HTML with utf-8 encoding
+        // This is to avoid the following security issue:
+        // http://openmya.hacker.jp/hasegawa/security/utf7cs.html
+        httpResponse.setContentType("text/html; charset=utf-8");
+      }
+      chain.doFilter(quoted, httpResponse);
     }
     }
 
 
+    /**
+     * Infer the mime type for the response based on the extension of the request
+     * URI. Returns null if unknown.
+     */
+    private String inferMimeType(ServletRequest request) {
+      String path = ((HttpServletRequest)request).getRequestURI();
+      ContextHandler.SContext sContext = (ContextHandler.SContext)config.getServletContext();
+      MimeTypes mimes = sContext.getContextHandler().getMimeTypes();
+      Buffer mimeBuffer = mimes.getMimeByExtension(path);
+      return (mimeBuffer == null) ? null : mimeBuffer.toString();
+    }
   }
   }
 }
 }

+ 25 - 0
src/test/org/apache/hadoop/http/TestHttpServer.java

@@ -23,6 +23,7 @@ import java.io.File;
 import java.io.IOException;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStream;
 import java.io.PrintStream;
 import java.io.PrintStream;
+import java.net.URLConnection;
 import java.net.HttpURLConnection;
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.net.URL;
 import java.util.Arrays;
 import java.util.Arrays;
@@ -162,6 +163,30 @@ public class TestHttpServer {
                  readOutput(new URL(baseUrl, "/echomap?a=b&c<=d&a=>")));
                  readOutput(new URL(baseUrl, "/echomap?a=b&c<=d&a=>")));
   }
   }
 
 
+  @Test public void testContentTypes() throws Exception {
+    // Static CSS files should have text/css
+    URL cssUrl = new URL(baseUrl, "/static/hadoop.css");
+    HttpURLConnection conn = (HttpURLConnection)cssUrl.openConnection();
+    conn.connect();
+    assertEquals(200, conn.getResponseCode());
+    assertEquals("text/css", conn.getContentType());
+
+    // Servlets should have text/html with proper encoding
+    URL servletUrl = new URL(baseUrl, "/echo?a=b");
+    conn = (HttpURLConnection)servletUrl.openConnection();
+    conn.connect();
+    assertEquals(200, conn.getResponseCode());
+    assertEquals("text/html; charset=utf-8", conn.getContentType());
+
+    // We should ignore parameters for mime types - ie a parameter
+    // ending in .css should not change mime type
+    servletUrl = new URL(baseUrl, "/echo?a=b.css");
+    conn = (HttpURLConnection)servletUrl.openConnection();
+    conn.connect();
+    assertEquals(200, conn.getResponseCode());
+    assertEquals("text/html; charset=utf-8", conn.getContentType());
+  }
+
   /**
   /**
    * Dummy filter that mimics as an authentication filter. Obtains user identity
    * Dummy filter that mimics as an authentication filter. Obtains user identity
    * from the request parameter user.name. Wraps around the request so that
    * from the request parameter user.name. Wraps around the request so that