You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@thrift.apache.org by je...@apache.org on 2014/01/16 22:33:03 UTC
git commit: THRIFT-2322 Correctly show the number of times
ExecutorService (java) has rejected the client.
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 <je...@apache.org>
Authored: Thu Jan 16 21:36:08 2014 +0100
Committer: Jens Geyer <je...@apache.org>
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;