geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hiteshkhame...@apache.org
Subject [6/6] incubator-geode git commit: GEODE-1106 test was setting testHook asynchronously. Now it set synchronously.
Date Fri, 18 Mar 2016 16:23:15 GMT
GEODE-1106 test was setting testHook asynchronously. Now it set synchronously.

That was causing other thread to not to use testhook


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/8c690ac6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/8c690ac6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/8c690ac6

Branch: refs/heads/develop
Commit: 8c690ac6ab4e968f404031f2ece8f1b89c7ff9a5
Parents: 9993c76
Author: Hitesh Khamesra <hkhamesra@pivotal.io>
Authored: Fri Mar 18 09:19:12 2016 -0700
Committer: Hitesh Khamesra <hkhamesra@pivotal.io>
Committed: Fri Mar 18 09:23:23 2016 -0700

----------------------------------------------------------------------
 .../tier/sockets/DurableClientSimpleDUnitTest.java   | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8c690ac6/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java
b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java
index 766fad5..0a263eb 100644
--- a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java
+++ b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientSimpleDUnitTest.java
@@ -2856,16 +2856,21 @@ public class DurableClientSimpleDUnitTest extends DurableClientTestCase
{
       startClient(publisherClientVM, serverPort, regionName);
     
       // Publish some entries
-      publishEntries(publisherClientVM, regionName, 10);
+      publishEntries(publisherClientVM, regionName, 10);
+      
+      this.server1VM.invoke(new CacheSerializableRunnable(
+          "Set test hook") {
+        public void run2() throws CacheException {
+          //Set the Test Hook!
+          //This test hook will pause during the drain process
+          CacheClientProxy.testHook = new RejectClientReconnectTestHook();
+        }
+      });
               
       this.server1VM.invokeAsync(new CacheSerializableRunnable(
           "Close cq for durable client") {
         public void run2() throws CacheException {
   
-          //Set the Test Hook!
-          //This test hook will pause during the drain process
-          CacheClientProxy.testHook = new RejectClientReconnectTestHook();
-  
           final CacheClientNotifier ccnInstance = CacheClientNotifier
               .getInstance();
           final CacheClientProxy clientProxy = ccnInstance


Mime
View raw message