Mercurial Hosting > luan
diff src/org/eclipse/jetty/server/Server.java @ 929:3191abe890ef
remove isInitial()
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Sun, 09 Oct 2016 19:13:46 -0600 |
parents | 17f4fe8271de |
children | 53b3f7d9714c |
line wrap: on
line diff
--- a/src/org/eclipse/jetty/server/Server.java Sun Oct 09 18:54:32 2016 -0600 +++ b/src/org/eclipse/jetty/server/Server.java Sun Oct 09 19:13:46 2016 -0600 @@ -157,48 +157,6 @@ handle(target, request, request, response); } - /* ------------------------------------------------------------ */ - /* Handle a request from a connection. - * Called to handle a request on the connection when either the header has been received, - * or after the entire request has been received (for short requests of known length), or - * on the dispatch of an async request. - */ - public void handleAsync(AbstractHttpConnection connection) throws IOException, ServletException - { - final AsyncContinuation async = connection.getRequest().getAsyncContinuation(); - final AsyncContinuation.AsyncEventState state = async.getAsyncEventState(); - - final Request baseRequest=connection.getRequest(); - final String path=state.getPath(); - - if (path!=null) - { - // this is a dispatch with a path - final String contextPath=state.getServletContext().getContextPath(); - HttpURI uri = new HttpURI(URIUtil.addPaths(contextPath,path)); - baseRequest.setUri(uri); - baseRequest.setRequestURI(null); - baseRequest.setPathInfo(baseRequest.getRequestURI()); - if (uri.getQuery()!=null) - baseRequest.mergeQueryString(uri.getQuery()); //we have to assume dispatch path and query are UTF8 - } - - final String target=baseRequest.getPathInfo(); - final HttpServletRequest request=(HttpServletRequest)async.getRequest(); - final HttpServletResponse response=(HttpServletResponse)async.getResponse(); - - if (LOG.isDebugEnabled()) - { - LOG.debug("REQUEST "+target+" on "+connection); - handle(target, baseRequest, request, response); - LOG.debug("RESPONSE "+target+" "+connection.getResponse().getStatus()); - } - else - handle(target, baseRequest, request, response); - - } - - public void join() throws InterruptedException { threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);