in src/main/java/org/apache/sling/engine/impl/SlingRequestProcessorImpl.java [195:297]
public void doProcessRequest(final HttpServletRequest servletRequest,
final HttpServletResponse servletResponse,
final ResourceResolver resourceResolver) throws IOException {
final ServletResolver sr = this.servletResolver;
// check that we have all required services
if (resourceResolver == null || sr == null) {
// Dependencies are missing
// In this case we must not use the Sling error handling infrastructure but
// just return a 503 status response handled by the servlet container environment
final int status = HttpServletResponse.SC_SERVICE_UNAVAILABLE;
String errorMessage = "Required service missing (";
if ( resourceResolver == null ) {
errorMessage = errorMessage.concat("ResourceResolver");
if ( sr == null ) {
errorMessage = errorMessage.concat(", ");
}
}
if ( sr == null ) {
errorMessage = errorMessage.concat("ServletResolver");
}
log.debug("{}, cannot service requests, sending status {}", errorMessage, status);
servletResponse.sendError(status, errorMessage);
return;
}
// setting the Sling request and response
final RequestData requestData = new RequestData(this, servletRequest, servletResponse,
protectHeadersOnInclude, checkContentTypeOnInclude, this.disableCheckCompliantGetUserPrincipal);
final SlingHttpServletRequest request = requestData.getSlingRequest();
final SlingHttpServletResponse response = requestData.getSlingResponse();
try {
// initialize the request data - resolve resource and servlet
final Resource resource = requestData.initResource(resourceResolver);
requestData.initServlet(resource, sr);
final FilterHandle[] filters = filterManager.getFilters(FilterChainType.REQUEST);
final FilterChain processor = new RequestSlingFilterChain(this, filters);
request.getRequestProgressTracker().log("Applying ".concat(FilterChainType.REQUEST.name()).concat("filters"));
processor.doFilter(request, response);
} catch ( final SlingHttpServletResponseImpl.WriterAlreadyClosedException wace ) {
// this is an exception case, log as error
log.error("Writer has already been closed.", wace);
} catch (final ResourceNotFoundException rnfe) {
// send this exception as a 404 status
log.debug("service: Resource {} not found", rnfe.getResource());
handleError(HttpServletResponse.SC_NOT_FOUND, rnfe.getMessage(), request, response);
} catch (final SlingException se) {
// if we have request data and a non-null active servlet name
// we assume, that this is the name of the causing servlet
if (requestData.getActiveServletName() != null) {
request.setAttribute(ERROR_SERVLET_NAME,
requestData.getActiveServletName());
}
// send this exception as is (albeit unwrapping and wrapped
// exception.
Throwable t = se;
while ( t instanceof SlingException && t.getCause() != null ) {
t = t.getCause();
}
log.error("service: Uncaught SlingException ", t);
handleError(t, request, response);
} catch (final AccessControlException ace) {
// SLING-319 if anything goes wrong, send 403/FORBIDDEN
log.debug(
"service: Authenticated user {} does not have enough rights to executed requested action",
request.getRemoteUser());
handleError(HttpServletResponse.SC_FORBIDDEN, null, request,
response);
} catch (final IOException ioe) {
// forward IOException up the call chain to properly handle it
throw ioe;
} catch (final Throwable t) {
// we assume, that this is the name of the causing servlet
if (requestData.getActiveServletName() != null) {
request.setAttribute(ERROR_SERVLET_NAME,
requestData.getActiveServletName());
}
log.error("service: Uncaught Throwable", t);
handleError(t, request, response);
} finally {
// record the request for the web console and info provider
RequestInfoProviderImpl.recordRequest(request);
final RequestProcessorMBeanImpl localBean = this.mbean;
if (localBean != null) {
localBean.addRequestData(requestData);
}
}
}