You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bs...@apache.org on 2015/11/20 22:02:31 UTC
[37/50] [abbrv] incubator-geode git commit: GEODE-77: changing names
of expected idle threads
GEODE-77: changing names of expected idle threads
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/4eb09ad4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/4eb09ad4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/4eb09ad4
Branch: refs/heads/develop
Commit: 4eb09ad43f47a4a0cef83c4d71acdb87554ab0ec
Parents: 1441789
Author: Bruce Schuchardt <bs...@pivotal.io>
Authored: Mon Nov 9 08:10:45 2015 -0800
Committer: Bruce Schuchardt <bs...@pivotal.io>
Committed: Mon Nov 9 08:10:45 2015 -0800
----------------------------------------------------------------------
.../com/gemstone/gemfire/internal/util/PluckStacks.java | 12 +++++-------
1 file changed, 5 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/4eb09ad4/gemfire-core/src/main/java/com/gemstone/gemfire/internal/util/PluckStacks.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/util/PluckStacks.java b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/util/PluckStacks.java
index f9f29e0..c1efbcc 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/util/PluckStacks.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/util/PluckStacks.java
@@ -198,21 +198,19 @@ public class PluckStacks {
if (threadName.startsWith("Function Execution Processor")) {
return isIdleExecutor(thread);
}
- if (threadName.startsWith("Geode Failure Detection Server thread")) {
- return stackSize < 11 && thread.get(1).contains("Thread.State: WAITING");
+ if (threadName.startsWith("Geode Failure Detection Server")) {
+ return stackSize < 11 && thread.getFirstFrame().contains("socketAccept");
}
if (threadName.startsWith("Geode Membership Timer")) {
// System.out.println("gf timer stack size = " + stackSize + "; frame = " + thread.get(1));
- return stackSize < 9 &&
- (thread.get(1).contains("Thread.State: WAITING")
- || thread.get(1).contains("Thread.State: TIMED_WAITING"));
+ return stackSize < 9 && !thread.isRunnable();
}
if (threadName.startsWith("Geode Membership View Creator")) {
// System.out.println("gf view creator stack size = " + stackSize + "; frame = " + thread.get(1));
- return stackSize < 8 && thread.get(1).contains("Thread.State: WAITING");
+ return stackSize < 8 && !thread.isRunnable();
}
if (threadName.startsWith("Geode Heartbeat Sender")) {
- return stackSize <= 8 && thread.get(1).contains("Thread.State: WAITING");
+ return stackSize <= 8 && !thread.isRunnable();
}
// thread currently disabled
// if (threadName.startsWith("Geode Suspect Message Collector")) {