Author: markt
Date: Fri Aug 12 07:45:55 2016
New Revision: 1756086

URL: http://svn.apache.org/viewvc?rev=1756086&view=rev
Log:
Align ActionCode.CLIENT_FLUSH

Modified:
    tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java
    tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java
    tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java

Modified: tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java?rev=1756086&r1=1756085&r2=1756086&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java Fri Aug 12 
07:45:55 2016
@@ -387,6 +387,7 @@ public class AjpProcessor extends Abstra
                 flush();
             } catch (IOException e) {
                 setErrorState(ErrorState.CLOSE_CONNECTION_NOW, e);
+                response.setErrorException(e);
             }
             break;
         }

Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java?rev=1756086&r1=1756085&r2=1756086&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java Fri Aug 12 
07:45:55 2016
@@ -677,7 +677,7 @@ public class Http11Processor extends Abs
         case CLIENT_FLUSH: {
             action(ActionCode.COMMIT, null);
             try {
-                outputBuffer.flush();
+                flush();
             } catch (IOException e) {
                 setErrorState(ErrorState.CLOSE_CONNECTION_NOW, e);
                 response.setErrorException(e);
@@ -1807,6 +1807,11 @@ public class Http11Processor extends Abs
     }
 
 
+    private void flush() throws IOException {
+        outputBuffer.flush();
+    }
+
+
     /**
      * Checks to see if the keep-alive loop should be broken, performing any
      * processing (e.g. sendfile handling) that may have an impact on whether

Modified: tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java?rev=1756086&r1=1756085&r2=1756086&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java Fri Aug 12 
07:45:55 2016
@@ -131,7 +131,7 @@ public class StreamProcessor extends Abs
         case CLIENT_FLUSH: {
             action(ActionCode.COMMIT, null);
             try {
-                stream.flushData();
+                flush();
             } catch (IOException ioe) {
                 setErrorState(ErrorState.CLOSE_CONNECTION_NOW, ioe);
                 response.setErrorException(ioe);
@@ -395,6 +395,11 @@ public class StreamProcessor extends Abs
     }
 
 
+    private void flush() throws IOException {
+        stream.flushData();
+    }
+
+
     @Override
     public void recycle() {
         // StreamProcessor instances are not re-used.



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org

Reply via email to