This is an automated email from the ASF dual-hosted git repository. amurmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/geode.git
commit 14bfde0bf0d174fea30a86b3bde4d479f2e1b2eb Merge: 48061cd 671671b Author: Alexander Murmann <[email protected]> AuthorDate: Wed Dec 12 14:26:43 2018 -0800 Merge branch 'release/1.8.0' .gitignore | 1 + BUILDING.md | 57 + KEYS | 59 + README.md | 5 + TESTING.md | 38 + build.gradle | 56 +- buildSrc/build.gradle | 1 - .../org/apache/geode/gradle/RepeatTest.groovy | 40 +- .../org/apache/geode/javac/CompilerException.java | 22 + .../geode/javac/TestAnnotationProcessor.java | 3 +- .../java/org/apache/geode/javac/TestCompiler.java | 4 +- ci/bin/concourse_job_performance.py | 47 +- ci/docker/cache_dependencies.sh | 23 +- ci/images/alpine-tools/Dockerfile | 7 +- ci/images/google-geode-builder/build_image.sh | 37 +- ci/images/google-geode-builder/packer.json | 17 +- .../scripts/cache_dependencies.sh | 25 +- ci/images/google-geode-builder/scripts/setup.sh | 12 +- .../google-windows-geode-builder/build_image.sh | 61 + .../windows-packer.json | 98 + ci/images/meta-mini/Dockerfile | 8 +- ci/images/test-container/Dockerfile | 12 +- ci/pipelines/clean_fork_pipelines.sh | 20 +- ci/pipelines/deploy_meta.sh | 82 - ci/pipelines/examples/deploy_pipeline.sh | 67 +- ci/pipelines/examples/jinja.template.yml | 112 +- ci/pipelines/geode-build/deploy_pipeline.sh | 83 +- ci/pipelines/geode-build/jinja.template.yml | 407 +- ci/pipelines/images/deploy_images_pipeline.sh | 55 +- ci/pipelines/images/images.yml | 249 - ci/pipelines/images/jinja.template.yml | 293 + ci/pipelines/meta.yml | 276 - ci/pipelines/meta/README.md | 62 + ci/pipelines/meta/deploy_meta.sh | 244 + ci/pipelines/meta/jinja.template.yml | 374 + ci/pipelines/meta/meta.properties | 26 + ci/pipelines/metrics.yml | 163 - ci/pipelines/metrics/deploy_metrics_pipeline.sh | 66 + ci/pipelines/metrics/jinja.template.yml | 73 + ci/pipelines/pull-request/deploy_pr_pipeline.sh | 32 +- ci/pipelines/pull-request/jinja.template.yml | 34 +- ci/pipelines/reaper.yml | 10 +- ci/pipelines/render.py | 24 +- ci/pipelines/shared/jinja.variables.yml | 87 +- ci/pipelines/shared/shared_jinja.yml | 18 +- ci/pipelines/shared/utilities.sh | 12 +- ci/scripts/archive_results.sh | 16 +- ci/scripts/build-examples.sh | 26 - ci/scripts/build.sh | 8 +- ci/scripts/capture-call-stacks.sh | 5 +- ci/scripts/create_instance.sh | 139 + ci/scripts/delete_instance.sh | 40 + ci/scripts/execute_build.sh | 18 +- ci/scripts/execute_build_examples.sh | 54 + ci/scripts/execute_publish.sh | 74 + ci/scripts/execute_tests.sh | 38 +- ci/scripts/publish.sh | 4 +- ci/scripts/repeat-new-tests.sh | 60 +- ci/scripts/rsync_code_down.sh | 22 +- ci/scripts/rsync_code_up.sh | 10 +- ci/scripts/start_instance.sh | 110 - ci/scripts/stop_instance.sh | 41 - ci/scripts/test-archive.sh | 2 +- ci/scripts/update-passing-ref.sh | 2 +- ci/scripts/windows/test-archive.sh | 2 +- ci/scripts/windows/test-run.sh | 2 - docker/Dockerfile | 4 +- extensions/geode-modules-assembly/build.gradle | 60 +- .../release/session/bin/modify_war | 31 +- .../geode-cs-tomcat-9/context-fragment.xml | 15 + .../geode-p2p-tomcat-9/context-fragment.xml | 15 + .../geode-modules-session-internal/build.gradle | 11 +- extensions/geode-modules-session/build.gradle | 39 +- .../session/installer/InstallerJUnitTest.java | 4 +- extensions/geode-modules-test/build.gradle | 26 +- extensions/geode-modules-tomcat7/build.gradle | 26 +- extensions/geode-modules-tomcat8/build.gradle | 25 +- .../Tomcat8SessionsClientServerDUnitTest.java | 3 + .../modules/session/Tomcat8SessionsDUnitTest.java | 3 + extensions/geode-modules-tomcat9/build.gradle | 47 + .../modules/session/catalina/DeltaSession9.java | 39 + .../catalina/Tomcat9DeltaSessionManager.java | 140 + extensions/geode-modules/build.gradle | 30 +- .../gatewaydelta/GatewayDeltaCreateEvent.java | 3 +- .../GatewayDeltaForwarderCacheListener.java | 4 - .../catalina/Tomcat6DeltaSessionManager.java | 4 + .../geode/modules/util/CreateRegionFunction.java | 9 +- extensions/session-testing-war/build.gradle | 3 +- geode-assembly/build.gradle | 269 +- geode-assembly/geode-assembly-test/build.gradle | 22 +- .../geode/session/tests/ContainerInstall.java | 8 +- .../geode/session/tests/ServerContainer.java | 13 +- .../apache/geode/session/tests/TomcatInstall.java | 33 +- .../geode/test/junit/rules/GeodeDevRestClient.java | 5 + .../cli/commands/ConnectCommandAcceptanceTest.java | 4 + .../GfshStartLocatorLogAcceptanceTest.java | 59 + .../cli/commands/GfshStartLocatorLogTest.java | 54 - ...scribeConfigAreFullyRedactedAcceptanceTest.java | 6 +- .../cli/commands/StartLocatorAcceptanceTest.java | 2 +- .../cli/commands/StartLocatorCommandDUnitTest.java | 202 +- .../cli/commands/StartServerCommandDUnitTest.java | 224 +- .../cli/commands/StopLocatorCommandDUnitTest.java | 7 +- .../web/controllers/RestAPIsWithSSLDUnitTest.java | 594 +- .../tests/GenericAppServerClientServerTest.java | 5 +- .../session/tests/GenericAppServerInstall.java | 5 +- .../session/tests/Tomcat9ClientServerTest.java | 42 + .../apache/geode/session/tests/Tomcat9Test.java | 41 + .../geode/AssemblyContentsIntegrationTest.java | 2 +- .../internal/web/RestSecurityIntegrationTest.java | 12 +- .../web/SwaggerVerificationIntegrationTest.java | 5 +- .../RestQueryAndFunctionIntegrationTest.java | 955 --- .../tools/pulse/PulseSecurityIntegrationTest.java | 5 +- .../integrationTest/resources/assembly_content.txt | 89 +- .../resources/dependency_classpath.txt | 42 +- .../integrationTest/resources/expected_jars.txt | 3 + geode-assembly/src/main/dist/LICENSE | 21 +- .../cli/commands/StartLocatorCommandTest.java | 80 +- .../StartLocatorCommandWorkingDirectoryTest.java | 152 + .../cli/commands/StartServerCommandTest.java | 27 + .../StartServerCommandWorkingDirectoryTest.java | 146 + geode-assembly/src/test/resources/expected-pom.xml | 4 +- ...omcatSessionBackwardsCompatibilityTestBase.java | 4 +- geode-common/build.gradle | 4 - geode-common/src/test/resources/expected-pom.xml | 2 +- geode-concurrency-test/build.gradle | 4 +- .../src/test/resources/expected-pom.xml | 2 +- geode-connectors/build.gradle | 65 +- .../jdbc/ClassWithSupportedPdxFields.java | 20 +- .../jdbc/CreatePooledJndiBindingDUnitTest.java | 109 + .../org/apache/geode/connectors/jdbc/Employee.java | 10 +- .../jdbc/JdbcAsyncWriterIntegrationTest.java | 30 +- .../geode/connectors/jdbc/JdbcDistributedTest.java | 50 +- .../connectors/jdbc/JdbcLoaderIntegrationTest.java | 26 +- .../connectors/jdbc/JdbcWriterIntegrationTest.java | 27 +- .../connectors/jdbc/TestDataSourceFactory.java | 47 + .../jdbc/internal/TestConfigService.java | 20 +- .../jdbc/internal/TestableConnectionManager.java | 22 - .../test/junit/rules/MySqlConnectionRule.java | 5 +- .../junit/rules/SqlDatabaseConnectionRule.java | 5 +- .../cli/AlterConnectionCommandDUnitTest.java | 136 - .../internal/cli/AlterMappingCommandDUnitTest.java | 144 - .../cli/CreateConnectionCommandDUnitTest.java | 109 - .../cli/CreateMappingCommandDUnitTest.java | 80 +- .../cli/DescribeConnectionCommandDUnitTest.java | 134 - .../cli/DescribeMappingCommandDUnitTest.java | 32 +- .../cli/DestroyConnectionCommandDUnitTest.java | 101 - .../cli/DestroyMappingCommandDunitTest.java | 27 +- .../cli/JdbcClusterConfigDistributedTest.java | 21 +- .../cli/ListConnectionCommandDUnitTest.java | 118 - .../internal/cli/ListMappingCommandDUnitTest.java | 13 +- .../cli/AlterConnectionCommandIntegrationTest.java | 84 - .../cli/AlterMappingCommandIntegrationTest.java | 86 - .../CreateConnectionCommandIntegrationTest.java | 125 - .../cli/CreateMappingCommandIntegrationTest.java | 46 +- .../DestroyConnectionCommandIntegrationTest.java | 84 - .../cli/DestroyMappingCommandIntegrationTest.java | 6 +- .../cli/JDBCConnectorFunctionsSecurityTest.java | 4 - .../apache/geode/codeAnalysis/excludedClasses.txt | 3 - .../jdbc/JdbcPooledDataSourceFactory.java | 86 + .../jdbc/internal/AbstractJdbcCallback.java | 9 +- .../internal/ConnectionConfigExistsException.java | 33 - .../ConnectionConfigNotFoundException.java | 34 - .../jdbc/internal/DataSourceManager.java | 48 - .../jdbc/internal/HikariJdbcDataSource.java | 47 - .../jdbc/internal/HikariJdbcDataSourceFactory.java | 23 - .../jdbc/internal/JdbcConnectorService.java | 24 +- .../jdbc/internal/JdbcConnectorServiceImpl.java | 74 +- .../connectors/jdbc/internal/JdbcDataSource.java | 22 - .../jdbc/internal/JdbcDataSourceFactory.java | 27 - .../geode/connectors/jdbc/internal/SqlHandler.java | 66 +- .../jdbc/internal/SqlToPdxInstanceCreator.java | 19 +- .../jdbc/internal/cli/AlterConnectionCommand.java | 120 - .../jdbc/internal/cli/AlterConnectionFunction.java | 75 - .../jdbc/internal/cli/AlterMappingCommand.java | 129 - .../jdbc/internal/cli/AlterMappingFunction.java | 79 - .../jdbc/internal/cli/CreateConnectionCommand.java | 131 - .../internal/cli/CreateConnectionFunction.java | 48 - .../jdbc/internal/cli/CreateMappingCommand.java | 52 +- .../jdbc/internal/cli/CreateMappingFunction.java | 23 +- .../internal/cli/DescribeConnectionCommand.java | 120 - .../internal/cli/DescribeConnectionFunction.java | 31 - .../jdbc/internal/cli/DescribeMappingCommand.java | 54 +- .../internal/cli/DestroyConnectionCommand.java | 71 - .../internal/cli/DestroyConnectionFunction.java | 42 - .../jdbc/internal/cli/DestroyMappingCommand.java | 20 +- .../jdbc/internal/cli/DestroyMappingFunction.java | 4 +- .../jdbc/internal/cli/ListConnectionCommand.java | 106 - .../jdbc/internal/cli/ListConnectionFunction.java | 29 - .../jdbc/internal/cli/ListMappingCommand.java | 46 +- .../internal/configuration/ConnectorService.java | 836 --- .../jdbc/internal/configuration/RegionMapping.java | 269 + .../connectors/jdbc/internal/xml/ElementType.java | 92 +- .../xml/JdbcConnectorServiceXmlParser.java | 4 +- .../internal/xml/JdbcServiceConfiguration.java | 79 - .../internal/xml/RegionMappingConfiguration.java | 64 + .../ConnectorsDistributedSystemService.java | 2 +- .../geode.apache.org/schema/jdbc/jdbc-1.0.xsd | 50 +- .../org.springframework.shell.core.CommandMarker | 6 - .../sanctioned-geode-connectors-serializables.txt | 13 +- .../jdbc/JdbcPooledDataSourceFactoryTest.java | 94 + .../jdbc/internal/AbstractJdbcCallbackTest.java | 16 - .../jdbc/internal/DataSourceManagerUnitTest.java | 98 - .../jdbc/internal/JdbcConnectorServiceTest.java | 51 +- .../jdbc/internal/RegionMappingTest.java | 195 +- .../connectors/jdbc/internal/SqlHandlerTest.java | 43 +- .../jdbc/internal/SqlToPdxInstanceCreatorTest.java | 39 +- .../internal/cli/AlterConnectionCommandTest.java | 151 - .../internal/cli/AlterConnectionFunctionTest.java | 247 - .../jdbc/internal/cli/AlterMappingCommandTest.java | 159 - .../internal/cli/AlterMappingFunctionTest.java | 289 - .../cli/ConnectionsCommandManagerJUnitTest.java | 80 + .../internal/cli/CreateConnectionFunctionTest.java | 133 - .../internal/cli/CreateMappingFunctionTest.java | 30 +- .../cli/DescribeConnectionCommandTest.java | 144 - .../cli/DescribeConnectionFunctionTest.java | 134 - .../internal/cli/DescribeMappingCommandTest.java | 78 +- .../internal/cli/DescribeMappingFunctionTest.java | 6 +- .../cli/DestroyConnectionFunctionTest.java | 122 - .../cli/DestroyMappingCommandFunctionTest.java | 6 +- .../internal/cli/JDBCCommandsAvailabilityTest.java | 45 - .../internal/cli/ListConnectionCommandTest.java | 152 - .../internal/cli/ListConnectionFunctionTest.java | 166 - .../jdbc/internal/cli/ListMappingCommandTest.java | 90 +- .../jdbc/internal/cli/ListMappingFunctionTest.java | 28 +- .../configuration/ConnectorServiceTest.java | 99 - .../jdbc/internal/xml/ElementTypeTest.java | 185 +- .../xml/JdbcConnectorServiceXmlParserTest.java | 54 +- .../internal/xml/JdbcServiceConfigurationTest.java | 84 - .../src/test/resources/expected-pom.xml | 68 +- geode-core/build.gradle | 319 +- .../geode/cache/ClientServerTimeSyncDUnitTest.java | 56 +- .../geode/cache/ConnectionPoolDUnitTest.java | 56 +- .../CreateAndLocalDestroyInTXRegressionTest.java | 15 +- .../cache/RegionExpirationDistributedTest.java | 12 +- .../internal/AutoConnectionSourceDUnitTest.java | 24 +- .../CacheServerSSLConnectionDUnitTest.java | 15 +- ...tServerHostNameVerificationDistributedTest.java | 3 + .../internal/CustomSSLProviderDistributedTest.java | 273 + .../internal/LocatorLoadBalancingDUnitTest.java | 36 +- .../internal/provider/CustomKeyManagerFactory.java | 107 + .../provider/CustomTrustManagerFactory.java | 106 + .../management/MemoryThresholdsDUnitTest.java | 154 +- .../MemoryThresholdsOffHeapDUnitTest.java | 39 +- .../cache/query/dunit/CompiledInDUnitTest.java | 44 +- .../cache/query/dunit/CqTimeTestListener.java | 12 +- .../geode/cache/query/dunit/PDXQueryTestBase.java | 21 +- ...artitionedRegionCompactRangeIndexDUnitTest.java | 89 +- .../cache/query/dunit/PdxLocalQueryDUnitTest.java | 2 +- .../geode/cache/query/dunit/PdxQueryDUnitTest.java | 205 +- .../cache/query/dunit/PdxStringQueryDUnitTest.java | 28 +- .../cache/query/dunit/PortfolioPdxVersion.java | 10 +- .../dunit/QueryDataInconsistencyDUnitTest.java | 38 +- .../query/dunit/QueryIndexUsingXMLDUnitTest.java | 8 +- .../cache/query/dunit/QueryUsingPoolDUnitTest.java | 51 +- .../cache/query/dunit/RemoteQueryDUnitTest.java | 42 +- .../ResourceManagerWithQueryMonitorDUnitTest.java | 223 +- .../internal/index/CopyOnReadIndexDUnitTest.java | 94 +- .../index/IndexTrackingQueryObserverDUnitTest.java | 19 +- .../InitializeIndexEntryDestroyQueryDUnitTest.java | 11 +- .../index/PutAllWithIndexPerfDUnitTest.java | 6 +- .../partitioned/PRColocatedEquiJoinDUnitTest.java | 6 +- .../geode/cache/snapshot/SnapshotDUnitTest.java | 5 +- .../apache/geode/cache30/CacheXml66DUnitTest.java | 37 +- .../geode/cache30/CacheXmlGeode10DUnitTest.java | 24 +- .../geode/cache30/ClientMembershipDUnitTest.java | 206 +- .../cache30/ClientRegisterInterestDUnitTest.java | 100 +- .../geode/cache30/ClientServerCCEDUnitTest.java | 28 +- .../cache30/ConcurrentLeaveDuringGIIDUnitTest.java | 29 +- .../geode/cache30/DiskRegionDistributedTest.java | 10 +- .../cache30/DistributedAckRegionCCEDUnitTest.java | 5 +- .../DistributedNoAckRegionCCEDUnitTest.java | 24 +- .../DistributedNoAckRegionCCEOffHeapDUnitTest.java | 2 +- .../cache30/DistributedNoAckRegionDUnitTest.java | 3 +- .../apache/geode/cache30/LocalRegionDUnitTest.java | 2 +- .../cache30/PRBucketSynchronizationDUnitTest.java | 4 +- .../cache30/PutAllCallBkRemoteVMDUnitTest.java | 7 +- .../apache/geode/cache30/QueueMsgDUnitTest.java | 45 +- .../geode/cache30/RRSynchronizationDUnitTest.java | 4 +- .../apache/geode/cache30/ReconnectDUnitTest.java | 418 +- .../cache30/ReconnectWithCacheXMLDUnitTest.java | 5 +- .../cache30/RegionMembershipListenerDUnitTest.java | 7 +- .../geode/cache30/RegionReliabilityTestCase.java | 32 +- .../geode/cache30/RequiredRolesDUnitTest.java | 50 +- .../org/apache/geode/cache30/SlowRecDUnitTest.java | 79 +- .../geode/cache30/TXDistributedDUnitTest.java | 6 +- .../DistributedLockServiceDUnitTest.java | 1379 ++-- .../distributed/DistributedMemberDUnitTest.java | 7 +- .../distributed/GrantorFailoverDUnitTest.java | 182 + .../apache/geode/distributed/LocatorDUnitTest.java | 45 +- .../geode/distributed/ServerLauncherDUnitTest.java | 5 +- .../ClusterDistributionManagerDUnitTest.java | 14 +- ...lusterDistributionManagerForAdminDUnitTest.java | 13 +- .../internal/DistributionAdvisorDUnitTest.java | 11 +- .../internal/ElderMemberDistributedTest.java | 126 + .../deadlock/GemFireDeadlockDetectorDUnitTest.java | 8 +- .../locks/DLockServiceCharacterizationTests.java | 207 +- .../disttx/DistributedTransactionDUnitTest.java | 78 +- .../internal/cache/CacheAdvisorDUnitTest.java | 6 +- ...eanupFailedInitWithDiskFilesRegressionTest.java | 5 +- .../ClearDuringNetSearchOplogRegressionTest.java | 5 +- ...entDeserializationCopyOnReadRegressionTest.java | 5 +- .../cache/ClientServerTransactionDUnitTest.java | 78 +- ...ntServerTransactionFailoverDistributedTest.java | 123 +- ...overWithMixedVersionServersDistributedTest.java | 9 +- .../internal/cache/ConcurrentMapOpsDUnitTest.java | 12 +- .../internal/cache/DeltaPropagationDUnitTest.java | 12 +- .../cache/DeltaPropagationStatsDUnitTest.java | 6 +- .../EntriesDoNotExpireDuringGiiRegressionTest.java | 7 +- ...FireAndForgetFunctionOnAllServersDUnitTest.java | 17 +- .../internal/cache/FixedPRSinglehopDUnitTest.java | 21 +- .../geode/internal/cache/GIIDeltaDUnitTest.java | 60 +- .../internal/cache/GIIFlowControlDUnitTest.java | 35 +- .../geode/internal/cache/GridAdvisorDUnitTest.java | 42 +- .../geode/internal/cache/MapClearGIIDUnitTest.java | 9 +- .../cache/NetSearchMessagingDUnitTest.java | 337 +- .../cache/P2PDeltaPropagationDUnitTest.java | 8 +- .../PRAccessorWithOverflowRegressionTest.java | 5 +- .../PREntryIdleExpirationDistributedTest.java | 6 +- .../internal/cache/PRQueryDistributedTest.java | 184 +- .../PartitionedRegionCacheCloseDUnitTest.java | 5 +- .../cache/PartitionedRegionCreationDUnitTest.java | 4 +- .../cache/PartitionedRegionDestroyDUnitTest.java | 5 +- .../cache/PartitionedRegionEvictionDUnitTest.java | 22 +- ...itionedRegionHAFailureAndRecoveryDUnitTest.java | 5 +- ...edRegionLowBucketRedundancyDistributedTest.java | 7 +- .../cache/PartitionedRegionMultipleDUnitTest.java | 10 +- .../cache/PartitionedRegionSingleHopDUnitTest.java | 116 +- ...nedRegionSingleHopWithServerGroupDUnitTest.java | 8 +- .../cache/PartitionedRegionStatsDUnitTest.java | 5 +- .../cache/PersistentRegionRecoveryDUnitTest.java | 7 +- .../PersistentRegionTransactionDUnitTest.java | 6 +- .../internal/cache/RemoteTransactionDUnitTest.java | 33 +- ...eplicateEntryIdleExpirationDistributedTest.java | 14 +- .../internal/cache/SingleHopStatsDUnitTest.java | 7 +- .../geode/internal/cache/SizingFlagDUnitTest.java | 17 +- .../backup/IncrementalBackupDistributedTest.java | 6 +- .../PrepareAndFinishBackupDistributedTest.java | 4 +- .../cache/control/RebalanceOperationDUnitTest.java | 5 +- .../cache/event/EventTrackerDUnitTest.java | 6 +- .../internal/cache/eviction/EvictionDUnitTest.java | 416 +- .../internal/cache/eviction/EvictionTestBase.java | 532 -- .../cache/eviction/OffHeapEvictionDUnitTest.java | 147 - .../ClientServerFunctionExecutionDUnitTest.java | 7 +- .../cache/execute/ColocationFailoverDUnitTest.java | 5 +- ...istributedRegionFunctionExecutionDUnitTest.java | 85 +- .../execute/FunctionServiceStatsDUnitTest.java | 14 +- .../execute/MemberFunctionExecutionDUnitTest.java | 11 +- .../OnGroupsFunctionExecutionDUnitTest.java | 33 +- ...ientServerRegionFunctionExecutionDUnitTest.java | 9 +- ...egionFunctionExecutionNoSingleHopDUnitTest.java | 5 +- ...ctionExecutionSelectorNoSingleHopDUnitTest.java | 5 +- ...rRegionFunctionExecutionSingleHopDUnitTest.java | 5 +- .../cache/execute/PRClientServerTestBase.java | 44 +- .../cache/execute/PRColocationDUnitTest.java | 4 +- .../execute/PRFunctionExecutionDUnitTest.java | 11 +- .../execute/SingleHopGetAllPutAllDUnitTest.java | 297 +- ...dRegionFunctionFunctionInvocationException.java | 56 - .../cache/functions/DistributedRegionFunction.java | 14 +- ...dRegionFunctionFunctionInvocationException.java | 56 + .../cache/ha/EventIdOptimizationDUnitTest.java | 5 +- .../geode/internal/cache/ha/FailoverDUnitTest.java | 11 +- .../internal/cache/ha/HAConflationDUnitTest.java | 7 +- .../cache/ha/HAEventIdPropagationDUnitTest.java | 7 +- .../geode/internal/cache/ha/HAExpiryDUnitTest.java | 11 +- .../geode/internal/cache/ha/HAGIIDUnitTest.java | 26 +- .../cache/ha/HARQueueNewImplDUnitTest.java | 44 +- .../internal/cache/ha/HARegionQueueDUnitTest.java | 38 +- .../ha/HARegionQueueExpiryRegressionTest.java | 5 +- .../cache/ha/HARegionQueueSizeRegressionTest.java | 9 +- .../HARegionQueueThreadIdExpiryRegressionTest.java | 5 +- .../internal/cache/ha/HASlowReceiverDUnitTest.java | 7 +- .../cache/ha/OperationsPropagationDUnitTest.java | 22 +- .../ha/PreferSerializedHARegionQueueTest.java | 7 +- .../cache/locks/TXLockServiceDUnitTest.java | 11 +- ...BucketCreationCrashCompletesRegressionTest.java | 5 +- .../internal/cache/partitioned/MockAppender.java | 61 + ...RDiskConflictWithColocationDistributedTest.java | 4 +- .../partitioned/PartitionResolverDUnitTest.java | 4 +- ...sistentColocatedPartitionedRegionDUnitTest.java | 306 +- ...PersistentPartitionedRegionDistributedTest.java | 35 +- .../PersistentPartitionedRegionRegressionTest.java | 10 +- .../PersistentPartitionedRegionTestBase.java | 20 +- ...eueRemovalMessageProcessingDistributedTest.java | 9 +- .../cache/partitioned/ShutdownAllDUnitTest.java | 26 +- ...PartitioningWithTransactionDistributedTest.java | 375 + .../PersistentRVVRecoveryDUnitTest.java | 15 +- .../PersistentRecoveryOrderDUnitTest.java | 44 +- .../persistence/PersistentReplicatedTestBase.java | 6 +- .../AcceptorImplClientQueueDistributedTest.java | 5 +- .../cache/tier/sockets/AcceptorImplDUnitTest.java | 15 +- .../sockets/CacheServerTransactionsDUnitTest.java | 32 +- .../CacheServerTransactionsSelectorDUnitTest.java | 2 +- .../tier/sockets/ClientConflationDUnitTest.java | 25 +- ...entDestroyRegionNotificationRegressionTest.java | 7 +- .../sockets/ClientInterestNotifyDUnitTest.java | 9 +- .../ClientProxyWithDeltaDistributedTest.java | 7 +- .../ClientServerForceInvalidateDUnitTest.java | 8 +- .../tier/sockets/ClientServerMiscDUnitTest.java | 8 +- .../ClientWithInterestFailoverDistributedTest.java | 7 +- .../cache/tier/sockets/ConflationDUnitTest.java | 21 +- .../DataSerializerPropagationDUnitTest.java | 10 +- .../sockets/DestroyEntryPropagationDUnitTest.java | 13 +- .../sockets/DurableClientBug39997DUnitTest.java | 6 +- .../sockets/DurableClientQueueSizeDUnitTest.java | 7 +- .../sockets/DurableClientReconnectDUnitTest.java | 28 +- .../tier/sockets/DurableRegistrationDUnitTest.java | 3 +- .../sockets/DurableResponseMatrixDUnitTest.java | 7 +- .../sockets/ForceInvalidateEvictionDUnitTest.java | 12 +- .../GetConnectedServerCountRegressionTest.java | 5 +- .../cache/tier/sockets/HABug36738DUnitTest.java | 5 +- .../tier/sockets/HAInterestPart2DUnitTest.java | 79 +- .../cache/tier/sockets/HAInterestTestCase.java | 102 +- .../HARegionQueueStatsCloseRegressionTest.java | 5 +- .../sockets/HAStartupAndFailoverDUnitTest.java | 20 +- .../sockets/InstantiatorPropagationDUnitTest.java | 11 +- .../cache/tier/sockets/InterestListDUnitTest.java | 10 +- .../sockets/InterestListEndpointDUnitTest.java | 17 +- .../InterestListEndpointSelectorDUnitTest.java | 2 +- .../sockets/InterestListFailoverDUnitTest.java | 7 +- .../sockets/InterestListRecoveryDUnitTest.java | 17 +- .../sockets/InterestRegrListenerDUnitTest.java | 52 +- .../sockets/RedundancyLevelPart1DUnitTest.java | 494 +- .../sockets/RedundancyLevelPart2DUnitTest.java | 598 +- .../sockets/RedundancyLevelPart3DUnitTest.java | 328 +- .../tier/sockets/RedundancyLevelTestBase.java | 554 +- .../cache/tier/sockets/RegionCloseDUnitTest.java | 15 +- ...isterInterestBeforeRegionCreationDUnitTest.java | 7 +- .../sockets/RegisterInterestDistributedTest.java | 21 +- ...nterestOnServerWithoutRegionRegressionTest.java | 5 +- ...isterInterestServerMetaDataDistributedTest.java | 7 +- .../tier/sockets/ReliableMessagingDUnitTest.java | 14 +- .../tier/sockets/UnregisterInterestDUnitTest.java | 8 +- .../tier/sockets/UpdatePropagationDUnitTest.java | 9 +- ...ifyUpdatesFromNonInterestEndPointDUnitTest.java | 4 +- .../cache/versions/TombstoneDUnitTest.java | 26 +- .../AsyncEventListenerDistributedTest.java | 17 +- ...ventListenerWithCacheLoaderDistributedTest.java | 5 +- ...syncEventListenerWithFilterDistributedTest.java | 5 +- ...oncurrentAsyncEventListenerDistributedTest.java | 9 +- .../ParallelAsyncEventListenerDistributedTest.java | 39 +- .../SerialEventListenerDistributedTest.java | 7 +- .../CompressionRegionConfigDUnitTest.java | 6 +- .../internal/jta/ClientServerJTADUnitTest.java | 6 +- .../ClientServerJTAFailoverDistributedTest.java | 5 +- .../internal/jta/dunit/IdleTimeOutDUnitTest.java | 1 + .../internal/jta/dunit/LoginTimeOutDUnitTest.java | 6 +- .../offheap/OutOfOffHeapMemoryDUnitTest.java | 11 +- .../statistics/StatisticsDistributedTest.java | 19 +- .../geode/internal/tcp/TCPConduitDUnitTest.java | 6 +- .../geode/management/CacheManagementDUnitTest.java | 23 +- .../management/ClientHealthStatsDUnitTest.java | 4 +- .../management/CompositeTypeTestDUnitTest.java | 10 +- .../geode/management/DLockManagementDUnitTest.java | 22 +- .../geode/management/DiskManagementDUnitTest.java | 11 +- .../management/DistributedSystemDUnitTest.java | 185 +- .../management/JMXMBeanReconnectDUnitTest.java | 12 +- .../management/LocatorManagementDUnitTest.java | 7 +- .../management/MemberMBeanAttributesDUnitTest.java | 5 +- .../management/OffHeapManagementDUnitTest.java | 5 +- .../geode/management/QueryDataDUnitTest.java | 30 +- .../management/RegionManagementDUnitTest.java | 12 +- ...niversalMembershipListenerAdapterDUnitTest.java | 25 +- .../stats/DistributedSystemStatsDUnitTest.java | 12 +- .../MBeanFederationErrorPathDUnitTest.java | 5 +- .../commands/ChangeLogLevelCommandDUnitTest.java | 18 - .../ChangeLogLevelCommandDistributedTest.java | 24 + .../CreateAsyncEventQueueCommandDUnitTest.java | 8 +- .../commands/CreateDataSourceCommandDUnitTest.java | 117 + .../CreateJndiBindingCommandDUnitTest.java | 31 +- .../cli/commands/CreateRegionCommandDUnitTest.java | 48 + .../commands/DeployCommandRedeployDUnitTest.java | 5 +- .../cli/commands/DeployWithGroupsDUnitTest.java | 9 +- .../DescribeJndiBindingCommandDUnitTest.java | 6 +- .../commands/DestroyRegionCommandDUnitTest.java | 11 +- .../DestroySecondJndiBindingCommandDUnitTest.java | 125 + .../ExecuteFunctionCommandSecurityTest.java | 5 +- .../internal/cli/commands/ExportLogsDUnitTest.java | 20 - .../cli/commands/ExportLogsDistributedTest.java | 25 + .../commands/ExportLogsOnServerManagerDUnit.java | 85 - .../ExportLogsOnServerManagerDistributedTest.java | 87 + .../cli/commands/ExportLogsStatsDUnitTest.java | 19 - .../commands/ExportLogsStatsDistributedTest.java | 24 + .../ExportLogsWithMemberGroupDUnitTest.java | 135 - .../ExportLogsWithMemberGroupDistributedTest.java | 139 + .../cli/commands/RebalanceCommandDUnitTest.java | 5 +- .../cli/commands/RemoveCommandJsonDUnitTest.java | 5 +- .../cli/commands/ShowDeadlockDUnitTest.java | 4 +- .../cli/commands/ShowLogCommandDUnitTest.java | 2 +- .../cli/commands/ShowMetricsDUnitTest.java | 11 +- .../commands/ShowMissingDiskStoresDUnitTest.java | 6 +- .../internal/cli/util/MergeLogsDUnitTest.java | 118 - .../cli/util/MergeLogsDistributedTest.java | 126 + .../ClusterConfigLocatorRestartDUnitTest.java | 13 +- ...urationPersistenceServiceUsingDirDUnitTest.java | 8 +- .../internal/pulse/TestClientIdsDUnitTest.java | 8 +- .../internal/pulse/TestFunctionsDUnitTest.java | 20 +- .../internal/pulse/TestHeapDUnitTest.java | 4 +- .../internal/pulse/TestLocatorsDUnitTest.java | 4 +- .../internal/pulse/TestSubscriptionsDUnitTest.java | 14 +- .../internal/security/MultiGfshDUnitTest.java | 5 +- .../geode/pdx/JSONPdxClientServerDUnitTest.java | 2 +- .../geode/pdx/PdxDeserializationDUnitTest.java | 9 +- ...onUsingLegacySecurityWithFailoverDUnitTest.java | 2 +- .../ClusterConfigWithoutSecurityDUnitTest.java | 10 +- .../PDXGfshPostProcessorOnRemoteServerTest.java | 5 +- .../geode/security/PDXPostProcessorDUnitTest.java | 5 +- .../security/SecurityClusterConfigDUnitTest.java | 14 +- .../SecurityWithoutClusterConfigDUnitTest.java | 8 +- .../geode/cache/client/internal/default.keystore | Bin 1115 -> 534 bytes .../org/apache/geode/internal/jta/cachejta.xml | 6 +- .../apache/geode/TXExpirationIntegrationTest.java | 13 +- .../java/org/apache/geode/TXJUnitTest.java | 21 +- .../DeprecatedAgentLauncherIntegrationTest.java | 6 +- .../ConcurrentRegionOperationIntegrationTest.java | 11 +- .../org/apache/geode/cache/ProxyJUnitTest.java | 107 - .../cache/RegionExpirationIntegrationTest.java | 26 +- ...ncEventQueueEvictionAndExpirationJUnitTest.java | 77 +- .../cache/client/ClientCacheFactoryJUnitTest.java | 430 +- .../AutoConnectionSourceImplJUnitTest.java | 21 +- .../internal/ConnectionPoolImplJUnitTest.java | 4 +- .../cache/client/internal/LocatorSSLJUnitTest.java | 10 +- .../client/internal/QueueManagerJUnitTest.java | 8 +- ...opClientExecutorWithLoggingIntegrationTest.java | 9 +- .../pooling/ConnectionManagerJUnitTest.java | 17 +- .../execute/FunctionDynamicByArgsSecurityTest.java | 88 + .../apache/geode/cache/query/QueryJUnitTest.java | 21 +- .../IndexMaintenanceAsynchJUnitTest.java | 11 +- ...IndexUsageInNestedQueryWithParamsJUnitTest.java | 285 + .../query/functional/LimitClauseJUnitTest.java | 33 - .../internal/CompiledGroupBySelectJUnitTest.java | 7 +- .../internal/QueryMonitorIntegrationTest.java | 154 + .../AsyncIndexUpdaterThreadShutdownJUnitTest.java | 46 +- .../index/AsynchIndexMaintenanceJUnitTest.java | 39 +- .../internal/index/CompactRangeIndexJUnitTest.java | 91 +- .../geode/cache/snapshot/WanSnapshotJUnitTest.java | 5 +- .../ShorteningExpirationTimeRegressionTest.java | 7 +- .../distributed/LauncherIntegrationTestCase.java | 10 +- .../LauncherMemberMXBeanIntegrationTest.java | 4 +- .../LocatorLauncherIntegrationTest.java | 15 +- .../LocatorLauncherIntegrationTestCase.java | 4 +- ...catorLauncherJmxManagerLocalRegressionTest.java | 13 +- .../LocatorLauncherRemoteIntegrationTestCase.java | 6 +- ...cherRemoteWithCustomLoggingIntegrationTest.java | 18 +- .../ServerLauncherBuilderIntegrationTest.java | 15 +- .../distributed/ServerLauncherIntegrationTest.java | 15 +- .../ServerLauncherIntegrationTestCase.java | 4 +- .../ServerLauncherRemoteIntegrationTestCase.java | 6 +- ...cherRemoteWithCustomLoggingIntegrationTest.java | 16 +- .../DefaultPropertiesGeneratorIntegrationTest.java | 11 +- .../InternalDistributedSystemJUnitTest.java | 13 +- .../gms/fd/GMSHealthMonitorJUnitTest.java | 112 +- .../gms/locator/GMSLocatorRecoveryJUnitTest.java | 30 +- .../gms/membership/GMSJoinLeaveJUnitTest.java | 27 +- .../gms/membership/GMSJoinLeaveTestHelper.java | 93 - .../tcpserver/TCPClientSSLIntegrationTest.java | 58 +- .../internal/tcpserver/TCPServerSSLJUnitTest.java | 7 +- .../internal/tcpserver/TcpServerJUnitTest.java | 75 +- .../geode/internal/ClassPathLoaderDeployTest.java | 161 + .../internal/ClassPathLoaderIntegrationTest.java | 127 - .../geode/internal/JarDeployerDeadlockTest.java | 5 +- ...edThreadPoolExecutorWithKeepAliveJUnitTest.java | 8 +- ...ionCreateNotBeforeRegionInitRegressionTest.java | 5 +- ...tMessagesRegionCreationAndDestroyJUnitTest.java | 12 +- .../internal/cache/ComplexDiskRegionJUnitTest.java | 4 +- ...precatedCacheServerLauncherIntegrationTest.java | 19 +- .../internal/cache/DiskInitFileJUnitTest.java | 177 +- .../geode/internal/cache/DiskOldAPIsJUnitTest.java | 4 +- .../DiskRandomOperationsAndRecoveryJUnitTest.java | 2 +- .../internal/cache/DiskRegRecoveryJUnitTest.java | 6 +- .../cache/DiskRegionAsyncRecoveryJUnitTest.java | 3 +- .../cache/DiskRegionAttributesIntegrationTest.java | 413 ++ .../DiskRegionCompactorCloseIntegrationTest.java | 189 + .../geode/internal/cache/DiskRegionJUnitTest.java | 4042 +++++----- .../cache/DiskStoreImplIntegrationTest.java | 9 +- .../internal/cache/InterruptDiskJUnitTest.java | 4 +- .../MultipleOplogsRollingFeatureJUnitTest.java | 8 +- .../geode/internal/cache/OplogJUnitTest.java | 18 +- .../geode/internal/cache/OplogRVVJUnitTest.java | 153 +- .../cache/PartitionedRegionCreationJUnitTest.java | 5 +- .../cache/control/MemoryMonitorJUnitTest.java | 7 +- .../control/MemoryMonitorOffHeapJUnitTest.java | 8 +- ...skRegionOverflowAsyncRollingOpLogJUnitTest.java | 4 +- ...iskRegionOverflowSyncRollingOpLogJUnitTest.java | 4 +- .../cache/eviction/EvictionIntegrationTest.java | 204 + .../cache/ha/BlockingHARegionJUnitTest.java | 70 +- .../cache/ha/BlockingHARegionQueueJUnitTest.java | 15 +- .../cache/ha/HARQAddOperationJUnitTest.java | 5 +- .../cache/ha/HARegionQueueIntegrationTest.java | 6 +- .../internal/cache/ha/HARegionQueueJUnitTest.java | 7 +- .../cache/tier/sockets/AcceptorImplJUnitTest.java | 151 +- .../CacheClientNotifierIntegrationTest.java | 5 +- .../CacheServerMaxConnectionsJUnitTest.java | 6 +- .../ClientHealthMonitorIntegrationTest.java | 10 +- .../tier/sockets/ConnectionProxyJUnitTest.java | 19 +- .../tier/sockets/RedundancyLevelJUnitTest.java | 4 +- .../sockets/ServerConnectionIntegrationTest.java | 12 - .../AsyncEventQueueValidationsJUnitTest.java | 9 +- .../datasource/AbstractPoolCacheJUnitTest.java | 67 +- .../internal/datasource/CleanUpJUnitTest.java | 31 - .../ConnectionPoolCacheImplJUnitTest.java | 118 - .../datasource/ConnectionPoolingJUnitTest.java | 2 +- .../datasource/DataSourceFactoryJUnitTest.java | 7 +- .../geode/internal/i18n/BasicI18nJUnitTest.java | 379 - .../logging/CacheLogRollingIntegrationTest.java | 125 +- .../DistributedSystemLogFileIntegrationTest.java | 1152 +++ .../logging/DistributedSystemLogFileJUnitTest.java | 1643 ----- .../logging/LocatorLogFileIntegrationTest.java | 123 + .../internal/logging/LocatorLogFileJUnitTest.java | 135 - .../logging/LogServiceIntegrationJUnitTest.java | 237 - .../logging/LogServiceIntegrationTest.java | 236 + .../logging/MergeLogFilesIntegrationTest.java | 232 + .../internal/logging/MergeLogFilesJUnitTest.java | 238 - .../logging/log4j/ConfigLocatorJUnitTest.java | 220 - ...penderWithLoggerContextRuleIntegrationTest.java | 142 + ...leAppenderWithSystemOutRuleIntegrationTest.java | 182 + .../CustomConfigWithCacheIntegrationTest.java | 143 + .../CustomConfigWithLogServiceIntegrationTest.java | 108 + .../log4j/FastLoggerIntegrationJUnitTest.java | 602 -- .../logging/log4j/FastLoggerIntegrationTest.java | 600 ++ ...FastLoggerWithDefaultConfigIntegrationTest.java | 89 + .../FastLoggerWithDefaultConfigJUnitTest.java | 87 - ...reVerboseMarkerFilterAcceptIntegrationTest.java | 95 + ...fireVerboseMarkerFilterDenyIntegrationTest.java | 87 + .../GeodeVerboseLogMarkerIntegrationTest.java | 221 - ...deVerboseMarkerFilterAcceptIntegrationTest.java | 96 + ...eodeVerboseMarkerFilterDenyIntegrationTest.java | 96 + .../log4j/LogWriterAppenderIntegrationTest.java | 251 + .../CustomConfigWithCacheIntegrationTest.java | 153 - .../CustomConfigWithLogServiceIntegrationTest.java | 121 - .../internal/net/SSLSocketIntegrationTest.java | 10 +- .../internal/net/SocketCloserIntegrationTest.java | 138 + .../net/SocketCloserWithWaitIntegrationTest.java | 35 + .../offheap/OffHeapLRURecoveryRegressionTest.java | 5 +- .../geode/internal/offheap/OffHeapRegionBase.java | 14 +- .../ControlFileWatchdogIntegrationTest.java | 21 +- .../ControllableProcessIntegrationTest.java | 5 +- .../FileProcessControllerIntegrationTest.java | 21 +- .../LocalProcessLauncherIntegrationTest.java | 9 +- .../process/NativeProcessUtilsIntegrationTest.java | 9 +- .../internal/process/PidFileIntegrationTest.java | 21 +- .../ProcessControllerFactoryIntegrationTest.java | 8 +- .../GemFireStatSamplerIntegrationTest.java | 23 +- .../internal/statistics/LinuxSystemStatsTest.java | 23 +- .../statistics/StatSamplerIntegrationTest.java | 63 +- .../statistics/ValueMonitorIntegrationTest.java | 364 +- .../DistributedSystemMXBeanIntegrationTest.java | 134 + .../FederatingManagerIntegrationTest.java | 5 +- .../internal/beans/ManagementAdapterTest.java | 2 +- .../internal/cli/GfshParserAutoCompletionTest.java | 160 +- .../ConfigurePDXCommandIntegrationTest.java | 2 +- .../CreateRegionCommandIntegrationTest.java | 4 +- .../cli/commands/HintCommandIntegrationTest.java | 69 + .../cli/commands/StartMemberUtilsTest.java | 55 +- .../functions/CreateJndiBindingFunctionTest.java | 35 +- .../functions/DestroyJndiBindingFunctionTest.java | 2 +- .../ExportLogsFunctionIntegrationTest.java | 51 +- .../cli/functions/ListJndiBindingFunctionTest.java | 2 +- .../SizeExportLogsFunctionFileIntegrationTest.java | 179 + .../functions/SizeExportLogsFunctionFileTest.java | 182 - .../SizeExportLogsFunctionIntegrationTest.java | 188 + .../cli/functions/SizeExportLogsFunctionTest.java | 189 - .../cli/util/LogExporterFileIntegrationTest.java | 137 + .../cli/util/LogExporterIntegrationTest.java | 76 +- .../internal/cli/util/LogExporterTest.java | 143 - .../apache/geode/pdx/JSONFormatterJUnitTest.java | 53 +- .../apache/geode/codeAnalysis/excludedClasses.txt | 10 +- .../codeAnalysis/sanctionedDataSerializables.txt | 10 +- ...moteWithCustomLoggingIntegrationTest_log4j2.xml | 45 + ...moteWithCustomLoggingIntegrationTest_log4j2.xml | 45 + .../internal/cache/DiskRegCacheXmlJUnitTest.xml | 0 .../cache/backup/BackupIntegrationTest.cache.xml | 0 .../incorrect_bytes_threshold.xml | 0 .../faultyDiskXMLsForTesting/incorrect_dir.xml | 0 .../incorrect_dir_size.xml | 0 .../incorrect_max_oplog_size.xml | 0 .../incorrect_roll_oplogs_value.xml | 0 .../incorrect_sync_value.xml | 0 .../incorrect_time_interval.xml | 0 .../mixed_diskstore_diskdir.xml | 0 .../mixed_diskstore_diskwriteattrs.xml | 0 .../tier/sockets/RedundancyLevelJUnitTest.xml | 0 ...nsJUnitTest.correctConfiguration[DTD].cache.xml | 0 ...nsJUnitTest.correctConfiguration[XSD].cache.xml | 0 ...pleReceiversShouldThrowException[DTD].cache.xml | 0 ...pleReceiversShouldThrowException[XSD].cache.xml | 0 ...EventQueueConfiguredFromXmlUsesFilter.cache.xml | 0 ...EventQueueConfiguredFromXmlUsesFilter.cache.xml | 0 ...st.testDTDFallbackWithNonEnglishLocal.cache.xml | 0 ...serJUnitTest.testSimpleClientCacheXml.cache.xml | 0 .../org/apache/geode/internal/jta/cachejta.xml | 6 +- ...WithLoggerContextRuleIntegrationTest_log4j2.xml | 42 + ...nderWithSystemOutRuleIntegrationTest_log4j2.xml | 40 + ...CustomConfigWithCacheIntegrationTest_log4j2.xml | 41 + ...mConfigWithLogServiceIntegrationTest_log4j2.xml | 41 + ...oseMarkerFilterAcceptIntegrationTest_log4j2.xml | 35 + ...rboseMarkerFilterDenyIntegrationTest_log4j2.xml | 35 + ...oseMarkerFilterAcceptIntegrationTest_log4j2.xml | 35 + ...rboseMarkerFilterDenyIntegrationTest_log4j2.xml | 35 + .../geode/internal/ra/spi/JCALocalTransaction.java | 4 +- .../MonitorQueryUnderContentionBenchmark.java | 189 + .../src/main/java/org/apache/geode/CopyHelper.java | 43 +- .../main/java/org/apache/geode/DataSerializer.java | 19 +- .../main/java/org/apache/geode/Instantiator.java | 9 +- .../src/main/java/org/apache/geode/LogWriter.java | 51 +- .../main/java/org/apache/geode/SystemFailure.java | 67 +- .../java/org/apache/geode/admin/AdminConfig.java | 6 +- .../geode/admin/AdminDistributedSystemFactory.java | 8 +- .../main/java/org/apache/geode/admin/Alert.java | 2 +- .../java/org/apache/geode/admin/AlertLevel.java | 7 +- .../geode/admin/DistributedSystemConfig.java | 6 +- .../java/org/apache/geode/admin/GemFireHealth.java | 7 +- .../geode/admin/RegionSubRegionSnapshot.java | 4 +- .../geode/admin/SystemMemberBridgeServer.java | 72 +- .../admin/internal/AbstractHealthEvaluator.java | 10 +- .../admin/internal/AdminDistributedSystemImpl.java | 98 +- .../geode/admin/internal/CacheHealthEvaluator.java | 15 +- .../admin/internal/ConfigurationParameterImpl.java | 28 +- .../internal/DistributedSystemConfigImpl.java | 46 +- .../internal/DistributedSystemHealthEvaluator.java | 8 +- .../internal/DistributedSystemHealthMonitor.java | 97 +- .../internal/DistributionLocatorConfigImpl.java | 9 +- .../admin/internal/DistributionLocatorImpl.java | 8 +- .../internal/EnabledManagedEntityController.java | 54 +- .../admin/internal/GemFireHealthConfigImpl.java | 8 +- .../admin/internal/GemFireHealthEvaluator.java | 3 +- .../geode/admin/internal/GemFireHealthImpl.java | 20 +- .../geode/admin/internal/InetAddressUtil.java | 4 +- .../apache/geode/admin/internal/LogCollator.java | 10 +- .../admin/internal/ManagedEntityConfigImpl.java | 11 +- .../admin/internal/ManagedEntityConfigXml.java | 11 +- .../internal/ManagedEntityConfigXmlGenerator.java | 7 +- .../internal/ManagedEntityConfigXmlParser.java | 13 +- .../admin/internal/MemberHealthEvaluator.java | 28 +- .../admin/internal/StatisticResourceImpl.java | 5 +- .../internal/SystemMemberBridgeServerImpl.java | 17 +- .../internal/SystemMemberCacheEventProcessor.java | 2 +- .../admin/internal/SystemMemberCacheImpl.java | 7 +- .../geode/admin/internal/SystemMemberImpl.java | 14 +- .../internal/AdminDistributedSystemJmxImpl.java | 115 +- .../geode/admin/jmx/internal/AgentConfigImpl.java | 202 +- .../apache/geode/admin/jmx/internal/AgentImpl.java | 122 +- .../geode/admin/jmx/internal/AgentLauncher.java | 117 +- .../admin/jmx/internal/CacheServerJmxImpl.java | 8 +- .../internal/ConfigurationParameterJmxImpl.java | 4 +- .../jmx/internal/DistributionLocatorJmxImpl.java | 5 +- .../admin/jmx/internal/GemFireHealthJmxImpl.java | 7 +- .../admin/jmx/internal/GenerateMBeanHTML.java | 7 +- .../apache/geode/admin/jmx/internal/MBeanUtil.java | 80 +- .../geode/admin/jmx/internal/MX4JModelMBean.java | 99 +- .../geode/admin/jmx/internal/MailManager.java | 32 +- .../jmx/internal/MemberInfoWithStatsMBean.java | 116 +- .../jmx/internal/StatisticResourceJmxImpl.java | 6 +- .../jmx/internal/SystemMemberCacheJmxImpl.java | 9 +- .../geode/admin/jmx/internal/SystemMemberJmx.java | 19 +- .../admin/jmx/internal/SystemMemberJmxImpl.java | 4 +- .../org/apache/geode/cache/AttributesFactory.java | 143 +- .../java/org/apache/geode/cache/CacheFactory.java | 10 +- .../java/org/apache/geode/cache/DataPolicy.java | 9 +- .../geode/cache/DiskWriteAttributesFactory.java | 30 +- .../apache/geode/cache/DynamicRegionFactory.java | 105 +- .../org/apache/geode/cache/EvictionAttributes.java | 2 +- .../java/org/apache/geode/cache/LossAction.java | 5 +- .../apache/geode/cache/MembershipAttributes.java | 4 +- .../java/org/apache/geode/cache/Operation.java | 2 +- .../geode/cache/PartitionAttributesFactory.java | 13 +- .../main/java/org/apache/geode/cache/Region.java | 4 +- .../java/org/apache/geode/cache/RegionFactory.java | 5 +- .../java/org/apache/geode/cache/RequiredRoles.java | 6 +- .../org/apache/geode/cache/ResumptionAction.java | 7 +- .../main/java/org/apache/geode/cache/Scope.java | 5 +- .../internal/AsyncEventQueueFactoryImpl.java | 12 +- .../internal/ParallelAsyncEventQueueImpl.java | 13 +- .../internal/SerialAsyncEventQueueImpl.java | 15 +- .../geode/cache/client/ClientCacheFactory.java | 10 +- .../client/internal/AutoConnectionSourceImpl.java | 37 +- .../client/internal/ClientMetadataService.java | 54 +- .../client/internal/ClientPartitionAdvisor.java | 5 +- .../client/internal/ClientSideHandshakeImpl.java | 7 +- .../cache/client/internal/ConnectionConnector.java | 2 +- .../cache/client/internal/ConnectionFactory.java | 2 +- .../client/internal/ConnectionFactoryImpl.java | 49 +- .../cache/client/internal/ConnectionImpl.java | 10 +- .../internal/DataSerializerRecoveryListener.java | 11 +- .../geode/cache/client/internal/DestroyOp.java | 4 +- .../client/internal/ExecuteFunctionNoAckOp.java | 8 +- .../cache/client/internal/ExecuteFunctionOp.java | 5 +- .../internal/ExecuteRegionFunctionNoAckOp.java | 8 +- .../client/internal/ExecuteRegionFunctionOp.java | 41 +- .../client/internal/GetClientPRMetaDataOp.java | 5 +- .../internal/GetClientPartitionAttributesOp.java | 5 +- .../internal/InstantiatorRecoveryListener.java | 11 +- .../cache/client/internal/OpExecutorImpl.java | 6 +- .../geode/cache/client/internal/PoolImpl.java | 145 +- .../cache/client/internal/QueueConnectionImpl.java | 2 +- .../cache/client/internal/QueueManagerImpl.java | 139 +- .../client/internal/RegisterInterestTracker.java | 17 +- .../cache/client/internal/ServerBlackList.java | 186 - .../cache/client/internal/ServerDenyList.java | 186 + .../cache/client/internal/ServerRegionProxy.java | 9 +- .../client/internal/SingleHopClientExecutor.java | 31 +- .../internal/pooling/ConnectionManagerImpl.java | 89 +- .../client/internal/pooling/PooledConnection.java | 12 +- .../geode/cache/configuration/CacheConfig.java | 6 +- .../cache/configuration/JndiBindingsType.java | 6 +- .../org/apache/geode/cache/execute/Function.java | 58 +- .../geode/cache/execute/FunctionService.java | 4 +- .../execute/internal/FunctionServiceManager.java | 67 +- .../cache/partition/PartitionRegionHelper.java | 19 +- .../geode/cache/query/CqAttributesFactory.java | 7 +- .../query/internal/AbstractCompiledValue.java | 13 +- .../internal/AbstractGroupOrRangeJunction.java | 4 +- .../cache/query/internal/AttributeDescriptor.java | 23 +- .../org/apache/geode/cache/query/internal/Bag.java | 6 +- .../cache/query/internal/CompiledBindArgument.java | 3 +- .../cache/query/internal/CompiledFunction.java | 4 +- .../query/internal/CompiledGroupBySelect.java | 7 +- .../geode/cache/query/internal/CompiledID.java | 5 +- .../geode/cache/query/internal/CompiledIn.java | 8 +- .../query/internal/CompiledIndexOperation.java | 17 +- .../cache/query/internal/CompiledIteratorDef.java | 13 +- .../cache/query/internal/CompiledJunction.java | 18 +- .../geode/cache/query/internal/CompiledLike.java | 4 +- .../cache/query/internal/CompiledNegation.java | 3 +- .../cache/query/internal/CompiledOperation.java | 17 +- .../geode/cache/query/internal/CompiledPath.java | 9 + .../geode/cache/query/internal/CompiledRegion.java | 3 +- .../geode/cache/query/internal/CompiledSelect.java | 28 +- .../cache/query/internal/CompiledUnaryMinus.java | 5 +- .../geode/cache/query/internal/CompiledValue.java | 4 + .../internal/CumulativeNonDistinctResults.java | 6 - .../geode/cache/query/internal/DefaultQuery.java | 194 +- .../cache/query/internal/DefaultQueryService.java | 61 +- .../cache/query/internal/ExecutionContext.java | 17 +- .../geode/cache/query/internal/Functions.java | 20 +- .../cache/query/internal/LinkedResultSet.java | 4 +- .../cache/query/internal/LinkedStructSet.java | 10 +- .../geode/cache/query/internal/MethodDispatch.java | 18 +- .../cache/query/internal/PRQueryTraceInfo.java | 7 +- .../cache/query/internal/ProxyQueryService.java | 5 +- .../geode/cache/query/internal/QCompiler.java | 20 +- .../apache/geode/cache/query/internal/QRegion.java | 35 +- .../internal/QueryExecutionCanceledException.java | 3 +- .../geode/cache/query/internal/QueryMonitor.java | 501 +- .../geode/cache/query/internal/QueryUtils.java | 27 +- .../geode/cache/query/internal/RangeJunction.java | 28 +- .../RestrictedMethodInvocationAuthorizer.java | 130 +- .../query/internal/ResultsCollectionWrapper.java | 10 +- .../geode/cache/query/internal/ResultsSet.java | 4 +- .../cache/query/internal/RuntimeIterator.java | 4 +- .../cache/query/internal/SortedResultSet.java | 4 +- .../cache/query/internal/SortedStructBag.java | 14 +- .../cache/query/internal/SortedStructSet.java | 14 +- .../geode/cache/query/internal/StructBag.java | 26 +- .../geode/cache/query/internal/StructImpl.java | 3 +- .../geode/cache/query/internal/StructSet.java | 19 +- .../apache/geode/cache/query/internal/Support.java | 3 +- .../cache/query/internal/cq/CqAttributesImpl.java | 36 +- .../cache/query/internal/index/AbstractIndex.java | 21 +- .../query/internal/index/CompactRangeIndex.java | 13 +- .../cache/query/internal/index/DummyQRegion.java | 3 +- .../index/FunctionalIndexCreationHelper.java | 61 +- .../cache/query/internal/index/HashIndex.java | 17 +- .../cache/query/internal/index/IndexElemArray.java | 60 +- .../cache/query/internal/index/IndexManager.java | 52 +- .../query/internal/index/MemoryIndexStore.java | 44 +- .../query/internal/index/PartitionedIndex.java | 22 +- .../query/internal/index/PrimaryKeyIndex.java | 30 +- .../index/PrimaryKeyIndexCreationHelper.java | 23 +- .../cache/query/internal/index/RangeIndex.java | 45 +- .../cache/query/internal/parse/ASTLiteral.java | 48 +- .../cache/query/internal/parse/ASTUnsupported.java | 3 +- .../cache/query/internal/types/StructTypeImpl.java | 5 +- .../cache/query/internal/types/TypeUtils.java | 37 +- .../geode/cache/query/internal/utils/PDXUtils.java | 5 +- .../server/internal/ConnectionCountProbe.java | 6 +- .../geode/cache/server/internal/LoadMonitor.java | 15 +- .../cache/server/internal/ServerMetricsImpl.java | 2 +- .../geode/datasource/PooledDataSourceFactory.java | 51 + .../apache/geode/distributed/AbstractLauncher.java | 28 +- .../geode/distributed/ConfigurationProperties.java | 32 +- .../geode/distributed/DistributedSystem.java | 10 +- .../java/org/apache/geode/distributed/Locator.java | 5 +- .../apache/geode/distributed/LocatorLauncher.java | 95 +- .../apache/geode/distributed/ServerLauncher.java | 120 +- .../internal/AbstractDistributionConfig.java | 682 +- .../internal/ClusterDistributionManager.java | 1158 +-- .../distributed/internal/ClusterElderManager.java | 215 + .../internal/CollectingReplyProcessor.java | 5 +- .../apache/geode/distributed/internal/DSClock.java | 24 +- .../internal/DistributedSystemService.java | 2 +- .../distributed/internal/DistributionAdvisor.java | 3 +- .../distributed/internal/DistributionConfig.java | 258 +- .../internal/DistributionConfigImpl.java | 2090 +++--- .../internal/DistributionConfigSnapshot.java | 27 +- .../distributed/internal/DistributionManager.java | 10 +- .../distributed/internal/DistributionMessage.java | 18 +- .../internal/FunctionExecutionPooledExecutor.java | 19 +- .../distributed/internal/HealthMonitorImpl.java | 16 +- .../internal/HighPriorityAckedMessage.java | 8 +- .../internal/InternalDistributedSystem.java | 274 +- .../distributed/internal/InternalLocator.java | 95 +- .../distributed/internal/LocatorLoadSnapshot.java | 18 +- .../internal/LonerDistributionManager.java | 24 +- .../internal/PooledExecutorWithDMStats.java | 16 +- .../geode/distributed/internal/ProductUseLog.java | 7 +- .../internal/ReliableReplyProcessor21.java | 5 +- .../geode/distributed/internal/ReplyException.java | 9 +- .../geode/distributed/internal/ReplyMessage.java | 10 +- .../distributed/internal/ReplyProcessor21.java | 58 +- .../internal/RuntimeDistributionConfigImpl.java | 70 +- .../geode/distributed/internal/ServerLocation.java | 2 +- .../geode/distributed/internal/ServerLocator.java | 15 +- .../distributed/internal/ShutdownMessage.java | 7 +- .../geode/distributed/internal/StartupMessage.java | 51 +- .../internal/StartupMessageReplyProcessor.java | 4 +- .../distributed/internal/StartupOperation.java | 23 +- .../distributed/internal/direct/DirectChannel.java | 57 +- .../distributed/internal/locks/DLockGrantor.java | 68 +- .../locks/DLockRecoverGrantorProcessor.java | 6 +- .../internal/locks/DLockRequestProcessor.java | 54 +- .../distributed/internal/locks/DLockService.java | 131 +- .../distributed/internal/locks/DLockToken.java | 5 +- .../internal/locks/DeposeGrantorProcessor.java | 6 +- .../internal/locks/DistributedMemberLock.java | 3 +- .../internal/locks/ElderInitProcessor.java | 40 +- .../distributed/internal/locks/ElderState.java | 39 +- .../internal/locks/GrantorRequestProcessor.java | 34 +- .../distributed/internal/locks/LockGrantorId.java | 5 +- .../locks/NonGrantorDestroyedProcessor.java | 2 +- .../membership/DistributedMembershipListener.java | 2 - .../membership/InternalDistributedMember.java | 30 +- .../internal/membership/InternalRole.java | 10 +- .../internal/membership/gms/GMSMember.java | 4 +- .../internal/membership/gms/GMSMemberFactory.java | 3 +- .../internal/membership/gms/ServiceConfig.java | 2 +- .../internal/membership/gms/Services.java | 11 - .../membership/gms/auth/GMSAuthenticator.java | 21 +- .../membership/gms/fd/GMSHealthMonitor.java | 41 +- .../membership/gms/locator/GMSLocator.java | 217 +- .../membership/gms/membership/GMSJoinLeave.java | 63 +- .../membership/gms/messenger/GMSQuorumChecker.java | 2 +- .../membership/gms/messenger/JGroupsMessenger.java | 14 +- .../membership/gms/mgr/GMSMembershipManager.java | 180 +- .../internal/streaming/StreamingOperation.java | 13 +- .../distributed/internal/tcpserver/TcpServer.java | 49 +- .../java/org/apache/geode/i18n/LogWriterI18n.java | 86 +- .../main/java/org/apache/geode/i18n/StringId.java | 6 +- .../org/apache/geode/internal/AbstractConfig.java | 181 +- .../java/org/apache/geode/internal/Assert.java | 9 +- .../org/apache/geode/internal/AvailablePort.java | 14 +- .../java/org/apache/geode/internal/Banner.java | 2 +- .../java/org/apache/geode/internal/Config.java | 34 +- .../org/apache/geode/internal/DSFIDFactory.java | 8 +- .../geode/internal/DataSerializableFixedID.java | 4 +- .../org/apache/geode/internal/DeployedJar.java | 13 +- .../apache/geode/internal/DistributionLocator.java | 53 +- .../geode/internal/HeapDataOutputStream.java | 9 +- .../geode/internal/InternalDataSerializer.java | 1838 +++-- .../geode/internal/InternalInstantiator.java | 133 +- .../org/apache/geode/internal/ManagerInfo.java | 40 +- .../java/org/apache/geode/internal/OSProcess.java | 122 +- .../apache/geode/internal/ObjIdConcurrentMap.java | 278 - .../java/org/apache/geode/internal/ObjIdMap.java | 9 +- .../internal/ObjectInputStreamFilterWrapper.java | 10 +- .../apache/geode/internal/ProcessOutputReader.java | 4 +- .../org/apache/geode/internal/SharedLibrary.java | 2 +- .../java/org/apache/geode/internal/SmHelper.java | 9 +- .../org/apache/geode/internal/SystemAdmin.java | 424 +- .../org/apache/geode/internal/SystemTimer.java | 5 +- .../apache/geode/internal/UniqueIdGenerator.java | 9 +- .../java/org/apache/geode/internal/Version.java | 15 +- .../apache/geode/internal/VersionDescription.java | 48 +- .../geode/internal/admin/CacheCollector.java | 7 +- .../org/apache/geode/internal/admin/CacheInfo.java | 2 +- .../admin/ClientHealthMonitoringRegion.java | 5 +- .../geode/internal/admin/ClientStatsManager.java | 15 +- .../internal/admin/CompoundEntrySnapshot.java | 4 +- .../internal/admin/CompoundRegionSnapshot.java | 4 +- .../org/apache/geode/internal/admin/GemFireVM.java | 10 +- .../apache/geode/internal/admin/ListenerIdMap.java | 11 +- .../org/apache/geode/internal/admin/SSLConfig.java | 12 +- .../geode/internal/admin/StatAlertsManager.java | 15 +- .../admin/remote/AddHealthListenerRequest.java | 5 +- .../admin/remote/AddStatListenerRequest.java | 3 +- .../remote/AdminConsoleDisconnectMessage.java | 11 +- .../geode/internal/admin/remote/AdminRegion.java | 47 +- .../geode/internal/admin/remote/AdminRequest.java | 12 +- .../geode/internal/admin/remote/AdminResponse.java | 5 +- .../geode/internal/admin/remote/AdminWaiters.java | 19 +- .../admin/remote/AlertLevelChangeMessage.java | 31 +- .../admin/remote/AlertListenerMessage.java | 107 +- .../internal/admin/remote/BridgeServerRequest.java | 48 +- .../admin/remote/BridgeServerResponse.java | 6 +- .../internal/admin/remote/CacheConfigRequest.java | 4 +- .../geode/internal/admin/remote/CacheDisplay.java | 4 +- .../internal/admin/remote/CacheInfoRequest.java | 3 +- .../admin/remote/CancelStatListenerRequest.java | 8 +- .../admin/remote/CancelStatListenerResponse.java | 5 +- .../internal/admin/remote/CancellationMessage.java | 5 +- .../admin/remote/CancellationRegistry.java | 3 +- .../internal/admin/remote/CliLegacyMessage.java | 11 +- .../internal/admin/remote/DestroyEntryMessage.java | 11 +- .../admin/remote/DestroyRegionMessage.java | 11 +- .../admin/remote/DistributionLocatorId.java | 11 +- .../internal/admin/remote/EntryValueNodeImpl.java | 7 +- .../admin/remote/FetchDistLockInfoRequest.java | 7 +- .../admin/remote/FetchDistLockInfoResponse.java | 5 +- .../admin/remote/FetchHealthDiagnosisRequest.java | 10 +- .../internal/admin/remote/FetchHostRequest.java | 7 +- .../internal/admin/remote/FetchHostResponse.java | 7 +- .../remote/FetchResourceAttributesRequest.java | 8 +- .../internal/admin/remote/FetchSysCfgRequest.java | 3 +- .../admin/remote/HealthListenerMessage.java | 5 +- .../internal/admin/remote/LicenseInfoRequest.java | 3 +- .../admin/remote/ObjectDetailsRequest.java | 3 +- .../internal/admin/remote/ObjectNamesRequest.java | 3 +- .../remote/PrepareRevokePersistentIDRequest.java | 6 +- .../internal/admin/remote/RegionAdminRequest.java | 5 +- .../admin/remote/RegionAttributesRequest.java | 3 +- .../geode/internal/admin/remote/RegionRequest.java | 11 +- .../internal/admin/remote/RegionResponse.java | 5 +- .../internal/admin/remote/RegionSizeRequest.java | 3 +- .../admin/remote/RegionStatisticsRequest.java | 3 +- .../geode/internal/admin/remote/RemoteAlert.java | 3 +- .../internal/admin/remote/RemoteBridgeServer.java | 33 +- .../internal/admin/remote/RemoteCacheInfo.java | 7 +- .../internal/admin/remote/RemoteGemFireVM.java | 25 +- .../admin/remote/RemoteGfManagerAgent.java | 71 +- .../admin/remote/RemoteRegionAttributes.java | 8 +- .../admin/remote/RemoteTransportConfig.java | 4 +- .../admin/remote/RemoveHealthListenerRequest.java | 3 +- .../admin/remote/ResetHealthStatusRequest.java | 3 +- .../internal/admin/remote/RootRegionRequest.java | 3 +- .../internal/admin/remote/ShutdownAllRequest.java | 20 +- .../internal/admin/remote/StoreSysCfgRequest.java | 3 +- .../internal/admin/remote/SubRegionRequest.java | 3 +- .../internal/admin/remote/TailLogRequest.java | 3 +- .../internal/admin/remote/TailLogResponse.java | 11 +- .../internal/admin/remote/VersionInfoRequest.java | 3 +- .../internal/cache/AbstractBucketRegionQueue.java | 4 +- .../geode/internal/cache/AbstractCacheServer.java | 8 +- .../geode/internal/cache/AbstractDiskRegion.java | 19 +- .../geode/internal/cache/AbstractRegion.java | 91 +- .../geode/internal/cache/AbstractRegionMap.java | 41 +- .../internal/cache/AbstractUpdateOperation.java | 9 +- .../geode/internal/cache/AfterCompletion.java | 66 +- .../geode/internal/cache/BeforeCompletion.java | 9 +- .../apache/geode/internal/cache/BucketAdvisor.java | 122 +- .../internal/cache/BucketPersistenceAdvisor.java | 35 +- .../apache/geode/internal/cache/BucketRegion.java | 128 +- .../geode/internal/cache/BucketRegionQueue.java | 4 +- .../geode/internal/cache/BucketServerLocation.java | 6 - .../apache/geode/internal/cache/CacheConfig.java | 23 +- .../internal/cache/CacheDistributionAdvisor.java | 9 +- .../geode/internal/cache/CachePerfStats.java | 7 +- .../geode/internal/cache/CacheServerImpl.java | 43 +- .../geode/internal/cache/CacheServerLauncher.java | 186 +- .../cache/CachedDeserializableFactory.java | 11 +- .../cache/ClientSubscriptionConfigImpl.java | 13 +- .../geode/internal/cache/ColocationHelper.java | 13 +- .../geode/internal/cache/ColocationLogger.java | 11 +- .../apache/geode/internal/cache/Conflatable.java | 2 +- .../geode/internal/cache/ControllerAdvisor.java | 10 +- .../internal/cache/CreateRegionProcessor.java | 45 +- .../geode/internal/cache/DestroyOperation.java | 6 +- .../cache/DestroyPartitionedRegionMessage.java | 9 +- .../internal/cache/DestroyRegionOperation.java | 26 +- .../org/apache/geode/internal/cache/DiskId.java | 13 +- .../apache/geode/internal/cache/DiskInitFile.java | 74 +- .../geode/internal/cache/DiskStoreFactoryImpl.java | 57 +- .../apache/geode/internal/cache/DiskStoreImpl.java | 203 +- .../geode/internal/cache/DiskStoreMonitor.java | 56 +- .../internal/cache/DiskWriteAttributesImpl.java | 38 +- .../geode/internal/cache/DistPeerTXStateStub.java | 9 +- .../geode/internal/cache/DistTXCommitMessage.java | 3 +- .../internal/cache/DistTXPrecommitMessage.java | 4 +- .../apache/geode/internal/cache/DistTXState.java | 6 +- .../internal/cache/DistTXStateOnCoordinator.java | 13 +- .../cache/DistTXStateProxyImplOnCoordinator.java | 40 +- .../cache/DistTXStateProxyImplOnDatanode.java | 4 +- .../internal/cache/DistributedCacheOperation.java | 20 +- .../geode/internal/cache/DistributedRegion.java | 310 +- .../DistributedRegionFunctionStreamingMessage.java | 17 +- .../cache/DistributedRemoveAllOperation.java | 4 +- .../apache/geode/internal/cache/EntriesSet.java | 16 +- .../geode/internal/cache/EntryEventImpl.java | 44 +- .../apache/geode/internal/cache/EntrySnapshot.java | 7 +- .../org/apache/geode/internal/cache/EventID.java | 9 +- .../geode/internal/cache/ExpirationScheduler.java | 7 +- .../apache/geode/internal/cache/ExpiryTask.java | 55 +- .../apache/geode/internal/cache/FilterProfile.java | 17 +- .../geode/internal/cache/FilterRoutingInfo.java | 2 +- .../internal/cache/FindDurableQueueProcessor.java | 2 +- .../geode/internal/cache/GemFireCacheImpl.java | 254 +- .../geode/internal/cache/GemfireCacheHelper.java | 36 - .../apache/geode/internal/cache/GridAdvisor.java | 8 +- .../org/apache/geode/internal/cache/HARegion.java | 9 +- .../internal/cache/InitialImageFlowControl.java | 16 +- .../internal/cache/InitialImageOperation.java | 33 +- .../apache/geode/internal/cache/InterestEvent.java | 6 +- .../internal/cache/InternalPersistentRegion.java | 25 + .../geode/internal/cache/InternalRegion.java | 7 + .../org/apache/geode/internal/cache/KeyInfo.java | 9 +- .../geode/internal/cache/LoaderHelperImpl.java | 8 +- .../apache/geode/internal/cache/LocalDataSet.java | 15 +- .../apache/geode/internal/cache/LocalRegion.java | 373 +- .../cache/MemberFunctionStreamingMessage.java | 18 +- .../geode/internal/cache/NonLocalRegionEntry.java | 91 +- .../org/apache/geode/internal/cache/Oplog.java | 265 +- .../apache/geode/internal/cache/OverflowOplog.java | 90 +- .../geode/internal/cache/OverflowOplogSet.java | 13 +- .../internal/cache/PRHARedundancyProvider.java | 81 +- .../geode/internal/cache/PRQueryProcessor.java | 169 +- .../internal/cache/PartitionAttributesImpl.java | 54 +- .../cache/PartitionRegionConfigValidator.java | 150 +- .../geode/internal/cache/PartitionedRegion.java | 472 +- .../internal/cache/PartitionedRegionDataStore.java | 156 +- .../internal/cache/PartitionedRegionHelper.java | 68 +- .../cache/PartitionedRegionQueryEvaluator.java | 39 +- .../cache/PartitionedRegionRedundancyTracker.java | 7 +- .../geode/internal/cache/PeerTXStateStub.java | 5 +- .../geode/internal/cache/PersistentOplogSet.java | 23 +- .../internal/cache/PlaceHolderDiskRegion.java | 11 +- .../geode/internal/cache/PoolFactoryImpl.java | 6 +- .../geode/internal/cache/PoolManagerImpl.java | 19 +- .../cache/PreferBytesCachedDeserializable.java | 4 +- .../geode/internal/cache/ProxyBucketRegion.java | 6 +- .../geode/internal/cache/ProxyRegionMap.java | 165 +- .../geode/internal/cache/QueuedOperation.java | 15 +- .../geode/internal/cache/RegionEventImpl.java | 3 +- .../geode/internal/cache/RegionNameValidation.java | 9 +- .../cache/SearchLoadAndWriteProcessor.java | 51 +- .../geode/internal/cache/ServerPingMessage.java | 14 +- .../internal/cache/SingleThreadJTAExecutor.java | 21 +- .../geode/internal/cache/StateFlushOperation.java | 21 +- .../cache/StoreAllCachedDeserializable.java | 3 +- .../geode/internal/cache/TXCommitMessage.java | 204 +- .../org/apache/geode/internal/cache/TXEntry.java | 10 +- .../apache/geode/internal/cache/TXEntryState.java | 50 +- .../geode/internal/cache/TXEntryUserAttrState.java | 6 +- .../geode/internal/cache/TXFarSideCMTracker.java | 63 +- .../apache/geode/internal/cache/TXManagerImpl.java | 92 +- .../org/apache/geode/internal/cache/TXMessage.java | 13 +- .../apache/geode/internal/cache/TXRegionState.java | 12 +- .../internal/cache/TXRemoteRollbackMessage.java | 3 +- .../geode/internal/cache/TXReservationMgr.java | 6 +- .../org/apache/geode/internal/cache/TXState.java | 101 +- .../geode/internal/cache/TXStateProxyImpl.java | 31 +- .../apache/geode/internal/cache/TXStateStub.java | 18 +- .../geode/internal/cache/TombstoneService.java | 16 +- .../internal/cache/UpdateAttributesProcessor.java | 2 +- .../cache/UpdateEntryVersionOperation.java | 7 +- .../geode/internal/cache/UpdateOperation.java | 8 +- .../internal/cache/VMCachedDeserializable.java | 3 +- .../geode/internal/cache/VMLRURegionMap.java | 9 +- .../geode/internal/cache/ValidatingDiskRegion.java | 3 +- .../internal/cache/backup/BackupOperation.java | 3 +- .../geode/internal/cache/backup/BackupService.java | 22 +- .../cache/backup/FileSystemBackupWriter.java | 4 +- .../internal/cache/backup/FinishBackupRequest.java | 4 +- .../cache/backup/PrepareBackupRequest.java | 4 +- .../CompressedCachedDeserializable.java | 7 +- .../internal/cache/control/HeapMemoryMonitor.java | 173 +- .../cache/control/InternalResourceManager.java | 66 +- .../internal/cache/control/MemoryThresholds.java | 10 +- .../cache/control/OffHeapMemoryMonitor.java | 50 +- .../internal/cache/control/ResourceAdvisor.java | 8 +- .../cache/entries/AbstractDiskRegionEntry.java | 8 +- .../cache/entries/AbstractRegionEntry.java | 44 +- .../geode/internal/cache/entries/DiskEntry.java | 187 +- .../cache/eviction/AbstractEvictionList.java | 14 +- .../internal/cache/eviction/CountLRUEviction.java | 11 +- .../geode/internal/cache/eviction/HeapEvictor.java | 45 +- .../internal/cache/eviction/HeapLRUController.java | 6 +- .../cache/eviction/LRUListWithAsyncSorting.java | 23 +- .../cache/eviction/LRUListWithSyncSorting.java | 11 +- .../cache/eviction/MemoryLRUController.java | 5 +- .../internal/cache/eviction/OffHeapEvictor.java | 7 +- .../internal/cache/eviction/RegionEvictorTask.java | 4 +- .../internal/cache/execute/AbstractExecution.java | 42 +- .../execute/DistributedRegionFunctionExecutor.java | 59 +- .../DistributedRegionFunctionResultSender.java | 22 +- .../cache/execute/FunctionExecutionNodePruner.java | 5 +- .../execute/FunctionStreamingResultCollector.java | 24 +- .../cache/execute/InternalFunctionService.java | 14 +- .../cache/execute/LocalResultCollectorImpl.java | 8 +- .../cache/execute/MemberFunctionExecutor.java | 31 +- .../cache/execute/MemberFunctionResultSender.java | 14 +- .../cache/execute/MultiRegionFunctionExecutor.java | 35 +- .../geode/internal/cache/execute/NoResult.java | 15 +- .../execute/PartitionedRegionFunctionExecutor.java | 33 +- .../PartitionedRegionFunctionResultSender.java | 16 +- .../cache/execute/ServerFunctionExecutor.java | 24 +- .../execute/ServerRegionFunctionExecutor.java | 28 +- .../ServerToClientFunctionResultSender.java | 36 +- .../ServerToClientFunctionResultSender65.java | 29 +- .../geode/internal/cache/ha/HARegionQueue.java | 104 +- .../internal/cache/ha/QueueRemovalMessage.java | 15 +- .../internal/cache/locks/TXLockServiceImpl.java | 29 +- .../cache/locks/TXOriginatorRecoveryProcessor.java | 15 +- .../locks/TXRecoverGrantorMessageProcessor.java | 16 +- .../internal/cache/map/AbstractRegionMapPut.java | 11 +- .../internal/cache/map/RegionMapCommitPut.java | 6 - .../geode/internal/cache/map/RegionMapDestroy.java | 16 +- .../geode/internal/cache/map/RegionMapPut.java | 2 +- .../AllBucketProfilesUpdateMessage.java | 9 +- .../cache/partitioned/BucketBackupMessage.java | 5 +- .../cache/partitioned/BucketSizeMessage.java | 13 +- .../cache/partitioned/ContainsKeyValueMessage.java | 21 +- .../internal/cache/partitioned/DestroyMessage.java | 5 +- .../internal/cache/partitioned/DumpB2NRegion.java | 5 +- .../cache/partitioned/FetchBulkEntriesMessage.java | 23 +- .../cache/partitioned/FetchEntriesMessage.java | 21 +- .../cache/partitioned/FetchEntryMessage.java | 14 +- .../cache/partitioned/FetchKeysMessage.java | 26 +- .../internal/cache/partitioned/GetMessage.java | 17 +- .../cache/partitioned/IndexCreationMsg.java | 20 +- .../cache/partitioned/InvalidateMessage.java | 7 +- .../cache/partitioned/ManageBucketMessage.java | 9 +- .../PRFunctionStreamingResultCollector.java | 18 +- .../partitioned/PRUpdateEntryVersionMessage.java | 3 +- .../cache/partitioned/PartitionMessage.java | 52 +- .../PartitionedRegionFunctionStreamingMessage.java | 9 +- .../partitioned/PartitionedRegionRebalanceOp.java | 15 +- .../cache/partitioned/PrimaryRequestMessage.java | 6 +- .../cache/partitioned/PutAllPRMessage.java | 53 +- .../internal/cache/partitioned/PutMessage.java | 27 +- .../internal/cache/partitioned/QueryMessage.java | 23 +- .../cache/partitioned/RedundancyLogger.java | 29 +- .../internal/cache/partitioned/RegionAdvisor.java | 12 +- .../cache/partitioned/RemoveAllPRMessage.java | 55 +- .../cache/partitioned/RemoveIndexesMessage.java | 25 +- .../internal/cache/partitioned/SizeMessage.java | 15 +- .../partitioned/StreamingPartitionOperation.java | 14 +- .../rebalance/ExplicitMoveDirector.java | 21 +- .../rebalance/PercentageMoveDirector.java | 21 +- .../cache/partitioned/rebalance/model/Member.java | 2 +- .../model/PartitionedRegionLoadModel.java | 8 +- .../cache/persistence/DiskInitFileParser.java | 5 +- .../cache/persistence/PersistenceAdvisorImpl.java | 64 +- .../PersistenceInitialImageAdvisor.java | 4 +- .../cache/persistence/PersistentMemberManager.java | 16 +- .../cache/snapshot/CacheSnapshotServiceImpl.java | 12 +- .../internal/cache/snapshot/FlowController.java | 22 +- .../geode/internal/cache/snapshot/GFSnapshot.java | 9 +- .../cache/snapshot/RegionSnapshotServiceImpl.java | 32 +- .../internal/cache/snapshot/WindowedExporter.java | 14 +- .../apache/geode/internal/cache/tier/Acceptor.java | 2 +- .../cache/tier/InternalClientMembership.java | 30 +- .../internal/cache/tier/sockets/AcceptorImpl.java | 356 +- .../internal/cache/tier/sockets/BaseCommand.java | 67 +- .../cache/tier/sockets/BaseCommandQuery.java | 24 +- .../cache/tier/sockets/CacheClientNotifier.java | 142 +- .../cache/tier/sockets/CacheClientProxy.java | 209 +- .../cache/tier/sockets/CacheClientUpdater.java | 129 +- .../cache/tier/sockets/CacheServerHelper.java | 9 +- .../cache/tier/sockets/ChunkedMessage.java | 13 +- .../tier/sockets/ClientBlacklistProcessor.java | 167 - .../tier/sockets/ClientDataSerializerMessage.java | 7 +- .../tier/sockets/ClientDenylistProcessor.java | 167 + .../cache/tier/sockets/ClientHealthMonitor.java | 59 +- .../tier/sockets/ClientInstantiatorMessage.java | 7 +- .../tier/sockets/ClientProxyMembershipID.java | 38 +- .../cache/tier/sockets/ClientUserAuths.java | 11 +- .../cache/tier/sockets/CommandInitializer.java | 6 + .../internal/cache/tier/sockets/EncryptorImpl.java | 21 +- .../cache/tier/sockets/HAEventWrapper.java | 2 +- .../internal/cache/tier/sockets/Handshake.java | 11 +- .../geode/internal/cache/tier/sockets/Message.java | 52 +- .../cache/tier/sockets/MessageIdExtractor.java | 5 +- .../tier/sockets/OriginalServerConnection.java | 7 +- .../sockets/RemoveClientFromBlacklistMessage.java | 98 - .../sockets/RemoveClientFromDenylistMessage.java | 98 + .../cache/tier/sockets/ServerConnection.java | 87 +- .../tier/sockets/ServerSideHandshakeFactory.java | 4 +- .../tier/sockets/ServerSideHandshakeImpl.java | 15 +- .../cache/tier/sockets/TcpServerFactory.java | 4 +- .../cache/tier/sockets/command/ClearRegion.java | 13 +- .../cache/tier/sockets/command/ContainsKey.java | 20 +- .../cache/tier/sockets/command/ContainsKey66.java | 22 +- .../cache/tier/sockets/command/CreateRegion.java | 22 +- .../cache/tier/sockets/command/Default.java | 13 +- .../cache/tier/sockets/command/Destroy.java | 31 +- .../cache/tier/sockets/command/Destroy65.java | 31 +- .../cache/tier/sockets/command/DestroyRegion.java | 13 +- .../tier/sockets/command/ExecuteFunction.java | 38 +- .../tier/sockets/command/ExecuteFunction65.java | 45 +- .../tier/sockets/command/ExecuteFunction66.java | 89 +- .../tier/sockets/command/ExecuteFunction70.java | 3 +- .../sockets/command/ExecuteRegionFunction.java | 53 +- .../sockets/command/ExecuteRegionFunction61.java | 65 +- .../sockets/command/ExecuteRegionFunction65.java | 73 +- .../sockets/command/ExecuteRegionFunction66.java | 370 +- .../command/ExecuteRegionFunctionGeode18.java | 62 + .../command/ExecuteRegionFunctionSingleHop.java | 51 +- .../sockets/command/GatewayReceiverCommand.java | 161 +- .../internal/cache/tier/sockets/command/Get70.java | 19 +- .../cache/tier/sockets/command/GetAll.java | 29 +- .../cache/tier/sockets/command/GetAll651.java | 26 +- .../cache/tier/sockets/command/GetAll70.java | 26 +- .../tier/sockets/command/GetAllWithCallback.java | 30 +- .../command/GetClientPRMetadataCommand.java | 14 +- .../command/GetClientPRMetadataCommand66.java | 14 +- .../GetClientPartitionAttributesCommand.java | 18 +- .../GetClientPartitionAttributesCommand66.java | 16 +- .../tier/sockets/command/GetFunctionAttribute.java | 9 +- .../cache/tier/sockets/command/Invalid.java | 11 +- .../cache/tier/sockets/command/Invalidate.java | 26 +- .../cache/tier/sockets/command/KeySet.java | 15 +- .../internal/cache/tier/sockets/command/Put.java | 35 +- .../internal/cache/tier/sockets/command/Put61.java | 7 +- .../internal/cache/tier/sockets/command/Put65.java | 7 +- .../cache/tier/sockets/command/PutAll.java | 13 +- .../cache/tier/sockets/command/PutAll70.java | 13 +- .../cache/tier/sockets/command/PutAll80.java | 13 +- .../tier/sockets/command/PutUserCredentials.java | 10 +- .../sockets/command/RegisterInstantiators.java | 6 +- .../tier/sockets/command/RegisterInterest.java | 21 +- .../tier/sockets/command/RegisterInterest61.java | 21 +- .../tier/sockets/command/RegisterInterestList.java | 23 +- .../sockets/command/RegisterInterestList61.java | 23 +- .../sockets/command/RegisterInterestList66.java | 21 +- .../cache/tier/sockets/command/RemoveAll.java | 18 +- .../cache/tier/sockets/command/RemoveUserAuth.java | 10 +- .../cache/tier/sockets/command/Request.java | 19 +- .../tier/sockets/command/RequestEventValue.java | 12 +- .../internal/cache/tier/sockets/command/Size.java | 15 +- .../tier/sockets/command/UnregisterInterest.java | 12 +- .../sockets/command/UnregisterInterestList.java | 12 +- .../cache/tx/AbstractPeerTXRegionStub.java | 37 +- .../geode/internal/cache/tx/ClientTXStateStub.java | 3 +- .../internal/cache/tx/DistClientTXStateStub.java | 37 +- .../internal/cache/tx/DistributedTXRegionStub.java | 37 +- .../internal/cache/tx/PartitionedTXRegionStub.java | 68 +- .../internal/cache/tx/RemoteClearMessage.java | 3 +- .../cache/tx/RemoteContainsKeyValueMessage.java | 9 +- .../internal/cache/tx/RemoteDestroyMessage.java | 5 +- .../internal/cache/tx/RemoteFetchEntryMessage.java | 5 +- .../internal/cache/tx/RemoteFetchKeysMessage.java | 6 +- .../cache/tx/RemoteFetchVersionMessage.java | 3 +- .../geode/internal/cache/tx/RemoteGetMessage.java | 13 +- .../internal/cache/tx/RemoteInvalidateMessage.java | 5 +- .../internal/cache/tx/RemoteOperationMessage.java | 5 +- .../internal/cache/tx/RemotePutAllMessage.java | 3 +- .../geode/internal/cache/tx/RemotePutMessage.java | 10 +- .../internal/cache/tx/RemoteRemoveAllMessage.java | 3 +- .../cache/versions/RegionVersionHolder.java | 6 +- .../cache/versions/RegionVersionVector.java | 7 +- .../internal/cache/wan/AbstractGatewaySender.java | 103 +- .../wan/AbstractGatewaySenderEventProcessor.java | 82 +- .../internal/cache/wan/GatewaySenderAdvisor.java | 172 +- .../wan/GatewaySenderEventCallbackDispatcher.java | 14 +- .../internal/cache/wan/GatewaySenderEventImpl.java | 6 +- ...aySenderQueueEntrySynchronizationOperation.java | 11 +- ...currentParallelGatewaySenderEventProcessor.java | 37 +- .../ConcurrentParallelGatewaySenderQueue.java | 5 - .../ParallelGatewaySenderEventProcessor.java | 12 +- .../wan/parallel/ParallelGatewaySenderQueue.java | 68 +- .../wan/parallel/ParallelQueueRemovalMessage.java | 23 +- .../cache/wan/serial/BatchDestroyOperation.java | 14 +- ...oncurrentSerialGatewaySenderEventProcessor.java | 36 +- .../serial/SerialGatewaySenderEventProcessor.java | 82 +- .../cache/wan/serial/SerialGatewaySenderQueue.java | 269 +- .../internal/cache/xmlcache/AbstractXmlParser.java | 5 +- .../internal/cache/xmlcache/CacheCreation.java | 381 +- .../cache/xmlcache/CacheServerCreation.java | 9 +- .../xmlcache/CacheTransactionManagerCreation.java | 43 +- .../geode/internal/cache/xmlcache/CacheXml.java | 7 +- .../internal/cache/xmlcache/CacheXmlGenerator.java | 18 +- .../internal/cache/xmlcache/CacheXmlParser.java | 274 +- .../cache/xmlcache/CacheXmlPropertyResolver.java | 7 +- .../xmlcache/CacheXmlPropertyResolverHelper.java | 8 +- .../cache/xmlcache/ClientCacheCreation.java | 33 +- .../cache/xmlcache/ClientHaQueueCreation.java | 13 +- .../xmlcache/DiskStoreAttributesCreation.java | 69 +- .../cache/xmlcache/RegionAttributesCreation.java | 129 +- .../internal/cache/xmlcache/RegionCreation.java | 204 +- .../cache/xmlcache/SerializerCreation.java | 7 +- .../internal/datasource/AbstractDataSource.java | 11 +- .../internal/datasource/AbstractPoolCache.java | 24 +- .../datasource/ClientConnectionFactoryWrapper.java | 5 +- .../datasource/ConnectionPoolCacheImpl.java | 7 +- .../datasource/DataSourceCreateException.java | 6 +- .../internal/datasource/DataSourceFactory.java | 194 +- .../datasource/FacetsJCAConnectionManagerImpl.java | 27 +- .../datasource/GemFireBasicDataSource.java | 37 +- .../datasource/GemFireConnPooledDataSource.java | 38 +- .../datasource/GemFireTransactionDataSource.java | 19 +- .../datasource/JCAConnectionManagerImpl.java | 26 +- .../internal/datasource/ManagedPoolCacheImpl.java | 4 +- .../internal/datasource/TranxPoolCacheImpl.java | 7 +- .../geode/internal/i18n/LocalizedStrings.java | 7762 -------------------- .../io/MainWithChildrenRollingFileHandler.java | 30 +- .../geode/internal/io/RollingFileHandler.java | 5 +- .../apache/geode/internal/jndi/ContextImpl.java | 91 +- .../apache/geode/internal/jndi/JNDIInvoker.java | 178 +- .../geode/internal/jta/GlobalTransaction.java | 125 +- .../apache/geode/internal/jta/TransactionImpl.java | 39 +- .../geode/internal/jta/TransactionManagerImpl.java | 170 +- .../geode/internal/jta/TransactionUtils.java | 10 +- .../geode/internal/jta/UserTransactionImpl.java | 10 +- .../apache/geode/internal/lang/SystemUtils.java | 46 - .../geode/internal/logging/DebugLogWriter.java | 117 - .../geode/internal/logging/GemFireFormatter.java | 3 +- .../geode/internal/logging/InternalLogWriter.java | 22 +- .../geode/internal/logging/LocalLogWriter.java | 42 +- .../apache/geode/internal/logging/LogConfig.java | 8 +- .../geode/internal/logging/LogConfigSupplier.java | 22 + .../geode/internal/logging/LogFileParser.java | 17 +- .../apache/geode/internal/logging/LogService.java | 87 +- .../geode/internal/logging/LogWriterFactory.java | 8 +- .../geode/internal/logging/LogWriterImpl.java | 528 +- .../geode/internal/logging/LogWriterLevel.java | 39 + .../geode/internal/logging/LoggingExecutors.java | 307 + .../geode/internal/logging/LoggingThread.java | 58 + .../internal/logging/LoggingThreadFactory.java | 131 + .../geode/internal/logging/LoggingThreadGroup.java | 26 +- .../logging/LoggingUncaughtExceptionHandler.java | 107 + .../geode/internal/logging/ManagerLogWriter.java | 213 +- .../geode/internal/logging/MergeLogFiles.java | 112 +- .../geode/internal/logging/PureLogWriter.java | 244 +- .../internal/logging/SecurityLocalLogWriter.java | 75 - .../geode/internal/logging/SecurityLogConfig.java | 19 +- .../geode/internal/logging/SecurityLogWriter.java | 20 +- .../internal/logging/SecurityManagerLogWriter.java | 20 +- .../apache/geode/internal/logging/SortLogFile.java | 20 +- .../internal/logging/StandardErrorPrinter.java | 9 +- .../internal/logging/StandardOutputPrinter.java | 9 +- .../internal/logging/log4j/AlertAppender.java | 48 +- .../geode/internal/logging/log4j/AlertLevel.java | 61 + .../internal/logging/log4j/GemFireLogger.java | 492 +- .../logging/log4j/HexThreadIdPatternConverter.java | 57 + .../internal/logging/log4j/LocalizedMessage.java | 80 - .../geode/internal/logging/log4j/LogLevel.java | 12 +- .../internal/logging/log4j/LogWriterAppenders.java | 18 +- .../internal/logging/log4j/LogWriterLogger.java | 825 ++- .../logging/log4j/ThreadIdPatternConverter.java | 57 - .../memcached/commands/StorageCommand.java | 12 +- .../internal/monitoring/ThreadsMonitoringImpl.java | 3 +- .../monitoring/ThreadsMonitoringProcess.java | 10 +- .../monitoring/executor/AbstractExecutor.java | 45 +- .../monitoring/executor/PooledExecutorGroup.java | 4 + .../internal/net/SSLConfigurationFactory.java | 11 +- .../apache/geode/internal/net/SocketCloser.java | 36 +- .../apache/geode/internal/net/SocketCreator.java | 83 +- .../DisconnectingOutOfOffHeapMemoryListener.java | 7 +- .../geode/internal/offheap/FreeListManager.java | 4 +- .../internal/offheap/MemoryAllocatorImpl.java | 2 +- .../internal/offheap/OffHeapRegionEntryHelper.java | 14 +- .../geode/internal/offheap/OffHeapStorage.java | 9 +- .../internal/offheap/OffHeapStoredObject.java | 2 +- .../internal/process/ControlFileWatchdog.java | 4 +- .../internal/process/FileProcessController.java | 3 +- .../process/MBeanOrFileProcessController.java | 6 + .../internal/process/MBeanProcessController.java | 32 +- .../internal/process/ProcessStreamReader.java | 8 +- .../geode/internal/process/StartupStatus.java | 9 +- .../geode/internal/security/AuthorizeRequest.java | 136 +- .../internal/security/AuthorizeRequestPP.java | 45 +- .../security/SecurableCommunicationChannel.java | 22 +- .../statistics/AbstractStatisticsFactory.java | 3 +- .../geode/internal/statistics/ArchiveSplitter.java | 27 +- .../geode/internal/statistics/CallbackSampler.java | 12 +- .../internal/statistics/GemFireStatSampler.java | 14 +- .../geode/internal/statistics/HostStatHelper.java | 25 +- .../geode/internal/statistics/HostStatSampler.java | 25 +- .../statistics/LocalStatisticsFactory.java | 6 +- .../geode/internal/statistics/ResourceType.java | 3 +- .../geode/internal/statistics/SampleCollector.java | 8 +- .../internal/statistics/SimpleStatSampler.java | 5 +- .../internal/statistics/StatArchiveHandler.java | 42 +- .../internal/statistics/StatArchiveReader.java | 60 +- .../internal/statistics/StatArchiveWriter.java | 70 +- .../internal/statistics/StatMonitorHandler.java | 4 +- .../statistics/StatisticDescriptorImpl.java | 27 +- .../geode/internal/statistics/StatisticsImpl.java | 9 +- .../statistics/StatisticsTypeFactoryImpl.java | 5 +- .../internal/statistics/StatisticsTypeImpl.java | 19 +- .../internal/statistics/StatisticsTypeXml.java | 30 +- .../statistics/platform/LinuxProcFsStatistics.java | 2 +- .../internal/stats50/Atomic50StatisticsImpl.java | 16 +- .../apache/geode/internal/stats50/VMStats50.java | 1 + .../geode/internal/tcp/ConnectExceptions.java | 7 +- .../org/apache/geode/internal/tcp/Connection.java | 519 +- .../apache/geode/internal/tcp/ConnectionTable.java | 86 +- .../geode/internal/tcp/DirectReplySender.java | 9 +- .../apache/geode/internal/tcp/MsgDestreamer.java | 16 +- .../apache/geode/internal/tcp/MsgOutputStream.java | 11 +- .../org/apache/geode/internal/tcp/MsgStreamer.java | 12 +- .../apache/geode/internal/tcp/ServerDelegate.java | 6 +- .../org/apache/geode/internal/tcp/TCPConduit.java | 197 +- .../apache/geode/internal/util/Breadcrumbs.java | 5 +- .../apache/geode/internal/util/DscodeHelper.java | 38 + .../apache/geode/internal/util/PasswordUtil.java | 2 +- .../apache/geode/internal/util/PluckStacks.java | 30 +- .../org/apache/geode/internal/util/StopWatch.java | 3 +- .../concurrent/CustomEntryConcurrentHashMap.java | 4 +- .../internal/util/concurrent/FutureResult.java | 7 +- .../concurrent/StoppableCountDownOrUpLatch.java | 3 +- .../util/concurrent/StoppableNonReentrantLock.java | 4 +- .../geode/management/cli/CommandService.java | 6 +- .../apache/geode/management/cli/GfshCommand.java | 5 + .../geode/management/cli/SingleGfshCommand.java | 4 +- .../management/internal/FederatingManager.java | 258 +- .../geode/management/internal/JettyHelper.java | 2 +- .../management/internal/JmxManagerAdvisor.java | 7 +- .../geode/management/internal/LocalManager.java | 37 +- .../geode/management/internal/MBeanJMXAdapter.java | 28 +- .../management/internal/MBeanProxyFactory.java | 10 +- .../internal/MXBeanProxyInvocationHandler.java | 6 +- .../management/internal/ManagementFunction.java | 5 +- .../internal/ManagementResourceRepo.java | 4 +- .../management/internal/ManagementStrings.java | 195 - .../management/internal/ManagerStartupMessage.java | 33 +- .../geode/management/internal/MemberMessenger.java | 78 +- .../geode/management/internal/NotificationHub.java | 6 +- .../internal/SystemManagementService.java | 22 +- .../internal/beans/AsyncEventQueueMBeanBridge.java | 8 +- .../internal/beans/DiskStoreMBeanBridge.java | 5 +- .../internal/beans/DistributedSystemBridge.java | 34 +- .../internal/beans/GatewaySenderMBeanBridge.java | 6 +- .../internal/beans/LocatorMBeanBridge.java | 12 +- .../management/internal/beans/MBeanAggregator.java | 6 +- .../internal/beans/ManagementListener.java | 57 +- .../internal/beans/MemberMBeanBridge.java | 54 +- .../internal/beans/QueryDataFunction.java | 35 +- .../internal/beans/RegionMBeanBridge.java | 5 +- .../management/internal/beans/ServerBridge.java | 5 +- .../beans/stats/AggregateRegionStatsMonitor.java | 323 +- .../internal/beans/stats/GCStatsMonitor.java | 75 +- .../beans/stats/GatewaySenderOverflowMonitor.java | 171 +- .../internal/beans/stats/MBeanStatsMonitor.java | 35 +- .../beans/stats/MemberLevelDiskMonitor.java | 375 +- .../internal/beans/stats/StatsAggregator.java | 6 +- .../internal/beans/stats/VMStatsMonitor.java | 116 +- .../management/internal/cli/GfshParseResult.java | 4 + .../geode/management/internal/cli/LogWrapper.java | 4 +- .../cli/commands/CommandAvailabilityIndicator.java | 1 + .../cli/commands/CreateDataSourceCommand.java | 177 + .../cli/commands/CreateDataSourceInterceptor.java | 59 + .../cli/commands/CreateDiskStoreCommand.java | 2 +- .../cli/commands/CreateGatewaySenderCommand.java | 101 +- .../cli/commands/CreateJndiBindingCommand.java | 23 +- .../internal/cli/commands/CreateRegionCommand.java | 23 +- .../cli/commands/DestroyGatewaySenderCommand.java | 36 +- .../cli/commands/GatewayCommandsUtils.java | 29 - .../commands/LoadBalanceGatewaySenderCommand.java | 79 +- .../cli/commands/PauseGatewaySenderCommand.java | 34 +- .../internal/cli/commands/RebalanceCommand.java | 5 +- .../cli/commands/ResumeGatewaySenderCommand.java | 36 +- .../internal/cli/commands/ShutdownCommand.java | 6 +- .../cli/commands/StartGatewayReceiverCommand.java | 32 +- .../cli/commands/StartGatewaySenderCommand.java | 47 +- .../internal/cli/commands/StartLocatorCommand.java | 48 +- .../internal/cli/commands/StartMemberUtils.java | 5 +- .../internal/cli/commands/StartServerCommand.java | 43 +- .../cli/commands/StatusGatewayReceiverCommand.java | 43 +- .../cli/commands/StatusGatewaySenderCommand.java | 40 +- .../cli/commands/StopGatewayReceiverCommand.java | 32 +- .../cli/commands/StopGatewaySenderCommand.java | 29 +- .../cli/commands/UsernamePasswordInterceptor.java | 60 + .../cli/converters/PoolPropertyConverter.java | 60 + .../cli/functions/CreateJndiBindingFunction.java | 49 +- .../functions/GatewayReceiverCreateFunction.java | 5 +- .../cli/functions/GatewaySenderCreateFunction.java | 15 +- .../cli/functions/GatewaySenderFunctionArgs.java | 76 +- .../cli/functions/RegionCreateFunction.java | 23 +- .../internal/cli/functions/RegionFunctionArgs.java | 5 +- .../internal/cli/functions/ShutDownFunction.java | 4 +- .../cli/functions/UserFunctionExecution.java | 2 +- .../geode/management/internal/cli/help/Helper.java | 51 +- .../management/internal/cli/i18n/CliStrings.java | 11 +- .../internal/cli/result/ResultBuilder.java | 4 - .../internal/cli/result/model/FileResultModel.java | 2 +- .../cli/result/model/TabularResultModel.java | 8 + .../geode/management/internal/cli/shell/Gfsh.java | 3 +- .../internal/cli/util/DiskStoreCompacter.java | 7 +- .../internal/cli/util/DiskStoreUpgrader.java | 7 +- .../management/internal/cli/util/JdkTool.java | 2 +- .../management/internal/cli/util/MergeLogs.java | 11 +- .../SerializableObjectHttpMessageConverter.java | 11 +- .../UniversalMembershipListenerAdapter.java | 5 +- .../pdx/internal/AutoSerializableManager.java | 5 +- .../geode/pdx/internal/ClientTypeRegistration.java | 6 + .../org/apache/geode/pdx/internal/EnumInfo.java | 5 +- .../apache/geode/pdx/internal/PdxInstanceEnum.java | 5 +- .../apache/geode/pdx/internal/PdxInstanceImpl.java | 2 +- .../apache/geode/pdx/internal/PdxReaderImpl.java | 9 +- .../apache/geode/pdx/internal/TypeRegistry.java | 9 +- .../pdx/internal/json/PdxInstanceSortedHelper.java | 3 +- .../org/apache/geode/redis/GeodeRedisServer.java | 3 +- .../geode/redis/internal/RegionProvider.java | 2 +- .../redis/internal/executor/list/ListExecutor.java | 2 +- .../executor/sortedset/SortedSetExecutor.java | 4 + .../executor/sortedset/ZLexCountExecutor.java | 8 +- .../executor/sortedset/ZRangeByLexExecutor.java | 8 +- .../executor/sortedset/ZRemRangeByLexExecutor.java | 8 +- .../geode.apache.org/schema/cache/cache-1.0.xsd | 47 +- geode-core/src/main/resources/log4j2-cli.xml | 18 +- geode-core/src/main/resources/log4j2.xml | 18 +- .../geode/internal/logging/log4j/log4j2-legacy.xml | 2 +- .../sanctioned-geode-core-serializables.txt | 3 +- .../logging/LogWriterDisabledPerformanceTest.java | 5 +- .../internal/logging/LogWriterPerformanceTest.java | 13 +- .../logging/LoggingPerformanceTestCase.java | 1 - .../log4j/Log4J2DisabledPerformanceTest.java | 5 +- .../logging/log4j/Log4J2PerformanceTest.java | 50 +- .../LogWriterLoggerDisabledPerformanceTest.java | 5 +- .../log4j/LogWriterLoggerPerformanceTest.java | 52 +- .../org/apache/geode/SystemFailureJUnitTest.java | 6 +- .../internal/ExecuteRegionFunctionOpTest.java | 63 + .../client/internal/ServerBlackListJUnitTest.java | 112 - .../client/internal/ServerDenyListJUnitTest.java | 112 + .../AbstractCompiledValueTestJUnitTest.java | 112 + .../CompiledAggregateFunctionJUnitTest.java | 69 +- .../cache/query/internal/QueryMonitorTest.java | 124 +- .../RestrictedMethodInvocationAuthorizerTest.java | 224 +- .../internal/index/IndexElemArrayJUnitTest.java | 60 + .../query/internal/index/PrimaryKeyIndexTest.java | 98 + .../java/org/apache/geode/cache30/TestHeapLRU.java | 36 +- ...erverLauncherWaitOnServerMultiThreadedTest.java | 108 - .../ServerLauncherWaitOnServerTest.java | 121 + .../internal/ClusterDistributionManagerTest.java | 43 - .../internal/ClusterElderManagerTest.java | 286 + .../internal/DistributionConfigJUnitTest.java | 22 +- .../internal/ServerLocatorJUnitTest.java | 4 +- .../internal/locks/DLockServiceJUnitTest.java | 60 + .../GMSAuthenticatorWithAuthenticatorTest.java | 12 - .../GMSAuthenticatorWithSecurityManagerTest.java | 12 - .../apache/geode/internal/AbstractConfigTest.java | 74 +- .../java/org/apache/geode/internal/DSCODETest.java | 18 + .../geode/internal/GemFireVersionJUnitTest.java | 9 +- .../internal/InternalDataSerializerJUnitTest.java | 50 + ...lDataSerializerSerializationAcceptlistTest.java | 148 + ...alDataSerializerSerializationWhitelistTest.java | 148 - .../internal/cache/AbstractRegionMapTest.java | 143 +- .../geode/internal/cache/AfterCompletionTest.java | 75 +- .../geode/internal/cache/BeforeCompletionTest.java | 40 +- .../internal/cache/BucketRegionJUnitTest.java | 4 +- .../geode/internal/cache/BucketRegionTest.java | 301 + .../geode/internal/cache/ColocationHelperTest.java | 39 +- .../internal/cache/DistributedRegionTest.java | 56 + .../geode/internal/cache/EntryEventImplTest.java | 18 +- .../geode/internal/cache/GemFireCacheImplTest.java | 5 +- .../cache/LocalRegionBulkOperationTest.java | 88 + .../cache/PartitionedRegionQueryEvaluatorTest.java | 5 +- .../internal/cache/RegionNameValidationTest.java | 13 +- .../cache/SearchLoadAndWriteProcessorTest.java | 12 +- .../cache/SingleThreadJTAExecutorTest.java | 24 +- .../geode/internal/cache/TXCommitMessageTest.java | 60 + .../internal/cache/TXFarSideCMTrackerTest.java | 119 + .../geode/internal/cache/TXManagerImplTest.java | 17 +- .../geode/internal/cache/TXStateProxyImplTest.java | 59 + .../apache/geode/internal/cache/TXStateTest.java | 40 +- .../geode/internal/cache/TxCommitMessageTest.java | 1164 --- .../cache/entries/AbstractRegionEntryTest.java | 313 +- .../cache/entries/DiskEntryHelperTest.java | 106 + .../eviction/LRUListWithAsyncSortingTest.java | 9 +- .../internal/cache/map/RegionMapCommitPutTest.java | 37 + .../internal/cache/map/RegionMapDestroyTest.java | 1905 +++-- .../geode/internal/cache/map/RegionMapPutTest.java | 36 + .../cache/partitioned/PutAllPRMessageTest.java | 108 + .../cache/partitioned/RemoveAllPRMessageTest.java | 85 + .../tier/sockets/ClientHealthMonitorJUnitTest.java | 8 +- .../internal/cache/tier/sockets/HandshakeTest.java | 3 +- .../cache/tier/sockets/ServerConnectionTest.java | 15 +- .../cache/tier/sockets/TcpServerFactoryTest.java | 2 +- .../cache/tier/sockets/command/Destroy65Test.java | 12 + .../cache/tier/sockets/command/DestroyTest.java | 12 + .../sockets/command/ExecuteFunction65Test.java | 1 + .../sockets/command/ExecuteFunction66Test.java | 1 + .../tier/sockets/command/ExecuteFunctionTest.java | 1 + .../command/ExecuteRegionFunction66Test.java | 194 + .../command/ExecuteRegionFunctionGeode18Test.java | 196 + .../cache/tx/AbstractPeerTXRegionStubTest.java | 82 +- .../internal/datasource/DataSourceFactoryTest.java | 320 + .../GemFireBasicDataSourceJUnitTest.java | 6 +- .../io/CompositeOutputStreamJUnitTest.java | 593 +- .../geode/internal/jndi/JNDIInvokerTest.java | 100 + .../geode/internal/lang/SystemUtilsJUnitTest.java | 26 - .../internal/logging/LogServiceJUnitTest.java | 107 - .../geode/internal/logging/LogServiceTest.java | 110 + .../internal/logging/LogWriterImplJUnitTest.java | 79 - .../geode/internal/logging/LogWriterImplTest.java | 82 + .../geode/internal/logging/LogWriterLevelTest.java | 38 + .../internal/logging/LoggingThreadFactoryTest.java | 116 + .../geode/internal/logging/LoggingThreadTest.java | 73 + .../LoggingUncaughtExceptionHandlerTest.java | 117 + .../geode/internal/logging/NullLogWriter.java | 153 - .../internal/logging/SortLogFileJUnitTest.java | 106 - .../geode/internal/logging/SortLogFileTest.java | 109 + .../logging/log4j/AlertAppenderJUnitTest.java | 251 - .../internal/logging/log4j/AlertAppenderTest.java | 259 + .../internal/logging/log4j/AlertLevelTest.java | 137 + .../internal/logging/log4j/Configuration.java | 43 - .../logging/log4j/FastLoggerJUnitTest.java | 190 - .../internal/logging/log4j/FastLoggerTest.java | 181 + .../log4j/HexThreadIdPatternConverterTest.java | 45 + .../logging/log4j/LocalizedMessageJUnitTest.java | 56 - .../geode/internal/logging/log4j/LogLevelTest.java | 459 +- .../logging/log4j/LogWriterAppenderJUnitTest.java | 248 - .../logging/log4j/custom/BasicAppender.java | 74 - .../logging/log4j/custom/CustomConfiguration.java | 60 - .../ThreadsMonitoringProcessJUnitTest.java | 18 + .../net/SSLConfigurationFactoryJUnitTest.java | 199 +- .../geode/internal/net/SocketCloserJUnitTest.java | 136 - .../net/SocketCloserWithWaitJUnitTest.java | 35 - .../geode/internal/net/SocketCreatorJUnitTest.java | 45 +- .../geode/internal/net/SocketUtilsJUnitTest.java | 103 +- .../offheap/OffHeapRegionEntryHelperJUnitTest.java | 21 - ...AbstractProcessStreamReaderIntegrationTest.java | 312 - .../geode/internal/process/StartupStatusTest.java | 13 +- .../internal/process/io/IntegerFileWriter.java | 33 - .../internal/process/io/StringFileWriter.java | 43 - .../internal/process/lang/AvailablePidTest.java | 6 +- .../SecurableCommunicationChannelTest.java | 54 + .../geode/internal/util/IOUtilsJUnitTest.java | 294 +- .../management/internal/JettyHelperJUnitTest.java | 47 +- .../management/internal/MBeanJMXAdapterTest.java | 110 + .../management/internal/MBeanProxyFactoryTest.java | 73 + ...ServerBridgeClientMembershipRegressionTest.java | 7 +- .../internal/beans/ManagementListenerTest.java | 148 + .../stats/AggregateRegionStatsMonitorTest.java | 255 + .../internal/beans/stats/GCStatsMonitorTest.java | 87 + .../stats/GatewaySenderOverflowMonitorTest.java | 181 + .../beans/stats/MBeanStatsMonitorTest.java | 44 +- .../beans/stats/MemberLevelDiskMonitorTest.java | 241 + .../internal/beans/stats/VMStatsMonitorTest.java | 142 + .../cli/commands/CreateDataSourceCommandTest.java | 330 + .../commands/CreateDataSourceInterceptorTest.java | 139 + .../commands/CreateGatewaySenderCommandTest.java | 84 +- .../cli/commands/CreateJndiBindingCommandTest.java | 52 +- .../commands/DestroyGatewaySenderCommandTest.java | 72 +- .../cli/commands/DiskStoreCommandsJUnitTest.java | 424 +- .../cli/commands/ExportLogsCommandTest.java | 71 +- .../commands/ExportLogsInterceptorJUnitTest.java | 77 - .../cli/commands/ExportLogsInterceptorTest.java | 79 + .../cli/commands/ListIndexCommandJUnitTest.java | 190 +- .../cli/commands/LogLevelInterceptorTest.java | 9 +- .../commands/UsernamePasswordInterceptorTest.java | 124 + .../cli/converters/LogLevelConverterTest.java | 10 +- .../DescribeDiskStoreFunctionJUnitTest.java | 1773 ++--- .../cli/functions/ExportLogsFunctionTest.java | 11 +- .../cli/functions/GetRegionsFunctionTest.java | 7 +- .../functions/ListDiskStoresFunctionJUnitTest.java | 257 +- .../cli/functions/ListIndexFunctionJUnitTest.java | 421 +- .../cli/shell/GfshExecutionStrategyTest.java | 43 + .../cli/util/ExportLogsCacheWriterTest.java | 47 + .../cli/util/ExportLogsCacheWriterUnitTest.java | 44 - .../internal/cli/util/LogFilterTest.java | 19 +- .../internal/cli/util/LogLevelExtractorTest.java | 20 +- .../management/internal/cli/util/LogSizerTest.java | 25 +- .../apache/geode/management/model/SubOrder.java | 28 - .../golden/PassWithExpectedProblemTestCase.java | 84 - .../apache/geode/test/process/ProcessWrapper.java | 562 -- geode-core/src/test/resources/expected-pom.xml | 32 +- geode-core/src/test/resources/jta/cachejta.xml | 2 +- .../logging/log4j/custom/log4j2-custom.xml | 29 - .../log4j/marker/log4j2-gemfire_verbose-accept.xml | 24 - .../log4j/marker/log4j2-gemfire_verbose-deny.xml | 24 - .../log4j/marker/log4j2-geode_verbose-accept.xml | 24 - .../log4j/marker/log4j2-geode_verbose-deny.xml | 24 - .../org/apache/geode/test/golden/log4j2-test.xml | 20 +- .../RollingUpgrade2DUnitTestBase.java | 21 +- .../rollingupgrade/RollingUpgradeClients.java | 6 +- .../RollingUpgradeConcurrentPutsReplicated.java | 6 +- .../rollingupgrade/RollingUpgradeDUnitTest.java | 7 +- ...gradeHARegionNameOnDifferentServerVersions.java | 6 +- .../RollingUpgradeNonHAFunction.java | 150 + .../RollingUpgradeRollLocatorWithTwoServers.java | 6 +- .../RollingUpgradeRollLocatorsWithOldServer.java | 6 +- ...LocatorWithMultipleServersReplicatedRegion.java | 6 +- .../rollingupgrade/RollingUpgradeTracePRQuery.java | 7 +- .../RollingUpgradeVerifyXmlEntity.java | 6 +- geode-cq/build.gradle | 41 +- ...ientStatisticsPublicationSecurityDUnitTest.java | 5 +- .../geode/cache/query/cq/CQDistributedTest.java | 33 +- .../cache/query/cq/dunit/CqDataDUnitTest.java | 6 +- .../query/cq/dunit/CqDataUsingPoolDUnitTest.java | 8 +- .../cache/query/cq/dunit/CqPerfDUnitTest.java | 7 +- .../query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 7 +- .../cache/query/cq/dunit/CqQueryDUnitTest.java | 23 +- .../query/cq/dunit/CqQueryUsingPoolDUnitTest.java | 19 +- .../dunit/CqSecurityAuthorizedUserDUnitTest.java | 10 +- ...SecurityPartitionedAuthorizedUserDUnitTest.java | 6 +- .../dunit/CqSecurityUnauthorizedUserDUnitTest.java | 5 +- .../cache/query/cq/dunit/CqStateDUnitTest.java | 24 +- .../cache/query/cq/dunit/CqTimeTestListener.java | 12 +- .../dunit/PartitionedRegionCqQueryDUnitTest.java | 64 +- .../query/cq/dunit/PrCqUsingPoolDUnitTest.java | 78 +- .../cache/query/dunit/PdxQueryCQDUnitTest.java | 52 +- .../cache/query/dunit/PdxQueryCQTestBase.java | 25 +- .../query/dunit/QueryIndexUpdateRIDUnitTest.java | 4 +- .../cache/query/dunit/QueryMonitorDUnitTest.java | 69 +- .../cache/PRDeltaPropagationDUnitTest.java | 18 +- .../geode/internal/cache/PutAllCSDUnitTest.java | 181 +- .../cache/RemoteCQTransactionDUnitTest.java | 17 +- .../internal/cache/ha/HADispatcherDUnitTest.java | 8 +- .../tier/sockets/ClientToServerDeltaDUnitTest.java | 10 +- .../sockets/DeltaPropagationWithCQDUnitTest.java | 22 +- ...ltaToRegionRelationCQRegistrationDUnitTest.java | 41 +- .../tier/sockets/DurableClientCQDUnitTest.java | 984 +++ .../tier/sockets/DurableClientCrashDUnitTest.java | 76 +- .../sockets/DurableClientHAQueuedDUnitTest.java | 963 +++ .../sockets/DurableClientNetDownDUnitTest.java | 83 +- .../tier/sockets/DurableClientSimpleDUnitTest.java | 2966 +------- .../cache/tier/sockets/DurableClientTestBase.java | 734 ++ .../cache/tier/sockets/DurableClientTestCase.java | 1586 +--- .../management/CacheServerManagementDUnitTest.java | 24 +- .../commands/DescribeClientCommandDUnitTest.java | 5 +- .../commands/DurableClientCommandsDUnitTest.java | 7 +- .../management/internal/pulse/TestCQDUnitTest.java | 4 +- .../internal/pulse/TestClientsDUnitTest.java | 7 +- .../internal/pulse/TestServerDUnitTest.java | 4 +- .../security/CQPDXPostProcessorDUnitTest.java | 5 +- .../ClientCQPostAuthorizationDUnitTest.java | 8 +- .../geode/security/FilterPostAuthorization.java | 20 +- .../geode/security/FilterPreAuthorization.java | 6 +- .../cache/query/internal/cq/ClientCQImpl.java | 103 +- .../query/internal/cq/CqAttributesMutatorImpl.java | 7 +- .../cache/query/internal/cq/CqConflatable.java | 3 +- .../geode/cache/query/internal/cq/CqEventImpl.java | 4 +- .../cache/query/internal/cq/CqListenerImpl.java | 5 +- .../geode/cache/query/internal/cq/CqQueryImpl.java | 32 +- .../cache/query/internal/cq/CqServiceImpl.java | 110 +- .../cache/query/internal/cq/ServerCQImpl.java | 30 +- .../geode/internal/CQDistributedSystemService.java | 2 +- .../cache/tier/sockets/command/CloseCQ.java | 7 +- .../cache/tier/sockets/command/ExecuteCQ.java | 3 +- .../cache/tier/sockets/command/ExecuteCQ61.java | 6 +- .../cache/tier/sockets/command/MonitorCQ.java | 16 +- .../cache/tier/sockets/command/StopCQ.java | 7 +- .../query/internal/cq/CqServiceImplJUnitTest.java | 3 +- geode-cq/src/test/resources/expected-pom.xml | 16 +- .../tier/sockets/ClientServerMiscBCDUnitTest.java | 17 +- .../managing_data_entries.html.md.erb | 22 +- .../using_custom_classes.html.md.erb | 7 + .../running/firewalls_ports.html.md.erb | 2 +- .../implementing_continuous_querying.html.md.erb | 2 - ...ing_durable_client_server_messaging.html.md.erb | 2 +- .../transactions/directed_example.html.md.erb | 33 +- .../system_requirements/host_machine.html.md.erb | 2 +- .../managing/security/implementing_ssl.html.md.erb | 20 +- .../topics/gemfire_properties.html.md.erb | 14 +- .../gfsh/command-pages/create.html.md.erb | 16 +- .../tomcat_installing_the_module.html.md.erb | 1 + geode-dunit/build.gradle | 30 +- .../dunit/rules/tests/MemberStarterRuleTest.java | 22 +- .../test/dunit/tests/BasicDistributedTest.java | 0 .../tests/GetCurrentVmNumDistributedTest.java | 0 .../GetDefaultDiskStoreNameDistributedTest.java | 0 .../GetPidAndIdAfterBounceDistributedTest.java | 0 .../dunit/tests/GetPidAndIdDistributedTest.java | 0 .../tests/GetTestMethodNameDistributedTest.java | 0 .../dunit/tests/GetUniqueNameDistributedTest.java | 0 ...GetPropertiesDisconnectsAllDistributedTest.java | 0 .../geode/test/dunit/tests/VMDistributedTest.java | 0 .../java/batterytest/greplogs/ExpectedStrings.java | 2 + .../java/batterytest/greplogs/LogConsumer.java | 2 +- .../cache/client/internal/LocatorTestBase.java | 2 +- .../cache/query/cq/dunit/CqQueryTestListener.java | 31 +- .../internal/index/IndexTrackingTestHook.java | 0 .../geode/cache30/CacheSerializableRunnable.java | 29 +- .../org/apache/geode/cache30/CacheXmlTestCase.java | 5 +- .../cache30/CertifiableTestCacheListener.java | 10 +- .../apache/geode/cache30/ClientServerTestCase.java | 24 +- .../geode/cache30/MultiVMRegionTestCase.java | 218 +- .../org/apache/geode/cache30/RegionTestCase.java | 99 +- .../apache/geode/cache30/TestCacheCallback.java | 4 +- .../membership/gms/MembershipManagerHelper.java | 9 +- .../gms/membership/GMSJoinLeaveTestHelper.java | 93 + .../geode/internal/cache/execute/data/Order.java | 8 + .../internal/cache/execute/data/Shipment.java | 10 + .../cache/tier/sockets/CacheServerTestUtil.java | 70 +- .../sockets/ClientServerMiscDUnitTestBase.java | 38 +- .../cache/wan/AsyncEventQueueTestBase.java | 42 +- .../org/apache/geode/management/MBeanUtil.java | 16 +- .../apache/geode/management/MXBeanAwaitility.java | 23 +- .../geode/management/ManagementTestBase.java | 10 +- .../ChangeLogLevelCommandDUnitTestBase.java | 120 - .../ChangeLogLevelCommandDistributedTestBase.java | 119 + .../cli/commands/ExportLogsDUnitTestBase.java | 404 - .../commands/ExportLogsDistributedTestBase.java | 399 + .../cli/commands/ExportLogsStatsDUnitTestBase.java | 161 - .../ExportLogsStatsDistributedTestBase.java | 158 + .../commands/FunctionCommandsDUnitTestBase.java | 5 +- .../cli/commands/QueryCommandDUnitTestBase.java | 6 +- .../RegionMembershipMBeanDUnitTestBase.java | 5 +- .../cli/commands/ShowLogCommandDUnitTestBase.java | 167 - .../ShowLogCommandDistributedTestBase.java | 166 + .../cli/commands/ShutdownCommandDUnitTestBase.java | 5 +- .../apache/geode/pdx/JSONFormatVerifyUtility.java | 72 + .../security/ClientAuthorizationTestCase.java | 21 +- .../apache/geode/security/SecurityTestUtils.java | 6 +- .../security/templates/SimpleAccessController.java | 8 +- .../security/templates/SimpleAuthenticator.java | 8 +- .../java/org/apache/geode/test/dunit/Invoke.java | 45 - .../java/org/apache/geode/test/dunit/LocalVM.java | 91 - .../geode/test/dunit/RepeatableRunnable.java | 28 - .../geode/test/dunit/StoppableWaitCriterion.java | 4 +- .../main/java/org/apache/geode/test/dunit/VM.java | 17 - .../java/org/apache/geode/test/dunit/Wait.java | 123 +- .../org/apache/geode/test/dunit/WaitCriterion.java | 19 +- .../dunit/cache/internal/JUnit4CacheTestCase.java | 7 +- .../dunit/internal/JUnit4DistributedTestCase.java | 7 +- .../apache/geode/test/dunit/rules/CacheRule.java | 2 +- .../geode/test/dunit/rules/ClusterStartupRule.java | 16 +- .../apache/geode/test/dunit/rules/MemberVM.java | 43 +- .../test/dunit/rules/SerializableFunction.java | 21 + .../geode/test/dunit/standalone/DUnitLauncher.java | 5 +- .../geode/test/dunit/standalone/ProcessHolder.java | 56 + .../test/dunit/standalone/ProcessManager.java | 48 +- .../geode/test/junit/rules/LocatorStarterRule.java | 6 +- .../junit/rules/MBeanServerConnectionRule.java | 5 +- .../geode/test/junit/rules/MemberStarterRule.java | 75 +- .../geode/test/junit/rules/ServerStarterRule.java | 14 +- .../apache/geode/test/junit/rules/VMProvider.java | 21 +- .../geode/cache/client/internal/default.keystore | Bin 0 -> 534 bytes geode-dunit/src/test/resources/expected-pom.xml | 14 +- geode-experimental-driver/build.gradle | 36 +- .../apache/geode/experimental/driver/SSLTest.java | 31 +- .../geode/experimental/driver/default.keystore | Bin 0 -> 534 bytes .../experimental/driver/ProtobufQueryService.java | 1 + .../src/test/resources/expected-pom.xml | 6 +- geode-json/src/test/resources/expected-pom.xml | 2 +- geode-junit/build.gradle | 31 +- .../rules/ExecutorServiceRuleIntegrationTest.java | 4 +- .../java/org/apache/geode/ExpirationDetector.java | 4 +- .../java/org/apache/geode/TXWriterTestCase.java | 0 .../admin/internal/HealthEvaluatorTestCase.java | 0 .../geode/cache/query/MultithreadedTester.java | 0 .../org/apache/geode/cache/query/data/Numbers.java | 2 +- .../apache/geode/cache/query/data/Portfolio.java | 10 +- .../geode/cache/query/data/PortfolioNoDS.java | 11 +- .../geode/cache/query/data/PortfolioPdx.java | 14 +- .../apache/geode/cache/query/data/PositionPdx.java | 6 +- .../org/apache/geode/cache/query/data/Quote.java | 2 +- .../apache/geode/cache/query/data/Restricted.java | 2 +- .../geode/cache/snapshot/SnapshotTestCase.java | 0 .../AnalyzeSerializablesJUnitTestBase.java | 12 +- .../geode/internal/cache/MockCacheService.java | 0 .../geode/internal/cache/MockCacheServiceImpl.java | 0 .../org/apache/geode/internal/cache/TestUtils.java | 0 .../internal/cache/eviction/LRUTestEntry.java | 0 .../cache/eviction/TestEvictionController.java | 0 .../cache/ha/TestBlockingHARegionQueue.java | 0 ...ilGatewaySenderFlushedCoordinatorJUnitTest.java | 0 .../jta/CacheJTAPooledDataSourceFactory.java | 69 + .../logging/LogServiceIntegrationTestSupport.java | 0 .../internal/logging/TestLogWriterFactory.java | 19 +- .../geode/internal/net/DummySocketCreator.java | 0 .../internal/offheap/NullOffHeapMemoryStats.java | 0 .../offheap/NullOutOfOffHeapMemoryListener.java | 0 ...AbstractProcessStreamReaderIntegrationTest.java | 306 + .../geode/internal/process/io/EmptyFileWriter.java | 0 .../geode/internal/process/lang/AvailablePid.java | 0 .../internal/statistics/StatSamplerTestCase.java | 0 .../geode/internal/statistics/StatUtils.java | 0 .../internal/statistics/TestStatArchiveWriter.java | 0 .../internal/statistics/TestStatisticsManager.java | 0 .../internal/statistics/TestStatisticsSampler.java | 0 .../internal/util/concurrent/cm/LoopHelpers.java | 0 .../management/bean/stats/MBeanStatsTestCase.java | 0 .../internal/beans/TestEventListener.java | 0 .../internal/cli/commands/TestCacheLoader.java | 0 .../internal/cli/commands/TestCacheWriter.java | 0 .../internal/cli/commands/TestCompressor.java | 0 .../internal/cli/commands/TestObjectSizer.java | 0 .../cli/commands/TestObjectSizerNotDeclarable.java | 0 .../cli/commands/TestPartitionResolver.java | 0 .../apache/geode/management/model/EmptyObject.java | 0 .../org/apache/geode/management/model/Item.java | 0 .../org/apache/geode/management/model/Order.java | 0 .../apache/geode/management/model/SubOrder.java | 25 + .../geode/test/awaitility/GeodeAwaitility.java | 105 + .../test/concurrent/FileBasedCountDownLatch.java | 6 +- .../test/dunit/standalone/VersionManager.java | 14 +- .../geode/test/golden/ExecutableProcess.java | 0 .../geode/test/golden/FailOutputTestCase.java | 0 .../golden/FailWithProblemInOutputTestCase.java | 0 .../apache/geode/test/golden/GoldenComparator.java | 0 .../geode/test/golden/GoldenStringComparator.java | 0 .../apache/geode/test/golden/GoldenTestCase.java | 0 .../golden/PassWithExpectedProblemTestCase.java | 84 + .../geode/test/golden/RegexGoldenComparator.java | 0 .../geode/test/golden/StringGoldenComparator.java | 0 .../geode/test/junit/categories/FlakyTest.java | 21 - .../geode/test/junit/rules/ConcurrencyRule.java | 74 +- .../test/junit/rules/gfsh/DebuggableCommand.java | 30 + .../geode/test/junit/rules/gfsh/GfshExecution.java | 59 + .../geode/test/junit/rules/gfsh/GfshRule.java | 96 +- .../geode/test/junit/rules/gfsh/GfshScript.java | 141 +- .../junit/rules/gfsh/internal/ProcessLogger.java | 39 +- .../geode/test/matchers/JsonEquivalence.java | 84 + .../apache/geode/test/process/MainLauncher.java | 0 .../apache/geode/test/process/OutputFormatter.java | 0 .../geode/test/process/ProcessOutputReader.java | 0 .../geode/test/process/ProcessStreamReader.java | 0 .../apache/geode/test/process/ProcessWrapper.java | 565 ++ .../org/apache/geode/test/util/ResourceUtils.java | 87 + .../java/org/apache/geode/util/JSR166TestCase.java | 0 .../org.apache.geode.internal.cache.CacheService | 0 .../geode/test/awaitility/GeodeAwaitilityTest.java | 87 + .../test/junit/rules/ConcurrencyRuleTest.java | 162 +- .../test/junit/rules/ExecutorServiceRuleTest.java | 11 +- .../test/util/ResourceUtilsIntegrationTest.java | 58 + .../apache/geode/test/util/ResourceUtilsTest.java | 67 + geode-junit/src/test/resources/expected-pom.xml | 16 +- .../geode/test/util/ResourceUtilsTest_resource.txt | 17 + geode-lucene/build.gradle | 68 +- geode-lucene/geode-lucene-test/build.gradle | 10 +- .../geode/cache/lucene/EvictionDUnitTest.java | 5 +- .../geode/cache/lucene/ExpirationDUnitTest.java | 6 +- .../cache/lucene/LuceneIndexCreationDUnitTest.java | 6 +- .../cache/lucene/LuceneIndexDestroyDUnitTest.java | 12 +- .../geode/cache/lucene/LuceneQueriesDUnitTest.java | 5 +- .../lucene/LuceneQueriesReindexDUnitTest.java | 6 +- .../lucene/RebalanceWithRedundancyDUnitTest.java | 7 +- ...ncyWithRegionCreatedBeforeReindexDUnitTest.java | 5 +- .../cli/DestroyLuceneIndexCommandsDUnitTest.java | 9 +- .../management/LuceneManagementDUnitTest.java | 5 +- ...eneIndexCreationPersistenceIntegrationTest.java | 5 +- .../LuceneIndexMaintenanceIntegrationTest.java | 6 +- .../cli/LuceneIndexCommandsIntegrationTest.java | 17 +- .../cache/lucene/LuceneIndexExistsException.java | 5 +- .../CreateLuceneCommandParametersValidator.java | 5 +- .../lucene/internal/DestroyLuceneIndexMessage.java | 5 +- .../LuceneFileRegionColocationListener.java | 5 +- .../internal/LuceneIndexCreationProfile.java | 45 +- .../internal/LuceneIndexForPartitionedRegion.java | 5 +- .../cache/lucene/internal/LuceneIndexImpl.java | 3 +- .../lucene/internal/LuceneRegionListener.java | 5 +- .../cache/lucene/internal/LuceneServiceImpl.java | 44 +- .../cache/lucene/internal/StringQueryProvider.java | 5 +- .../internal/distributed/LuceneQueryFunction.java | 7 +- .../lucene/internal/xml/LuceneIndexCreation.java | 5 +- .../cache/lucene/internal/xml/LuceneXmlParser.java | 7 +- .../internal/LuceneDistributedSystemService.java | 2 +- .../PartitionedRepositoryManagerJUnitTest.java | 20 +- .../internal/cli/LuceneIndexCommandsJUnitTest.java | 235 +- .../internal/distributed/TopEntriesJUnitTest.java | 60 +- geode-lucene/src/test/resources/expected-pom.xml | 63 +- .../LuceneSearchWithRollingUpgradeDUnit.java | 4 +- ...ultAfterTwoLocatorsWithTwoServersAreRolled.java | 8 +- ...tResultsAfterClientAndServersAreRolledOver.java | 6 +- ...ntAndServersAreRolledOverAllBucketsCreated.java | 6 +- ...ccessfulWhenAllServersRollToCurrentVersion.java | 6 +- geode-old-client-support/build.gradle | 3 +- .../src/test/resources/expected-pom.xml | 4 +- geode-old-versions/build.gradle | 1 + geode-protobuf-messages/build.gradle | 6 +- .../src/test/resources/expected-pom.xml | 2 +- geode-protobuf/build.gradle | 41 +- geode-protobuf/geode-protobuf-test/build.gradle | 11 +- .../v1/acceptance/LocatorConnectionDUnitTest.java | 5 +- .../protobuf/v1/AuthenticationIntegrationTest.java | 7 +- .../protobuf/v1/AuthorizationIntegrationTest.java | 5 +- .../v1/DisconnectClientIntegrationTest.java | 5 +- .../v1/ExecuteFunctionOnGroupIntegrationTest.java | 7 +- .../v1/ExecuteFunctionOnMemberIntegrationTest.java | 7 +- .../v1/ExecuteFunctionOnRegionIntegrationTest.java | 7 +- .../v1/ProtocolVersionIntegrationTest.java | 9 +- .../v1/ValueSerializerIntegrationTest.java | 5 +- .../v1/acceptance/CacheConnectionJUnitTest.java | 16 +- .../CacheConnectionTimeoutJUnitTest.java | 5 +- .../v1/acceptance/CacheMaxConnectionJUnitTest.java | 13 +- .../v1/acceptance/CacheOperationsJUnitTest.java | 5 +- .../PutIfAbsentRequestIntegrationTest.java | 5 +- .../protobuf/v1/acceptance/default.keystore | Bin 1115 -> 534 bytes .../security/SecureFunctionServiceImpl.java | 16 +- .../security/SecureFunctionServiceImplTest.java | 6 +- geode-protobuf/src/test/resources/expected-pom.xml | 28 +- geode-pulse/build.gradle | 76 +- geode-pulse/geode-pulse-test/build.gradle | 15 +- .../org/apache/geode/tools/pulse/tests/Server.java | 6 +- .../geode/tools/pulse/tests/rules/ServerRule.java | 7 +- .../controllers/PulseControllerJUnitTest.java | 2 +- .../geode/tools/pulse/internal/data/Cluster.java | 20 +- .../tools/pulse/internal/data/JMXDataUpdater.java | 2 +- .../pulse/internal/security/LogoutHandlerTest.java | 111 + .../internal/security/LogoutHandlerUnitTest.java | 102 - geode-pulse/src/test/resources/expected-pom.xml | 2 +- geode-rebalancer/build.gradle | 21 +- .../util/AutoBalancerIntegrationJUnitTest.java | 5 +- .../geode/cache/util/AutoBalancerJUnitTest.java | 539 +- .../src/test/resources/expected-pom.xml | 20 +- geode-wan/build.gradle | 20 +- .../internal/cache/UpdateVersionDUnitTest.java | 13 +- ...ueueOverflowMBeanAttributesDistributedTest.java | 7 +- .../cache/wan/CacheClientNotifierDUnitTest.java | 14 +- .../GatewayLegacyAuthenticationRegressionTest.java | 11 +- .../cache/wan/GatewayReceiverMBeanDUnitTest.java | 5 +- ...nderOverflowMBeanAttributesDistributedTest.java | 7 +- .../cache/wan/Simple2CacheServerDUnitTest.java | 9 +- .../geode/internal/cache/wan/WANTestBase.java | 115 +- .../ConcurrentParallelGatewaySenderDUnitTest.java | 79 +- ...ParallelGatewaySenderOperation_2_DUnitTest.java | 28 +- .../misc/CommonParallelGatewaySenderDUnitTest.java | 7 +- .../KeepEventsOnGatewaySenderQueueDUnitTest.java | 4 +- .../wan/misc/NewWanAuthenticationDUnitTest.java | 11 +- .../cache/wan/misc/PDXNewWanDUnitTest.java | 10 +- ...hutdownAllPersistentGatewaySenderDUnitTest.java | 10 +- .../internal/cache/wan/misc/WANSSLDUnitTest.java | 12 +- .../cache/wan/misc/WanValidationsDUnitTest.java | 6 +- .../ParallelGatewaySenderOperationsDUnitTest.java | 4 +- ...arallelGatewaySenderQueueOverflowDUnitTest.java | 5 +- .../parallel/ParallelWANConflationDUnitTest.java | 5 +- .../wan/parallel/ParallelWANStatsDUnitTest.java | 7 +- .../SerialGatewaySenderEventListenerDUnitTest.java | 9 +- .../cache/wan/serial/SerialWANStatsDUnitTest.java | 5 +- .../WANHostNameVerificationDistributedTest.java | 9 +- ...CreateDestroyGatewaySenderCommandDUnitTest.java | 31 +- .../CreateGatewayReceiverCommandDUnitTest.java | 3 +- .../DestroyGatewaySenderCommandDUnitTest.java | 8 +- .../wancommand/ListGatewaysCommandDUnitTest.java | 6 +- .../PauseGatewaySenderCommandDUnitTest.java | 35 +- .../ResumeGatewaySenderCommandDUnitTest.java | 35 +- .../StartGatewayReceiverCommandDUnitTest.java | 36 +- .../StartGatewaySenderCommandDUnitTest.java | 52 +- .../StatusGatewayReceiverCommandDUnitTest.java | 70 +- .../StatusGatewaySenderCommandDUnitTest.java | 93 +- .../StopGatewayReceiverCommandDUnitTest.java | 35 +- .../StopGatewaySenderCommandDUnitTest.java | 36 +- .../cache/wan/wancommand/WANCommandUtils.java | 12 +- .../geode/management/WANManagementDUnitTest.java | 6 +- .../WANClusterConfigurationDUnitTest.java | 5 +- .../cache/wan/misc/WANConfigurationJUnitTest.java | 20 +- .../client/internal/GatewaySenderBatchOp.java | 5 +- .../internal/locator/wan/LocatorDiscovery.java | 46 +- .../locator/wan/LocatorMembershipListenerImpl.java | 14 +- .../locator/wan/WanLocatorDiscovererImpl.java | 17 +- .../internal/WANDistributedSystemService.java | 2 +- .../cache/wan/AbstractRemoteGatewaySender.java | 44 +- .../cache/wan/GatewayReceiverFactoryImpl.java | 4 +- .../internal/cache/wan/GatewayReceiverImpl.java | 90 +- .../wan/GatewaySenderEventRemoteDispatcher.java | 105 +- .../cache/wan/GatewaySenderFactoryImpl.java | 44 +- .../wan/parallel/ParallelGatewaySenderImpl.java | 13 +- .../cache/wan/serial/SerialGatewaySenderImpl.java | 15 +- .../cache/wan/GatewayReceiverImplJUnitTest.java | 69 + ...SenderEventRemoteDispatcherIntegrationTest.java | 189 + geode-wan/src/test/resources/expected-pom.xml | 2 +- ...ateGatewaySenderMixedSiteOneCurrentSiteTwo.java | 6 +- .../cache/wan/WANRollingUpgradeDUnitTest.java | 5 +- ...eEventProcessingMixedSiteOneCurrentSiteTwo.java | 6 +- ...gradeEventProcessingMixedSiteOneOldSiteTwo.java | 15 +- ...adeEventProcessingOldSiteOneCurrentSiteTwo.java | 6 +- ...ipleReceiversDefinedInClusterConfiguration.java | 5 +- ...tReprocessedAfterCurrentSiteMemberFailover.java | 6 +- ...fterCurrentSiteMemberFailoverWithOldClient.java | 6 +- ...tsNotReprocessedAfterOldSiteMemberFailover.java | 6 +- ...eCacheServerProfileToMembersOlderThan1dot5.java | 6 +- ...ANRollingUpgradeVerifyGatewaySenderProfile.java | 6 +- geode-web-api/build.gradle | 51 +- .../web/controllers/AddFreeItemToOrders.java | 147 + .../rest/internal/web/controllers/Customer.java | 124 + .../geode/rest/internal/web/controllers/Item.java | 158 + .../web/controllers/NoArgumentFunction.java | 119 + .../geode/rest/internal/web/controllers/Order.java | 186 + .../web/controllers/RestAccessControllerTest.java | 927 +++ .../web/controllers/customer-list-no-type.json | 302 + .../internal/web/controllers/customer-list.json | 332 + .../rest/internal/web/controllers/malformed.json | 3 + .../internal/web/controllers/order-cas-new.json | 35 + .../internal/web/controllers/order-cas-old.json | 28 + .../web/controllers/order-cas-wrong-old.json | 65 + .../rest/internal/web/controllers/order-cas.json | 65 + .../internal/web/controllers/order1-no-type.json | 27 + .../rest/internal/web/controllers/order1.json | 28 + .../internal/web/controllers/order2-updated.json | 28 + .../rest/internal/web/controllers/order2.json | 28 + .../web/controllers/AbstractBaseController.java | 9 +- .../web/controllers/CommonCrudController.java | 3 +- .../web/controllers/FunctionAccessController.java | 17 +- .../web/controllers/QueryAccessController.java | 6 +- .../internal/web/swagger/config/SwaggerConfig.java | 15 +- geode-web-api/src/test/resources/expected-pom.xml | 2 +- geode-web/build.gradle | 39 +- .../cli/commands/AlterRuntimeCommandDUnitTest.java | 14 +- .../ChangeLogLevelCommandOverHttpDUnitTest.java | 24 - ...angeLogLevelCommandOverHttpDistributedTest.java | 32 + .../cli/commands/ConnectCommandWithSSLTest.java | 132 +- .../ExportLogsOverHttpDistributedTest.java | 10 +- .../commands/ExportLogsStatsOverHttpDUnitTest.java | 72 - .../ExportLogsStatsOverHttpDistributedTest.java | 73 + .../commands/ShowLogComandOverHttpDUnitTest.java | 31 - .../ShowLogCommandOverHttpDistributedTest.java | 35 + .../internal/cli/commands/CommandOverHttpTest.java | 2 +- .../security/LogNoPasswordIntegrationTest.java | 91 + .../internal/security/LogNoPasswordTest.java | 85 - .../support/LoginHandlerInterceptorJUnitTest.java | 311 - ...inHandlerInterceptorRequestHeaderJUnitTest.java | 71 - .../LoginHandlerInterceptorRequestHeaderTest.java | 73 + .../support/LoginHandlerInterceptorTest.java | 270 + ...lizableObjectHttpMessageConverterJUnitTest.java | 137 +- geode-web/src/test/resources/expected-pom.xml | 2 +- gradle.properties | 21 +- gradle/dependency-versions.properties | 17 +- gradle/docker.gradle | 42 +- gradle/java.gradle | 5 + gradle/publish.gradle | 200 +- gradle/rat.gradle | 3 + gradle/resolve-dependencies.gradle | 35 + gradle/spotless.gradle | 57 +- gradle/test-by-category.gradle | 15 - gradle/test.gradle | 185 +- gradle/utilities.gradle | 49 +- gradle/wrapper/gradle-wrapper.jar | Bin 56172 -> 56177 bytes gradle/wrapper/gradle-wrapper.properties | 2 +- settings.gradle | 1 + 2210 files changed, 66468 insertions(+), 73204 deletions(-)
