You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/06/18 06:22:18 UTC
[08/13] git commit: Improve error messaging for OperatorStats
assertion messages.
Improve error messaging for OperatorStats assertion messages.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/d7a75dda
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/d7a75dda
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/d7a75dda
Branch: refs/heads/master
Commit: d7a75ddaf9e2f2e998b071fc1f3fad1b3579f01c
Parents: e2f57b4
Author: Jacques Nadeau <ja...@apache.org>
Authored: Tue Jun 17 09:28:09 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
Committed: Tue Jun 17 16:04:39 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/drill/exec/ops/OperatorStats.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d7a75dda/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorStats.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorStats.java b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorStats.java
index 4afea7b..7d1e9dc 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorStats.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorStats.java
@@ -67,40 +67,40 @@ public class OperatorStats {
}
public void startSetup() {
- assert !inSetup;
+ assert !inSetup : "Failure while starting setup. Currently in setup.";
stopProcessing();
inSetup = true;
setupMark = System.nanoTime();
}
public void stopSetup() {
- assert inSetup;
+ assert inSetup : "Failure while stopping setup. Not currently in setup.";
startProcessing();
setupNanos += System.nanoTime() - setupMark;
inSetup = false;
}
public void startProcessing() {
- assert !inProcessing;
+ assert !inProcessing : "Failure while starting processing. Currently in processing.";
processingMark = System.nanoTime();
inProcessing = true;
}
public void stopProcessing() {
- assert inProcessing;
+ assert inProcessing : "Failure while stopping processing. Not currently in processing.";
processingNanos += System.nanoTime() - processingMark;
inProcessing = false;
}
public void startWait() {
- assert !inWait;
+ assert !inWait : "Failure while starting waiting. Currently in waiting.";
stopProcessing();
inWait = true;
waitMark = System.nanoTime();
}
public void stopWait() {
- assert inWait;
+ assert inWait : "Failure while stopping waiting. Currently not in waiting.";
startProcessing();
waitNanos += System.nanoTime() - waitMark;
inWait = false;