Repository: cassandra
Updated Branches:
  refs/heads/trunk 4d1f8e404 -> 4675b2089


avoid thread count Pattern matching if not running multiple thread counts


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/4675b208
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/4675b208
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/4675b208

Branch: refs/heads/trunk
Commit: 4675b2089f727c015bd6ea446f9896ac2f17c9a5
Parents: 4d1f8e4
Author: Dave Brosius <[email protected]>
Authored: Sat Dec 26 22:43:04 2015 -0500
Committer: Dave Brosius <[email protected]>
Committed: Sun Dec 27 15:13:41 2015 -0500

----------------------------------------------------------------------
 .../src/org/apache/cassandra/stress/StressGraph.java      | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/4675b208/tools/stress/src/org/apache/cassandra/stress/StressGraph.java
----------------------------------------------------------------------
diff --git a/tools/stress/src/org/apache/cassandra/stress/StressGraph.java 
b/tools/stress/src/org/apache/cassandra/stress/StressGraph.java
index 10fd62f..4e7fd12 100644
--- a/tools/stress/src/org/apache/cassandra/stress/StressGraph.java
+++ b/tools/stress/src/org/apache/cassandra/stress/StressGraph.java
@@ -143,16 +143,16 @@ public class StressGraph
                 if (line.startsWith("Thread count was not specified"))
                     runningMultipleThreadCounts = true;
 
-                // Detect thread count:
-                Matcher tc = threadCountMessage.matcher(line);
-                if (tc.matches())
+                if (runningMultipleThreadCounts)
                 {
-                    if (runningMultipleThreadCounts)
+                    // Detect thread count:
+                    Matcher tc = threadCountMessage.matcher(line);
+                    if (tc.matches())
                     {
                         currentThreadCount = tc.group(2);
                     }
                 }
-
+                
                 // Detect mode changes
                 if (line.equals(StressMetrics.HEAD))
                 {

Reply via email to