This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a change to branch feature/GEODE-6583
in repository https://gitbox.apache.org/repos/asf/geode.git.
discard 77db462 reinstated use of next-neighbors by default. added check for
insufficient history to phi detectors & use timestamps if that's the case.
discard 64387f8 reverting use of phi detectors for verification checks
discard 74b0dc6 optimization
discard 9e9fdd8 fix for failing unit test
discard e8c258c spotless
discard 5a73127 removed sync when creating detectors & cleaned up copyright
notice
discard 59e2b1a GEODE-6583 Integrate phi-accrual failure detection into Geode
add 0860e38 GEODE-4958: Lowering the log level to warn.
add 016cf13 GEODE-6634: Fix parallel option for repeatTest (#3443)
add 8ff0939 GEODE-6557:Handling a possible null situation.
add 62b8c22 GEODE-6638: do not fail with IllegalMonitorStateException
during cache close (#3451)
add 7fee5bf fix typo in JAVA_HOME command on OSX
add 94ccba3 GEODE-6649: Static analyzer warning cleanup.
add fc4e825 GEODE-6649: Add tests for effected methods.
add 5d0fcf3 GEODE-6649: Remove lock contention in ClientHealthMonitor
heartbeats.
add 133d6af GEODE-5231: Fix PersistentReplicatedTestBase subclass
flakiness
add 99dae16 GEODE-5231: addIgnoredException to
PersistentRVVRecoveryDUnitTest
add ea0dc64 GEODE-5231: Fix timeout in PersistentRVVRecoveryDUnitTest
add 2862bc7 GEODE-6639: Cleanup static analyzer warnings.
add a75c5d0 GEODE-6639: Adds unit test for processing message time logic.
add 55fd4a2 GEODE-6639: Use AtomicLong for processingMessageStartTime
add ff703dd GEODE-6664 CI failure:
org.apache.geode.ClusterCommunicationsDUnitTest.receiveBigResponse
add 0e90b5a GEODE-6646 - CI failure in serverRestarsAfterLocatorReconnects
add 447f508 GEODE-6611: geode-all-bom does not import java-library (#3474)
add 064892c GEODE-6662 NioPlainEngine.ensureWrappedCapacity
add 96bd60e GEODE-6640: add integration tests to do put, invalidate, then
get from async JDBC mapping (#3468)
add def65d4 GEODE-6579: optimize string deserialization (#3381)
add 7a82437 GEODE-6666: Catch SocketTimeoutException (#3478)
add cee84bb GEODE-6665: Avoid creating regions on Locator (#3480)
add 104268a GEODE-5986 Inconsistent equals/hashCode
add 6a177ec GEODE-6612: add entry count for list Region and rework
filtering by groups (#3465)
add f3428c6 GEODE-6611: Correct publication issues in all-bom. (#3483)
add 49757e7 GEODE-6630: move allBucketsRecoveredFromDisk count down latch
(#3477)
add a0da3ce Fixes CI benchmark baseline selection.
add 1355084 adding my PGP block as instructed in release steps
add 5053c7f reduce verbosity of benchmark CI output and update version
numbers due to new release
add 0adb400 GEODE-6679: Use ephemeral ports in
StandaloneClientManagementAPIAcceptanceTest (#3485)
add c7e43c7 GEODE-5971: refactor remaining command's usage of Result
(#3481)
add ca36754 GEODE-6629: Add additional test assertions for disk store
creation
add fe0ddc5 GEODE-6656: Fix up
PersistentPartitionHangsDuringRestartRegressionTest
add afc311c GEODE-6607: Moving client registration queue to
CacheClientNotifier
add d746ec4 GEODE-6694: Use volatile access to read current state of
BucketAdvisor
add a6045e8 GEODE-6697: Make system property controlled variable static.
add 6e17bdd GEODE-6620: Upgrading springframework library (#3472)
add 88b3c51 GEODE-6693: run concurrency tests for longer (#3488)
add 323cd0d GEODE-5971: Remove FileResult (#3487)
add aae23e3 GEODE-6612: use java Objects for comparision instead of guava
(#3493)
add d3154bc GEODE-5971: have command pipeline send ResultModel json
across the wire (#3495)
add 96466c9 GEODE-5971: delete LegacyCommandResult and rename
ModelResultModel to… (#3497)
add 45c9538 Adding a couple of scripts to automate release candidates
add 8181426 Updating the prepare_rc script to find the right version of
openssl
add 3511c67 add newly-released 1.9.0 to old versions
add d684876 update the benchmarks baseline as 1.9.0 is released now
add 9df7fc4 we have a deploy script; add a corresponding destroy script
(#3504)
add b19734d GEODE-6595: Deprecates and ignore thread local connection
pool attribute. (#3394)
add 8320fdc GEODE-6709: Locators should not start when
ClusterConfigurationServic… (#3503)
add 3282d5a GEODE-6667: Await 2 owners of bucket in
testCrashWhileCreatingABucket
add 0a9a097 GEODE-5971: remove unnecessary @VisibleToTest methods (#3505)
add 39d8370 Fixing the minor version byte for Version.GEODE_1_10_0
add 3ea508d GEODE-6580: Cleanup static analyzer warnings. (#3432)
add 59c76ee GEODE-6692: canonicalize deserialization of empty string
(#3513)
add 52abb90 GEODE-6674: only create StringBuilder if needed (#3511)
add 7fbb95c GEODE-6688: prevent Integer allocation in
InternalDistributedMember deserialization (#3514)
add f2710b1 GEODE-6704: optimize getAllGatewaySenderIds (#3518)
add 76c98e8 GEODE-6673: remove unneeded HashSet creations (#3517)
add bc2a2fa GEODE-6708: Ensuring single drainer and preventing NPE
add c545aee Use Ubuntu Bionic as the test-container base (#3448)
add cdf10a9 GEODE-6561: When a test server is forced to shutdown, do not
save cache xml if use cluster config (#3509)
add 2d48994 GEODE-6720: Add FastLogger benchmarks (#3522)
add 3e30fbf GEODE-6727 CI failure:
AcceptorImplClientQueueDistributedTest.
clientSubscriptionQueueInitializationShouldNotBlockNewConnections
add 014e0e7 GEODE-6626: Fix getStartPort in GatewayReceiverMBeanBridge
add 459911d GEODE-6626: Remove unused method from GatewayReceiverMBean
add f096248 GEODE-6626: Cleanup GemFireCacheImpl use of GatewayReceiver
add 566c82d GEODE-6626: Cleanup GatewayReceiverImpl and its unit test
add 27bf663 GEODE-6626: Expand GatewayReceiverFactoryImplTest
add 73f6f85 GEODE-6626: Cleanup ServerConnection warnings
add 8505247 GEODE-6626: Cleanup AcceptorImpl warnings
add 1603ea0 GEODE-6626: Separate CacheServer and GatewayReceiver
add 8c2c9c8 GEODE-6687: replace ByteArrayInputStream+DataInputStream with
ByteArrayDataInput
add 30c2340 GEODE-6702: optimize equals by not calling compareTo (#3524)
add 835d7ae GEODE-6724 split brain formed on concurrent locator startup
add c283197 GEODE-6583 Integrate phi-accrual failure detection into Geode
add d54c197 removed sync when creating detectors & cleaned up copyright
notice
add adcfe26 spotless
add a5e0880 fix for failing unit test
add 610033c optimization
add 9cf7987 reverting use of phi detectors for verification checks
add e5abbe6 reinstated use of next-neighbors by default. added check for
insufficient history to phi detectors & use timestamps if that's the case.
add e25ee55 rework failure detectors to prefill their history. Disable
suspect initiation on loss of the shared/unordered TCPConduit connection
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (77db462)
\
N -- N -- N refs/heads/feature/GEODE-6583 (e25ee55)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
BUILDING.md | 2 +-
KEYS | 58 +
boms/build.gradle | 5 -
boms/geode-all-bom/build.gradle | 76 +-
.../src/test/resources/expected-pom.xml | 164 ++-
.../DockerizedJavaExecHandleBuilder.groovy | 12 +-
.../dockerizedtest/DockerizedTestPlugin.groovy | 6 +-
.../gradle/plugins/DependencyConstraints.groovy | 2 +-
ci/images/test-container/Dockerfile | 2 +-
ci/pipelines/geode-build/deploy_pipeline.sh | 2 +-
ci/pipelines/images/jinja.template.yml | 8 +-
ci/pipelines/meta/destroy_pipelines.sh | 84 ++
ci/pipelines/shared/jinja.variables.yml | 6 +-
ci/scripts/repeat-new-tests.sh | 2 +-
ci/scripts/run_benchmarks.sh | 4 +-
dev-tools/release/README.md | 8 +
dev-tools/release/prepare_rc.sh | 160 +++
dev-tools/release/print_rc_email.sh | 87 ++
.../modules/util/BootstrappingFunctionTest.java | 129 +++
.../modules/util/ModuleFunctionsSecurityTest.java | 2 +-
.../geode/modules/util/BootstrappingFunction.java | 18 +-
...tandaloneClientManagementAPIAcceptanceTest.java | 19 +-
.../ManagementClientTestCreateRegion.java | 11 +-
...ateRegionWithDiskstoreAndSecurityDUnitTest.java | 9 +
.../cli/commands/StartLocatorCommandDUnitTest.java | 42 +-
.../cli/commands/StartServerCommandDUnitTest.java | 66 +-
...StatusClusterConfigServiceCommandDUnitTest.java | 4 +-
.../commands/StatusLocatorCommandDunitTest.java | 10 +-
.../cli/commands/StopLocatorCommandDUnitTest.java | 6 +-
.../rest/ListRegionManagementDunitTest.java | 140 ++-
.../internal/rest/ServerRestartTest.java | 65 ++
.../integrationTest/resources/assembly_content.txt | 14 +-
.../resources/dependency_classpath.txt | 2 +-
geode-concurrency-test/build.gradle | 4 +-
.../test/concurrency/ConcurrentTestRunnerTest.java | 2 +-
.../geode/test/concurrency/loop/LoopRunner.java | 2 +-
.../geode/connectors/jdbc/JdbcDistributedTest.java | 241 +++-
...reateMappingCommandForProxyRegionDUnitTest.java | 12 +-
.../internal/cli/ListMappingCommandDUnitTest.java | 25 +-
.../cli/JDBCConnectorFunctionsSecurityTest.java | 2 +-
.../jdbc/internal/cli/CreateMappingCommand.java | 22 +-
.../cli/CreateMappingCommandInterceptorTest.java | 31 +-
.../internal/cli/DescribeMappingCommandTest.java | 108 +-
.../internal/cli/DestroyDataSourceCommandTest.java | 8 +-
.../geode/cache/ConnectionPoolDUnitTest.java | 121 +-
.../cache/RegionClearStatsDistributedTest.java | 8 +-
.../geode/cache30/CacheXMLPartitionResolver.java | 8 +-
.../apache/geode/distributed/LocatorDUnitTest.java | 59 +-
.../internal/cache/DeltaPropagationDUnitTest.java | 2 +-
.../cache/DeltaPropagationStatsDUnitTest.java | 7 +-
.../cache/HAOverflowMemObjectSizerDUnitTest.java | 2 +-
...zedDiskRegionWithIoExceptionRegressionTest.java | 4 +-
.../extension/mock/MockExtensionCommands.java | 43 +-
.../geode/internal/cache/ha/HAGIIDUnitTest.java | 2 +-
.../cache/ha/HARQueueNewImplDUnitTest.java | 2 +-
.../internal/cache/ha/HASlowReceiverDUnitTest.java | 5 +-
...BucketCreationCrashCompletesRegressionTest.java | 147 ++-
...tPartitionHangsDuringRestartRegressionTest.java | 50 +-
.../fixed/QuarterPartitionResolver.java | 7 +
.../fixed/SingleHopQuarterPartitionResolver.java | 7 +
.../PersistentRVVRecoveryDUnitTest.java | 40 +-
.../PersistentRecoveryOrderDUnitTest.java | 124 +-
.../PersistentRecoveryOrderOldConfigDUnitTest.java | 1 +
.../persistence/PersistentReplicatedTestBase.java | 13 +-
.../AcceptorImplClientQueueDistributedTest.java | 12 +-
.../cache/tier/sockets/AcceptorImplDUnitTest.java | 6 +-
...dCompatibilityHigherVersionClientDUnitTest.java | 6 +-
.../tier/sockets/ClientConflationDUnitTest.java | 4 +-
.../sockets/ClientInterestNotifyDUnitTest.java | 2 +-
.../ClientProxyWithDeltaDistributedTest.java | 5 +-
...ientServerConnectDisconnectDistributedTest.java | 4 +-
.../ClientServerForceInvalidateDUnitTest.java | 2 +-
.../ClientWithInterestFailoverDistributedTest.java | 2 +-
.../cache/tier/sockets/ConflationDUnitTest.java | 2 +-
.../tier/sockets/DurableClientStatsDUnitTest.java | 5 +-
.../tier/sockets/EventIDVerificationDUnitTest.java | 2 +-
.../HARegionQueueStatsCloseRegressionTest.java | 2 +-
.../cache/tier/sockets/InterestListDUnitTest.java | 2 +-
.../sockets/InterestListRecoveryDUnitTest.java | 2 +-
.../sockets/InterestResultPolicyDUnitTest.java | 2 +-
.../cache/tier/sockets/RegionCloseDUnitTest.java | 2 +-
...isterInterestServerMetaDataDistributedTest.java | 2 +-
.../tier/sockets/ReliableMessagingDUnitTest.java | 2 +-
.../management/JMXMBeanReconnectDUnitTest.java | 122 +-
.../management/internal/cli/NetstatDUnitTest.java | 31 +-
.../cli/commands/AlterRegionCommandDUnitTest.java | 2 +-
.../CreateAsyncEventQueueCommandDUnitTest.java | 12 +-
.../CreateDefinedIndexesCommandDUnitTest.java | 76 +-
.../commands/DescribeMembersCommandDUnitTest.java | 3 +-
.../commands/DestroyRegionCommandDUnitTest.java | 10 +-
.../cli/commands/DiskStoreCommandsDUnitTest.java | 64 +-
.../ExportLogsWithMemberGroupDistributedTest.java | 9 +-
.../ListAsyncEventQueuesCommandDUnitTest.java | 4 +-
.../commands/ListJndiBindingCommandDUnitTest.java | 26 +-
.../cli/commands/ListMembersCommandDUnitTest.java | 31 +-
.../cli/commands/LocateEntryDUnitTest.java | 44 +-
...ersistThroughClusterConfigurationDUnitTest.java | 6 +-
.../cli/commands/ShowMetricsDUnitTest.java | 2 +-
.../ShowMissingDiskStoreCommandDUnitTest.java | 3 +-
.../ClusterConfigImportDUnitTest.java | 12 +-
.../ClusterConfigLocatorRestartDUnitTest.java | 25 +-
...rConfigServerRestartWithJarDeployDUnitTest.java | 2 +-
.../internal/pulse/TestClientIdsDUnitTest.java | 2 +-
.../internal/pulse/TestSubscriptionsDUnitTest.java | 2 +-
.../internal/security/MultiGfshDUnitTest.java | 41 +-
.../pdx/ClientsWithVersioningRetryDUnitTest.java | 7 -
.../geode/pdx/JSONPdxClientServerDUnitTest.java | 14 +-
.../apache/geode/pdx/PdxClientServerDUnitTest.java | 51 +-
.../security/SecurityClusterConfigDUnitTest.java | 38 +-
.../AutoConnectionSourceImplJUnitTest.java | 8 -
.../internal/ConnectionPoolImplJUnitTest.java | 15 -
.../client/internal/QueueManagerJUnitTest.java | 8 -
.../pooling/ConnectionManagerJUnitTest.java | 34 +-
.../cache/execute/CoreFunctionSecurityTest.java | 2 +-
.../execute/FunctionDynamicByArgsSecurityTest.java | 4 +-
.../gms/fd/PhiAccrualFailureDetectorTest.java | 10 +-
.../cache/LocatorMisconfigurationTest.java} | 21 +-
.../cache/ServerBuilderIntegrationTest.java | 114 ++
.../tier/sockets/AcceptorImplIntegrationTest.java | 135 +++
.../cache/tier/sockets/AcceptorImplJUnitTest.java | 145 ---
.../CacheClientNotifierIntegrationTest.java | 301 -----
.../CacheServerMaxConnectionsJUnitTest.java | 1 -
.../ClientHealthMonitorIntegrationTest.java | 2 +-
.../tier/sockets/ConnectionProxyJUnitTest.java | 3 -
.../sockets/ServerConnectionIntegrationTest.java | 115 +-
...t.java => CacheServerStatsIntegrationTest.java} | 7 +-
...va => GatewayReceiverStatsIntegrationTest.java} | 67 +-
.../internal/cli/HeadlessGfshIntegrationTest.java | 6 +-
.../cli/commands/EchoCommandIntegrationTest.java | 41 +-
.../cli/commands/GetCommandIntegrationTest.java | 158 ++-
.../cli/commands/PutCommandIntegrationTest.java | 60 +-
.../GfshStatusCommandsIntegrationTest.java | 22 +-
.../result/model/ResultModelIntegrationTest.java | 11 +-
.../RegionConfigMutatorIntegrationTest.java | 2 +-
.../apache/geode/codeAnalysis/excludedClasses.txt | 2 +
.../codeAnalysis/sanctionedDataSerializables.txt | 4 +-
.../internal/InternalDataSerializerBenchmark.java | 72 ++
.../log4j/FastLoggerDisabledLevelBenchmark.java | 110 ++
.../log4j/FastLoggerEnabledLevelBenchmark.java | 96 ++
.../log4j/FastLoggerParameterTypeBenchmark.java | 175 +++
.../geode/cache/client/ClientCacheFactory.java | 53 +-
.../java/org/apache/geode/cache/client/Pool.java | 14 +-
.../org/apache/geode/cache/client/PoolFactory.java | 12 +-
.../geode/cache/client/internal/AbstractOp.java | 54 +-
.../cache/client/internal/AuthenticateUserOp.java | 75 +-
.../client/internal/ClientSideHandshakeImpl.java | 8 +-
.../internal/DataSerializerRecoveryListener.java | 14 +-
.../cache/client/internal/ExecutablePool.java | 6 +-
.../internal/ExplicitConnectionSourceImpl.java | 8 +-
.../internal/InstantiatorRecoveryListener.java | 11 +-
.../org/apache/geode/cache/client/internal/Op.java | 5 +-
.../cache/client/internal/OpExecutorImpl.java | 286 ++---
.../geode/cache/client/internal/PoolImpl.java | 391 +++----
.../apache/geode/cache/client/internal/PutOp.java | 161 +--
.../internal/pooling/ConnectionManagerImpl.java | 213 ++--
.../apache/geode/cache/wan/EventSequenceID.java | 5 +-
.../apache/geode/cache/wan/GatewayReceiver.java | 3 -
.../InternalConfigurationPersistenceService.java | 32 +-
.../internal/InternalDistributedSystem.java | 8 +
.../distributed/internal/InternalLocator.java | 6 +
.../membership/InternalDistributedMember.java | 67 +-
.../internal/membership/gms/GMSUtil.java | 3 +
.../membership/gms/fd/GMSHealthMonitor.java | 11 +-
.../gms/fd/PhiAccrualFailureDetector.java | 10 +-
.../membership/gms/membership/GMSJoinLeave.java | 17 +-
.../distributed/internal/tcpserver/TcpServer.java | 8 +
.../apache/geode/internal/ByteArrayDataInput.java | 8 +
.../geode/internal/InternalDataSerializer.java | 11 +-
.../geode/internal/ThreadLocalByteArrayCache.java | 56 +
.../java/org/apache/geode/internal/Version.java | 2 +-
.../admin/ClientHealthMonitoringRegion.java | 11 +-
.../internal/admin/remote/RemoteBridgeServer.java | 62 +-
.../geode/internal/cache/AbstractCacheServer.java | 8 +-
.../geode/internal/cache/AbstractRegion.java | 11 +-
.../apache/geode/internal/cache/BucketAdvisor.java | 30 +-
.../geode/internal/cache/CacheServerImpl.java | 200 ++--
.../internal/cache/ClusterConfigurationLoader.java | 5 +-
.../internal/cache/DistributedCacheOperation.java | 23 +-
.../geode/internal/cache/EntryEventImpl.java | 4 +-
.../org/apache/geode/internal/cache/EventID.java | 12 +-
.../geode/internal/cache/FilterRoutingInfo.java | 13 +-
.../geode/internal/cache/GemFireCacheImpl.java | 170 +--
.../apache/geode/internal/cache/InternalCache.java | 6 +-
.../cache/InternalCacheForClientAccess.java | 11 +-
.../geode/internal/cache/InternalCacheServer.java | 32 +
.../internal/cache/PRHARedundancyProvider.java | 90 +-
.../geode/internal/cache/PoolFactoryImpl.java | 248 ++--
.../geode/internal/cache/PoolManagerImpl.java | 97 +-
.../apache/geode/internal/cache/ServerBuilder.java | 170 +++
.../cache/ServerFactory.java} | 17 +-
.../org/apache/geode/internal/cache/TXState.java | 12 +-
.../geode/internal/cache/TombstoneService.java | 32 +-
.../geode/internal/cache/ha/ThreadIdentifier.java | 5 +-
...yLogger.java => PersistentBucketRecoverer.java} | 111 +-
.../apache/geode/internal/cache/tier/Acceptor.java | 46 +-
.../cache/tier/InternalClientMembership.java | 43 +-
.../cache/tier/OverflowAttributes.java} | 22 +-
.../cache/tier/sockets/AcceptorBuilder.java | 397 +++++++
.../sockets/AcceptorFactory.java} | 16 +-
.../internal/cache/tier/sockets/AcceptorImpl.java | 754 ++++++------
.../geode/internal/cache/tier/sockets/AuthIds.java | 6 +-
.../cache/tier/sockets/CacheClientNotifier.java | 1208 +++++++++-----------
.../cache/tier/sockets/CacheClientProxy.java | 93 +-
.../cache/tier/sockets/CacheClientUpdater.java | 5 +-
.../cache/tier/sockets/CacheServerStats.java | 5 +-
.../cache/tier/sockets/ClientHealthMonitor.java | 278 +++--
.../tier/sockets/ClientProxyMembershipID.java | 9 +-
.../ClientRegistrationEventQueueManager.java | 312 +++++
.../tier/sockets/ClientRegistrationMetadata.java | 193 ++++
.../tier/sockets/ClientUpdateMessageImpl.java | 5 +-
.../internal/cache/tier/sockets/EncryptorImpl.java | 8 +-
.../tier/sockets/OriginalServerConnection.java | 35 +-
.../tier/sockets/ProtobufServerConnection.java | 44 +-
.../cache/tier/sockets/ServerConnection.java | 787 +++++++------
.../tier/sockets/ServerConnectionFactory.java | 49 +-
.../cache/tier/sockets/SocketMessageWriter.java | 102 ++
.../sockets/command/GatewayReceiverCommand.java | 179 +--
.../internal/cache/tier/sockets/command/Put65.java | 5 +-
.../internal/cache/wan/GatewayReceiverStats.java | 5 +-
.../internal/cache/xmlcache/CacheCreation.java | 18 +-
.../cache/xmlcache/CacheServerCreation.java | 58 +
.../cache/xmlcache/GatewayReceiverCreation.java | 12 +-
.../apache/geode/internal/net/NioPlainEngine.java | 1 +
.../apache/geode/internal/net/NioSslEngine.java | 15 +-
.../apache/geode/internal/offheap/DataType.java | 5 +-
.../org/apache/geode/internal/tcp/Connection.java | 12 +-
.../geode/internal/util/JavaWorkarounds.java | 12 +-
.../org/apache/geode/management/cli/Result.java | 29 +-
.../api/LocatorClusterManagementService.java | 77 +-
.../internal/beans/CacheServerBridge.java | 7 +-
.../internal/beans/GatewayReceiverMBean.java | 4 -
.../internal/beans/GatewayReceiverMBeanBridge.java | 134 +--
.../internal/beans/MemberMBeanBridge.java | 10 +-
.../management/internal/beans/ServerBridge.java | 6 +-
.../internal/cli/CliAroundInterceptor.java | 13 +-
.../geode/management/internal/cli/CliUtil.java | 1 +
.../management/internal/cli/CommandRequest.java | 2 +-
.../management/internal/cli/CommandResponse.java | 203 ----
.../internal/cli/CommandResponseBuilder.java | 85 --
.../internal/cli/CommandResponseWriter.java | 62 -
.../geode/management/internal/cli/LogWrapper.java | 30 -
.../cli/commands/ChangeLogLevelCommand.java | 10 +-
.../cli/commands/CreateGatewaySenderCommand.java | 10 +-
.../internal/cli/commands/DeployCommand.java | 21 +-
.../internal/cli/commands/ExportLogsCommand.java | 3 +-
.../ImportClusterConfigurationCommand.java | 8 +-
.../internal/cli/commands/ListClientCommand.java | 4 -
.../cli/commands/ListDiskStoresCommand.java | 4 +-
.../internal/cli/commands/QueryInterceptor.java | 15 +-
.../internal/cli/commands/ShowDeadlockCommand.java | 28 +-
.../internal/cli/commands/ShowMetricsCommand.java | 10 +-
.../cli/commands/ShowMetricsInterceptor.java | 20 +-
.../cli/commands/ShowMissingDiskStoreCommand.java | 4 +-
.../cli/commands/lifecycle/StartPulseCommand.java | 64 +-
.../cli/commands/lifecycle/StartVsdCommand.java | 61 +-
.../cli/functions/ContinuousQueryFunction.java | 10 +-
.../cli/remote/CommandExecutionContext.java | 24 -
.../internal/cli/remote/CommandExecutor.java | 28 +-
.../cli/remote/OnlineCommandProcessor.java | 15 +-
.../internal/cli/result/AbstractResultData.java | 294 -----
.../internal/cli/result/CommandResult.java | 219 +++-
.../internal/cli/result/CompositeResultData.java | 238 ----
.../internal/cli/result/DownloadFileResult.java | 73 --
.../internal/cli/result/ErrorResultData.java | 112 --
.../management/internal/cli/result/FileResult.java | 101 --
.../internal/cli/result/InfoResultData.java | 91 --
.../internal/cli/result/LegacyCommandResult.java | 540 ---------
.../internal/cli/result/ModelCommandResult.java | 361 ------
.../internal/cli/result/ResultBuilder.java | 399 -------
.../management/internal/cli/result/ResultData.java | 79 --
.../internal/cli/result/TabularResultData.java | 129 ---
.../internal/cli/result/model/FileResultModel.java | 55 +-
.../internal/cli/result/model/ResultModel.java | 94 +-
.../geode/management/internal/cli/shell/Gfsh.java | 18 +-
.../internal/cli/shell/GfshExecutionStrategy.java | 109 +-
.../internal/cli/shell/JmxOperationInvoker.java | 5 +-
.../internal/cli/shell/ScriptExecutionDetails.java | 5 +-
.../functions/DownloadJarFunction.java | 53 +-
.../mutators/ConfigurationManager.java | 3 +-
.../mutators/RegionConfigManager.java | 42 +-
.../validators/CacheElementValidator.java} | 26 +-
.../validators/RegionConfigValidator.java | 5 -
.../internal/web/http/support/HttpRequester.java | 6 +
.../internal/web/shell/HttpOperationInvoker.java | 2 +-
.../sanctioned-geode-core-serializables.txt | 2 -
.../java/org/apache/geode/DataSerializerTest.java | 18 +
.../client/internal/OpExecutorImplJUnitTest.java | 122 +-
.../cache/client/internal/TXFailoverOpTest.java | 2 +-
.../membership/InternalDistributedMemberTest.java | 183 +++
.../internal/ThreadLocalByteArrayCacheTest.java | 85 ++
.../internal/cache/AbstractRegionJUnitTest.java | 75 +-
.../geode/internal/cache/CacheServerImplTest.java | 198 ++++
.../geode/internal/cache/GemFireCacheImplTest.java | 217 +++-
.../internal/cache/PRHARedundancyProviderTest.java | 22 +-
.../geode/internal/cache/ServerBuilderTest.java | 146 +++
.../apache/geode/internal/cache/TXStateTest.java | 74 ++
.../partitioned/PersistentBucketRecovererTest.java | 69 ++
.../cache/tier/sockets/AcceptorBuilderTest.java | 379 ++++++
.../cache/tier/sockets/AcceptorImplTest.java | 120 ++
.../tier/sockets/CacheClientNotifierTest.java | 176 +++
.../cache/tier/sockets/CacheServerUtils.java | 55 -
...JUnitTest.java => ClientHealthMonitorTest.java} | 87 +-
.../ClientRegistrationEventQueueManagerTest.java | 250 ++++
.../tier/sockets/ProcessingMessageTimerTest.java | 86 ++
.../tier/sockets/ServerConnectionFactoryTest.java | 119 +-
.../cache/tier/sockets/ServerConnectionTest.java | 94 +-
.../cache/tier/sockets/command/Put65Test.java | 26 +
.../geode/internal/net/NioPlainEngineTest.java | 6 +-
.../geode/internal/net/NioSslEngineTest.java | 12 +-
.../api/LocatorClusterManagementServiceTest.java | 111 +-
.../beans/GatewayReceiverMBeanBridgeTest.java | 53 +
.../internal/cli/CommandManagerJUnitTest.java | 6 +-
.../commands/AlterAsyncEventQueueCommandTest.java | 6 +-
.../internal/cli/commands/ConnectCommandTest.java | 4 +-
.../commands/CreateAsyncEventQueueCommandTest.java | 18 +-
.../commands/CreateDefinedIndexesCommandTest.java | 36 +-
.../cli/commands/CreateIndexCommandTest.java | 46 +-
.../commands/DescribeJndiBindingCommandTest.java | 6 +-
.../DestroyAsyncEventQueueCommandTest.java | 6 +-
.../DestroyGatewayReceiverCommandTest.java | 2 +-
.../ExportClusterConfigurationCommandTest.java | 2 +-
.../cli/commands/ListGatewayCommandTest.java | 8 +-
.../cli/commands/ListMembersCommandTest.java | 16 +-
.../cli/commands/ShowMetricsJUnitTest.java | 26 +-
.../cli/remote/OnlineCommandProcessorTest.java | 13 +-
.../internal/cli/result/CommandResultTest.java | 71 --
.../cli/result/CompositeResultDataTest.java | 129 ---
.../internal/cli/result/ErrorResultDataTest.java | 72 --
.../internal/cli/result/FileResultTest.java | 16 +-
.../internal/cli/result/InfoResultDataTest.java | 60 -
.../internal/cli/result/ResultBuilderTest.java | 130 ---
.../internal/cli/result/TabularResultDataTest.java | 92 --
.../model/LegacyVsResultModelComparisonTest.java | 199 ----
.../internal/cli/result/model/ResultModelTest.java | 30 +
.../internal/cli/shell/GfshAbstractUnitTest.java | 12 +-
.../cli/shell/GfshExecutionStrategyTest.java | 29 +-
.../functions/DownloadJarFunctionTest.java | 55 +
.../mutators/RegionConfigManagerTest.java | 54 +
.../validators/CacheElementValidatorTest.java} | 36 +-
.../validators/RegionConfigValidatorTest.java | 9 -
.../RollingUpgrade2DUnitTestBase.java | 15 +-
.../cache/PRDeltaPropagationDUnitTest.java | 4 +-
.../tier/sockets/ClientToServerDeltaDUnitTest.java | 2 +-
.../sockets/DeltaPropagationWithCQDUnitTest.java | 2 +-
...ltaToRegionRelationCQRegistrationDUnitTest.java | 8 +-
.../cache/tier/sockets/DurableClientTestBase.java | 2 +-
.../commands/DurableClientCommandsDUnitTest.java | 7 +-
.../cli/commands/ListClientCommandDUnitTest.java | 2 +-
.../geode/security/CQPostProcessorDunitTest.java | 1 -
.../cache/query/cq/internal/command/ExecuteCQ.java | 4 +-
.../query/cq/internal/command/ExecuteCQ61.java | 4 +-
.../query/cq/internal/command/GetDurableCQs.java | 4 +-
...t_communication_have_enough_sockets.html.md.erb | 3 +-
geode-docs/reference/topics/cache_xml.html.md.erb | 5 -
.../reference/topics/client-cache.html.md.erb | 5 -
.../cs_configuration/chapter_overview.html.md.erb | 2 +-
.../client_server_whats_next.html.md.erb | 21 +-
.../apache/geode/cache30/ClientServerTestCase.java | 47 +-
.../membership/gms/MembershipManagerHelper.java | 4 +-
.../cache/execute/CustomerIDPartitionResolver.java | 6 +
.../cache/tier/sockets/CacheServerTestUtil.java | 1 -
.../sockets/ClientServerMiscDUnitTestBase.java | 11 +-
.../management/internal/cli/HeadlessGfsh.java | 20 +-
.../ExportLogsStatsDistributedTestBase.java | 5 +-
.../cli/commands/GcCommandDUnitTestBase.java | 7 +-
.../commands/GemfireDataCommandsDUnitTestBase.java | 11 +-
.../commands/IndexCommandsIntegrationTestBase.java | 44 +-
.../cli/commands/QueryCommandDUnitTestBase.java | 46 +-
.../commands/QueryCommandIntegrationTestBase.java | 66 +-
.../ShowLogCommandDistributedTestBase.java | 11 +-
.../security/GfshCommandsSecurityTestBase.java | 47 +-
.../geode/test/dunit/rules/ClientCacheRule.java | 2 +-
.../apache/geode/test/dunit/rules/MemberVM.java | 80 +-
.../geode/test/junit/rules/GfshCommandRule.java | 18 +-
.../geode/test/junit/rules/LocatorStarterRule.java | 29 +
.../junit/rules/MBeanServerConnectionRule.java | 45 +-
.../geode/test/junit/rules/MemberStarterRule.java | 5 +-
.../geode/test/junit/rules/ServerStarterRule.java | 29 +
.../management/internal/security/TestCommand.java | 6 +-
.../java/org/apache/geode/test/fake/Fakes.java | 9 +-
.../assertions/ClusterManagementResultAssert.java | 4 +-
.../test/junit/assertions/CommandResultAssert.java | 137 +--
.../test/junit/assertions/ResultModelAssert.java | 4 +
.../geode/test/junit/rules/GfshParserRule.java | 20 +-
.../lucene/LuceneCommandsSecurityDUnitTest.java | 8 +-
.../cli/DestroyLuceneIndexCommandsDUnitTest.java | 2 +-
.../LuceneClusterConfigurationDUnitTest.java | 5 +-
.../cli/LuceneIndexCommandsIntegrationTest.java | 7 +-
.../lucene/test/LuceneFunctionSecurityTest.java | 6 +-
.../internal/cli/LuceneSearchIndexCommand.java | 5 +-
.../internal/cli/LuceneIndexCommandsJUnitTest.java | 15 +-
.../geode/cache/configuration/CacheElement.java | 40 +-
.../apache/geode/cache/configuration/PoolType.java | 74 +-
.../geode/cache/configuration/RegionConfig.java | 24 +
.../management/api/ClusterManagementResult.java | 8 +-
.../management/configuration/MemberConfig.java | 6 +-
.../configuration/RuntimeCacheElement.java | 27 +-
.../configuration/RuntimeRegionConfig.java | 34 +-
.../configuration/CacheElementJsonMappingTest.java | 54 +-
.../cache/configuration/CacheElementTest.java | 102 ++
...st.java => CacheConnectionIntegrationTest.java} | 87 +-
...java => CacheMaxConnectionIntegrationTest.java} | 67 +-
.../OutputCapturingServerConnectionTest.java | 88 +-
.../tier/sockets/ProtobufServerConnectionTest.java | 170 +--
.../cache/wan/CacheClientNotifierDUnitTest.java | 9 +-
.../PauseGatewaySenderCommandDUnitTest.java | 2 +-
.../ResumeGatewaySenderCommandDUnitTest.java | 9 +-
.../StartGatewayReceiverCommandDUnitTest.java | 9 +-
.../StartGatewaySenderCommandDUnitTest.java | 11 +-
.../StatusGatewayReceiverCommandDUnitTest.java | 13 +-
.../StatusGatewaySenderCommandDUnitTest.java | 17 +-
.../StopGatewayReceiverCommandDUnitTest.java | 9 +-
.../StopGatewaySenderCommandDUnitTest.java | 6 +-
.../cache/wan/GatewayReceiverFactoryImpl.java | 6 +-
.../internal/cache/wan/GatewayReceiverImpl.java | 167 ++-
.../wan/GatewaySenderEventRemoteDispatcher.java | 3 +-
.../wan/GatewayReceiverFactoryImplJUnitTest.java | 135 ---
.../cache/wan/GatewayReceiverFactoryImplTest.java | 297 +++++
.../cache/wan/GatewayReceiverImplJUnitTest.java | 182 ---
.../cache/wan/GatewayReceiverImplTest.java | 183 +++
.../ClientClusterManagementServiceDUnitTest.java | 15 +-
.../rest/RegionManagementIntegrationTest.java | 13 +
.../cli/commands/AlterRuntimeCommandDUnitTest.java | 93 +-
.../commands/ClusterConfigurationDUnitTest.java | 2 +-
.../ShellCommandsControllerProcessCommandTest.java | 50 +-
.../web/controllers/ShellCommandsController.java | 10 +-
...rverSerializableObjectHttpMessageConverter.java | 3 +-
gradle.properties | 2 +-
gradle/wrapper/gradle-wrapper.properties | 2 +-
settings.gradle | 3 +-
430 files changed, 12180 insertions(+), 11209 deletions(-)
create mode 100755 ci/pipelines/meta/destroy_pipelines.sh
create mode 100644 dev-tools/release/README.md
create mode 100755 dev-tools/release/prepare_rc.sh
create mode 100755 dev-tools/release/print_rc_email.sh
create mode 100644
extensions/geode-modules/src/integrationTest/java/org/apache/geode/modules/util/BootstrappingFunctionTest.java
create mode 100644
geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/rest/ServerRestartTest.java
rename geode-concurrency-test/src/{test =>
integrationTest}/java/org/apache/geode/test/concurrency/ConcurrentTestRunnerTest.java
(97%)
copy
geode-core/src/{main/java/org/apache/geode/internal/cache/InternalCacheServer.java
=>
integrationTest/java/org/apache/geode/internal/cache/LocatorMisconfigurationTest.java}
(56%)
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/ServerBuilderIntegrationTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/tier/sockets/AcceptorImplIntegrationTest.java
delete mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/tier/sockets/AcceptorImplJUnitTest.java
delete mode 100644
geode-core/src/integrationTest/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifierIntegrationTest.java
rename
geode-core/src/integrationTest/java/org/apache/geode/management/bean/stats/{CacheServerStatsJUnitTest.java
=> CacheServerStatsIntegrationTest.java} (96%)
rename
geode-core/src/integrationTest/java/org/apache/geode/management/bean/stats/{GatewayReceiverStatsJUnitTest.java
=> GatewayReceiverStatsIntegrationTest.java} (69%)
create mode 100644
geode-core/src/jmh/java/org/apache/geode/internal/InternalDataSerializerBenchmark.java
create mode 100644
geode-core/src/jmh/java/org/apache/geode/internal/logging/log4j/FastLoggerDisabledLevelBenchmark.java
create mode 100644
geode-core/src/jmh/java/org/apache/geode/internal/logging/log4j/FastLoggerEnabledLevelBenchmark.java
create mode 100644
geode-core/src/jmh/java/org/apache/geode/internal/logging/log4j/FastLoggerParameterTypeBenchmark.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/ThreadLocalByteArrayCache.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/ServerBuilder.java
copy
geode-core/src/main/java/org/apache/geode/{management/internal/cli/result/ResultDataException.java
=> internal/cache/ServerFactory.java} (73%)
rename
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/{RedundancyLogger.java
=> PersistentBucketRecoverer.java} (81%)
copy
geode-core/src/main/java/org/apache/geode/{management/internal/cli/result/ResultDataException.java
=> internal/cache/tier/OverflowAttributes.java} (67%)
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/AcceptorBuilder.java
copy
geode-core/src/main/java/org/apache/geode/internal/cache/{InternalCacheServer.java
=> tier/sockets/AcceptorFactory.java} (69%)
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientRegistrationEventQueueManager.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientRegistrationMetadata.java
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/SocketMessageWriter.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/CommandResponse.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/CommandResponseBuilder.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/CommandResponseWriter.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/AbstractResultData.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/CompositeResultData.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/DownloadFileResult.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/ErrorResultData.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/FileResult.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/InfoResultData.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/LegacyCommandResult.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/ModelCommandResult.java
delete mode 100755
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/ResultBuilder.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/ResultData.java
delete mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/TabularResultData.java
copy
geode-core/src/main/java/org/apache/geode/management/internal/{cli/result/ResultDataException.java
=> configuration/validators/CacheElementValidator.java} (52%)
create mode 100644
geode-core/src/test/java/org/apache/geode/distributed/internal/membership/InternalDistributedMemberTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/ThreadLocalByteArrayCacheTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/CacheServerImplTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/ServerBuilderTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/partitioned/PersistentBucketRecovererTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/AcceptorBuilderTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/AcceptorImplTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifierTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/CacheServerUtils.java
rename
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/{ClientHealthMonitorJUnitTest.java
=> ClientHealthMonitorTest.java} (50%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/ClientRegistrationEventQueueManagerTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/ProcessingMessageTimerTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/beans/GatewayReceiverMBeanBridgeTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/CommandResultTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/CompositeResultDataTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/ErrorResultDataTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/InfoResultDataTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/ResultBuilderTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/TabularResultDataTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/cli/result/model/LegacyVsResultModelComparisonTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/configuration/functions/DownloadJarFunctionTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/configuration/mutators/RegionConfigManagerTest.java
rename
geode-core/src/test/java/org/apache/geode/management/internal/{cli/result/DownloadFileResultTest.java
=> configuration/validators/CacheElementValidatorTest.java} (51%)
copy
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/ResultDataException.java
=>
geode-management/src/main/java/org/apache/geode/management/configuration/RuntimeCacheElement.java
(59%)
rename
geode-core/src/main/java/org/apache/geode/management/internal/cli/result/ResultDataException.java
=>
geode-management/src/main/java/org/apache/geode/management/configuration/RuntimeRegionConfig.java
(56%)
create mode 100644
geode-management/src/test/java/org/apache/geode/cache/configuration/CacheElementTest.java
rename
geode-protobuf/src/integrationTest/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/{CacheConnectionJUnitTest.java
=> CacheConnectionIntegrationTest.java} (78%)
rename
geode-protobuf/src/integrationTest/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/{CacheMaxConnectionJUnitTest.java
=> CacheMaxConnectionIntegrationTest.java} (82%)
delete mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverFactoryImplJUnitTest.java
create mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverFactoryImplTest.java
delete mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverImplJUnitTest.java
create mode 100644
geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverImplTest.java
