You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bo...@apache.org on 2019/11/16 01:04:05 UTC
[geode] branch feature/GEODE-7466 created (now ded358a)
This is an automated email from the ASF dual-hosted git repository.
boglesby pushed a change to branch feature/GEODE-7466
in repository https://gitbox.apache.org/repos/asf/geode.git.
at ded358a GEODE-7466: Closed the existing CacheClientNotifier instance if it exists
This branch includes the following new commits:
new ded358a GEODE-7466: Closed the existing CacheClientNotifier instance if it exists
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[geode] 01/01: GEODE-7466: Closed the existing CacheClientNotifier
instance if it exists
Posted by bo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
boglesby pushed a commit to branch feature/GEODE-7466
in repository https://gitbox.apache.org/repos/asf/geode.git
commit ded358a9242e2436aa73918d9e554a6ea6d65c10
Author: Barry Oglesby <bo...@pivotal.io>
AuthorDate: Fri Nov 15 17:02:46 2019 -0800
GEODE-7466: Closed the existing CacheClientNotifier instance if it exists
---
.../java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java
index cd33f8d..88577d8 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/HARegionQueueTest.java
@@ -23,6 +23,7 @@ import java.io.IOException;
import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;
+import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier;
import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -67,6 +68,10 @@ public class HARegionQueueTest {
new HAContainerMap(new ConcurrentHashMap()), null, (byte) 1, true,
mock(HARegionQueueStats.class), giiLock, rwLock, mock(CancelCriterion.class), false,
mock(StatisticsClock.class));
+
+ if (CacheClientNotifier.getInstance() != null) {
+ CacheClientNotifier.getInstance().shutdown(0l);
+ }
}
@Test