2 // ========================================================================
3 // Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd.
4 // ------------------------------------------------------------------------
5 // All rights reserved. This program and the accompanying materials
6 // are made available under the terms of the Eclipse Public License v1.0
7 // and Apache License v2.0 which accompanies this distribution.
9 // The Eclipse Public License is available at
10 // http://www.eclipse.org/legal/epl-v10.html
12 // The Apache License v2.0 is available at
13 // http://www.opensource.org/licenses/apache2.0.php
15 // You may elect to redistribute this code under either of these licenses.
16 // ========================================================================
19 package org.eclipse.jetty.server;
21 import java.io.IOException;
23 import javax.servlet.AsyncContext;
24 import javax.servlet.AsyncEvent;
25 import javax.servlet.AsyncListener;
26 import javax.servlet.ServletContext;
27 import javax.servlet.ServletException;
28 import javax.servlet.ServletRequest;
29 import javax.servlet.ServletResponse;
31 import org.eclipse.jetty.server.handler.ContextHandler;
34 public class AsyncContextState implements AsyncContext
36 volatile HttpChannelState _state;
38 public AsyncContextState(HttpChannelState state)
43 HttpChannelState state()
45 HttpChannelState state=_state;
47 throw new IllegalStateException("AsyncContext completed");
52 public void addListener(final AsyncListener listener, final ServletRequest request, final ServletResponse response)
54 AsyncListener wrap = new AsyncListener()
57 public void onTimeout(AsyncEvent event) throws IOException
59 listener.onTimeout(new AsyncEvent(event.getAsyncContext(),request,response,event.getThrowable()));
63 public void onStartAsync(AsyncEvent event) throws IOException
65 listener.onStartAsync(new AsyncEvent(event.getAsyncContext(),request,response,event.getThrowable()));
69 public void onError(AsyncEvent event) throws IOException
71 listener.onComplete(new AsyncEvent(event.getAsyncContext(),request,response,event.getThrowable()));
75 public void onComplete(AsyncEvent event) throws IOException
77 listener.onComplete(new AsyncEvent(event.getAsyncContext(),request,response,event.getThrowable()));
80 state().addListener(wrap);
84 public void addListener(AsyncListener listener)
86 state().addListener(listener);
90 public void complete()
96 public <T extends AsyncListener> T createListener(Class<T> clazz) throws ServletException
98 ContextHandler contextHandler = state().getContextHandler();
99 if (contextHandler != null)
100 return contextHandler.getServletContext().createListener(clazz);
103 return clazz.newInstance();
107 throw new ServletException(e);
112 public void dispatch()
114 state().dispatch(null,null);
118 public void dispatch(String path)
120 state().dispatch(null,path);
124 public void dispatch(ServletContext context, String path)
126 state().dispatch(context,path);
130 public ServletRequest getRequest()
132 return state().getAsyncContextEvent().getSuppliedRequest();
136 public ServletResponse getResponse()
138 return state().getAsyncContextEvent().getSuppliedResponse();
142 public long getTimeout()
144 return state().getTimeout();
148 public boolean hasOriginalRequestAndResponse()
150 HttpChannel<?> channel=state().getHttpChannel();
151 return channel.getRequest()==getRequest() && channel.getResponse()==getResponse();
155 public void setTimeout(long arg0)
157 state().setTimeout(arg0);
161 public void start(final Runnable task)
163 state().getHttpChannel().execute(new Runnable()
168 state().getAsyncContextEvent().getContext().getContextHandler().handle(task);
178 public HttpChannelState getHttpChannelState()