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/10/18 18:57:32 UTC
[02/42] incubator-geode git commit: Move Admin API to internal
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/admin/internal/HealthEvaluatorTestCase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/admin/internal/HealthEvaluatorTestCase.java b/geode-core/src/test/java/org/apache/geode/admin/internal/HealthEvaluatorTestCase.java
deleted file mode 100644
index 63927e8..0000000
--- a/geode-core/src/test/java/org/apache/geode/admin/internal/HealthEvaluatorTestCase.java
+++ /dev/null
@@ -1,76 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.geode.admin.internal;
-
-import org.apache.geode.distributed.DistributedSystem;
-import org.apache.geode.distributed.internal.InternalDistributedSystem;
-import org.junit.After;
-import org.junit.Before;
-
-import java.util.Properties;
-
-import static org.apache.geode.distributed.ConfigurationProperties.*;
-
-/**
- * Superclass of tests for the {@linkplain
- * org.apache.geode.admin.internal.AbstractHealthEvaluator health
- * evaluator} classes.
- *
- *
- * @since GemFire 3.5
- */
-public abstract class HealthEvaluatorTestCase {
-
- /** The DistributedSystem used for this test */
- protected InternalDistributedSystem system;
-
- /**
- * Creates a "loner" <code>DistributedSystem</code> for this test.
- */
- @Before
- public void setUp() {
- Properties props = getProperties();
- system = (InternalDistributedSystem)
- DistributedSystem.connect(props);
- }
-
- /**
- * Closes the "loner" <code>DistributedSystem</code>
- */
- @After
- public void tearDown() {
- if (this.system != null) {
- this.system.disconnect();
- }
-
- this.system = null;
- }
-
- /**
- * Creates the <code>Properties</code> objects used to connect to
- * the distributed system.
- */
- protected Properties getProperties() {
- Properties props = new Properties();
- props.setProperty(MCAST_PORT, "0");
- props.setProperty(LOCATORS, "");
- props.setProperty(STATISTIC_SAMPLING_ENABLED, "true");
-
- return props;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/admin/internal/MemberHealthEvaluatorJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/admin/internal/MemberHealthEvaluatorJUnitTest.java b/geode-core/src/test/java/org/apache/geode/admin/internal/MemberHealthEvaluatorJUnitTest.java
deleted file mode 100644
index 91b0230..0000000
--- a/geode-core/src/test/java/org/apache/geode/admin/internal/MemberHealthEvaluatorJUnitTest.java
+++ /dev/null
@@ -1,101 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.geode.admin.internal;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
-import org.apache.geode.admin.GemFireHealth;
-import org.apache.geode.admin.GemFireHealthConfig;
-import org.apache.geode.internal.statistics.GemFireStatSampler;
-import org.apache.geode.internal.statistics.platform.ProcessStats;
-import org.apache.geode.internal.PureJavaMode;
-import org.apache.geode.test.junit.categories.IntegrationTest;
-
-/**
- * Contains simple tests for the {@link MemberHealthEvaluator}.
- *
- *
- * @since GemFire 3.5
- */
-@SuppressWarnings("deprecation")
-@Category(IntegrationTest.class)
-public class MemberHealthEvaluatorJUnitTest extends HealthEvaluatorTestCase {
-
- /**
- * Tests that we are in {@link GemFireHealth#OKAY_HEALTH okay}
- * health if the VM's process size is too big.
- *
- * @see MemberHealthEvaluator#checkVMProcessSize
- */
- @Test
- public void testCheckVMProcessSize() throws InterruptedException {
- if(PureJavaMode.osStatsAreAvailable()) {
- GemFireStatSampler sampler = system.getStatSampler();
- assertNotNull(sampler);
-
- sampler.waitForInitialization(10000); // fix: remove infinite wait
-
- ProcessStats stats = sampler.getProcessStats();
- assertNotNull(stats);
-
- List status = new ArrayList();
- long threshold = stats.getProcessSize() * 2;
-
- if (threshold <= 0) {
- // The process size is zero on some Linux versions
- return;
- }
-
- GemFireHealthConfig config = new GemFireHealthConfigImpl(null);
- config.setMaxVMProcessSize(threshold);
-
- MemberHealthEvaluator eval =
- new MemberHealthEvaluator(config,
- this.system.getDistributionManager());
- eval.evaluate(status);
- assertTrue(status.isEmpty());
-
- status = new ArrayList();
- long processSize = stats.getProcessSize();
- threshold = processSize / 2;
- assertTrue("Threshold (" + threshold + ") is > 0. " +
- "Process size is " + processSize,
- threshold > 0);
-
- config = new GemFireHealthConfigImpl(null);
- config.setMaxVMProcessSize(threshold);
-
- eval = new MemberHealthEvaluator(config,
- this.system.getDistributionManager());
- eval.evaluate(status);
- assertEquals(1, status.size());
-
- AbstractHealthEvaluator.HealthStatus ill =
- (AbstractHealthEvaluator.HealthStatus) status.get(0);
- assertEquals(GemFireHealth.OKAY_HEALTH, ill.getHealthCode());
- assertTrue(ill.getDiagnosis().indexOf("The size of this VM") != -1);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/cache/query/dunit/QueryUsingPoolDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/cache/query/dunit/QueryUsingPoolDUnitTest.java b/geode-core/src/test/java/org/apache/geode/cache/query/dunit/QueryUsingPoolDUnitTest.java
index 7c38823..05076b0 100644
--- a/geode-core/src/test/java/org/apache/geode/cache/query/dunit/QueryUsingPoolDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/cache/query/dunit/QueryUsingPoolDUnitTest.java
@@ -197,7 +197,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
Assert.fail("Failed to get QueryService.", e);
}
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName;
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName;
try {
Query query = qService.newQuery(queryString);
@@ -209,7 +209,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where ticker = 'ibm'";
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where ticker = 'ibm'";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -219,7 +219,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where ticker = 'IBM'";
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where ticker = 'IBM'";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -229,7 +229,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertEquals(0, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where price > 49";
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where price > 49";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -239,7 +239,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries / 2, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where price = 50";
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName + " where price = 50";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -249,7 +249,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertEquals(1, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct * from " + regionName
+ " where ticker = 'ibm' and price = 50";
try {
Query query = qService.newQuery(queryString);
@@ -306,7 +306,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
Assert.fail("Failed to get QueryService.", e);
}
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName;
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName;
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -317,7 +317,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
queryString =
- "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where ticker = 'ibm'";
+ "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where ticker = 'ibm'";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -328,7 +328,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
queryString =
- "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where ticker = 'IBM'";
+ "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where ticker = 'IBM'";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -339,7 +339,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
queryString =
- "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where price > 49";
+ "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where price > 49";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -350,7 +350,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
queryString =
- "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where price = 50";
+ "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName + " where price = 50";
try {
Query query = qService.newQuery(queryString);
results = (SelectResults) query.execute();
@@ -360,7 +360,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
assertEquals(1, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
- queryString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName
+ queryString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject; select distinct ticker, price from " + regionName
+ " where ticker = 'ibm' and price = 50";
try {
Query query = qService.newQuery(queryString);
@@ -1599,7 +1599,7 @@ public class QueryUsingPoolDUnitTest extends JUnit4CacheTestCase {
}
try {
- String importString = "import org.apache.geode.admin.QueryUsingPoolDUnitTest.TestObject;";
+ String importString = "import org.apache.geode.query.dunit.QueryUsingPoolDUnitTest.TestObject;";
qService.createIndex("test", IndexType.FUNCTIONAL, "ticker", regionName1, importString);
} catch (UnsupportedOperationException e) {
// Expected behavior.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/cache/query/dunit/RemoteQueryDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/cache/query/dunit/RemoteQueryDUnitTest.java b/geode-core/src/test/java/org/apache/geode/cache/query/dunit/RemoteQueryDUnitTest.java
index e97b5bf..8097bca 100644
--- a/geode-core/src/test/java/org/apache/geode/cache/query/dunit/RemoteQueryDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/cache/query/dunit/RemoteQueryDUnitTest.java
@@ -287,7 +287,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
String queryString = null;
SelectResults results = null;
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath();
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath();
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -296,7 +296,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where ticker = 'ibm'";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where ticker = 'ibm'";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -305,7 +305,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where ticker = 'IBM'";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where ticker = 'IBM'";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -314,7 +314,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(0, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where price > 49";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where price > 49";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -323,7 +323,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries/2, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where price = 50";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where price = 50";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -332,7 +332,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(1, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where ticker = 'ibm' and price = 50";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct * from " + region.getFullPath() + " where ticker = 'ibm' and price = 50";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -415,7 +415,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
String queryString = null;
SelectResults results = null;
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath();
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath();
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -424,7 +424,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where ticker = 'ibm'";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where ticker = 'ibm'";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -433,7 +433,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where ticker = 'IBM'";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where ticker = 'IBM'";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -442,7 +442,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(0, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where price > 49";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where price > 49";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -451,7 +451,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(numberOfEntries/2, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where price = 50";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where price = 50";
try {
results = region.query(queryString);
} catch (Exception e) {
@@ -460,7 +460,7 @@ public class RemoteQueryDUnitTest extends JUnit4CacheTestCase {
assertEquals(1, results.size());
assertTrue(!results.getCollectionType().allowsDuplicates() && results.getCollectionType().getElementType().isStructType());
- queryString = "import org.apache.geode.admin.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where ticker = 'ibm' and price = 50";
+ queryString = "import org.apache.geode.query.dunit.RemoteQueryDUnitTest.TestObject; select distinct ticker, price from " + region.getFullPath() + " where ticker = 'ibm' and price = 50";
try {
results = region.query(queryString);
} catch (Exception e) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/distributed/internal/ConsoleDistributionManagerDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/distributed/internal/ConsoleDistributionManagerDUnitTest.java b/geode-core/src/test/java/org/apache/geode/distributed/internal/ConsoleDistributionManagerDUnitTest.java
index 5f3b48e..591d94a 100644
--- a/geode-core/src/test/java/org/apache/geode/distributed/internal/ConsoleDistributionManagerDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/distributed/internal/ConsoleDistributionManagerDUnitTest.java
@@ -58,8 +58,7 @@ import org.apache.geode.test.junit.categories.DistributedTest;
import org.apache.geode.test.junit.categories.FlakyTest;
/**
- * This class tests the functionality of the {@linkplain org.apache.geode.internal.admin internal
- * admin} API.
+ * This class tests the functionality of the internal admin API.
*/
@Category(DistributedTest.class)
public class ConsoleDistributionManagerDUnitTest extends JUnit4CacheTestCase implements AlertListener {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerDUnitTest.java b/geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerDUnitTest.java
index c1f894f..586cc7c 100644
--- a/geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerDUnitTest.java
@@ -30,12 +30,12 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.apache.geode.LogWriter;
-import org.apache.geode.admin.AdminDistributedSystem;
-import org.apache.geode.admin.AdminDistributedSystemFactory;
-import org.apache.geode.admin.Alert;
-import org.apache.geode.admin.AlertLevel;
-import org.apache.geode.admin.AlertListener;
-import org.apache.geode.admin.DistributedSystemConfig;
+import org.apache.geode.internal.admin.api.AdminDistributedSystem;
+import org.apache.geode.internal.admin.api.AdminDistributedSystemFactory;
+import org.apache.geode.internal.admin.api.Alert;
+import org.apache.geode.internal.admin.api.AlertLevel;
+import org.apache.geode.internal.admin.api.AlertListener;
+import org.apache.geode.internal.admin.api.DistributedSystemConfig;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.CacheListener;
import org.apache.geode.cache.DataPolicy;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/AvailablePortJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/AvailablePortJUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/AvailablePortJUnitTest.java
index 45bedf3..8ec9277 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/AvailablePortJUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/AvailablePortJUnitTest.java
@@ -16,7 +16,7 @@
*/
package org.apache.geode.internal;
-import org.apache.geode.admin.internal.InetAddressUtil;
+import org.apache.geode.internal.admin.api.impl.InetAddressUtil;
import org.apache.geode.distributed.internal.DistributionConfig;
import org.apache.geode.test.junit.categories.IntegrationTest;
import org.junit.After;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/AdminTestHelper.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/AdminTestHelper.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/AdminTestHelper.java
new file mode 100644
index 0000000..76b200c
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/AdminTestHelper.java
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api;
+
+import static org.junit.Assert.*;
+import org.apache.geode.distributed.internal.DistributionManager;
+import org.apache.geode.internal.admin.api.AdminDistributedSystemFactory;
+
+public class AdminTestHelper {
+ private AdminTestHelper() {}
+
+ public static void checkEnableAdministrationOnly(boolean v, boolean expectException) {
+ boolean origIsDedicatedAdminVM = DistributionManager.isDedicatedAdminVM;
+ if (expectException) {
+ try {
+ AdminDistributedSystemFactory.setEnableAdministrationOnly(v);
+ fail("expected IllegalStateException");
+ } catch (IllegalStateException expected) {
+ assertEquals(origIsDedicatedAdminVM, DistributionManager.isDedicatedAdminVM);
+ } finally {
+ DistributionManager.isDedicatedAdminVM = origIsDedicatedAdminVM;
+ }
+ } else {
+ try {
+ AdminDistributedSystemFactory.setEnableAdministrationOnly(v);
+ assertEquals(v, DistributionManager.isDedicatedAdminVM);
+ } finally {
+ DistributionManager.isDedicatedAdminVM = origIsDedicatedAdminVM;
+ }
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/AlertLevelJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/AlertLevelJUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/AlertLevelJUnitTest.java
new file mode 100644
index 0000000..e904a57
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/AlertLevelJUnitTest.java
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api;
+
+import static org.apache.geode.internal.Assert.assertTrue;
+import static org.junit.Assert.*;
+
+import java.lang.reflect.Constructor;
+
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.internal.admin.api.AlertLevel;
+import org.apache.geode.test.junit.categories.UnitTest;
+
+/**
+ * AlertLevel Tester.
+ */
+@Category(UnitTest.class)
+public class AlertLevelJUnitTest {
+
+ /**
+ * Method: equals(Object other)
+ */
+
+ private AlertLevel alertLevel1 = AlertLevel.WARNING;
+ private AlertLevel alertLevel2 = AlertLevel.ERROR;
+ private AlertLevel alertLevel3 = AlertLevel.WARNING;
+
+
+ @Test
+ public void testEquals() throws Exception {
+ //TODO: Test goes here...
+ assertTrue(alertLevel1.equals(alertLevel3));
+ assertFalse(alertLevel1.equals(alertLevel2));
+ assertFalse(alertLevel1.equals(null));
+
+ Constructor<AlertLevel> constructor;
+ constructor = AlertLevel.class.getDeclaredConstructor(int.class, String.class);
+ constructor.setAccessible(true);
+ AlertLevel level = constructor.newInstance(AlertLevel.ERROR.getSeverity(), "ERROR");
+ assertEquals(level.getSeverity(), AlertLevel.ERROR.getSeverity());
+
+
+ AlertLevel level1 = constructor.newInstance(AlertLevel.ERROR.getSeverity(), new String("ERROR"));
+ assertEquals(level1.getName(), alertLevel2.getName());
+ assertTrue(level1.equals(alertLevel2));
+
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/BindDistributedSystemJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/BindDistributedSystemJUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/BindDistributedSystemJUnitTest.java
new file mode 100755
index 0000000..c92ff70
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/BindDistributedSystemJUnitTest.java
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api.impl;
+
+import org.apache.geode.distributed.DistributedSystem;
+import org.apache.geode.internal.AvailablePortHelper;
+import org.apache.geode.internal.admin.api.impl.AdminDistributedSystemImpl;
+import org.apache.geode.internal.admin.api.impl.InetAddressUtil;
+import org.apache.geode.test.junit.categories.IntegrationTest;
+import org.junit.After;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.Properties;
+
+import static org.apache.geode.distributed.ConfigurationProperties.BIND_ADDRESS;
+import static org.apache.geode.distributed.ConfigurationProperties.START_LOCATOR;
+import static org.junit.Assert.assertEquals;
+
+/**
+ * Tests {@link AdminDistributedSystemImpl}.
+ *
+ * @created August 30, 2004
+ * @since GemFire 3.5
+ */
+@SuppressWarnings("deprecation")
+@Category(IntegrationTest.class)
+public class BindDistributedSystemJUnitTest {
+
+ private final static int RETRY_ATTEMPTS = 3;
+ private final static int RETRY_SLEEP = 100;
+
+ private DistributedSystem system;
+
+ @After
+ public void tearDown() {
+ if (this.system != null) {
+ this.system.disconnect();
+ }
+ this.system = null;
+ }
+
+// public void testBindToAddressNull() throws Exception {
+// DistributedSystemFactory.bindToAddress(null);
+// todo...
+// }
+//
+// public void testBindToAddressEmpty() throws Exception {
+// DistributedSystemFactory.bindToAddress("");
+// todo...
+// }
+
+ @Test
+ public void testBindToAddressLoopback() throws Exception {
+ String bindTo = "127.0.0.1";
+ // make sure bindTo is the loopback... needs to be later in test...
+ assertEquals(true, InetAddressUtil.isLoopback(bindTo));
+
+ Properties props = new Properties();
+ props.setProperty(BIND_ADDRESS, bindTo);
+ props.setProperty(START_LOCATOR,
+ "localhost["+AvailablePortHelper.getRandomAvailableTCPPort()+"]");
+ this.system = org.apache.geode.distributed.DistributedSystem.connect(
+ props);
+
+ assertEquals(true, this.system.isConnected());
+
+ // Because of fix for bug 31409
+ this.system.disconnect();
+
+ }
+
+
+}
+
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/CacheHealthEvaluatorJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/CacheHealthEvaluatorJUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/CacheHealthEvaluatorJUnitTest.java
new file mode 100644
index 0000000..cc2965b
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/CacheHealthEvaluatorJUnitTest.java
@@ -0,0 +1,208 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api.impl;
+
+import static org.junit.Assert.*;
+
+import org.apache.geode.cache.*;
+import org.apache.geode.internal.admin.api.GemFireHealth;
+import org.apache.geode.internal.admin.api.GemFireHealthConfig;
+import org.apache.geode.internal.cache.*;
+import org.apache.geode.test.junit.categories.IntegrationTest;
+
+import java.util.*;
+
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+import org.junit.rules.TestName;
+
+/**
+ * Contains simple tests for the {@link CacheHealthEvaluator}
+ *
+ *
+ * @since GemFire 3.5
+ */
+@SuppressWarnings("deprecation")
+@Category(IntegrationTest.class)
+public class CacheHealthEvaluatorJUnitTest extends HealthEvaluatorTestCase {
+
+ @Rule
+ public TestName testName = new TestName();
+
+ /**
+ * Tests that we are in {@link GemFireHealth#OKAY_HEALTH okay}
+ * health if cache loads take too long.
+ *
+ * @see CacheHealthEvaluator#checkLoadTime
+ */
+ @Test
+ public void testCheckLoadTime() throws CacheException {
+ Cache cache = CacheFactory.create(this.system);
+ CachePerfStats stats = ((GemFireCacheImpl) cache).getCachePerfStats();
+
+ AttributesFactory factory = new AttributesFactory();
+ factory.setScope(Scope.LOCAL);
+ factory.setCacheLoader(new CacheLoader() {
+ public Object load(LoaderHelper helper)
+ throws CacheLoaderException {
+
+ return "Loaded";
+ }
+
+ public void close() { }
+ });
+
+ RegionAttributes attrs = factory.create();
+ Region region = cache.createRegion(getName(), attrs);
+
+ GemFireHealthConfig config = new GemFireHealthConfigImpl(null);
+ config.setMaxLoadTime(100);
+
+ CacheHealthEvaluator eval =
+ new CacheHealthEvaluator(config, this.system.getDistributionManager());
+ for (int i = 0; i < 10; i++) {
+ region.get("Test1 " + i);
+ }
+ long firstLoadTime = stats.getLoadTime();
+ long firstLoadsCompleted = stats.getLoadsCompleted();
+ assertTrue(firstLoadTime >= 0);
+ assertTrue(firstLoadsCompleted > 0);
+
+ // First time should always be empty
+ List status = new ArrayList();
+ eval.evaluate(status);
+ assertEquals(0, status.size());
+
+ config = new GemFireHealthConfigImpl(null);
+ config.setMaxLoadTime(10);
+ eval = new CacheHealthEvaluator(config,
+ this.system.getDistributionManager());
+ eval.evaluate(status);
+
+ long start = System.currentTimeMillis();
+ for (int i = 0; i < 100; i++) {
+ region.get("Test2 " + i);
+ }
+ assertTrue(System.currentTimeMillis() - start < 1000);
+ long secondLoadTime = stats.getLoadTime();
+ long secondLoadsCompleted = stats.getLoadsCompleted();
+ assertTrue("firstLoadTime=" + firstLoadTime + ", secondLoadTime=" + secondLoadTime, secondLoadTime >= firstLoadTime);
+ assertTrue(secondLoadsCompleted > firstLoadsCompleted);
+
+ // Averge should be less than 10 milliseconds
+ status = new ArrayList();
+ eval.evaluate(status);
+ assertEquals(0, status.size());
+
+ region.getAttributesMutator().setCacheLoader(new CacheLoader() {
+ public Object load(LoaderHelper helper)
+ throws CacheLoaderException {
+
+ try {
+ Thread.sleep(20);
+
+ } catch (InterruptedException ex) {
+ fail("Why was I interrupted?");
+ }
+ return "Loaded";
+ }
+
+ public void close() { }
+
+ });
+
+ for (int i = 0; i < 50; i++) {
+ region.get("Test3 " + i);
+ }
+
+ long thirdLoadTime = stats.getLoadTime();
+ long thirdLoadsCompleted = stats.getLoadsCompleted();
+ assertTrue(thirdLoadTime > secondLoadTime);
+ assertTrue(thirdLoadsCompleted > secondLoadsCompleted);
+
+ status = new ArrayList();
+ eval.evaluate(status);
+ assertEquals(1, status.size());
+
+ AbstractHealthEvaluator.HealthStatus ill =
+ (AbstractHealthEvaluator.HealthStatus) status.get(0);
+ assertEquals(GemFireHealth.OKAY_HEALTH, ill.getHealthCode());
+ String s = "The average duration of a Cache load";
+ assertTrue(ill.getDiagnosis().indexOf(s) != -1);
+ }
+
+ /**
+ * Tests that we are in {@link GemFireHealth#OKAY_HEALTH okay}
+ * health if the hit ratio dips below the threshold.
+ */
+ @Test
+ public void testCheckHitRatio() throws CacheException {
+ Cache cache = CacheFactory.create(this.system);
+// CachePerfStats stats = ((GemFireCache) cache).getCachePerfStats();
+
+ AttributesFactory factory = new AttributesFactory();
+ factory.setScope(Scope.LOCAL);
+ factory.setCacheLoader(new CacheLoader() {
+ public Object load(LoaderHelper helper)
+ throws CacheLoaderException {
+
+ return "Loaded";
+ }
+
+ public void close() { }
+ });
+
+ RegionAttributes attrs = factory.create();
+ Region region = cache.createRegion(getName(), attrs);
+
+ GemFireHealthConfig config = new GemFireHealthConfigImpl(null);
+ config.setMinHitRatio(0.5);
+
+ CacheHealthEvaluator eval =
+ new CacheHealthEvaluator(config,
+ this.system.getDistributionManager());
+ List status = new ArrayList();
+ eval.evaluate(status);
+ assertEquals(0, status.size());
+
+ region.get("One");
+ region.get("One");
+ region.get("One");
+
+ status = new ArrayList();
+ eval.evaluate(status);
+ assertEquals(0, status.size());
+
+ for (int i = 0; i < 50; i++) {
+ region.get("Miss " + i);
+ }
+
+ status = new ArrayList();
+ eval.evaluate(status);
+
+ AbstractHealthEvaluator.HealthStatus ill =
+ (AbstractHealthEvaluator.HealthStatus) status.get(0);
+ assertEquals(GemFireHealth.OKAY_HEALTH, ill.getHealthCode());
+ String s = "The hit ratio of this Cache";
+ assertTrue(ill.getDiagnosis().indexOf(s) != -1);
+ }
+
+ private String getName() {
+ return getClass().getSimpleName()+"_"+testName.getMethodName();
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/DistributedSystemTestCase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/DistributedSystemTestCase.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/DistributedSystemTestCase.java
new file mode 100755
index 0000000..2516484
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/DistributedSystemTestCase.java
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api.impl;
+
+import org.apache.geode.distributed.DistributedSystem;
+import org.junit.After;
+import org.junit.Before;
+
+import java.util.Properties;
+
+import static org.apache.geode.distributed.ConfigurationProperties.*;
+
+/**
+ * Provides common setUp and tearDown for testing the Admin API.
+ *
+ * @since GemFire 3.5
+ */
+public abstract class DistributedSystemTestCase {
+
+ /** The DistributedSystem used for this test */
+ protected DistributedSystem system;
+
+ /**
+ * Creates a "loner" <code>DistributedSystem</code> for this test.
+ */
+ @Before
+ public void setUp() throws Exception {
+ this.system = DistributedSystem.connect(defineProperties());
+ }
+
+ /**
+ * Closes the "loner" <code>DistributedSystem</code>
+ */
+ @After
+ public void tearDown() throws Exception {
+ if (this.system != null) {
+ this.system.disconnect();
+ }
+ this.system = null;
+ }
+
+ /**
+ * Defines the <code>Properties</code> used to connect to the distributed
+ * system.
+ */
+ protected Properties defineProperties() {
+ Properties props = new Properties();
+ props.setProperty(MCAST_PORT, "0");
+ props.setProperty(LOCATORS, "");
+ props.setProperty(CONSERVE_SOCKETS, "true");
+ return props;
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/HealthEvaluatorTestCase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/HealthEvaluatorTestCase.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/HealthEvaluatorTestCase.java
new file mode 100644
index 0000000..abd802e
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/HealthEvaluatorTestCase.java
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api.impl;
+
+import org.apache.geode.distributed.DistributedSystem;
+import org.apache.geode.distributed.internal.InternalDistributedSystem;
+import org.apache.geode.internal.admin.api.impl.AbstractHealthEvaluator;
+
+import org.junit.After;
+import org.junit.Before;
+
+import java.util.Properties;
+
+import static org.apache.geode.distributed.ConfigurationProperties.*;
+
+/**
+ * Superclass of tests for the {@linkplain
+ * AbstractHealthEvaluator health
+ * evaluator} classes.
+ *
+ *
+ * @since GemFire 3.5
+ */
+public abstract class HealthEvaluatorTestCase {
+
+ /** The DistributedSystem used for this test */
+ protected InternalDistributedSystem system;
+
+ /**
+ * Creates a "loner" <code>DistributedSystem</code> for this test.
+ */
+ @Before
+ public void setUp() {
+ Properties props = getProperties();
+ system = (InternalDistributedSystem)
+ DistributedSystem.connect(props);
+ }
+
+ /**
+ * Closes the "loner" <code>DistributedSystem</code>
+ */
+ @After
+ public void tearDown() {
+ if (this.system != null) {
+ this.system.disconnect();
+ }
+
+ this.system = null;
+ }
+
+ /**
+ * Creates the <code>Properties</code> objects used to connect to
+ * the distributed system.
+ */
+ protected Properties getProperties() {
+ Properties props = new Properties();
+ props.setProperty(MCAST_PORT, "0");
+ props.setProperty(LOCATORS, "");
+ props.setProperty(STATISTIC_SAMPLING_ENABLED, "true");
+
+ return props;
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/MemberHealthEvaluatorJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/MemberHealthEvaluatorJUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/MemberHealthEvaluatorJUnitTest.java
new file mode 100644
index 0000000..e3217c7
--- /dev/null
+++ b/geode-core/src/test/java/org/apache/geode/internal/admin/api/impl/MemberHealthEvaluatorJUnitTest.java
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.geode.internal.admin.api.impl;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.internal.admin.api.GemFireHealth;
+import org.apache.geode.internal.admin.api.GemFireHealthConfig;
+import org.apache.geode.internal.statistics.GemFireStatSampler;
+import org.apache.geode.internal.statistics.platform.ProcessStats;
+import org.apache.geode.internal.PureJavaMode;
+import org.apache.geode.test.junit.categories.IntegrationTest;
+
+/**
+ * Contains simple tests for the {@link MemberHealthEvaluator}.
+ *
+ *
+ * @since GemFire 3.5
+ */
+@SuppressWarnings("deprecation")
+@Category(IntegrationTest.class)
+public class MemberHealthEvaluatorJUnitTest extends HealthEvaluatorTestCase {
+
+ /**
+ * Tests that we are in {@link GemFireHealth#OKAY_HEALTH okay}
+ * health if the VM's process size is too big.
+ *
+ * @see MemberHealthEvaluator#checkVMProcessSize
+ */
+ @Test
+ public void testCheckVMProcessSize() throws InterruptedException {
+ if(PureJavaMode.osStatsAreAvailable()) {
+ GemFireStatSampler sampler = system.getStatSampler();
+ assertNotNull(sampler);
+
+ sampler.waitForInitialization(10000); // fix: remove infinite wait
+
+ ProcessStats stats = sampler.getProcessStats();
+ assertNotNull(stats);
+
+ List status = new ArrayList();
+ long threshold = stats.getProcessSize() * 2;
+
+ if (threshold <= 0) {
+ // The process size is zero on some Linux versions
+ return;
+ }
+
+ GemFireHealthConfig config = new GemFireHealthConfigImpl(null);
+ config.setMaxVMProcessSize(threshold);
+
+ MemberHealthEvaluator eval =
+ new MemberHealthEvaluator(config,
+ this.system.getDistributionManager());
+ eval.evaluate(status);
+ assertTrue(status.isEmpty());
+
+ status = new ArrayList();
+ long processSize = stats.getProcessSize();
+ threshold = processSize / 2;
+ assertTrue("Threshold (" + threshold + ") is > 0. " +
+ "Process size is " + processSize,
+ threshold > 0);
+
+ config = new GemFireHealthConfigImpl(null);
+ config.setMaxVMProcessSize(threshold);
+
+ eval = new MemberHealthEvaluator(config,
+ this.system.getDistributionManager());
+ eval.evaluate(status);
+ assertEquals(1, status.size());
+
+ AbstractHealthEvaluator.HealthStatus ill =
+ (AbstractHealthEvaluator.HealthStatus) status.get(0);
+ assertEquals(GemFireHealth.OKAY_HEALTH, ill.getHealthCode());
+ assertTrue(ill.getDiagnosis().indexOf("The size of this VM") != -1);
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/cache/BackupDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/BackupDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/BackupDUnitTest.java
index 7f333a4..265aeaf 100755
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/BackupDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/BackupDUnitTest.java
@@ -21,8 +21,6 @@ import org.junit.Test;
import static org.junit.Assert.*;
-import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase;
-import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase;
import org.apache.geode.test.junit.categories.DistributedTest;
import java.io.BufferedReader;
@@ -40,10 +38,8 @@ import java.util.TreeSet;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;
-import org.apache.geode.GemFireIOException;
-import org.apache.geode.admin.BackupStatus;
-import org.apache.geode.admin.internal.FinishBackupRequest;
-import org.apache.geode.admin.internal.PrepareBackupRequest;
+import org.apache.geode.internal.admin.api.BackupStatus;
+import org.apache.geode.internal.admin.api.impl.PrepareBackupRequest;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.DataPolicy;
import org.apache.geode.cache.DiskStore;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/cache/IncrementalBackupDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/IncrementalBackupDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/IncrementalBackupDUnitTest.java
index 191aa8f..26b1ccf 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/IncrementalBackupDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/IncrementalBackupDUnitTest.java
@@ -34,12 +34,12 @@ import java.util.Set;
import org.junit.Test;
import org.junit.experimental.categories.Category;
-import org.apache.geode.admin.AdminDistributedSystem;
-import org.apache.geode.admin.AdminDistributedSystemFactory;
-import org.apache.geode.admin.AdminException;
-import org.apache.geode.admin.BackupStatus;
-import org.apache.geode.admin.DistributedSystemConfig;
-import org.apache.geode.admin.internal.AdminDistributedSystemImpl;
+import org.apache.geode.internal.admin.api.AdminDistributedSystem;
+import org.apache.geode.internal.admin.api.AdminDistributedSystemFactory;
+import org.apache.geode.internal.admin.api.AdminException;
+import org.apache.geode.internal.admin.api.BackupStatus;
+import org.apache.geode.internal.admin.api.DistributedSystemConfig;
+import org.apache.geode.internal.admin.api.impl.AdminDistributedSystemImpl;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.CacheFactory;
import org.apache.geode.cache.Region;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentColocatedPartitionedRegionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentColocatedPartitionedRegionDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentColocatedPartitionedRegionDUnitTest.java
index 0a25228..c0f4192 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentColocatedPartitionedRegionDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentColocatedPartitionedRegionDUnitTest.java
@@ -18,7 +18,6 @@ package org.apache.geode.internal.cache.partitioned;
import org.junit.experimental.categories.Category;
import org.mockito.ArgumentCaptor;
-import org.mockito.Mockito;
import org.apache.logging.log4j.Level;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.core.Appender;
@@ -36,8 +35,6 @@ import static org.mockito.Mockito.verifyNoMoreInteractions;
import static org.mockito.Mockito.when;
import static org.mockito.Mockito.times;
-import org.apache.geode.test.dunit.cache.internal.JUnit4CacheTestCase;
-import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase;
import org.apache.geode.test.junit.categories.DistributedTest;
import java.io.IOException;
@@ -50,9 +47,8 @@ import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import com.jayway.awaitility.core.ConditionTimeoutException;
-import org.junit.experimental.categories.Category;
-import org.apache.geode.admin.internal.AdminDistributedSystemImpl;
+import org.apache.geode.internal.admin.api.impl.AdminDistributedSystemImpl;
import org.apache.geode.cache.AttributesFactory;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.CacheClosedException;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionTestBase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionTestBase.java b/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionTestBase.java
index 91b0c7f..1aee885 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionTestBase.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionTestBase.java
@@ -30,11 +30,11 @@ import java.util.TreeSet;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
-import org.apache.geode.admin.AdminDistributedSystem;
-import org.apache.geode.admin.AdminDistributedSystemFactory;
-import org.apache.geode.admin.AdminException;
-import org.apache.geode.admin.BackupStatus;
-import org.apache.geode.admin.DistributedSystemConfig;
+import org.apache.geode.internal.admin.api.AdminDistributedSystem;
+import org.apache.geode.internal.admin.api.AdminDistributedSystemFactory;
+import org.apache.geode.internal.admin.api.AdminException;
+import org.apache.geode.internal.admin.api.BackupStatus;
+import org.apache.geode.internal.admin.api.DistributedSystemConfig;
import org.apache.geode.cache.AttributesFactory;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.DataPolicy;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/ShutdownAllDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/ShutdownAllDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/ShutdownAllDUnitTest.java
index d3a2085..6254ff2 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/ShutdownAllDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/ShutdownAllDUnitTest.java
@@ -29,10 +29,10 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.apache.geode.InternalGemFireError;
-import org.apache.geode.admin.AdminDistributedSystemFactory;
-import org.apache.geode.admin.AdminException;
-import org.apache.geode.admin.DistributedSystemConfig;
-import org.apache.geode.admin.internal.AdminDistributedSystemImpl;
+import org.apache.geode.internal.admin.api.AdminDistributedSystemFactory;
+import org.apache.geode.internal.admin.api.AdminException;
+import org.apache.geode.internal.admin.api.DistributedSystemConfig;
+import org.apache.geode.internal.admin.api.impl.AdminDistributedSystemImpl;
import org.apache.geode.cache.AttributesFactory;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.CacheClosedException;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/internal/cache/persistence/PersistentRecoveryOrderDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/persistence/PersistentRecoveryOrderDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/persistence/PersistentRecoveryOrderDUnitTest.java
index 0f39ca4..cac52a6 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/persistence/PersistentRecoveryOrderDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/persistence/PersistentRecoveryOrderDUnitTest.java
@@ -37,10 +37,10 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.apache.geode.DataSerializer;
-import org.apache.geode.admin.AdminDistributedSystem;
-import org.apache.geode.admin.AdminDistributedSystemFactory;
-import org.apache.geode.admin.AdminException;
-import org.apache.geode.admin.DistributedSystemConfig;
+import org.apache.geode.internal.admin.api.AdminDistributedSystem;
+import org.apache.geode.internal.admin.api.AdminDistributedSystemFactory;
+import org.apache.geode.internal.admin.api.AdminException;
+import org.apache.geode.internal.admin.api.DistributedSystemConfig;
import org.apache.geode.cache.AttributesFactory;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.CacheClosedException;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/management/internal/beans/DistributedSystemBridgeJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/beans/DistributedSystemBridgeJUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/beans/DistributedSystemBridgeJUnitTest.java
index a8327a1..5494cb6 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/beans/DistributedSystemBridgeJUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/beans/DistributedSystemBridgeJUnitTest.java
@@ -28,9 +28,9 @@ import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.mockito.InOrder;
-import org.apache.geode.admin.internal.BackupDataStoreHelper;
-import org.apache.geode.admin.internal.FinishBackupRequest;
-import org.apache.geode.admin.internal.PrepareBackupRequest;
+import org.apache.geode.internal.admin.api.impl.BackupDataStoreHelper;
+import org.apache.geode.internal.admin.api.impl.FinishBackupRequest;
+import org.apache.geode.internal.admin.api.impl.PrepareBackupRequest;
import org.apache.geode.distributed.internal.DM;
import org.apache.geode.distributed.internal.locks.DLockService;
import org.apache.geode.internal.cache.GemFireCacheImpl;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/java/org/apache/geode/test/dunit/internal/JUnit4DistributedTestCase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/internal/JUnit4DistributedTestCase.java b/geode-core/src/test/java/org/apache/geode/test/dunit/internal/JUnit4DistributedTestCase.java
index 86971d4..e904d5f 100644
--- a/geode-core/src/test/java/org/apache/geode/test/dunit/internal/JUnit4DistributedTestCase.java
+++ b/geode-core/src/test/java/org/apache/geode/test/dunit/internal/JUnit4DistributedTestCase.java
@@ -33,7 +33,7 @@ import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Rule;
-import org.apache.geode.admin.internal.AdminDistributedSystemImpl;
+import org.apache.geode.internal.admin.api.impl.AdminDistributedSystemImpl;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.Region;
import org.apache.geode.cache.query.QueryTestUtils;
@@ -46,7 +46,6 @@ import org.apache.geode.distributed.DistributedSystem;
import org.apache.geode.distributed.internal.DistributionConfig;
import org.apache.geode.distributed.internal.DistributionMessageObserver;
import org.apache.geode.distributed.internal.InternalDistributedSystem;
-import org.apache.geode.internal.net.SSLConfigurationFactory;
import org.apache.geode.internal.net.SocketCreator;
import org.apache.geode.internal.admin.ClientStatsManager;
import org.apache.geode.internal.cache.DiskStoreObserver;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c0221bed/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
----------------------------------------------------------------------
diff --git a/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt b/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
index 23162e5..2a8e368 100644
--- a/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
+++ b/geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
@@ -1,27 +1,3 @@
-org/apache/geode/admin/RegionSubRegionSnapshot,2
-fromData,62,2a2bb80023b500082a2bb900240100b5000b2a2bb80025b500052ab40005b9002601004d2cb9002701009900132cb900280100c000292ab6001ba7ffeab1
-toData,30,2ab400082bb800202b2ab4000bb9002102002ab40005c000032bb80022b1
-
-org/apache/geode/admin/internal/FinishBackupRequest,2
-fromData,33,2a2bb700292a2bb8002ab500022a2bb8002ab500032a2bb8002bb6002cb50004b1
-toData,33,2a2bb7002d2ab400022bb8002e2ab400032bb8002e2ab40004b8002f2bb80030b1
-
-org/apache/geode/admin/internal/FinishBackupResponse,2
-fromData,14,2a2bb700042a2bb80005b50003b1
-toData,14,2a2bb700062ab400032bb80007b1
-
-org/apache/geode/admin/internal/PrepareBackupResponse,2
-fromData,14,2a2bb700042a2bb80005b50003b1
-toData,14,2a2bb700062ab400032bb80007b1
-
-org/apache/geode/admin/internal/SystemMemberCacheEventProcessor$SystemMemberCacheMessage,2
-fromData,27,2a2bb7001a2a2bb8001bb5000c2a2bb9001c0100b8001db5000fb1
-toData,27,2a2bb7001e2ab4000c2bb8001f2b2ab4000fb40020b900210200b1
-
-org/apache/geode/admin/jmx/internal/StatAlertNotification,2
-fromData,39,2a2bb8002ab600032a2bb8002bb600072a2bb8002cc0002dc0002db600052a2bb8002eb50008b1
-toData,33,2ab600162bb800262ab600202bb800272ab6000e2bb800282ab400082bb80029b1
-
org/apache/geode/cache/ExpirationAttributes,2
fromData,22,2a2bb900120100b500022a2bb80013c00014b50004b1
toData,19,2b2ab40002b9001502002ab400042bb80016b1
@@ -199,9 +175,9 @@ fromData,27,2a2bb7000c2a2bb9000d0100b500032a2bb8000ec0000fb50002b1
toData,24,2a2bb700092b2ab40003b9000a02002ab400022bb8000bb1
org/apache/geode/distributed/internal/StartupMessage,3
-fromDataProblem,38,2ab40039c7000e2abb006759b70068b500392ab400392bb60069572ab40039126ab6006957b1
-fromData,293,2a2bb7006b2a2bb8006cb500092a2bb9006d0100b5000c2a2bb9006e0100b5000d2a2bb9006e0100b500112bb9006d01003d033e1d1ca2003e2bb8006f3a042bb9006d010036051904c6000d19040301011505b80070a700183a062ab2007104bd00225903190653b60026b70072840301a7ffc32bb9006d01003e03360415041da200492bb8006f3a052bb8006f3a062bb9006d010036071905c600121906c6000d19051906150703b80073a700183a082ab2007404bd00225903190853b60026b70072840401a7ffb72a2bb80075c00076b500122a2bb9006d0100b500172a2bb8006cb500182a2bb9006e0100b50019bb006059b700613a0419042bb600772a1904b60078b5000a2a1904b60079b5000b2a1904b6007ab5000e2a1904b6007bb5000fb1
-toData,318,2a2bb7004d2ab400092bb8004e2b2ab4000cb9004f02002b2ab4000db9005002002b2ab40011b900500200b800514d2b2cbeb9004f0200033e1d2cbea2001f2c1d32b600522bb800532b2c1d32b60054b9004f0200840301a7ffe1b800554e2b2dbeb9004f020003360415042dbea200782d150432c100569900302d150432c00056b60057b600583a052d150432c00056b60059b600583a062d150432c00056b6005a3607a700272d150432c0005bb6005c3a052d150432c0005bb6005d3a062d150432c0005bb6005e360719052bb8005319062bb800532b1507b9004f0200840401a7ff872ab400122bb8005f2b2ab40017b9004f02002ab400182bb8004e2b2ab40019b900500200bb006059b700613a0419042ab4000ab6006219042ab4000bb6006319042ab4000eb6006419042ab4000fb6006519042bb60066b1
+fromDataProblem,38,2ab40037c7000e2abb006559b70066b500372ab400372bb60067572ab400371268b6006757b1
+fromData,293,2a2bb700692a2bb8006ab500092a2bb9006b0100b5000c2a2bb9006c0100b5000d2a2bb9006c0100b500112bb9006b01003d033e1d1ca2003e2bb8006d3a042bb9006b010036051904c6000d19040301011505b8006ea700183a062ab2006f04bd00205903190653b60024b70070840301a7ffc32bb9006b01003e03360415041da200492bb8006d3a052bb8006d3a062bb9006b010036071905c600121906c6000d19051906150703b80071a700183a082ab2007204bd00205903190853b60024b70070840401a7ffb72a2bb80073c00074b500122a2bb9006b0100b500172a2bb8006ab500182a2bb9006c0100b50019bb005e59b7005f3a0419042bb600752a1904b60076b5000a2a1904b60077b5000b2a1904b60078b5000e2a1904b60079b5000fb1
+toData,318,2a2bb7004b2ab400092bb8004c2b2ab4000cb9004d02002b2ab4000db9004e02002b2ab40011b9004e0200b8004f4d2b2cbeb9004d0200033e1d2cbea2001f2c1d32b600502bb800512b2c1d32b60052b9004d0200840301a7ffe1b800534e2b2dbeb9004d020003360415042dbea200782d150432c100549900302d150432c00054b60055b600563a052d150432c00054b60057b600563a062d150432c00054b600583607a700272d150432c00059b6005a3a052d150432c00059b6005b3a062d150432c00059b6005c360719052bb8005119062bb800512b1507b9004d0200840401a7ff872ab400122bb8005d2b2ab40017b9004d02002ab400182bb8004c2b2ab40019b9004e0200bb005e59b7005f3a0419042ab4000ab6006019042ab4000bb6006119042ab4000eb6006219042ab4000fb6006319042bb60064b1
org/apache/geode/distributed/internal/StartupResponseMessage,3
fromDataProblem,43,2ab40026c7000e2abb003859b70039b500262ab400262bb6003a572ab40026123b123cb8003db6003a57b1
@@ -293,8 +269,8 @@ toDataPre_GFE_7_1_0_0,226,2ab400139e000704a7000403b800432ab600502bb800982b2ab600
toDataPre_GFE_9_0_0_0,225,2ab600502bb800982b2ab6004fb9009902002ab400062bb8007d033d2ab40029b9007e01009900071c04803d2ab40029b9006d01009900071c05803d2ab4003a9900071c07803d1c1008803d2b1c1100ff7e91b9009a02002b2ab40011b9009902002b2ab40002b9009902002b2ab40013b9009a02002ab400202bb800802ab400182bb8007d2ab40013100da0000e2ab400192bb8007da7000e2ab40014b8009b2bb8007d2ab4001ec700081247a7000a2ab4001eb600812bb8007d2ab4001ec7000911012ca7000a2ab4001eb60082b800832bb800842b2ab4001b04b80085b1
org/apache/geode/distributed/internal/membership/NetView,2
-fromData,98,2a2bb8006ec0002bb500112a2bb9006f0100b500062a2bb80070b50009b200409a00122ab40009c7000bbb004159b70042bf2abb000a592ab40009b7000bb5000c2a2bb80071b5000e2a2bb80071b500102a2bb80072b500052a2bb80073b50004b1
-toData,60,2ab400112bb800682b2ab40006b9006902002a2ab400092bb7006a2ab4000e2bb8006b2ab400102bb8006b2ab400052bb8006c2ab400042bb8006db1
+fromData,98,2a2bb80070c0002db500132a2bb900710100b500082a2bb80072b5000bb200429a00122ab4000bc7000bbb004359b70044bf2abb000c592ab4000bb7000db5000e2a2bb80073b500102a2bb80073b500122a2bb80074b500052a2bb80075b50004b1
+toData,60,2ab400132bb8006a2b2ab40008b9006b02002a2ab4000b2bb7006c2ab400102bb8006d2ab400122bb8006d2ab400052bb8006e2ab400042bb8006fb1
org/apache/geode/distributed/internal/membership/gms/GMSMember,2
fromData,62,2a2bb600472a2bb900480100b500052a2bb900490100b5003b2a2bb900490100b500072a2bb900480100b500062a2bb8004ab500082a2bb8004bb50009b1
@@ -413,6 +389,30 @@ org/apache/geode/internal/admin/ClientMembershipMessage,2
fromData,32,2a2bb7000d2a2bb8000eb500022a2bb8000eb500032a2bb9000f0100b50004b1
toData,32,2a2bb7000a2ab400022bb8000b2ab400032bb8000b2b2ab40004b9000c0200b1
+org/apache/geode/internal/admin/api/RegionSubRegionSnapshot,2
+fromData,62,2a2bb80023b500082a2bb900240100b5000b2a2bb80025b500052ab40005b9002601004d2cb9002701009900132cb900280100c000292ab6001ba7ffeab1
+toData,30,2ab400082bb800202b2ab4000bb9002102002ab40005c000032bb80022b1
+
+org/apache/geode/internal/admin/api/impl/FinishBackupRequest,2
+fromData,33,2a2bb700292a2bb8002ab500022a2bb8002ab500032a2bb8002bb6002cb50004b1
+toData,33,2a2bb7002d2ab400022bb8002e2ab400032bb8002e2ab40004b8002f2bb80030b1
+
+org/apache/geode/internal/admin/api/impl/FinishBackupResponse,2
+fromData,14,2a2bb700042a2bb80005b50003b1
+toData,14,2a2bb700062ab400032bb80007b1
+
+org/apache/geode/internal/admin/api/impl/PrepareBackupResponse,2
+fromData,14,2a2bb700042a2bb80005b50003b1
+toData,14,2a2bb700062ab400032bb80007b1
+
+org/apache/geode/internal/admin/api/impl/SystemMemberCacheEventProcessor$SystemMemberCacheMessage,2
+fromData,27,2a2bb7001a2a2bb8001bb5000c2a2bb9001c0100b8001db5000fb1
+toData,27,2a2bb7001e2ab4000c2bb8001f2b2ab4000fb40020b900210200b1
+
+org/apache/geode/internal/admin/api/jmx/impl/StatAlertNotification,2
+fromData,39,2a2bb8002ab600032a2bb8002bb600072a2bb8002cc0002dc0002db600052a2bb8002eb50008b1
+toData,33,2ab600162bb800262ab600202bb800272ab6000e2bb800282ab400082bb80029b1
+
org/apache/geode/internal/admin/remote/AddHealthListenerRequest,2
fromData,17,2a2bb700102a2bb80011c00012b50007b1
toData,14,2a2bb7000e2ab400072bb8000fb1
@@ -2079,8 +2079,8 @@ fromData,31,2a2bb80019b6001ab500022a2bb8001bb500032a2bb8001cc0001db50004b1
toData,28,2ab40002b800152bb800162ab400032bb800172ab400042bb80018b1
org/apache/geode/management/internal/configuration/domain/XmlEntity,2
-fromData,52,2a2bb8006ab500072a2bb8006bc0006cb500042a2bb8006ab500032a2bb8006ab5001c2a2bb8006ab500062a2bb8006ab50005b1
-toData,49,2ab400072bb800682ab400042bb800692ab400032bb800682ab4001c2bb800682ab400062bb800682ab400052bb80068b1
+fromData,52,2a2bb80065b500072a2bb80066c00067b500042a2bb80065b500032a2bb80065b5001c2a2bb80065b500062a2bb80065b50005b1
+toData,49,2ab400072bb800632ab400042bb800642ab400032bb800632ab4001c2bb800632ab400062bb800632ab400052bb80063b1
org/apache/geode/management/internal/configuration/messages/ConfigurationRequest,2
fromData,73,2a2bb900130100b500052bb9001401003dbb000259b700034e1c9e001f03360415041ca200162d2bb900150100b90009020057840401a7ffea2a2db500042a2bb900140100b50007b1
@@ -2124,7 +2124,7 @@ toData,105,2ab400022bb800112b2ab40003b9001202002b2ab40004b9001202002ab400052bb80
org/apache/geode/pdx/internal/PdxType,2
fromData,109,2a2bb80018b5000c2ab7000e2bb9001901003d2a1c047e99000704a7000403b5000d2a1c057e99000704a7000403b5001b2a2bb9001c0100b5000f2a2bb9001c0100b500102bb8001d3d033e1d1ca2001ebb001459b7001e3a0419042bb6001f2a1904b60015840301a7ffe3b1
-toData,124,2ab4000c2bb8001d033d2ab4000d9900081c0480913d2bb8001e4e2db2001fb600209b000f2ab400189900081c0580913d2b1cb9002102002b2ab4000eb9002202002b2ab4000fb9002202002ab40005b600232bb80024033d1c2ab40005b60023a2001a2ab400051cb60025c000134e2d2bb60026840201a7ffe1b1
+toData,124,2ab4000c2bb80020033d2ab4000d9900081c0480913d2bb800214e2db20022b600239b000f2ab4001b9900081c0580913d2b1cb9002402002b2ab4000fb9002502002b2ab40010b9002502002ab40005b600262bb80027033d1c2ab40005b60026a2001a2ab400051cb60028c000144e2d2bb60029840201a7ffe1b1
org/apache/geode/redis/internal/ByteArrayWrapper,2
fromData,20,2a2bb80006b500022a2ab40002b80003b50004b1