Repository: incubator-geode Updated Branches: refs/heads/feature/GEODE-835 7e559224a -> 52f21b0fc
GEODE-988: Added wait for events to arrive on stopped CQ before it is stopped. The test stops the CQ and verifies no events are recieved in stopped state; it was doing that by checking operations/events that happend before stop and not counting the changes happened during stop. In a slower environment, it could so happen that the CQ may not have recieved all the events before it is stopped, thus causing the validation to fail. Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/425581c6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/425581c6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/425581c6 Branch: refs/heads/feature/GEODE-835 Commit: 425581c650aeb472f38b814ca1617786e8c4fc9c Parents: 8a3c351 Author: Anil <aging...@pivotal.io> Authored: Thu May 19 14:02:54 2016 -0700 Committer: Anil <aging...@pivotal.io> Committed: Fri May 20 10:50:11 2016 -0700 ---------------------------------------------------------------------- .../gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/425581c6/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java index 130f924..2a91abb 100644 --- a/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java +++ b/geode-cq/src/test/java/com/gemstone/gemfire/cache/query/cq/dunit/CqPerfUsingPoolDUnitTest.java @@ -429,7 +429,6 @@ public class CqPerfUsingPoolDUnitTest extends CacheTestCase { // Create. cqDUnitTest.createValues(server, cqDUnitTest.regions[0], size); cqDUnitTest.waitForCreated(client, "testMatchingCqs_0", CqQueryUsingPoolDUnitTest.KEY+size); - cqDUnitTest.waitForCreated(client, "testMatchingCqs_3", CqQueryUsingPoolDUnitTest.KEY+size); // Close one of the CQ. cqDUnitTest.closeCQ(client, "testMatchingCqs_0"); @@ -438,6 +437,7 @@ public class CqPerfUsingPoolDUnitTest extends CacheTestCase { // Update. cqDUnitTest.createValues(server, cqDUnitTest.regions[0], size); cqDUnitTest.waitForUpdated(client, "testMatchingCqs_3", CqQueryUsingPoolDUnitTest.KEY+size); + cqDUnitTest.waitForUpdated(client, "testMatchingCqs_1", CqQueryUsingPoolDUnitTest.KEY+size); // Stop one of the CQ. cqDUnitTest.stopCQ(client, "testMatchingCqs_1");