You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2013/09/30 21:26:28 UTC
svn commit: r1527732 -
/tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
Author: markt
Date: Mon Sep 30 19:26:27 2013
New Revision: 1527732
URL: http://svn.apache.org/r1527732
Log:
Refactor the method names some more.
Modified:
tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
Modified: tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java?rev=1527732&r1=1527731&r2=1527732&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java Mon Sep 30 19:26:27 2013
@@ -896,7 +896,7 @@ public class AprEndpoint extends Abstrac
}
}
- private void destroySocket(long socket) {
+ private void closeSocket(long socket) {
// If not running the socket will be destroyed by
// parent pool or acceptor socket.
// In any case disable double free which would cause JVM core.
@@ -908,7 +908,7 @@ public class AprEndpoint extends Abstrac
Poller poller = this.poller;
if (poller != null) {
if (!poller.close(socket)) {
- destroySocketInternal(socket);
+ destroySocket(socket);
}
}
}
@@ -917,7 +917,7 @@ public class AprEndpoint extends Abstrac
* This method should only be called if there is no chance that the socket
* is currently being used by the Poller.
*/
- private void destroySocketInternal(long socket) {
+ private void destroySocket(long socket) {
connections.remove(Long.valueOf(socket));
if (log.isDebugEnabled()) {
String msg = sm.getString("endpoint.debug.destroySocket",
@@ -999,11 +999,11 @@ public class AprEndpoint extends Abstrac
// Hand this socket off to an appropriate processor
if (!processSocketWithOptions(socket)) {
// Close socket and pool right away
- destroySocket(socket);
+ closeSocket(socket);
}
} else {
// Close socket and pool right away
- destroySocket(socket);
+ closeSocket(socket);
}
} catch (Throwable t) {
ExceptionUtils.handleThrowable(t);
@@ -1408,7 +1408,7 @@ public class AprEndpoint extends Abstrac
connections.get(Long.valueOf(info.socket)).isComet();
if (!comet || (comet && !processSocket(
info.socket, SocketStatus.STOP))) {
- destroySocket(info.socket);
+ closeSocket(info.socket);
}
info = addList.get();
}
@@ -1422,7 +1422,7 @@ public class AprEndpoint extends Abstrac
Long.valueOf(desc[n*2+1])).isComet();
if (!comet || (comet && !processSocket(
desc[n*2+1], SocketStatus.STOP))) {
- destroySocketInternal(desc[n*2+1]);
+ destroySocket(desc[n*2+1]);
}
}
}
@@ -1484,7 +1484,7 @@ public class AprEndpoint extends Abstrac
Long.valueOf(socket)).isComet();
if (!comet || (comet && !processSocket(
socket, SocketStatus.ERROR))) {
- destroySocket(socket);
+ closeSocket(socket);
}
}
}
@@ -1568,7 +1568,7 @@ public class AprEndpoint extends Abstrac
Long.valueOf(socket)).isComet();
if (!comet || (comet && !processSocket(
socket, SocketStatus.TIMEOUT))) {
- destroySocketInternal(socket);
+ destroySocket(socket);
}
socket = timeouts.check(date);
}
@@ -1670,7 +1670,7 @@ public class AprEndpoint extends Abstrac
while (info != null) {
localAddList.remove(info.socket);
removeFromPoller(info.socket);
- destroySocketInternal(info.socket);
+ destroySocket(info.socket);
info = localCloseList.get();
}
}
@@ -1703,7 +1703,7 @@ public class AprEndpoint extends Abstrac
// away
if (!comet || (comet && !processSocket(
info.socket, SocketStatus.ERROR))) {
- destroySocket(info.socket);
+ closeSocket(info.socket);
}
} else {
timeouts.add(info.socket,
@@ -1712,7 +1712,7 @@ public class AprEndpoint extends Abstrac
}
} else {
// Should never happen.
- destroySocket(info.socket);
+ closeSocket(info.socket);
getLog().warn(sm.getString(
"endpoint.apr.pollAddInvalid", info));
}
@@ -1754,7 +1754,7 @@ public class AprEndpoint extends Abstrac
|| ((desc[n*2] & Poll.APR_POLLNVAL) == Poll.APR_POLLNVAL)) {
if (!processSocket(desc[n*2+1], SocketStatus.ERROR)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else if ((desc[n*2] & Poll.APR_POLLIN) == Poll.APR_POLLIN) {
if (wrapper.pollerFlags != 0) {
@@ -1762,7 +1762,7 @@ public class AprEndpoint extends Abstrac
}
if (!processSocket(desc[n*2+1], SocketStatus.OPEN_READ)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else if ((desc[n*2] & Poll.APR_POLLOUT) == Poll.APR_POLLOUT) {
if (wrapper.pollerFlags != 0) {
@@ -1770,7 +1770,7 @@ public class AprEndpoint extends Abstrac
}
if (!processSocket(desc[n*2+1], SocketStatus.OPEN_WRITE)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else {
// Unknown event
@@ -1779,7 +1779,7 @@ public class AprEndpoint extends Abstrac
Long.valueOf(desc[n*2])));
if (!processSocket(desc[n*2+1], SocketStatus.ERROR)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
}
} else if (((desc[n*2] & Poll.APR_POLLHUP) == Poll.APR_POLLHUP)
@@ -1801,35 +1801,35 @@ public class AprEndpoint extends Abstrac
// Error probably occurred during a non-blocking read
if (!processSocket(desc[n*2+1], SocketStatus.OPEN_READ)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else if ((desc[n*2] & Poll.APR_POLLOUT) == Poll.APR_POLLOUT) {
// Error probably occurred during a non-blocking write
if (!processSocket(desc[n*2+1], SocketStatus.OPEN_WRITE)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else if ((wrapper.pollerFlags & Poll.APR_POLLIN) == Poll.APR_POLLIN) {
// Can't tell what was happening when the error occurred but the
// socket is registered for non-blocking read so use that
if (!processSocket(desc[n*2+1], SocketStatus.OPEN_READ)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else if ((wrapper.pollerFlags & Poll.APR_POLLOUT) == Poll.APR_POLLOUT) {
// Can't tell what was happening when the error occurred but the
// socket is registered for non-blocking write so use that
if (!processSocket(desc[n*2+1], SocketStatus.OPEN_WRITE)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else if (((desc[n*2] & Poll.APR_POLLIN) == Poll.APR_POLLIN)
|| ((desc[n*2] & Poll.APR_POLLOUT) == Poll.APR_POLLOUT)) {
@@ -1838,13 +1838,13 @@ public class AprEndpoint extends Abstrac
!processSocket(desc[n*2+1], SocketStatus.OPEN_READ)) {
error = true;
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
if (!error &&
((desc[n*2] & Poll.APR_POLLOUT) == Poll.APR_POLLOUT) &&
!processSocket(desc[n*2+1], SocketStatus.OPEN_WRITE)) {
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
} else {
// Unknown event
@@ -1852,7 +1852,7 @@ public class AprEndpoint extends Abstrac
"endpoint.apr.pollUnknownEvent",
Long.valueOf(desc[n*2])));
// Close socket and clear pool
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
}
} else if (rv < 0) {
@@ -1994,13 +1994,13 @@ public class AprEndpoint extends Abstrac
// Close any socket remaining in the add queue
for (int i = (addS.size() - 1); i >= 0; i--) {
SendfileData data = addS.get(i);
- destroySocket(data.socket);
+ closeSocket(data.socket);
}
// Close all sockets still in the poller
int rv = Poll.pollset(sendfilePollset, desc);
if (rv > 0) {
for (int n = 0; n < rv; n++) {
- destroySocket(desc[n*2+1]);
+ closeSocket(desc[n*2+1]);
}
}
Pool.destroy(pool);
@@ -2131,7 +2131,7 @@ public class AprEndpoint extends Abstrac
Integer.valueOf(rv),
Error.strerror(rv)));
// Can't do anything: close the socket right away
- destroySocket(data.socket);
+ closeSocket(data.socket);
}
}
addS.clear();
@@ -2153,7 +2153,7 @@ public class AprEndpoint extends Abstrac
remove(state);
// Destroy file descriptor pool, which should close the file
// Close the socket, as the response would be incomplete
- destroySocket(state.socket);
+ closeSocket(state.socket);
continue;
}
// Write some data using sendfile
@@ -2165,7 +2165,7 @@ public class AprEndpoint extends Abstrac
remove(state);
// Close the socket, as the response would be incomplete
// This will close the file too.
- destroySocket(state.socket);
+ closeSocket(state.socket);
continue;
}
@@ -2185,7 +2185,7 @@ public class AprEndpoint extends Abstrac
} else {
// Close the socket since this is
// the end of not keep-alive request.
- destroySocket(state.socket);
+ closeSocket(state.socket);
}
}
}
@@ -2221,7 +2221,7 @@ public class AprEndpoint extends Abstrac
remove(state);
// Destroy file descriptor pool, which should close the file
// Close the socket, as the response would be incomplete
- destroySocket(state.socket);
+ closeSocket(state.socket);
}
}
}
@@ -2281,14 +2281,14 @@ public class AprEndpoint extends Abstrac
getSoTimeout(), true, false);
} else {
// Close socket and pool
- destroySocket(socket.getSocket().longValue());
+ closeSocket(socket.getSocket().longValue());
socket = null;
}
} else {
// Process the request from this socket
if (!setSocketOptions(socket.getSocket().longValue())) {
// Close socket and pool
- destroySocket(socket.getSocket().longValue());
+ closeSocket(socket.getSocket().longValue());
socket = null;
return;
}
@@ -2297,7 +2297,7 @@ public class AprEndpoint extends Abstrac
SocketStatus.OPEN_READ);
if (state == Handler.SocketState.CLOSED) {
// Close socket and pool
- destroySocket(socket.getSocket().longValue());
+ closeSocket(socket.getSocket().longValue());
socket = null;
} else if (state == Handler.SocketState.LONG) {
socket.access();
@@ -2359,7 +2359,7 @@ public class AprEndpoint extends Abstrac
SocketState state = handler.process(socket, status);
if (state == Handler.SocketState.CLOSED) {
// Close socket and pool
- destroySocket(socket.getSocket().longValue());
+ closeSocket(socket.getSocket().longValue());
socket.reset(null, 1);
} else if (state == Handler.SocketState.LONG) {
socket.access();
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org