Remove START/STOP actions and started attribute. They aren't adding anything.
authormarkt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Fri, 17 Sep 2010 14:08:10 +0000 (14:08 +0000)
committermarkt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Fri, 17 Sep 2010 14:08:10 +0000 (14:08 +0000)
git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@998143 13f79535-47bb-0310-9956-ffa450edef68

java/org/apache/coyote/http11/Http11Processor.java
java/org/apache/coyote/http11/Http11Protocol.java

index 22e0873..5b056ac 100644 (file)
@@ -105,12 +105,6 @@ public class Http11Processor extends AbstractHttp11Processor implements ActionHo
 
     
     /**
-     * State flag.
-     */
-    protected boolean started = false;
-
-
-    /**
      * Socket associated with the current connection.
      */
     protected SocketWrapper<Socket> socket;
@@ -184,7 +178,7 @@ public class Http11Processor extends AbstractHttp11Processor implements ActionHo
 
         boolean keptAlive = socketWrapper.isKeptAlive();
 
-        while (started && !error && keepAlive && !endpoint.isPaused()) {
+        while (!error && keepAlive && !endpoint.isPaused()) {
 
             // Parsing the request header
             try {
@@ -397,14 +391,6 @@ public class Http11Processor extends AbstractHttp11Processor implements ActionHo
                 error = true;
             }
 
-        } else if (actionCode == ActionCode.START) {
-
-            started = true;
-
-        } else if (actionCode == ActionCode.STOP) {
-
-            started = false;
-
         } else if (actionCode == ActionCode.REQ_SSL_ATTRIBUTE ) {
 
             try {
index e49a102..7ba195c 100644 (file)
@@ -26,7 +26,6 @@ import java.util.concurrent.atomic.AtomicLong;
 
 import javax.management.ObjectName;
 
-import org.apache.coyote.ActionCode;
 import org.apache.coyote.RequestGroupInfo;
 import org.apache.coyote.RequestInfo;
 import org.apache.juli.logging.Log;
@@ -246,7 +245,6 @@ public class Http11Protocol extends AbstractHttp11JsseProtocol {
                 if (processor == null) {
                     processor = createProcessor();
                 }
-                processor.action(ActionCode.START, null);
 
                 if (proto.isSSLEnabled() && (proto.sslImplementation != null)) {
                     processor.setSSLSupport
@@ -290,7 +288,6 @@ public class Http11Protocol extends AbstractHttp11JsseProtocol {
                 //                processor.recycle();
 
                 if (recycle) {
-                    processor.action(ActionCode.STOP, null);
                     recycledProcessors.offer(processor);
                 }
             }