Repository: thrift Updated Branches: refs/heads/master 2659381e7 -> b1a35da91
THRIFT-3088 TThreadPoolServer with Sasl auth may leak CLOSE_WAIT socket TThreadPoolServer with Sasl auth may leak CLOSE_WAIT socket Project: http://git-wip-us.apache.org/repos/asf/thrift/repo Commit: http://git-wip-us.apache.org/repos/asf/thrift/commit/b1a35da9 Tree: http://git-wip-us.apache.org/repos/asf/thrift/tree/b1a35da9 Diff: http://git-wip-us.apache.org/repos/asf/thrift/diff/b1a35da9 Branch: refs/heads/master Commit: b1a35da9168cca5a7524ab9814161f024da145df Parents: 2659381 Author: Winger Pun <[email protected]> Authored: Thu Apr 9 15:56:54 2015 +0800 Committer: Roger Meier <[email protected]> Committed: Sun Apr 12 17:46:35 2015 +0200 ---------------------------------------------------------------------- lib/java/src/org/apache/thrift/server/TThreadPoolServer.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/thrift/blob/b1a35da9/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java ---------------------------------------------------------------------- diff --git a/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java b/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java index 8009118..65257ec 100755 --- a/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java +++ b/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java @@ -303,6 +303,10 @@ public class TThreadPoolServer extends TServer { if (outputTransport != null) { outputTransport.close(); } + + if (client_.isOpen()) { + client_.close(); + } } } }
