Author: markt Date: Thu Jun 12 15:10:46 2014 New Revision: 1602198 URL: http://svn.apache.org/r1602198 Log: Fix https://issues.apache.org/bugzilla/show_bug.cgi?id=56518 Do not attempt an NIO write if a thread has been interrupted as it can lead to a connection limit leak
Modified: tomcat/trunk/java/org/apache/catalina/connector/CoyoteAdapter.java tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java tomcat/trunk/java/org/apache/coyote/Adapter.java tomcat/trunk/java/org/apache/coyote/LocalStrings.properties tomcat/trunk/java/org/apache/coyote/Processor.java tomcat/trunk/java/org/apache/coyote/ajp/AbstractAjpProcessor.java tomcat/trunk/java/org/apache/coyote/http11/AbstractHttp11Processor.java tomcat/trunk/java/org/apache/coyote/http11/Http11AprProcessor.java tomcat/trunk/java/org/apache/coyote/http11/Http11Nio2Processor.java tomcat/trunk/java/org/apache/coyote/http11/Http11NioProcessor.java tomcat/trunk/java/org/apache/coyote/http11/upgrade/AbstractProcessor.java tomcat/trunk/java/org/apache/coyote/spdy/SpdyProcessor.java tomcat/trunk/java/org/apache/tomcat/util/net/NioChannel.java tomcat/trunk/java/org/apache/tomcat/util/net/SecureNioChannel.java tomcat/trunk/java/org/apache/tomcat/util/net/SocketStatus.java tomcat/trunk/java/org/apache/tomcat/util/net/res/LocalStrings.properties tomcat/trunk/webapps/docs/changelog.xml Modified: tomcat/trunk/java/org/apache/catalina/connector/CoyoteAdapter.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/connector/CoyoteAdapter.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/connector/CoyoteAdapter.java (original) +++ tomcat/trunk/java/org/apache/catalina/connector/CoyoteAdapter.java Thu Jun 12 15:10:46 2014 @@ -599,6 +599,35 @@ public class CoyoteAdapter implements Ad } + + @Override + public void errorDispatch(org.apache.coyote.Request req, + org.apache.coyote.Response res) { + Request request = (Request) req.getNote(ADAPTER_NOTES); + Response response = (Response) res.getNote(ADAPTER_NOTES); + + if (request != null && request.getMappingData().context != null) { + request.getMappingData().context.logAccess( + request, response, + System.currentTimeMillis() - req.getStartTime(), + false); + } else { + log(req, res, System.currentTimeMillis() - req.getStartTime()); + } + + if (request != null) { + request.recycle(); + } + + if (response != null) { + response.recycle(); + } + + res.recycle(); + res.recycle(); + } + + @Override public void log(org.apache.coyote.Request req, org.apache.coyote.Response res, long time) { Modified: tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java (original) +++ tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java Thu Jun 12 15:10:46 2014 @@ -74,8 +74,20 @@ public abstract class AbstractProcessor< * Update the current error state to the new error state if the new error * state is more severe than the current error state. */ - protected void setErrorState(ErrorState errorState) { + protected void setErrorState(ErrorState errorState, Throwable t) { + boolean blockIo = this.errorState.isIoAllowed() && !errorState.isIoAllowed(); this.errorState = this.errorState.getMostSevere(errorState); + if (blockIo && !ContainerThreadMarker.isContainerThread()) { + // The error occurred on a non-container thread which means not all + // of the necessary clean-up will have been completed. Dispatch to + // a container thread to do the clean-up. Need to do it this way to + // ensure that all the necessary clean-up is performed. + if (response.getStatus() < 400) { + response.setStatus(500); + } + getLog().info(sm.getString("abstractProcessor.nonContainerThreadError"), t); + getEndpoint().processSocket(socketWrapper, SocketStatus.CLOSE_NOW, true); + } } @@ -162,6 +174,11 @@ public abstract class AbstractProcessor< } @Override + public void errorDispatch() { + getAdapter().errorDispatch(request, response); + } + + @Override public abstract boolean isComet(); @Override Modified: tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java (original) +++ tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java Thu Jun 12 15:10:46 2014 @@ -624,7 +624,10 @@ public abstract class AbstractProtocol<S SocketState state = SocketState.CLOSED; Iterator<DispatchType> dispatches = null; do { - if (dispatches != null) { + if (status == SocketStatus.CLOSE_NOW) { + processor.errorDispatch(); + state = SocketState.CLOSED; + } else if (dispatches != null) { // Associate the processor with the connection as // these calls may result in a nested call to process() connections.put(socket, processor); Modified: tomcat/trunk/java/org/apache/coyote/Adapter.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/Adapter.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/Adapter.java (original) +++ tomcat/trunk/java/org/apache/coyote/Adapter.java Thu Jun 12 15:10:46 2014 @@ -51,6 +51,8 @@ public interface Adapter { public boolean asyncDispatch(Request req,Response res, SocketStatus status) throws Exception; + public void errorDispatch(Request request, Response response); + public void log(Request req, Response res, long time); /** Modified: tomcat/trunk/java/org/apache/coyote/LocalStrings.properties URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/LocalStrings.properties?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/LocalStrings.properties (original) +++ tomcat/trunk/java/org/apache/coyote/LocalStrings.properties Thu Jun 12 15:10:46 2014 @@ -16,6 +16,8 @@ abstractConnectionHandler.error=Error re abstractConnectionHandler.ioexception.debug=IOExceptions are normal, ignored abstractConnectionHandler.socketexception.debug=SocketExceptions are normal, ignored +abstractProcessor.nonContainerThreadError=An error occurred in processing while on a non-container thread. The connection will be closed immediately + abstractProtocol.mbeanDeregistrationFailed=Failed to deregister MBean named [{0}] from MBean server [{1}] abstractProtocolHandler.getAttribute=Get attribute [{0}] with value [{1}] Modified: tomcat/trunk/java/org/apache/coyote/Processor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/Processor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/Processor.java (original) +++ tomcat/trunk/java/org/apache/coyote/Processor.java Thu Jun 12 15:10:46 2014 @@ -43,6 +43,8 @@ public interface Processor<S> { HttpUpgradeHandler getHttpUpgradeHandler(); SocketState upgradeDispatch(SocketStatus status) throws IOException; + void errorDispatch(); + boolean isComet(); boolean isAsync(); boolean isUpgrade(); Modified: tomcat/trunk/java/org/apache/coyote/ajp/AbstractAjpProcessor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/ajp/AbstractAjpProcessor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/ajp/AbstractAjpProcessor.java (original) +++ tomcat/trunk/java/org/apache/coyote/ajp/AbstractAjpProcessor.java Thu Jun 12 15:10:46 2014 @@ -359,7 +359,7 @@ public abstract class AbstractAjpProcess try { finish(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -371,13 +371,13 @@ public abstract class AbstractAjpProcess try { prepareResponse(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } try { flush(false); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -391,7 +391,7 @@ public abstract class AbstractAjpProcess try { prepareResponse(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); return; } } @@ -399,7 +399,7 @@ public abstract class AbstractAjpProcess try { flush(true); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -410,7 +410,7 @@ public abstract class AbstractAjpProcess case DISABLE_SWALLOW_INPUT: { // TODO: Do not swallow request input but // make sure we are closing the connection - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); break; } case RESET: { @@ -642,7 +642,7 @@ public abstract class AbstractAjpProcess case CLOSE_NOW: { // Prevent further writes to the response swallowResponse = true; - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); break; } } @@ -690,14 +690,14 @@ public abstract class AbstractAjpProcess try { rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); if(!getAdapter().asyncDispatch(request, response, status)) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } resetTimeouts(); } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); getLog().error(sm.getString("http11processor.request.process"), t); } @@ -766,7 +766,7 @@ public abstract class AbstractAjpProcess try { output(pongMessageArray, 0, pongMessageArray.length, true); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } recycle(false); continue; @@ -776,20 +776,20 @@ public abstract class AbstractAjpProcess if (getLog().isDebugEnabled()) { getLog().debug("Unexpected message: " + type); } - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); break; } keptAlive = true; request.setStartTime(System.currentTimeMillis()); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); break; } catch (Throwable t) { ExceptionUtils.handleThrowable(t); getLog().debug(sm.getString("ajpprocessor.header.error"), t); // 400 - Bad Request response.setStatus(400); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, t); getAdapter().log(request, response, 0); } @@ -803,7 +803,7 @@ public abstract class AbstractAjpProcess getLog().debug(sm.getString("ajpprocessor.request.prepare"), t); // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, t); getAdapter().log(request, response, 0); } } @@ -811,7 +811,7 @@ public abstract class AbstractAjpProcess if (!getErrorState().isError() && !cping && endpoint.isPaused()) { // 503 - Service unavailable response.setStatus(503); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); getAdapter().log(request, response, 0); } cping = false; @@ -822,13 +822,13 @@ public abstract class AbstractAjpProcess rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); getAdapter().service(request, response); } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); getLog().error(sm.getString("ajpprocessor.request.process"), t); // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, t); getAdapter().log(request, response, 0); } } @@ -843,7 +843,7 @@ public abstract class AbstractAjpProcess finish(); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); } } @@ -1191,7 +1191,7 @@ public abstract class AbstractAjpProcess long cl = vMB.getLong(); if (contentLengthSet) { response.setStatus(HttpServletResponse.SC_BAD_REQUEST); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); } else { contentLengthSet = true; // Set the content-length header for the request @@ -1306,7 +1306,7 @@ public abstract class AbstractAjpProcess secret = true; if (!tmpMB.equals(requiredSecret)) { response.setStatus(403); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); } } break; @@ -1322,7 +1322,7 @@ public abstract class AbstractAjpProcess // Check if secret was submitted if required if ((requiredSecret != null) && !secret) { response.setStatus(403); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); } // Check for a full URI (including protocol://host:port/) @@ -1373,7 +1373,7 @@ public abstract class AbstractAjpProcess request.serverName().duplicate(request.localName()); } catch (IOException e) { response.setStatus(400); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, e); } return; } @@ -1423,7 +1423,7 @@ public abstract class AbstractAjpProcess // Invalid character // 400 - Bad request response.setStatus(400); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); break; } port = port + (charValue * mult); @@ -1542,7 +1542,7 @@ public abstract class AbstractAjpProcess try { prepareResponse(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); return; } } @@ -1748,7 +1748,7 @@ public abstract class AbstractAjpProcess try { prepareResponse(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } } Modified: tomcat/trunk/java/org/apache/coyote/http11/AbstractHttp11Processor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/AbstractHttp11Processor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/http11/AbstractHttp11Processor.java (original) +++ tomcat/trunk/java/org/apache/coyote/http11/AbstractHttp11Processor.java Thu Jun 12 15:10:46 2014 @@ -698,7 +698,7 @@ public abstract class AbstractHttp11Proc // Unsupported transfer encoding // 501 - Unimplemented response.setStatus(501); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); if (getLog().isDebugEnabled()) { getLog().debug(sm.getString("http11processor.request.prepare") + " Unsupported transfer encoding [" + encodingName + "]"); @@ -722,7 +722,7 @@ public abstract class AbstractHttp11Proc try { getOutputBuffer().endRequest(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -737,7 +737,7 @@ public abstract class AbstractHttp11Proc prepareResponse(); getOutputBuffer().commit(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -753,7 +753,7 @@ public abstract class AbstractHttp11Proc try { getOutputBuffer().sendAck(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -761,7 +761,7 @@ public abstract class AbstractHttp11Proc try { getOutputBuffer().flush(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); response.setErrorException(e); } break; @@ -773,7 +773,7 @@ public abstract class AbstractHttp11Proc case DISABLE_SWALLOW_INPUT: { // Do not swallow request input and make sure we are closing the // connection - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); getInputBuffer().setSwallowInput(false); break; } @@ -875,7 +875,7 @@ public abstract class AbstractHttp11Proc isReady.set(getOutputBuffer().isReady()); } catch (IOException e) { getLog().debug("isReady() failed", e); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } break; } @@ -903,7 +903,7 @@ public abstract class AbstractHttp11Proc case CLOSE_NOW: { // Block further output getOutputBuffer().finished = true; - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); break; } default: { @@ -997,7 +997,7 @@ public abstract class AbstractHttp11Proc if (endpoint.isPaused()) { // 503 - Service unavailable response.setStatus(503); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); } else { // Make sure that connectors that are non-blocking during // header processing (NIO) only set the start time the first @@ -1025,7 +1025,7 @@ public abstract class AbstractHttp11Proc getLog().debug( sm.getString("http11processor.header.parse"), e); } - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); break; } catch (Throwable t) { ExceptionUtils.handleThrowable(t); @@ -1047,7 +1047,7 @@ public abstract class AbstractHttp11Proc } // 400 - Bad Request response.setStatus(400); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, t); getAdapter().log(request, response, 0); } @@ -1064,7 +1064,7 @@ public abstract class AbstractHttp11Proc } // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, t); getAdapter().log(request, response, 0); } } @@ -1090,20 +1090,20 @@ public abstract class AbstractHttp11Proc response.getErrorException() != null || (!isAsync() && statusDropsConnection(response.getStatus())))) { - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); } setCometTimeouts(socketWrapper); } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (HeadersTooLargeException e) { // The response should not have been committed but check it // anyway to be safe if (response.isCommitted()) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } else { response.reset(); response.setStatus(500); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, e); response.setHeader("Connection", "close"); // TODO: Remove } } catch (Throwable t) { @@ -1112,7 +1112,7 @@ public abstract class AbstractHttp11Proc "http11processor.request.process"), t); // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, t); getAdapter().log(request, response, 0); } } @@ -1230,7 +1230,7 @@ public abstract class AbstractHttp11Proc http11 = false; // Send 505; Unsupported HTTP version response.setStatus(505); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); if (getLog().isDebugEnabled()) { getLog().debug(sm.getString("http11processor.request.prepare")+ " Unsupported HTTP version \""+protocolMB+"\""); @@ -1268,7 +1268,7 @@ public abstract class AbstractHttp11Proc expectation = true; } else { response.setStatus(HttpServletResponse.SC_EXPECTATION_FAILED); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); } } @@ -1362,7 +1362,7 @@ public abstract class AbstractHttp11Proc if (http11 && (valueMB == null)) { // 400 - Bad request response.setStatus(400); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); if (getLog().isDebugEnabled()) { getLog().debug(sm.getString("http11processor.request.prepare")+ " host header missing"); @@ -1623,7 +1623,7 @@ public abstract class AbstractHttp11Proc // Invalid character // 400 - Bad request response.setStatus(400); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); break; } port = port + (charValue * mult); @@ -1675,14 +1675,14 @@ public abstract class AbstractHttp11Proc try { rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); if (!getAdapter().asyncDispatch(request, response, status)) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } resetTimeouts(); } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); getLog().error(sm.getString("http11processor.request.process"), t); } @@ -1752,14 +1752,14 @@ public abstract class AbstractHttp11Proc try { getInputBuffer().endRequest(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); // 500 - Internal Server Error // Can't add a 500 to the access log since that has already been // written in the Adapter.service method. response.setStatus(500); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); getLog().error(sm.getString("http11processor.request.finish"), t); } } @@ -1767,10 +1767,10 @@ public abstract class AbstractHttp11Proc try { getOutputBuffer().endRequest(); } catch (IOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); getLog().error(sm.getString("http11processor.response.finish"), t); } } Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11AprProcessor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11AprProcessor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/http11/Http11AprProcessor.java (original) +++ tomcat/trunk/java/org/apache/coyote/http11/Http11AprProcessor.java Thu Jun 12 15:10:46 2014 @@ -113,15 +113,15 @@ public class Http11AprProcessor extends try { rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); if (!getAdapter().event(request, response, status)) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); getAdapter().log(request, response, 0); log.error(sm.getString("http11processor.request.process"), t); } @@ -178,7 +178,7 @@ public class Http11AprProcessor extends if (endpoint.isPaused()) { // 503 - Service unavailable response.setStatus(503); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); getAdapter().log(request, response, 0); } else { return true; @@ -215,7 +215,7 @@ public class Http11AprProcessor extends log.debug(sm.getString( "http11processor.sendfile.error")); } - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } else { // The sendfile Poller will add the socket to the main // Poller once sendfile processing is complete Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11Nio2Processor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11Nio2Processor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/http11/Http11Nio2Processor.java (original) +++ tomcat/trunk/java/org/apache/coyote/http11/Http11Nio2Processor.java Thu Jun 12 15:10:46 2014 @@ -94,7 +94,7 @@ public class Http11Nio2Processor extends try { rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); if (!getAdapter().event(request, response, status)) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } if (!getErrorState().isError()) { if (socketWrapper != null) { @@ -117,12 +117,12 @@ public class Http11Nio2Processor extends } } } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); getAdapter().log(request, response, 0); log.error(sm.getString("http11processor.request.process"), t); } @@ -239,7 +239,7 @@ public class Http11Nio2Processor extends if (endpoint.isPaused()) { // 503 - Service unavailable response.setStatus(503); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); getAdapter().log(request, response, 0); } else { return true; @@ -285,7 +285,7 @@ public class Http11Nio2Processor extends if (log.isDebugEnabled()) { log.debug(sm.getString("http11processor.sendfile.error")); } - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } return true; } Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11NioProcessor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11NioProcessor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/http11/Http11NioProcessor.java (original) +++ tomcat/trunk/java/org/apache/coyote/http11/Http11NioProcessor.java Thu Jun 12 15:10:46 2014 @@ -103,7 +103,7 @@ public class Http11NioProcessor extends try { rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); if (!getAdapter().event(request, response, status)) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } if (!getErrorState().isError()) { if (attach != null) { @@ -126,12 +126,12 @@ public class Http11NioProcessor extends } } } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); // 500 - Internal Server Error response.setStatus(500); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); log.error(sm.getString("http11processor.request.process"), t); getAdapter().log(request, response, 0); } @@ -236,7 +236,7 @@ public class Http11NioProcessor extends if (endpoint.isPaused()) { // 503 - Service unavailable response.setStatus(503); - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); getAdapter().log(request, response, 0); } else { return true; @@ -290,7 +290,7 @@ public class Http11NioProcessor extends if (log.isDebugEnabled()) { log.debug(sm.getString("http11processor.sendfile.error")); } - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); } return true; } Modified: tomcat/trunk/java/org/apache/coyote/http11/upgrade/AbstractProcessor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/upgrade/AbstractProcessor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/http11/upgrade/AbstractProcessor.java (original) +++ tomcat/trunk/java/org/apache/coyote/http11/upgrade/AbstractProcessor.java Thu Jun 12 15:10:46 2014 @@ -150,6 +150,11 @@ public abstract class AbstractProcessor< } @Override + public void errorDispatch() { + // NO-OP + } + + @Override public final SocketState asyncPostProcess() { return null; } Modified: tomcat/trunk/java/org/apache/coyote/spdy/SpdyProcessor.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/spdy/SpdyProcessor.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/coyote/spdy/SpdyProcessor.java (original) +++ tomcat/trunk/java/org/apache/coyote/spdy/SpdyProcessor.java Thu Jun 12 15:10:46 2014 @@ -160,7 +160,7 @@ public class SpdyProcessor<S> extends Ab rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE); getAdapter().service(request, response); } catch (InterruptedIOException e) { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, e); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); // log.error(sm.getString("ajpprocessor.request.process"), t); @@ -169,7 +169,7 @@ public class SpdyProcessor<S> extends Ab t.printStackTrace(); response.setStatus(500); getAdapter().log(request, response, 0); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); } // TODO: async, etc ( detached mode - use a special light protocol) @@ -180,7 +180,7 @@ public class SpdyProcessor<S> extends Ab finish(); } catch (Throwable t) { ExceptionUtils.handleThrowable(t); - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, t); } } @@ -251,7 +251,7 @@ public class SpdyProcessor<S> extends Ab case DISABLE_SWALLOW_INPUT: { // TODO: Do not swallow request input but // make sure we are closing the connection - setErrorState(ErrorState.CLOSE_CLEAN); + setErrorState(ErrorState.CLOSE_CLEAN, null); break; } case CLOSE: { @@ -414,7 +414,7 @@ public class SpdyProcessor<S> extends Ab break; } case CLOSE_NOW: { - setErrorState(ErrorState.CLOSE_NOW); + setErrorState(ErrorState.CLOSE_NOW, null); break; } default: { Modified: tomcat/trunk/java/org/apache/tomcat/util/net/NioChannel.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/NioChannel.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/tomcat/util/net/NioChannel.java (original) +++ tomcat/trunk/java/org/apache/tomcat/util/net/NioChannel.java Thu Jun 12 15:10:46 2014 @@ -25,6 +25,7 @@ import java.nio.channels.SocketChannel; import org.apache.tomcat.util.net.NioEndpoint.Poller; import org.apache.tomcat.util.net.SecureNioChannel.ApplicationBufferHandler; +import org.apache.tomcat.util.res.StringManager; /** * @@ -36,6 +37,9 @@ import org.apache.tomcat.util.net.Secure */ public class NioChannel implements ByteChannel { + protected static final StringManager sm = + StringManager.getManager("org.apache.tomcat.util.net.res"); + protected static ByteBuffer emptyBuf = ByteBuffer.allocate(0); protected SocketChannel sc = null; @@ -119,6 +123,7 @@ public class NioChannel implements ByteC */ @Override public int write(ByteBuffer src) throws IOException { + checkInterruptStatus(); return sc.write(src); } @@ -211,4 +216,19 @@ public class NioChannel implements ByteC } + /** + * This method should be used to check the interrupt status before + * attempting a write. + * + * If a thread has been interrupted and the interrupt has not been cleared + * then an attempt to write to the socket will fail. When this happens the + * socket is removed from the poller without the socket being selected. This + * results in a connection limit leak for NIO as the endpoint expects the + * socket to be selected even in error conditions. + */ + protected void checkInterruptStatus() throws IOException { + if (Thread.interrupted()) { + throw new IOException(sm.getString("channel.nio.interrupted")); + } + } } Modified: tomcat/trunk/java/org/apache/tomcat/util/net/SecureNioChannel.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/SecureNioChannel.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/tomcat/util/net/SecureNioChannel.java (original) +++ tomcat/trunk/java/org/apache/tomcat/util/net/SecureNioChannel.java Thu Jun 12 15:10:46 2014 @@ -29,8 +29,6 @@ import javax.net.ssl.SSLEngineResult; import javax.net.ssl.SSLEngineResult.HandshakeStatus; import javax.net.ssl.SSLEngineResult.Status; -import org.apache.tomcat.util.res.StringManager; - /** * * Implementation of a secure socket channel @@ -39,8 +37,6 @@ import org.apache.tomcat.util.res.String public class SecureNioChannel extends NioChannel { - protected static final StringManager sm = StringManager.getManager("org.apache.tomcat.util.net.res"); - protected ByteBuffer netInBuffer; protected ByteBuffer netOutBuffer; @@ -475,6 +471,7 @@ public class SecureNioChannel extends Ni */ @Override public int write(ByteBuffer src) throws IOException { + checkInterruptStatus(); if ( src == this.netOutBuffer ) { //we can get here through a recursive call //by using the NioBlockingSelector Modified: tomcat/trunk/java/org/apache/tomcat/util/net/SocketStatus.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/SocketStatus.java?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/tomcat/util/net/SocketStatus.java (original) +++ tomcat/trunk/java/org/apache/tomcat/util/net/SocketStatus.java Thu Jun 12 15:10:46 2014 @@ -23,5 +23,5 @@ package org.apache.tomcat.util.net; * @author remm */ public enum SocketStatus { - OPEN_READ, OPEN_WRITE, STOP, TIMEOUT, DISCONNECT, ERROR, ASYNC_WRITE_ERROR, ASYNC_READ_ERROR + OPEN_READ, OPEN_WRITE, STOP, TIMEOUT, DISCONNECT, ERROR, ASYNC_WRITE_ERROR, ASYNC_READ_ERROR, CLOSE_NOW } Modified: tomcat/trunk/java/org/apache/tomcat/util/net/res/LocalStrings.properties URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/res/LocalStrings.properties?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/tomcat/util/net/res/LocalStrings.properties (original) +++ tomcat/trunk/java/org/apache/tomcat/util/net/res/LocalStrings.properties Thu Jun 12 15:10:46 2014 @@ -61,6 +61,7 @@ endpoint.apr.remoteport=APR socket [{0}] endpoint.nio.selectorCloseFail=Failed to close selector when closing the poller endpoint.nio2.exclusiveExecutor=The NIO2 connector requires an exclusive executor to operate properly on shutdown +channel.nio.interrupted=The current thread was interrupted channel.nio.ssl.notHandshaking=NOT_HANDSHAKING during handshake channel.nio.ssl.handhakeError=Handshake error channel.nio.ssl.unexpectedStatusDuringWrap=Unexpected status [{0}] during handshake WRAP. Modified: tomcat/trunk/webapps/docs/changelog.xml URL: http://svn.apache.org/viewvc/tomcat/trunk/webapps/docs/changelog.xml?rev=1602198&r1=1602197&r2=1602198&view=diff ============================================================================== --- tomcat/trunk/webapps/docs/changelog.xml (original) +++ tomcat/trunk/webapps/docs/changelog.xml Thu Jun 12 15:10:46 2014 @@ -147,6 +147,12 @@ <subsection name="Coyote"> <changelog> <fix> + <bug>56518</bug>: When using NIO, do not attempt to write to the socket + if the thread is marked interrupted as this will lead to a connection + limit leak. This fix was based on analysis of the issue by hanyong. + (markt) + </fix> + <fix> <bug>56521</bug>: Re-use the asynchronous write buffer between writes to reduce allocation and GC overhead. Based on a patch by leonzhx. Also make the buffer size configurable and remove copying of data within --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org