You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2018/01/21 01:45:14 UTC
[geode] branch feature/GEODE-3967 updated (e2bf74c -> 6805477)
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEODE-3967
in repository https://gitbox.apache.org/repos/asf/geode.git.
from e2bf74c GEODE-3938: Allow query parameters within the to_date preset query function (#1003)
add 080730b GEODE-3801: Use hardlinks for backup oplog files (#963)
add 11a385e GEODE-3940: fix deadlock in backup messages
add 0e5dd6b GEODE-3007: Simplify support for custom GFSH commands (#1042)
add 7f0d5f5 GEODE-1920 Addition of more logs to the test
add 478665f Revert "GEODE-1920 Addition of more logs to the test"
add ad786a5 Merge remote-tracking branch 'origin/develop' into feature/GEODE-3940
add d59c730 Merge pull request #1053 from apache/feature/GEODE-3940
add c1db889 GEODE-1897: Ensure that eviction-object-sizer also implements Declarable (#1068)
add 9d72237 GEODE-3761 Document the deprecation of manual start of gateway senders - updated wording per reviewer feedback.
add d5e0462 GEODE-3985: rolling upgrade tests is prone to accidentally roll the vms back to current version (#1067)
add 245a4ff GEODE-3982: MemoryIndexStoreIterator should not call GemFireCacheImpl (#1064)
add 2b21e2b Revert "GEODE-3007: Simplify support for custom GFSH commands (#1042)" (#1072)
add cd0b65a GEODE-3539: Restore and correct test coverage for 'describe connection' command.
add 445b304 GEODE-3341: Convert DiskStoreCommandsDUnitTest to use gfsh rules (#1062)
add 3a3935f GEODE-2676: fix NPE with ShowMetricsCommand.
add 526bcfc GEODE-3539: Add missing test coverage for 'list regions' and 'describe region' commands
add 0dd3c91 GEODE-3980: Remove unneeded additional findAvailablePids calls (#1076)
add a89fce1 GEODE-3999: Prevent prematurely running out of heap (#1078)
add bdc8251 commit dade94b3b5a3a3b2178a62e31edab27ccca40aa8 Merge: 526bcfc 73be2d9 Author: Bruce Schuchardt <bs...@pivotal.io> Date: Mon Nov 20 11:39:19 2017 -0800
add 6c345cd GEODE-2567: Add --if-exists to destroy disk-store (#1080)
add 862c4d2 GEODE-3995: Moving server_api.proto to locator_api.proto.
add 4b3db8b GEODE-3995: Moving server_api.proto to locator_api.proto. (#1074)
add 3a63e60 GEODE-2567: Update AnalyzeSerializables
add 37a8970 GEODE-3962: use function call to get cluster configuration from a locator (#1059)
add 717fa6b GEODE-1897: Acceptance test - users should be able to configure eviction through gfsh
add 7d80ee4 GEODE-3788: GfshParserRule enhancement (#1082)
add 10dc0a2 GEODE-3788: add utility methods to get the async event queues in the … (#1083)
add 9384423 User Guide - quick format fix for header of <cache> Element Hierarchy page
add f429e9a GEODE-3038: A server process shuts down quietly when path to cache.xml is incorrect (#677)
add 013b061 GEODE-3038: Run Spotless
add 57712d4 GEODE-4011: Disable test until we can fix it properly
add 0d5d2cb GEODE-3038 Fix suspect string found in logs during test run
add f3a0219 GEODE-3539: Add missing test coverage to 'list disk-stores' and 'describe disk-stores' commands
add b3f1c42 GEODE-4002 User Guide: Consolidate cache element descriptions
add 0277c09 GEODE-3969: Remove CallbackArgs from protobuf requests
add 9221905b Feature/GEODE 3996 (#1073)
add e286c4e GEODE-4015: Modified test Wait description to return actual value
add 40f3ed9 GEODE-3539: Add test coverage to 'alter disk-store'.
add a88a0a0 GEODE-1683: fix ClientAuthenticationDUnit test intermittent failures (#1092)
add 71fdfa9 GEODE-4014: use getVMCount instead of hardcoding number of VMs (#1089)
add c18cf17 GEODE-3063 partition resolver doc revisions (#1077)
add dd8cb9c Revert "GEODE-3063 partition resolver doc revisions (#1077)" (#1096)
add 375a8f6 GEODE-3242 Update docs with new --serializer option for (#1090)
add df0a856 GEODE-3539: add ability to stop a vm without clean out the working dir (#1094)
add e057702 GEODE-3788: add alter async-event-queue command and tests
add de794ff GEODE-4000: The serializerClass is actually introduced in 1.4 not 1.3. (#1097)
add 4e2560c GEODE-4011: Ensure that LogWrapper is closed correctly in GfshCommandRule (#1100)
add ba8f963 GEODE-3987: enforce GatewayReceiver uniqueness per member
add 41888fb GEODE-1897 Docs: configure eviction through gfsh (#1098)
add d891343 GEODE-3788: alter async event queue on a locator with no cluster config service. (#1101)
add de22c2d GEODE-3539: add test coverage for "create async-event-queue" and "lis… (#1093)
add 375d368 GEODE-3539: enhance rule to start locator joining other locators (#1104)
add d03b3f0 GEODE-4023: Add precheckin tests to pipeline.
add fa3a8db GEODE-1683: fix ClientAuthorizationDUnit test failures (#1106)
add d65763e GEODE-1897 Docs for gfsh eviction, minor correction.
add a2bd578 GEODE-3923 Provide whitelist/blacklist capability for java serialization
add 94153ce GEODE-4000: The serializerClass is actually introduced in 1.4 not 1.3
add 9ff9211 GEODE-3923 Provide whitelist/blacklist capability for java serialization
add c51a455 GEODE-3539: enhance GfshCommandRule (#1108)
add 465f2cd GEODE-1683: temp trial to fix clientAuthorizationDUnitTest (#1112)
add b2d37ec GEODE-3539: enhance GfshCommandRule. Renmame method for consistency. (#1111)
add 586f945 [GEODE-4023] Minor fixes for typos and complex gradle test types.
add 13876f6 GEODE-3788: add availability indicator for alter aeq command (#1107)
add 34928a6 GEODE-4042: Cargo tests will use java.io.tmpdir if possible, instead /tmp (#1114)
add 9c508e2 GEODE-4035: Refactor Converter classes (#1110)
add 7972b77 GEODE-4029: Deployed jars may not be correct when multiple locators a… (#1103)
add f504c7d GEODE-4033: Exception is thrown when Tx Id is not found on server dur… (#1115)
add b74de48 GEODE-4049: add convenience methods for easy mocking and reduce code duplication.
add 21820bc GEODE-4049: add convenience methods for easy mocking and reduce code duplication.
add 23382e6 GEODE-4049: refactor CreateRegionCommand and DestoryRegionCommand status
add 279072f GEODE-4042: Fixed additional tmp dir references (#1121)
add 5c9caf4 GEODE-3683 CacheConnectionTimeoutJUnitTest failing intermittently in CI
add 17369d1 GEODE-3923 Provide whitelist/blacklist capability for java serialization
add 9c1bd4b GEODE-4058: Always delete disk files after every test runs
add e8017b5 GEODE-4052: Extract GfshExitCodeStatusCommandsTest to multiple acceptance tests for better failure reporting.
add b033979 GEODE-3955: Preparing, refactoring, and addition of test utility
add 9636d67 GEODE-3955: Add AEQ and Gateway Sender information to 'describe region' output.
add 5063aca GEODE-4007: Authentication/Handshake errors should close the socket
add d6c978a GEODE-4053: Create module for Protobuf messages
add 1a291a4 GEODE-3622: Implement new algorithm for eviction (#1017)
add 9557eeb GEODE-3241 User can set a LuceneSerializer through XML (#1132)
add de90e71 GEODE-4068: Removing RemoveAll from .proto files
add 6fa9bf6 GEODE-3956: Add async-event-queue-ids and gateway-sender-ids to the R… (#1135)
add ab9d252 GEODE-3956: Remove inadvertently added test
add 15bb387 GEODE-4059: Changing protobuf handshake to not need communication mode bytes
add 32d41ca GEODE-3637: Reimplement client queue initialization. Adding shutdown logic
add c974780 GEODE-4070: Ignore SnapshotPerformanceDUnitTest (#1144)
add fa2687c GEODE-2668: build tabular command result from a list of function results (#1127)
add 6578ecc GEODE-4008: Added serialVersionUID to FunctionAdapter (#1119)
add eee9b2d GEODE-3976: improve exception message
add 36b4f5b Merge pull request #1146 from dschneider-pivotal/feature/GEODE-3976
add 36eeafe Revert "GEODE-4008: Added serialVersionUID to FunctionAdapter (#1119)"
add 57b9dbf GEODE-4073: Add ability for SuiteRunner to interleave a candidate test class (#1150)
add 1569dbf GEODE-4042: Passing down java.io.tmpdir to tests running in geode-assembly (#1145)
add d67359f GEODE-4074: Cleanup of PdxSerializers in TypeRegistry (#1151)
add 107eae6 GEODE-4072: Fixed race condition in AckThreadReader shutdown.
add 437b3cc Revert "GEODE-4042: Passing down java.io.tmpdir to tests running in geode-assembly (#1145)"
add 767682c GEODE-3964: More logging for suspect processing. (#1088)
add 08944b0 GEODE-3063 partition resolver doc revisions (#1105)
add a237203 GEODE-3929: GFSH create lucene index command allowed on existing regions.
add eb4e948 GEODE-4076: throw AuthenticationRequiredException instead of GemfireSecurityException (#1147)
add 33129b1 GEODE-4078: Display full path when locator view log cannot be opened (#1154)
add 4e1c63c GEODE-3869: Fix early eviction. (#1152)
add db30e3f GEODE-4081: update cluster config after destroy gateway sender (#1140)
add d06524d GEODE-4085 The cache server thinks that all protobuf clients have a 10 second read timeout
add 790bee0 GEODE-3956: Consistent naming for async event queue related variables (#1157)
add 82f4ebc GEODE-4070: Re-enable SnapshotPerformanceDUnitTest
add 7788c0d User Guide, Statistics reference: introduce product_name variable.
add b1486ae GEODE-4083: fix infinite loop caused by thread race changing version (#1161)
add fa48599 GEODE-4091: add ThreadFactory for evictor
add 2d73891 Merge pull request #1165 from dschneider-pivotal/feature/GEODE-4091
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)
add 4a0f565 GEODE-4286: Use canonical path for docker mounted volumes (#1275)
add bed35d3 GEODE-4101: Remove test assertions that mask failure information (#1276)
add 8afb56e GEODE-4252: User function execution produces correct errors (#1269)
add e7b29fa GEODE-4281: Move three security test classes out of production code.
add 522e70e GEODE-4101: Only check for specific command line arguments (#1278)
add 9eb82df GEODE-4293: Pulse works correctly when jmx-manager-password-file is set (#1279)
add 511e131 GEODE-2556 RollingUpgradeDUnitTest.testRollServersOnPersistentRegion_dataserializable[0] fails intermittently
add d0f5068 GEODE-4280 add the ability to close a Driver and to see if the driver is usable
add 6ceeb12 GEODE-4144: Do not client side event id if port has not been set(#1277)
add fb166cc GEODE-4257: change default of value-contains-primary-key (#1261)
add 7339fbc Feature/geode 3583 storage (#1285)
add cf31261 GEODE-4227 : Cluster config updated during Lucene Reindex (#1257)
add e662639 GEODE-4227: applying spotless
add 13364a3 GEODE-4290 add operation time statistics to the protobuf server
add c31a0f8 GEODE-4296 Protobuf driver should turn off TCP delay, or make it configurable
add 2a52890 GEODE-4292: Update scm refs in maven pom to github (#1280)
add e36e42b GEODE-4294 User Guide: Region level expiration is not supported for p… (#1282)
add e1434bd GEODE-4298: Restore public access to StartServer method.
add 6d1f2b6 GEODE-4291: Avoid asking user input in SocketCreator. (#1283)
add 2affe0f GEODE-3745 User Guide: Incomplete diagram, durable client
add 1ed9e94 GEODE-527: Fix race condition that caused sporadic test failure (#1296)
add 541f0d9 GEODE-4140: Avoid race condition in rolling upgrade tests.
add 6267bb5 GEODE-4303: Add assertions to nil test.
add da42607 GEODE-4285: Get a distributed lock if we can't find a PDX type
add fccdd15 GEODE-4310: allow ResourcePermission to take Strings as arguments for Resource and Operation. (#1300)
add f565ac1 GEODE-2275: Remove async creation of shared static resource (#1298)
add c9feba3 GEODE-4299: refactor eviction (#1290)
add ffee51a GEODE-4305: encapsulate the concurrencyChecksEnabled field (#1297)
add 501cfda GEODE-4147: Add variability to client rebalance logic.
add 893f5a6 GEODE-4316: Additional function deploy tests (#1303)
add 3504d51 GEODE-4304: use the gettor method for dataPolicy (#1295)
add f0d3f23 GEODE-4238: rewrite flaky region expiration tests (#1292)
add cb3baf3 GEODE-3322: Fix javadoc warnings
add 081aa75 Commit-then-review: updated Gemfile.lock file for building documentation
add 00be4f9 GEODE-3974: function security improvement (#1287)
add 75f2401 GEODE-4129: do not list coordinator as a different entry in list memb… (#1308)
add 90617d0 GEODE-427: Prevent out of order message processing (#1307)
add 33d7f4f GEODE-4275: Improved StartMemberUtils.addMaxHeap (#1270)
add 2d5ff11 GEODE-4061 Update docs output for gfsh list members; (#1309)
add e63aaf8 GEODE-4251: Removed the 2 second client timeout from the test
add 2d04130 GEODE-4312: Wait for rebalancing to complete as part of teardown (#1302)
add b1cb0e3 GEODE-4307: Removing some static calls to GemFireCacheImpl.getForPDX
new 6805477 GEODE-3967: when ConcurrentCacheModificationException happened. GatewaySenderEventImpl should save the status and notify gatewaysender anyway. SerialGatewaySender will handle it. In AbstractUpdateOperation's doPutOrCreate's 3 tries of basicUpdate, the 3rd one should allow both create and update.
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:
build.gradle | 3 +-
.../geode/gradle/TestPropertiesWriter.groovy | 1 -
ci/docker/Dockerfile | 36 +-
ci/docker/docker.list | 17 +
ci/docker/initdocker | 31 +
ci/docker/tini-wrapper.go | 42 +
ci/pipelines/develop.yml | 344 +-
ci/pipelines/docker-images.yml | 2 +-
ci/scripts/build-examples.sh | 26 +
ci/scripts/build.sh | 9 +-
ci/scripts/test-archive.sh | 122 +
ci/scripts/test-run.sh | 147 +
ci/scripts/update-passing-ref.sh | 28 +
.../SessionReplicationIntegrationJUnitTest.java | 688 +--
.../session/junit/PerTestClassLoaderRunner.java | 25 +-
extensions/geode-modules/build.gradle | 2 +-
.../gatewaydelta/GatewayDeltaCreateEvent.java | 4 +-
.../modules/session/catalina/DeltaSession.java | 2 +-
.../geode/modules/util/BootstrappingFunction.java | 28 +-
.../geode/modules/util/CreateRegionFunction.java | 38 +-
.../geode/modules/util/RegionSizeFunction.java | 27 +-
.../TouchPartitionedRegionEntriesFunction.java | 42 +-
.../util/TouchReplicatedRegionEntriesFunction.java | 46 +-
.../modules/util/ModuleFunctionsSecurityTest.java | 75 +
geode-assembly/build.gradle | 18 +-
geode-assembly/src/main/dist/NOTICE | 4 +-
.../cli/commands/ConfigureEvictionThroughGfsh.java | 219 +
.../cli/commands/DeployWithLargeJarTest.java | 47 +
.../cli/commands/DestroyIndexIfExistsTest.java | 49 +
.../LauncherLifecycleCommandsDUnitTest.java | 2 +-
.../StartLocatorCommandIntegrationTest.java | 6 -
.../cli/commands/StartLocatorCommandTest.java | 97 +
.../StartServerCommandIntegrationTest.java | 6 -
.../cli/commands/StartServerCommandTest.java | 84 +
.../cli/shell/GfshExitCodeStatusCommandsTest.java | 404 --
.../shell/StatusLocatorExitCodeAcceptanceTest.java | 267 ++
.../shell/StatusServerExitCodeAcceptanceTest.java | 207 +
.../controllers/RestAPIsAndInterOpsDUnitTest.java | 2 +-
.../web/controllers/RestAPIsWithSSLDUnitTest.java | 47 +-
.../geode/session/tests/ContainerInstall.java | 8 +-
.../session/tests/GenericAppServerContainer.java | 3 +-
.../session/tests/GenericAppServerInstall.java | 6 +-
.../geode/session/tests/ServerContainer.java | 4 +-
.../session/tests/TomcatClientServerTest.java | 4 +-
.../geode/test/junit/rules/HttpClientRule.java | 52 +-
.../geode/tools/pulse/PulseConnectivityTest.java | 4 +-
.../tools/pulse/PulseJmxPasswordFileTest.java | 62 +
.../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 -
geode-book/Gemfile.lock | 48 +-
.../source/subnavs/geode-subnav.erb | 136 +-
.../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 | 18 +-
.../protobuf/v1/serializer/ProtocolSerializer.java | 34 -
...ompatibleAuthenticationMechanismsException.java | 23 -
.../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 -
.../state/ConnectionHandshakingStateProcessor.java | 28 -
.../ConnectionShiroAuthorizingStateProcessor.java | 3 +-
.../protocol/state/ConnectionStateProcessor.java | 30 +-
.../state/ConnectionTerminatingStateProcessor.java | 34 +
.../LegacySecurityConnectionStateProcessor.java | 4 +-
.../exception/OperationNotAuthorizedException.java | 23 +
.../protocol/statistics/NoOpStatistics.java | 10 +
.../statistics/ProtocolClientStatistics.java | 12 +
...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 | 147 +
.../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 | 93 +
.../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 +
.../java/org/apache/geode/admin/GemFireHealth.java | 5 +-
.../apache/geode/admin/GemFireMemberStatus.java | 4 +-
.../admin/internal/AbstractHealthEvaluator.java | 4 +-
.../admin/internal/AdminDistributedSystemImpl.java | 37 +-
.../admin/internal/BackupDataStoreHelper.java | 74 -
.../admin/internal/BackupDataStoreResult.java | 48 -
.../geode/admin/internal/CacheHealthEvaluator.java | 8 +-
.../geode/admin/internal/CacheServerImpl.java | 7 +-
.../admin/internal/ConfigurationParameterImpl.java | 12 -
.../internal/DistributedSystemHealthEvaluator.java | 14 +-
.../admin/internal/DistributionLocatorImpl.java | 5 +-
.../geode/admin/internal/FinishBackupRequest.java | 174 -
.../geode/admin/internal/FinishBackupResponse.java | 76 -
.../geode/admin/internal/FlushToDiskRequest.java | 92 -
.../geode/admin/internal/FlushToDiskResponse.java | 43 -
.../admin/internal/GemFireHealthEvaluator.java | 4 +-
.../admin/internal/MemberHealthEvaluator.java | 4 +-
.../geode/admin/internal/PrepareBackupRequest.java | 134 -
.../admin/internal/PrepareBackupResponse.java | 80 -
.../internal/SystemMemberCacheEventProcessor.java | 4 +-
.../apache/geode/admin/jmx/internal/AgentImpl.java | 6 +-
.../geode/admin/jmx/internal/AgentLauncher.java | 4 +-
.../internal/ConfigurationParameterJmxImpl.java | 5 -
.../apache/geode/cache/CacheClosedException.java | 5 -
.../java/org/apache/geode/cache/CacheFactory.java | 2 +-
.../apache/geode/cache/DynamicRegionFactory.java | 5 +-
.../org/apache/geode/cache/EvictionAlgorithm.java | 6 +-
.../org/apache/geode/cache/EvictionAttributes.java | 44 +-
.../apache/geode/cache/RegionAccessException.java | 8 +-
.../geode/cache/RegionDistributionException.java | 8 +-
.../geode/cache/client/ClientCacheFactory.java | 3 +-
.../client/internal/CacheServerLoadMessage.java | 4 +-
.../cache/client/internal/OpExecutorImpl.java | 19 +-
.../geode/cache/client/internal/ProxyCache.java | 13 +-
.../geode/cache/client/internal/ProxyRegion.java | 2 +-
.../internal/pooling/ConnectionManagerImpl.java | 59 +-
.../geode/cache/execute/FunctionAdapter.java | 3 +
.../geode/cache/execute/FunctionContext.java | 21 +
.../org/apache/geode/cache/query/IndexType.java | 4 +
.../org/apache/geode/cache/query/QueryService.java | 24 +-
.../geode/cache/query/internal/DefaultQuery.java | 2 +-
.../cache/query/internal/ProxyQueryService.java | 2 +-
.../cache/query/internal/index/AbstractIndex.java | 5 +-
.../cache/query/internal/index/HashIndex.java | 5 +
.../query/internal/index/MemoryIndexStore.java | 2 +-
.../query/internal/index/PartitionedIndex.java | 3 +-
.../cache/query/internal/parse/GemFireAST.java | 3 +-
.../geode/cache/snapshot/SnapshotReader.java | 16 +-
.../geode/distributed/ConfigurationProperties.java | 27 +
.../geode/distributed/DistributedSystem.java | 6 +-
.../java/org/apache/geode/distributed/Locator.java | 9 +-
.../apache/geode/distributed/LocatorLauncher.java | 2 +-
.../apache/geode/distributed/ServerLauncher.java | 2 +-
.../internal/AbstractDistributionConfig.java | 3 +
.../internal/ClusterConfigurationService.java | 227 +-
.../internal/ClusterDistributionManager.java | 4577 ++++++++++++++++++
.../internal/CollectingReplyProcessor.java | 2 +-
.../org/apache/geode/distributed/internal/DM.java | 487 --
.../distributed/internal/DirectReplyProcessor.java | 23 +-
.../internal/DistributedSystemService.java | 26 +
.../distributed/internal/DistributionAdvisee.java | 4 +-
.../distributed/internal/DistributionAdvisor.java | 6 +-
.../distributed/internal/DistributionChannel.java | 162 -
.../distributed/internal/DistributionConfig.java | 48 +
.../internal/DistributionConfigImpl.java | 26 +-
.../distributed/internal/DistributionManager.java | 4841 +-------------------
.../distributed/internal/DistributionMessage.java | 28 +-
.../internal/DistributionMessageObserver.java | 20 +-
.../distributed/internal/HealthMonitorImpl.java | 4 +-
.../internal/HighPriorityAckedMessage.java | 6 +-
.../internal/HighPriorityDistributionMessage.java | 2 +-
.../internal/InternalDistributedSystem.java | 81 +-
.../distributed/internal/InternalLocator.java | 152 +-
.../distributed/internal/LocatorLoadSnapshot.java | 128 +-
.../internal/LonerDistributionManager.java | 46 +-
.../distributed/internal/MembershipListener.java | 2 +-
.../internal/OverflowQueueWithDMStats.java | 3 +-
.../internal/PooledDistributionMessage.java | 2 +-
.../geode/distributed/internal/ProductUseLog.java | 7 +-
.../internal/ReliableReplyProcessor21.java | 4 +-
.../geode/distributed/internal/ReplyMessage.java | 6 +-
.../distributed/internal/ReplyProcessor21.java | 179 +-
.../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 +-
.../internal/deadlock/GemFireDeadlockDetector.java | 5 +-
.../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 | 316 +-
.../org/apache/geode/internal/DSFIDFactory.java | 36 +-
.../geode/internal/DataSerializableFixedID.java | 10 +-
.../org/apache/geode/internal/DeployedJar.java | 100 +-
.../apache/geode/internal/DistributionLocator.java | 2 +-
.../geode/internal/EmptyInputStreamFilter.java | 24 +
.../apache/geode/internal/InputStreamFilter.java | 21 +
.../geode/internal/InternalDataSerializer.java | 105 +-
.../geode/internal/InternalInstantiator.java | 6 +-
.../org/apache/geode/internal/JarDeployer.java | 148 +-
.../java/org/apache/geode/internal/OSProcess.java | 45 +-
.../internal/ObjectInputStreamFilterWrapper.java | 94 +
.../org/apache/geode/internal/SystemAdmin.java | 2 +-
.../internal/admin/ClientMembershipMessage.java | 6 +-
.../geode/internal/admin/GfManagerAgent.java | 4 +-
.../geode/internal/admin/StatAlertsManager.java | 10 +-
.../admin/remote/AddStatListenerRequest.java | 2 +
.../remote/AdminConsoleDisconnectMessage.java | 4 +-
.../internal/admin/remote/AdminConsoleMessage.java | 9 +-
.../admin/remote/AdminFailureResponse.java | 36 +-
.../admin/remote/AdminMultipleReplyProcessor.java | 55 +-
.../geode/internal/admin/remote/AdminRequest.java | 7 +-
.../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/CacheInfoRequest.java | 2 +
.../internal/admin/remote/CancellationMessage.java | 2 +-
.../admin/remote/ChangeRefreshIntervalMessage.java | 4 +-
.../internal/admin/remote/CliLegacyMessage.java | 7 +-
.../internal/admin/remote/CompactRequest.java | 21 +-
.../internal/admin/remote/DestroyEntryMessage.java | 4 +-
.../admin/remote/DestroyRegionMessage.java | 4 +-
.../admin/remote/DurableClientInfoRequest.java | 2 +
.../admin/remote/FetchDistLockInfoRequest.java | 2 +
.../remote/FetchResourceAttributesResponse.java | 25 +-
.../internal/admin/remote/FetchStatsResponse.java | 14 +-
.../admin/remote/FlushAppCacheSnapshotMessage.java | 2 +-
.../admin/remote/HealthListenerMessage.java | 2 +-
.../internal/admin/remote/LicenseInfoRequest.java | 2 +
.../internal/admin/remote/LicenseInfoResponse.java | 5 +-
.../admin/remote/MissingPersistentIDsRequest.java | 19 +-
.../admin/remote/MissingPersistentIDsResponse.java | 5 +-
.../admin/remote/ObjectDetailsRequest.java | 2 +
.../internal/admin/remote/ObjectNamesRequest.java | 2 +
.../remote/PrepareRevokePersistentIDRequest.java | 12 +-
.../admin/remote/RegionAttributesRequest.java | 2 +
.../geode/internal/admin/remote/RegionRequest.java | 2 +
.../internal/admin/remote/RegionSizeRequest.java | 2 +
.../admin/remote/RemoteGfManagerAgent.java | 40 +-
.../admin/remote/ResetHealthStatusRequest.java | 2 +
.../admin/remote/RevokePersistentIDRequest.java | 7 +-
.../remote/ShutdownAllGatewayHubsRequest.java | 6 +-
.../internal/admin/remote/ShutdownAllRequest.java | 16 +-
.../admin/remote/SnapshotResultMessage.java | 2 +-
.../remote/StatAlertsManagerAssignMessage.java | 6 +-
.../internal/admin/remote/StatListenerMessage.java | 2 +-
.../internal/admin/remote/SubRegionRequest.java | 2 +
.../admin/remote/UpdateAlertDefinitionMessage.java | 4 +-
.../internal/admin/remote/VersionInfoRequest.java | 2 +
.../internal/cache/AbstractBucketRegionQueue.java | 16 +-
.../geode/internal/cache/AbstractCacheServer.java | 4 +-
.../internal/cache/AbstractDiskLRURegionEntry.java | 38 -
.../geode/internal/cache/AbstractDiskRegion.java | 32 +-
.../geode/internal/cache/AbstractLRURegionMap.java | 870 ----
.../geode/internal/cache/AbstractRegion.java | 76 +-
.../geode/internal/cache/AbstractRegionMap.java | 113 +-
.../internal/cache/AbstractUpdateOperation.java | 21 +-
.../cache/AddCacheServerProfileMessage.java | 4 +-
.../apache/geode/internal/cache/BackupLock.java | 99 -
.../apache/geode/internal/cache/BackupManager.java | 603 ---
.../apache/geode/internal/cache/BackupUtil.java | 75 -
.../apache/geode/internal/cache/BucketAdvisor.java | 9 +-
.../internal/cache/BucketPersistenceAdvisor.java | 2 +-
.../apache/geode/internal/cache/BucketRegion.java | 41 +-
.../geode/internal/cache/BucketRegionEvictior.java | 60 -
.../internal/cache/CacheDistributionAdvisor.java | 9 +-
.../geode/internal/cache/CacheServerAdvisor.java | 8 +-
.../geode/internal/cache/CacheServerImpl.java | 5 +-
.../geode/internal/cache/CachedDeserializable.java | 3 +-
.../cache/CachedDeserializableFactory.java | 15 +-
.../geode/internal/cache/CloseCacheMessage.java | 6 +-
.../internal/cache/ClusterConfigurationLoader.java | 193 +-
.../geode/internal/cache/ControllerAdvisor.java | 9 +-
.../internal/cache/CreateRegionProcessor.java | 9 +-
.../geode/internal/cache/DestroyOperation.java | 6 +-
.../cache/DestroyPartitionedRegionMessage.java | 4 +-
.../internal/cache/DestroyRegionOperation.java | 12 +-
.../geode/internal/cache/DirectReplyMessage.java | 7 +-
.../geode/internal/cache/DirectoryHolder.java | 2 +-
.../apache/geode/internal/cache/DiskInitFile.java | 3 -
.../apache/geode/internal/cache/DiskRegion.java | 18 +-
.../geode/internal/cache/DiskStoreBackup.java | 2 -
.../geode/internal/cache/DiskStoreFactoryImpl.java | 1 +
.../apache/geode/internal/cache/DiskStoreImpl.java | 100 +-
.../geode/internal/cache/DiskStoreMonitor.java | 76 +-
.../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 +-
.../apache/geode/internal/cache/DistTXState.java | 25 +-
.../internal/cache/DistTXStateOnCoordinator.java | 27 +-
.../geode/internal/cache/DistTXStateProxyImpl.java | 15 +-
.../cache/DistTXStateProxyImplOnCoordinator.java | 45 +-
.../cache/DistTXStateProxyImplOnDatanode.java | 9 +-
.../internal/cache/DistributedCacheOperation.java | 21 +-
.../internal/cache/DistributedClearOperation.java | 8 +-
.../internal/cache/DistributedPutAllOperation.java | 6 +-
.../geode/internal/cache/DistributedRegion.java | 69 +-
.../DistributedRegionFunctionStreamingMessage.java | 37 +-
.../cache/DistributedRemoveAllOperation.java | 4 +-
.../cache/DistributedTombstoneOperation.java | 8 +-
.../apache/geode/internal/cache/EntriesMap.java | 5 +-
.../geode/internal/cache/EntryEventImpl.java | 173 +-
.../org/apache/geode/internal/cache/EventID.java | 4 +-
.../geode/internal/cache/EventStateHelper.java | 5 +-
.../geode/internal/cache/EvictableRegion.java | 36 +
.../internal/cache/EvictionAttributesImpl.java | 105 +-
.../cache/EvictionAttributesMutatorImpl.java | 36 +
.../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 | 116 +-
.../apache/geode/internal/cache/GridAdvisor.java | 11 +-
.../org/apache/geode/internal/cache/HARegion.java | 2 +-
...ava~d2263ebc2... Create HasDiskRegion interface | 22 +
.../internal/cache/InitialImageFlowControl.java | 16 +-
.../internal/cache/InitialImageOperation.java | 160 +-
.../apache/geode/internal/cache/InternalCache.java | 21 +-
.../geode/internal/cache/InternalRegion.java | 34 +-
.../geode/internal/cache/InvalidateOperation.java | 8 +-
.../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 | 275 +-
.../geode/internal/cache/LocalRegionDataView.java | 4 +-
.../cache/MemberFunctionStreamingMessage.java | 42 +-
.../geode/internal/cache/NonLocalRegionEntry.java | 36 +-
.../org/apache/geode/internal/cache/Oplog.java | 83 +-
.../internal/cache/PRHARedundancyProvider.java | 10 +-
.../internal/cache/PartitionAttributesImpl.java | 3 +-
.../cache/PartitionRegionConfigValidator.java | 2 +-
.../geode/internal/cache/PartitionedRegion.java | 75 +-
.../internal/cache/PartitionedRegionDataStore.java | 12 +-
.../internal/cache/PartitionedRegionHelper.java | 18 +-
.../internal/cache/PausedTXStateProxyImpl.java | 3 +-
.../internal/cache/PlaceHolderDiskRegion.java | 18 +-
.../geode/internal/cache/ProxyBucketRegion.java | 4 +-
.../geode/internal/cache/ProxyRegionMap.java | 72 +-
.../geode/internal/cache/QueuedOperation.java | 2 +-
.../apache/geode/internal/cache/RegionEntry.java | 14 +-
.../geode/internal/cache/RegionEntryContext.java | 12 +-
.../geode/internal/cache/RegionEvictorTask.java | 141 -
.../org/apache/geode/internal/cache/RegionMap.java | 29 +-
.../geode/internal/cache/RegionMapFactory.java | 2 +-
.../apache/geode/internal/cache/RegionStatus.java | 5 +-
.../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 | 13 +-
.../internal/cache/RemoteInvalidateMessage.java | 22 +-
.../internal/cache/RemoteOperationMessage.java | 33 +-
.../RemoteOperationMessageWithDirectReply.java | 6 +-
.../geode/internal/cache/RemotePutAllMessage.java | 14 +-
.../geode/internal/cache/RemotePutMessage.java | 18 +-
.../internal/cache/RemoteRegionOperation.java | 6 +-
.../internal/cache/RemoteRemoveAllMessage.java | 14 +-
.../cache/SearchLoadAndWriteProcessor.java | 70 +-
.../geode/internal/cache/ServerPingMessage.java | 6 +-
.../geode/internal/cache/StateFlushOperation.java | 84 +-
.../geode/internal/cache/TXCommitMessage.java | 51 +-
.../apache/geode/internal/cache/TXEntryState.java | 9 +-
.../geode/internal/cache/TXFarSideCMTracker.java | 11 +-
.../apache/geode/internal/cache/TXManagerImpl.java | 26 +-
.../org/apache/geode/internal/cache/TXMessage.java | 18 +-
.../internal/cache/TXRegionLockRequestImpl.java | 33 +-
.../apache/geode/internal/cache/TXRegionState.java | 4 +-
.../internal/cache/TXRemoteCommitMessage.java | 9 +-
.../internal/cache/TXRemoteRollbackMessage.java | 4 +-
.../org/apache/geode/internal/cache/TXState.java | 4 +-
.../geode/internal/cache/TXStateInterface.java | 4 +-
.../geode/internal/cache/TXStateProxyImpl.java | 122 +-
.../apache/geode/internal/cache/TXStateStub.java | 56 +-
.../internal/cache/TXSynchronizationRunnable.java | 36 +-
.../geode/internal/cache/TombstoneService.java | 2 +-
.../internal/cache/UpdateAttributesProcessor.java | 13 +-
.../cache/UpdateEntryVersionOperation.java | 6 +-
.../geode/internal/cache/UpdateOperation.java | 12 +-
.../internal/cache/VMCachedDeserializable.java | 18 +-
.../geode/internal/cache/VMLRURegionMap.java | 784 +++-
.../apache/geode/internal/cache/VMRegionMap.java | 3 -
.../geode/internal/cache/ValidatingDiskRegion.java | 21 +-
.../cache/backup/BackupDataStoreHelper.java | 77 +
.../cache/backup/BackupDataStoreResult.java | 48 +
.../internal/cache/backup/BackupDefinition.java | 83 +
.../internal/cache/backup/BackupDestination.java | 28 +
.../internal/cache/backup/BackupInspector.java | 174 +
.../geode/internal/cache/backup/BackupLock.java | 114 +
.../geode/internal/cache/backup/BackupManager.java | 661 +++
.../internal/cache/backup/BackupOperation.java | 85 +
.../cache/backup/BackupReplyProcessor.java | 59 +
.../internal/cache/backup/BackupResponse.java | 69 +
.../cache/backup/BackupResultCollector.java | 24 +
.../geode/internal/cache/backup/BackupUtil.java | 73 +
.../cache/backup/FileSystemBackupDestination.java | 145 +
.../geode/internal/cache/backup/FinishBackup.java | 47 +
.../internal/cache/backup/FinishBackupFactory.java | 49 +
.../cache/backup/FinishBackupOperation.java | 75 +
.../internal/cache/backup/FinishBackupRequest.java | 100 +
.../geode/internal/cache/backup/FlushToDisk.java | 33 +
.../internal/cache/backup/FlushToDiskFactory.java | 43 +
.../cache/backup/FlushToDiskOperation.java | 85 +
.../cache/backup/FlushToDiskProcessor.java | 38 +
.../internal/cache/backup/FlushToDiskRequest.java | 57 +
.../internal/cache/backup/FlushToDiskResponse.java | 43 +
.../geode/internal/cache/backup/PrepareBackup.java | 44 +
.../cache/backup/PrepareBackupFactory.java | 45 +
.../cache/backup/PrepareBackupOperation.java | 65 +
.../cache/backup/PrepareBackupRequest.java | 73 +
.../geode/internal/cache/backup/RestoreScript.java | 151 +
.../internal/cache/backup/ScriptGenerator.java | 38 +
.../internal/cache/backup/UnixBackupInspector.java | 73 +
.../internal/cache/backup/UnixScriptGenerator.java | 69 +
.../cache/backup/WindowsBackupInspector.java | 81 +
.../cache/backup/WindowsScriptGenerator.java | 93 +
.../client/protocol/ClientProtocolProcessor.java | 5 +
.../client/protocol/ClientProtocolService.java | 3 +-
.../protocol/ClientProtocolServiceLoader.java | 6 +-
.../CompressedCachedDeserializable.java | 2 +-
.../internal/cache/control/ResourceAdvisor.java | 12 +-
.../cache/entries/AbstractDiskLRURegionEntry.java | 34 +
.../cache/entries/AbstractDiskRegionEntry.java | 2 +-
.../cache/entries/AbstractLRURegionEntry.java | 20 +-
.../entries/AbstractOplogDiskRegionEntry.java | 8 +-
.../cache/entries/AbstractRegionEntry.java | 147 +-
.../geode/internal/cache/entries/DiskEntry.java | 75 +-
.../internal/cache/entries/LeafRegionEntry.cpp | 68 +-
.../cache/entries/VMStatsDiskLRURegionEntry.java | 1 -
.../VMStatsDiskLRURegionEntryHeapIntKey.java | 53 +-
.../VMStatsDiskLRURegionEntryHeapLongKey.java | 53 +-
.../VMStatsDiskLRURegionEntryHeapObjectKey.java | 53 +-
.../VMStatsDiskLRURegionEntryHeapStringKey1.java | 53 +-
.../VMStatsDiskLRURegionEntryHeapStringKey2.java | 53 +-
.../VMStatsDiskLRURegionEntryHeapUUIDKey.java | 53 +-
.../VMStatsDiskLRURegionEntryOffHeapIntKey.java | 53 +-
.../VMStatsDiskLRURegionEntryOffHeapLongKey.java | 53 +-
.../VMStatsDiskLRURegionEntryOffHeapObjectKey.java | 53 +-
...VMStatsDiskLRURegionEntryOffHeapStringKey1.java | 53 +-
...VMStatsDiskLRURegionEntryOffHeapStringKey2.java | 53 +-
.../VMStatsDiskLRURegionEntryOffHeapUUIDKey.java | 53 +-
.../entries/VMStatsDiskRegionEntryHeapIntKey.java | 8 +-
.../entries/VMStatsDiskRegionEntryHeapLongKey.java | 8 +-
.../VMStatsDiskRegionEntryHeapObjectKey.java | 8 +-
.../VMStatsDiskRegionEntryHeapStringKey1.java | 8 +-
.../VMStatsDiskRegionEntryHeapStringKey2.java | 8 +-
.../entries/VMStatsDiskRegionEntryHeapUUIDKey.java | 8 +-
.../VMStatsDiskRegionEntryOffHeapIntKey.java | 8 +-
.../VMStatsDiskRegionEntryOffHeapLongKey.java | 8 +-
.../VMStatsDiskRegionEntryOffHeapObjectKey.java | 8 +-
.../VMStatsDiskRegionEntryOffHeapStringKey1.java | 8 +-
.../VMStatsDiskRegionEntryOffHeapStringKey2.java | 8 +-
.../VMStatsDiskRegionEntryOffHeapUUIDKey.java | 8 +-
.../entries/VMStatsLRURegionEntryHeapIntKey.java | 49 +-
.../entries/VMStatsLRURegionEntryHeapLongKey.java | 49 +-
.../VMStatsLRURegionEntryHeapObjectKey.java | 49 +-
.../VMStatsLRURegionEntryHeapStringKey1.java | 49 +-
.../VMStatsLRURegionEntryHeapStringKey2.java | 49 +-
.../entries/VMStatsLRURegionEntryHeapUUIDKey.java | 49 +-
.../VMStatsLRURegionEntryOffHeapIntKey.java | 49 +-
.../VMStatsLRURegionEntryOffHeapLongKey.java | 49 +-
.../VMStatsLRURegionEntryOffHeapObjectKey.java | 49 +-
.../VMStatsLRURegionEntryOffHeapStringKey1.java | 49 +-
.../VMStatsLRURegionEntryOffHeapStringKey2.java | 49 +-
.../VMStatsLRURegionEntryOffHeapUUIDKey.java | 49 +-
.../entries/VMStatsRegionEntryHeapIntKey.java | 4 +-
.../entries/VMStatsRegionEntryHeapLongKey.java | 4 +-
.../entries/VMStatsRegionEntryHeapObjectKey.java | 4 +-
.../entries/VMStatsRegionEntryHeapStringKey1.java | 4 +-
.../entries/VMStatsRegionEntryHeapStringKey2.java | 4 +-
.../entries/VMStatsRegionEntryHeapUUIDKey.java | 4 +-
.../entries/VMStatsRegionEntryOffHeapIntKey.java | 4 +-
.../entries/VMStatsRegionEntryOffHeapLongKey.java | 4 +-
.../VMStatsRegionEntryOffHeapObjectKey.java | 4 +-
.../VMStatsRegionEntryOffHeapStringKey1.java | 4 +-
.../VMStatsRegionEntryOffHeapStringKey2.java | 4 +-
.../entries/VMStatsRegionEntryOffHeapUUIDKey.java | 4 +-
.../cache/entries/VMThinDiskLRURegionEntry.java | 1 -
.../VMThinDiskLRURegionEntryHeapIntKey.java | 53 +-
.../VMThinDiskLRURegionEntryHeapLongKey.java | 53 +-
.../VMThinDiskLRURegionEntryHeapObjectKey.java | 53 +-
.../VMThinDiskLRURegionEntryHeapStringKey1.java | 53 +-
.../VMThinDiskLRURegionEntryHeapStringKey2.java | 53 +-
.../VMThinDiskLRURegionEntryHeapUUIDKey.java | 53 +-
.../VMThinDiskLRURegionEntryOffHeapIntKey.java | 53 +-
.../VMThinDiskLRURegionEntryOffHeapLongKey.java | 53 +-
.../VMThinDiskLRURegionEntryOffHeapObjectKey.java | 53 +-
.../VMThinDiskLRURegionEntryOffHeapStringKey1.java | 53 +-
.../VMThinDiskLRURegionEntryOffHeapStringKey2.java | 53 +-
.../VMThinDiskLRURegionEntryOffHeapUUIDKey.java | 53 +-
.../entries/VMThinDiskRegionEntryHeapIntKey.java | 8 +-
.../entries/VMThinDiskRegionEntryHeapLongKey.java | 8 +-
.../VMThinDiskRegionEntryHeapObjectKey.java | 8 +-
.../VMThinDiskRegionEntryHeapStringKey1.java | 8 +-
.../VMThinDiskRegionEntryHeapStringKey2.java | 8 +-
.../entries/VMThinDiskRegionEntryHeapUUIDKey.java | 8 +-
.../VMThinDiskRegionEntryOffHeapIntKey.java | 8 +-
.../VMThinDiskRegionEntryOffHeapLongKey.java | 8 +-
.../VMThinDiskRegionEntryOffHeapObjectKey.java | 8 +-
.../VMThinDiskRegionEntryOffHeapStringKey1.java | 8 +-
.../VMThinDiskRegionEntryOffHeapStringKey2.java | 8 +-
.../VMThinDiskRegionEntryOffHeapUUIDKey.java | 8 +-
.../entries/VMThinLRURegionEntryHeapIntKey.java | 49 +-
.../entries/VMThinLRURegionEntryHeapLongKey.java | 49 +-
.../entries/VMThinLRURegionEntryHeapObjectKey.java | 49 +-
.../VMThinLRURegionEntryHeapStringKey1.java | 49 +-
.../VMThinLRURegionEntryHeapStringKey2.java | 49 +-
.../entries/VMThinLRURegionEntryHeapUUIDKey.java | 49 +-
.../entries/VMThinLRURegionEntryOffHeapIntKey.java | 49 +-
.../VMThinLRURegionEntryOffHeapLongKey.java | 49 +-
.../VMThinLRURegionEntryOffHeapObjectKey.java | 49 +-
.../VMThinLRURegionEntryOffHeapStringKey1.java | 49 +-
.../VMThinLRURegionEntryOffHeapStringKey2.java | 49 +-
.../VMThinLRURegionEntryOffHeapUUIDKey.java | 49 +-
.../cache/entries/VMThinRegionEntryHeapIntKey.java | 4 +-
.../entries/VMThinRegionEntryHeapLongKey.java | 4 +-
.../entries/VMThinRegionEntryHeapObjectKey.java | 4 +-
.../entries/VMThinRegionEntryHeapStringKey1.java | 4 +-
.../entries/VMThinRegionEntryHeapStringKey2.java | 4 +-
.../entries/VMThinRegionEntryHeapUUIDKey.java | 4 +-
.../entries/VMThinRegionEntryOffHeapIntKey.java | 4 +-
.../entries/VMThinRegionEntryOffHeapLongKey.java | 4 +-
.../entries/VMThinRegionEntryOffHeapObjectKey.java | 4 +-
.../VMThinRegionEntryOffHeapStringKey1.java | 4 +-
.../VMThinRegionEntryOffHeapStringKey2.java | 4 +-
.../entries/VMThinRegionEntryOffHeapUUIDKey.java | 4 +-
...VersionedStatsDiskLRURegionEntryHeapIntKey.java | 53 +-
...ersionedStatsDiskLRURegionEntryHeapLongKey.java | 53 +-
...sionedStatsDiskLRURegionEntryHeapObjectKey.java | 53 +-
...ionedStatsDiskLRURegionEntryHeapStringKey1.java | 53 +-
...ionedStatsDiskLRURegionEntryHeapStringKey2.java | 53 +-
...ersionedStatsDiskLRURegionEntryHeapUUIDKey.java | 53 +-
...sionedStatsDiskLRURegionEntryOffHeapIntKey.java | 53 +-
...ionedStatsDiskLRURegionEntryOffHeapLongKey.java | 53 +-
...nedStatsDiskLRURegionEntryOffHeapObjectKey.java | 53 +-
...edStatsDiskLRURegionEntryOffHeapStringKey1.java | 53 +-
...edStatsDiskLRURegionEntryOffHeapStringKey2.java | 53 +-
...ionedStatsDiskLRURegionEntryOffHeapUUIDKey.java | 53 +-
.../VersionedStatsDiskRegionEntryHeapIntKey.java | 8 +-
.../VersionedStatsDiskRegionEntryHeapLongKey.java | 8 +-
...VersionedStatsDiskRegionEntryHeapObjectKey.java | 8 +-
...ersionedStatsDiskRegionEntryHeapStringKey1.java | 8 +-
...ersionedStatsDiskRegionEntryHeapStringKey2.java | 8 +-
.../VersionedStatsDiskRegionEntryHeapUUIDKey.java | 8 +-
...VersionedStatsDiskRegionEntryOffHeapIntKey.java | 8 +-
...ersionedStatsDiskRegionEntryOffHeapLongKey.java | 8 +-
...sionedStatsDiskRegionEntryOffHeapObjectKey.java | 8 +-
...ionedStatsDiskRegionEntryOffHeapStringKey1.java | 8 +-
...ionedStatsDiskRegionEntryOffHeapStringKey2.java | 8 +-
...ersionedStatsDiskRegionEntryOffHeapUUIDKey.java | 8 +-
.../VersionedStatsLRURegionEntryHeapIntKey.java | 49 +-
.../VersionedStatsLRURegionEntryHeapLongKey.java | 49 +-
.../VersionedStatsLRURegionEntryHeapObjectKey.java | 49 +-
...VersionedStatsLRURegionEntryHeapStringKey1.java | 49 +-
...VersionedStatsLRURegionEntryHeapStringKey2.java | 49 +-
.../VersionedStatsLRURegionEntryHeapUUIDKey.java | 49 +-
.../VersionedStatsLRURegionEntryOffHeapIntKey.java | 49 +-
...VersionedStatsLRURegionEntryOffHeapLongKey.java | 49 +-
...rsionedStatsLRURegionEntryOffHeapObjectKey.java | 49 +-
...sionedStatsLRURegionEntryOffHeapStringKey1.java | 49 +-
...sionedStatsLRURegionEntryOffHeapStringKey2.java | 49 +-
...VersionedStatsLRURegionEntryOffHeapUUIDKey.java | 49 +-
.../VersionedStatsRegionEntryHeapIntKey.java | 4 +-
.../VersionedStatsRegionEntryHeapLongKey.java | 4 +-
.../VersionedStatsRegionEntryHeapObjectKey.java | 4 +-
.../VersionedStatsRegionEntryHeapStringKey1.java | 4 +-
.../VersionedStatsRegionEntryHeapStringKey2.java | 4 +-
.../VersionedStatsRegionEntryHeapUUIDKey.java | 4 +-
.../VersionedStatsRegionEntryOffHeapIntKey.java | 4 +-
.../VersionedStatsRegionEntryOffHeapLongKey.java | 4 +-
.../VersionedStatsRegionEntryOffHeapObjectKey.java | 4 +-
...VersionedStatsRegionEntryOffHeapStringKey1.java | 4 +-
...VersionedStatsRegionEntryOffHeapStringKey2.java | 4 +-
.../VersionedStatsRegionEntryOffHeapUUIDKey.java | 4 +-
.../VersionedThinDiskLRURegionEntryHeapIntKey.java | 53 +-
...VersionedThinDiskLRURegionEntryHeapLongKey.java | 53 +-
...rsionedThinDiskLRURegionEntryHeapObjectKey.java | 53 +-
...sionedThinDiskLRURegionEntryHeapStringKey1.java | 53 +-
...sionedThinDiskLRURegionEntryHeapStringKey2.java | 53 +-
...VersionedThinDiskLRURegionEntryHeapUUIDKey.java | 53 +-
...rsionedThinDiskLRURegionEntryOffHeapIntKey.java | 53 +-
...sionedThinDiskLRURegionEntryOffHeapLongKey.java | 53 +-
...onedThinDiskLRURegionEntryOffHeapObjectKey.java | 53 +-
...nedThinDiskLRURegionEntryOffHeapStringKey1.java | 53 +-
...nedThinDiskLRURegionEntryOffHeapStringKey2.java | 53 +-
...sionedThinDiskLRURegionEntryOffHeapUUIDKey.java | 53 +-
.../VersionedThinDiskRegionEntryHeapIntKey.java | 8 +-
.../VersionedThinDiskRegionEntryHeapLongKey.java | 8 +-
.../VersionedThinDiskRegionEntryHeapObjectKey.java | 8 +-
...VersionedThinDiskRegionEntryHeapStringKey1.java | 8 +-
...VersionedThinDiskRegionEntryHeapStringKey2.java | 8 +-
.../VersionedThinDiskRegionEntryHeapUUIDKey.java | 8 +-
.../VersionedThinDiskRegionEntryOffHeapIntKey.java | 8 +-
...VersionedThinDiskRegionEntryOffHeapLongKey.java | 8 +-
...rsionedThinDiskRegionEntryOffHeapObjectKey.java | 8 +-
...sionedThinDiskRegionEntryOffHeapStringKey1.java | 8 +-
...sionedThinDiskRegionEntryOffHeapStringKey2.java | 8 +-
...VersionedThinDiskRegionEntryOffHeapUUIDKey.java | 8 +-
.../VersionedThinLRURegionEntryHeapIntKey.java | 49 +-
.../VersionedThinLRURegionEntryHeapLongKey.java | 49 +-
.../VersionedThinLRURegionEntryHeapObjectKey.java | 49 +-
.../VersionedThinLRURegionEntryHeapStringKey1.java | 49 +-
.../VersionedThinLRURegionEntryHeapStringKey2.java | 49 +-
.../VersionedThinLRURegionEntryHeapUUIDKey.java | 49 +-
.../VersionedThinLRURegionEntryOffHeapIntKey.java | 49 +-
.../VersionedThinLRURegionEntryOffHeapLongKey.java | 49 +-
...ersionedThinLRURegionEntryOffHeapObjectKey.java | 49 +-
...rsionedThinLRURegionEntryOffHeapStringKey1.java | 49 +-
...rsionedThinLRURegionEntryOffHeapStringKey2.java | 49 +-
.../VersionedThinLRURegionEntryOffHeapUUIDKey.java | 49 +-
.../VersionedThinRegionEntryHeapIntKey.java | 4 +-
.../VersionedThinRegionEntryHeapLongKey.java | 4 +-
.../VersionedThinRegionEntryHeapObjectKey.java | 4 +-
.../VersionedThinRegionEntryHeapStringKey1.java | 4 +-
.../VersionedThinRegionEntryHeapStringKey2.java | 4 +-
.../VersionedThinRegionEntryHeapUUIDKey.java | 4 +-
.../VersionedThinRegionEntryOffHeapIntKey.java | 4 +-
.../VersionedThinRegionEntryOffHeapLongKey.java | 4 +-
.../VersionedThinRegionEntryOffHeapObjectKey.java | 4 +-
.../VersionedThinRegionEntryOffHeapStringKey1.java | 4 +-
.../VersionedThinRegionEntryOffHeapStringKey2.java | 4 +-
.../VersionedThinRegionEntryOffHeapUUIDKey.java | 4 +-
.../cache/eviction/AbstractEvictionController.java | 161 +
.../cache/eviction/AbstractEvictionList.java | 197 +
.../eviction/CachedDeserializableValueWrapper.java | 32 +
.../internal/cache/eviction/CountLRUEviction.java | 127 +
.../cache/eviction/CountLRUStatistics.java | 112 +
.../cache/eviction/DisabledEvictionCounters.java | 90 +
.../internal/cache/eviction/EvictableEntry.java | 31 +
.../internal/cache/eviction/EvictableMap.java | 69 +
.../cache/eviction/EvictionController.java | 73 +
.../internal/cache/eviction/EvictionCounters.java | 48 +
.../cache/eviction/EvictionCountersImpl.java | 124 +
.../internal/cache/eviction/EvictionList.java | 56 +
.../cache/eviction/EvictionListBuilder.java | 42 +
.../internal/cache/eviction/EvictionNode.java | 55 +
.../internal/cache/eviction/EvictionStats.java | 39 +
.../geode/internal/cache/eviction/GuardNode.java | 94 +
.../geode/internal/cache/eviction/HeapEvictor.java | 496 ++
.../internal/cache/eviction/HeapLRUController.java | 123 +
.../internal/cache/eviction/HeapLRUStatistics.java | 108 +
.../geode/internal/cache/eviction/LIFOList.java | 66 +
.../cache/eviction/LRUListWithAsyncSorting.java | 232 +
.../cache/eviction/LRUListWithSyncSorting.java | 112 +
.../cache/eviction/MemoryLRUController.java | 134 +
.../cache/eviction/MemoryLRUStatistics.java | 111 +
.../internal/cache/eviction/OffHeapEvictor.java | 92 +
.../internal/cache/eviction/RegionEvictorTask.java | 106 +
.../internal/cache/eviction/SizeLRUController.java | 75 +
.../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 +-
.../PartitionedRegionFunctionResultWaiter.java | 1 -
.../cache/execute/ServerFunctionExecutor.java | 4 +-
.../execute/ServerRegionFunctionExecutor.java | 4 +-
.../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 +-
.../apache/geode/internal/cache/lru/EnableLRU.java | 114 -
.../geode/internal/cache/lru/HeapEvictor.java | 487 --
.../cache/lru/HeapLRUCapacityController.java | 313 --
.../internal/cache/lru/HeapLRUStatistics.java | 59 -
.../geode/internal/cache/lru/LRUAlgorithm.java | 317 --
.../internal/cache/lru/LRUCapacityController.java | 337 --
.../geode/internal/cache/lru/LRUClockNode.java | 52 -
.../apache/geode/internal/cache/lru/LRUEntry.java | 31 -
.../geode/internal/cache/lru/LRUMapCallbacks.java | 67 -
.../geode/internal/cache/lru/LRUStatistics.java | 201 -
.../cache/lru/MemLRUCapacityController.java | 509 --
.../geode/internal/cache/lru/NewLIFOClockHand.java | 94 -
.../geode/internal/cache/lru/NewLRUClockHand.java | 464 --
.../geode/internal/cache/lru/OffHeapEvictor.java | 96 -
.../apache/geode/internal/cache/lru/Sizeable.java | 60 -
.../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 | 17 +-
.../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 | 34 +-
.../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/BackupInspector.java | 174 -
.../internal/cache/persistence/DiskRegionView.java | 5 +-
.../cache/persistence/MembershipFlushRequest.java | 9 +-
.../cache/persistence/MembershipViewRequest.java | 27 +-
.../cache/persistence/PersistenceAdvisorImpl.java | 4 +-
.../persistence/PersistentStateQueryMessage.java | 14 +-
.../PrepareNewPersistentMemberMessage.java | 10 +-
.../persistence/RemovePersistentMemberMessage.java | 11 +-
.../internal/cache/persistence/RestoreScript.java | 150 -
.../cache/persistence/ScriptGenerator.java | 38 -
.../cache/persistence/UnixBackupInspector.java | 73 -
.../cache/persistence/UnixScriptGenerator.java | 69 -
.../cache/persistence/WindowsBackupInspector.java | 81 -
.../cache/persistence/WindowsScriptGenerator.java | 94 -
.../apache/geode/internal/cache/properties.html | 686 +--
.../region/entry/RegionEntryFactoryBuilder.java | 6 +-
.../cache/snapshot/CacheSnapshotServiceImpl.java | 2 +-
.../internal/cache/snapshot/ClientExporter.java | 9 +-
.../internal/cache/snapshot/FlowController.java | 27 +-
.../geode/internal/cache/snapshot/GFSnapshot.java | 39 +-
.../cache/snapshot/RegionSnapshotServiceImpl.java | 18 +-
.../internal/cache/snapshot/WindowedExporter.java | 11 +-
.../internal/cache/tier/CommunicationMode.java | 25 +-
.../internal/cache/tier/sockets/AcceptorImpl.java | 322 +-
.../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 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 7 +-
.../cache/tier/sockets/ClientUserAuths.java | 3 +
.../sockets/GenericProtocolServerConnection.java | 6 +-
.../cache/tier/sockets/HAEventWrapper.java | 2 +-
.../internal/cache/tier/sockets/HandShake.java | 5 +-
.../sockets/RemoveClientFromBlacklistMessage.java | 5 +-
.../cache/tier/sockets/ServerConnection.java | 68 +-
.../tier/sockets/ServerConnectionFactory.java | 18 +-
.../sockets/ServerInterestRegistrationMessage.java | 6 +-
.../cache/tier/sockets/VersionedObjectList.java | 5 +-
.../tier/sockets/command/ExecuteFunction66.java | 11 +-
.../sockets/command/GatewayReceiverCommand.java | 2 +-
.../cache/tier/sockets/command/PutAll.java | 3 +-
.../cache/tier/sockets/command/PutAll70.java | 3 +-
.../cache/tier/sockets/command/PutAll80.java | 3 +-
.../internal/cache/tier/sockets/command/Size.java | 6 +-
.../tier/sockets/command/TXFailoverCommand.java | 17 +-
.../sockets/command/TXSynchronizationCommand.java | 3 +-
.../geode/internal/cache/tx/ClientTXStateStub.java | 63 +-
.../internal/cache/tx/DistClientTXStateStub.java | 25 +-
.../geode/internal/cache/tx/DistTxEntryEvent.java | 28 +-
.../internal/cache/tx/DistributedTXRegionStub.java | 19 +-
.../internal/cache/tx/PartitionedTXRegionStub.java | 4 +-
.../cache/versions/RegionVersionVector.java | 106 +-
.../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 +-
.../internal/cache/wan/GatewaySenderEventImpl.java | 45 +-
...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 +-
.../serial/SerialGatewaySenderEventProcessor.java | 9 +-
.../internal/cache/xmlcache/CacheCreation.java | 18 +-
.../geode/internal/cache/xmlcache/CacheXml.java | 5 +
.../internal/cache/xmlcache/CacheXmlParser.java | 6 +-
.../xmlcache/ParallelAsyncEventQueueCreation.java | 4 +-
.../xmlcache/ParallelGatewaySenderCreation.java | 4 +-
.../xmlcache/SerialAsyncEventQueueCreation.java | 4 +-
.../xmlcache/SerialGatewaySenderCreation.java | 4 +-
.../geode/internal/i18n/LocalizedStrings.java | 6 +-
.../geode/internal/jta/GlobalTransaction.java | 4 +-
.../geode/internal/jta/TransactionManagerImpl.java | 2 +-
.../geode/internal/lang/SystemPropertyHelper.java | 53 +-
.../internal/logging/log4j/AlertAppender.java | 4 +-
.../apache/geode/internal/net/SocketCreator.java | 49 +-
.../internal/offheap/MemoryAllocatorImpl.java | 16 +-
.../geode/internal/offheap/OffHeapHelper.java | 12 +-
.../internal/offheap/OffHeapRegionEntryHelper.java | 4 +-
.../internal/security/FilterPostAuthorization.java | 218 -
.../internal/security/FilterPreAuthorization.java | 149 -
.../security/IntegratedSecurityService.java | 8 +-
.../geode/internal/security/ObjectWithAuthz.java | 67 -
.../org/apache/geode/internal/size/Sizeable.java | 61 +
.../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/BackupStatus.java | 7 +-
.../apache/geode/management/ManagementService.java | 5 +
.../org/apache/geode/management/MemberMXBean.java | 28 +-
.../geode/management/RegionAttributesData.java | 49 +-
.../geode/management/cli/CommandService.java | 8 +-
.../apache/geode/management/cli/ConverterHint.java | 36 +-
.../management/internal/JmxManagerAdvisee.java | 4 +-
.../management/internal/JmxManagerAdvisor.java | 11 +-
.../geode/management/internal/MBeanJMXAdapter.java | 5 -
.../geode/management/internal/ManagementAgent.java | 33 +-
.../management/internal/ManagementConstants.java | 3 +
.../management/internal/ManagerStartupMessage.java | 7 +-
.../geode/management/internal/MemberMessenger.java | 8 +-
.../internal/SystemManagementService.java | 8 +
.../internal/beans/DistributedSystemBridge.java | 14 +-
.../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 | 55 +-
.../internal/beans/QueryDataFunction.java | 5 +-
.../internal/beans/RegionMBeanBridge.java | 46 +-
.../beans/RegionMBeanCompositeDataFactory.java | 23 +-
.../geode/management/internal/cli/CliUtil.java | 74 +-
.../management/internal/cli/CommandRequest.java | 22 +-
.../cli/commands/AlterAsyncEventQueueCommand.java | 173 +
.../internal/cli/commands/AlterRegionCommand.java | 43 +-
.../cli/commands/BackupDiskStoreCommand.java | 6 +-
.../cli/commands/CommandAvailabilityIndicator.java | 2 +-
.../internal/cli/commands/ConnectCommand.java | 27 +-
.../cli/commands/CreateAsyncEventQueueCommand.java | 109 +-
.../cli/commands/CreateDiskStoreCommand.java | 115 +-
.../cli/commands/CreateGatewayReceiverCommand.java | 90 +-
.../cli/commands/CreateGatewaySenderCommand.java | 105 +-
.../internal/cli/commands/CreateIndexCommand.java | 92 +-
.../internal/cli/commands/CreateRegionCommand.java | 50 +-
.../internal/cli/commands/DeployCommand.java | 139 +-
.../cli/commands/DescribeRegionCommand.java | 243 +-
.../commands/DestroyAsyncEventQueueCommand.java | 79 +
.../cli/commands/DestroyDiskStoreCommand.java | 70 +-
.../cli/commands/DestroyGatewaySenderCommand.java | 38 +-
.../internal/cli/commands/DestroyIndexCommand.java | 59 +-
.../cli/commands/DestroyRegionCommand.java | 60 +-
.../cli/commands/ExecuteFunctionCommand.java | 94 +-
.../ExportImportClusterConfigurationCommands.java | 67 +-
.../cli/commands/ExportStackTraceCommand.java | 65 +-
.../internal/cli/commands/GfshCommand.java | 29 +-
.../internal/cli/commands/ListMembersCommand.java | 61 +-
.../internal/cli/commands/ListRegionCommand.java | 23 +-
.../internal/cli/commands/StartLocatorCommand.java | 13 +-
.../internal/cli/commands/StartMemberUtils.java | 14 +-
.../internal/cli/commands/StartServerCommand.java | 21 +-
.../cli/converters/BaseStringConverter.java | 54 +
.../converters/ClusterMemberIdNameConverter.java | 31 +-
.../converters/ConnectionEndpointConverter.java | 43 -
.../cli/converters/DiskStoreNameConverter.java | 32 +-
.../converters/GatewayReceiverIdsConverter.java | 71 -
.../cli/converters/GatewaySenderIdConverter.java | 26 +-
.../LocatorDiscoveryConfigConverter.java | 32 +-
.../cli/converters/LocatorIdNameConverter.java | 26 +-
.../internal/cli/converters/LogLevelConverter.java | 31 +-
.../cli/converters/MemberGroupConverter.java | 36 +-
.../cli/converters/MemberIdNameConverter.java | 32 +-
.../internal/cli/domain/DataCommandRequest.java | 1 -
.../cli/domain/EvictionAttributesInfo.java | 4 +-
.../internal/cli/domain/RegionAttributesInfo.java | 291 +-
.../internal/cli/domain/RegionDescription.java | 145 +-
.../internal/cli/functions/CliFunctionResult.java | 27 +-
.../functions/CreateAsyncEventQueueFunction.java | 57 +-
.../cli/functions/CreateIndexFunction.java | 3 +-
.../internal/cli/functions/DeployFunction.java | 94 +-
.../functions/DestroyAsyncEventQueueFunction.java | 80 +
.../DestroyAsyncEventQueueFunctionArgs.java | 38 +
.../cli/functions/DestroyDiskStoreFunction.java | 72 +-
.../functions/DestroyDiskStoreFunctionArgs.java | 38 +
.../internal/cli/functions/ExportDataFunction.java | 8 +-
.../functions/FetchRegionAttributesFunction.java | 5 +-
.../functions/GatewayReceiverCreateFunction.java | 84 +-
.../cli/functions/GatewaySenderCreateFunction.java | 32 +-
.../functions/GatewaySenderDestroyFunction.java | 5 +-
.../functions/GetRegionDescriptionFunction.java | 5 +-
.../internal/cli/functions/ImportDataFunction.java | 4 +-
.../cli/functions/RegionCreateFunction.java | 19 +-
.../cli/functions/RegionDestroyFunction.java | 25 +-
.../cli/functions/UserFunctionExecution.java | 220 +-
.../geode/management/internal/cli/help/Helper.java | 4 +
.../management/internal/cli/i18n/CliStrings.java | 17 +-
.../management/internal/cli/json/GfJsonObject.java | 8 +
.../cli/remote/CommandExecutionContext.java | 13 +-
.../internal/cli/remote/CommandExecutor.java | 17 +-
.../cli/remote/OnlineCommandProcessor.java | 8 +-
.../internal/cli/result/CommandResult.java | 59 +-
.../management/internal/cli/result/FileResult.java | 48 +-
.../internal/cli/result/ResultBuilder.java | 17 +
.../internal/cli/result/TabularResultData.java | 18 +
.../internal/cli/shell/GfshExecutionStrategy.java | 6 +-
.../internal/cli/shell/JmxOperationInvoker.java | 59 +-
.../internal/cli/shell/OperationInvoker.java | 2 +
.../internal/cli/util/RegionAttributesDefault.java | 14 -
.../internal/cli/util/RegionAttributesNames.java | 2 +
.../callbacks/ConfigurationChangeListener.java | 64 +-
.../internal/configuration/domain/XmlEntity.java | 171 +-
.../functions/DownloadJarFunction.java | 88 +
.../functions/GetClusterConfigurationFunction.java | 69 +
.../configuration/functions/UploadJarFunction.java | 63 -
.../handlers/ConfigurationRequestHandler.java | 81 -
.../messages/ConfigurationRequest.java | 121 -
.../messages/ConfigurationResponse.java | 55 +-
.../internal/messages/CompactRequest.java | 20 +-
.../internal/security/ResourcePermissions.java | 6 +
.../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 | 27 +-
.../geode/pdx/internal/CheckTypeRegistryState.java | 7 +-
.../geode/pdx/internal/ClientTypeRegistration.java | 4 +-
.../geode/pdx/internal/PdxInstanceFactoryImpl.java | 10 +-
.../geode/pdx/internal/PeerTypeRegistration.java | 26 +-
.../apache/geode/security/ResourcePermission.java | 126 +-
.../geode.apache.org/schema/cache/cache-1.0.xsd | 2 +-
.../org/apache/geode/cache/doc-files/cache8_0.dtd | 2 +-
.../sanctioned-geode-core-serializables.txt | 793 ++++
.../org/apache/geode/admin/AdminTestHelper.java | 12 +-
.../geode/cache/ConnectionPoolDUnitTest.java | 23 +-
.../geode/cache/RegionExpirationDUnitTest.java | 193 +
.../cache/RegionExpirationIntegrationTest.java | 126 +
.../CacheServerSSLConnectionDUnitTest.java | 74 +-
.../internal/ConnectionPoolImplJUnitTest.java | 5 +-
.../cache/client/internal/TXFailoverOpTest.java | 82 +
.../pooling/ConnectionManagerJUnitTest.java | 24 +-
.../cache/execute/FunctionAdapterJUnitTest.java | 52 +-
.../management/MemoryThresholdsDUnitTest.java | 70 +-
.../MemoryThresholdsOffHeapDUnitTest.java | 118 +-
.../geode/cache/query/PdxStringQueryJUnitTest.java | 33 +-
.../cache/query/cq/dunit/CqQueryTestListener.java | 2 +-
.../cache/query/dunit/CompiledInDUnitTest.java | 11 +
.../cache/query/dunit/PdxLocalQueryDUnitTest.java | 10 +-
.../PdxLocalQueryVersionedClassDUnitTest.java | 5 +-
.../geode/cache/query/dunit/PdxQueryDUnitTest.java | 52 +-
.../cache/query/dunit/PdxStringQueryDUnitTest.java | 24 +-
.../dunit/QueryUsingFunctionContextDUnitTest.java | 23 +-
.../query/dunit/SelectStarQueryDUnitTest.java | 6 +-
...ncurrentIndexInitOnOverflowRegionDUnitTest.java | 13 +-
...ntIndexOperationsOnOverflowRegionDUnitTest.java | 11 +
.../InitializeIndexEntryDestroyQueryDUnitTest.java | 12 +
.../internal/index/MemoryIndexStoreJUnitTest.java | 6 +
.../internal/index/PartitionedIndexJUnitTest.java | 69 +
.../partitioned/PRBasicIndexCreationDUnitTest.java | 11 +
.../PRBasicMultiIndexCreationDUnitTest.java | 10 +
.../query/partitioned/PRBasicQueryDUnitTest.java | 17 +-
.../partitioned/PRBasicRemoveIndexDUnitTest.java | 11 +
.../partitioned/PRColocatedEquiJoinDUnitTest.java | 159 +-
.../partitioned/PRQueryCacheCloseDUnitTest.java | 15 +-
.../cache/query/partitioned/PRQueryDUnitTest.java | 16 +-
.../partitioned/PRQueryRegionCloseDUnitTest.java | 16 +-
.../PRQueryRegionDestroyedDUnitTest.java | 16 +-
.../PRQueryRemoteNodeExceptionDUnitTest.java | 11 +
.../geode/cache/query/transaction/Person.java | 21 +-
.../cache/snapshot/ParallelSnapshotDUnitTest.java | 11 +
.../geode/cache/snapshot/SnapshotDUnitTest.java | 25 +-
.../snapshot/SnapshotPerformanceDUnitTest.java | 6 +-
.../apache/geode/cache30/CacheXml66DUnitTest.java | 23 +-
.../apache/geode/cache30/CacheXml70DUnitTest.java | 4 +-
.../cache30/CacheXmlNotFoundRegressionTest.java | 77 +
.../org/apache/geode/cache30/CacheXmlTestCase.java | 20 +
.../geode/cache30/ClientServerCCEDUnitTest.java | 4 +-
.../apache/geode/cache30/DiskRegionDUnitTest.java | 56 +-
...ibutedAckOverflowRegionCCEOffHeapDUnitTest.java | 2 +-
...utedAckPersistentRegionCCEOffHeapDUnitTest.java | 2 +-
.../cache30/DistributedAckRegionCCEDUnitTest.java | 7 +-
.../DistributedAckRegionCCEOffHeapDUnitTest.java | 2 +-
.../cache30/DistributedAckRegionDUnitTest.java | 2 +-
.../DistributedAckRegionOffHeapDUnitTest.java | 2 +-
.../DistributedNoAckRegionCCEOffHeapDUnitTest.java | 2 +-
.../DistributedNoAckRegionOffHeapDUnitTest.java | 2 +-
.../cache30/GlobalRegionCCEOffHeapDUnitTest.java | 2 +-
.../cache30/GlobalRegionOffHeapDUnitTest.java | 2 +-
.../cache30/LRUEvictionControllerDUnitTest.java | 71 +-
.../cache30/MemLRUEvictionControllerDUnitTest.java | 18 +-
.../geode/cache30/MultiVMRegionTestCase.java | 9 +
.../OffHeapLRUEvictionControllerDUnitTest.java | 4 +-
.../geode/cache30/PartitionedRegionDUnitTest.java | 10 +
.../cache30/PartitionedRegionOffHeapDUnitTest.java | 2 +-
.../geode/cache30/RegionExpirationDUnitTest.java | 259 --
.../geode/cache30/RegionReliabilityTestCase.java | 4 +-
.../org/apache/geode/cache30/SlowRecDUnitTest.java | 14 +-
.../org/apache/geode/cache30/TestDiskRegion.java | 16 +-
.../AnalyzeSerializablesJUnitTest.java | 306 +-
.../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 | 63 +-
.../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/DistributionConfigJUnitTest.java | 6 +-
.../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 +-
.../deadlock/GemFireDeadlockDetectorDUnitTest.java | 17 +-
.../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 +
...alDataSerializerSerializationWhitelistTest.java | 152 +
.../geode/internal/JarDeployerDeadlockTest.java | 11 +-
.../geode/internal/JarDeployerIntegrationTest.java | 22 +-
.../internal/PutAllOperationContextJUnitTest.java | 2 +-
.../internal/cache/AbstractLRURegionMapTest.java | 45 -
.../internal/cache/AbstractRegionJUnitTest.java | 49 +-
.../geode/internal/cache/BackupDUnitTest.java | 778 ----
.../geode/internal/cache/BackupJUnitTest.java | 430 --
.../cache/Bug34179TooManyFilesOpenJUnitTest.java | 2 +-
.../geode/internal/cache/Bug37244JUnitTest.java | 244 -
.../geode/internal/cache/Bug41091DUnitTest.java | 5 +-
.../geode/internal/cache/Bug41733DUnitTest.java | 8 +-
.../internal/cache/CacheAdvisorDUnitTest.java | 4 +-
.../internal/cache/CacheOperationMessageTest.java | 4 +-
.../geode/internal/cache/CacheProfileTest.java | 57 +
.../CacheWriterGetOldValueIntegrationTest.java | 286 ++
.../internal/cache/ClearTXLockingDUnitTest.java | 179 +-
.../cache/ClientServerGetAllDUnitTest.java | 33 +-
...entServerInvalidAndDestroyedEntryDUnitTest.java | 14 +-
.../cache/ClientServerTransactionCCEDUnitTest.java | 14 +
.../cache/ClientServerTransactionDUnitTest.java | 92 +-
.../ClusterConfigurationLoaderIntegrationTest.java | 59 +
.../geode/internal/cache/CommitFunction.java | 17 +-
.../internal/cache/ConcurrentMapOpsDUnitTest.java | 22 +-
.../internal/cache/DeltaFaultInDUnitTest.java | 4 +-
.../internal/cache/DeltaPropagationDUnitTest.java | 16 +-
.../DiskRegOplogSwtchingAndRollerJUnitTest.java | 6 +-
.../internal/cache/DiskRegRecoveryJUnitTest.java | 2 +-
.../cache/DiskRegionAsyncRecoveryJUnitTest.java | 2 +-
.../internal/cache/DiskRegionHelperFactory.java | 109 +-
.../geode/internal/cache/DiskRegionJUnitTest.java | 18 +-
.../internal/cache/DiskRegionTestingBase.java | 118 +-
.../cache/DiskStoreImplIntegrationTest.java | 93 +
.../geode/internal/cache/DiskStoreMonitorTest.java | 57 +
.../apache/geode/internal/cache/DiskUsageTest.java | 255 ++
.../DistrbutedRegionProfileOffHeapDUnitTest.java | 2 +-
.../internal/cache/DistributedCacheTestCase.java | 17 +-
...tributedRegionFunctionStreamingMessageTest.java | 4 +-
.../geode/internal/cache/EntryEventImplTest.java | 125 +
.../geode/internal/cache/EvictionDUnitTest.java | 209 -
.../cache/EvictionObjectSizerDUnitTest.java | 370 --
.../internal/cache/EvictionStatsDUnitTest.java | 564 ---
.../geode/internal/cache/EvictionTestBase.java | 545 ---
.../geode/internal/cache/GIIDeltaDUnitTest.java | 10 +-
.../internal/cache/GIIFlowControlDUnitTest.java | 6 +-
.../geode/internal/cache/GemFireCacheImplTest.java | 95 +-
.../geode/internal/cache/GridProfileTest.java | 6 +-
.../cache/HAOverflowMemObjectSizerDUnitTest.java | 20 +-
.../internal/cache/IncrementalBackupDUnitTest.java | 1114 -----
.../internal/cache/InitialImageOperationTest.java | 56 +
.../cache/InterruptClientServerDUnitTest.java | 8 +-
.../internal/cache/InterruptDiskJUnitTest.java | 21 +-
.../geode/internal/cache/InterruptsDUnitTest.java | 8 +-
.../LIFOEvictionAlgoEnabledRegionJUnitTest.java | 16 +-
...FOEvictionAlgoMemoryEnabledRegionJUnitTest.java | 494 +-
.../LRUClearWithDiskRegionOpRegressionTest.java | 122 +
.../internal/cache/NestedTransactionFunction.java | 17 +-
.../cache/NetSearchMessagingDUnitTest.java | 12 +-
.../internal/cache/OffHeapEvictionDUnitTest.java | 147 -
.../cache/OffHeapEvictionStatsDUnitTest.java | 89 -
.../geode/internal/cache/OffHeapTestUtil.java | 6 +-
.../geode/internal/cache/OplogJUnitTest.java | 2413 ++--------
.../cache/PRCacheListenerInvocationTest.java | 2 +
...istenerWithInterestPolicyAllInvocationTest.java | 2 +
.../cache/PartitionAttributesImplJUnitTest.java | 47 +
.../cache/PartitionedRegionEvictionDUnitTest.java | 30 +-
.../PartitionedRegionLocalMaxMemoryDUnitTest.java | 2 +-
...tionedRegionLocalMaxMemoryOffHeapDUnitTest.java | 2 +-
.../PartitionedRegionOffHeapEvictionDUnitTest.java | 9 +-
.../cache/PartitionedRegionQueryDUnitTest.java | 18 +-
.../cache/PartitionedRegionSingleHopDUnitTest.java | 12 +-
.../cache/PartitionedRegionTestUtilsDUnitTest.java | 60 +-
.../geode/internal/cache/RegionCommitTest.java | 58 +
.../cache/RemoteFetchEntryMessageTest.java | 4 +-
.../internal/cache/RemoteOperationMessageTest.java | 6 +-
.../cache/RemoteTransactionCCEDUnitTest.java | 12 +
.../internal/cache/RemoteTransactionDUnitTest.java | 15 +
.../cache/RequestFilterInfoMessageTest.java | 30 +
.../geode/internal/cache/RollbackFunction.java | 17 +-
.../cache/SearchLoadAndWriteProcessorTest.java | 4 +-
.../internal/cache/SimpleDiskRegionJUnitTest.java | 2 +-
.../geode/internal/cache/SizingFlagDUnitTest.java | 6 +-
.../geode/internal/cache/SnapshotTestUtil.java | 8 +-
.../internal/cache/StateMarkerMessageTest.java | 31 +
.../internal/cache/SystemFailureDUnitTest.java | 4 +-
.../geode/internal/cache/TXManagerImplTest.java | 7 +-
.../cache/TXRegionLockRequestImplTest.java | 55 +
.../internal/cache/TXReservationMgrJUnitTest.java | 2 +-
.../internal/cache/TXStateProxyImplJUnitTest.java | 61 -
.../geode/internal/cache/TXStateProxyImplTest.java | 82 +
.../cache/TXSynchronizationRunnableTest.java | 64 +
.../cache/TransactionsWithDeltaDUnitTest.java | 28 +-
.../geode/internal/cache/VMLRURegionMapTest.java | 43 +
.../cache/backup/BackupDefinitionTest.java | 119 +
.../cache/backup/BackupDistributedTest.java | 747 +++
.../backup/BackupInspectorIntegrationTest.java | 170 +
.../cache/backup/BackupIntegrationTest.java | 435 ++
.../internal/cache/backup/BackupLockTest.java | 105 +
.../backup/BackupPrepareAndFinishMsgDUnitTest.java | 239 +
.../cache/backup/BackupReplyProcessorTest.java | 94 +
.../backup/FileSystemBackupDestinationTest.java | 229 +
.../cache/backup/FinishBackupFactoryTest.java | 87 +
.../cache/backup/FinishBackupOperationTest.java | 243 +
.../cache/backup/FinishBackupRequestTest.java | 117 +
.../cache/backup/FlushToDiskFactoryTest.java | 82 +
.../cache/backup/FlushToDiskOperationTest.java | 127 +
.../cache/backup/FlushToDiskRequestTest.java | 86 +
.../backup/IncrementalBackupDistributedTest.java | 1100 +++++
...titionedBackupPrepareAndFinishMsgDUnitTest.java | 27 +
.../cache/backup/PrepareBackupFactoryTest.java | 86 +
.../cache/backup/PrepareBackupOperationTest.java | 239 +
.../cache/backup/PrepareBackupRequestTest.java | 102 +
...eplicateBackupPrepareAndFinishMsgDUnitTest.java | 27 +
.../cache/backup/UnixScriptGeneratorTest.java | 118 +
.../cache/backup/WindowsScriptGeneratorTest.java | 120 +
.../DiskRegOverflowAsyncJUnitPerformanceTest.java | 8 +-
.../DiskRegOverflowSyncJUnitPerformanceTest.java | 8 +-
...skRegionOverflowAsyncRollingOpLogJUnitTest.java | 10 +-
...iskRegionOverflowSyncRollingOpLogJUnitTest.java | 16 +-
.../DiskRegionPerfJUnitPerformanceTest.java | 2 +-
.../DiskRegionRollOpLogJUnitPerformanceTest.java | 2 +-
.../cache/eviction/AbstractEvictionListTest.java | 251 +
.../internal/cache/eviction/EvictionDUnitTest.java | 209 +
.../eviction/EvictionObjectSizerDUnitTest.java | 366 ++
.../cache/eviction/EvictionStatsDUnitTest.java | 516 +++
.../internal/cache/eviction/EvictionTestBase.java | 532 +++
.../internal/cache/eviction/LIFOListTest.java | 102 +
.../LRUListWithAsyncSortingIntegrationTest.java | 177 +
.../eviction/LRUListWithAsyncSortingTest.java | 253 +
.../LRUListWithSyncSortingIntegrationTest.java | 181 +
.../cache/eviction/LRUListWithSyncSortingTest.java | 156 +
.../internal/cache/eviction/LRUTestEntry.java | 459 ++
.../cache/eviction/LinkableEvictionNode.java | 19 +
.../cache/eviction/OffHeapEvictionDUnitTest.java | 150 +
.../eviction/OffHeapEvictionStatsDUnitTest.java | 91 +
.../RegionEntryEvictionIntegrationTest.java | 63 +
.../cache/eviction/TestEvictionController.java | 93 +
.../eviction/TestLRUListWithAsyncSorting.java | 30 +
.../eviction/TransactionsWithOverflowTest.java | 88 +
.../ClientServerFunctionExecutionDUnitTest.java | 10 +
...istributedRegionFunctionExecutionDUnitTest.java | 17 +-
.../FunctionExecution_ExceptionDUnitTest.java | 9 +
.../cache/execute/FunctionServiceBase.java | 46 +-
.../cache/execute/FunctionServiceClientBase.java | 10 +
.../execute/FunctionServiceStatsDUnitTest.java | 9 +
.../execute/LocalDataSetIndexingDUnitTest.java | 34 +-
.../execute/MemberFunctionExecutionDUnitTest.java | 173 +-
.../MultiRegionFunctionExecutionDUnitTest.java | 13 +-
.../OnGroupsFunctionExecutionDUnitTest.java | 49 +-
...ctionExecutionSelectorNoSingleHopDUnitTest.java | 10 +
.../cache/execute/PRClientServerTestBase.java | 10 +-
.../cache/execute/PRColocationDUnitTest.java | 13 +
.../execute/PRFunctionExecutionDUnitTest.java | 15 +-
.../geode/internal/cache/execute/TestFunction.java | 25 +-
.../ExtensionClusterConfigurationDUnitTest.java | 18 +-
.../mock/AlterMockCacheExtensionFunction.java | 17 +-
.../mock/AlterMockRegionExtensionFunction.java | 17 +-
.../mock/CreateMockCacheExtensionFunction.java | 17 +-
.../mock/CreateMockRegionExtensionFunction.java | 16 +-
.../mock/DestroyMockCacheExtensionFunction.java | 17 +-
.../mock/DestroyMockRegionExtensionFunction.java | 17 +-
.../FireAndForgetFunctionOnAllServers.java | 19 +-
.../internal/cache/functions/TestFunction.java | 44 +-
.../geode/internal/cache/ha/ConflatableObject.java | 25 +-
.../internal/cache/ha/HASlowReceiverDUnitTest.java | 57 +-
.../geode/internal/cache/ha/PutAllDUnitTest.java | 5 +-
.../cache/locks/TXLockServiceDUnitTest.java | 6 +-
.../geode/internal/cache/lru/LRUAlgorithmTest.java | 35 -
.../internal/cache/lru/LRUClockJUnitTest.java | 516 ---
.../cache/lru/TransactionsWithOverflowTest.java | 88 -
.../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 | 7 +-
.../cache/partitioned/PersistPRKRFDUnitTest.java | 36 +-
...sistentColocatedPartitionedRegionDUnitTest.java | 366 +-
.../PersistentPartitionedRegionDUnitTest.java | 145 +-
.../PersistentPartitionedRegionTestBase.java | 961 ++--
...tPartitionedRegionWithTransactionDUnitTest.java | 28 +-
.../cache/partitioned/RemoveBucketMessageTest.java | 4 +-
.../fixed/FixedPartitioningDUnitTest.java | 12 +
.../fixed/FixedPartitioningTestBase.java | 6 +-
.../BackupInspectorIntegrationTest.java | 170 -
.../BackupPrepareAndFinishMsgDUnitTest.java | 240 -
...titionedBackupPrepareAndFinishMsgDUnitTest.java | 28 -
.../PersistentRVVRecoveryDUnitTest.java | 6 +-
.../PersistentRecoveryOrderDUnitTest.java | 41 +-
...eplicateBackupPrepareAndFinishMsgDUnitTest.java | 28 -
.../cache/persistence/UnixScriptGeneratorTest.java | 118 -
.../persistence/WindowsScriptGeneratorTest.java | 120 -
.../entry/RegionEntryFactoryBuilderJUnitTest.java | 6 +-
.../rollingupgrade/RollingUpgrade2DUnitTest.java | 489 +-
.../rollingupgrade/RollingUpgradeDUnitTest.java | 166 +-
.../cache/snapshot/ClientExporterTest.java | 52 +
.../snapshot/GFSnapshotJUnitPerformanceTest.java | 15 +-
.../sockets/AcceptorImplClientQueueDUnitTest.java | 263 ++
.../tier/sockets/ClientHealthMonitorJUnitTest.java | 21 +-
.../ClientHealthMonitorSelectorJUnitTest.java | 4 +-
.../tier/sockets/ClientProxyWithDeltaTest.java | 15 +-
.../tier/sockets/ClientServerMiscDUnitTest.java | 117 +-
.../cache/tier/sockets/ConflationDUnitTest.java | 17 +-
.../tier/sockets/EventIDVerificationDUnitTest.java | 4 +
.../ForceInvalidateOffHeapEvictionDUnitTest.java | 2 +-
.../sockets/HAInterestDistributedTestCase.java | 26 -
.../sockets/RegisterInterestKeysDUnitTest.java | 4 +-
.../sockets/command/TXFailoverCommandTest.java | 72 +-
.../internal/cache/tx/ClientTXStateStubTest.java | 82 +
.../versions/RegionVersionVectorJUnitTest.java | 618 ---
.../cache/versions/RegionVersionVectorTest.java | 716 +++
.../cache/wan/AsyncEventQueueTestBase.java | 5 +-
...ewayReceiverXmlParsingValidationsJUnitTest.java | 110 +
.../ParallelQueueRemovalMessageJUnitTest.java | 23 +-
.../cache/xmlcache/CacheXmlParserJUnitTest.java | 7 +-
.../CompressionCacheListenerOffHeapDUnitTest.java | 2 +-
.../CompressionRegionOperationsDUnitTest.java | 15 +-
...ompressionRegionOperationsOffHeapDUnitTest.java | 2 +-
...ainWithChildrenRollingFileHandlerDUnitTest.java | 6 +-
.../geode/internal/lang/StringUtilsJUnitTest.java | 2 +-
.../lang/SystemPropertyHelperJUnitTest.java | 32 +-
.../internal/net/SSLSocketIntegrationTest.java | 18 +
...nectingOutOfOffHeapMemoryListenerJUnitTest.java | 4 +-
.../internal/offheap/MemoryAllocatorJUnitTest.java | 2 +-
.../internal/offheap/OffHeapHelperJUnitTest.java | 26 +-
.../geode/internal/offheap/OffHeapRegionBase.java | 2 +-
.../offheap/OutOfOffHeapMemoryDUnitTest.java | 8 +-
.../BlockingProcessStreamReaderWindowsTest.java | 20 +-
.../FileProcessControllerIntegrationTest.java | 23 +-
.../internal/process/PidFileIntegrationTest.java | 10 -
.../internal/process/lang/AvailablePidTest.java | 2 -
.../apache/geode/internal/size/SizeOfUtil0.java | 0
.../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 +-
.../geode/management/QueryDataDUnitTest.java | 13 +-
.../QueryDataFunctionIntegrationTest.java | 5 +-
.../management/RegionManagementDUnitTest.java | 10 +-
.../bean/stats/GatewayMBeanBridgeJUnitTest.java | 2 +-
.../beans/DistributedSystemBridgeJUnitTest.java | 14 +-
.../internal/beans/FileUploaderTest.java | 84 +
.../internal/beans/RegionMBeanAttributesTest.java | 93 +
.../internal/beans/TestEventListener.java | 33 +
.../management/internal/cli/CliUtilDUnitTest.java | 38 +-
.../geode/management/internal/cli/CliUtilTest.java | 30 +
.../internal/cli/GfshParserAutoCompletionTest.java | 16 +-
.../internal/cli/GfshParserConverterTest.java | 2 +-
.../management/internal/cli/HeadlessGfsh.java | 6 +-
.../management/internal/cli/NetstatDUnitTest.java | 4 +-
.../AlterAsyncEventQueueCommandDUnitTest.java | 100 +
.../commands/AlterAsyncEventQueueCommandTest.java | 246 +
.../cli/commands/AlterDiskStoreDUnitTest.java | 168 +
.../cli/commands/AlterDiskStoreJUnitTest.java | 55 +
.../commands/ChangeLogLevelCommandDUnitTest.java | 12 +-
.../internal/cli/commands/CliCommandTestBase.java | 2 +-
.../commands/CommandAvailabilityIndicatorTest.java | 65 +
.../cli/commands/ConcurrentDeployDUnitTest.java | 4 +-
.../cli/commands/ConnectCommandDUnitTest.java | 51 +
.../internal/cli/commands/ConnectCommandTest.java | 39 +-
.../CreateAsyncEventQueueCommandDUnitTest.java | 128 +
.../commands/CreateAsyncEventQueueCommandTest.java | 205 +
.../CreateDefinedIndexesCommandDUnitTest.java | 41 +-
.../commands/CreateGatewayReceiverCommandTest.java | 127 +
.../commands/CreateGatewaySenderCommandTest.java | 151 +
.../cli/commands/CreateIndexCommandTest.java | 12 +-
.../cli/commands/CreateRegionCommandDUnitTest.java | 28 +-
.../CreateRegionCommandIntegrationTest.java | 29 +-
.../cli/commands/CreateRegionCommandTest.java | 9 -
...DeployCommandFunctionRegistrationDUnitTest.java | 4 +-
.../commands/DeployCommandRedeployDUnitTest.java | 39 +-
.../internal/cli/commands/DeployCommandTest.java | 63 +
.../cli/commands/DeployWithGroupsDUnitTest.java | 71 +-
.../DescribeConnectionCommandJUnitTest.java | 65 +
.../DescribeDiskStoreCommandIntegrationTest.java | 101 +
.../commands/DescribeMembersCommandDUnitTest.java | 4 +-
.../cli/commands/DescribeRegionDUnitTest.java | 212 +
.../commands/DescribeRegionIntegrationTest.java | 64 +
.../cli/commands/DescribeRegionJUnitTest.java | 188 +
.../DestroyAsyncEventQueueCommandDUnitTest.java | 216 +
.../DestroyAsyncEventQueueCommandTest.java | 198 +
.../commands/DestroyGatewaySenderCommandTest.java | 65 +-
.../commands/DestroyIndexCommandsDUnitTest.java | 34 +-
.../commands/DestroyRegionCommandDUnitTest.java | 129 +-
.../cli/commands/DestroyRegionCommandTest.java | 75 +-
.../cli/commands/DiskStoreCommandsDUnitTest.java | 1566 +------
.../ExecuteFunctionCommandSecurityTest.java | 16 +-
.../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 | 132 +-
.../internal/cli/commands/GcCommandDUnitTest.java | 17 +-
.../cli/commands/GemfireDataCommandsDUnitTest.java | 11 +-
.../cli/commands/IndexCommandsIntegrationTest.java | 2 +-
.../IndexCommandsShareConfigurationDUnitTest.java | 8 +-
.../ListAndDescribeDiskStoreCommandsDUnitTest.java | 205 -
.../commands/ListAndDescribeRegionDUnitTest.java | 268 --
.../ListAsyncEventQueuesCommandDUnitTest.java | 81 +
.../ListDiskStoreCommandIntegrationTest.java | 63 +
.../cli/commands/ListIndexCommandDUnitTest.java | 6 +-
.../cli/commands/ListMembersCommandDUnitTest.java | 43 +-
.../cli/commands/ListMembersCommandTest.java | 101 +
.../internal/cli/commands/ListRegionDUnitTest.java | 149 +
.../cli/commands/ListRegionIntegrationTest.java | 79 +
.../cli/commands/LocateEntryDUnitTest.java | 4 +-
.../cli/commands/QueueCommandsDUnitTest.java | 437 --
.../cli/commands/RemoveCommandDUnitTest.java | 10 +-
.../cli/commands/RemoveCommandJsonDUnitTest.java | 10 +-
.../cli/commands/ShowDeadlockDUnitTest.java | 8 +-
.../cli/commands/ShowLogCommandDUnitTest.java | 12 +-
.../ShowMetricsCommandIntegrationTest.java | 22 +-
.../cli/commands/ShowMetricsDUnitTest.java | 8 +-
.../commands/ShowMissingDiskStoresDUnitTest.java | 4 +-
.../cli/commands/ShowStackTraceDUnitTest.java | 269 --
.../cli/commands/ShutdownCommandDUnitTest.java | 10 +-
.../cli/commands/StartMemberUtilsTest.java | 50 +
.../cli/commands/TestObjectSizerNotDeclarable.java | 25 +
.../converters/BaseStringConverterJUnitTest.java | 82 +
.../cli/domain/RegionDescriptionJUnitTest.java | 255 ++
.../cli/functions/CliFunctionResultTest.java | 34 +-
.../DestroyAsyncEventQueueFunctionTest.java | 107 +
.../cli/functions/RegionDestroyFunctionTest.java | 20 +-
.../cli/functions/RegionFunctionArgsTest.java | 3 +-
.../cli/json/TypedJsonPdxIntegrationTest.java | 7 +-
.../internal/cli/remote/CommandExecutorTest.java | 22 +-
.../cli/remote/OnlineCommandProcessorTest.java | 5 +
.../internal/cli/result/FileResultTest.java | 56 +
.../internal/cli/result/TabularResultDataTest.java | 51 +
.../internal/cli/util/MergeLogsDUnitTest.java | 9 +-
.../internal/configuration/ClusterConfig.java | 23 +-
.../ClusterConfigDeployJarDUnitTest.java | 11 +-
.../ClusterConfigDistributionDUnitTest.java | 6 +-
.../ClusterConfigImportDUnitTest.java | 4 +-
.../configuration/ClusterConfigTestBase.java | 4 +-
.../ClusterConfigWithSecurityDUnitTest.java | 10 +-
.../ClusterConfigurationServiceDUnitTest.java | 408 --
.../ImportClusterConfigDistributedTest.java | 8 +-
.../ImportOldClusterConfigDUnitTest.java | 6 +-
.../GetClusterConfigurationFunctionTest.java | 48 +
.../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 | 132 +
.../internal/security/MultiGfshDUnitTest.java | 154 +
.../security/MultiUserAuthenticationDUnitTest.java | 116 +
.../internal/security/MultiUserDUnitTest.java | 151 -
.../internal/security/ResourcePermissionTest.java | 225 +-
.../ShellCommandsControllerProcessCommandTest.java | 3 +-
.../geode/pdx/AutoSerializableJUnitTest.java | 38 +
.../pdx/ClientsWithVersioningRetryDUnitTest.java | 9 +-
.../geode/pdx/DistributedSystemIdDUnitTest.java | 6 +-
.../geode/pdx/PdxInstanceFactoryJUnitTest.java | 173 +-
.../org/apache/geode/pdx/PdxInstanceJUnitTest.java | 40 +-
.../apache/geode/pdx/PdxSerializableDUnitTest.java | 4 +-
.../apache/geode/pdx/PdxSerializableJUnitTest.java | 8 +-
.../org/apache/geode/pdx/PdxStringJUnitTest.java | 14 +-
.../apache/geode/security/ClientAuthDUnitTest.java | 31 +-
.../security/ClientAuthenticationTestCase.java | 44 +-
.../security/ClientAuthorizationDUnitTest.java | 29 +-
.../security/ClientAuthorizationTestCase.java | 75 +-
.../ClientDestroyInvalidateAuthDUnitTest.java | 44 +-
.../ClientExecuteFunctionAuthDUnitTest.java | 101 +-
.../security/ClusterConfigNotEnabledDUnitTest.java | 55 +
.../ClusterConfigWithoutSecurityDUnitTest.java | 4 +-
.../ClusterConfigurationSecurityDUnitTest.java | 87 +
.../PDXGfshPostProcessorOnRemoteServerTest.java | 10 +-
.../geode/security/PeerAuthenticatorDUnitTest.java | 6 +-
.../PeerSecurityWithEmbeddedLocatorDUnitTest.java | 8 +-
.../security/SecurityClusterConfigDUnitTest.java | 4 +-
.../apache/geode/security/SecurityTestUtil.java | 5 +
.../apache/geode/security/SecurityTestUtils.java | 12 +
.../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 -
.../geode/test/dunit/DistributedTestUtils.java | 1 +
.../dunit/cache/internal/JUnit4CacheTestCase.java | 16 +-
.../dunit/internal/JUnit4DistributedTestCase.java | 28 +
.../apache/geode/test/dunit/rules/CacheRule.java | 22 +-
.../apache/geode/test/dunit/rules/ClientVM.java | 32 +
.../geode/test/dunit/rules/ClusterStartupRule.java | 429 ++
.../test/dunit/rules/LocatorServerStartupRule.java | 312 --
.../apache/geode/test/dunit/rules/MemberVM.java | 66 +-
.../test/dunit/rules/tests/CacheRuleTest.java | 10 +-
...tartupRuleCanSpecifyOlderVersionsDUnitTest.java | 101 +
.../geode/test/dunit/standalone/DUnitLauncher.java | 30 +-
.../test/dunit/standalone/ProcessManager.java | 8 +-
.../test/dunit/standalone/VersionManager.java | 3 +
.../java/org/apache/geode/test/fake/Fakes.java | 9 +-
.../test/junit/assertions/CommandResultAssert.java | 118 +-
.../geode/test/junit/rules/ClientCacheRule.java | 70 +
.../geode/test/junit/rules/GfshCommandRule.java | 21 +-
.../geode/test/junit/rules/GfshParserRule.java | 12 +-
.../geode/test/junit/rules/LocatorStarterRule.java | 1 -
.../junit/rules/MBeanServerConnectionRule.java | 40 +-
.../geode/test/junit/rules/MemberStarterRule.java | 37 +-
.../apache/geode/test/junit/rules/VMProvider.java | 55 +
.../geode/test/process/MainLauncherJUnitTest.java | 32 +-
...unctionAdapterWithDifferentSerialVersionUID.ser | Bin 0 -> 151 bytes
.../apache/geode/codeAnalysis/excludedClasses.txt | 317 +-
.../org/apache/geode/codeAnalysis/openBugs.txt | 2 +
.../codeAnalysis/sanctionedDataSerializables.txt | 166 +-
.../geode/codeAnalysis/sanctionedSerializables.txt | 603 ---
.../BackupIntegrationTest.cache.xml} | 0
...nsJUnitTest.correctConfiguration[DTD].cache.xml | 26 +
...nsJUnitTest.correctConfiguration[XSD].cache.xml | 27 +
...pleReceiversShouldThrowException[DTD].cache.xml | 27 +
...pleReceiversShouldThrowException[XSD].cache.xml | 28 +
...serJUnitTest.testSimpleClientCacheXml.cache.xml | 2 +-
.../cache/query/internal/cq/ClientCQImpl.java | 6 +-
.../geode/internal/CQDistributedSystemService.java | 42 +
...e.distributed.internal.DistributedSystemService | 16 +
.../sanctioned-geode-cq-serializables.txt} | 0
.../cache/query/cq/dunit/CqPerfDUnitTest.java | 86 +-
.../query/cq/dunit/CqPerfUsingPoolDUnitTest.java | 100 +-
.../cache/snapshot/ClientSnapshotDUnitTest.java | 15 +
.../geode/internal/cache/PutAllCSDUnitTest.java | 8 +-
.../tier/sockets/ClientServerMiscBCDUnitTest.java | 11 +-
.../security/ClientAuthzObjectModDUnitTest.java | 3 -
.../geode/security/ClientCQAuthDUnitTest.java | 4 +-
.../geode/security/FilterPostAuthorization.java | 218 +
.../geode/security/FilterPreAuthorization.java | 144 +
.../org/apache/geode/security/ObjectWithAuthz.java | 67 +
.../running/firewalls_ports.html.md.erb | 4 +-
...ing_durable_client_server_messaging.html.md.erb | 2 +-
.../list_of_event_handlers_and_events.html.md.erb | 7 +-
.../eviction/configuring_data_eviction.html.md.erb | 60 +-
.../expiration/chapter_overview.html.md.erb | 4 +-
.../configuring_data_expiration.html.md.erb | 31 +-
.../expiration/how_expiration_works.html.md.erb | 29 +-
.../chapter_overview.html.md.erb | 2 +-
.../colocating_partitioned_region_data.html.md.erb | 41 +-
...om_partitioning_and_data_colocation.html.md.erb | 36 +-
.../fixed_custom_partitioning.html.md.erb | 204 +
...om_partitioning_and_data_colocation.html.md.erb | 14 +-
.../standard_custom_partitioning.html.md.erb | 178 +
.../using_custom_partition_resolvers.html.md.erb | 358 +-
.../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 +-
.../15_minute_quickstart_gfsh.html.md.erb | 20 +-
geode-docs/images/ClientServerAdvancedTopics-6.gif | Bin 12056 -> 0 bytes
geode-docs/images/ClientServerAdvancedTopics-6.png | Bin 0 -> 22878 bytes
geode-docs/images_svg/custom_partitioned.svg | 3 -
.../managing/heap_use/heap_management.html.md.erb | 2 +-
geode-docs/reference/statistics_list.html.md.erb | 44 +-
.../topics/cache-elements-list.html.md.erb | 2 +-
geode-docs/reference/topics/cache_xml.html.md.erb | 356 +-
.../reference/topics/elements_ref.html.md.erb | 6 +-
.../topics/gemfire_properties.html.md.erb | 13 +
.../reference/topics/gfe_cache_xml.html.md.erb | 3414 --------------
.../gfsh/command-pages/alter.html.md.erb | 57 +-
.../gfsh/command-pages/create.html.md.erb | 78 +-
.../gfsh/command-pages/destroy.html.md.erb | 49 +-
.../gfsh/command-pages/list.html.md.erb | 17 +-
.../gfsh/command-pages/start.html.md.erb | 2 +
.../tools_modules/gfsh/tour_of_gfsh.html.md.erb | 9 +-
.../tools_modules/lucene_integration.html.md.erb | 254 +-
geode-experimental-driver/build.gradle | 28 +
.../apache/geode/experimental/driver/Driver.java | 60 +
.../geode/experimental/driver/DriverFactory.java | 60 +
.../geode/experimental/driver/JSONWrapper.java | 76 +
.../geode/experimental/driver/ProtobufDriver.java | 175 +
.../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 | 111 +
.../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 +-
.../geode/test/junit/runners/SuiteBlockRunner.java | 3 +-
.../geode/test/junit/runners/SuiteRunner.java | 26 +
.../rules/ExecutorServiceRuleIntegrationTest.java | 131 +
.../test/junit/rules/ExecutorServiceRuleTest.java | 380 ++
.../lucene/internal/DestroyLuceneIndexMessage.java | 5 +-
.../lucene/internal/LuceneBucketListener.java | 6 +-
.../internal/LuceneIndexCreationProfile.java | 10 +-
.../internal/LuceneIndexForPartitionedRegion.java | 6 +-
.../cache/lucene/internal/LuceneServiceImpl.java | 5 +-
.../lucene/internal/cli/LuceneIndexCommands.java | 14 +-
.../cli/functions/LuceneCreateIndexFunction.java | 56 +-
.../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 -
.../internal/LuceneDistributedSystemService.java | 41 +
...e.distributed.internal.DistributedSystemService | 16 +
.../sanctioned-geode-lucene-serializables.txt | 20 +
.../geode/cache/lucene/EvictionDUnitTest.java | 4 +-
.../lucene/FlatFormatPdxSerializerJunitTest.java | 16 +-
.../lucene/LuceneClientSecurityDUnitTest.java | 5 +
.../lucene/LuceneCommandsSecurityDUnitTest.java | 4 +-
.../apache/geode/cache/lucene/LuceneDUnitTest.java | 15 +-
.../cache/lucene/LuceneQueriesAccessorBase.java | 18 +-
.../geode/cache/lucene/LuceneQueriesDUnitTest.java | 11 +
.../LuceneSearchWithRollingUpgradeDUnit.java | 43 +-
.../cache/lucene/MixedObjectIndexDUnitTest.java | 13 +
.../LuceneIndexRecoveryHAIntegrationTest.java | 1 -
.../internal/cli/LuceneIndexCommandsDUnitTest.java | 64 +-
...neIndexCommandsWithReindexAllowedDUnitTest.java | 228 +
.../LuceneCreateIndexFunctionJUnitTest.java | 20 +-
.../LuceneClusterConfigurationDUnitTest.java | 95 +-
...onWhereRegionCreatedBeforeReindexDUnitTest.java | 91 +
...ClusterConfigurationWithReindexFlagEnabled.java | 58 +
.../management/LuceneManagementDUnitTest.java | 62 +-
...uceneIndexXmlGeneratorIntegrationJUnitTest.java | 27 +-
...onCreatedBeforeReindexIntegrationJUnitTest.java | 56 +
...WithReindexFlagEnabledIntegrationJUnitTest.java | 39 +
.../LuceneIndexXmlParserIntegrationJUnitTest.java | 26 +-
.../lucene/test/LuceneFunctionSecurityTest.java | 131 +
.../AnalyzeLuceneSerializablesJUnitTest.java | 28 +
.../apache/geode/codeAnalysis/excludedClasses.txt | 0
.../org/apache/geode/codeAnalysis/openBugs.txt | 0
.../codeAnalysis/sanctionedDataSerializables.txt | 44 +
.../apache/geode/OldClientSupportDUnitTest.java | 12 +
geode-old-versions/build.gradle | 1 +
geode-protobuf-messages/build.gradle | 62 +
.../src/main/proto/protocolVersion.proto | 37 +
.../src/main/proto/v1/basicTypes.proto | 81 +
.../src/main/proto/v1/clientProtocol.proto | 74 +
.../src/main/proto/v1/connection_API.proto | 25 +
.../src/main/proto/v1/locator_API.proto | 34 +
.../src/main/proto/v1/region_API.proto | 86 +
geode-protobuf/build.gradle | 44 +-
.../operations/ProtobufOperationHandler.java | 31 +
.../statistics/ProtobufClientStatisticsImpl.java | 21 +-
.../protobuf/v1/EncodingTypeTranslator.java | 68 -
.../protobuf/v1/ProtobufCachePipeline.java | 19 +-
.../protobuf/v1/ProtobufLocatorPipeline.java | 58 -
.../protobuf/v1/ProtobufOperationContext.java | 6 +-
.../protocol/protobuf/v1/ProtobufOpsProcessor.java | 18 +-
.../protobuf/v1/ProtobufProtocolService.java | 20 +-
.../protobuf/v1/ProtobufSerializationService.java | 155 +-
.../protobuf/v1/ProtobufStreamProcessor.java | 5 +
.../operations/GetAllRequestOperationHandler.java | 65 +-
.../GetAvailableServersOperationHandler.java | 63 -
.../GetRegionNamesRequestOperationHandler.java | 6 +-
.../GetRegionRequestOperationHandler.java | 14 +-
.../v1/operations/GetRequestOperationHandler.java | 42 +-
.../v1/operations/GetServerOperationHandler.java | 89 +
.../HandshakeRequestOperationHandler.java | 64 -
.../v1/operations/ProtocolVersionHandler.java | 55 +
.../operations/PutAllRequestOperationHandler.java | 39 +-
.../v1/operations/PutRequestOperationHandler.java | 37 +-
.../operations/RemoveRequestOperationHandler.java | 33 +-
.../protobuf/v1/operations/VersionValidator.java | 43 +
.../AuthenticationRequestOperationHandler.java | 44 +-
.../registry/ProtobufOperationContextRegistry.java | 18 +-
.../v1/serializer/ProtobufProtocolSerializer.java | 1 +
.../ProtobufConnectionHandshakeStateProcessor.java | 36 +-
.../v1/utilities/ProtobufPrimitiveTypes.java | 49 -
.../v1/utilities/ProtobufRequestUtilities.java | 7 +-
.../v1/utilities/ProtobufResponseUtilities.java | 4 +-
.../protobuf/v1/utilities/ProtobufUtilities.java | 168 +-
.../exception/UnknownProtobufEncodingType.java | 24 +
.../exception/UnknownProtobufPrimitiveType.java | 24 -
geode-protobuf/src/main/proto/v1/basicTypes.proto | 88 -
.../src/main/proto/v1/clientProtocol.proto | 78 -
.../src/main/proto/v1/connection_API.proto | 45 -
geode-protobuf/src/main/proto/v1/region_API.proto | 95 -
geode-protobuf/src/main/proto/v1/server_API.proto | 32 -
.../internal/protocol/TestExecutionContext.java | 4 +-
...TypeToSerializationTypeTranslatorJUnitTest.java | 56 -
.../protobuf/v1/AuthenticationIntegrationTest.java | 37 +-
.../protobuf/v1/AuthorizationIntegrationTest.java | 16 +-
.../protocol/protobuf/v1/ErrorCodesJUnitTest.java | 45 +
.../protobuf/v1/HandshakeIntegrationTest.java | 125 -
.../internal/protocol/protobuf/v1/MessageUtil.java | 56 +-
.../v1/ProtocolVersionIntegrationTest.java | 143 +
.../v1/acceptance/CacheConnectionJUnitTest.java | 24 +-
.../CacheConnectionTimeoutJUnitTest.java | 17 +-
.../v1/acceptance/CacheMaxConnectionJUnitTest.java | 19 +-
.../v1/acceptance/CacheOperationsJUnitTest.java | 47 +-
.../LocatorConnectionAuthenticationDUnitTest.java | 156 +
.../v1/acceptance/LocatorConnectionDUnitTest.java | 27 +-
.../GetAllRequestOperationHandlerJUnitTest.java | 39 +-
.../GetAndPutJsonDocumentsDUnitTest.java | 248 +
...tAvailableServersOperationHandlerJUnitTest.java | 114 -
...egionNamesRequestOperationHandlerJUnitTest.java | 7 +-
.../GetRegionRequestOperationHandlerJUnitTest.java | 7 +-
.../GetRequestOperationHandlerJUnitTest.java | 38 +-
.../GetServerOperationHandlerJUnitTest.java | 104 +
.../HandshakeRequestOperationHandlerJUnitTest.java | 175 -
.../v1/operations/OperationHandlerJUnitTest.java | 9 +-
.../ProtocolVersionHandlerJUnitTest.java | 126 +
.../PutAllRequestOperationHandlerJUnitTest.java | 38 +-
.../PutRequestOperationHandlerJUnitTest.java | 44 +-
.../RemoveRequestOperationHandlerJUnitTest.java | 35 +-
.../v1/operations/VersionValidatorJUnitTest.java | 59 +
.../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 +-
.../internal/WANDistributedSystemService.java | 42 +
.../cache/wan/GatewayReceiverFactoryImpl.java | 6 +
.../wan/GatewaySenderEventRemoteDispatcher.java | 31 +-
...e.distributed.internal.DistributedSystemService | 15 +
.../sanctioned-geode-wan-serializables.txt} | 0
.../cache/wan/WANRollingUpgradeDUnitTest.java | 110 +-
.../cache/wan/CacheClientNotifierDUnitTest.java | 5 +-
.../wan/GatewayReceiverFactoryImplJUnitTest.java | 138 +
...atewaySenderEventRemoteDispatcherJUnitTest.java | 45 +
.../geode/internal/cache/wan/WANTestBase.java | 395 +-
.../cache/wan/misc/PDXNewWanDUnitTest.java | 200 +-
.../cache/wan/misc/WANConfigurationJUnitTest.java | 10 +-
...teAndDestroyGatewaySenderCommandsDUnitTest.java | 598 ---
...CreateDestroyGatewaySenderCommandDUnitTest.java | 328 ++
.../CreateGatewayReceiverCommandDUnitTest.java | 839 ++--
.../CreateGatewaySenderCommandDUnitTest.java | 181 -
.../DestroyGatewaySenderCommandDUnitTest.java | 60 -
.../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 | 129 +-
.../wan/wancommand/WanCommandListDUnitTest.java | 48 +-
.../geode/management/WANManagementDUnitTest.java | 413 +-
.../cli/commands/DescribeRegionDUnitTest.java | 68 +
...rConfigurationIndexWithFromClauseDUnitTest.java | 4 +-
.../WANClusterConfigurationDUnitTest.java | 15 +-
.../internal/pulse/TestRemoteClusterDUnitTest.java | 250 -
geode-web-api/build.gradle | 2 +
.../web/controllers/AbstractBaseController.java | 4 +-
.../sanctioned-geode-web-api-serializables.txt | 0
geode-web-api/src/main/webapp/META-INF/NOTICE | 4 +-
.../AnalyzeWebApiSerializablesJUnitTest.java | 28 +
.../apache/geode/codeAnalysis/excludedClasses.txt | 8 +
.../org/apache/geode/codeAnalysis/openBugs.txt | 0
.../codeAnalysis/sanctionedDataSerializables.txt | 0
geode-web/src/main/webapp/META-INF/NOTICE | 2 +-
.../cli/commands/AlterRuntimeCommandDUnitTest.java | 58 +-
.../commands/ClusterConfigurationDUnitTest.java | 6 +-
.../cli/commands/CommandOverHttpDUnitTest.java | 4 +-
.../cli/commands/ConnectCommandWithSSLTest.java | 4 +-
.../commands/DescribeConfigCommandDUnitTest.java | 8 +-
...xecuteFunctionCommandWithSecurityDUnitTest.java | 9 +-
.../cli/commands/ExportConfigCommandDUnitTest.java | 8 +-
.../commands/ExportLogsStatsOverHttpDUnitTest.java | 2 +-
.../FunctionCommandsOverHttpDUnitTest.java | 5 +-
.../internal/security/LogNoPasswordTest.java | 4 +-
.../internal/web/util/ConvertUtilsJUnitTest.java | 185 -
gradle.properties | 5 +-
gradle/dependency-versions.properties | 12 +-
gradle/java.gradle | 6 +
gradle/publish.gradle | 6 +-
gradle/test.gradle | 5 +-
settings.gradle | 4 +-
1904 files changed, 74712 insertions(+), 51074 deletions(-)
create mode 100644 ci/docker/docker.list
create mode 100644 ci/docker/initdocker
create mode 100644 ci/docker/tini-wrapper.go
create mode 100755 ci/scripts/build-examples.sh
create mode 100755 ci/scripts/test-archive.sh
create mode 100755 ci/scripts/test-run.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/ConfigureEvictionThroughGfsh.java
create mode 100644 geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/DeployWithLargeJarTest.java
create mode 100644 geode-assembly/src/test/java/org/apache/geode/management/internal/cli/commands/DestroyIndexIfExistsTest.java
delete mode 100755 geode-assembly/src/test/java/org/apache/geode/management/internal/cli/shell/GfshExitCodeStatusCommandsTest.java
create mode 100644 geode-assembly/src/test/java/org/apache/geode/management/internal/cli/shell/StatusLocatorExitCodeAcceptanceTest.java
create mode 100755 geode-assembly/src/test/java/org/apache/geode/management/internal/cli/shell/StatusServerExitCodeAcceptanceTest.java
create mode 100644 geode-assembly/src/test/java/org/apache/geode/tools/pulse/PulseJmxPasswordFileTest.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
delete mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/security/exception/IncompatibleAuthenticationMechanismsException.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/java/org/apache/geode/internal/protocol/state/ConnectionHandshakingStateProcessor.java
create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/ConnectionTerminatingStateProcessor.java
create mode 100644 geode-client-protocol/src/main/java/org/apache/geode/internal/protocol/state/exception/OperationNotAuthorizedException.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
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/BackupDataStoreHelper.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/BackupDataStoreResult.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupRequest.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupResponse.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskRequest.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskResponse.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupRequest.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupResponse.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
create mode 100644 geode-core/src/main/java/org/apache/geode/distributed/internal/DistributedSystemService.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/EmptyInputStreamFilter.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/InputStreamFilter.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/ObjectInputStreamFilterWrapper.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskLRURegionEntry.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionMap.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/BackupLock.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/BackupManager.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/BackupUtil.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionEvictior.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/EvictableRegion.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/EvictionAttributesMutatorImpl.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/HasDiskRegion.java~d2263ebc2... Create HasDiskRegion interface
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/RegionEvictorTask.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupDataStoreHelper.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupDataStoreResult.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/BackupInspector.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupLock.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupManager.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupOperation.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupReplyProcessor.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupResponse.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupResultCollector.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/BackupUtil.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/internal/cache/backup/FinishBackup.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FinishBackupFactory.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FinishBackupOperation.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FinishBackupRequest.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FlushToDisk.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FlushToDiskFactory.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FlushToDiskOperation.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FlushToDiskProcessor.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FlushToDiskRequest.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/FlushToDiskResponse.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/PrepareBackup.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/PrepareBackupFactory.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/PrepareBackupOperation.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/PrepareBackupRequest.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/RestoreScript.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/ScriptGenerator.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/UnixBackupInspector.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/UnixScriptGenerator.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/WindowsBackupInspector.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/backup/WindowsScriptGenerator.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/entries/AbstractDiskLRURegionEntry.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/AbstractEvictionController.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/AbstractEvictionList.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/CachedDeserializableValueWrapper.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/CountLRUEviction.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/CountLRUStatistics.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/DisabledEvictionCounters.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictableEntry.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictableMap.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionController.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionCounters.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionCountersImpl.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionList.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionListBuilder.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionNode.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/EvictionStats.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/GuardNode.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/HeapEvictor.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/HeapLRUController.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/HeapLRUStatistics.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/LIFOList.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/LRUListWithAsyncSorting.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/LRUListWithSyncSorting.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/MemoryLRUController.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/MemoryLRUStatistics.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/OffHeapEvictor.java
create mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/RegionEvictorTask.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/eviction/SizeLRUController.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/lru/EnableLRU.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/HeapEvictor.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/HeapLRUCapacityController.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/HeapLRUStatistics.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUAlgorithm.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUCapacityController.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUClockNode.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUEntry.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUMapCallbacks.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/lru/LRUStatistics.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/MemLRUCapacityController.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLIFOClockHand.java
delete mode 100755 geode-core/src/main/java/org/apache/geode/internal/cache/lru/NewLRUClockHand.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/OffHeapEvictor.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/lru/Sizeable.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/BackupInspector.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/RestoreScript.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/ScriptGenerator.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/UnixBackupInspector.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/UnixScriptGenerator.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/WindowsBackupInspector.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/persistence/WindowsScriptGenerator.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/security/FilterPostAuthorization.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/security/FilterPreAuthorization.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/internal/security/ObjectWithAuthz.java
create mode 100644 geode-core/src/main/java/org/apache/geode/internal/size/Sizeable.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/AlterAsyncEventQueueCommand.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/converters/BaseStringConverter.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/cli/converters/GatewayReceiverIdsConverter.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/cli/functions/DestroyDiskStoreFunctionArgs.java
create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/configuration/functions/DownloadJarFunction.java
create mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/configuration/functions/GetClusterConfigurationFunction.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/configuration/handlers/ConfigurationRequestHandler.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/configuration/messages/ConfigurationRequest.java
delete mode 100644 geode-core/src/main/java/org/apache/geode/management/internal/web/util/ConvertUtils.java
create mode 100644 geode-core/src/main/resources/org/apache/geode/internal/sanctioned-geode-core-serializables.txt
create mode 100644 geode-core/src/test/java/org/apache/geode/cache/RegionExpirationDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/cache/RegionExpirationIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/cache/client/internal/TXFailoverOpTest.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/cache30/CacheXmlNotFoundRegressionTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/cache30/RegionExpirationDUnitTest.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/InternalDataSerializerSerializationWhitelistTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/AbstractLRURegionMapTest.java
delete mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/BackupDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/BackupJUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/Bug37244JUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/CacheProfileTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/CacheWriterGetOldValueIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/ClusterConfigurationLoaderIntegrationTest.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/DiskStoreMonitorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/DiskUsageTest.java
delete mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/EvictionDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/EvictionObjectSizerDUnitTest.java
delete mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/EvictionStatsDUnitTest.java
delete mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/EvictionTestBase.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/IncrementalBackupDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/InitialImageOperationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/LRUClearWithDiskRegionOpRegressionTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/OffHeapEvictionDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/OffHeapEvictionStatsDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/RegionCommitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/TXRegionLockRequestImplTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/TXStateProxyImplJUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/TXStateProxyImplTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/TXSynchronizationRunnableTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/VMLRURegionMapTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupDefinitionTest.java
create mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupDistributedTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupInspectorIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupLockTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupPrepareAndFinishMsgDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/BackupReplyProcessorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FileSystemBackupDestinationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FinishBackupFactoryTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FinishBackupOperationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FinishBackupRequestTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FlushToDiskFactoryTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FlushToDiskOperationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/FlushToDiskRequestTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/IncrementalBackupDistributedTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/PartitionedBackupPrepareAndFinishMsgDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/PrepareBackupFactoryTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/PrepareBackupOperationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/PrepareBackupRequestTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/ReplicateBackupPrepareAndFinishMsgDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/UnixScriptGeneratorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/backup/WindowsScriptGeneratorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/AbstractEvictionListTest.java
create mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/EvictionDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/EvictionObjectSizerDUnitTest.java
create mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/EvictionStatsDUnitTest.java
create mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/EvictionTestBase.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LIFOListTest.java
create mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LRUListWithAsyncSortingIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LRUListWithAsyncSortingTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LRUListWithSyncSortingIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LRUListWithSyncSortingTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LRUTestEntry.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/LinkableEvictionNode.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/OffHeapEvictionDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/OffHeapEvictionStatsDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/RegionEntryEvictionIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/TestEvictionController.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/TestLRUListWithAsyncSorting.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/eviction/TransactionsWithOverflowTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/lru/LRUAlgorithmTest.java
delete mode 100755 geode-core/src/test/java/org/apache/geode/internal/cache/lru/LRUClockJUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/lru/TransactionsWithOverflowTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/persistence/BackupInspectorIntegrationTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/persistence/BackupPrepareAndFinishMsgDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/persistence/PartitionedBackupPrepareAndFinishMsgDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/persistence/ReplicateBackupPrepareAndFinishMsgDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/persistence/UnixScriptGeneratorTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/persistence/WindowsScriptGeneratorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/snapshot/ClientExporterTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/tier/sockets/AcceptorImplClientQueueDUnitTest.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/internal/cache/tx/ClientTXStateStubTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/versions/RegionVersionVectorJUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/versions/RegionVersionVectorTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverXmlParsingValidationsJUnitTest.java
rename geode-core/src/{main => test}/java/org/apache/geode/internal/size/SizeOfUtil0.java (100%)
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/beans/RegionMBeanAttributesTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/beans/TestEventListener.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterAsyncEventQueueCommandDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterAsyncEventQueueCommandTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterDiskStoreDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/AlterDiskStoreJUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/CommandAvailabilityIndicatorTest.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/CreateAsyncEventQueueCommandDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/CreateAsyncEventQueueCommandTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/CreateGatewayReceiverCommandTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/CreateGatewaySenderCommandTest.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/DescribeConnectionCommandJUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DescribeDiskStoreCommandIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DescribeRegionDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DescribeRegionIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DescribeRegionJUnitTest.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/ListAndDescribeDiskStoreCommandsDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListAndDescribeRegionDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListAsyncEventQueuesCommandDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListDiskStoreCommandIntegrationTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListMembersCommandTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListRegionDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ListRegionIntegrationTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/QueueCommandsDUnitTest.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/commands/TestObjectSizerNotDeclarable.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/converters/BaseStringConverterJUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/cli/domain/RegionDescriptionJUnitTest.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/cli/result/TabularResultDataTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/configuration/ClusterConfigurationServiceDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/configuration/functions/GetClusterConfigurationFunctionTest.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/management/internal/security/MultiClientDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/security/MultiGfshDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/security/MultiUserAuthenticationDUnitTest.java
delete mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/security/MultiUserDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/security/ClusterConfigNotEnabledDUnitTest.java
create mode 100644 geode-core/src/test/java/org/apache/geode/security/ClusterConfigurationSecurityDUnitTest.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
delete mode 100755 geode-core/src/test/resources/org/apache/geode/codeAnalysis/sanctionedSerializables.txt
rename geode-core/src/test/resources/org/apache/geode/internal/cache/{BackupJUnitTest.cache.xml => backup/BackupIntegrationTest.cache.xml} (100%)
create mode 100755 geode-core/src/test/resources/org/apache/geode/internal/cache/wan/GatewayReceiverXmlParsingValidationsJUnitTest.correctConfiguration[DTD].cache.xml
create mode 100755 geode-core/src/test/resources/org/apache/geode/internal/cache/wan/GatewayReceiverXmlParsingValidationsJUnitTest.correctConfiguration[XSD].cache.xml
create mode 100755 geode-core/src/test/resources/org/apache/geode/internal/cache/wan/GatewayReceiverXmlParsingValidationsJUnitTest.multipleReceiversShouldThrowException[DTD].cache.xml
create mode 100755 geode-core/src/test/resources/org/apache/geode/internal/cache/wan/GatewayReceiverXmlParsingValidationsJUnitTest.multipleReceiversShouldThrowException[XSD].cache.xml
create mode 100644 geode-cq/src/main/java/org/apache/geode/internal/CQDistributedSystemService.java
create mode 100644 geode-cq/src/main/resources/META-INF/services/org.apache.geode.distributed.internal.DistributedSystemService
rename geode-cq/src/{test/resources/org/apache/geode/codeAnalysis/sanctionedSerializables.txt => main/resources/org/apache/geode/internal/sanctioned-geode-cq-serializables.txt} (100%)
create mode 100644 geode-cq/src/test/java/org/apache/geode/security/FilterPostAuthorization.java
create mode 100644 geode-cq/src/test/java/org/apache/geode/security/FilterPreAuthorization.java
create mode 100644 geode-cq/src/test/java/org/apache/geode/security/ObjectWithAuthz.java
create mode 100644 geode-docs/developing/partitioned_regions/fixed_custom_partitioning.html.md.erb
create mode 100644 geode-docs/developing/partitioned_regions/standard_custom_partitioning.html.md.erb
delete mode 100644 geode-docs/images/ClientServerAdvancedTopics-6.gif
create mode 100644 geode-docs/images/ClientServerAdvancedTopics-6.png
delete mode 100644 geode-docs/images_svg/custom_partitioned.svg
delete mode 100644 geode-docs/reference/topics/gfe_cache_xml.html.md.erb
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/main/java/org/apache/geode/internal/LuceneDistributedSystemService.java
create mode 100644 geode-lucene/src/main/resources/META-INF/services/org.apache.geode.distributed.internal.DistributedSystemService
create mode 100755 geode-lucene/src/main/resources/org/apache/geode/internal/sanctioned-geode-lucene-serializables.txt
create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/cli/LuceneIndexCommandsWithReindexAllowedDUnitTest.java
create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/configuration/LuceneClusterConfigurationWhereRegionCreatedBeforeReindexDUnitTest.java
create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/configuration/LuceneClusterConfigurationWithReindexFlagEnabled.java
create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/xml/LuceneIndexXmlGeneratorWhereRegionCreatedBeforeReindexIntegrationJUnitTest.java
create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/xml/LuceneIndexXmlGeneratorWithReindexFlagEnabledIntegrationJUnitTest.java
create mode 100644 geode-lucene/src/test/java/org/apache/geode/cache/lucene/test/LuceneFunctionSecurityTest.java
create mode 100755 geode-lucene/src/test/java/org/apache/geode/codeAnalysis/AnalyzeLuceneSerializablesJUnitTest.java
copy {geode-wan => geode-lucene}/src/test/resources/org/apache/geode/codeAnalysis/excludedClasses.txt (100%)
copy {geode-wan => geode-lucene}/src/test/resources/org/apache/geode/codeAnalysis/openBugs.txt (100%)
create mode 100644 geode-lucene/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
create mode 100644 geode-protobuf-messages/build.gradle
create mode 100644 geode-protobuf-messages/src/main/proto/protocolVersion.proto
create mode 100644 geode-protobuf-messages/src/main/proto/v1/basicTypes.proto
create mode 100644 geode-protobuf-messages/src/main/proto/v1/clientProtocol.proto
create mode 100644 geode-protobuf-messages/src/main/proto/v1/connection_API.proto
create mode 100644 geode-protobuf-messages/src/main/proto/v1/locator_API.proto
create mode 100644 geode-protobuf-messages/src/main/proto/v1/region_API.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/HandshakeRequestOperationHandler.java
create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ProtocolVersionHandler.java
create mode 100644 geode-protobuf/src/main/java/org/apache/geode/internal/protocol/protobuf/v1/operations/VersionValidator.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/main/proto/v1/basicTypes.proto
delete mode 100644 geode-protobuf/src/main/proto/v1/clientProtocol.proto
delete mode 100644 geode-protobuf/src/main/proto/v1/connection_API.proto
delete mode 100644 geode-protobuf/src/main/proto/v1/region_API.proto
delete mode 100644 geode-protobuf/src/main/proto/v1/server_API.proto
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/HandshakeRequestOperationHandlerJUnitTest.java
create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/ProtocolVersionHandlerJUnitTest.java
create mode 100644 geode-protobuf/src/test/java/org/apache/geode/internal/protocol/protobuf/v1/operations/VersionValidatorJUnitTest.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/main/java/org/apache/geode/internal/WANDistributedSystemService.java
create mode 100644 geode-wan/src/main/resources/META-INF/services/org.apache.geode.distributed.internal.DistributedSystemService
copy geode-wan/src/{test/resources/org/apache/geode/codeAnalysis/sanctionedSerializables.txt => main/resources/org/apache/geode/internal/sanctioned-geode-wan-serializables.txt} (100%)
create mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewayReceiverFactoryImplJUnitTest.java
create mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/GatewaySenderEventRemoteDispatcherJUnitTest.java
delete mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/CreateAndDestroyGatewaySenderCommandsDUnitTest.java
create mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/CreateDestroyGatewaySenderCommandDUnitTest.java
delete mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/CreateGatewaySenderCommandDUnitTest.java
delete mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/wancommand/DestroyGatewaySenderCommandDUnitTest.java
create mode 100644 geode-wan/src/test/java/org/apache/geode/management/internal/cli/commands/DescribeRegionDUnitTest.java
delete mode 100644 geode-wan/src/test/java/org/apache/geode/management/internal/pulse/TestRemoteClusterDUnitTest.java
copy geode-wan/src/test/resources/org/apache/geode/codeAnalysis/sanctionedSerializables.txt => geode-web-api/src/main/resources/org/apache/geode/internal/sanctioned-geode-web-api-serializables.txt (100%)
mode change 100755 => 100644
create mode 100644 geode-web-api/src/test/java/org/apache/geode/codeAnalysis/AnalyzeWebApiSerializablesJUnitTest.java
create mode 100644 geode-web-api/src/test/resources/org/apache/geode/codeAnalysis/excludedClasses.txt
copy geode-wan/src/test/resources/org/apache/geode/codeAnalysis/sanctionedSerializables.txt => geode-web-api/src/test/resources/org/apache/geode/codeAnalysis/openBugs.txt (100%)
mode change 100755 => 100644
rename geode-wan/src/test/resources/org/apache/geode/codeAnalysis/sanctionedSerializables.txt => geode-web-api/src/test/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt (100%)
mode change 100755 => 100644
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" <co...@geode.apache.org>'].
[geode] 01/01: GEODE-3967: when
ConcurrentCacheModificationException happened. GatewaySenderEventImpl
should save the status and notify gatewaysender anyway. SerialGatewaySender
will handle it. In AbstractUpdateOperation's doPutOrCreate's 3 tries of
basicUpdate, the 3rd one should allow both create and update.
Posted by zh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a commit to branch feature/GEODE-3967
in repository https://gitbox.apache.org/repos/asf/geode.git
commit 68054778c8030a88281cada6a693e72b935c9144
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Sat Jan 20 17:39:00 2018 -0800
GEODE-3967: when ConcurrentCacheModificationException happened. GatewaySenderEventImpl should save the status and notify gatewaysender anyway. SerialGatewaySender will handle it. In AbstractUpdateOperation's doPutOrCreate's 3 tries of basicUpdate, the 3rd one should allow both create and update.
---
.../apache/geode/internal/cache/AbstractRegionMap.java | 3 +++
.../geode/internal/cache/AbstractUpdateOperation.java | 2 +-
.../org/apache/geode/internal/cache/LocalRegion.java | 18 +++++++++++++-----
.../internal/cache/wan/GatewaySenderEventImpl.java | 6 +++++-
.../wan/serial/SerialGatewaySenderEventProcessor.java | 9 ++++++---
5 files changed, 28 insertions(+), 10 deletions(-)
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java
index 487c35a..1fe9c00 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java
@@ -1185,6 +1185,7 @@ public abstract class AbstractRegionMap implements RegionMap {
true/* conflict with clear */, duringRI, true);
doPart3 = true;
} catch (ConcurrentCacheModificationException ccme) {
+ event.isConcurrencyConflict(true);
VersionTag tag = event.getVersionTag();
if (tag != null && tag.isTimeStampUpdated()) {
// Notify gateways of new time-stamp.
@@ -2096,6 +2097,7 @@ public abstract class AbstractRegionMap implements RegionMap {
}
} // !opCompleted
} catch (ConcurrentCacheModificationException ccme) {
+ event.isConcurrencyConflict(true);
VersionTag tag = event.getVersionTag();
if (tag != null && tag.isTimeStampUpdated()) {
// Notify gateways of new time-stamp.
@@ -2854,6 +2856,7 @@ public abstract class AbstractRegionMap implements RegionMap {
clearOccured = true;
owner.recordEvent(event);
} catch (ConcurrentCacheModificationException ccme) {
+ event.isConcurrencyConflict(true);
VersionTag tag = event.getVersionTag();
if (tag != null && tag.isTimeStampUpdated()) {
// Notify gateways of new time-stamp.
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java
index 585e131..a706abd 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java
@@ -175,7 +175,7 @@ public abstract class AbstractUpdateOperation extends DistributedCacheOperation
|| (rgn.getDataPolicy().withReplication() && rgn.getConcurrencyChecksEnabled())) {
overwriteDestroyed = true;
ev.makeCreate();
- rgn.basicUpdate(ev, true /* ifNew */, false/* ifOld */, lastMod,
+ rgn.basicUpdate(ev, false /* ifNew */, false/* ifOld */, lastMod,
overwriteDestroyed);
rgn.getCachePerfStats().endPut(startPut, ev.isOriginRemote());
updated = true;
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java
index aca96d0..4a9ff44 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java
@@ -2840,6 +2840,8 @@ public class LocalRegion extends AbstractRegion implements LoaderHelperFactory,
logger.debug("caught concurrent modification attempt when applying {}", event);
}
notifyBridgeClients(event);
+ notifyGatewaySender(event.getOperation().isUpdate() ? EnumListenerEvent.AFTER_UPDATE
+ : EnumListenerEvent.AFTER_CREATE, event);
}
if (!getDataView().isDeferredStats()) {
getCachePerfStats().endPut(startPut, event.isOriginRemote());
@@ -5618,6 +5620,8 @@ public class LocalRegion extends AbstractRegion implements LoaderHelperFactory,
logger.debug("caught concurrent modification attempt when applying {}", event);
}
notifyBridgeClients(event);
+ notifyGatewaySender(event.getOperation().isUpdate() ? EnumListenerEvent.AFTER_UPDATE
+ : EnumListenerEvent.AFTER_CREATE, event);
return false;
}
@@ -5844,6 +5848,9 @@ public class LocalRegion extends AbstractRegion implements LoaderHelperFactory,
updateTimeStampEvent.setGenerateCallbacks(false);
updateTimeStampEvent.distributedMember = event.getDistributedMember();
updateTimeStampEvent.setNewEventId(getSystem());
+ if (event.isConcurrencyConflict()) {
+ updateTimeStampEvent.isConcurrencyConflict(true);
+ }
if (event.getRegion() instanceof BucketRegion) {
BucketRegion bucketRegion = (BucketRegion) event.getRegion();
@@ -6100,8 +6107,7 @@ public class LocalRegion extends AbstractRegion implements LoaderHelperFactory,
}
protected void notifyGatewaySender(EnumListenerEvent operation, EntryEventImpl event) {
- if (isPdxTypesRegion() || event.isConcurrencyConflict()) {
- // isConcurrencyConflict is usually a concurrent cache modification problem
+ if (isPdxTypesRegion()) {
return;
}
@@ -6125,9 +6131,10 @@ public class LocalRegion extends AbstractRegion implements LoaderHelperFactory,
if (allRemoteDSIds != null) {
for (GatewaySender sender : getCache().getAllGatewaySenders()) {
if (allGatewaySenderIds.contains(sender.getId())) {
- // TODO: This is a BUG. Why return and not continue?
- if (!this.getDataPolicy().withStorage() && sender.isParallel()) {
- return;
+ // if isConcurrencyConflict is true, only notify serial gateway sender
+ if ((!this.getDataPolicy().withStorage() || event.isConcurrencyConflict())
+ && sender.isParallel()) {
+ continue;
}
if (logger.isDebugEnabled()) {
logger.debug("Notifying the GatewaySender : {}", sender.getId());
@@ -6485,6 +6492,7 @@ public class LocalRegion extends AbstractRegion implements LoaderHelperFactory,
// Notify clients only if its NOT a gateway event.
if (event.getVersionTag() != null && !event.getVersionTag().isGatewayTag()) {
notifyBridgeClients(event);
+ notifyGatewaySender(EnumListenerEvent.AFTER_DESTROY, event);
}
return true; // event was elided
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventImpl.java
index 2748c7d..e744afc 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventImpl.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/GatewaySenderEventImpl.java
@@ -171,6 +171,8 @@ public class GatewaySenderEventImpl
protected boolean isInitialized;
+ public boolean isConcurrencyConflict = false;
+
/**
* Is this thread in the process of serializing this event?
*/
@@ -312,6 +314,7 @@ public class GatewaySenderEventImpl
if (initialize) {
initialize();
}
+ this.isConcurrencyConflict = event.isConcurrencyConflict();
}
/**
@@ -744,7 +747,8 @@ public class GatewaySenderEventImpl
.append(";creationTime=").append(this.creationTime).append(";shadowKey= ")
.append(this.shadowKey).append(";timeStamp=").append(this.versionTimeStamp)
.append(";acked=").append(this.isAcked).append(";dispatched=").append(this.isDispatched)
- .append(";bucketId=").append(this.bucketId).append("]");
+ .append(";bucketId=").append(this.bucketId).append(";isConcurrencyConflict=")
+ .append(this.isConcurrencyConflict).append("]");
return buffer.toString();
}
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
index 734b560..d5d0baa 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
@@ -35,6 +35,7 @@ import org.apache.geode.SystemFailure;
import org.apache.geode.cache.CacheException;
import org.apache.geode.cache.CacheListener;
import org.apache.geode.cache.EntryEvent;
+import org.apache.geode.cache.Operation;
import org.apache.geode.cache.Region;
import org.apache.geode.cache.RegionDestroyedException;
import org.apache.geode.cache.wan.GatewayQueueEvent;
@@ -423,9 +424,11 @@ public class SerialGatewaySenderEventProcessor extends AbstractGatewaySenderEven
} else {
// If it is not, create an uninitialized GatewayEventImpl and
// put it into the map of unprocessed events.
- senderEvent = new GatewaySenderEventImpl(operation, event, substituteValue, false); // OFFHEAP
- // ok
- handleSecondaryEvent(senderEvent);
+ if (!event.getOperation().equals(Operation.UPDATE_VERSION_STAMP)) {
+ senderEvent = new GatewaySenderEventImpl(operation, event, substituteValue, false); // OFFHEAP
+ // ok
+ handleSecondaryEvent(senderEvent);
+ }
}
}
}
--
To stop receiving notification emails like this one, please contact
"commits@geode.apache.org" <co...@geode.apache.org>.