Updated Branches: refs/heads/master 169d65581 -> 77369a0ec
THRIFT-2322 Correctly show the number of times ExecutorService (java) has rejected the client. Patch: Rohit Agarwal & Jens Geyer Project: http://git-wip-us.apache.org/repos/asf/thrift/repo Commit: http://git-wip-us.apache.org/repos/asf/thrift/commit/77369a0e Tree: http://git-wip-us.apache.org/repos/asf/thrift/tree/77369a0e Diff: http://git-wip-us.apache.org/repos/asf/thrift/diff/77369a0e Branch: refs/heads/master Commit: 77369a0ecd7045aec7be0226ca4843f893bbcda0 Parents: 169d655 Author: Jens Geyer <[email protected]> Authored: Thu Jan 16 21:36:08 2014 +0100 Committer: Jens Geyer <[email protected]> Committed: Thu Jan 16 21:36:08 2014 +0100 ---------------------------------------------------------------------- lib/java/src/org/apache/thrift/server/TThreadPoolServer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/thrift/blob/77369a0e/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 38dfd58..0a1763e 100644 --- a/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java +++ b/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java @@ -117,13 +117,13 @@ public class TThreadPoolServer extends TServer { stopped_ = false; setServing(true); - while (!stopped_) { - int failureCount = 0; + int failureCount = 0; + while (!stopped_) { try { TTransport client = serverTransport_.accept(); WorkerProcess wp = new WorkerProcess(client); + int rejections = 0; while(true) { - int rejections = 0; try { executorService_.execute(wp); break;
