From: markt Date: Fri, 17 Sep 2010 14:11:03 +0000 (+0000) Subject: Remove more START/STOP actions and started attribute. They aren't adding anything. X-Git-Url: https://git.internetallee.de/?a=commitdiff_plain;h=bf23c9af60acb202d0e8339ac5a233fbac0f67dd;p=tomcat7.0 Remove more START/STOP actions and started attribute. They aren't adding anything. git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@998145 13f79535-47bb-0310-9956-ffa450edef68 --- diff --git a/java/org/apache/coyote/ActionCode.java b/java/org/apache/coyote/ActionCode.java index 971877bcd..043b4ddcf 100644 --- a/java/org/apache/coyote/ActionCode.java +++ b/java/org/apache/coyote/ActionCode.java @@ -40,8 +40,6 @@ public enum ActionCode { CUSTOM, RESET, - START, - STOP, WEBAPP, /** diff --git a/java/org/apache/coyote/ajp/AjpAprProcessor.java b/java/org/apache/coyote/ajp/AjpAprProcessor.java index b452b512d..48f92e19d 100644 --- a/java/org/apache/coyote/ajp/AjpAprProcessor.java +++ b/java/org/apache/coyote/ajp/AjpAprProcessor.java @@ -176,12 +176,6 @@ public class AjpAprProcessor implements ActionHook { /** - * State flag. - */ - protected boolean started = false; - - - /** * Error flag. */ protected boolean error = false; @@ -378,7 +372,7 @@ public class AjpAprProcessor implements ActionHook { boolean openSocket = true; boolean keptAlive = false; - while (started && !error && !endpoint.isPaused()) { + while (!error && !endpoint.isPaused()) { // Parsing the request header try { @@ -593,14 +587,6 @@ public class AjpAprProcessor implements ActionHook { error = true; } - } else if (actionCode == ActionCode.START) { - - started = true; - - } else if (actionCode == ActionCode.STOP) { - - started = false; - } else if (actionCode == ActionCode.REQ_SSL_ATTRIBUTE ) { if (!certificates.isNull()) { diff --git a/java/org/apache/coyote/ajp/AjpAprProtocol.java b/java/org/apache/coyote/ajp/AjpAprProtocol.java index 6dc73af96..84396cc7e 100644 --- a/java/org/apache/coyote/ajp/AjpAprProtocol.java +++ b/java/org/apache/coyote/ajp/AjpAprProtocol.java @@ -396,8 +396,6 @@ public class AjpAprProtocol processor = createProcessor(); } - processor.action(ActionCode.START, null); - if (processor.process(socket)) { connections.put(Long.valueOf(socket), processor); return SocketState.OPEN; @@ -427,7 +425,6 @@ public class AjpAprProtocol AjpAprProtocol.log.error (sm.getString("ajpprotocol.proto.error"), e); } finally { - processor.action(ActionCode.STOP, null); recycledProcessors.offer(processor); } return SocketState.CLOSED; diff --git a/java/org/apache/coyote/ajp/AjpProcessor.java b/java/org/apache/coyote/ajp/AjpProcessor.java index a8709f960..c7c45ba57 100644 --- a/java/org/apache/coyote/ajp/AjpProcessor.java +++ b/java/org/apache/coyote/ajp/AjpProcessor.java @@ -171,12 +171,6 @@ public class AjpProcessor implements ActionHook { /** - * State flag. - */ - protected boolean started = false; - - - /** * Error flag. */ protected boolean error = false; @@ -383,7 +377,7 @@ public class AjpProcessor implements ActionHook { // Error flag error = false; - while (started && !error && !endpoint.isPaused()) { + while (!error && !endpoint.isPaused()) { // Parsing the request header try { @@ -596,14 +590,6 @@ public class AjpProcessor implements ActionHook { error = true; } - } else if (actionCode == ActionCode.START) { - - started = true; - - } else if (actionCode == ActionCode.STOP) { - - started = false; - } else if (actionCode == ActionCode.REQ_SSL_ATTRIBUTE ) { if (!certificates.isNull()) { diff --git a/java/org/apache/coyote/ajp/AjpProtocol.java b/java/org/apache/coyote/ajp/AjpProtocol.java index b9430db38..f42bb24cf 100644 --- a/java/org/apache/coyote/ajp/AjpProtocol.java +++ b/java/org/apache/coyote/ajp/AjpProtocol.java @@ -391,7 +391,6 @@ public class AjpProtocol if (processor == null) { processor = createProcessor(); } - processor.action(ActionCode.START, null); SocketState state = socket.isAsync()?processor.asyncDispatch(status):processor.process(socket); if (state == SocketState.LONG) { @@ -423,7 +422,6 @@ public class AjpProtocol AjpProtocol.log.error (sm.getString("ajpprotocol.proto.error"), e); } finally { - processor.action(ActionCode.STOP, null); recycledProcessors.offer(processor); } return SocketState.CLOSED;