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>'].
