This is an automated email from the ASF dual-hosted git repository. zhouxj pushed a change to branch feature/GEM-883 in repository https://gitbox.apache.org/repos/asf/geode.git.
omit 33b01b7 GEODE-3967: if put hits concurrent modification exception should still notify serial gateway sender GEODE-3967: notifyTimestampsToGateways should inherit isConcurrencyConflict GEODE-3967: add to secondary event isConcurrencyConflict add faa0e54 GEODE-4099: change warning to debug add ea7c6ef Merge pull request #1168 from dschneider-pivotal/feature/GEODE-4099 add 6c49506 GEODE-3799: Move backups towards a pluggable architecture (#1109) add 2b6e375 GEODE-2296: Internal message SIZE should not have authorization checks (#1169) add f76eeae GEODE-3539: add tests for ExportStackTraceCommand (#1162) add 73e7f48 GEODE-4103: Set forkEvery=1 for distributedTest (#1170) add eff77bb GEODE-3923 Document the 2 new properties serializable-object-filter (#1166) add 9ca4314 GEODE-4084 rename handshake.proto (#1155) add 43b8cd5 GEODE-4047 User Guide: Update Lucene docs to include nested objects (#1164) add 6190edc GEODE-4047 User Guide: Update Lucene docs to include nested objects, reviewer’s correction add 59b949e GEODE-4079: Deprecated Hash Index add 19b8199 GEODE-4090: Add ErrorCode mirroring ProtocolErrorCode enum into protobuf add 2ab745e GEODE-4109: add log message add 8baedce Merge pull request #1174 from dschneider-pivotal/feature/GEODE-4109 add 1b29986 GEODE-4111: Add log message for cache service initialization add 15402eb GEODE-4106: Fix relative path destinations for backups (#1173) add fdcdbc0 Feature/GEODE-4061 : Adding coordinator in list member command output (#1138) add 8d86830 GEODE-4088: add a dunit test to show the client region keySet() in TX (#1159) add 2f59663 GEODE-4054: Create module for Protobuf message-based client add b16f984 GEODE-4093: new protocol needs to work on an embedded locator add afd72b0 GEODE-4079 Identify hash indexes as deprecated in docs (#1180) add 56bd06d Feature/geode 3781: JDBC Connector (#1176) add f0c038c GEODE-4054: Fixing integration test failure with experimental client add c25e43d GEODE-4061: Updated DUnit test for changes in list member command (#1184) add e363d20 [GEODE-4123] - Improve output email of concourse.apachegeodeci.info add 9f747ef Merge pull request #1190 from onichols-pivotal/feature/GEODE-4123 add 9ad4649 GEODE-4127: Removed HAInterestDistributedTestCase add b75bbf9 GEODE-4117: use loopback instead of non-existent server host (#1181) add ca62b21 GEODE-4110: extend LocatorServerStartupRule to start a client VM. (#1175) add 635ab6a GEODE-3788 alter async event queue attributes (document this feature) (#1191) add e24e038 GEODE-4080: Protobuf JSON objects are in a proto string (#1171) add 3e6b9a9 GEODE-4124: Correct help message in gfsh 'create region' command add ed6bac5 GEODE-551: make sure accessor gets critical by putting into its local region (#1183) add 0833068 [GEODE-4123] - Improve output email of concourse.apachegeodeci.info add bdbea62 Merge pull request #1198 from onichols-pivotal/feature/GEODE-4123 add eec297f GEODE-4112: Replaced FunctionAdapter with Function add a7a883e GEODE-4137 CacheServerSSLConnectionDUnitTest fails with NoAvailableServersException add 42974bf GEODE-4114: Removed usage of GemFireCacheImpl.getInstance in geode-lucene add 20f0d99 GEODE-4077: Replaced WaitCriterion and Thread.sleep() with Awaitility.await(). add d4183f6 GEODE-2665: Add Gfsh command to delete async event queues (#1116) add 0ca3c8c GEODE-4134: use ExecutorService for CompletableFuture (#1195) add 26b00fc GEODE-4133: synchronize `ClientHealthMonitor.getClientHeartbeats` (#1194) add 09026a6 GEODE-2665: Document Gfsh command to delete async event queues (#1200) add 61ba3b6 GEODE-4030, GEODE-3495: Bump dependencies to new versions add 7baa22e User Guide: typo corrections in Event Handlers list add 778d240 GEODE-4159: Increase default timeout for GfshScript rule to 2 minutes add 507c419 GEODE-4154: Removed GemFireCacheImpl.getInstance add cbbf639 GEODE-4145: Clean up protobuf error codes. add 04f1419 GEODE-4087 modify SocketCreator to not set the default SSLContext for the JVM add 8a1ec2d GEODE-4132: Sending handshake response from locator for new protocol add 3be095a GEODE-4163 clean up DistributionManager code add cf81ebc GEODE-4110: rename LocatorServerStartupRule to ClusterStartupRule (#1205) add b22a088 GEODE-3764 Documented fix for "idle expiration will happen even if the entry has been accessed on a replicate" (#1207) add e2cdaa7 GEODE-4163 clean up DistributionManager code add 589edae GEODE-4175 User Guide: gfsh doc example for creating a hash index does not include --type=hash option add c4e1975 GEODE-4097 allow to take geode-core jar from classpath (#1167) add b100f08 GEODE-4097: Adding a test for this change (#1211) add 78f503f GEODE-4170: Index docs are easier to locate (#1208) add d0a6394 GEODE-4168 Can't get json object stored as PDX using the new protocol GEODE-4116 Can't get PDX objects using the new protocol add cadecc246 GEODE-4092 New protocol does not have an API to get the best server to connect to add 0f8cd8e GEODE-4122: Add runner annotation to avoid skipping tests with Parameterized add 2e3c6b9 GEODE-4008: Added serialVersionUID to FunctionAdapter (#1119) add c537f55 GEODE-4146: fix XmlEntity matching for JdbcConnectorService (#1215) add cdd98b2 GEODE-4176 locator creates "locator0view.dat" file when started with port 0 add cdde35a GEODE-4178 ClientServerMiscDUnitTest.testOnSeverMethodsWithCachingProxyClientHA failure add 4c298b2 GEODE-4185: Add job to update file in GCS with SHA that passed all tests add cf4959f GEODE-3861 ClientHealthMonitorSelectorJUnitTest.testDeadClientRemovalByServer failed add 7a4c347 GEODE-4113 Enhance experimental Java driver to support putting and getting objects add 07713e5 GEODE-4009: add jdbc connection pooling (#1213) add 19d47fc GEODE-4191: Replace imports of io.codearte..Mockito with org.mockito.Mockito add 57baff1 GEODE-4193: fix password file security in JMX (#1227) add 86ddafa GEODE-4131: Do not reference deployed jars as byte arrays anymore (#1212) add 6c37ff4 GEODE-4096: Fixed race condition for connection global variable add 75062b6 GEODE-4144: EventId in client does not match that of server (with putAll) add d6055a7 GEODE-4165: Listener EventId in server does not match that of the client for clearRegion add 03af545 GEODE-4161: fix gfsh describe jdbc-mapping add bc976fd Merge pull request #1225 from dschneider-pivotal/feature/GEODE-4161 add db99985 rev the version number since a release branch has been created for 1.4.0 add 2249d60 GEODE-4184: Handled concurrent access of HashSet add 12307b8 GEODE-4177: client does not receive all put all creates when servers close cache add bb9ae49 GEODE-4229 CI failure due to suspect string: "Locator socket was closed unexpectedly" add 2d4cd26 GEODE-4135: Awaitility condition added add 636cb7d Fix script so passing.txt is branch-dependent. add 78438f8 GEODE-4131: add the deprecated API in MemberMXBean (#1231) add 92ced79 GEODE-4160: fix gfsh describe jdbc-connection (#1223) add 7e42f33 GEODE-4221: Restore the ability to access the debugging VM. (#1234) add 193bb07 GEODE-4158: Correct the detection of Geode-internal classes for serialization. - Remove consideration of any class under org.apache as a Geode-internal class that resulted from a search-and-replace. add 75c0413 GEODE-3965: rename DistributionManager classes add 1788b5f GEODE-3965: define exceptionInThreads methods in DistributionManager add 1f4c907 GEODE-3965: rename and cleanup DistributionManager tests add a675572 GEODE-4192 GetServer request should return error if no servers found add 5c6c297 GEODE-4231: Renamed FunctionAdapter test resource file to have .ser extension add 1954a35 GEODE-4247: Pre-populate email subject and body files add ad74d98 GEODE-4148 Locator threshold before rebalancing clients add 977e16b GEODE-4131: reduce flakiness of the added acceptance test (#1247) add 83edc8d GEODE-4230: fixed the heap example add 61077fb GEODE-4051: change StateMarkerMessage to always reply add f905ea2 Merge pull request #1239 from dschneider-pivotal/feature/GEODE-4051 add 55adfec changed DistributionManager to ClusterDistributionManager in unit test add 22a443b GEODE-4172: CI Failure:CqPerfUsingPoolDUnitTest.testMatchingCQsWithMultipleServers (#1222) add 2505155 GEODE-4016: Create benchmarks for eviction (#1240) add ff008e3 GEODE-3539: fix test category (#1253) add 3cf7caa Squashed commit of the following: add 6eece22 GEODE-4237: The JdbcLoader creates PdxInstance using region mapping (column to field). add 8998a8f [GEODE-4265] Add dunit progress tool to docker image. add 15ae789 [GEODE-4265] Use updated version that has been appropriately licensed. add 90f8f62 GEODE-3974: Improve permissions for geode-modules functions (#1258) add 7d7e1da GEODE-4225: Extend ClusterStartupRule to specify member / client version. add 48d93ed GEODE-3539: rule cleanup (#1242) add 3bc3b51 GEODE-4241: Write region mapping to cluster configuration add fbad978 [GEODE-4274] Add TestExamples job. (#1267) add 39d9c2c GEODE-4225: getVM(n) call does not accidentally bounce the VM with current version. (#1266) add c1c7e51 GEODE-3946: add version check when connect to cluster using gfsh (#1259) add b54189b GEODE-4236: Increase default timeout for await methods (#1268) add 66007d6 Add tag to DistributedTest so it runs on a different worker class. add da3384d GEODE-4232: Switch to minuscule initial letter for Javadoc deprecated tag. add a4329ad GEODE-4255: Remove mandatory failure on macOS. add 8c5aceb GEODE-4180 always use absolute paths add 740289c GEODE-3974: Improve permissions for geode-lucene functions add 49d28f9 GEODE-3974: Improve permissions for geode-connectors functions (#1265) add 2ba05e0 GEODE-4246: Skip setting the mcast-port property. add 4e065c4 GEODE-4239: refactor tests to use new ExecutorServiceRule (#1244) add 5c1d8ef GEODE-4101: Add --redirect-output flag to GFSH (#1203) add ec33108 GEODE-4268: Delete geode-benchmarks and move benchmarks to geode-core (#1263) new 5fa6ca5 GEODE-3967: if put hits concurrent modification exception should still notify serial gateway sender GEODE-3967: notifyTimestampsToGateways should inherit isConcurrencyConflict GEODE-3967: add to secondary event isConcurrencyConflict This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (33b01b7) \ N -- N -- N refs/heads/feature/GEM-883 (5fa6ca5) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../geode/gradle/TestPropertiesWriter.groovy | 1 - ci/docker/Dockerfile | 4 + ci/pipelines/develop.yml | 67 +- ci/scripts/build-examples.sh | 26 + ci/scripts/test-archive.sh | 2 +- ci/scripts/test-run.sh | 8 +- ci/scripts/update-passing-ref.sh | 28 + .../SessionReplicationIntegrationJUnitTest.java | 688 +-- .../session/junit/PerTestClassLoaderRunner.java | 25 +- extensions/geode-modules/build.gradle | 2 +- .../geode/modules/util/BootstrappingFunction.java | 14 +- .../geode/modules/util/CreateRegionFunction.java | 13 +- .../geode/modules/util/RegionSizeFunction.java | 9 + .../TouchPartitionedRegionEntriesFunction.java | 9 + .../util/TouchReplicatedRegionEntriesFunction.java | 9 + .../modules/util/ModuleFunctionsSecurityTest.java | 91 + geode-assembly/build.gradle | 12 +- geode-assembly/src/main/dist/NOTICE | 4 +- .../cli/commands/DeployWithLargeJarTest.java | 47 + .../cli/commands/StartLocatorCommandTest.java | 111 + .../cli/commands/StartServerCommandTest.java | 99 + .../controllers/RestAPIsAndInterOpsDUnitTest.java | 2 +- .../web/controllers/RestAPIsWithSSLDUnitTest.java | 47 +- .../session/tests/GenericAppServerInstall.java | 6 +- .../session/tests/TomcatClientServerTest.java | 4 +- .../geode/test/junit/rules/HttpClientRule.java | 52 +- .../geode/tools/pulse/PulseConnectivityTest.java | 4 +- .../tools/pulse/PulseSecurityWithSSLTest.java | 4 +- .../src/test/resources/expected_jars.txt | 16 +- geode-benchmarks/build.gradle | 28 - .../benchmark/RangeQueryWithIndexBenchmark.java | 105 - .../cache/benchmark/RegionOperationBenchmark.java | 63 - .../source/subnavs/geode-subnav.erb | 93 +- .../protocol/LocatorMessageExecutionContext.java | 61 + .../internal/protocol/MessageExecutionContext.java | 55 +- .../geode/internal/protocol/OperationContext.java | 9 +- .../geode/internal/protocol/ProtocolErrorCode.java | 28 +- .../internal/protocol/ProtocolSerializer.java | 34 + .../protocol/ServerMessageExecutionContext.java | 60 + .../protocol/operations/OperationHandler.java | 11 +- .../protobuf/v1/serializer/ProtocolSerializer.java | 34 - .../protocol/serialization/JsonPdxConverter.java | 49 + .../serialization/SerializationService.java | 9 +- .../internal/protocol/serialization/TypeCodec.java | 36 - .../protocol/serialization/TypeConverter.java | 37 + .../protocol/serialization/codec/JSONCodec.java | 39 - .../serialization/exception/EncodingException.java | 31 + .../UnsupportedEncodingTypeException.java | 31 - .../registry/SerializationCodecRegistry.java | 67 - .../CodecAlreadyRegisteredForTypeException.java | 28 - .../CodecNotRegisteredForTypeException.java | 27 - .../protocol/state/ConnectionStateProcessor.java | 4 +- .../state/ConnectionTerminatingStateProcessor.java | 2 +- .../LegacySecurityConnectionStateProcessor.java | 4 +- ...geode.internal.protocol.serialization.TypeCodec | 1 - geode-connectors/build.gradle | 33 + .../geode/connectors/jdbc/JdbcAsyncWriter.java | 117 + .../apache/geode/connectors/jdbc/JdbcLoader.java | 54 + .../apache/geode/connectors/jdbc/JdbcWriter.java | 102 + .../jdbc/internal/AbstractJdbcCallback.java | 65 + .../connectors/jdbc/internal/ColumnValue.java | 44 + .../jdbc/internal/ConnectionConfigBuilder.java | 82 + .../internal/ConnectionConfigExistsException.java | 33 + .../ConnectionConfigNotFoundException.java | 34 + .../jdbc/internal/ConnectionConfiguration.java | 110 + .../jdbc/internal/DataSourceManager.java | 46 + .../jdbc/internal/HikariJdbcDataSource.java | 45 + .../jdbc/internal/HikariJdbcDataSourceFactory.java | 21 + .../jdbc/internal/JdbcConnectorService.java | 49 + .../jdbc/internal/JdbcConnectorServiceImpl.java | 159 + .../connectors/jdbc/internal/JdbcDataSource.java | 22 + .../jdbc/internal/JdbcDataSourceFactory.java | 25 + .../connectors/jdbc/internal/RegionMapping.java | 169 + .../jdbc/internal/RegionMappingBuilder.java | 99 + .../internal/RegionMappingExistsException.java | 33 + .../internal/RegionMappingNotFoundException.java | 33 + .../geode/connectors/jdbc/internal/SqlHandler.java | 286 ++ .../jdbc/internal/SqlStatementFactory.java | 78 + .../jdbc/internal/TableKeyColumnManager.java | 86 + .../jdbc/internal/cli/AlterConnectionCommand.java | 142 + .../jdbc/internal/cli/AlterConnectionFunction.java | 98 + .../jdbc/internal/cli/AlterMappingCommand.java | 151 + .../jdbc/internal/cli/AlterMappingFunction.java | 96 + .../jdbc/internal/cli/CreateConnectionCommand.java | 145 + .../internal/cli/CreateConnectionFunction.java | 66 + .../jdbc/internal/cli/CreateMappingCommand.java | 152 + .../jdbc/internal/cli/CreateMappingFunction.java | 70 + .../internal/cli/DescribeConnectionCommand.java | 113 + .../internal/cli/DescribeConnectionFunction.java | 44 + .../jdbc/internal/cli/DescribeMappingCommand.java | 112 + .../jdbc/internal/cli/DescribeMappingFunction.java | 43 + .../internal/cli/DestroyConnectionCommand.java | 113 + .../internal/cli/DestroyConnectionFunction.java | 89 + .../jdbc/internal/cli/DestroyMappingCommand.java | 110 + .../jdbc/internal/cli/DestroyMappingFunction.java | 89 + .../jdbc/internal/cli/ExceptionHandler.java | 58 + .../cli/FunctionContextArgumentProvider.java | 70 + .../jdbc/internal/cli/JdbcCliFunction.java | 77 + .../jdbc/internal/cli/ListConnectionCommand.java | 107 + .../jdbc/internal/cli/ListConnectionFunction.java | 54 + .../jdbc/internal/cli/ListMappingCommand.java | 106 + .../jdbc/internal/cli/ListMappingFunction.java | 53 + .../connectors/jdbc/internal/xml/ElementType.java | 143 + .../xml/JdbcConnectorServiceXmlGenerator.java | 165 + .../xml/JdbcConnectorServiceXmlParser.java | 59 + .../internal/xml/JdbcServiceConfiguration.java | 79 + .../org.apache.geode.internal.cache.CacheService | 1 + ....apache.geode.internal.cache.xmlcache.XmlParser | 1 + .../org.springframework.shell.core.CommandMarker | 27 + .../geode.apache.org/schema/jdbc/jdbc-1.0.xsd | 86 + .../org/apache/geode/connectors/jdbc/Employee.java | 54 + .../jdbc/JdbcAsyncWriterIntegrationTest.java | 260 ++ .../geode/connectors/jdbc/JdbcAsyncWriterTest.java | 97 + .../geode/connectors/jdbc/JdbcDUnitTest.java | 306 ++ .../connectors/jdbc/JdbcLoaderIntegrationTest.java | 110 + .../geode/connectors/jdbc/JdbcLoaderTest.java | 56 + .../connectors/jdbc/JdbcWriterIntegrationTest.java | 241 + .../geode/connectors/jdbc/JdbcWriterTest.java | 106 + .../jdbc/internal/AbstractJdbcCallbackTest.java | 73 + .../connectors/jdbc/internal/ColumnValueTest.java | 58 + .../jdbc/internal/ConnectionConfigBuilderTest.java | 92 + .../jdbc/internal/ConnectionConfigurationTest.java | 96 + .../jdbc/internal/DataSourceManagerUnitTest.java | 98 + .../jdbc/internal/JdbcConnectorServiceTest.java | 115 + .../jdbc/internal/RegionMappingBuilderTest.java | 115 + .../jdbc/internal/RegionMappingTest.java | 243 + .../connectors/jdbc/internal/SqlHandlerTest.java | 473 ++ .../jdbc/internal/SqlStatementFactoryTest.java | 90 + .../jdbc/internal/TableKeyColumnManagerTest.java | 140 + .../jdbc/internal/TestConfigService.java | 55 + .../jdbc/internal/TestableConnectionManager.java | 22 + .../cli/AlterConnectionCommandDUnitTest.java | 135 + .../cli/AlterConnectionCommandIntegrationTest.java | 80 + .../internal/cli/AlterConnectionFunctionTest.java | 222 + .../internal/cli/AlterMappingCommandDUnitTest.java | 139 + .../cli/AlterMappingCommandIntegrationTest.java | 82 + .../internal/cli/AlterMappingFunctionTest.java | 241 + .../cli/CreateConnectionCommandDUnitTest.java | 92 + .../CreateConnectionCommandIntegrationTest.java | 111 + .../internal/cli/CreateConnectionFunctionTest.java | 136 + .../cli/CreateMappingCommandDUnitTest.java | 117 + .../cli/CreateMappingCommandIntegrationTest.java | 120 + .../internal/cli/CreateMappingFunctionTest.java | 137 + .../cli/DescribeConnectionCommandDUnitTest.java | 109 + .../DescribeConnectionCommandIntegrationTest.java | 149 + .../cli/DescribeConnectionFunctionTest.java | 138 + .../cli/DescribeMappingCommandDUnitTest.java | 117 + .../cli/DescribeMappingCommandIntegrationTest.java | 144 + .../internal/cli/DescribeMappingFunctionTest.java | 138 + .../cli/DestroyConnectionCommandDUnitTest.java | 99 + .../DestroyConnectionCommandIntegrationTest.java | 83 + .../cli/DestroyConnectionFunctionTest.java | 124 + .../cli/DestroyMappingCommandDunitTest.java | 101 + .../cli/DestroyMappingCommandFunctionTest.java | 124 + .../cli/DestroyMappingCommandIntegrationTest.java | 82 + .../cli/FunctionContextArgumentProviderTest.java | 81 + .../cli/JDBCConnectorFunctionsSecurityTest.java | 150 + .../jdbc/internal/cli/JdbcCliFunctionTest.java | 54 + .../cli/JdbcClusterConfigDistributedTest.java | 144 + .../cli/ListConnectionCommandDUnitTest.java | 121 + .../cli/ListConnectionCommandIntegrationTest.java | 109 + .../internal/cli/ListConnectionFunctionTest.java | 167 + .../internal/cli/ListMappingCommandDUnitTest.java | 123 + .../cli/ListMappingCommandIntegrationTest.java | 109 + .../jdbc/internal/cli/ListMappingFunctionTest.java | 166 + .../jdbc/internal/xml/ElementTypeTest.java | 252 + ...onnectorServiceXmlGeneratorIntegrationTest.java | 334 ++ .../xml/JdbcConnectorServiceXmlGeneratorTest.java | 34 + .../JdbcConnectorServiceXmlIntegrationTest.java | 127 + .../xml/JdbcConnectorServiceXmlParserTest.java | 109 + .../internal/xml/JdbcServiceConfigurationTest.java | 137 + geode-core/build.gradle | 10 + .../geode/cache/CreateOnRegionBenchmark.java | 74 + .../CreateWithEvictionUnderLimitBenchmark.java | 86 + .../cache/EvictionBasePerformanceBenchmark.java | 98 + .../EvictionMultiThreadedPerformanceBenchmark.java | 129 + .../EvictionWithPartiallyMarkedListsBenchmark.java | 101 + .../apache/geode/cache/FirstEvictionBenchmark.java | 80 + .../apache/geode/cache/GetOnRegionBenchmark.java | 80 + .../GetsWithEvictionPerformanceBenchmark.java | 92 + .../geode/cache/RangeQueryWithIndexBenchmark.java | 97 + .../geode/cache/RegionOperationBenchmark.java | 52 + .../geode/cache/UpdateOnRegionBenchmark.java | 79 + .../apache/geode/admin/GemFireMemberStatus.java | 4 +- .../admin/internal/AbstractHealthEvaluator.java | 4 +- .../admin/internal/AdminDistributedSystemImpl.java | 35 +- .../geode/admin/internal/CacheHealthEvaluator.java | 8 +- .../geode/admin/internal/CacheServerImpl.java | 7 +- .../internal/DistributedSystemHealthEvaluator.java | 14 +- .../admin/internal/DistributionLocatorImpl.java | 5 +- .../admin/internal/GemFireHealthEvaluator.java | 4 +- .../admin/internal/MemberHealthEvaluator.java | 4 +- .../internal/SystemMemberCacheEventProcessor.java | 4 +- .../apache/geode/admin/jmx/internal/AgentImpl.java | 6 +- .../geode/admin/jmx/internal/AgentLauncher.java | 4 +- .../geode/cache/client/ClientCacheFactory.java | 3 +- .../client/internal/CacheServerLoadMessage.java | 4 +- .../geode/cache/execute/FunctionAdapter.java | 3 + .../org/apache/geode/cache/query/IndexType.java | 4 + .../org/apache/geode/cache/query/QueryService.java | 24 +- .../cache/query/internal/index/HashIndex.java | 5 + .../query/internal/index/PartitionedIndex.java | 3 +- .../geode/distributed/DistributedSystem.java | 6 +- .../java/org/apache/geode/distributed/Locator.java | 9 +- .../apache/geode/distributed/LocatorLauncher.java | 2 +- .../internal/ClusterConfigurationService.java | 141 +- .../internal/ClusterDistributionManager.java | 4577 ++++++++++++++++++ .../internal/CollectingReplyProcessor.java | 2 +- .../org/apache/geode/distributed/internal/DM.java | 490 -- .../distributed/internal/DirectReplyProcessor.java | 23 +- .../distributed/internal/DistributionAdvisee.java | 4 +- .../distributed/internal/DistributionAdvisor.java | 6 +- .../distributed/internal/DistributionChannel.java | 162 - .../distributed/internal/DistributionManager.java | 4841 +------------------- .../distributed/internal/DistributionMessage.java | 28 +- .../internal/DistributionMessageObserver.java | 6 +- .../distributed/internal/HealthMonitorImpl.java | 4 +- .../internal/HighPriorityAckedMessage.java | 6 +- .../internal/HighPriorityDistributionMessage.java | 2 +- .../internal/InternalDistributedSystem.java | 46 +- .../distributed/internal/InternalLocator.java | 127 +- .../distributed/internal/LocatorLoadSnapshot.java | 128 +- .../internal/LonerDistributionManager.java | 27 +- .../distributed/internal/MembershipListener.java | 2 +- .../internal/PooledDistributionMessage.java | 2 +- .../geode/distributed/internal/ProductUseLog.java | 5 +- .../internal/ReliableReplyProcessor21.java | 4 +- .../geode/distributed/internal/ReplyMessage.java | 6 +- .../distributed/internal/ReplyProcessor21.java | 39 +- .../geode/distributed/internal/ReplySender.java | 4 +- .../distributed/internal/SerialAckedMessage.java | 6 +- .../internal/SerialDistributionMessage.java | 2 +- .../geode/distributed/internal/ServerLocator.java | 2 +- .../distributed/internal/ShutdownMessage.java | 2 +- .../geode/distributed/internal/StartupMessage.java | 9 +- .../internal/StartupMessageReplyProcessor.java | 6 +- .../distributed/internal/StartupOperation.java | 4 +- .../internal/StartupResponseMessage.java | 5 +- .../StartupResponseWithVersionMessage.java | 5 +- .../internal/WaitForViewInstallation.java | 6 +- .../distributed/internal/direct/DirectChannel.java | 10 +- .../internal/direct/DirectChannelListener.java | 4 +- .../distributed/internal/locks/DLockGrantor.java | 8 +- .../internal/locks/DLockQueryProcessor.java | 16 +- .../locks/DLockRecoverGrantorProcessor.java | 23 +- .../internal/locks/DLockReleaseProcessor.java | 16 +- .../internal/locks/DLockRequestProcessor.java | 33 +- .../distributed/internal/locks/DLockService.java | 14 +- .../distributed/internal/locks/DLockToken.java | 8 +- .../internal/locks/DeposeGrantorProcessor.java | 14 +- .../internal/locks/DistributedMemberLock.java | 4 +- .../internal/locks/ElderInitProcessor.java | 15 +- .../distributed/internal/locks/ElderState.java | 8 +- .../internal/locks/GrantorRequestProcessor.java | 20 +- .../distributed/internal/locks/LockGrantorId.java | 8 +- .../locks/NonGrantorDestroyedProcessor.java | 20 +- .../membership/DistributedMembershipListener.java | 1 - .../membership/InternalDistributedMember.java | 39 +- .../internal/membership/InternalRole.java | 6 +- .../internal/membership/MemberAttributes.java | 4 +- .../internal/membership/MemberFactory.java | 11 +- .../internal/membership/MemberServices.java | 7 +- .../internal/membership/MembershipManager.java | 12 + .../distributed/internal/membership/NetView.java | 24 +- .../internal/membership/gms/GMSMemberFactory.java | 5 +- .../gms/locator/FindCoordinatorRequest.java | 5 +- .../gms/locator/FindCoordinatorResponse.java | 4 +- .../membership/gms/locator/GMSLocator.java | 24 +- .../membership/gms/membership/GMSJoinLeave.java | 149 +- .../gms/messages/FinalCheckPassedMessage.java | 4 +- .../membership/gms/messages/HeartbeatMessage.java | 4 +- .../gms/messages/HeartbeatRequestMessage.java | 4 +- .../gms/messages/InstallViewMessage.java | 8 +- .../gms/messages/JoinRequestMessage.java | 4 +- .../gms/messages/JoinResponseMessage.java | 8 +- .../gms/messages/LeaveRequestMessage.java | 4 +- .../gms/messages/NetworkPartitionMessage.java | 4 +- .../gms/messages/RemoveMemberMessage.java | 5 +- .../gms/messages/SuspectMembersMessage.java | 4 +- .../membership/gms/messages/ViewAckMessage.java | 4 +- .../membership/gms/messenger/JGroupsMessenger.java | 14 +- .../membership/gms/mgr/GMSMembershipManager.java | 22 +- .../membership/gms/mgr/LocalViewMessage.java | 6 +- .../apache/geode/distributed/internal/package.html | 20 +- .../internal/streaming/StreamingOperation.java | 17 +- .../distributed/internal/tcpserver/TcpServer.java | 122 +- .../org/apache/geode/internal/DeployedJar.java | 100 +- .../apache/geode/internal/DistributionLocator.java | 2 +- .../geode/internal/InternalDataSerializer.java | 12 +- .../geode/internal/InternalInstantiator.java | 6 +- .../org/apache/geode/internal/JarDeployer.java | 148 +- .../java/org/apache/geode/internal/OSProcess.java | 45 +- .../internal/admin/ClientMembershipMessage.java | 6 +- .../geode/internal/admin/GfManagerAgent.java | 4 +- .../geode/internal/admin/StatAlertsManager.java | 10 +- .../admin/remote/AddHealthListenerRequest.java | 2 +- .../admin/remote/AddHealthListenerResponse.java | 4 +- .../admin/remote/AddStatListenerRequest.java | 2 +- .../admin/remote/AddStatListenerResponse.java | 4 +- .../remote/AdminConsoleDisconnectMessage.java | 4 +- .../internal/admin/remote/AdminConsoleMessage.java | 9 +- .../admin/remote/AdminMultipleReplyProcessor.java | 4 +- .../geode/internal/admin/remote/AdminRequest.java | 8 +- .../geode/internal/admin/remote/AdminResponse.java | 2 +- .../geode/internal/admin/remote/AdminWaiters.java | 6 +- .../admin/remote/AlertLevelChangeMessage.java | 4 +- .../admin/remote/AlertListenerMessage.java | 2 +- .../admin/remote/AlertsNotificationMessage.java | 4 +- .../admin/remote/AppCacheSnapshotMessage.java | 2 +- .../internal/admin/remote/BridgeServerRequest.java | 4 +- .../admin/remote/BridgeServerResponse.java | 4 +- .../internal/admin/remote/CacheConfigRequest.java | 2 +- .../internal/admin/remote/CacheConfigResponse.java | 6 +- .../internal/admin/remote/CacheInfoRequest.java | 2 +- .../internal/admin/remote/CacheInfoResponse.java | 5 +- .../admin/remote/CancelStatListenerRequest.java | 2 +- .../admin/remote/CancelStatListenerResponse.java | 4 +- .../internal/admin/remote/CancellationMessage.java | 2 +- .../admin/remote/ChangeRefreshIntervalMessage.java | 4 +- .../internal/admin/remote/CliLegacyMessage.java | 4 +- .../internal/admin/remote/CompactRequest.java | 12 +- .../internal/admin/remote/DestroyEntryMessage.java | 4 +- .../admin/remote/DestroyRegionMessage.java | 4 +- .../admin/remote/DurableClientInfoRequest.java | 2 +- .../admin/remote/DurableClientInfoResponse.java | 6 +- .../admin/remote/FetchDistLockInfoRequest.java | 2 +- .../admin/remote/FetchDistLockInfoResponse.java | 3 +- .../admin/remote/FetchHealthDiagnosisRequest.java | 2 +- .../admin/remote/FetchHealthDiagnosisResponse.java | 4 +- .../internal/admin/remote/FetchHostRequest.java | 2 +- .../internal/admin/remote/FetchHostResponse.java | 5 +- .../remote/FetchResourceAttributesRequest.java | 2 +- .../remote/FetchResourceAttributesResponse.java | 6 +- .../internal/admin/remote/FetchStatsRequest.java | 2 +- .../internal/admin/remote/FetchStatsResponse.java | 6 +- .../internal/admin/remote/FetchSysCfgRequest.java | 2 +- .../internal/admin/remote/FetchSysCfgResponse.java | 3 +- .../admin/remote/FlushAppCacheSnapshotMessage.java | 2 +- .../admin/remote/HealthListenerMessage.java | 2 +- .../internal/admin/remote/LicenseInfoRequest.java | 2 +- .../internal/admin/remote/LicenseInfoResponse.java | 4 +- .../admin/remote/MissingPersistentIDsRequest.java | 10 +- .../admin/remote/MissingPersistentIDsResponse.java | 5 +- .../admin/remote/ObjectDetailsRequest.java | 2 +- .../admin/remote/ObjectDetailsResponse.java | 3 +- .../internal/admin/remote/ObjectNamesRequest.java | 2 +- .../internal/admin/remote/ObjectNamesResponse.java | 3 +- .../remote/PrepareRevokePersistentIDRequest.java | 13 +- .../admin/remote/RefreshMemberSnapshotRequest.java | 2 +- .../remote/RefreshMemberSnapshotResponse.java | 5 +- .../admin/remote/RegionAttributesRequest.java | 2 +- .../admin/remote/RegionAttributesResponse.java | 4 +- .../geode/internal/admin/remote/RegionRequest.java | 2 +- .../internal/admin/remote/RegionResponse.java | 2 +- .../internal/admin/remote/RegionSizeRequest.java | 2 +- .../internal/admin/remote/RegionSizeResponse.java | 3 +- .../admin/remote/RegionStatisticsRequest.java | 2 +- .../admin/remote/RegionStatisticsResponse.java | 4 +- .../admin/remote/RegionSubRegionSizeRequest.java | 4 +- .../admin/remote/RegionSubRegionsSizeResponse.java | 7 +- .../admin/remote/RemoteGfManagerAgent.java | 40 +- .../admin/remote/RemoveHealthListenerRequest.java | 2 +- .../admin/remote/RemoveHealthListenerResponse.java | 4 +- .../admin/remote/ResetHealthStatusRequest.java | 2 +- .../admin/remote/ResetHealthStatusResponse.java | 4 +- .../admin/remote/RevokePersistentIDRequest.java | 8 +- .../internal/admin/remote/RootRegionRequest.java | 2 +- .../internal/admin/remote/RootRegionResponse.java | 5 +- .../remote/ShutdownAllGatewayHubsRequest.java | 6 +- .../internal/admin/remote/ShutdownAllRequest.java | 13 +- .../admin/remote/SnapshotResultMessage.java | 2 +- .../remote/StatAlertsManagerAssignMessage.java | 6 +- .../internal/admin/remote/StatListenerMessage.java | 2 +- .../internal/admin/remote/StoreSysCfgRequest.java | 2 +- .../internal/admin/remote/StoreSysCfgResponse.java | 3 +- .../internal/admin/remote/SubRegionRequest.java | 2 +- .../internal/admin/remote/SubRegionResponse.java | 3 +- .../internal/admin/remote/TailLogRequest.java | 2 +- .../internal/admin/remote/TailLogResponse.java | 5 +- .../admin/remote/UpdateAlertDefinitionMessage.java | 4 +- .../internal/admin/remote/VersionInfoRequest.java | 2 +- .../internal/admin/remote/VersionInfoResponse.java | 3 +- .../geode/internal/cache/AbstractCacheServer.java | 4 +- .../geode/internal/cache/AbstractRegion.java | 4 +- .../internal/cache/AbstractUpdateOperation.java | 10 +- .../cache/AddCacheServerProfileMessage.java | 4 +- .../apache/geode/internal/cache/BucketAdvisor.java | 4 +- .../internal/cache/CacheDistributionAdvisor.java | 6 +- .../geode/internal/cache/CacheServerAdvisor.java | 6 +- .../geode/internal/cache/CacheServerImpl.java | 5 +- .../geode/internal/cache/CloseCacheMessage.java | 4 +- .../internal/cache/ClusterConfigurationLoader.java | 83 +- .../geode/internal/cache/ControllerAdvisor.java | 7 +- .../internal/cache/CreateRegionProcessor.java | 5 +- .../geode/internal/cache/DestroyOperation.java | 6 +- .../cache/DestroyPartitionedRegionMessage.java | 4 +- .../internal/cache/DestroyRegionOperation.java | 12 +- .../geode/internal/cache/DirectReplyMessage.java | 7 +- .../apache/geode/internal/cache/DiskStoreImpl.java | 29 + .../geode/internal/cache/DistPeerTXStateStub.java | 10 +- .../internal/cache/DistTXAdjunctCommitMessage.java | 4 +- .../geode/internal/cache/DistTXCommitMessage.java | 9 +- .../internal/cache/DistTXCoordinatorInterface.java | 9 +- .../internal/cache/DistTXPrecommitMessage.java | 9 +- .../internal/cache/DistTXRollbackMessage.java | 10 +- .../internal/cache/DistTXStateOnCoordinator.java | 8 +- .../cache/DistTXStateProxyImplOnCoordinator.java | 14 +- .../internal/cache/DistributedCacheOperation.java | 21 +- .../internal/cache/DistributedClearOperation.java | 8 +- .../geode/internal/cache/DistributedRegion.java | 11 +- .../DistributedRegionFunctionStreamingMessage.java | 26 +- .../cache/DistributedTombstoneOperation.java | 8 +- .../apache/geode/internal/cache/EntriesMap.java | 5 +- .../apache/geode/internal/cache/FilterProfile.java | 6 +- .../internal/cache/FindDurableQueueProcessor.java | 10 +- .../geode/internal/cache/FindRemoteTXMessage.java | 9 +- .../internal/cache/FindVersionTagOperation.java | 10 +- .../FunctionStreamingOrderedReplyMessage.java | 7 +- .../cache/FunctionStreamingReplyMessage.java | 5 +- .../geode/internal/cache/GemFireCacheImpl.java | 54 +- .../internal/cache/InitialImageFlowControl.java | 16 +- .../internal/cache/InitialImageOperation.java | 71 +- .../apache/geode/internal/cache/InternalCache.java | 18 +- .../geode/internal/cache/InternalRegion.java | 4 +- .../geode/internal/cache/InvalidateOperation.java | 6 +- .../cache/InvalidatePartitionedRegionMessage.java | 4 +- .../internal/cache/InvalidateRegionOperation.java | 4 +- .../internal/cache/JtaAfterCompletionMessage.java | 9 +- .../internal/cache/JtaBeforeCompletionMessage.java | 4 +- .../cache/LatestLastAccessTimeMessage.java | 4 +- .../cache/LatestLastAccessTimeOperation.java | 4 +- .../cache/LatestLastAccessTimeReplyProcessor.java | 5 +- .../apache/geode/internal/cache/LocalRegion.java | 4 +- .../cache/MemberFunctionStreamingMessage.java | 23 +- .../geode/internal/cache/NonLocalRegionEntry.java | 4 +- .../org/apache/geode/internal/cache/Oplog.java | 4 +- .../internal/cache/PRHARedundancyProvider.java | 6 +- .../geode/internal/cache/PartitionedRegion.java | 20 +- .../internal/cache/PartitionedRegionDataStore.java | 6 +- .../internal/cache/PartitionedRegionHelper.java | 4 +- .../geode/internal/cache/ProxyBucketRegion.java | 4 +- .../geode/internal/cache/ProxyRegionMap.java | 4 +- .../apache/geode/internal/cache/RegionEntry.java | 4 +- .../internal/cache/ReleaseClearLockMessage.java | 8 +- .../cache/RemoteContainsKeyValueMessage.java | 6 +- .../geode/internal/cache/RemoteDestroyMessage.java | 15 +- .../internal/cache/RemoteFetchEntryMessage.java | 8 +- .../internal/cache/RemoteFetchVersionMessage.java | 10 +- .../geode/internal/cache/RemoteGetMessage.java | 10 +- .../internal/cache/RemoteInvalidateMessage.java | 22 +- .../internal/cache/RemoteOperationMessage.java | 21 +- .../RemoteOperationMessageWithDirectReply.java | 6 +- .../geode/internal/cache/RemotePutAllMessage.java | 12 +- .../geode/internal/cache/RemotePutMessage.java | 18 +- .../internal/cache/RemoteRegionOperation.java | 6 +- .../internal/cache/RemoteRemoveAllMessage.java | 12 +- .../cache/SearchLoadAndWriteProcessor.java | 57 +- .../geode/internal/cache/ServerPingMessage.java | 6 +- .../geode/internal/cache/StateFlushOperation.java | 84 +- .../geode/internal/cache/TXCommitMessage.java | 37 +- .../geode/internal/cache/TXFarSideCMTracker.java | 11 +- .../apache/geode/internal/cache/TXManagerImpl.java | 10 +- .../org/apache/geode/internal/cache/TXMessage.java | 8 +- .../internal/cache/TXRemoteCommitMessage.java | 9 +- .../internal/cache/TXRemoteRollbackMessage.java | 4 +- .../internal/cache/UpdateAttributesProcessor.java | 13 +- .../cache/UpdateEntryVersionOperation.java | 6 +- .../geode/internal/cache/UpdateOperation.java | 12 +- .../geode/internal/cache/ValidatingDiskRegion.java | 4 +- .../cache/backup/BackupDataStoreHelper.java | 12 +- .../internal/cache/backup/BackupDefinition.java | 83 + .../internal/cache/backup/BackupDestination.java | 28 + .../geode/internal/cache/backup/BackupManager.java | 374 +- .../internal/cache/backup/BackupOperation.java | 8 +- .../cache/backup/BackupReplyProcessor.java | 4 +- .../geode/internal/cache/backup/BackupUtil.java | 6 +- .../cache/backup/FileSystemBackupDestination.java | 145 + .../internal/cache/backup/FinishBackupFactory.java | 6 +- .../cache/backup/FinishBackupOperation.java | 8 +- .../internal/cache/backup/FinishBackupRequest.java | 4 +- .../internal/cache/backup/FlushToDiskFactory.java | 7 +- .../cache/backup/FlushToDiskOperation.java | 12 +- .../cache/backup/FlushToDiskProcessor.java | 4 +- .../internal/cache/backup/FlushToDiskRequest.java | 4 +- .../cache/backup/PrepareBackupFactory.java | 6 +- .../cache/backup/PrepareBackupOperation.java | 7 +- .../cache/backup/PrepareBackupRequest.java | 4 +- .../geode/internal/cache/backup/RestoreScript.java | 3 +- .../internal/cache/backup/UnixScriptGenerator.java | 3 - .../client/protocol/ClientProtocolService.java | 3 +- .../internal/cache/control/ResourceAdvisor.java | 12 +- .../entries/AbstractOplogDiskRegionEntry.java | 6 +- .../cache/entries/AbstractRegionEntry.java | 6 +- .../geode/internal/cache/entries/DiskEntry.java | 5 +- .../cache/eviction/LRUListWithAsyncSorting.java | 1 + .../internal/cache/execute/AbstractExecution.java | 18 +- .../DistributedRegionFunctionResultSender.java | 12 +- .../cache/execute/MemberFunctionExecutor.java | 4 +- .../cache/execute/MemberFunctionResultSender.java | 11 +- .../cache/execute/MultiRegionFunctionExecutor.java | 4 +- .../PartitionedRegionFunctionResultSender.java | 16 +- .../geode/internal/cache/ha/HARegionQueue.java | 4 +- .../internal/cache/ha/QueueRemovalMessage.java | 5 +- .../cache/locks/TXLessorDepartureHandler.java | 4 +- .../locks/TXLockUpdateParticipantsMessage.java | 4 +- .../cache/locks/TXOriginatorRecoveryProcessor.java | 12 +- .../locks/TXRecoverGrantorMessageProcessor.java | 8 +- .../AllBucketProfilesUpdateMessage.java | 8 +- .../partitioned/BecomePrimaryBucketMessage.java | 14 +- .../cache/partitioned/BucketBackupMessage.java | 6 +- .../partitioned/BucketProfileUpdateMessage.java | 10 +- .../cache/partitioned/BucketSizeMessage.java | 12 +- .../cache/partitioned/ContainsKeyValueMessage.java | 6 +- .../cache/partitioned/CreateBucketMessage.java | 12 +- .../partitioned/DeposePrimaryBucketMessage.java | 12 +- .../internal/cache/partitioned/DestroyMessage.java | 12 +- .../DestroyRegionOnDataStoreMessage.java | 14 +- .../cache/partitioned/DumpAllPRConfigMessage.java | 4 +- .../internal/cache/partitioned/DumpB2NRegion.java | 12 +- .../cache/partitioned/DumpBucketsMessage.java | 4 +- .../partitioned/EndBucketCreationMessage.java | 8 +- .../cache/partitioned/FetchBulkEntriesMessage.java | 12 +- .../cache/partitioned/FetchEntriesMessage.java | 13 +- .../cache/partitioned/FetchEntryMessage.java | 8 +- .../cache/partitioned/FetchKeysMessage.java | 14 +- .../partitioned/FetchPartitionDetailsMessage.java | 12 +- .../internal/cache/partitioned/FlushMessage.java | 4 +- .../internal/cache/partitioned/GetMessage.java | 14 +- .../cache/partitioned/IdentityRequestMessage.java | 11 +- .../cache/partitioned/IdentityUpdateMessage.java | 6 +- .../cache/partitioned/IndexCreationMsg.java | 20 +- .../cache/partitioned/InterestEventMessage.java | 14 +- .../cache/partitioned/InvalidateMessage.java | 10 +- .../partitioned/ManageBackupBucketMessage.java | 16 +- .../cache/partitioned/ManageBucketMessage.java | 16 +- .../cache/partitioned/MoveBucketMessage.java | 12 +- .../cache/partitioned/PRSanityCheckMessage.java | 10 +- .../cache/partitioned/PRTombstoneMessage.java | 6 +- .../partitioned/PRUpdateEntryVersionMessage.java | 4 +- .../cache/partitioned/PartitionMessage.java | 22 +- .../PartitionMessageWithDirectReply.java | 3 +- .../PartitionedRegionFunctionStreamingMessage.java | 16 +- .../partitioned/PartitionedRegionRebalanceOp.java | 4 +- .../cache/partitioned/PrimaryRequestMessage.java | 8 +- .../cache/partitioned/PutAllPRMessage.java | 12 +- .../internal/cache/partitioned/PutMessage.java | 14 +- .../internal/cache/partitioned/QueryMessage.java | 8 +- .../cache/partitioned/RemoteFetchKeysMessage.java | 14 +- .../cache/partitioned/RemoteSizeMessage.java | 9 +- .../cache/partitioned/RemoveAllPRMessage.java | 12 +- .../cache/partitioned/RemoveBucketMessage.java | 12 +- .../cache/partitioned/RemoveIndexesMessage.java | 17 +- .../internal/cache/partitioned/SizeMessage.java | 20 +- .../partitioned/StreamingPartitionOperation.java | 10 +- .../cache/persistence/MembershipFlushRequest.java | 9 +- .../cache/persistence/MembershipViewRequest.java | 27 +- .../cache/persistence/PersistenceAdvisorImpl.java | 4 +- .../cache/persistence/PersistentMemberManager.java | 8 +- .../persistence/PersistentStateQueryMessage.java | 14 +- .../PrepareNewPersistentMemberMessage.java | 10 +- .../persistence/RemovePersistentMemberMessage.java | 11 +- .../apache/geode/internal/cache/properties.html | 686 +-- .../internal/cache/snapshot/FlowController.java | 27 +- .../internal/cache/tier/sockets/AcceptorImpl.java | 4 +- .../cache/tier/sockets/CacheClientNotifier.java | 7 +- .../cache/tier/sockets/CacheClientProxy.java | 4 +- .../cache/tier/sockets/CacheClientUpdater.java | 7 +- .../tier/sockets/ClientBlacklistProcessor.java | 12 +- .../cache/tier/sockets/ClientHealthMonitor.java | 28 +- .../internal/cache/tier/sockets/HandShake.java | 5 +- .../sockets/RemoveClientFromBlacklistMessage.java | 5 +- .../sockets/ServerInterestRegistrationMessage.java | 6 +- .../cache/tier/sockets/VersionedObjectList.java | 5 +- .../tier/sockets/command/ExecuteFunction66.java | 11 +- .../internal/cache/tier/sockets/command/Size.java | 6 +- .../tier/sockets/command/TXFailoverCommand.java | 4 +- .../geode/internal/cache/tx/ClientTXStateStub.java | 4 +- .../internal/cache/tx/DistClientTXStateStub.java | 9 +- .../internal/cache/tx/DistributedTXRegionStub.java | 19 +- .../cache/versions/RegionVersionVector.java | 7 +- .../internal/cache/versions/VMVersionTag.java | 4 +- .../geode/internal/cache/versions/VersionTag.java | 4 +- .../internal/cache/wan/AbstractGatewaySender.java | 4 +- .../internal/cache/wan/GatewaySenderAdvisor.java | 7 +- ...aySenderQueueEntrySynchronizationOperation.java | 8 +- .../wan/parallel/ParallelGatewaySenderQueue.java | 5 +- .../parallel/ParallelQueueBatchRemovalMessage.java | 8 +- .../wan/parallel/ParallelQueueRemovalMessage.java | 5 +- ...tilParallelGatewaySenderFlushedCoordinator.java | 3 +- .../cache/wan/serial/BatchDestroyOperation.java | 6 +- .../internal/cache/xmlcache/CacheCreation.java | 11 +- .../geode/internal/cache/xmlcache/CacheXml.java | 5 + .../xmlcache/ParallelAsyncEventQueueCreation.java | 4 +- .../xmlcache/ParallelGatewaySenderCreation.java | 4 +- .../xmlcache/SerialAsyncEventQueueCreation.java | 4 +- .../xmlcache/SerialGatewaySenderCreation.java | 4 +- .../geode/internal/jta/GlobalTransaction.java | 4 +- .../internal/logging/log4j/AlertAppender.java | 4 +- .../apache/geode/internal/net/SocketCreator.java | 5 +- .../org/apache/geode/internal/tcp/Connection.java | 12 +- .../apache/geode/internal/tcp/ConnectionTable.java | 6 +- .../org/apache/geode/internal/tcp/TCPConduit.java | 10 +- .../org/apache/geode/internal/tcp/package.html | 21 +- .../org/apache/geode/management/MemberMXBean.java | 28 +- .../management/internal/JmxManagerAdvisee.java | 4 +- .../management/internal/JmxManagerAdvisor.java | 11 +- .../geode/management/internal/ManagementAgent.java | 24 +- .../management/internal/ManagementConstants.java | 3 + .../management/internal/ManagerStartupMessage.java | 7 +- .../geode/management/internal/MemberMessenger.java | 8 +- .../internal/beans/DistributedSystemBridge.java | 10 +- .../management/internal/beans/FileUploader.java | 90 + .../internal/beans/FileUploaderMBean.java | 34 + .../internal/beans/ManagementAdapter.java | 4 +- .../management/internal/beans/MemberMBean.java | 40 +- .../internal/beans/MemberMBeanBridge.java | 19 +- .../geode/management/internal/cli/CliUtil.java | 59 +- .../management/internal/cli/CommandRequest.java | 22 +- .../cli/commands/BackupDiskStoreCommand.java | 4 +- .../internal/cli/commands/ConnectCommand.java | 27 +- .../internal/cli/commands/DeployCommand.java | 139 +- .../commands/DestroyAsyncEventQueueCommand.java | 79 + .../ExportImportClusterConfigurationCommands.java | 65 +- .../cli/commands/ExportStackTraceCommand.java | 65 +- .../internal/cli/commands/GfshCommand.java | 2 + .../internal/cli/commands/ListMembersCommand.java | 20 + .../internal/cli/commands/StartLocatorCommand.java | 13 +- .../internal/cli/commands/StartMemberUtils.java | 2 +- .../internal/cli/commands/StartServerCommand.java | 21 +- .../converters/ConnectionEndpointConverter.java | 43 - .../internal/cli/functions/CliFunctionResult.java | 7 - .../internal/cli/functions/DeployFunction.java | 94 +- .../functions/DestroyAsyncEventQueueFunction.java | 80 + .../DestroyAsyncEventQueueFunctionArgs.java | 38 + .../cli/functions/RegionCreateFunction.java | 9 + .../management/internal/cli/i18n/CliStrings.java | 14 +- .../cli/remote/CommandExecutionContext.java | 13 +- .../cli/remote/OnlineCommandProcessor.java | 8 +- .../management/internal/cli/result/FileResult.java | 48 +- .../internal/cli/shell/GfshExecutionStrategy.java | 6 +- .../internal/cli/shell/JmxOperationInvoker.java | 59 +- .../internal/cli/shell/OperationInvoker.java | 2 + .../callbacks/ConfigurationChangeListener.java | 4 - .../internal/configuration/domain/XmlEntity.java | 171 +- .../functions/DownloadJarFunction.java | 88 + .../functions/GetClusterConfigurationFunction.java | 2 +- .../configuration/functions/UploadJarFunction.java | 62 - .../messages/ConfigurationResponse.java | 33 +- .../internal/messages/CompactRequest.java | 12 +- .../controllers/AbstractCommandsController.java | 53 +- .../web/controllers/ShellCommandsController.java | 10 +- .../internal/web/shell/HttpOperationInvoker.java | 16 +- .../management/internal/web/util/ConvertUtils.java | 136 - .../pdx/internal/AutoSerializableManager.java | 26 +- .../geode/pdx/internal/CheckTypeRegistryState.java | 7 +- .../sanctioned-geode-core-serializables.txt | 6 +- .../org/apache/geode/admin/AdminTestHelper.java | 12 +- .../geode/cache/ConnectionPoolDUnitTest.java | 8 +- .../CacheServerSSLConnectionDUnitTest.java | 74 +- .../cache/execute/FunctionAdapterJUnitTest.java | 52 +- .../MemoryThresholdsOffHeapDUnitTest.java | 118 +- .../cache/query/cq/dunit/CqQueryTestListener.java | 2 +- .../cache/query/dunit/PdxLocalQueryDUnitTest.java | 6 +- .../geode/cache/query/dunit/PdxQueryDUnitTest.java | 14 +- .../cache/query/dunit/PdxStringQueryDUnitTest.java | 24 +- .../query/dunit/SelectStarQueryDUnitTest.java | 6 +- .../internal/index/PartitionedIndexJUnitTest.java | 69 + .../geode/cache30/ClientServerCCEDUnitTest.java | 4 +- .../cache30/DistributedAckRegionCCEDUnitTest.java | 7 +- .../geode/cache30/RegionReliabilityTestCase.java | 4 +- .../org/apache/geode/cache30/SlowRecDUnitTest.java | 14 +- .../DistributedLockServiceDUnitTest.java | 7 +- .../distributed/DistributedMemberDUnitTest.java | 15 +- .../distributed/DistributedSystemDUnitTest.java | 17 +- .../geode/distributed/HostedLocatorsDUnitTest.java | 28 +- .../apache/geode/distributed/LocatorDUnitTest.java | 60 +- .../apache/geode/distributed/LocatorJUnitTest.java | 25 +- .../distributed/LocatorLauncherBuilderTest.java | 15 +- .../apache/geode/distributed/RoleDUnitTest.java | 8 +- .../distributed/ServerLauncherBuilderTest.java | 15 +- .../geode/distributed/SystemAdminDUnitTest.java | 5 +- .../ClusterDistributionManagerDUnitTest.java | 399 ++ ...lusterDistributionManagerForAdminDUnitTest.java | 317 ++ .../internal/ClusterDistributionManagerTest.java | 46 + .../ConsoleDistributionManagerDUnitTest.java | 446 -- .../geode/distributed/internal/DateMessage.java | 2 +- .../internal/DistributionAdvisorDUnitTest.java | 2 +- .../internal/DistributionManagerDUnitTest.java | 545 --- .../internal/DistributionManagerTest.java | 44 - .../InternalDistributedSystemJUnitTest.java | 3 +- .../internal/InternalLocatorIntegrationTest.java | 3 +- .../org/apache/geode/distributed/internal/LDM.java | 4 +- .../internal/LocatorLoadSnapshotJUnitTest.java | 66 + .../distributed/internal/ProduceDateMessages.java | 2 +- .../internal/locks/DLockServiceLeakTest.java | 23 +- .../internal/membership/MembershipJUnitTest.java | 31 +- .../internal/membership/NetViewJUnitTest.java | 24 +- .../membership/gms/MembershipManagerHelper.java | 5 +- .../gms/fd/GMSHealthMonitorJUnitTest.java | 5 +- .../gms/locator/GMSLocatorRecoveryJUnitTest.java | 38 +- .../gms/membership/GMSJoinLeaveJUnitTest.java | 11 +- .../gms/membership/GMSJoinLeaveTestHelper.java | 4 +- .../gms/membership/StatRecorderJUnitTest.java | 6 +- .../gms/messenger/GMSEncryptJUnitTest.java | 37 +- .../gms/messenger/GMSQuorumCheckerJUnitTest.java | 27 +- .../gms/messenger/JGroupsMessengerJUnitTest.java | 12 +- .../gms/mgr/GMSMembershipManagerJUnitTest.java | 6 +- .../internal/ClassPathLoaderIntegrationTest.java | 76 +- .../apache/geode/internal/ClassPathLoaderTest.java | 34 +- .../geode/internal/DeployedJarJUnitTest.java | 20 +- .../internal/InternalDataSerializerJUnitTest.java | 63 + .../geode/internal/JarDeployerDeadlockTest.java | 11 +- .../geode/internal/JarDeployerIntegrationTest.java | 22 +- .../geode/internal/cache/Bug41091DUnitTest.java | 5 +- .../geode/internal/cache/Bug41733DUnitTest.java | 8 +- .../internal/cache/CacheOperationMessageTest.java | 4 +- .../cache/ClientServerTransactionDUnitTest.java | 76 + .../cache/DiskStoreImplIntegrationTest.java | 93 + .../internal/cache/DistributedCacheTestCase.java | 17 +- ...tributedRegionFunctionStreamingMessageTest.java | 4 +- .../geode/internal/cache/GIIDeltaDUnitTest.java | 10 +- .../internal/cache/GIIFlowControlDUnitTest.java | 6 +- .../cache/InterruptClientServerDUnitTest.java | 8 +- .../internal/cache/InterruptDiskJUnitTest.java | 21 +- .../geode/internal/cache/InterruptsDUnitTest.java | 8 +- ...FOEvictionAlgoMemoryEnabledRegionJUnitTest.java | 5 +- .../cache/NetSearchMessagingDUnitTest.java | 8 +- .../cache/PRCacheListenerInvocationTest.java | 2 + ...istenerWithInterestPolicyAllInvocationTest.java | 2 + .../cache/PartitionedRegionQueryDUnitTest.java | 5 +- .../cache/RemoteFetchEntryMessageTest.java | 4 +- .../internal/cache/RemoteOperationMessageTest.java | 6 +- .../cache/SearchLoadAndWriteProcessorTest.java | 4 +- .../internal/cache/StateMarkerMessageTest.java | 31 + .../internal/cache/SystemFailureDUnitTest.java | 4 +- .../geode/internal/cache/TXManagerImplTest.java | 7 +- .../cache/backup/BackupDefinitionTest.java | 119 + .../cache/backup/BackupDistributedTest.java | 567 +-- .../cache/backup/BackupIntegrationTest.java | 2 +- .../backup/BackupPrepareAndFinishMsgDUnitTest.java | 7 +- .../cache/backup/BackupReplyProcessorTest.java | 14 +- .../backup/FileSystemBackupDestinationTest.java | 229 + .../cache/backup/FinishBackupFactoryTest.java | 12 +- .../cache/backup/FinishBackupOperationTest.java | 17 +- .../cache/backup/FinishBackupRequestTest.java | 6 +- .../cache/backup/FlushToDiskFactoryTest.java | 13 +- .../cache/backup/FlushToDiskOperationTest.java | 14 +- .../cache/backup/FlushToDiskRequestTest.java | 14 +- .../backup/IncrementalBackupDistributedTest.java | 205 +- .../cache/backup/PrepareBackupFactoryTest.java | 11 +- .../cache/backup/PrepareBackupOperationTest.java | 17 +- .../cache/backup/PrepareBackupRequestTest.java | 14 +- .../internal/cache/eviction/LRUTestEntry.java | 5 +- ...istributedRegionFunctionExecutionDUnitTest.java | 4 +- .../execute/MemberFunctionExecutionDUnitTest.java | 4 +- .../execute/PRFunctionExecutionDUnitTest.java | 4 +- .../ExtensionClusterConfigurationDUnitTest.java | 18 +- .../internal/cache/ha/HASlowReceiverDUnitTest.java | 57 +- .../geode/internal/cache/ha/PutAllDUnitTest.java | 5 +- .../cache/locks/TXLockServiceDUnitTest.java | 6 +- .../cache/partitioned/Bug39356DUnitTest.java | 6 +- .../DeposePrimaryBucketMessageTest.java | 4 +- .../cache/partitioned/FetchEntryMessageTest.java | 4 +- .../FetchPartitionDetailsMessageTest.java | 4 +- .../cache/partitioned/MoveBucketMessageTest.java | 4 +- .../cache/partitioned/PartitionMessageTest.java | 6 +- ...sistentColocatedPartitionedRegionDUnitTest.java | 146 +- .../PersistentPartitionedRegionDUnitTest.java | 19 +- .../cache/partitioned/RemoveBucketMessageTest.java | 4 +- .../PersistentRVVRecoveryDUnitTest.java | 6 +- .../PersistentRecoveryOrderDUnitTest.java | 41 +- .../tier/sockets/ClientHealthMonitorJUnitTest.java | 21 +- .../ClientHealthMonitorSelectorJUnitTest.java | 4 +- .../tier/sockets/ClientServerMiscDUnitTest.java | 111 +- .../tier/sockets/EventIDVerificationDUnitTest.java | 4 + .../sockets/HAInterestDistributedTestCase.java | 26 - .../cache/versions/RegionVersionVectorTest.java | 24 +- ...ewayReceiverXmlParsingValidationsJUnitTest.java | 5 +- .../ParallelQueueRemovalMessageJUnitTest.java | 4 +- .../cache/xmlcache/CacheXmlParserJUnitTest.java | 7 +- ...ainWithChildrenRollingFileHandlerDUnitTest.java | 6 +- .../internal/net/SSLSocketIntegrationTest.java | 18 + ...nectingOutOfOffHeapMemoryListenerJUnitTest.java | 4 +- .../offheap/OutOfOffHeapMemoryDUnitTest.java | 6 +- .../BlockingProcessStreamReaderWindowsTest.java | 20 +- .../FileProcessControllerIntegrationTest.java | 23 +- .../internal/process/PidFileIntegrationTest.java | 10 - .../geode/internal/tcp/ConnectionJUnitTest.java | 4 +- .../geode/internal/tcp/ConnectionTableTest.java | 4 +- .../util/AbortableTaskServiceJUnitTest.java | 18 +- .../apache/geode/management/JMXMBeanDUnitTest.java | 6 +- .../geode/management/ManagementTestRule.java | 4 +- .../management/RegionManagementDUnitTest.java | 4 +- .../bean/stats/GatewayMBeanBridgeJUnitTest.java | 2 +- .../beans/DistributedSystemBridgeJUnitTest.java | 6 +- .../internal/beans/FileUploaderTest.java | 84 + .../internal/beans/RegionMBeanAttributesTest.java | 4 +- .../management/internal/cli/CliUtilDUnitTest.java | 27 +- .../geode/management/internal/cli/CliUtilTest.java | 30 + .../internal/cli/GfshParserAutoCompletionTest.java | 16 +- .../management/internal/cli/NetstatDUnitTest.java | 4 +- .../AlterAsyncEventQueueCommandDUnitTest.java | 10 +- .../cli/commands/AlterDiskStoreDUnitTest.java | 10 +- .../commands/ChangeLogLevelCommandDUnitTest.java | 12 +- .../cli/commands/ConcurrentDeployDUnitTest.java | 4 +- .../cli/commands/ConnectCommandDUnitTest.java | 51 + .../internal/cli/commands/ConnectCommandTest.java | 39 +- .../CreateAsyncEventQueueCommandDUnitTest.java | 8 +- .../commands/CreateAsyncEventQueueCommandTest.java | 2 +- .../CreateDefinedIndexesCommandDUnitTest.java | 41 +- .../cli/commands/CreateRegionCommandDUnitTest.java | 12 +- ...DeployCommandFunctionRegistrationDUnitTest.java | 4 +- .../commands/DeployCommandRedeployDUnitTest.java | 8 +- .../internal/cli/commands/DeployCommandTest.java | 63 + .../cli/commands/DeployWithGroupsDUnitTest.java | 8 +- .../commands/DescribeMembersCommandDUnitTest.java | 4 +- .../cli/commands/DescribeRegionDUnitTest.java | 8 +- .../DestroyAsyncEventQueueCommandDUnitTest.java | 216 + .../DestroyAsyncEventQueueCommandTest.java | 198 + .../commands/DestroyIndexCommandsDUnitTest.java | 26 +- .../commands/DestroyRegionCommandDUnitTest.java | 21 +- .../cli/commands/DiskStoreCommandsDUnitTest.java | 36 +- .../ExecuteFunctionCommandSecurityTest.java | 6 +- .../internal/cli/commands/ExportLogsDUnitTest.java | 8 +- .../commands/ExportLogsOnServerManagerDUnit.java | 13 +- .../cli/commands/ExportLogsStatsDUnitTest.java | 13 +- .../ExportLogsWithMemberGroupDUnitTest.java | 6 +- .../commands/ExportStackTraceCommandDUnitTest.java | 102 + .../cli/commands/ExportStackTraceCommandTest.java | 72 + .../cli/commands/FunctionCommandsDUnitTest.java | 10 +- .../internal/cli/commands/GcCommandDUnitTest.java | 17 +- .../IndexCommandsShareConfigurationDUnitTest.java | 8 +- .../ListAsyncEventQueuesCommandDUnitTest.java | 8 +- .../cli/commands/ListIndexCommandDUnitTest.java | 6 +- .../cli/commands/ListMembersCommandDUnitTest.java | 9 +- .../internal/cli/commands/ListRegionDUnitTest.java | 8 +- .../cli/commands/LocateEntryDUnitTest.java | 4 +- .../cli/commands/RemoveCommandDUnitTest.java | 10 +- .../cli/commands/RemoveCommandJsonDUnitTest.java | 10 +- .../cli/commands/ShowDeadlockDUnitTest.java | 8 +- .../cli/commands/ShowLogCommandDUnitTest.java | 12 +- .../cli/commands/ShowMetricsDUnitTest.java | 8 +- .../commands/ShowMissingDiskStoresDUnitTest.java | 4 +- .../cli/commands/ShowStackTraceDUnitTest.java | 269 -- .../cli/commands/ShutdownCommandDUnitTest.java | 10 +- .../cli/commands/StartMemberUtilsTest.java | 20 + .../converters/BaseStringConverterJUnitTest.java | 7 +- .../DestroyAsyncEventQueueFunctionTest.java | 107 + .../cli/remote/OnlineCommandProcessorTest.java | 5 + .../internal/cli/result/FileResultTest.java | 56 + .../internal/cli/util/MergeLogsDUnitTest.java | 9 +- .../internal/configuration/ClusterConfig.java | 8 +- .../ClusterConfigDistributionDUnitTest.java | 6 +- .../ClusterConfigImportDUnitTest.java | 4 +- .../configuration/ClusterConfigTestBase.java | 4 +- .../ClusterConfigWithSecurityDUnitTest.java | 10 +- .../ImportClusterConfigDistributedTest.java | 8 +- .../ImportOldClusterConfigDUnitTest.java | 6 +- .../CacheServerMBeanAuthenticationJUnitTest.java | 2 +- .../CacheServerMBeanAuthorizationJUnitTest.java | 2 +- ...acheServerMBeanWithShiroIniIntegrationTest.java | 2 +- .../internal/security/CliCommandsSecurityTest.java | 2 +- .../security/DataCommandsSecurityTest.java | 2 +- .../security/DeployCommandsSecurityTest.java | 2 +- .../security/DiskStoreMXBeanSecurityJUnitTest.java | 2 +- .../DistributedSystemMXBeanSecurityTest.java | 2 +- .../security/FileUploaderMBeanSecurityTest.java | 67 + .../security/GatewayReceiverMBeanSecurityTest.java | 2 +- .../security/GatewaySenderMBeanSecurityTest.java | 2 +- .../internal/security/JmxPasswordFileTest.java | 55 + .../LockServiceMBeanAuthorizationJUnitTest.java | 2 +- .../ManagerMBeanAuthorizationJUnitTest.java | 2 +- .../security/MemberMBeanSecurityJUnitTest.java | 2 +- .../internal/security/MultiClientDUnitTest.java | 116 +- .../internal/security/MultiGfshDUnitTest.java | 4 +- .../security/MultiUserAuthenticationDUnitTest.java | 4 +- .../ShellCommandsControllerProcessCommandTest.java | 3 +- .../geode/pdx/AutoSerializableJUnitTest.java | 38 + .../pdx/ClientsWithVersioningRetryDUnitTest.java | 7 +- .../geode/pdx/DistributedSystemIdDUnitTest.java | 6 +- .../apache/geode/pdx/PdxSerializableDUnitTest.java | 4 +- .../apache/geode/pdx/PdxSerializableJUnitTest.java | 8 +- .../apache/geode/security/ClientAuthDUnitTest.java | 31 +- .../ClientDestroyInvalidateAuthDUnitTest.java | 44 +- .../security/ClusterConfigNotEnabledDUnitTest.java | 8 +- .../ClusterConfigWithoutSecurityDUnitTest.java | 4 +- .../ClusterConfigurationSecurityDUnitTest.java | 4 +- .../PDXGfshPostProcessorOnRemoteServerTest.java | 10 +- .../geode/security/PeerAuthenticatorDUnitTest.java | 6 +- .../PeerSecurityWithEmbeddedLocatorDUnitTest.java | 8 +- .../security/SecurityClusterConfigDUnitTest.java | 4 +- .../SecurityWithoutClusterConfigDUnitTest.java | 4 +- .../security/StartServerAuthorizationTest.java | 4 +- .../security/query/IndexSecurityDUnitTest.java | 7 +- .../query/PartitionedIndexSecurityDUnitTest.java | 3 +- ...tionedQuerySecurityAllowedQueriesDUnitTest.java | 2 + .../PdxQuerySecurityAllowedQueriesDUnitTest.java | 10 +- ...PdxQuerySecurityRestrictedQueriesDUnitTest.java | 11 +- ...rityUnauthorizedUserBindParameterDUnitTest.java | 3 - .../apache/geode/test/dunit/rules/ClientVM.java | 32 + .../geode/test/dunit/rules/ClusterStartupRule.java | 429 ++ .../test/dunit/rules/LocatorServerStartupRule.java | 368 -- .../apache/geode/test/dunit/rules/MemberVM.java | 50 +- ...tartupRuleCanSpecifyOlderVersionsDUnitTest.java | 101 + .../geode/test/dunit/standalone/DUnitLauncher.java | 24 +- .../test/dunit/standalone/VersionManager.java | 3 + .../java/org/apache/geode/test/fake/Fakes.java | 9 +- .../geode/test/junit/rules/ClientCacheRule.java | 70 + .../geode/test/junit/rules/LocatorStarterRule.java | 1 - .../junit/rules/MBeanServerConnectionRule.java | 40 +- .../apache/geode/test/junit/rules/VMProvider.java | 55 + .../geode/test/process/MainLauncherJUnitTest.java | 32 +- ...unctionAdapterWithDifferentSerialVersionUID.ser | Bin 0 -> 151 bytes .../codeAnalysis/sanctionedDataSerializables.txt | 109 +- ...serJUnitTest.testSimpleClientCacheXml.cache.xml | 2 +- .../cache/query/cq/dunit/CqPerfDUnitTest.java | 86 +- .../query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 100 +- .../geode/internal/cache/PutAllCSDUnitTest.java | 8 +- .../tier/sockets/ClientServerMiscBCDUnitTest.java | 4 +- .../geode/security/ClientCQAuthDUnitTest.java | 4 +- .../list_of_event_handlers_and_events.html.md.erb | 7 +- .../expiration/chapter_overview.html.md.erb | 4 +- .../configuring_data_expiration.html.md.erb | 7 +- .../expiration/how_expiration_works.html.md.erb | 29 +- .../chapter_overview.html.md.erb | 2 +- .../create_multiple_indexes.html.md.erb | 3 - .../query_index/creating_an_index.html.md.erb | 5 +- .../query_index/creating_hash_indexes.html.md.erb | 5 + .../developing/query_index/query_index.html.md.erb | 2 +- .../querying_basics/chapter_overview.html.md.erb | 5 +- .../querying_basics/query_basics.html.md.erb | 13 +- .../managing/heap_use/heap_management.html.md.erb | 2 +- .../topics/gemfire_properties.html.md.erb | 13 + .../gfsh/command-pages/alter.html.md.erb | 57 +- .../gfsh/command-pages/create.html.md.erb | 4 +- .../gfsh/command-pages/destroy.html.md.erb | 49 +- .../tools_modules/lucene_integration.html.md.erb | 192 +- geode-experimental-driver/build.gradle | 28 + .../apache/geode/experimental/driver/Driver.java | 50 + .../geode/experimental/driver/DriverFactory.java | 60 + .../geode/experimental/driver/JSONWrapper.java | 76 + .../geode/experimental/driver/ProtobufDriver.java | 158 + .../geode/experimental/driver/ProtobufRegion.java | 168 + .../apache/geode/experimental/driver/Region.java | 88 + .../experimental/driver/RegionAttributes.java | 79 + .../geode/experimental/driver/ValueEncoder.java | 116 + .../experimental/driver/DriverConnectionTest.java | 101 + .../experimental/driver/RegionIntegrationTest.java | 148 + .../experimental/driver/ValueEncoderTest.java | 45 + .../org/apache/geode/test/compiler/JarBuilder.java | 9 - .../test/junit/rules/ExecutorServiceRule.java | 355 ++ .../geode/test/junit/rules/gfsh/GfshRule.java | 4 + .../geode/test/junit/rules/gfsh/GfshScript.java | 2 +- .../rules/ExecutorServiceRuleIntegrationTest.java | 131 + .../test/junit/rules/ExecutorServiceRuleTest.java | 380 ++ .../lucene/internal/DestroyLuceneIndexMessage.java | 5 +- .../lucene/internal/LuceneBucketListener.java | 6 +- .../internal/LuceneIndexForPartitionedRegion.java | 6 +- .../cli/functions/LuceneCreateIndexFunction.java | 22 +- .../cli/functions/LuceneDescribeIndexFunction.java | 22 +- .../cli/functions/LuceneDestroyIndexFunction.java | 16 +- .../cli/functions/LuceneListIndexFunction.java | 21 +- .../cli/functions/LuceneSearchIndexFunction.java | 19 +- .../internal/directory/DumpDirectoryFiles.java | 13 + .../internal/distributed/LuceneQueryFunction.java | 1 - .../distributed/WaitUntilFlushedFunction.java | 1 - .../internal/results/LuceneGetPageFunction.java | 1 - .../sanctioned-geode-lucene-serializables.txt | 8 +- .../lucene/LuceneCommandsSecurityDUnitTest.java | 4 +- .../LuceneIndexRecoveryHAIntegrationTest.java | 1 - .../internal/cli/LuceneIndexCommandsDUnitTest.java | 10 +- .../LuceneClusterConfigurationDUnitTest.java | 12 +- .../management/LuceneManagementDUnitTest.java | 46 +- .../LuceneIndexXmlParserIntegrationJUnitTest.java | 26 +- .../lucene/test/LuceneFunctionSecurityTest.java | 485 ++ .../src/main/proto/handshake.proto | 37 - .../src/main/proto/protocolVersion.proto | 37 + .../src/main/proto/v1/basicTypes.proto | 27 +- .../src/main/proto/v1/clientProtocol.proto | 6 +- .../src/main/proto/v1/locator_API.proto | 10 +- .../operations/ProtobufOperationHandler.java | 31 + .../statistics/ProtobufClientStatisticsImpl.java | 5 + .../protobuf/v1/EncodingTypeTranslator.java | 68 - .../protobuf/v1/ProtobufCachePipeline.java | 14 +- .../protobuf/v1/ProtobufLocatorPipeline.java | 87 - .../protobuf/v1/ProtobufOperationContext.java | 6 +- .../protocol/protobuf/v1/ProtobufOpsProcessor.java | 7 +- .../protobuf/v1/ProtobufProtocolService.java | 21 +- .../protobuf/v1/ProtobufSerializationService.java | 155 +- .../operations/GetAllRequestOperationHandler.java | 63 +- .../GetAvailableServersOperationHandler.java | 63 - .../GetRegionNamesRequestOperationHandler.java | 6 +- .../GetRegionRequestOperationHandler.java | 14 +- .../v1/operations/GetRequestOperationHandler.java | 40 +- .../v1/operations/GetServerOperationHandler.java | 89 + .../protobuf/v1/operations/HandshakeHandler.java | 54 - .../v1/operations/ProtocolVersionHandler.java | 55 + .../operations/PutAllRequestOperationHandler.java | 37 +- .../v1/operations/PutRequestOperationHandler.java | 34 +- .../operations/RemoveRequestOperationHandler.java | 30 +- .../protobuf/v1/operations/VersionValidator.java | 10 +- .../AuthenticationRequestOperationHandler.java | 10 +- .../registry/ProtobufOperationContextRegistry.java | 10 +- .../v1/serializer/ProtobufProtocolSerializer.java | 1 + .../ProtobufConnectionHandshakeStateProcessor.java | 6 +- .../v1/utilities/ProtobufPrimitiveTypes.java | 49 - .../v1/utilities/ProtobufRequestUtilities.java | 5 +- .../v1/utilities/ProtobufResponseUtilities.java | 4 +- .../protobuf/v1/utilities/ProtobufUtilities.java | 168 +- .../exception/UnknownProtobufEncodingType.java | 24 + .../exception/UnknownProtobufPrimitiveType.java | 24 - .../internal/protocol/TestExecutionContext.java | 4 +- ...TypeToSerializationTypeTranslatorJUnitTest.java | 56 - .../protobuf/v1/AuthenticationIntegrationTest.java | 9 +- .../protobuf/v1/AuthorizationIntegrationTest.java | 4 +- .../protocol/protobuf/v1/ErrorCodesJUnitTest.java | 45 + .../protobuf/v1/HandshakeIntegrationTest.java | 147 - .../internal/protocol/protobuf/v1/MessageUtil.java | 32 +- .../v1/ProtocolVersionIntegrationTest.java | 143 + .../v1/acceptance/CacheConnectionJUnitTest.java | 6 +- .../CacheConnectionTimeoutJUnitTest.java | 2 +- .../v1/acceptance/CacheOperationsJUnitTest.java | 33 +- .../LocatorConnectionAuthenticationDUnitTest.java | 156 + .../v1/acceptance/LocatorConnectionDUnitTest.java | 18 +- .../GetAllRequestOperationHandlerJUnitTest.java | 32 +- .../GetAndPutJsonDocumentsDUnitTest.java | 248 + ...tAvailableServersOperationHandlerJUnitTest.java | 113 - ...egionNamesRequestOperationHandlerJUnitTest.java | 5 +- .../GetRegionRequestOperationHandlerJUnitTest.java | 7 +- .../GetRequestOperationHandlerJUnitTest.java | 38 +- .../GetServerOperationHandlerJUnitTest.java | 104 + .../v1/operations/HandshakeHandlerJUnitTest.java | 140 - .../v1/operations/OperationHandlerJUnitTest.java | 9 +- .../ProtocolVersionHandlerJUnitTest.java | 126 + .../PutAllRequestOperationHandlerJUnitTest.java | 38 +- .../PutRequestOperationHandlerJUnitTest.java | 44 +- .../RemoveRequestOperationHandlerJUnitTest.java | 35 +- .../v1/operations/VersionValidatorJUnitTest.java | 14 +- .../v1/serialization/codec/JSONCodecJUnitTest.java | 231 - .../codec/JsonPdxConverterJUnitTest.java | 230 + .../registry/CodecRegistryJUnitTest.java | 49 - .../ProtobufProtocolSerializerJUnitTest.java | 1 + .../v1/utilities/ProtobufUtilitiesJUnitTest.java | 78 +- geode-pulse/build.gradle | 2 + geode-pulse/src/main/webapp/META-INF/NOTICE | 4 +- .../internal/security/LogoutHandlerUnitTest.java | 4 +- .../wan/GatewaySenderEventRemoteDispatcher.java | 27 +- .../wan/GatewayReceiverFactoryImplJUnitTest.java | 2 + ...atewaySenderEventRemoteDispatcherJUnitTest.java | 45 + .../geode/internal/cache/wan/WANTestBase.java | 393 +- .../cache/wan/misc/PDXNewWanDUnitTest.java | 11 +- .../cache/wan/misc/WANConfigurationJUnitTest.java | 10 +- ...CreateDestroyGatewaySenderCommandDUnitTest.java | 45 +- .../CreateGatewayReceiverCommandDUnitTest.java | 131 +- .../PauseGatewaySenderCommandDUnitTest.java | 24 +- .../ResumeGatewaySenderCommandDUnitTest.java | 24 +- .../StartGatewayReceiverCommandDUnitTest.java | 24 +- .../StartGatewaySenderCommandDUnitTest.java | 20 +- .../StatusGatewayReceiverCommandDUnitTest.java | 28 +- .../StatusGatewaySenderCommandDUnitTest.java | 28 +- .../StopGatewayReceiverCommandDUnitTest.java | 24 +- .../StopGatewaySenderCommandDUnitTest.java | 20 +- .../cache/wan/wancommand/WANCommandUtils.java | 30 +- .../wan/wancommand/WanCommandListDUnitTest.java | 48 +- .../geode/management/WANManagementDUnitTest.java | 374 +- .../cli/commands/DescribeRegionDUnitTest.java | 4 +- ...rConfigurationIndexWithFromClauseDUnitTest.java | 4 +- .../WANClusterConfigurationDUnitTest.java | 15 +- .../internal/pulse/TestRemoteClusterDUnitTest.java | 250 - geode-web-api/build.gradle | 1 + .../web/controllers/AbstractBaseController.java | 4 +- geode-web-api/src/main/webapp/META-INF/NOTICE | 4 +- geode-web/src/main/webapp/META-INF/NOTICE | 2 +- .../cli/commands/AlterRuntimeCommandDUnitTest.java | 58 +- .../commands/ClusterConfigurationDUnitTest.java | 6 +- .../cli/commands/CommandOverHttpDUnitTest.java | 3 +- .../cli/commands/ConnectCommandWithSSLTest.java | 4 +- .../commands/DescribeConfigCommandDUnitTest.java | 8 +- ...xecuteFunctionCommandWithSecurityDUnitTest.java | 4 +- .../cli/commands/ExportConfigCommandDUnitTest.java | 8 +- .../commands/ExportLogsStatsOverHttpDUnitTest.java | 2 +- .../internal/security/LogNoPasswordTest.java | 4 +- .../internal/web/util/ConvertUtilsJUnitTest.java | 185 - gradle.properties | 2 +- gradle/dependency-versions.properties | 12 +- gradle/test.gradle | 2 +- settings.gradle | 3 +- 1087 files changed, 34611 insertions(+), 16778 deletions(-) create mode 100755 ci/scripts/build-examples.sh create mode 100755 ci/scripts/update-passing-ref.sh create mode 100644 extensions/geode-modules/src/test/java/org/apache/geode/modules/util/ModuleFunctionsSecurityTest.java create mode 100644 geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/DeployWithLargeJarTest.java delete mode 100644 geode-benchmarks/build.gradle delete mode 100644 geode-benchmarks/src/jmh/java/org/apache/geode/cache/benchmark/RangeQueryWithIndexBenchmark.java delete mode 100644 geode-benchmarks/src/jmh/java/org/apache/geode/cache/benchmark/RegionOperationBenchmark.java create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/LocatorMessageExecutionContext.java create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/ProtocolSerializer.java create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/ServerMessageExecutionContext.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/serializer/ProtocolSerializer.java create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/JsonPdxConverter.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/TypeCodec.java create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/TypeConverter.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/codec/JSONCodec.java create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/exception/EncodingException.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/exception/UnsupportedEncodingTypeException.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/registry/SerializationCodecRegistry.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/registry/exception/CodecAlreadyRegisteredForTypeException.java delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/serialization/registry/exception/CodecNotRegisteredForTypeException.java delete mode 100644 geode-client-protocol/src/main/resources/META-INF/services/org.apache.geode.internal.protocol.serialization.TypeCodec create mode 100644 geode-connectors/build.gradle create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriter.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcLoader.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/JdbcWriter.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/AbstractJdbcCallback.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/ColumnValue.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/ConnectionConfigBuilder.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/ConnectionConfigExistsException.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/ConnectionConfigNotFoundException.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/ConnectionConfiguration.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/DataSourceManager.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/HikariJdbcDataSource.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/HikariJdbcDataSourceFactory.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/JdbcConnectorService.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/JdbcConnectorServiceImpl.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/JdbcDataSource.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/JdbcDataSourceFactory.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/RegionMapping.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/RegionMappingBuilder.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/RegionMappingExistsException.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/RegionMappingNotFoundException.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/SqlHandler.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/SqlStatementFactory.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/TableKeyColumnManager.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterConnectionCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterConnectionFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateConnectionCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateConnectionFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeConnectionCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeConnectionFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyConnectionCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyConnectionFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/ExceptionHandler.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/FunctionContextArgumentProvider.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcCliFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/ListConnectionCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/ListConnectionFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommand.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingFunction.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/ElementType.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlGenerator.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlParser.java create mode 100644 geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcServiceConfiguration.java create mode 100644 geode-connectors/src/main/resources/META-INF/services/org.apache.geode.internal.cache.CacheService create mode 100644 geode-connectors/src/main/resources/META-INF/services/org.apache.geode.internal.cache.xmlcache.XmlParser create mode 100644 geode-connectors/src/main/resources/META-INF/services/org.springframework.shell.core.CommandMarker create mode 100644 geode-connectors/src/main/resources/META-INF/services/schemas/geode.apache.org/schema/jdbc/jdbc-1.0.xsd create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/Employee.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriterIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcAsyncWriterTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcLoaderIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcLoaderTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcWriterIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/JdbcWriterTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/AbstractJdbcCallbackTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/ColumnValueTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/ConnectionConfigBuilderTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/ConnectionConfigurationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/DataSourceManagerUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/JdbcConnectorServiceTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/RegionMappingBuilderTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/RegionMappingTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/SqlHandlerTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/SqlStatementFactoryTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/TableKeyColumnManagerTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/TestConfigService.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/TestableConnectionManager.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterConnectionCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterConnectionCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterConnectionFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateConnectionCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateConnectionCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateConnectionFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeConnectionCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeConnectionCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeConnectionFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyConnectionCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyConnectionCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyConnectionFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandDunitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/FunctionContextArgumentProviderTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/JDBCConnectorFunctionsSecurityTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcCliFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcClusterConfigDistributedTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListConnectionCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListConnectionCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListConnectionFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandDUnitTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingFunctionTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/ElementTypeTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlGeneratorIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlGeneratorTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlIntegrationTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlParserTest.java create mode 100644 geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcServiceConfigurationTest.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/CreateOnRegionBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/CreateWithEvictionUnderLimitBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/EvictionBasePerformanceBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/EvictionMultiThreadedPerformanceBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/EvictionWithPartiallyMarkedListsBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/FirstEvictionBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/GetOnRegionBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/GetsWithEvictionPerformanceBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/RangeQueryWithIndexBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/RegionOperationBenchmark.java create mode 100644 geode-core/src/jmh/java/org/apache/geode/cache/UpdateOnRegionBenchmark.java create mode 100644 geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java delete mode 100644 geode-core/src/main/java/org/apache/geode/distributed/internal/DM.java delete mode 100644 geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionChannel.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupDefinition.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupDestination.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FileSystemBackupDestination.java create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/beans/FileUploader.java create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/beans/FileUploaderMBean.java create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/cli/commands/DestroyAsyncEventQueueCommand.java create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/DestroyAsyncEventQueueFunction.java create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/DestroyAsyncEventQueueFunctionArgs.java create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/configuration/functions/DownloadJarFunction.java delete mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/configuration/functions/UploadJarFunction.java delete mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/web/util/ConvertUtils.java create mode 100644 geode-core/src/test/java/org/apache/geode/cache/query/internal/index/PartitionedIndexJUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/ClusterDistributionManagerDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/ClusterDistributionManagerForAdminDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/ClusterDistributionManagerTest.java delete mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/ConsoleDistributionManagerDUnitTest.java delete mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerDUnitTest.java delete mode 100644 geode-core/src/test/java/org/apache/geode/distributed/internal/DistributionManagerTest.java create mode 100755 geode-core/src/test/java/org/apache/geode/internal/InternalDataSerializerJUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/DiskStoreImplIntegrationTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupDefinitionTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FileSystemBackupDestinationTest.java delete mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/HAInterestDistributedTestCase.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/beans/FileUploaderTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ConnectCommandDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DeployCommandTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DestroyAsyncEventQueueCommandDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DestroyAsyncEventQueueCommandTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ExportStackTraceCommandDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ExportStackTraceCommandTest.java delete mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ShowStackTraceDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/functions/DestroyAsyncEventQueueFunctionTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/result/FileResultTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/security/FileUploaderMBeanSecurityTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/security/JmxPasswordFileTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/ClientVM.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/ClusterStartupRule.java delete mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/LocatorServerStartupRule.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/ClusterStartupRuleCanSpecifyOlderVersionsDUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/junit/rules/ClientCacheRule.java create mode 100644 geode-core/src/test/java/org/apache/geode/test/junit/rules/VMProvider.java create mode 100644 geode-core/src/test/resources/org/apache/geode/cache/execute/FunctionAdapterJUnitTest.serializedFunctionAdapterWithDifferentSerialVersionUID.ser create mode 100644 geode-experimental-driver/build.gradle create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/Driver.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/DriverFactory.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/JSONWrapper.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/ProtobufDriver.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/ProtobufRegion.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/Region.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/RegionAttributes.java create mode 100644 geode-experimental-driver/src/main/java/org/apache/geode/experimental/driver/ValueEncoder.java create mode 100644 geode-experimental-driver/src/test/java/org/apache/geode/experimental/driver/DriverConnectionTest.java create mode 100644 geode-experimental-driver/src/test/java/org/apache/geode/experimental/driver/RegionIntegrationTest.java create mode 100644 geode-experimental-driver/src/test/java/org/apache/geode/experimental/driver/ValueEncoderTest.java create mode 100644 geode-junit/src/main/java/org/apache/geode/test/junit/rules/ExecutorServiceRule.java create mode 100644 geode-junit/src/test/java/org/apache/geode/test/junit/rules/ExecutorServiceRuleIntegrationTest.java create mode 100644 geode-junit/src/test/java/org/apache/geode/test/junit/rules/ExecutorServiceRuleTest.java create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/test/LuceneFunctionSecurityTest.java delete mode 100644 geode-protobuf-messages/src/main/proto/handshake.proto create mode 100644 geode-protobuf-messages/src/main/proto/protocolVersion.proto create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/operations/ProtobufOperationHandler.java delete mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/EncodingTypeTranslator.java delete mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/ProtobufLocatorPipeline.java delete mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/GetAvailableServersOperationHandler.java create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/GetServerOperationHandler.java delete mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/HandshakeHandler.java create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ProtocolVersionHandler.java delete mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/utilities/ProtobufPrimitiveTypes.java create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/utilities/exception/UnknownProtobufEncodingType.java delete mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/utilities/exception/UnknownProtobufPrimitiveType.java delete mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/EncodingTypeToSerializationTypeTranslatorJUnitTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/ErrorCodesJUnitTest.java delete mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/HandshakeIntegrationTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/ProtocolVersionIntegrationTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/acceptance/LocatorConnectionAuthenticationDUnitTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/GetAndPutJsonDocumentsDUnitTest.java delete mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/GetAvailableServersOperationHandlerJUnitTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/GetServerOperationHandlerJUnitTest.java delete mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/HandshakeHandlerJUnitTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ProtocolVersionHandlerJUnitTest.java delete mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/serialization/codec/JSONCodecJUnitTest.java create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/serialization/codec/JsonPdxConverterJUnitTest.java delete mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/serialization/registry/CodecRegistryJUnitTest.java create mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcherJUnitTest.java delete mode 100644 geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java delete mode 100644 geode-web/src/test/java/org/apache/geode/management/internal/web/util/ConvertUtilsJUnitTest.java -- To stop receiving notification emails like this one, please contact ['"commits@geode.apache.org" <commits@geode.apache.org>'].