You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2016/03/18 17:28:30 UTC
[7/8] incubator-geode git commit: GEODE-1106 test was setting
testHook asynchronously. Now it set synchronously.
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/feature/GEODE-1050
Commit: 8c690ac6ab4e968f404031f2ece8f1b89c7ff9a5
Parents: 9993c76
Author: Hitesh Khamesra <hk...@pivotal.io>
Authored: Fri Mar 18 09:19:12 2016 -0700
Committer: Hitesh Khamesra <hk...@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