Mercurial Hosting > luan
comparison 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 |
comparison
equal
deleted
inserted
replaced
928:23a57aad34c0 | 929:3191abe890ef |
---|---|
155 } | 155 } |
156 else | 156 else |
157 handle(target, request, request, response); | 157 handle(target, request, request, response); |
158 } | 158 } |
159 | 159 |
160 /* ------------------------------------------------------------ */ | |
161 /* Handle a request from a connection. | |
162 * Called to handle a request on the connection when either the header has been received, | |
163 * or after the entire request has been received (for short requests of known length), or | |
164 * on the dispatch of an async request. | |
165 */ | |
166 public void handleAsync(AbstractHttpConnection connection) throws IOException, ServletException | |
167 { | |
168 final AsyncContinuation async = connection.getRequest().getAsyncContinuation(); | |
169 final AsyncContinuation.AsyncEventState state = async.getAsyncEventState(); | |
170 | |
171 final Request baseRequest=connection.getRequest(); | |
172 final String path=state.getPath(); | |
173 | |
174 if (path!=null) | |
175 { | |
176 // this is a dispatch with a path | |
177 final String contextPath=state.getServletContext().getContextPath(); | |
178 HttpURI uri = new HttpURI(URIUtil.addPaths(contextPath,path)); | |
179 baseRequest.setUri(uri); | |
180 baseRequest.setRequestURI(null); | |
181 baseRequest.setPathInfo(baseRequest.getRequestURI()); | |
182 if (uri.getQuery()!=null) | |
183 baseRequest.mergeQueryString(uri.getQuery()); //we have to assume dispatch path and query are UTF8 | |
184 } | |
185 | |
186 final String target=baseRequest.getPathInfo(); | |
187 final HttpServletRequest request=(HttpServletRequest)async.getRequest(); | |
188 final HttpServletResponse response=(HttpServletResponse)async.getResponse(); | |
189 | |
190 if (LOG.isDebugEnabled()) | |
191 { | |
192 LOG.debug("REQUEST "+target+" on "+connection); | |
193 handle(target, baseRequest, request, response); | |
194 LOG.debug("RESPONSE "+target+" "+connection.getResponse().getStatus()); | |
195 } | |
196 else | |
197 handle(target, baseRequest, request, response); | |
198 | |
199 } | |
200 | |
201 | |
202 public void join() throws InterruptedException | 160 public void join() throws InterruptedException |
203 { | 161 { |
204 threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); | 162 threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); |
205 } | 163 } |
206 | 164 |