Author: markt
Date: Wed Sep 30 13:37:07 2015
New Revision: 1706032

URL: http://svn.apache.org/viewvc?rev=1706032&view=rev
Log:
Refactor to align Processor implementations.
The other processors call commit from the CLIENT_FLUSH action

Modified:
    tomcat/trunk/java/org/apache/coyote/http11/Http11OutputBuffer.java
    tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java

Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11OutputBuffer.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11OutputBuffer.java?rev=1706032&r1=1706031&r2=1706032&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http11/Http11OutputBuffer.java 
(original)
+++ tomcat/trunk/java/org/apache/coyote/http11/Http11OutputBuffer.java Wed Sep 
30 13:37:07 2015
@@ -233,14 +233,6 @@ public class Http11OutputBuffer implemen
      * @throws IOException an underlying I/O error occurred
      */
     public void flush() throws IOException {
-
-        if (!committed) {
-            // Send the connector a request for commit. The connector should
-            // then validate the headers, send them (using sendHeader) and
-            // set the filters accordingly.
-            response.action(ActionCode.COMMIT, null);
-        }
-
         // go through the filters and if there is gzip filter
         // invoke it to flush
         for (int i = 0; i <= lastActiveFilter; i++) {

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=1706032&r1=1706031&r2=1706032&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java Wed Sep 30 
13:37:07 2015
@@ -692,6 +692,7 @@ public class Http11Processor extends Abs
             break;
         }
         case CLIENT_FLUSH: {
+            action(ActionCode.COMMIT, null);
             try {
                 outputBuffer.flush();
             } catch (IOException e) {



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

Reply via email to