fixed merge

This commit is contained in:
Greg Wilkins 2013-06-11 10:52:15 +10:00
parent d2794584e1
commit 3de2ba33f1
5 changed files with 6 additions and 13 deletions

View File

@ -34,7 +34,7 @@ import javax.servlet.ServletResponseWrapper;
/* ------------------------------------------------------------ */ /* ------------------------------------------------------------ */
/** /**
* This implementation of Continuation is used by {@link ContinuationSupport} * This implementation of Continuation is used by {@link ContinuationSupport}
* when it detects that the application has been deployed in a non-jetty Servlet 3 * when it detects that the application has been deployed in a Servlet 3
* server. * server.
*/ */
public class Servlet3Continuation implements Continuation public class Servlet3Continuation implements Continuation

View File

@ -355,7 +355,7 @@ public class HttpChannel<T> implements HttpParser.RequestHandler<T>, Runnable
_transport.completed(); _transport.completed();
} }
LOG.debug("{} handle exit, result {}", this, next); LOG.debug("{} handle exit, result {}", this, action);
return action!=Action.WAIT; return action!=Action.WAIT;
} }

View File

@ -163,9 +163,7 @@ public class HttpChannelState
{ {
synchronized (this) synchronized (this)
{ {
return _state+ return String.format("s=%s i=%b a=%s",_state,_initial,_async);
(_initial?",initial ":" ")+
_async;
} }
} }
@ -343,7 +341,7 @@ public class HttpChannelState
synchronized (this) synchronized (this)
{ {
if (_async!=Async.STARTED && _async!=Async.EXPIRING) if (_async!=Async.STARTED && _async!=Async.EXPIRING)
throw new IllegalStateException(this.getStatusString()); throw new IllegalStateException("AsyncContext#dispath "+this.getStatusString());
_async=Async.DISPATCH; _async=Async.DISPATCH;
_event.setDispatchTarget(context,path); _event.setDispatchTarget(context,path);
@ -552,7 +550,8 @@ public class HttpChannelState
{ {
synchronized (this) synchronized (this)
{ {
return _async==Async.STARTED; // Either we are started, or we are still dispatched and async has been completed or dispatched
return _async==Async.STARTED || _async!=null && _state==State.DISPATCHED;
} }
} }

View File

@ -77,7 +77,6 @@ public abstract class ContinuationBase
protected void doSuspendResume() throws Exception protected void doSuspendResume() throws Exception
{ {
String response=process("suspend=200&resume=0",null); String response=process("suspend=200&resume=0",null);
System.err.println(response);
assertContains("RESUMED",response); assertContains("RESUMED",response);
assertNotContains("history: onTimeout",response); assertNotContains("history: onTimeout",response);
assertContains("history: onComplete",response); assertContains("history: onComplete",response);
@ -503,7 +502,6 @@ public abstract class ContinuationBase
public void onTimeout(Continuation continuation) public void onTimeout(Continuation continuation)
{ {
((HttpServletResponse)continuation.getServletResponse()).addHeader("history","onTimeout"); ((HttpServletResponse)continuation.getServletResponse()).addHeader("history","onTimeout");
continuation.resume();
} }
}; };

View File

@ -119,10 +119,6 @@ public abstract class AbstractProxySerializationTest
//stop the context to be sure the sesssion will be passivated //stop the context to be sure the sesssion will be passivated
context.stop(); context.stop();
//after a stop some of the volatile info is lost, so reinstate it
context.setClassLoader(loader);
context.addServlet("TestServlet", servletMapping);
//restart the context //restart the context
context.start(); context.start();