This is an automated email from the ASF dual-hosted git repository. rgoers pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/logging-log4j-server.git
commit ae46a9a373542fa8395794027ffef3b9d9781a24 Author: Gary Gregory <[email protected]> AuthorDate: Fri Jul 28 16:05:17 2017 -0700 [LOG4J2-1994] TcpSocketServer does not close accepted Sockets. --- .../main/java/org/apache/logging/log4j/server/TcpSocketServer.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/log4j-server/src/main/java/org/apache/logging/log4j/server/TcpSocketServer.java b/log4j-server/src/main/java/org/apache/logging/log4j/server/TcpSocketServer.java index 4d8146b..af458f8 100644 --- a/log4j-server/src/main/java/org/apache/logging/log4j/server/TcpSocketServer.java +++ b/log4j-server/src/main/java/org/apache/logging/log4j/server/TcpSocketServer.java @@ -71,10 +71,12 @@ public class TcpSocketServer<T extends InputStream> extends AbstractSocketServer private class SocketHandler extends Log4jThread { private final T inputStream; + private final Socket socket; private volatile boolean shutdown = false; public SocketHandler(final Socket socket) throws IOException { + this.socket = socket; this.inputStream = logEventInput.wrapStream(socket.getInputStream()); } @@ -107,6 +109,9 @@ public class TcpSocketServer<T extends InputStream> extends AbstractSocketServer public void shutdown() { this.shutdown = true; + if (socket != null) { + Closer.closeSilently(socket); + } interrupt(); } }
