GEODE-412 We were re-setting the value count after getting its value. Sepatrated that logic as test may look this count more than once.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/531b8aae Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/531b8aae Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/531b8aae Branch: refs/heads/feature/GEODE-715 Commit: 531b8aaeb10fa5c5d2b9729d247fee8aceb5f253 Parents: a097fcf Author: Hitesh Khamesra <hkhame...@pivotal.io> Authored: Thu Jan 7 16:06:43 2016 -0800 Committer: Hitesh Khamesra <hkhame...@pivotal.io> Committed: Thu Jan 7 16:12:51 2016 -0800 ---------------------------------------------------------------------- .../cache/execute/OnGroupsFunctionExecutionDUnitTest.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/531b8aae/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/execute/OnGroupsFunctionExecutionDUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/execute/OnGroupsFunctionExecutionDUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/execute/OnGroupsFunctionExecutionDUnitTest.java index 5a642ca..6cb1ffd 100644 --- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/execute/OnGroupsFunctionExecutionDUnitTest.java +++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/execute/OnGroupsFunctionExecutionDUnitTest.java @@ -181,7 +181,7 @@ public class OnGroupsFunctionExecutionDUnitTest extends DistributedTestCase { int count = 0; synchronized (OnGroupsFunction.class) { count = f.invocationCount; - f.invocationCount = 0; + // f.invocationCount = 0; } return count; @@ -746,7 +746,7 @@ public class OnGroupsFunctionExecutionDUnitTest extends DistributedTestCase { } else { e.execute(new OnGroupsFunction()).getResult(); } - return null; + return null; } }); verifyAndResetInvocationCount(server0, 1); @@ -1235,5 +1235,8 @@ public class OnGroupsFunctionExecutionDUnitTest extends DistributedTestCase { } }; DistributedTestCase.waitForCriterion(wc2, 30000, 1000, true); + resetInvocationCount(server0); + resetInvocationCount(server1); + resetInvocationCount(server2); } }
