date:20201013

[geode] 01/01: GEM-3093: add some trace code

2020-10-13 Thread zhouxj

This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a commit to branch feature/GEM-3093
in repository https://gitbox.apache.org/repos/asf/geode.git

commit f9a08325533cb5d94072d904305b0f21cc01c6cb
Author: zhouxh 
AuthorDate: Tue Oct 13 22:10:31 2020 -0700

GEM-3093: add some trace code
---
 .../java/org/apache/geode/internal/cache/StateFlushOperation.java   | 1 +
 .../geode/distributed/internal/membership/gms/GMSMembership.java| 6 +-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
 
b/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
index 5f09010..a66803f 100755
--- 
a/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
+++ 
b/geode-core/src/main/java/org/apache/geode/internal/cache/StateFlushOperation.java
@@ -772,6 +772,7 @@ public class StateFlushOperation {
 @Override
 public void memberDeparted(DistributionManager distributionManager,
 final InternalDistributedMember id, final boolean crashed) {
+  logger.info("GGG:StateFlushReplyProcesssor.memberDeparted:id=" + id);
   super.memberDeparted(distributionManager, id, crashed);
 }
 
diff --git 
a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
 
b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
index db2ecae..97f26cc 100644
--- 
a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
+++ 
b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/GMSMembership.java
@@ -688,6 +688,8 @@ public class GMSMembership 
implements Membership

[geode] branch feature/GEM-3093 created (now f9a0832)

2020-10-13 Thread zhouxj

This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a change to branch feature/GEM-3093
in repository https://gitbox.apache.org/repos/asf/geode.git.


  at f9a0832  GEM-3093: add some trace code

This branch includes the following new commits:

 new f9a0832  GEM-3093: add some trace code

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] branch feature/GEODE-7665 updated: GEODE-7845: Adding a cleaner simpler test. (#5622)

2020-10-13 Thread mhanson

This is an automated email from the ASF dual-hosted git repository.

mhanson pushed a commit to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-7665 by this 
push:
 new 41bd59b  GEODE-7845: Adding a cleaner simpler test. (#5622)
41bd59b is described below

commit 41bd59ba62fa6c64c4a7a99e7ac80bec3644ef22
Author: mhansonp 
AuthorDate: Tue Oct 13 17:09:03 2020 -0700

GEODE-7845: Adding a cleaner simpler test. (#5622)

- Changed the test for ServerVersionMismatchException to be more readable.
---
 ...ionRegionClearMixedServerPartitionedRegion.java | 412 -
 ...ePartitionRegionClearServerVersionMismatch.java | 174 +
 2 files changed, 174 insertions(+), 412 deletions(-)

diff --git 
a/geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradePartitionRegionClearMixedServerPartitionedRegion.java
 
b/geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradePartitionRegionClearMixedServerPartitionedRegion.java
deleted file mode 100644
index bfcd651..000
--- 
a/geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradePartitionRegionClearMixedServerPartitionedRegion.java
+++ /dev/null
@@ -1,412 +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.internal.cache.rollingupgrade;
-
-import static org.assertj.core.api.Assertions.assertThat;
-import static org.assertj.core.api.Assertions.catchThrowable;
-
-import java.io.File;
-import java.lang.reflect.Constructor;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.List;
-import java.util.Properties;
-
-import org.apache.commons.io.FileUtils;
-import org.apache.logging.log4j.Logger;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameter;
-import org.junit.runners.Parameterized.Parameters;
-import org.junit.runners.Parameterized.UseParametersRunnerFactory;
-
-import org.apache.geode.cache.Cache;
-import org.apache.geode.cache.CacheFactory;
-import org.apache.geode.cache.GemFireCache;
-import org.apache.geode.cache.Region;
-import org.apache.geode.cache.RegionFactory;
-import org.apache.geode.cache.RegionShortcut;
-import org.apache.geode.cache.ServerVersionMismatchException;
-import org.apache.geode.cache.client.ClientCache;
-import org.apache.geode.cache.client.ClientCacheFactory;
-import org.apache.geode.cache.client.ClientRegionShortcut;
-import org.apache.geode.cache.client.ServerOperationException;
-import org.apache.geode.cache.server.CacheServer;
-import org.apache.geode.distributed.DistributedSystem;
-import org.apache.geode.distributed.internal.DistributionConfig;
-import 
org.apache.geode.distributed.internal.membership.InternalDistributedMember;
-import org.apache.geode.internal.AvailablePortHelper;
-import org.apache.geode.internal.cache.GemFireCacheImpl;
-import org.apache.geode.internal.cache.PartitionedRegion;
-import org.apache.geode.logging.internal.log4j.api.LogService;
-import org.apache.geode.test.dunit.DistributedTestUtils;
-import org.apache.geode.test.dunit.Host;
-import org.apache.geode.test.dunit.IgnoredException;
-import org.apache.geode.test.dunit.Invoke;
-import org.apache.geode.test.dunit.NetworkUtils;
-import org.apache.geode.test.dunit.VM;
-import org.apache.geode.test.dunit.internal.DUnitLauncher;
-import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase;
-import 
org.apache.geode.test.junit.runners.CategoryWithParameterizedRunnerFactory;
-import org.apache.geode.test.version.VersionManager;
-
-@RunWith(Parameterized.class)
-@UseParametersRunnerFactory(CategoryWithParameterizedRunnerFactory.class)
-public class RollingUpgradePartitionRegionClearMixedServerPartitionedRegion
-extends JUnit4DistributedTestCase {
-
-  protected static final Logger logger = LogService.getLogger();
-  protected static GemFireCache cache;
-  protected static ClientCache clientcache;
-
-  @Parameter
-  public String oldVersion;
-
-  @Parameters(name = "from_v{0}")
-  public static Collection data() {
-

[geode] branch feature/GEODE-7665 updated: GEODE-7845: Adding a cleaner simpler test. (#5622)

2020-10-13 Thread mhanson

This is an automated email from the ASF dual-hosted git repository.

mhanson pushed a commit to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-7665 by this 
push:
 new 41bd59b  GEODE-7845: Adding a cleaner simpler test. (#5622)
41bd59b is described below

commit 41bd59ba62fa6c64c4a7a99e7ac80bec3644ef22
Author: mhansonp 
AuthorDate: Tue Oct 13 17:09:03 2020 -0700

GEODE-7845: Adding a cleaner simpler test. (#5622)

- Changed the test for ServerVersionMismatchException to be more readable.
---
 ...ionRegionClearMixedServerPartitionedRegion.java | 412 -
 ...ePartitionRegionClearServerVersionMismatch.java | 174 +
 2 files changed, 174 insertions(+), 412 deletions(-)

diff --git 
a/geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradePartitionRegionClearMixedServerPartitionedRegion.java
 
b/geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradePartitionRegionClearMixedServerPartitionedRegion.java
deleted file mode 100644
index bfcd651..000
--- 
a/geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradePartitionRegionClearMixedServerPartitionedRegion.java
+++ /dev/null
@@ -1,412 +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.internal.cache.rollingupgrade;
-
-import static org.assertj.core.api.Assertions.assertThat;
-import static org.assertj.core.api.Assertions.catchThrowable;
-
-import java.io.File;
-import java.lang.reflect.Constructor;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.List;
-import java.util.Properties;
-
-import org.apache.commons.io.FileUtils;
-import org.apache.logging.log4j.Logger;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.junit.runners.Parameterized.Parameter;
-import org.junit.runners.Parameterized.Parameters;
-import org.junit.runners.Parameterized.UseParametersRunnerFactory;
-
-import org.apache.geode.cache.Cache;
-import org.apache.geode.cache.CacheFactory;
-import org.apache.geode.cache.GemFireCache;
-import org.apache.geode.cache.Region;
-import org.apache.geode.cache.RegionFactory;
-import org.apache.geode.cache.RegionShortcut;
-import org.apache.geode.cache.ServerVersionMismatchException;
-import org.apache.geode.cache.client.ClientCache;
-import org.apache.geode.cache.client.ClientCacheFactory;
-import org.apache.geode.cache.client.ClientRegionShortcut;
-import org.apache.geode.cache.client.ServerOperationException;
-import org.apache.geode.cache.server.CacheServer;
-import org.apache.geode.distributed.DistributedSystem;
-import org.apache.geode.distributed.internal.DistributionConfig;
-import 
org.apache.geode.distributed.internal.membership.InternalDistributedMember;
-import org.apache.geode.internal.AvailablePortHelper;
-import org.apache.geode.internal.cache.GemFireCacheImpl;
-import org.apache.geode.internal.cache.PartitionedRegion;
-import org.apache.geode.logging.internal.log4j.api.LogService;
-import org.apache.geode.test.dunit.DistributedTestUtils;
-import org.apache.geode.test.dunit.Host;
-import org.apache.geode.test.dunit.IgnoredException;
-import org.apache.geode.test.dunit.Invoke;
-import org.apache.geode.test.dunit.NetworkUtils;
-import org.apache.geode.test.dunit.VM;
-import org.apache.geode.test.dunit.internal.DUnitLauncher;
-import org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase;
-import 
org.apache.geode.test.junit.runners.CategoryWithParameterizedRunnerFactory;
-import org.apache.geode.test.version.VersionManager;
-
-@RunWith(Parameterized.class)
-@UseParametersRunnerFactory(CategoryWithParameterizedRunnerFactory.class)
-public class RollingUpgradePartitionRegionClearMixedServerPartitionedRegion
-extends JUnit4DistributedTestCase {
-
-  protected static final Logger logger = LogService.getLogger();
-  protected static GemFireCache cache;
-  protected static ClientCache clientcache;
-
-  @Parameter
-  public String oldVersion;
-
-  @Parameters(name = "from_v{0}")
-  public static Collection data() {
-

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

2020-10-13 Thread boglesby

This is an automated email from the ASF dual-hosted git repository.

boglesby pushed a change to branch feature/GEODE-8324
in repository https://gitbox.apache.org/repos/asf/geode.git.


 discard 514b17a  GEODE-8324: Don't add a remote ds id to recipients unless it 
is running
 add ee9a4b0  GEODE-8259: when client singlehop getAll encountered 
SerializationException, it should retry (#5253)
 add ffeabe0  GEODE-8239 - Add gradle config to add 'Class-Path' and 
'Dependent-Modules' attirbutes to manifest file. (#5317)
 add fdc4401  GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
 add 5e6c9e9  GEODE-8250: Create new custom log config acceptance tests 
(#5309)
 add 54a21c5  GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
 add ee13af8  GEODE-8327: buildSrc depends directly on guava. Declare it. 
Misc other build fixups (#5339)
 add 7badfc7  GEODE-8332: Refactor inregion classes (#5320)
 add 625a204  GEODE-8323: Process QueueRemovalMessage after queue 
initialized. (#5333)
 add 868d4bc  GEODE-8330: Structural Improvements to Versioning
 add 13d17ec  GEODE-8313: Improve RedisData synchronization for toData 
(#5318)
 add 9d7d467  GEODE-8341: Correct docs typo in gfsh export logs (#5352)
 add fae1c94  GEODE-7956: Correct documentation of legal region names 
(format fix) (#5362)
 add 62ee81f  GEODE-8346: Add try/catch around Entry.getValue in 
CompiledComparison (#5359)
 add daa70d7  GEODE-8347: use same benchmarks branch as geode branch, since 
that's the way we release (#5361)
 add 8c35d9c  GEODE-8302: Fixed 'events not queued conflated' stats when 
group-tran… (#5313)
 add 426b9de  GEODE-8200: Rebalance operations stuck in "IN_PROGRESS" state 
forever (#5350)
 add 25bb3b5  GEODE-8338: change redis commands not be repeated when a 
server dies (#5351)
 add 9cd8e7d  GEODE-8326: remove 5 minutes wait to get stack dump (#5358)
 add c41e3b4  GEODE-8355: add `public: true` to the test job in 
long-running-test (#5366)
 add 1ebd307  GEODE-8351: DUnit tests for Delta Propagation (#5364)
 add 0a5a629  GEODE-8348: Add benchmarks EC2 image builder job. (#5367)
 add 0f16c0f  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5375)
 add 86e3266  GEODE-8358: Run Geode Redis session tests against native 
Redis (#5373)
 add 85ab541  GEODE-8359 (#5371)
 add 28fb073  GEODE-8365: Redis Delta not propagating updated hash values 
properly (#5377)
 add 4b84af3  GEODE-2113: User Guide - p2p.HANDSHAKE_POOL_SIZE is obsolete, 
remove from docs (#5383)
 add 17d6679  GEODE-8337: git mv Version.java->KnownVersion.java
 add 2a3b609  GEODE-8337: git mv VersionOrdinal.java->Version.java
 add fd76cc0  GEODE-8298: Fix multicast version detection (#5370)
 add 25c15e9  GEODE-8369: Do not build docker images on Windows for 
geode-assembly:acceptanceTest (#5384)
 add 1067f45  GEODE-8363: Label Micrometer docs as experimental (#5386)
 add 6fa5dcb  GEODE-7628: Block jmx mbean creation when no security manager 
is configured (docs) (#5387)
 add 4b91664  GEODE-8362: add redis tests that access binary data (#5374)
 add 5365651  GEODE-8371: Move ClassGraph to MIT License (#5388)
 add 2a2c2aa  GEODE-8370: Add test for maxInactiveInterval (#5385)
 add 78e182e  Revert "GEODE-8298: Fix multicast version detection (#5370)"
 add 12f393d  Revert "GEODE-8337: git mv VersionOrdinal.java->Version.java"
 add 76a034b  Revert "GEODE-8337: git mv Version.java->KnownVersion.java"
 add 6a0e2bc  GEODE-8377: User Guide: GFSH GC command should be documented 
... (#5396)
 add f962632  GEODE-8366: Compared the input region's data policy to the 
sender instead of the leader region's
 add a4306dc  GEODE-8316: move RollingUpgradeWithGfshDUnitTest to 
geode-assembly since it needs to do installDist first. (#5394)
 add a322434  GEODE-8375: No-op test to run Redis server for Geode for 
local development (#5392)
 add c3cefe1  GEODE-8381: User Guide - Reformat table in REST command 
description (#5398)
 add 067194e  GEODE-8333: Fix PUBSUB hang (#5349)
 add 1469eb7  For CI test runs, split the assemble and test invocation, to 
set max-test-workers
 add ce5e315  GEODE-8383: User Guide - add "Client" to 
ssl-enabled-component property table (#5401)
 add ee6b3a9  Revert "For CI test runs, split the assemble and test 
invocation, to set max-test-workers" (#5407)
 add e705128  GEODE-7864: Fix several LGTM warnings (#5400)
 add 08316aa  GEODE-8385: hang recovering from disk with cyclic 
dependencies (#5403)
 add de6ab7a  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5408)
 add 4cea862  GEODE-8331: allow GFSH to connect to other versions of 
cluster (doc correction) (#5410)
 add 95bba9a  Revert "GEODE-8333: Fix PUBSUB hang (#5349)" (#5415)
 add 1f1bd1a  GEODE-8372: Configure CMS to send UTF-8 regardless of JVM 
default (#5411)
 add

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

2020-10-13 Thread boglesby

This is an automated email from the ASF dual-hosted git repository.

boglesby pushed a change to branch feature/GEODE-8324
in repository https://gitbox.apache.org/repos/asf/geode.git.


 discard 514b17a  GEODE-8324: Don't add a remote ds id to recipients unless it 
is running
 add ee9a4b0  GEODE-8259: when client singlehop getAll encountered 
SerializationException, it should retry (#5253)
 add ffeabe0  GEODE-8239 - Add gradle config to add 'Class-Path' and 
'Dependent-Modules' attirbutes to manifest file. (#5317)
 add fdc4401  GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
 add 5e6c9e9  GEODE-8250: Create new custom log config acceptance tests 
(#5309)
 add 54a21c5  GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
 add ee13af8  GEODE-8327: buildSrc depends directly on guava. Declare it. 
Misc other build fixups (#5339)
 add 7badfc7  GEODE-8332: Refactor inregion classes (#5320)
 add 625a204  GEODE-8323: Process QueueRemovalMessage after queue 
initialized. (#5333)
 add 868d4bc  GEODE-8330: Structural Improvements to Versioning
 add 13d17ec  GEODE-8313: Improve RedisData synchronization for toData 
(#5318)
 add 9d7d467  GEODE-8341: Correct docs typo in gfsh export logs (#5352)
 add fae1c94  GEODE-7956: Correct documentation of legal region names 
(format fix) (#5362)
 add 62ee81f  GEODE-8346: Add try/catch around Entry.getValue in 
CompiledComparison (#5359)
 add daa70d7  GEODE-8347: use same benchmarks branch as geode branch, since 
that's the way we release (#5361)
 add 8c35d9c  GEODE-8302: Fixed 'events not queued conflated' stats when 
group-tran… (#5313)
 add 426b9de  GEODE-8200: Rebalance operations stuck in "IN_PROGRESS" state 
forever (#5350)
 add 25bb3b5  GEODE-8338: change redis commands not be repeated when a 
server dies (#5351)
 add 9cd8e7d  GEODE-8326: remove 5 minutes wait to get stack dump (#5358)
 add c41e3b4  GEODE-8355: add `public: true` to the test job in 
long-running-test (#5366)
 add 1ebd307  GEODE-8351: DUnit tests for Delta Propagation (#5364)
 add 0a5a629  GEODE-8348: Add benchmarks EC2 image builder job. (#5367)
 add 0f16c0f  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5375)
 add 86e3266  GEODE-8358: Run Geode Redis session tests against native 
Redis (#5373)
 add 85ab541  GEODE-8359 (#5371)
 add 28fb073  GEODE-8365: Redis Delta not propagating updated hash values 
properly (#5377)
 add 4b84af3  GEODE-2113: User Guide - p2p.HANDSHAKE_POOL_SIZE is obsolete, 
remove from docs (#5383)
 add 17d6679  GEODE-8337: git mv Version.java->KnownVersion.java
 add 2a3b609  GEODE-8337: git mv VersionOrdinal.java->Version.java
 add fd76cc0  GEODE-8298: Fix multicast version detection (#5370)
 add 25c15e9  GEODE-8369: Do not build docker images on Windows for 
geode-assembly:acceptanceTest (#5384)
 add 1067f45  GEODE-8363: Label Micrometer docs as experimental (#5386)
 add 6fa5dcb  GEODE-7628: Block jmx mbean creation when no security manager 
is configured (docs) (#5387)
 add 4b91664  GEODE-8362: add redis tests that access binary data (#5374)
 add 5365651  GEODE-8371: Move ClassGraph to MIT License (#5388)
 add 2a2c2aa  GEODE-8370: Add test for maxInactiveInterval (#5385)
 add 78e182e  Revert "GEODE-8298: Fix multicast version detection (#5370)"
 add 12f393d  Revert "GEODE-8337: git mv VersionOrdinal.java->Version.java"
 add 76a034b  Revert "GEODE-8337: git mv Version.java->KnownVersion.java"
 add 6a0e2bc  GEODE-8377: User Guide: GFSH GC command should be documented 
... (#5396)
 add f962632  GEODE-8366: Compared the input region's data policy to the 
sender instead of the leader region's
 add a4306dc  GEODE-8316: move RollingUpgradeWithGfshDUnitTest to 
geode-assembly since it needs to do installDist first. (#5394)
 add a322434  GEODE-8375: No-op test to run Redis server for Geode for 
local development (#5392)
 add c3cefe1  GEODE-8381: User Guide - Reformat table in REST command 
description (#5398)
 add 067194e  GEODE-8333: Fix PUBSUB hang (#5349)
 add 1469eb7  For CI test runs, split the assemble and test invocation, to 
set max-test-workers
 add ce5e315  GEODE-8383: User Guide - add "Client" to 
ssl-enabled-component property table (#5401)
 add ee6b3a9  Revert "For CI test runs, split the assemble and test 
invocation, to set max-test-workers" (#5407)
 add e705128  GEODE-7864: Fix several LGTM warnings (#5400)
 add 08316aa  GEODE-8385: hang recovering from disk with cyclic 
dependencies (#5403)
 add de6ab7a  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5408)
 add 4cea862  GEODE-8331: allow GFSH to connect to other versions of 
cluster (doc correction) (#5410)
 add 95bba9a  Revert "GEODE-8333: Fix PUBSUB hang (#5349)" (#5415)
 add 1f1bd1a  GEODE-8372: Configure CMS to send UTF-8 regardless of JVM 
default (#5411)
 add

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

2020-10-13 Thread boglesby

This is an automated email from the ASF dual-hosted git repository.

boglesby pushed a change to branch feature/GEODE-8324
in repository https://gitbox.apache.org/repos/asf/geode.git.


 discard 514b17a  GEODE-8324: Don't add a remote ds id to recipients unless it 
is running
 add ee9a4b0  GEODE-8259: when client singlehop getAll encountered 
SerializationException, it should retry (#5253)
 add ffeabe0  GEODE-8239 - Add gradle config to add 'Class-Path' and 
'Dependent-Modules' attirbutes to manifest file. (#5317)
 add fdc4401  GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
 add 5e6c9e9  GEODE-8250: Create new custom log config acceptance tests 
(#5309)
 add 54a21c5  GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
 add ee13af8  GEODE-8327: buildSrc depends directly on guava. Declare it. 
Misc other build fixups (#5339)
 add 7badfc7  GEODE-8332: Refactor inregion classes (#5320)
 add 625a204  GEODE-8323: Process QueueRemovalMessage after queue 
initialized. (#5333)
 add 868d4bc  GEODE-8330: Structural Improvements to Versioning
 add 13d17ec  GEODE-8313: Improve RedisData synchronization for toData 
(#5318)
 add 9d7d467  GEODE-8341: Correct docs typo in gfsh export logs (#5352)
 add fae1c94  GEODE-7956: Correct documentation of legal region names 
(format fix) (#5362)
 add 62ee81f  GEODE-8346: Add try/catch around Entry.getValue in 
CompiledComparison (#5359)
 add daa70d7  GEODE-8347: use same benchmarks branch as geode branch, since 
that's the way we release (#5361)
 add 8c35d9c  GEODE-8302: Fixed 'events not queued conflated' stats when 
group-tran… (#5313)
 add 426b9de  GEODE-8200: Rebalance operations stuck in "IN_PROGRESS" state 
forever (#5350)
 add 25bb3b5  GEODE-8338: change redis commands not be repeated when a 
server dies (#5351)
 add 9cd8e7d  GEODE-8326: remove 5 minutes wait to get stack dump (#5358)
 add c41e3b4  GEODE-8355: add `public: true` to the test job in 
long-running-test (#5366)
 add 1ebd307  GEODE-8351: DUnit tests for Delta Propagation (#5364)
 add 0a5a629  GEODE-8348: Add benchmarks EC2 image builder job. (#5367)
 add 0f16c0f  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5375)
 add 86e3266  GEODE-8358: Run Geode Redis session tests against native 
Redis (#5373)
 add 85ab541  GEODE-8359 (#5371)
 add 28fb073  GEODE-8365: Redis Delta not propagating updated hash values 
properly (#5377)
 add 4b84af3  GEODE-2113: User Guide - p2p.HANDSHAKE_POOL_SIZE is obsolete, 
remove from docs (#5383)
 add 17d6679  GEODE-8337: git mv Version.java->KnownVersion.java
 add 2a3b609  GEODE-8337: git mv VersionOrdinal.java->Version.java
 add fd76cc0  GEODE-8298: Fix multicast version detection (#5370)
 add 25c15e9  GEODE-8369: Do not build docker images on Windows for 
geode-assembly:acceptanceTest (#5384)
 add 1067f45  GEODE-8363: Label Micrometer docs as experimental (#5386)
 add 6fa5dcb  GEODE-7628: Block jmx mbean creation when no security manager 
is configured (docs) (#5387)
 add 4b91664  GEODE-8362: add redis tests that access binary data (#5374)
 add 5365651  GEODE-8371: Move ClassGraph to MIT License (#5388)
 add 2a2c2aa  GEODE-8370: Add test for maxInactiveInterval (#5385)
 add 78e182e  Revert "GEODE-8298: Fix multicast version detection (#5370)"
 add 12f393d  Revert "GEODE-8337: git mv VersionOrdinal.java->Version.java"
 add 76a034b  Revert "GEODE-8337: git mv Version.java->KnownVersion.java"
 add 6a0e2bc  GEODE-8377: User Guide: GFSH GC command should be documented 
... (#5396)
 add f962632  GEODE-8366: Compared the input region's data policy to the 
sender instead of the leader region's
 add a4306dc  GEODE-8316: move RollingUpgradeWithGfshDUnitTest to 
geode-assembly since it needs to do installDist first. (#5394)
 add a322434  GEODE-8375: No-op test to run Redis server for Geode for 
local development (#5392)
 add c3cefe1  GEODE-8381: User Guide - Reformat table in REST command 
description (#5398)
 add 067194e  GEODE-8333: Fix PUBSUB hang (#5349)
 add 1469eb7  For CI test runs, split the assemble and test invocation, to 
set max-test-workers
 add ce5e315  GEODE-8383: User Guide - add "Client" to 
ssl-enabled-component property table (#5401)
 add ee6b3a9  Revert "For CI test runs, split the assemble and test 
invocation, to set max-test-workers" (#5407)
 add e705128  GEODE-7864: Fix several LGTM warnings (#5400)
 add 08316aa  GEODE-8385: hang recovering from disk with cyclic 
dependencies (#5403)
 add de6ab7a  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5408)
 add 4cea862  GEODE-8331: allow GFSH to connect to other versions of 
cluster (doc correction) (#5410)
 add 95bba9a  Revert "GEODE-8333: Fix PUBSUB hang (#5349)" (#5415)
 add 1f1bd1a  GEODE-8372: Configure CMS to send UTF-8 regardless of JVM 
default (#5411)
 add

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

2020-10-13 Thread boglesby

This is an automated email from the ASF dual-hosted git repository.

boglesby pushed a change to branch feature/GEODE-8324
in repository https://gitbox.apache.org/repos/asf/geode.git.


 discard 514b17a  GEODE-8324: Don't add a remote ds id to recipients unless it 
is running
 add ee9a4b0  GEODE-8259: when client singlehop getAll encountered 
SerializationException, it should retry (#5253)
 add ffeabe0  GEODE-8239 - Add gradle config to add 'Class-Path' and 
'Dependent-Modules' attirbutes to manifest file. (#5317)
 add fdc4401  GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
 add 5e6c9e9  GEODE-8250: Create new custom log config acceptance tests 
(#5309)
 add 54a21c5  GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
 add ee13af8  GEODE-8327: buildSrc depends directly on guava. Declare it. 
Misc other build fixups (#5339)
 add 7badfc7  GEODE-8332: Refactor inregion classes (#5320)
 add 625a204  GEODE-8323: Process QueueRemovalMessage after queue 
initialized. (#5333)
 add 868d4bc  GEODE-8330: Structural Improvements to Versioning
 add 13d17ec  GEODE-8313: Improve RedisData synchronization for toData 
(#5318)
 add 9d7d467  GEODE-8341: Correct docs typo in gfsh export logs (#5352)
 add fae1c94  GEODE-7956: Correct documentation of legal region names 
(format fix) (#5362)
 add 62ee81f  GEODE-8346: Add try/catch around Entry.getValue in 
CompiledComparison (#5359)
 add daa70d7  GEODE-8347: use same benchmarks branch as geode branch, since 
that's the way we release (#5361)
 add 8c35d9c  GEODE-8302: Fixed 'events not queued conflated' stats when 
group-tran… (#5313)
 add 426b9de  GEODE-8200: Rebalance operations stuck in "IN_PROGRESS" state 
forever (#5350)
 add 25bb3b5  GEODE-8338: change redis commands not be repeated when a 
server dies (#5351)
 add 9cd8e7d  GEODE-8326: remove 5 minutes wait to get stack dump (#5358)
 add c41e3b4  GEODE-8355: add `public: true` to the test job in 
long-running-test (#5366)
 add 1ebd307  GEODE-8351: DUnit tests for Delta Propagation (#5364)
 add 0a5a629  GEODE-8348: Add benchmarks EC2 image builder job. (#5367)
 add 0f16c0f  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5375)
 add 86e3266  GEODE-8358: Run Geode Redis session tests against native 
Redis (#5373)
 add 85ab541  GEODE-8359 (#5371)
 add 28fb073  GEODE-8365: Redis Delta not propagating updated hash values 
properly (#5377)
 add 4b84af3  GEODE-2113: User Guide - p2p.HANDSHAKE_POOL_SIZE is obsolete, 
remove from docs (#5383)
 add 17d6679  GEODE-8337: git mv Version.java->KnownVersion.java
 add 2a3b609  GEODE-8337: git mv VersionOrdinal.java->Version.java
 add fd76cc0  GEODE-8298: Fix multicast version detection (#5370)
 add 25c15e9  GEODE-8369: Do not build docker images on Windows for 
geode-assembly:acceptanceTest (#5384)
 add 1067f45  GEODE-8363: Label Micrometer docs as experimental (#5386)
 add 6fa5dcb  GEODE-7628: Block jmx mbean creation when no security manager 
is configured (docs) (#5387)
 add 4b91664  GEODE-8362: add redis tests that access binary data (#5374)
 add 5365651  GEODE-8371: Move ClassGraph to MIT License (#5388)
 add 2a2c2aa  GEODE-8370: Add test for maxInactiveInterval (#5385)
 add 78e182e  Revert "GEODE-8298: Fix multicast version detection (#5370)"
 add 12f393d  Revert "GEODE-8337: git mv VersionOrdinal.java->Version.java"
 add 76a034b  Revert "GEODE-8337: git mv Version.java->KnownVersion.java"
 add 6a0e2bc  GEODE-8377: User Guide: GFSH GC command should be documented 
... (#5396)
 add f962632  GEODE-8366: Compared the input region's data policy to the 
sender instead of the leader region's
 add a4306dc  GEODE-8316: move RollingUpgradeWithGfshDUnitTest to 
geode-assembly since it needs to do installDist first. (#5394)
 add a322434  GEODE-8375: No-op test to run Redis server for Geode for 
local development (#5392)
 add c3cefe1  GEODE-8381: User Guide - Reformat table in REST command 
description (#5398)
 add 067194e  GEODE-8333: Fix PUBSUB hang (#5349)
 add 1469eb7  For CI test runs, split the assemble and test invocation, to 
set max-test-workers
 add ce5e315  GEODE-8383: User Guide - add "Client" to 
ssl-enabled-component property table (#5401)
 add ee6b3a9  Revert "For CI test runs, split the assemble and test 
invocation, to set max-test-workers" (#5407)
 add e705128  GEODE-7864: Fix several LGTM warnings (#5400)
 add 08316aa  GEODE-8385: hang recovering from disk with cyclic 
dependencies (#5403)
 add de6ab7a  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5408)
 add 4cea862  GEODE-8331: allow GFSH to connect to other versions of 
cluster (doc correction) (#5410)
 add 95bba9a  Revert "GEODE-8333: Fix PUBSUB hang (#5349)" (#5415)
 add 1f1bd1a  GEODE-8372: Configure CMS to send UTF-8 regardless of JVM 
default (#5411)
 add

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

2020-10-13 Thread boglesby

This is an automated email from the ASF dual-hosted git repository.

boglesby pushed a change to branch feature/GEODE-8324
in repository https://gitbox.apache.org/repos/asf/geode.git.


 discard 514b17a  GEODE-8324: Don't add a remote ds id to recipients unless it 
is running
 add ee9a4b0  GEODE-8259: when client singlehop getAll encountered 
SerializationException, it should retry (#5253)
 add ffeabe0  GEODE-8239 - Add gradle config to add 'Class-Path' and 
'Dependent-Modules' attirbutes to manifest file. (#5317)
 add fdc4401  GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
 add 5e6c9e9  GEODE-8250: Create new custom log config acceptance tests 
(#5309)
 add 54a21c5  GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
 add ee13af8  GEODE-8327: buildSrc depends directly on guava. Declare it. 
Misc other build fixups (#5339)
 add 7badfc7  GEODE-8332: Refactor inregion classes (#5320)
 add 625a204  GEODE-8323: Process QueueRemovalMessage after queue 
initialized. (#5333)
 add 868d4bc  GEODE-8330: Structural Improvements to Versioning
 add 13d17ec  GEODE-8313: Improve RedisData synchronization for toData 
(#5318)
 add 9d7d467  GEODE-8341: Correct docs typo in gfsh export logs (#5352)
 add fae1c94  GEODE-7956: Correct documentation of legal region names 
(format fix) (#5362)
 add 62ee81f  GEODE-8346: Add try/catch around Entry.getValue in 
CompiledComparison (#5359)
 add daa70d7  GEODE-8347: use same benchmarks branch as geode branch, since 
that's the way we release (#5361)
 add 8c35d9c  GEODE-8302: Fixed 'events not queued conflated' stats when 
group-tran… (#5313)
 add 426b9de  GEODE-8200: Rebalance operations stuck in "IN_PROGRESS" state 
forever (#5350)
 add 25bb3b5  GEODE-8338: change redis commands not be repeated when a 
server dies (#5351)
 add 9cd8e7d  GEODE-8326: remove 5 minutes wait to get stack dump (#5358)
 add c41e3b4  GEODE-8355: add `public: true` to the test job in 
long-running-test (#5366)
 add 1ebd307  GEODE-8351: DUnit tests for Delta Propagation (#5364)
 add 0a5a629  GEODE-8348: Add benchmarks EC2 image builder job. (#5367)
 add 0f16c0f  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5375)
 add 86e3266  GEODE-8358: Run Geode Redis session tests against native 
Redis (#5373)
 add 85ab541  GEODE-8359 (#5371)
 add 28fb073  GEODE-8365: Redis Delta not propagating updated hash values 
properly (#5377)
 add 4b84af3  GEODE-2113: User Guide - p2p.HANDSHAKE_POOL_SIZE is obsolete, 
remove from docs (#5383)
 add 17d6679  GEODE-8337: git mv Version.java->KnownVersion.java
 add 2a3b609  GEODE-8337: git mv VersionOrdinal.java->Version.java
 add fd76cc0  GEODE-8298: Fix multicast version detection (#5370)
 add 25c15e9  GEODE-8369: Do not build docker images on Windows for 
geode-assembly:acceptanceTest (#5384)
 add 1067f45  GEODE-8363: Label Micrometer docs as experimental (#5386)
 add 6fa5dcb  GEODE-7628: Block jmx mbean creation when no security manager 
is configured (docs) (#5387)
 add 4b91664  GEODE-8362: add redis tests that access binary data (#5374)
 add 5365651  GEODE-8371: Move ClassGraph to MIT License (#5388)
 add 2a2c2aa  GEODE-8370: Add test for maxInactiveInterval (#5385)
 add 78e182e  Revert "GEODE-8298: Fix multicast version detection (#5370)"
 add 12f393d  Revert "GEODE-8337: git mv VersionOrdinal.java->Version.java"
 add 76a034b  Revert "GEODE-8337: git mv Version.java->KnownVersion.java"
 add 6a0e2bc  GEODE-8377: User Guide: GFSH GC command should be documented 
... (#5396)
 add f962632  GEODE-8366: Compared the input region's data policy to the 
sender instead of the leader region's
 add a4306dc  GEODE-8316: move RollingUpgradeWithGfshDUnitTest to 
geode-assembly since it needs to do installDist first. (#5394)
 add a322434  GEODE-8375: No-op test to run Redis server for Geode for 
local development (#5392)
 add c3cefe1  GEODE-8381: User Guide - Reformat table in REST command 
description (#5398)
 add 067194e  GEODE-8333: Fix PUBSUB hang (#5349)
 add 1469eb7  For CI test runs, split the assemble and test invocation, to 
set max-test-workers
 add ce5e315  GEODE-8383: User Guide - add "Client" to 
ssl-enabled-component property table (#5401)
 add ee6b3a9  Revert "For CI test runs, split the assemble and test 
invocation, to set max-test-workers" (#5407)
 add e705128  GEODE-7864: Fix several LGTM warnings (#5400)
 add 08316aa  GEODE-8385: hang recovering from disk with cyclic 
dependencies (#5403)
 add de6ab7a  GEODE-8331: allow GFSH to connect to other versions of 
cluster (#5408)
 add 4cea862  GEODE-8331: allow GFSH to connect to other versions of 
cluster (doc correction) (#5410)
 add 95bba9a  Revert "GEODE-8333: Fix PUBSUB hang (#5349)" (#5415)
 add 1f1bd1a  GEODE-8372: Configure CMS to send UTF-8 regardless of JVM 
default (#5411)
 add

[geode] branch develop updated (1cab75d -> b167094)

2020-10-13 Thread kmiller

This is an automated email from the ASF dual-hosted git repository.

kmiller pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.


from 1cab75d  GEODE-8600: Fix for faulty statistics QueueSize (#5616)
 add b167094  GEODE-8556: Remove outdated msg from docs (#5614)

No new revisions were added by this update.

Summary of changes:
 .../configuring/running/starting_up_shutting_down.html.md.erb | 8 
 1 file changed, 4 insertions(+), 4 deletions(-)

[geode-native] branch develop updated: GEODE-8512: Add expectDomainClass for PdxInstance (#661)

2020-10-13 Thread bbender

This is an automated email from the ASF dual-hosted git repository.

bbender pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode-native.git


The following commit(s) were added to refs/heads/develop by this push:
 new 7c30a8c  GEODE-8512: Add expectDomainClass for PdxInstance (#661)
7c30a8c is described below

commit 7c30a8cdbf4de1d7ae34309f5094dea261a8ce1e
Author: Mario Salazar de Torres 
AuthorDate: Tue Oct 13 20:03:25 2020 +0200

GEODE-8512: Add expectDomainClass for PdxInstance (#661)

 - In Java client you can specify whether or not the PdxInstance you
   are trying to create when calling createPdxInstanceFactory
   represnets a Java domain class.
 - This commit adds the possibility to also specify expectDomainClass
   for the native C++ client.
 - Take into account that this is necessary in order to query
   PdxInstance entries which classname is __GEMFIRE_JSON with
   Gfsh tool.
 - Fix doxygen comments for old createPdxInstanceFactory overloads.
 - Modified Gfsh utilities from the testing framework to allow
   executing queries.
 - Added integration test in which is test the functionality.
 - Removed CacheImpl::createPdxInstanceFactory overload with a single 
parameter
   as there is no need for it anymore.
 - Inverted semantics of m_noJavaClass in PdxType so logic is more clear.
 - Added QueryFunction server function in order to further use it in 
testing,
   Such function allows the user to make a query from the server side.
 - Minor changes done to PdxTypeTest unit-test TS so ByteArray gtest 
expectations can
   be used.
 - Added unit-tests to verify serialization is properly done with the 
is_java_class_
   attribute.
 - Added unit-tests to verify de-serialization is properly done with the 
is_java_class_
   attribute.
 - Changed the integration test so it uses a server function instead of 
calling
   gfsh with a command.
 - Reversed changes that added the capability for Gfsh interface to execute
   queries as it is not needed anymore.
 - Fixed Cluster class so now it's possible to specify a single CacheXmlFile
   entry.
 - Added a resource folder for the new integration tests. Before resources
   were taken from the resources folder of the old testing framework.
 - Added a new entry in TestConfig so the above mentioned folder path can
   be accesed in the tests.
 - Added pdxjson_cacheserver.xml in the new integration test resource 
folder.
---
 cppcache/include/geode/AuthenticatedView.hpp   |  14 +-
 cppcache/include/geode/Cache.hpp   |  15 +-
 cppcache/include/geode/PdxInstanceFactory.hpp  |   2 +-
 cppcache/include/geode/RegionService.hpp   |  15 +-
 cppcache/integration/framework/Cluster.cpp |   2 +-
 cppcache/integration/framework/TestConfig.cpp.in   |   1 +
 cppcache/integration/framework/TestConfig.h|  12 +-
 cppcache/integration/test/PdxJsonTypeTest.cpp  |  37 +
 .../test/resources/pdxjson_cacheserver.xml |  32 
 cppcache/src/AuthenticatedView.cpp |  10 +-
 cppcache/src/Cache.cpp |   7 +-
 cppcache/src/CacheImpl.cpp |   4 +-
 cppcache/src/CacheImpl.hpp |   4 +-
 cppcache/src/PdxInstanceFactory.cpp|   4 +-
 cppcache/src/PdxType.cpp   |  15 +-
 cppcache/src/PdxType.hpp   |   5 +-
 cppcache/test/PdxTypeTest.cpp  | 170 +++--
 tests/javaobject/QueryFunction.java|  79 ++
 18 files changed, 358 insertions(+), 70 deletions(-)

diff --git a/cppcache/include/geode/AuthenticatedView.hpp 
b/cppcache/include/geode/AuthenticatedView.hpp
index 1399978..89ef1fa 100644
--- a/cppcache/include/geode/AuthenticatedView.hpp
+++ b/cppcache/include/geode/AuthenticatedView.hpp
@@ -103,8 +103,18 @@ class APACHE_GEODE_EXPORT AuthenticatedView : public 
RegionService {
   /**
* Returns a factory that can create a {@link PdxInstance}.
* @param className the fully qualified class name that the PdxInstance will
-   * become
-   * when it is fully deserialized.
+   * become when it is fully deserialized.
+   * @param expectDomainClass Whether or not created PdxType represents a
+   * Java domain class.
+   * @return the factory
+   */
+  PdxInstanceFactory createPdxInstanceFactory(
+  const std::string& className, bool expectDomainClass) const override;
+
+  /**
+   * Returns a factory that can create a {@link PdxInstance}.
+   * @param className the fully qualified class name that the PdxInstance will
+   * become when it is fully deserialized.
* @return the factory
*/
   PdxInstanceFactory createPdxInstanceFactory(
diff --git a/cppcache/include/geode/Cache.hpp b/cppcache/include/geode/Cache.hpp
index 2f4fe2c..028a6d5 100644
--- a/cppcac

[geode] branch feature/GEODE-7665 updated: GEODE-7845 blocking PR region clear if one or more server versions are too old (#5577)

2020-10-13 Thread mhanson

This is an automated email from the ASF dual-hosted git repository.

mhanson pushed a commit to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-7665 by this 
push:
 new 0d3  GEODE-7845 blocking PR region clear if one or more server 
versions are too old (#5577)
0d3 is described below

commit 0d31e2fcf63c22eef9153bdc0ac3ec4ba575
Author: mhansonp 
AuthorDate: Tue Oct 13 10:10:25 2020 -0700

GEODE-7845 blocking PR region clear if one or more server versions are too 
old (#5577)

- if a server is running an old version when a PR clear is invoked
by the client, the client will receive a ServerOperationException
with a cause of ServerVersionMismatchException.
---
 .../integrationTest/resources/assembly_content.txt |   1 +
 .../main/java/org/apache/geode/cache/Region.java   |   2 +
 .../cache/ServerVersionMismatchException.java  |  34 ++
 .../geode/internal/cache/PartitionedRegion.java|   1 +
 .../internal/cache/PartitionedRegionClear.java |  34 +-
 .../sanctioned-geode-core-serializables.txt|   1 +
 .../internal/cache/PartitionedRegionClearTest.java | 109 --
 .../RollingUpgrade2DUnitTestBase.java  |   4 +-
 ...ionRegionClearMixedServerPartitionedRegion.java | 412 +
 9 files changed, 571 insertions(+), 27 deletions(-)

diff --git a/geode-assembly/src/integrationTest/resources/assembly_content.txt 
b/geode-assembly/src/integrationTest/resources/assembly_content.txt
index 549150f..553785a 100644
--- a/geode-assembly/src/integrationTest/resources/assembly_content.txt
+++ b/geode-assembly/src/integrationTest/resources/assembly_content.txt
@@ -245,6 +245,7 @@ javadoc/org/apache/geode/cache/RoleEvent.html
 javadoc/org/apache/geode/cache/RoleException.html
 javadoc/org/apache/geode/cache/Scope.html
 javadoc/org/apache/geode/cache/SerializedCacheValue.html
+javadoc/org/apache/geode/cache/ServerVersionMismatchException.html
 javadoc/org/apache/geode/cache/StatisticsDisabledException.html
 javadoc/org/apache/geode/cache/SubscriptionAttributes.html
 javadoc/org/apache/geode/cache/SynchronizationCommitConflictException.html
diff --git a/geode-core/src/main/java/org/apache/geode/cache/Region.java 
b/geode-core/src/main/java/org/apache/geode/cache/Region.java
index 4707a46..5162bd5 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/Region.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/Region.java
@@ -1307,6 +1307,8 @@ public interface Region extends ConcurrentMap 
{
* @throws PartitionedRegionPartialClearException when data is partially 
cleared on partitioned
* region. It is caller responsibility to handle the partial data 
clear either by retrying
* the clear operation or continue working with the partially 
cleared partitioned region.
+   * @throws ServerVersionMismatchException when data was not cleared because 
one or more
+   * of the member servers' version was too old to understand the 
clear message.
*/
   @Override
   void clear();
diff --git 
a/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
 
b/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
new file mode 100644
index 000..1d4231a
--- /dev/null
+++ 
b/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
@@ -0,0 +1,34 @@
+/*
+ * 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.cache;
+
+import java.util.List;
+
+/**
+ * Indicates a failure to perform an operation on a Partitioned Region due to
+ * server versions not meeting requirements.
+ *
+ * @since GEODE 1.14.0
+ */
+public class ServerVersionMismatchException extends CacheRuntimeException {
+  private static final long serialVersionUID = -3004093739855972548L;
+
+  public ServerVersionMismatchException(List members, String 
featureName,
+  String version) {
+super(
+"A server's " + members + " version was too old (< " + version + ") 
for : " + featureName);
+
+  }
+}
diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
 
b/geode-cor

[geode] branch feature/GEODE-7665 updated: GEODE-7845 blocking PR region clear if one or more server versions are too old (#5577)

2020-10-13 Thread mhanson

This is an automated email from the ASF dual-hosted git repository.

mhanson pushed a commit to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-7665 by this 
push:
 new 0d3  GEODE-7845 blocking PR region clear if one or more server 
versions are too old (#5577)
0d3 is described below

commit 0d31e2fcf63c22eef9153bdc0ac3ec4ba575
Author: mhansonp 
AuthorDate: Tue Oct 13 10:10:25 2020 -0700

GEODE-7845 blocking PR region clear if one or more server versions are too 
old (#5577)

- if a server is running an old version when a PR clear is invoked
by the client, the client will receive a ServerOperationException
with a cause of ServerVersionMismatchException.
---
 .../integrationTest/resources/assembly_content.txt |   1 +
 .../main/java/org/apache/geode/cache/Region.java   |   2 +
 .../cache/ServerVersionMismatchException.java  |  34 ++
 .../geode/internal/cache/PartitionedRegion.java|   1 +
 .../internal/cache/PartitionedRegionClear.java |  34 +-
 .../sanctioned-geode-core-serializables.txt|   1 +
 .../internal/cache/PartitionedRegionClearTest.java | 109 --
 .../RollingUpgrade2DUnitTestBase.java  |   4 +-
 ...ionRegionClearMixedServerPartitionedRegion.java | 412 +
 9 files changed, 571 insertions(+), 27 deletions(-)

diff --git a/geode-assembly/src/integrationTest/resources/assembly_content.txt 
b/geode-assembly/src/integrationTest/resources/assembly_content.txt
index 549150f..553785a 100644
--- a/geode-assembly/src/integrationTest/resources/assembly_content.txt
+++ b/geode-assembly/src/integrationTest/resources/assembly_content.txt
@@ -245,6 +245,7 @@ javadoc/org/apache/geode/cache/RoleEvent.html
 javadoc/org/apache/geode/cache/RoleException.html
 javadoc/org/apache/geode/cache/Scope.html
 javadoc/org/apache/geode/cache/SerializedCacheValue.html
+javadoc/org/apache/geode/cache/ServerVersionMismatchException.html
 javadoc/org/apache/geode/cache/StatisticsDisabledException.html
 javadoc/org/apache/geode/cache/SubscriptionAttributes.html
 javadoc/org/apache/geode/cache/SynchronizationCommitConflictException.html
diff --git a/geode-core/src/main/java/org/apache/geode/cache/Region.java 
b/geode-core/src/main/java/org/apache/geode/cache/Region.java
index 4707a46..5162bd5 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/Region.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/Region.java
@@ -1307,6 +1307,8 @@ public interface Region extends ConcurrentMap 
{
* @throws PartitionedRegionPartialClearException when data is partially 
cleared on partitioned
* region. It is caller responsibility to handle the partial data 
clear either by retrying
* the clear operation or continue working with the partially 
cleared partitioned region.
+   * @throws ServerVersionMismatchException when data was not cleared because 
one or more
+   * of the member servers' version was too old to understand the 
clear message.
*/
   @Override
   void clear();
diff --git 
a/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
 
b/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
new file mode 100644
index 000..1d4231a
--- /dev/null
+++ 
b/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
@@ -0,0 +1,34 @@
+/*
+ * 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.cache;
+
+import java.util.List;
+
+/**
+ * Indicates a failure to perform an operation on a Partitioned Region due to
+ * server versions not meeting requirements.
+ *
+ * @since GEODE 1.14.0
+ */
+public class ServerVersionMismatchException extends CacheRuntimeException {
+  private static final long serialVersionUID = -3004093739855972548L;
+
+  public ServerVersionMismatchException(List members, String 
featureName,
+  String version) {
+super(
+"A server's " + members + " version was too old (< " + version + ") 
for : " + featureName);
+
+  }
+}
diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
 
b/geode-cor

[geode] branch feature/GEODE-7665 updated: GEODE-7845 blocking PR region clear if one or more server versions are too old (#5577)

2020-10-13 Thread mhanson

This is an automated email from the ASF dual-hosted git repository.

mhanson pushed a commit to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-7665 by this 
push:
 new 0d3  GEODE-7845 blocking PR region clear if one or more server 
versions are too old (#5577)
0d3 is described below

commit 0d31e2fcf63c22eef9153bdc0ac3ec4ba575
Author: mhansonp 
AuthorDate: Tue Oct 13 10:10:25 2020 -0700

GEODE-7845 blocking PR region clear if one or more server versions are too 
old (#5577)

- if a server is running an old version when a PR clear is invoked
by the client, the client will receive a ServerOperationException
with a cause of ServerVersionMismatchException.
---
 .../integrationTest/resources/assembly_content.txt |   1 +
 .../main/java/org/apache/geode/cache/Region.java   |   2 +
 .../cache/ServerVersionMismatchException.java  |  34 ++
 .../geode/internal/cache/PartitionedRegion.java|   1 +
 .../internal/cache/PartitionedRegionClear.java |  34 +-
 .../sanctioned-geode-core-serializables.txt|   1 +
 .../internal/cache/PartitionedRegionClearTest.java | 109 --
 .../RollingUpgrade2DUnitTestBase.java  |   4 +-
 ...ionRegionClearMixedServerPartitionedRegion.java | 412 +
 9 files changed, 571 insertions(+), 27 deletions(-)

diff --git a/geode-assembly/src/integrationTest/resources/assembly_content.txt 
b/geode-assembly/src/integrationTest/resources/assembly_content.txt
index 549150f..553785a 100644
--- a/geode-assembly/src/integrationTest/resources/assembly_content.txt
+++ b/geode-assembly/src/integrationTest/resources/assembly_content.txt
@@ -245,6 +245,7 @@ javadoc/org/apache/geode/cache/RoleEvent.html
 javadoc/org/apache/geode/cache/RoleException.html
 javadoc/org/apache/geode/cache/Scope.html
 javadoc/org/apache/geode/cache/SerializedCacheValue.html
+javadoc/org/apache/geode/cache/ServerVersionMismatchException.html
 javadoc/org/apache/geode/cache/StatisticsDisabledException.html
 javadoc/org/apache/geode/cache/SubscriptionAttributes.html
 javadoc/org/apache/geode/cache/SynchronizationCommitConflictException.html
diff --git a/geode-core/src/main/java/org/apache/geode/cache/Region.java 
b/geode-core/src/main/java/org/apache/geode/cache/Region.java
index 4707a46..5162bd5 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/Region.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/Region.java
@@ -1307,6 +1307,8 @@ public interface Region extends ConcurrentMap 
{
* @throws PartitionedRegionPartialClearException when data is partially 
cleared on partitioned
* region. It is caller responsibility to handle the partial data 
clear either by retrying
* the clear operation or continue working with the partially 
cleared partitioned region.
+   * @throws ServerVersionMismatchException when data was not cleared because 
one or more
+   * of the member servers' version was too old to understand the 
clear message.
*/
   @Override
   void clear();
diff --git 
a/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
 
b/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
new file mode 100644
index 000..1d4231a
--- /dev/null
+++ 
b/geode-core/src/main/java/org/apache/geode/cache/ServerVersionMismatchException.java
@@ -0,0 +1,34 @@
+/*
+ * 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.cache;
+
+import java.util.List;
+
+/**
+ * Indicates a failure to perform an operation on a Partitioned Region due to
+ * server versions not meeting requirements.
+ *
+ * @since GEODE 1.14.0
+ */
+public class ServerVersionMismatchException extends CacheRuntimeException {
+  private static final long serialVersionUID = -3004093739855972548L;
+
+  public ServerVersionMismatchException(List members, String 
featureName,
+  String version) {
+super(
+"A server's " + members + " version was too old (< " + version + ") 
for : " + featureName);
+
+  }
+}
diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java
 
b/geode-cor

[geode] branch develop updated: GEODE-8600: Fix for faulty statistics QueueSize (#5616)

2020-10-13 Thread mivanac

This is an automated email from the ASF dual-hosted git repository.

mivanac pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
 new 1cab75d  GEODE-8600: Fix for faulty statistics QueueSize (#5616)
1cab75d is described below

commit 1cab75df7f95e82d113b4f81596bf2eda1e333fc
Author: Mario Ivanac <48509724+miva...@users.noreply.github.com>
AuthorDate: Tue Oct 13 11:25:22 2020 +0200

GEODE-8600: Fix for faulty statistics QueueSize (#5616)
---
 .../wan/parallel/ParallelGatewaySenderQueue.java   |  3 ++
 .../geode/internal/cache/wan/WANTestBase.java  |  9 +
 .../wan/parallel/ParallelWANStatsDUnitTest.java| 43 ++
 3 files changed, 55 insertions(+)

diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
 
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
index 108eff5..88ef0b1 100644
--- 
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
+++ 
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
@@ -278,6 +278,9 @@ public class ParallelGatewaySenderQueue implements 
RegionQueue {
 for (Region userRegion : listOfRegions) {
   if (userRegion instanceof PartitionedRegion) {
 addShadowPartitionedRegionForUserPR((PartitionedRegion) userRegion);
+if (index == 0 && getRegion(userRegion.getFullPath()) != null) {
+  
this.stats.incQueueSize(getRegion(userRegion.getFullPath()).getLocalSize());
+}
   } else {
 // Fix for Bug#51491. Once decided to support this configuration we 
have call
 // addShadowPartitionedRegionForUserRR
diff --git 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
index 883b313..8446885 100644
--- 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
+++ 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
@@ -1202,6 +1202,15 @@ public class WANTestBase extends DistributedTestCase {
 return statistics.getSecondaryEventQueueSize();
   }
 
+  public static void checkQueueSizeInStats(String senderId, final int 
expectedQueueSize) {
+AbstractGatewaySender sender = (AbstractGatewaySender) 
cache.getGatewaySender(senderId);
+GatewaySenderStats statistics = sender.getStatistics();
+await()
+.untilAsserted(() -> assertEquals("Expected queue size: " + 
expectedQueueSize
++ " but actual size: " + statistics.getEventQueueSize(), 
expectedQueueSize,
+statistics.getEventQueueSize()));
+  }
+
   public static void checkConnectionStats(String senderId) {
 AbstractGatewaySender sender =
 (AbstractGatewaySender) 
CacheFactory.getAnyInstance().getGatewaySender(senderId);
diff --git 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
index 7155975..7ff1c8d 100644
--- 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
+++ 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
@@ -1054,6 +1054,49 @@ public class ParallelWANStatsDUnitTest extends 
WANTestBase {
 verifyConflationIndexesSize(senderId, 0, vm1);
   }
 
+
+  @Test
+  public void 
testPartitionedRegionParallelPropagation_RestartSenders_NoRedundancy() {
+Integer lnPort = vm0.invoke(() -> 
WANTestBase.createFirstLocatorWithDSId(1));
+Integer nyPort = vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2, 
lnPort));
+
+createCacheInVMs(nyPort, vm2);
+createReceiverInVMs(vm2);
+
+createSenders(lnPort);
+
+createReceiverPR(vm2, 0);
+
+createSenderPRs(0);
+
+startSenderInVMs("ln", vm4, vm5, vm6, vm7);
+
+// pause the senders
+vm4.invoke(() -> WANTestBase.pauseSender("ln"));
+vm5.invoke(() -> WANTestBase.pauseSender("ln"));
+vm6.invoke(() -> WANTestBase.pauseSender("ln"));
+vm7.invoke(() -> WANTestBase.pauseSender("ln"));
+
+vm4.invoke(() -> WANTestBase.doPuts(testName, NUM_PUTS));
+
+vm4.invoke(() -> WANTestBase.stopSender("ln"));
+vm5.invoke(() -> WANTestBase.stopSender("ln"));
+vm6.invoke(() -> WANTestBase.stopSender("ln"));
+vm7.invoke(() -> WANTestBase.stopSender("ln"));
+
+startSenderInVMs("ln", vm4, vm5, vm6, vm7);
+
+vm4.invoke(() -> WANTestBase.checkQueueSizeInStats("ln", 0));
+vm5.invoke(() -> WANTestBase.checkQueueSizeInStats("ln", 0));
+vm6.invoke(() -> WANTestBase.checkQueueSizeInSt

[geode] branch develop updated: GEODE-8600: Fix for faulty statistics QueueSize (#5616)

2020-10-13 Thread mivanac

This is an automated email from the ASF dual-hosted git repository.

mivanac pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/develop by this push:
 new 1cab75d  GEODE-8600: Fix for faulty statistics QueueSize (#5616)
1cab75d is described below

commit 1cab75df7f95e82d113b4f81596bf2eda1e333fc
Author: Mario Ivanac <48509724+miva...@users.noreply.github.com>
AuthorDate: Tue Oct 13 11:25:22 2020 +0200

GEODE-8600: Fix for faulty statistics QueueSize (#5616)
---
 .../wan/parallel/ParallelGatewaySenderQueue.java   |  3 ++
 .../geode/internal/cache/wan/WANTestBase.java  |  9 +
 .../wan/parallel/ParallelWANStatsDUnitTest.java| 43 ++
 3 files changed, 55 insertions(+)

diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
 
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
index 108eff5..88ef0b1 100644
--- 
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
+++ 
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderQueue.java
@@ -278,6 +278,9 @@ public class ParallelGatewaySenderQueue implements 
RegionQueue {
 for (Region userRegion : listOfRegions) {
   if (userRegion instanceof PartitionedRegion) {
 addShadowPartitionedRegionForUserPR((PartitionedRegion) userRegion);
+if (index == 0 && getRegion(userRegion.getFullPath()) != null) {
+  
this.stats.incQueueSize(getRegion(userRegion.getFullPath()).getLocalSize());
+}
   } else {
 // Fix for Bug#51491. Once decided to support this configuration we 
have call
 // addShadowPartitionedRegionForUserRR
diff --git 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
index 883b313..8446885 100644
--- 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
+++ 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/WANTestBase.java
@@ -1202,6 +1202,15 @@ public class WANTestBase extends DistributedTestCase {
 return statistics.getSecondaryEventQueueSize();
   }
 
+  public static void checkQueueSizeInStats(String senderId, final int 
expectedQueueSize) {
+AbstractGatewaySender sender = (AbstractGatewaySender) 
cache.getGatewaySender(senderId);
+GatewaySenderStats statistics = sender.getStatistics();
+await()
+.untilAsserted(() -> assertEquals("Expected queue size: " + 
expectedQueueSize
++ " but actual size: " + statistics.getEventQueueSize(), 
expectedQueueSize,
+statistics.getEventQueueSize()));
+  }
+
   public static void checkConnectionStats(String senderId) {
 AbstractGatewaySender sender =
 (AbstractGatewaySender) 
CacheFactory.getAnyInstance().getGatewaySender(senderId);
diff --git 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
index 7155975..7ff1c8d 100644
--- 
a/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
+++ 
b/geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java
@@ -1054,6 +1054,49 @@ public class ParallelWANStatsDUnitTest extends 
WANTestBase {
 verifyConflationIndexesSize(senderId, 0, vm1);
   }
 
+
+  @Test
+  public void 
testPartitionedRegionParallelPropagation_RestartSenders_NoRedundancy() {
+Integer lnPort = vm0.invoke(() -> 
WANTestBase.createFirstLocatorWithDSId(1));
+Integer nyPort = vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2, 
lnPort));
+
+createCacheInVMs(nyPort, vm2);
+createReceiverInVMs(vm2);
+
+createSenders(lnPort);
+
+createReceiverPR(vm2, 0);
+
+createSenderPRs(0);
+
+startSenderInVMs("ln", vm4, vm5, vm6, vm7);
+
+// pause the senders
+vm4.invoke(() -> WANTestBase.pauseSender("ln"));
+vm5.invoke(() -> WANTestBase.pauseSender("ln"));
+vm6.invoke(() -> WANTestBase.pauseSender("ln"));
+vm7.invoke(() -> WANTestBase.pauseSender("ln"));
+
+vm4.invoke(() -> WANTestBase.doPuts(testName, NUM_PUTS));
+
+vm4.invoke(() -> WANTestBase.stopSender("ln"));
+vm5.invoke(() -> WANTestBase.stopSender("ln"));
+vm6.invoke(() -> WANTestBase.stopSender("ln"));
+vm7.invoke(() -> WANTestBase.stopSender("ln"));
+
+startSenderInVMs("ln", vm4, vm5, vm6, vm7);
+
+vm4.invoke(() -> WANTestBase.checkQueueSizeInStats("ln", 0));
+vm5.invoke(() -> WANTestBase.checkQueueSizeInStats("ln", 0));
+vm6.invoke(() -> WANTestBase.checkQueueSizeInSt

[geode] 01/01: GEM-3093: add some trace code

[geode] branch feature/GEM-3093 created (now f9a0832)

[geode] branch feature/GEODE-7665 updated: GEODE-7845: Adding a cleaner simpler test. (#5622)

[geode] branch feature/GEODE-7665 updated: GEODE-7845: Adding a cleaner simpler test. (#5622)

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

[geode] branch feature/GEODE-8324 updated (514b17a -> be100b3)

[geode] branch develop updated (1cab75d -> b167094)

[geode-native] branch develop updated: GEODE-8512: Add expectDomainClass for PdxInstance (#661)

[geode] branch feature/GEODE-7665 updated: GEODE-7845 blocking PR region clear if one or more server versions are too old (#5577)

[geode] branch feature/GEODE-7665 updated: GEODE-7845 blocking PR region clear if one or more server versions are too old (#5577)

[geode] branch feature/GEODE-7665 updated: GEODE-7845 blocking PR region clear if one or more server versions are too old (#5577)

[geode] branch develop updated: GEODE-8600: Fix for faulty statistics QueueSize (#5616)

[geode] branch develop updated: GEODE-8600: Fix for faulty statistics QueueSize (#5616)

16 matches

Site Navigation

Mail list logo

Footer information