Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improved Javadocs. 

git-svn-id: svn+ssh://dev.eclipse.org/svnroot/rt/org.eclipse.jetty/jetty/trunk@3026 7e9141cc-0065-0410-87d8-b60c137991c4
This commit is contained in:
Simone Bordet 2011-04-20 15:41:21 +00:00
parent 6746c79e71
commit ed46fbf209
1 changed files with 20 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
jetty-continuation/src/main/java/org/eclipse/jetty/continuation/ContinuationFilter.java
View File

@ -1,7 +1,6 @@
package org.eclipse.jetty.continuation; package org.eclipse.jetty.continuation;
import java.io.IOException; import java.io.IOException;
import javax.servlet.Filter; import javax.servlet.Filter;
import javax.servlet.FilterChain; import javax.servlet.FilterChain;
import javax.servlet.FilterConfig; import javax.servlet.FilterConfig;
@ -13,16 +12,24 @@ import javax.servlet.ServletResponse;
/* ------------------------------------------------------------ */ /* ------------------------------------------------------------ */
/** ContinuationFilter /**
* <p> * <p>ContinuationFilter must be applied to servlet paths that make use of
* This filter may be applied to webapplication that use the asynchronous * the asynchronous features provided by {@link Continuation} APIs, but that
* features of the {@link Continuation} API, but that are deployed in container * are deployed in servlet containers that are neither Jetty (>= 7) nor a
* that is neither Jetty (>=6.1) nor a Servlet3.0 container. * compliant Servlet 3.0 container.</p>
* The following init parameters may be used to configure the filter (these are mostly for testing):<dl> * <p>The following init parameters may be used to configure the filter (these are mostly for testing):</p>
* <dl>
* <dt>debug</dt><dd>Boolean controlling debug output</dd> * <dt>debug</dt><dd>Boolean controlling debug output</dd>
* <dt>jetty6</dt><dd>Boolean to force support for jetty 6 continuations)</dd> * <dt>jetty6</dt><dd>Boolean to force use of Jetty 6 continuations</dd>
* <dt>faux</dt><dd>Boolean to force support for faux continuations</dd> * <dt>faux</dt><dd>Boolean to force use of faux continuations</dd>
* </dl> * </dl>
* <p>If the servlet container is not Jetty (either 6 or 7) nor a Servlet 3
* container, then "faux" continuations will be used.</p>
* <p>Faux continuations will just put the thread that called {@link Continuation#suspend()}
* in wait, and will notify that thread when {@link Continuation#resume()} or
* {@link Continuation#complete()} is called.</p>
* <p>Faux continuations are not threadless continuations (they are "faux" - fake - for this reason)
* and as such they will scale less than proper continuations.</p>
*/ */
public class ContinuationFilter implements Filter public class ContinuationFilter implements Filter
{ {
@ -38,12 +45,12 @@ public class ContinuationFilter implements Filter
{ {
boolean jetty_7_or_greater="org.eclipse.jetty.servlet".equals(filterConfig.getClass().getPackage().getName()); boolean jetty_7_or_greater="org.eclipse.jetty.servlet".equals(filterConfig.getClass().getPackage().getName());
_context = filterConfig.getServletContext(); _context = filterConfig.getServletContext();
String param=filterConfig.getInitParameter("debug"); String param=filterConfig.getInitParameter("debug");
_debug=param!=null&&Boolean.parseBoolean(param); _debug=param!=null&&Boolean.parseBoolean(param);
if (_debug) if (_debug)
__debug=true; __debug=true;
param=filterConfig.getInitParameter("jetty6"); param=filterConfig.getInitParameter("jetty6");
if (param==null) if (param==null)
param=filterConfig.getInitParameter("partial"); param=filterConfig.getInitParameter("partial");
@ -57,7 +64,7 @@ public class ContinuationFilter implements Filter
_faux=Boolean.parseBoolean(param); _faux=Boolean.parseBoolean(param);
else else
_faux=!(jetty_7_or_greater || _jetty6 || _context.getMajorVersion()>=3); _faux=!(jetty_7_or_greater || _jetty6 || _context.getMajorVersion()>=3);
_filtered=_faux||_jetty6; _filtered=_faux||_jetty6;
if (_debug) if (_debug)
_context.log("ContinuationFilter "+ _context.log("ContinuationFilter "+
@ -124,7 +131,7 @@ public class ContinuationFilter implements Filter
_context.log(string); _context.log(string);
} }
} }
private void debug(String string, Throwable th) private void debug(String string, Throwable th)
{ {
if (_debug) if (_debug)