incubator-geode git commit: 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 sto

[ag...@apache.org]

Repository: incubator-geode
Updated Branches:
  refs/heads/develop 8a3c351ab -> 425581c65


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/develop
Commit: 425581c650aeb472f38b814ca1617786e8c4fc9c
Parents: 8a3c351
Author: Anil <ag...@pivotal.io>
Authored: Thu May 19 14:02:54 2016 -0700
Committer: Anil <ag...@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");