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 <[email protected]> Authored: Tue Jun 17 09:28:09 2014 -0700 Committer: Jacques Nadeau <[email protected]> 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;
