Author: markt
Date: Thu Nov 17 16:42:52 2011
New Revision: 1203256
URL: http://svn.apache.org/viewvc?rev=1203256&view=rev
Log:
Refactor acceptor pause and shutdown to remove need for 'random' waits in the
shutdown code.
Removes the need for the fastShutdown attribute
Modified:
tomcat/tc7.0.x/trunk/ (props changed)
tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AbstractEndpoint.java
tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/JIoEndpoint.java
tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java
tomcat/tc7.0.x/trunk/test/org/apache/catalina/startup/TomcatBaseTest.java
tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml
tomcat/tc7.0.x/trunk/webapps/docs/config/ajp.xml
tomcat/tc7.0.x/trunk/webapps/docs/config/http.xml
Propchange: tomcat/tc7.0.x/trunk/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Nov 17 16:42:52 2011
@@ -1 +1 @@
-/tomcat/trunk:1156115,1156171,1156276,1156304,1156519,1156530,1156602,1157015,1157018,1157151,1157198,1157204,1157810,1157832,1157834,1157847,1157908,1157939,1158155,1158160,1158176,1158195,1158198-1158199,1158227,1158331,1158334-1158335,1158426,1160347,1160592,1160611,1160619,1160626,1160639,1160652,1160720-1160721,1160772,1160774,1160776,1161303,1161310,1161322,1161339,1161486,1161540,1161549,1161584,1162082,1162149,1162169,1162721,1162769,1162836,1162932,1163630,1164419,1164438,1164469,1164480,1164567,1165234,1165247-1165248,1165253,1165273,1165282,1165309,1165331,1165338,1165347,1165360-1165361,1165367-1165368,1165602,1165608,1165677,1165693,1165721,1165723,1165728,1165730,1165738,1165746,1165765,1165777,1165918,1165921,1166077,1166150-1166151,1166290,1166366,1166620,1166686,1166693,1166752,1166757,1167368,1167394,1169447,1170647,1171692,1172233-1172234,1172236,1172269,1172278,1172282,1172556,1172610,1172664,1172689,1172711,1173020-1173021,1173082,1173088,1173090,1173096
,1173241,1173256,1173288,1173333,1173342,1173461,1173614,1173630,1173659,1173722,1174061,1174239,1174322,1174325,1174329-1174330,1174337-1174339,1174343,1174353,1174799,1174882,1174884,1174983,1175155,1175158,1175167,1175182,1175190,1175201,1175272,1175275,1175283,1175582,1175589-1175590,1175594,1175602,1175613,1175633,1175690,1175713,1175798,1175889,1175896,1175907,1176584,1176590,1176799,1177050,1177060,1177125,1177152,1177160,1177245,1177850,1177862,1177978,1178209,1178228,1178233,1178449,1178542,1178681,1178684,1178721,1179268,1179274,1180261,1180865,1180891,1180894,1180907,1181028,1181123,1181125,1181136,1181291,1181743,1182796,1183078,1183105,1183142,1183328,1183339-1183340,1183492-1183494,1183605,1184917,1184919,1185018,1185020,1185200,1185588,1185626,1185756,1185758,1186011,1186042-1186045,1186104,1186123,1186137,1186153,1186254,1186257,1186377-1186379,1186479-1186480,1186712,1186743,1186750,1186763,1186890-1186892,1186894,1186949,1187018,1187027-1187028,1187381,1187
753,1187755,1187775,1187801,1187806,1187809,1187827,1188301,1188303-1188305,1188399,1188822,1188930-1188931,1189116,1189129,1189183,1189240,1189256,1189386,1189413-1189414,1189477,1189685,1189805,1189857,1189864,1189882,1190034,1190185,1190279,1190339,1190371,1190388-1190389,1190474,1190481,1194915,1195222-1195223,1195531,1195899,1195905,1195943,1195949,1195953,1195955,1195965,1195968,1196175,1196212,1196223,1196304-1196305,1196735,1196825,1196827,1197158,1197261,1197263,1197299-1197300,1197305,1197339-1197340,1197343,1197382,1197386-1197387,1197480,1197578,1198497,1198528,1198552,1198602,1198604,1198607,1198622,1198640,1198696,1198707,1199418,1199432,1199436,1199513,1199529,1199980,1199996,1200056,1200089,1200106-1200107,1200263,1200316,1200320,1200398-1200399,1200445-1200446,1200555,1200627,1200696,1200725,1200937,1200941,1201069,1201087,1201180,1201235-1201237,1201508,1201521,1201542,1201545-1201546,1201548,1201555-1201556,1201568,1201576,1201608,1201921-1201922,1201931,1
202035,1202039,1202271,1202565,1202578,1202705,1202828,1202860,1203047-1203052,1203078,1203091
+/tomcat/trunk:1156115,1156171,1156276,1156304,1156519,1156530,1156602,1157015,1157018,1157151,1157198,1157204,1157810,1157832,1157834,1157847,1157908,1157939,1158155,1158160,1158176,1158195,1158198-1158199,1158227,1158331,1158334-1158335,1158426,1160347,1160592,1160611,1160619,1160626,1160639,1160652,1160720-1160721,1160772,1160774,1160776,1161303,1161310,1161322,1161339,1161486,1161540,1161549,1161584,1162082,1162149,1162169,1162721,1162769,1162836,1162932,1163630,1164419,1164438,1164469,1164480,1164567,1165234,1165247-1165248,1165253,1165273,1165282,1165309,1165331,1165338,1165347,1165360-1165361,1165367-1165368,1165602,1165608,1165677,1165693,1165721,1165723,1165728,1165730,1165738,1165746,1165765,1165777,1165918,1165921,1166077,1166150-1166151,1166290,1166366,1166620,1166686,1166693,1166752,1166757,1167368,1167394,1169447,1170647,1171692,1172233-1172234,1172236,1172269,1172278,1172282,1172556,1172610,1172664,1172689,1172711,1173020-1173021,1173082,1173088,1173090,1173096
,1173241,1173256,1173288,1173333,1173342,1173461,1173614,1173630,1173659,1173722,1174061,1174239,1174322,1174325,1174329-1174330,1174337-1174339,1174343,1174353,1174799,1174882,1174884,1174983,1175155,1175158,1175167,1175182,1175190,1175201,1175272,1175275,1175283,1175582,1175589-1175590,1175594,1175602,1175613,1175633,1175690,1175713,1175798,1175889,1175896,1175907,1176584,1176590,1176799,1177050,1177060,1177125,1177152,1177160,1177245,1177850,1177862,1177978,1178209,1178228,1178233,1178449,1178542,1178681,1178684,1178721,1179268,1179274,1180261,1180865,1180891,1180894,1180907,1181028,1181123,1181125,1181136,1181291,1181743,1182796,1183078,1183105,1183142,1183328,1183339-1183340,1183492-1183494,1183605,1184917,1184919,1185018,1185020,1185200,1185588,1185626,1185756,1185758,1186011,1186042-1186045,1186104,1186123,1186137,1186153,1186254,1186257,1186377-1186379,1186479-1186480,1186712,1186743,1186750,1186763,1186890-1186892,1186894,1186949,1187018,1187027-1187028,1187381,1187
753,1187755,1187775,1187801,1187806,1187809,1187827,1188301,1188303-1188305,1188399,1188822,1188930-1188931,1189116,1189129,1189183,1189240,1189256,1189386,1189413-1189414,1189477,1189685,1189805,1189857,1189864,1189882,1190034,1190185,1190279,1190339,1190371,1190388-1190389,1190474,1190481,1194915,1195222-1195223,1195531,1195899,1195905,1195943,1195949,1195953,1195955,1195965,1195968,1196175,1196212,1196223,1196304-1196305,1196735,1196825,1196827,1197158,1197261,1197263,1197299-1197300,1197305,1197339-1197340,1197343,1197382,1197386-1197387,1197480,1197578,1198497,1198528,1198552,1198602,1198604,1198607,1198622,1198640,1198696,1198707,1199418,1199432,1199436,1199513,1199529,1199980,1199996,1200056,1200089,1200106-1200107,1200263,1200316,1200320,1200398-1200399,1200445-1200446,1200555,1200627,1200696,1200725,1200937,1200941,1201069,1201087,1201180,1201235-1201237,1201508,1201521,1201542,1201545-1201546,1201548,1201555-1201556,1201568,1201576,1201608,1201921-1201922,1201931,1
202035,1202039,1202271,1202565,1202578,1202705,1202828,1202860,1203047-1203052,1203078,1203091,1203253
Modified:
tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AbstractEndpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AbstractEndpoint.java?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AbstractEndpoint.java
(original)
+++ tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AbstractEndpoint.java
Thu Nov 17 16:42:52 2011
@@ -30,6 +30,7 @@ import javax.net.ssl.KeyManagerFactory;
import org.apache.juli.logging.Log;
import org.apache.tomcat.util.IntrospectionUtils;
+import org.apache.tomcat.util.net.AbstractEndpoint.Acceptor.AcceptorState;
import org.apache.tomcat.util.res.StringManager;
import org.apache.tomcat.util.threads.LimitLatch;
import org.apache.tomcat.util.threads.ResizableExecutor;
@@ -74,6 +75,25 @@ public abstract class AbstractEndpoint {
UNBOUND, BOUND_ON_INIT, BOUND_ON_START
}
+ public abstract static class Acceptor implements Runnable {
+ public enum AcceptorState {
+ NEW, RUNNING, PAUSED, ENDED
+ }
+
+ protected volatile AcceptorState state = AcceptorState.NEW;
+ public final AcceptorState getState() {
+ return state;
+ }
+
+ private String threadName;
+ protected final void setThreadName(final String threadName) {
+ this.threadName = threadName;
+ }
+ protected final String getThreadName() {
+ return threadName;
+ }
+ }
+
private static final int INITIAL_ERROR_DELAY = 50;
private static final int MAX_ERROR_DELAY = 1600;
@@ -109,25 +129,33 @@ public abstract class AbstractEndpoint {
return socketProperties;
}
+ /**
+ * Threads used to accept new connections and pass them to worker threads.
+ */
+ protected Acceptor[] acceptors;
+
// -----------------------------------------------------------------
Properties
/**
- * A flag that can be used to speed up Tomcat shutdown by testing
- * environments where we control external connections to Tomcat. Set it to
- * {@code true} if it is known that there are no active or pending
- * connections and all requests have already been processed. The default
- * value is {@code false}.
+ * Acceptor thread count.
*/
- private boolean fastShutdown = false;
-
- public void setFastShutdown(boolean fastShutdown) {
- this.fastShutdown = fastShutdown;
+ protected int acceptorThreadCount = 0;
+ public void setAcceptorThreadCount(int acceptorThreadCount) {
+ this.acceptorThreadCount = acceptorThreadCount;
}
+ public int getAcceptorThreadCount() { return acceptorThreadCount; }
+
- public boolean isFastShutdown() {
- return fastShutdown;
+ /**
+ * Priority of the acceptor threads.
+ */
+ protected int acceptorThreadPriority = Thread.NORM_PRIORITY;
+ public void setAcceptorThreadPriority(int acceptorThreadPriority) {
+ this.acceptorThreadPriority = acceptorThreadPriority;
}
+ public int getAcceptorThreadPriority() { return acceptorThreadPriority; }
+
private int maxConnections = 10000;
public void setMaxConnections(int maxCon) {
@@ -480,6 +508,16 @@ public abstract class AbstractEndpoint {
if (getLog().isDebugEnabled()) {
getLog().debug("Socket unlock completed for:"+saddr);
}
+
+ // Wait for upto 1000ms acceptor threads to unlock
+ long waitLeft = 1000;
+ for (Acceptor acceptor : acceptors) {
+ while (waitLeft > 0 &&
+ acceptor.getState() == AcceptorState.RUNNING) {
+ Thread.sleep(50);
+ waitLeft -= 50;
+ }
+ }
} catch(Exception e) {
if (getLog().isDebugEnabled()) {
getLog().debug(sm.getString("endpoint.debug.unlock", "" +
getPort()), e);
@@ -525,24 +563,33 @@ public abstract class AbstractEndpoint {
startInternal();
}
+ protected final void startAcceptorThreads() {
+ int count = getAcceptorThreadCount();
+ acceptors = new Acceptor[count];
+
+ for (int i = 0; i < count; i++) {
+ acceptors[i] = createAcceptor();
+ Thread t = new Thread(acceptors[i], getName() + "-Acceptor-" + i);
+ t.setPriority(getAcceptorThreadPriority());
+ t.setDaemon(getDaemon());
+ t.start();
+ }
+ }
+
+
+ /**
+ * Hook to allow Endpoints to provide a specific Acceptor implementation.
+ */
+ protected abstract Acceptor createAcceptor();
+
+
/**
* Pause the endpoint, which will stop it accepting new connections.
*/
public void pause() {
if (running && !paused) {
paused = true;
- if (isFastShutdown()) {
- // unlockAccept will also be called by stopInternal(),
- // so when shutting down it can be skipped here.
- return;
- }
unlockAccept();
- // Heuristic: Sleep for a while to ensure pause of the endpoint
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- // Ignore
- }
}
}
Modified: tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
(original)
+++ tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java Thu
Nov 17 16:42:52 2011
@@ -40,6 +40,7 @@ import org.apache.tomcat.jni.SSLSocket;
import org.apache.tomcat.jni.Socket;
import org.apache.tomcat.jni.Status;
import org.apache.tomcat.util.ExceptionUtils;
+import org.apache.tomcat.util.net.AbstractEndpoint.Acceptor.AcceptorState;
import org.apache.tomcat.util.net.AbstractEndpoint.Handler.SocketState;
@@ -91,9 +92,6 @@ public class AprEndpoint extends Abstrac
protected long sslContext = 0;
- private Acceptor acceptors[] = null;
-
-
protected ConcurrentLinkedQueue<SocketWrapper<Long>> waitingRequests =
new ConcurrentLinkedQueue<SocketWrapper<Long>>();
@@ -165,14 +163,6 @@ public class AprEndpoint extends Abstrac
/**
- * Acceptor thread count.
- */
- protected int acceptorThreadCount = 0;
- public void setAcceptorThreadCount(int acceptorThreadCount) {
this.acceptorThreadCount = acceptorThreadCount; }
- public int getAcceptorThreadCount() { return acceptorThreadCount; }
-
-
- /**
* Sendfile thread count.
*/
protected int sendfileThreadCount = 0;
@@ -619,15 +609,7 @@ public class AprEndpoint extends Abstrac
}
}
- // Start acceptor threads
- acceptors = new Acceptor[acceptorThreadCount];
- for (int i = 0; i < acceptorThreadCount; i++) {
- acceptors[i] = new Acceptor();
- acceptors[i].setName(getName() + "-Acceptor-" + i);
- acceptors[i].setPriority(threadPriority);
- acceptors[i].setDaemon(getDaemon());
- acceptors[i].start();
- }
+ startAcceptorThreads();
// Start async timeout thread
Thread timeoutThread = new Thread(new AsyncTimeout(),
@@ -651,25 +633,28 @@ public class AprEndpoint extends Abstrac
if (running) {
running = false;
unlockAccept();
- for (int i = 0; i < acceptors.length; i++) {
- long s = System.currentTimeMillis() + 10000;
- while (acceptors[i].isAlive() && serverSock != 0) {
+ for (AbstractEndpoint.Acceptor acceptor : acceptors) {
+ long waitLeft = 10000;
+ while (waitLeft > 0 &&
+ acceptor.getState() != AcceptorState.ENDED &&
+ serverSock != 0) {
try {
- acceptors[i].interrupt();
- acceptors[i].join(1000);
+ Thread.sleep(50);
} catch (InterruptedException e) {
- // Ignore
- }
- if (System.currentTimeMillis() >= s) {
-
log.warn(sm.getString("endpoint.warn.unlockAcceptorFailed",
- acceptors[i].getName()));
- // If the Acceptor is still running force
- // the hard socket close.
- if (serverSock != 0) {
- Socket.shutdown(serverSock,
Socket.APR_SHUTDOWN_READ);
- serverSock = 0;
- }
+ // Ignore and clean the interrupt flag
+ Thread.interrupted();
}
+ waitLeft -= 50;
+ }
+ if (waitLeft == 0) {
+ log.warn(sm.getString("endpoint.warn.unlockAcceptorFailed",
+ acceptor.getThreadName()));
+ // If the Acceptor is still running force
+ // the hard socket close.
+ if (serverSock != 0) {
+ Socket.shutdown(serverSock, Socket.APR_SHUTDOWN_READ);
+ serverSock = 0;
+ }
}
}
for (int i = 0; i < pollers.length; i++) {
@@ -738,6 +723,11 @@ public class AprEndpoint extends Abstrac
// ------------------------------------------------------ Protected Methods
+ @Override
+ protected AbstractEndpoint.Acceptor createAcceptor() {
+ return new Acceptor();
+ }
+
/**
* Process the specified connection.
@@ -957,10 +947,11 @@ public class AprEndpoint extends Abstrac
/**
* Server socket acceptor thread.
*/
- protected class Acceptor extends Thread {
+ protected class Acceptor extends AbstractEndpoint.Acceptor {
private final Log log = LogFactory.getLog(AprEndpoint.Acceptor.class);
+
/**
* The background thread that listens for incoming TCP/IP connections
and
* hands them off to an appropriate processor.
@@ -975,6 +966,7 @@ public class AprEndpoint extends Abstrac
// Loop if endpoint is paused
while (paused && running) {
+ state = AcceptorState.PAUSED;
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
@@ -985,6 +977,8 @@ public class AprEndpoint extends Abstrac
if (!running) {
break;
}
+ state = AcceptorState.RUNNING;
+
try {
//if we have reached max connections, wait
countUpOrAwaitConnection();
@@ -1036,13 +1030,10 @@ public class AprEndpoint extends Abstrac
}
}
}
-
// The processor will recycle itself when it finishes
-
}
-
+ state = AcceptorState.ENDED;
}
-
}
Modified: tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/JIoEndpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/JIoEndpoint.java?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/JIoEndpoint.java
(original)
+++ tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/JIoEndpoint.java Thu
Nov 17 16:42:52 2011
@@ -76,13 +76,6 @@ public class JIoEndpoint extends Abstrac
// ------------------------------------------------------------- Properties
/**
- * Acceptor thread count.
- */
- protected int acceptorThreadCount = 0;
- public void setAcceptorThreadCount(int acceptorThreadCount) {
this.acceptorThreadCount = acceptorThreadCount; }
- public int getAcceptorThreadCount() { return acceptorThreadCount; }
-
- /**
* Handling of accepted sockets.
*/
protected Handler handler = null;
@@ -174,8 +167,7 @@ public class JIoEndpoint extends Abstrac
/**
* Server socket acceptor thread.
*/
- protected class Acceptor implements Runnable {
-
+ protected class Acceptor extends AbstractEndpoint.Acceptor {
/**
* The background thread that listens for incoming TCP/IP connections
and
@@ -191,6 +183,7 @@ public class JIoEndpoint extends Abstrac
// Loop if endpoint is paused
while (paused && running) {
+ state = AcceptorState.PAUSED;
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
@@ -201,6 +194,8 @@ public class JIoEndpoint extends Abstrac
if (!running) {
break;
}
+ state = AcceptorState.RUNNING;
+
try {
//if we have reached max connections, wait
countUpOrAwaitConnection();
@@ -252,6 +247,7 @@ public class JIoEndpoint extends Abstrac
}
// The processor will recycle itself when it finishes
}
+ state = AcceptorState.ENDED;
}
}
@@ -405,14 +401,7 @@ public class JIoEndpoint extends Abstrac
initializeConnectionLatch();
- // Start acceptor threads
- for (int i = 0; i < acceptorThreadCount; i++) {
- Thread acceptorThread = new Thread(new Acceptor(),
- getName() + "-Acceptor-" + i);
- acceptorThread.setPriority(threadPriority);
- acceptorThread.setDaemon(getDaemon());
- acceptorThread.start();
- }
+ startAcceptorThreads();
// Start async timeout thread
Thread timeoutThread = new Thread(new AsyncTimeout(),
@@ -457,6 +446,12 @@ public class JIoEndpoint extends Abstrac
}
+ @Override
+ protected AbstractEndpoint.Acceptor createAcceptor() {
+ return new Acceptor();
+ }
+
+
/**
* Configure the socket.
*/
Modified: tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java
(original)
+++ tomcat/tc7.0.x/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java Thu
Nov 17 16:42:52 2011
@@ -301,13 +301,6 @@ public class NioEndpoint extends Abstrac
/**
- * Priority of the acceptor threads.
- */
- protected int acceptorThreadPriority = Thread.NORM_PRIORITY;
- public void setAcceptorThreadPriority(int acceptorThreadPriority) {
this.acceptorThreadPriority = acceptorThreadPriority; }
- public int getAcceptorThreadPriority() { return acceptorThreadPriority; }
-
- /**
* Priority of the poller threads.
*/
protected int pollerThreadPriority = Thread.NORM_PRIORITY;
@@ -337,14 +330,6 @@ public class NioEndpoint extends Abstrac
/**
- * Acceptor thread count.
- */
- protected int acceptorThreadCount = 1;
- public void setAcceptorThreadCount(int acceptorThreadCount) {
this.acceptorThreadCount = acceptorThreadCount; }
- public int getAcceptorThreadCount() { return acceptorThreadCount; }
-
-
- /**
* Poller thread count.
*/
protected int pollerThreadCount =
Runtime.getRuntime().availableProcessors();
@@ -536,13 +521,7 @@ public class NioEndpoint extends Abstrac
pollerThread.start();
}
- // Start acceptor threads
- for (int i = 0; i < acceptorThreadCount; i++) {
- Thread acceptorThread = new Thread(new Acceptor(), getName() +
"-Acceptor-" + i);
- acceptorThread.setPriority(threadPriority);
- acceptorThread.setDaemon(getDaemon());
- acceptorThread.start();
- }
+ startAcceptorThreads();
}
}
@@ -631,6 +610,12 @@ public class NioEndpoint extends Abstrac
}
+ @Override
+ protected AbstractEndpoint.Acceptor createAcceptor() {
+ return new Acceptor();
+ }
+
+
/**
* Process the specified connection.
*/
@@ -742,7 +727,7 @@ public class NioEndpoint extends Abstrac
/**
* Server socket acceptor thread.
*/
- protected class Acceptor implements Runnable {
+ protected class Acceptor extends AbstractEndpoint.Acceptor {
/**
* The background thread that listens for incoming TCP/IP connections
and
* hands them off to an appropriate processor.
@@ -757,6 +742,7 @@ public class NioEndpoint extends Abstrac
// Loop if endpoint is paused
while (paused && running) {
+ state = AcceptorState.PAUSED;
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
@@ -767,6 +753,8 @@ public class NioEndpoint extends Abstrac
if (!running) {
break;
}
+ state = AcceptorState.RUNNING;
+
try {
//if we have reached max connections, wait
countUpOrAwaitConnection();
@@ -829,6 +817,7 @@ public class NioEndpoint extends Abstrac
log.error(sm.getString("endpoint.accept.fail"), t);
}
}//while
+ state = AcceptorState.ENDED;
}//run
}
Modified:
tomcat/tc7.0.x/trunk/test/org/apache/catalina/startup/TomcatBaseTest.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/test/org/apache/catalina/startup/TomcatBaseTest.java?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/test/org/apache/catalina/startup/TomcatBaseTest.java
(original)
+++ tomcat/tc7.0.x/trunk/test/org/apache/catalina/startup/TomcatBaseTest.java
Thu Nov 17 16:42:52 2011
@@ -158,10 +158,6 @@ public abstract class TomcatBaseTest ext
@Override
public void tearDown() throws Exception {
try {
- // Speed up Tomcat shutdown
- if (tomcat.connector != null) {
- tomcat.connector.setProperty("fastShutdown", "true");
- }
// Some tests may call tomcat.destroy(), some tests may just call
// tomcat.stop(), some not call either method. Make sure that
stop()
// & destroy() are called as necessary.
Modified: tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml (original)
+++ tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml Thu Nov 17 16:42:52 2011
@@ -274,15 +274,14 @@
enabled for a connector and the response is flushed. Includes a test
case provided by David Marcks. (kkolinko/markt)
</fix>
- <add>
- Add new attribute <code>fastShutdown</code> to the
- <code>AbstractEndpoint</code> class and use it to speed up Tomcat
- tests. (kkolinko)
- </add>
<fix>
Improve multi-byte character handling in Coyote output for HTTP
and AJP. (rjung)
</fix>
+ <add>
+ Refactor acceptor unlock code to reduce waiting time during connector
+ pause and stop. (markt)
+ </add>
</changelog>
</subsection>
<subsection name="Jasper">
Modified: tomcat/tc7.0.x/trunk/webapps/docs/config/ajp.xml
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/webapps/docs/config/ajp.xml?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/webapps/docs/config/ajp.xml (original)
+++ tomcat/tc7.0.x/trunk/webapps/docs/config/ajp.xml Thu Nov 17 16:42:52 2011
@@ -273,6 +273,13 @@
<code>1</code>.</p>
</attribute>
+ <attribute name="acceptorThreadPriority" required="false">
+ <p>The priority of the acceptor threads. The threads used to accept
+ new connections. The default value is
+ <code>java.lang.Thread#NORM_PRIORITY</code>. See the JavaDoc for the
+ java.lang.Thread class for more details on what this priority means.</p>
+ </attribute>
+
<attribute name="address" required="false">
<p>For servers with more than one IP address, this attribute
specifies which address will be used for listening on the specified
@@ -321,17 +328,6 @@
provide the thread pool.</p>
</attribute>
- <attribute name="fastShutdown" required="false">
- <p>This flag can be used to speed up Tomcat shutdown in testing
- environments where Tomcat is started and stopped many times in a row,
- but where all connections to Tomcat are known and controlled. It can be
- used if it is known that there are no active connections and all requests
- have already been processed.
- If it is set to <code>true</code>, it turns off small delay when
- pausing Connector Endpoint. The default value is
- <code>false</code>.</p>
- </attribute>
-
<attribute name="keepAliveTimeout" required="false">
<p>The number of milliseconds this <strong>Connector</strong> will wait
for
another AJP request before closing the connection.
Modified: tomcat/tc7.0.x/trunk/webapps/docs/config/http.xml
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/webapps/docs/config/http.xml?rev=1203256&r1=1203255&r2=1203256&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/webapps/docs/config/http.xml (original)
+++ tomcat/tc7.0.x/trunk/webapps/docs/config/http.xml Thu Nov 17 16:42:52 2011
@@ -267,6 +267,13 @@
<code>1</code>.</p>
</attribute>
+ <attribute name="acceptorThreadPriority" required="false">
+ <p>The priority of the acceptor threads. The threads used to accept
+ new connections. The default value is
+ <code>java.lang.Thread#NORM_PRIORITY</code>. See the JavaDoc for the
+ java.lang.Thread class for more details on what this priority means.</p>
+ </attribute>
+
<attribute name="address" required="false">
<p>For servers with more than one IP address, this attribute
specifies which address will be used for listening on the specified
@@ -355,17 +362,6 @@
provide the thread pool.</p>
</attribute>
- <attribute name="fastShutdown" required="false">
- <p>This flag can be used to speed up Tomcat shutdown in testing
- environments where Tomcat is started and stopped many times in a row,
- but where all connections to Tomcat are known and controlled. It can be
- used if it is known that there are no active connections and all requests
- have already been processed.
- If it is set to <code>true</code>, it turns off small delay when
- pausing Connector Endpoint. The default value is
- <code>false</code>.</p>
- </attribute>
-
<attribute name="keepAliveTimeout" required="false">
<p>The number of milliseconds this <strong>Connector</strong> will wait
for another HTTP request before closing the connection. The default value
@@ -605,13 +601,6 @@
<attributes>
- <attribute name="acceptorThreadPriority" required="false">
- <p>(int)The priority of the acceptor threads. The threads used to
accept
- new connections. The default value is
- <code>java.lang.Thread#NORM_PRIORITY</code>. See the JavaDoc for the
- java.lang.Thread class for more details on what this priority
means.</p>
- </attribute>
-
<attribute name="pollerThreadCount" required="false">
<p>(int)The number of threads to be used to run for the polling events.
Default value is <code>1</code> per processor. Can't see a reason to go
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
