This is an automated email from the ASF dual-hosted git repository.
nnag pushed a change to branch feature/GEODE-7665
in repository https://gitbox.apache.org/repos/asf/geode.git.
omit 4cd3917 GEODE-8173: Add unit test (coverage) for
PartitionedRegionClear class. (#5208)
omit cdcdc51 GEODE-7669 Test coverage for Partitioned Region clear with
Overflow enabled (#5189)
omit 93ff5f4 GEODE-7678 (2nd PR) - Support for cache-listener and
client-notification for Partitioned Region Clear operation (#5124)
omit 86ef373 GEODE-7667: Fixing test to include PR clear help text.
omit edc4162 GEODE-7894: Moving expiry tasks to AbstractRegion.
omit 19b9316 GEODE-7676: Conversion of duration to seconds.
omit ef0c7ae GEODE-7667: Add a 'clear' gfsh command for PR and RR clear
(#4818)
omit 8930e7e GEODE-7676: Add PR clear with expiration tests (#4970)
omit bdfd611 GEODE-7983: Clear region writer callbacks should not be
invoked for bucket regions (#4954)
omit be614cc GEODE-7912: cacheWriter should be triggered when PR.clear
(#4882)
omit 19a6079 PR.clear's event id should be created and used in BR (#4805)
omit 41efe40 GEODE-7682: add PR.clear API (#4755)
omit d757db8 GEODE-7683: introduce BR.cmnClearRegion
add d82e30d GEODE-8243: Use java.exe on Windows in Launcher tests (#5241)
add cb5990c GEODE-8221: Refactor tests to run in appropriate projects.
(#5244)
add 4477013 GEODE-8179: gfsh query cmd returns incorrect results if '='
sign is missing (#5187)
add dd6a002 GEODE-8244: enable ignored redis tests (#5245)
add e5426f7 change more string commands to have CommandFunction support
(#5184)
add 0f763ea GEODE-8099: add dlock around cms create/delete operations.
(#5188)
add 4789e8c GEODE-8242: Add HSTRLEN redis command (#5240)
add 9e52198 GEODE-8253: Add additional concurrency tests for redis DEL
(#5252)
add b1107d2 GEODE-8144: setting SNI server name is not needed if endpoint
verification is disabled (#5250)
add 70fe060 GEODE-7896 Update tomcat support
add bcbc53b Merge pull request #5110 from metatype/develop
add a5c8164 GEODE-8260: add toString to RedisData classes (#5255)
add d405e4b GEODE-8176: Move test to ClientServerMiscDUnitTest (#5238)
add 7609cfa GEODE-8261: Added a null check for the proxyID. (#5251)
add 8d5e3d4 GEODE-7864: Overriding hashCode when equals in overridden
(#4866)
add e159238 GEODE-8268: clean up ExecutionHandlerContext (#5237)
add 86778ec GEODE-7591: Fix for hang in ClusterDistributionManager (#5182)
add d1e857d GEODE-8270: Reorganize test packages to match main package
structure (#5263)
add 9fdd3d0 GEODE-8263: change SET command to reject KEEPTTL (#5258)
add c93773f GEODE-8274: Improve readability of Version comparison. (#5266)
add e955968 GEODE-8264: add serialization tests for RedisData classes
(#5260)
add 87a2f10 GEODE-8237: Add note about 'alter region' & cluster conf
service (#5231)
add a6640d7 GEODE-8277: acceptance test certificates expired in
Dockerized SNI acceptance tests (#5274)
add 9ea7a7c GEODE-8276: fix KEYS command to handle non-ASCII keys (#5272)
add 3e7f2df GEODE-8269: Improve test coverage for redis (#5262)
add 215643b GEODE-8216: Refactoring the test - moving the location of
pausing senders. (#5259)
add 720a4ca GEODE-8241: Locator observes locator-wait-time (#5236)
add 84ab66b GEODE-8272 Refactor Restore Redundancy Command (#5249)
add 18e5817 GEODE-8269: Improve test coverage (#5275)
add 4a825a8 GEODE-8251: make sure Configuration can be deserialized post
1.12. (#5257)
add 16e2c7b GEODE-8280: Return correct Redis AUTH errors (#5276)
add 9939cc0 GEODE-8221: Commits session data prior to sending output to
browser (#5246)
add 3c52713 Add Mass Test Run pipeline. (#5271)
add cd4477a GEODE-8284: Break up StringsIntegration test class (#5277)
add 9f1bf04 GEODE-8273: Cleanup GfshExecution and GfshScript (#5267)
add 91fd5f5 GEODE-8289: Add gradle task chaining for
geode-old-versions:clean (#5283)
add ca5d961 GEODE-8275: Improvements to mass-test-run after first pass
deployment (#5287)
add 210dc4f GEODE-8250: Geode Logging doc changes (#5294)
add 5256fde GEODE-8288: Match Native Redis's glob-style pattern (#5282)
add d740a70 GEODE-8239 - Add gradle config to add 'Class-Path' and
'Dependent-Modules' attirbutes to manifest file. (#5297)
add ba6e44c GEODE-8250: Create new custom log config acceptance tests
(#5268)
add eed47f4 Fix metric-tools image python requirements. (#5298)
add ab83b61 GEODE-8285: Change location of generated test file to build
dir and fix error message path for sanctioned text file (#5280)
add 5732a1c GEODE-8095 Further rework of the RestoreRedundancy data
objects for serialization (#5281)
add 5e2baea Feature/expand pubsub support (#5284)
add 827f865 GEODE-8287: Added another condition to cause the indexed
value to be used
add 33987ae Revert "GEODE-8250: Create new custom log config acceptance
tests (#5268)" (#5301)
add 561533c GEODE-8200: enhance GfshRule to specify a working dir (#5299)
add a89dbea GEODE-8295: refactor GeodeRedisServer (#5289)
add b65af0e GEODE-8099: make those gfsh commands that updates cluster
configurati… (#5285)
add 9cc61bf GEODE-8217: Deserialize attribute before update and remove.
(#5256)
add 036e94f GEODE-8305: Revert "Feature/expand pubsub support (#5284)"
(#5310)
add 1801310 GEODE-8283: Provide REST interface for disk-store creation
add 2c25481 Fix spotless issues
add a664647 Add missing documentation files to assembly
add 5ea4e0d Updating assembly validation txt (#4)
add 7e5dc04 Fix jq issues
add 5f98828 Disk store rest api (#5)
add c68479d Add JQ testing for disk-store controller
add 99d21ea Change DiskDir size to be Integer
add 9834ffa Fix serializables
add 97ba5d0 Remove Id field from DiskStore
add c9ed7d7 GEODE-8283: Provide REST interface for disk-store creation
(#5288)
add 3cda1b1 GEODE-8195: ConcurrentModificationException from
LocatorMembershipListenerImpl (#5306)
add b164321 GEODE-8304 - Better highlight steps for building
documentation (#5308)
add 15d6d26 First pass at switching to liberica jdk. (#5312)
add f84e9e8 GEODE-8303: refactor Redis (String)SetExecutor (#5216)
add 6bd1d4b GEODE-8247: modified FilterRoutingInfo checks (#5248)
add d4fec09 GEODE-8301: add redis stats (#5307)
add 3b4b8ea GEODE-8309: fix ping to return its parameter (#5314)
add f1a2c47 GEODE-8311: fix setrange to prefix value (#5315)
add a936e6c Fix test-container and internal docker image. (#5319)
add 63a245b GEODE-8310: remove numThreads redis sys prop (#5311)
add 84fc86d GEODE-8315: update Shiro from 1.5.2 to 1.5.3 (#5321)
add 34cfe04 GEODE-8176: Fix flakiness in testPingWrongServer (#5303)
add f5c5e2c GEODE-8095: Changes to make GEODE Respond to Restore
Redundancy REST Command (#5300)
add 4caa90b GEODE-8312: Improve Redis pub/sub capabilities (#5316)
add 3f3b77e GEODE-8110: Ignore AlertingIOException in
JMXMBeanReconnectDUnitTest (#5323)
add c79a5bc Revert "Fix test-container and internal docker image.
(#5319)" (#5326)
add f521117 GEODE-8172: flaky test (#5148)
add 4ff9955 GEODE-8319: fix NPE when cluster configuration folder does
not exist … (#5325)
add bfe1ca1 GEODE-8240: Member Identifier Future Versions
add 5d6fcf1 GEODE-7864: Fix array index out of bounds alerts (#5330)
add ee9a4b0 GEODE-8259: when client singlehop getAll encountered
SerializationException, it should retry (#5253)
add ffeabe0 GEODE-8239 - Add gradle config to add 'Class-Path' and
'Dependent-Modules' attirbutes to manifest file. (#5317)
add fdc4401 GEODE-8029: Allow OplogEntryIdSet to Overflow (#5329)
add 5e6c9e9 GEODE-8250: Create new custom log config acceptance tests
(#5309)
add 54a21c5 GEODE-8328: Fix GfshRuleIntegrationTest on Windows (#5345)
add ee13af8 GEODE-8327: buildSrc depends directly on guava. Declare it.
Misc other build fixups (#5339)
add 7badfc7 GEODE-8332: Refactor inregion classes (#5320)
add 625a204 GEODE-8323: Process QueueRemovalMessage after queue
initialized. (#5333)
add 868d4bc GEODE-8330: Structural Improvements to Versioning
add 13d17ec GEODE-8313: Improve RedisData synchronization for toData
(#5318)
add 9d7d467 GEODE-8341: Correct docs typo in gfsh export logs (#5352)
add fae1c94 GEODE-7956: Correct documentation of legal region names
(format fix) (#5362)
new 3e8304c GEODE-7683: introduce BR.cmnClearRegion
new 6174f70 GEODE-7682: add PR.clear API (#4755)
new 23954be PR.clear's event id should be created and used in BR (#4805)
new 2840a19 GEODE-7912: cacheWriter should be triggered when PR.clear
(#4882)
new 32f59fc GEODE-7983: Clear region writer callbacks should not be
invoked for bucket regions (#4954)
new 75ae591 GEODE-7676: Add PR clear with expiration tests (#4970)
new 9bf176c GEODE-7667: Add a 'clear' gfsh command for PR and RR clear
(#4818)
new c78064a GEODE-7676: Conversion of duration to seconds.
new 43192d2 GEODE-7894: Moving expiry tasks to AbstractRegion.
new 2e8c7a8 GEODE-7667: Fixing test to include PR clear help text.
new 8eeaac4 GEODE-7678 (2nd PR) - Support for cache-listener and
client-notification for Partitioned Region Clear operation (#5124)
new b49e67c GEODE-7669 Test coverage for Partitioned Region clear with
Overflow enabled (#5189)
new af4b35a GEODE-8173: Add unit test (coverage) for
PartitionedRegionClear class. (#5208)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (4cd3917)
\
N -- N -- N refs/heads/feature/GEODE-7665 (af4b35a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 13 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:
.../src/test/resources/expected-pom.xml | 2 +-
buildSrc/build.gradle | 1 +
.../gradle/plugins/DependencyConstraints.groovy | 4 +-
ci/bin/concourse_job_performance.py | 20 +-
ci/bin/concourse_job_performance_requirements.txt | 5 +
ci/images/meta-mini/Dockerfile | 2 +-
ci/images/metric-tools/Dockerfile | 1 +
ci/pipelines/mass-test-run/deploy_pipeline.sh | 90 ++
ci/pipelines/mass-test-run/jinja.template.yml | 440 ++++++++
ci/pipelines/meta/deploy_meta.sh | 2 +
ci/pipelines/meta/destroy_pipelines.sh | 2 +-
ci/pipelines/meta/jinja.template.yml | 54 +
ci/pipelines/shared/jinja.variables.yml | 1 +
dev-tools/docker/docs/README.md | 4 +-
extensions/geode-modules-assembly/build.gradle | 4 +
extensions/geode-modules-session/build.gradle | 3 +
extensions/geode-modules-test/build.gradle | 15 +-
...SessionsBase.java => AbstractSessionsTest.java} | 143 +--
...AbstractCommitSessionValveIntegrationTest.java} | 42 +-
.../AbstractDeltaSessionIntegrationTest.java | 110 ++
...t.java => AbstractDeltaSessionManagerTest.java} | 189 ++--
...UnitTest.java => AbstractDeltaSessionTest.java} | 103 +-
.../AbstractSessionValveIntegrationTest.java | 0
.../ClientServerSessionCacheJUnitTest.java | 319 ------
extensions/geode-modules-tomcat7/build.gradle | 4 +
...ionsJUnitTest.java => Tomcat7SessionsTest.java} | 10 +-
.../CommitSessionValveIntegrationTest.java | 57 ++
.../session/catalina/DeltaSession7Test.java} | 38 +-
.../catalina/Tomcat7CommitSessionOutputBuffer.java | 53 +
.../catalina/Tomcat7CommitSessionValve.java | 58 ++
.../catalina/Tomcat7DeltaSessionManager.java | 12 +-
.../session/catalina/DeltaSession7Test.java | 147 +++
.../Tomcat7CommitSessionOutputBufferTest.java | 63 ++
.../catalina/Tomcat7CommitSessionValveTest.java | 98 ++
...st.java => Tomcat7DeltaSessionManagerTest.java} | 7 +-
extensions/geode-modules-tomcat8/build.gradle | 109 +-
.../CommitSessionValveIntegrationTest.java | 57 ++
.../session/catalina/DeltaSession8Test.java} | 38 +-
.../modules/session/catalina/DeltaSession8.java | 1 +
.../catalina/Tomcat8CommitSessionOutputBuffer.java | 60 ++
.../catalina/Tomcat8CommitSessionValve.java | 59 ++
.../catalina/Tomcat8DeltaSessionManager.java | 8 +-
.../session/catalina/DeltaSession8Test.java | 147 +++
.../Tomcat8CommitSessionOutputBufferTest.java | 77 ++
.../catalina/Tomcat8CommitSessionValveTest.java | 98 ++
...st.java => Tomcat8DeltaSessionManagerTest.java} | 3 +-
extensions/geode-modules-tomcat9/build.gradle | 15 +-
.../CommitSessionValveIntegrationTest.java | 52 +
.../session/catalina/DeltaSession9Test.java} | 40 +-
.../catalina/Tomcat9CommitSessionOutputBuffer.java | 53 +
.../catalina/Tomcat9CommitSessionValve.java | 58 ++
.../catalina/Tomcat9DeltaSessionManager.java | 7 +-
.../session/catalina/DeltaSession9Test.java | 147 +++
.../Tomcat9CommitSessionOutputBufferTest.java | 60 ++
.../catalina/Tomcat9CommitSessionValveTest.java | 94 ++
...st.java => Tomcat9DeltaSessionManagerTest.java} | 3 +-
extensions/geode-modules/build.gradle | 7 +-
...ionsJUnitTest.java => Tomcat6SessionsTest.java} | 4 +-
.../catalina/AbstractCommitSessionValve.java | 83 ++
.../session/catalina/CommitSessionValve.java | 69 --
.../modules/session/catalina/DeltaSession.java | 366 ++++---
.../session/catalina/DeltaSessionManager.java | 164 +--
....java => DeltaSessionManagerConfiguration.java} | 46 +-
.../session/catalina/JvmRouteBinderValve.java | 10 +-
.../modules/session/catalina/SessionCommitter.java | 23 +-
.../modules/session/catalina/SessionManager.java | 4 +
.../catalina/Tomcat6CommitSessionValve.java | 20 +-
.../catalina/Tomcat6DeltaSessionManager.java | 7 +-
.../callback/SessionExpirationCacheListener.java | 2 +-
.../catalina/AbstractSessionCacheTest.java} | 29 +-
.../catalina/ClientServerSessionCacheTest.java | 303 +++++-
.../session/catalina/DeltaSessionFacadeTest.java} | 6 +-
.../catalina/PeerToPeerSessionCacheTest.java} | 26 +-
.../SessionExpirationCacheListenerTest.java} | 10 +-
.../DeltaSessionAttributeEventBatchTest.java} | 17 +-
.../DeltaSessionDestroyAttributeEventTest.java} | 9 +-
.../internal/DeltaSessionStatisticsTest.java} | 11 +-
.../DeltaSessionUpdateAttributeEventTest.java} | 10 +-
.../modules/util/CreateRegionFunctionTest.java} | 17 +-
...TouchPartitionedRegionEntriesFunctionTest.java} | 16 +-
.../TouchReplicatedRegionEntriesFunctionTest.java} | 20 +-
.../session/AccessAttributeValueListener.java | 29 +-
.../src/main/webapp/WEB-INF/web.xml | 4 +
geode-assembly/build.gradle | 6 +-
geode-assembly/geode-assembly-test/build.gradle | 2 +
.../apache/geode/session/tests/TomcatInstall.java | 2 +-
.../client/sni/GenerateSNIKeyAndTrustStores.java | 79 ++
...rLauncherWithCustomLogConfigAcceptanceTest.java | 6 +-
.../LocatorLauncherWithPulseAcceptanceTest.java | 6 +-
...rWithPulseAndCustomLogConfigAcceptanceTest.java | 6 +-
...rLauncherWithCustomLogConfigAcceptanceTest.java | 6 +-
.../LocatorWithCustomLogConfigAcceptanceTest.java | 288 ++++++
.../ServerWithCustomLogConfigAcceptanceTest.java | 212 ++++
.../internal/cli/shell/DirectoryTree.java | 68 ++
.../shell/StatusLocatorExitCodeAcceptanceTest.java | 303 +++---
.../shell/StatusServerExitCodeAcceptanceTest.java | 233 +++--
.../sni/geode-config/locator-maeve-keystore.jks | Bin 3525 -> 3529 bytes
.../geode-config/server-clementine-keystore.jks | Bin 3537 -> 3537 bytes
.../sni/geode-config/server-dolores-keystore.jks | Bin 3528 -> 3533 bytes
.../geode/client/sni/geode-config/truststore.jks | Bin 1126 -> 1129 bytes
...stomLogConfigAcceptanceTestWithGeodePlugins.xml | 49 +
...mLogConfigAcceptanceTestWithoutGeodePlugins.xml | 37 +
...stomLogConfigAcceptanceTestWithGeodePlugins.xml | 49 +
...mLogConfigAcceptanceTestWithoutGeodePlugins.xml | 37 +
.../management/JQFilterVerificationDUnitTest.java | 35 +-
.../rest/RestoreRedundancyManagementDUnitTest.java | 345 +++++++
.../apache/geode/session/tests/CargoTestBase.java | 41 +-
.../org/apache/geode/session/tests/LogChecker.java | 126 +++
.../test/junit/rules/GfshRuleIntegrationTest.java | 85 ++
.../integrationTest/resources/assembly_content.txt | 36 +-
.../resources/dependency_classpath.txt | 18 +-
.../geode/test/junit/rules/GfshRuleTest.java | 51 -
.../DeploymentManagementUpgradeTest.java | 52 +-
.../jdbc/internal/cli/DeregisterDriverCommand.java | 4 +-
.../jdbc/internal/cli/ListDriversCommand.java | 4 +-
.../jdbc/internal/cli/RegisterDriverCommand.java | 4 +-
geode-core/build.gradle | 620 ++++++------
.../IndexUsageInJoinQueryDistributedTest.java | 215 ++++
.../ClusterDistributionManagerDUnitTest.java | 33 +
.../RestoreRedundancyOperationDUnitTest.java | 32 +-
.../tier/sockets/ClientServerMiscDUnitTest.java | 35 +-
.../management/JMXMBeanReconnectDUnitTest.java | 2 +
.../cache/client/ClientCacheFactoryJUnitTest.java | 6 +-
.../cache/execute/CoreFunctionSecurityTest.java | 2 +
...igurationPersistenceServiceIntegrationTest.java | 48 +
.../cache/ha/HARegionQueueIntegrationTest.java | 2 +-
.../internal/net/SSLSocketIntegrationTest.java | 29 +-
.../version/VersionManagerIntegrationTest.java} | 33 +-
.../codeAnalysis/sanctionedDataSerializables.txt | 112 +-
.../org/apache/geode/cache/AttributesFactory.java | 4 +-
.../client/internal/ClientSideHandshakeImpl.java | 33 +-
.../geode/cache/client/internal/GetAllOp.java | 38 +-
.../pooling/AvailableConnectionManager.java | 6 +
.../geode/cache/configuration/CacheConfig.java | 2 +-
.../geode/cache/control/ResourceManager.java | 1 +
.../cache/control/RestoreRedundancyOperation.java | 2 +
.../geode/cache/query/internal/QueryUtils.java | 3 +
.../internal/ClusterDistributionManager.java | 6 +-
.../InternalConfigurationPersistenceService.java | 57 +-
.../internal/LonerDistributionManager.java | 4 +-
.../distributed/internal/ReplyProcessor21.java | 16 +-
.../distributed/internal/locks/DLockService.java | 12 +
.../membership/InternalDistributedMember.java | 5 +-
.../internal/streaming/StreamingOperation.java | 6 +-
.../org/apache/geode/internal/AvailablePort.java | 2 +-
.../org/apache/geode/internal/DSFIDFactory.java | 10 +-
.../geode/internal/InternalDataSerializer.java | 2 +-
.../geode/internal/VersionedObjectOutput.java | 2 +-
.../internal/cache/AbstractUpdateOperation.java | 2 +-
.../apache/geode/internal/cache/DiskInitFile.java | 3 +-
.../geode/internal/cache/DiskStoreAttributes.java | 60 ++
.../geode/internal/cache/DiskStoreFactoryImpl.java | 84 +-
.../apache/geode/internal/cache/DiskStoreImpl.java | 83 +-
.../internal/cache/DistributedPutAllOperation.java | 5 +-
.../cache/DistributedRemoveAllOperation.java | 10 +-
.../org/apache/geode/internal/cache/EventID.java | 4 +-
...xpireDisconnectedClientTransactionsMessage.java | 4 +-
.../apache/geode/internal/cache/FilterProfile.java | 23 +-
.../geode/internal/cache/GemFireCacheImpl.java | 3 +-
.../org/apache/geode/internal/cache/HARegion.java | 15 +-
.../internal/cache/InitialImageOperation.java | 25 +-
.../org/apache/geode/internal/cache/Oplog.java | 39 +-
.../geode/internal/cache/PartitionedRegion.java | 4 +-
.../cache/PartitionedRegionQueryEvaluator.java | 2 +-
.../geode/internal/cache/ServerPingMessage.java | 2 +-
.../geode/internal/cache/TXCommitMessage.java | 2 +-
.../internal/cache/TXRegionLockRequestImpl.java | 4 +-
.../internal/cache/TxCallbackEventFactoryImpl.java | 3 +-
.../cache/control/InternalResourceManager.java | 2 +-
.../control/RestoreRedundancyOperationImpl.java | 28 +-
.../control/RestoreRedundancyResultsImpl.java | 206 ----
...=> SerializableRegionRedundancyStatusImpl.java} | 58 +-
.../SerializableRestoreRedundancyResultsImpl.java | 77 ++
.../cache/execute/FunctionRemoteContext.java | 4 +-
.../geode/internal/cache/ha/HARegionQueue.java | 87 +-
.../internal/cache/ha/QueueRemovalMessage.java | 169 ++--
.../cache/partitioned/FetchBulkEntriesMessage.java | 4 +-
.../cache/partitioned/FetchEntriesMessage.java | 4 +-
.../cache/partitioned/FetchKeysMessage.java | 4 +-
.../cache/partitioned/IndexCreationMsg.java | 2 +-
.../cache/partitioned/PartitionMemberInfoImpl.java | 4 +-
.../cache/partitioned/PartitionMessage.java | 4 +-
.../cache/partitioned/PutAllPRMessage.java | 7 +-
.../internal/cache/partitioned/QueryMessage.java | 4 +-
.../cache/partitioned/RemoveAllPRMessage.java | 8 +-
.../partitioned/StreamingPartitionOperation.java | 5 +-
.../cache/persistence/DiskInitFileParser.java | 13 +-
.../persistence/query/mock/ByteComparator.java | 2 +-
.../internal/cache/tier/sockets/BaseCommand.java | 6 +-
.../cache/tier/sockets/BaseCommandQuery.java | 6 +-
.../cache/tier/sockets/CacheClientNotifier.java | 4 +-
.../cache/tier/sockets/ChunkedMessage.java | 2 +-
.../tier/sockets/ClientDataSerializerMessage.java | 6 +-
.../tier/sockets/ClientInstantiatorMessage.java | 4 +-
.../tier/sockets/ClientInterestMessageImpl.java | 2 +-
.../tier/sockets/ClientMarkerMessageImpl.java | 2 +-
.../cache/tier/sockets/ClientPingMessageImpl.java | 2 +-
.../tier/sockets/ClientProxyMembershipID.java | 8 +-
.../tier/sockets/ClientRegistrationMetadata.java | 71 +-
.../tier/sockets/ClientUpdateMessageImpl.java | 8 +-
.../cache/tier/sockets/MessageDispatcher.java | 2 +-
.../cache/tier/sockets/ServerConnection.java | 6 +-
.../tier/sockets/ServerSideHandshakeFactory.java | 50 +-
.../tier/sockets/ServerSideHandshakeImpl.java | 21 +-
.../cache/tier/sockets/SocketMessageWriter.java | 8 +-
.../tier/sockets/command/CloseConnection.java | 2 +-
.../sockets/command/GatewayReceiverCommand.java | 2 +-
.../internal/cache/tier/sockets/command/Put65.java | 4 +-
.../tier/sockets/command/RegisterInterest61.java | 2 +-
.../sockets/command/RegisterInterestList66.java | 2 +-
.../geode/internal/cache/tx/DistTxEntryEvent.java | 4 +-
.../internal/cache/tx/RemoteFetchKeysMessage.java | 5 +-
.../internal/cache/tx/RemotePutAllMessage.java | 2 +-
.../internal/cache/tx/RemoteRemoveAllMessage.java | 2 +-
.../geode/internal/cache/versions/VersionTag.java | 2 +-
.../internal/cache/wan/GatewaySenderAdvisor.java | 4 +-
.../xmlcache/DiskStoreAttributesCreation.java | 25 +-
.../cache/xmlcache/ResourceManagerCreation.java | 2 +-
.../apache/geode/internal/net/SocketCreator.java | 10 +-
.../org/apache/geode/internal/tcp/Connection.java | 16 +-
.../management/internal/BaseManagementService.java | 7 +
.../api/LocatorClusterManagementService.java | 239 +++--
.../converters/DiskStoreConverter.java | 126 +++
.../configuration/domain/Configuration.java | 9 +-
.../configuration/mutators/DiskStoreManager.java | 76 ++
.../configuration/realizers/DiskStoreRealizer.java | 118 +++
.../validators/DiskStoreValidator.java | 101 ++
.../functions/CacheRealizationFunction.java | 3 +
.../internal/functions/RebalanceFunction.java | 31 +-
.../functions/RestoreRedundancyFunction.java | 93 ++
.../internal/operation/OperationManager.java | 2 +
.../operation/RebalanceOperationPerformer.java | 77 +-
.../operation/RestoreRedundancyPerformer.java | 182 ++++
.../management/internal/util/ManagementUtils.java | 3 +-
.../org/apache/geode/pdx/internal/PdxField.java | 2 +-
.../org/apache/geode/pdx/internal/PdxType.java | 2 +-
.../sanctioned-geode-core-serializables.txt | 3 +-
.../cache/client/internal/GetAllOpJUnitTest.java | 101 ++
...nternalConfigurationPersistenceServiceTest.java | 74 +-
.../distributed/internal/InternalLocatorTest.java} | 80 +-
...eDisconnectedClientTransactionsMessageTest.java | 2 +-
.../apache/geode/internal/cache/HARegionTest.java | 77 ++
.../internal/cache/OplogEntryIdSetJUnitTest.java | 74 --
.../geode/internal/cache/OplogEntryIdSetTest.java | 169 ++++
.../control/RegionRedundancyStatusImplTest.java | 12 +-
.../RestoreRedundancyOperationImplTest.java | 14 +-
...ializableRestoreRedundancyResultsImplTest.java} | 148 +--
.../geode/internal/cache/ha/HARegionQueueTest.java | 57 ++
.../internal/cache/ha/QueueRemovalMessageTest.java | 215 ++++
.../api/LocatorClusterManagementServiceTest.java | 31 +
.../converters/DiskStoreConverterTest.java | 120 +++
.../mutators/DiskStoreManagerTest.java | 109 ++
.../realizers/DiskStoreRealizerTest.java | 117 +++
.../validators/DiskStoreValidatorTest.java | 167 +++
.../functions/RestoreRedundancyFunctionTest.java | 150 +++
.../operation/RestoreRedundancyPerformerTest.java | 264 +++++
.../RollingUpgrade2DUnitTestBase.java | 5 +-
.../rollingupgrade/RollingUpgradeDUnitTest.java | 23 +-
.../RollingUpgradeWithGfshDUnitTest.java | 128 +++
.../geode/cache/query/cq/CQDistributedTest.java | 80 +-
.../data_regions/region_naming.html.md.erb | 2 +-
.../cluster_config/gfsh_persist.html.md.erb | 4 +-
.../logging/configuring_log4j2.html.md.erb | 32 +-
.../managing/logging/how_logging_works.html.md.erb | 2 +-
.../gfsh/command-pages/export.html.md.erb | 2 +-
.../internal/cache/functions/TestFunction.java | 6 +
.../sockets/ClientServerMiscDUnitTestBase.java | 30 -
.../commands/QueryCommandIntegrationTestBase.java | 15 +-
.../main/java/org/apache/geode/test/dunit/VM.java | 10 +
geode-gfsh/build.gradle | 2 +-
.../RestoreRedundancyCommandDUnitTest.java | 10 +-
.../commands/StatusRedundancyCommandDUnitTest.java | 6 +-
.../apache/geode/management/cli/GfshCommand.java | 8 +
.../geode/management/cli/SingleGfshCommand.java | 13 +-
.../geode/management/internal/cli/GfshParser.java | 24 +-
.../cli/commands/AlterOfflineDiskStoreCommand.java | 4 +-
.../cli/commands/AlterRuntimeConfigCommand.java | 5 +
.../commands/CompactOfflineDiskStoreCommand.java | 4 +-
.../cli/commands/CreateGatewaySenderCommand.java | 3 +-
.../internal/cli/commands/DeployCommand.java | 7 +-
.../commands/DescribeOfflineDiskStoreCommand.java | 4 +-
.../cli/commands/DescribeQueryServiceCommand.java | 4 +-
.../commands/ExportOfflineDiskStoreCommand.java | 4 +-
.../cli/commands/ListJndiBindingCommand.java | 2 +-
.../commands/LoadBalanceGatewaySenderCommand.java | 4 +-
.../cli/commands/PauseGatewaySenderCommand.java | 4 +-
.../internal/cli/commands/RedundancyCommand.java | 155 +--
.../cli/commands/RestoreRedundancyCommand.java | 2 +-
.../ResumeAsyncEventQueueDispatcherCommand.java | 4 +-
.../cli/commands/ResumeGatewaySenderCommand.java | 4 +-
.../cli/commands/StartGatewayReceiverCommand.java | 4 +-
.../cli/commands/StartGatewaySenderCommand.java | 4 +-
.../cli/commands/StatusGatewayReceiverCommand.java | 4 +-
.../cli/commands/StatusGatewaySenderCommand.java | 4 +-
.../cli/commands/StopGatewayReceiverCommand.java | 4 +-
.../cli/commands/StopGatewaySenderCommand.java | 4 +-
.../internal/cli/commands/UndeployCommand.java | 5 +
.../commands/UpgradeOfflineDiskStoreCommand.java | 4 +-
.../cli/functions/RedundancyCommandFunction.java | 78 --
.../internal/cli/remote/CommandExecutor.java | 50 +-
.../internal/cli/remote/MemberCommandService.java | 7 +
.../cli/remote/OnlineCommandProcessor.java | 19 +-
.../internal/cli/shell/GfshExecutionStrategy.java | 2 +-
.../sanctioned-geode-gfsh-serializables.txt | 1 -
.../internal/cli/GfshParserJUnitTest.java | 62 ++
.../commands/CreateGatewaySenderCommandTest.java | 4 +-
.../cli/commands/RedundancyCommandTest.java | 523 ----------
.../functions/RedundancyCommandFunctionTest.java | 137 ---
.../internal/cli/remote/CommandExecutorTest.java | 66 +-
.../cli/remote/MemberCommandServiceTest.java | 20 +-
.../cli/remote/OnlineCommandProcessorTest.java | 8 +-
.../main/java/org/apache/geode/DeltaTestImpl.java | 9 +
.../org/apache/geode/cache/ssl/CertStores.java | 4 +-
.../AnalyzeDataSerializablesJUnitTestBase.java | 31 +-
.../cache/PartitionedRegionTestHelper.java | 8 +
.../geode/pdx/TestObjectForJSONFormatter.java | 26 +
.../security/query/data/PdxQueryTestObject.java | 7 +
.../geode/security/query/data/QueryTestObject.java | 7 +
.../assertj/internal/AbstractLogFileAssert.java | 5 +
.../geode/test/junit/rules/GfshParserRule.java | 3 +-
.../geode/test/junit/rules/gfsh/GfshExecution.java | 160 +--
.../geode/test/junit/rules/gfsh/GfshRule.java | 100 +-
.../geode/test/junit/rules/gfsh/GfshScript.java | 124 ++-
.../org/apache/geode/test/version/TestVersion.java | 11 -
.../apache/geode/test/version/VersionManager.java | 176 ++--
.../cache/lucene/internal/LuceneServiceImpl.java | 9 +-
.../internal/distributed/LuceneQueryFunction.java | 2 +-
.../LuceneSearchWithRollingUpgradeTestBase.java | 13 +-
.../configuration/AbstractConfiguration.java | 2 +-
.../geode/management/configuration/Deployment.java | 17 +-
.../geode/management/configuration/DiskDir.java | 54 +
.../geode/management/configuration/DiskStore.java | 164 +++
.../operation/RegionRedundancyStatusImpl.java | 103 ++
.../operation/RestoreRedundancyResultsImpl.java | 240 +++++
.../operation/RestoreRedundancyRequest.java | 127 +++
.../geode/management/runtime/DeploymentInfo.java | 3 +
.../geode/management/runtime/DiskStoreInfo.java | 25 +
.../apache/geode/management/runtime/IndexInfo.java | 3 +
.../runtime}/RegionRedundancyStatus.java | 11 +-
.../runtime}/RestoreRedundancyResults.java | 35 +-
.../sanctioned-geode-management-serializables.txt | 12 +-
.../RestoreRedundancyResultsImplTest.java | 57 ++
.../operation/RestoreRedundancyRequestTest.java | 33 +-
geode-membership/build.gradle | 23 +-
.../gms/GMSMemberDataVersionJUnitTest.java | 99 ++
.../membership/gms/MembershipIntegrationTest.java | 120 ++-
.../gms/membership/GMSJoinLeaveJUnitTest.java | 30 +
.../internal/membership/api/MemberData.java | 4 +-
.../internal/membership/api/MemberIdentifier.java | 3 +-
.../internal/membership/gms/GMSMemberData.java | 48 +-
.../internal/membership/gms/GMSMembership.java | 9 +-
.../internal/membership/gms/GMSMembershipView.java | 19 +
.../membership/gms/MemberIdentifierImpl.java | 25 +-
.../membership/gms/locator/GMSLocator.java | 6 +-
.../membership/gms/membership/GMSJoinLeave.java | 23 +-
.../membership/gms/messenger/JGroupsMessenger.java | 36 +-
.../gemstone/gemfire/OldClientSupportProvider.java | 4 +-
geode-old-versions/README.md | 55 +
geode-old-versions/build.gradle | 8 +-
geode-redis/build.gradle | 2 +
.../GlobPatternNativeRedisAcceptanceTest.java} | 15 +-
.../connection/AuthNativeRedisAcceptanceTest.java} | 46 +-
.../connection/PingNativeRedisAcceptanceTest.java} | 16 +-
.../hash}/HashesNativeRedisAcceptanceTest.java | 2 +-
.../key/DelNativeRedisAcceptanceTest.java} | 16 +-
.../key/ExistsNativeRedisAcceptanceTest.java} | 5 +-
.../key}/ExpireAtNativeRedisAcceptanceTest.java | 3 +-
.../key}/ExpireNativeRedisAcceptanceTest.java | 3 +-
.../key/KeysNativeRedisAcceptanceTest.java} | 11 +-
.../key/PTTLNativeRedisAcceptanceTest.java} | 15 +-
.../key}/PersistNativeRedisAcceptanceTest.java | 3 +-
.../key}/PexpireNativeRedisAcceptanceTest.java | 3 +-
.../key}/RenameNativeRedisAcceptanceTest.java | 2 +-
.../key/TTLNativeRedisAcceptanceTest.java} | 15 +-
.../key/TypeNativeRedisAcceptanceTest.java} | 16 +-
.../pubsub}/PubSubNativeRedisAcceptanceTest.java | 2 +-
.../set}/SDiffNativeRedisAcceptanceTest.java | 2 +-
.../set}/SInterNativeRedisAcceptanceTest.java | 2 +-
.../set/SIsMemberNativeRedisAcceptanceTest.java} | 12 +-
.../set}/SMoveNativeRedisAcceptanceTest.java | 2 +-
.../set}/SPopNativeRedisAcceptanceTest.java | 2 +-
.../set}/SRemNativeRedisAcceptanceTest.java | 2 +-
.../set}/SUnionNativeRedisAcceptanceTest.java | 2 +-
.../set}/SetsNativeRedisAcceptanceTest.java | 2 +-
.../string/AppendNativeRedisAcceptanceTest.java} | 14 +-
.../string/BitCountNativeRedisAcceptanceTest.java} | 18 +-
.../string/BitOpNativeRedisAcceptanceTest.java} | 16 +-
.../string/BitPosNativeRedisAcceptanceTest.java} | 16 +-
.../string/DecrByNativeRedisAcceptanceTest.java} | 15 +-
.../string/DecrNativeRedisAcceptanceTest.java} | 14 +-
.../string/GetBitNativeRedisAcceptanceTest.java} | 16 +-
.../string/GetNativeRedisAcceptanceTest.java} | 16 +-
.../string/GetRangeNativeRedisAcceptanceTest.java} | 17 +-
.../string/GetSetNativeRedisAcceptanceTest.java} | 14 +-
.../IncrByFloatNativeRedisAcceptanceTest.java} | 13 +-
.../string/IncrByNativeRedisAcceptanceTest.java} | 13 +-
.../string/IncrNativeRedisAcceptanceTest.java} | 14 +-
.../string/MGetNativeRedisAcceptanceTest.java} | 15 +-
.../string/MSetNXNativeRedisAcceptanceTest.java} | 15 +-
.../string/MSetNativeRedisAcceptanceTest.java} | 14 +-
.../string/PSetEXNativeRedisAcceptanceTest.java} | 15 +-
.../string/SetBitNativeRedisAcceptanceTest.java} | 15 +-
.../string/SetExNativeRedisAcceptanceTest.java} | 15 +-
.../string/SetNXNativeRedisAcceptanceTest.java} | 15 +-
.../string/SetNativeRedisAcceptanceTest.java} | 14 +-
.../string/SetRangeNativeRedisAcceptanceTest.java} | 17 +-
.../string/StrLenNativeRedisAcceptanceTest.java} | 15 +-
.../apache/geode/redis/GeodeRedisServerRule.java | 9 +-
.../geode/redis/CheckPrimaryBucketFunction.java | 6 +-
.../redis/GeodeRedisServerStartupDUnitTest.java | 2 +-
.../org/apache/geode/redis/RedisDistDUnitTest.java | 94 +-
.../executor}/hash/HMsetDUnitTest.java | 15 +-
.../executor/hash/HashesAndCrashesDUnitTest.java | 314 ++++++
.../executor}/hash/HsetDUnitTest.java | 14 +-
.../executor/key}/ExistsDUnitTest.java | 2 +-
.../executor/key}/ExpireDUnitTest.java | 6 +-
.../executor/key}/PersistDUnitTest.java | 2 +-
.../executor/key}/RenameDUnitTest.java | 2 +-
.../executor/pubsub}/PubSubDUnitTest.java | 61 +-
.../executor}/set/SaddDUnitTest.java | 14 +-
.../executor}/set/SremDUnitTest.java | 14 +-
.../executor}/string/StringsDUnitTest.java | 16 +-
.../config/DUnitSocketAddressResolver.java | 6 +
.../redis/ConcurrentStartIntegrationTest.java | 99 --
.../apache/geode/redis/PubSubIntegrationTest.java | 320 ------
.../apache/geode/redis/StringsIntegrationTest.java | 1067 --------------------
.../executor/GlobPatternIntegrationTest.java | 264 +++++
.../executor/UnknownIntegrationTest.java} | 33 +-
.../executor/connection}/AuthIntegrationTest.java | 136 ++-
.../executor/connection/PingIntegrationTest.java | 81 ++
.../executor/hash}/HashesIntegrationTest.java | 85 +-
.../internal/executor/key/DelIntegrationTest.java | 117 +++
.../executor}/key/ExistsIntegrationTest.java | 2 +-
.../executor}/key/ExpireAtIntegrationTest.java | 12 +-
.../executor}/key/ExpireIntegrationTest.java | 36 +-
.../internal/executor/key/KeysIntegrationTest.java | 100 ++
.../executor/key/PTTLIntegrationTest.java} | 51 +-
.../executor}/key/PersistIntegrationTest.java | 2 +-
.../executor}/key/PexpireIntegrationTest.java | 38 +-
.../executor/key}/RenameIntegrationTest.java | 55 +-
.../executor/key/TTLIntegrationTest.java} | 51 +-
.../internal/executor/key/TypeIntegrationTest.java | 93 ++
.../executor/pubsub/PubSubIntegrationTest.java | 682 +++++++++++++
.../executor/server}/FlushAllIntegrationTest.java | 2 +-
.../executor/server}/ShutdownIntegrationTest.java | 2 +-
.../executor/server}/TimeIntegrationTest.java | 2 +-
.../executor/set}/SDiffIntegrationTest.java | 2 +-
.../executor/set}/SInterIntegrationTest.java | 2 +-
.../executor/set/SIsMemberIntegrationTest.java | 91 ++
.../executor/set}/SMoveIntegrationTest.java | 2 +-
.../executor/set}/SPopIntegrationTest.java | 2 +-
.../executor/set}/SRemIntegrationTest.java | 31 +-
.../executor/set}/SUnionIntegrationTest.java | 2 +-
.../executor/set}/SetsIntegrationTest.java | 63 +-
.../executor/string/AppendIntegrationTest.java | 107 ++
.../executor/string/BitCountIntegrationTest.java | 158 +++
.../executor/string/BitOpIntegrationTest.java | 209 ++++
.../executor/string/BitPosIntegrationTest.java | 76 ++
.../executor/string/DecrByIntegrationTest.java} | 60 +-
.../executor/string/DecrIntegrationTest.java | 91 ++
.../executor/string/GetBitIntegrationTest.java} | 60 +-
.../executor/string/GetIntegrationTest.java} | 60 +-
.../executor/string/GetRangeIntegrationTest.java | 144 +++
.../executor/string/GetSetIntegrationTest.java | 163 +++
.../string/IncrByFloatIntegrationTest.java} | 48 +-
.../executor/string/IncrByIntegrationTest.java} | 59 +-
.../executor/string/IncrIntegrationTest.java | 121 +++
.../executor/string/MGetIntegrationTest.java} | 40 +-
.../executor/string/MSetIntegrationTest.java | 160 +++
.../executor/string/MSetNXIntegrationTest.java} | 47 +-
.../executor/string/PSetEXIntegrationTest.java} | 32 +-
.../executor/string/SetBitIntegrationTest.java | 95 ++
.../executor/string/SetEXIntegrationTest.java} | 32 +-
.../executor/string/SetIntegrationTest.java | 500 +++++++++
.../executor/string/SetNXIntegrationTest.java} | 44 +-
.../executor/string/SetRangeIntegrationTest.java | 107 ++
.../executor/string/StrLenIntegrationTest.java} | 52 +-
.../pubsub/SubscriptionsIntegrationTest.java | 117 +--
.../pubsub => mocks}/DummySubscription.java | 15 +-
.../apache/geode/redis/mocks/MockSubscriber.java | 53 +
.../codeAnalysis/sanctionedDataSerializables.txt | 4 +
.../geode/redis/internal/GeodeRedisServer.java | 599 +----------
.../geode/redis/internal/GeodeRedisService.java | 19 +-
.../redis/internal/PassiveExpirationManager.java | 87 ++
.../geode/redis/internal/RedisCommandType.java | 66 +-
.../geode/redis/internal/RedisConstants.java | 6 +-
.../apache/geode/redis/internal/RedisStats.java | 214 ++++
.../geode/redis/internal/RegionProvider.java | 23 +-
.../redis/internal/data/AbstractRedisData.java | 36 +
.../geode/redis/internal/data/CommandHelper.java | 147 +++
.../geode/redis/internal/data/EmptyRedisSet.java | 79 --
.../geode/redis/internal/data/NullRedisData.java | 116 +++
.../{EmptyRedisHash.java => NullRedisHash.java} | 23 +-
.../geode/redis/internal/data/NullRedisSet.java | 177 ++++
.../geode/redis/internal/data/NullRedisString.java | 314 ++++++
.../geode/redis/internal/data/RedisData.java | 23 +
...java => RedisDataCommandsFunctionExecutor.java} | 37 +-
.../geode/redis/internal/data/RedisHash.java | 62 +-
...java => RedisHashCommandsFunctionExecutor.java} | 89 +-
.../data/RedisKeyCommandsFunctionExecutor.java | 65 ++
.../redis/internal/data/RedisKeyInRegion.java | 117 ---
.../apache/geode/redis/internal/data/RedisSet.java | 73 +-
.../data/RedisSetCommandsFunctionExecutor.java | 111 ++
.../redis/internal/data/RedisSetInRegion.java | 256 -----
.../geode/redis/internal/data/RedisString.java | 565 ++++++++++-
.../data/RedisStringCommandsFunctionExecutor.java | 154 +++
.../redis/internal/data/RedisStringInRegion.java | 191 ----
.../redis/internal/executor/AbstractExecutor.java | 51 +-
.../redis/internal/executor/CommandFunction.java | 256 ++---
.../geode/redis/internal/executor/GlobPattern.java | 48 +-
.../redis/internal/executor/RedisResponse.java | 9 +
.../executor/SingleResultRedisFunction.java | 30 +-
.../{server => connection}/AuthExecutor.java | 6 +-
.../{server => connection}/EchoExecutor.java | 2 +-
.../{server => connection}/PingExecutor.java | 11 +-
.../{server => connection}/QuitExecutor.java | 2 +-
.../internal/executor/hash/HScanExecutor.java | 2 +-
.../HStrLenExecutor.java} | 21 +-
.../redis/internal/executor/hash/HashExecutor.java | 2 +-
.../internal/executor/hash/RedisHashCommands.java | 2 +
....java => RedisHashCommandsFunctionInvoker.java} | 40 +-
.../internal/executor/key/ExpireAtExecutor.java | 4 -
.../internal/executor/key/ExpireExecutor.java | 6 +-
.../redis/internal/executor/key/KeysExecutor.java | 20 +-
.../internal/executor/key/PersistExecutor.java | 2 +-
...r.java => RedisKeyCommandsFunctionInvoker.java} | 23 +-
.../internal/executor/key/RenameFunction.java | 59 +-
.../redis/internal/executor/key/TTLExecutor.java | 8 -
.../redis/internal/executor/key/TypeExecutor.java | 6 -
.../internal/executor/pubsub/PublishExecutor.java | 7 +-
.../executor/pubsub/PunsubscribeExecutor.java | 57 +-
.../executor/pubsub/SubscribeExecutor.java | 4 +-
.../executor/pubsub/UnsubscribeExecutor.java | 56 +-
.../executor/{key => server}/DBSizeExecutor.java | 2 +-
.../executor/{key => server}/FlushAllExecutor.java | 3 +-
.../internal/executor/server/ShutDownExecutor.java | 2 +-
...r.java => RedisSetCommandsFunctionInvoker.java} | 31 +-
.../internal/executor/set/SRandMemberExecutor.java | 16 +-
.../redis/internal/executor/set/SScanExecutor.java | 2 +-
.../redis/internal/executor/set/SetExecutor.java | 2 +-
.../internal/executor/string/AppendExecutor.java | 2 +-
.../internal/executor/string/BitCountExecutor.java | 59 +-
.../internal/executor/string/BitOpExecutor.java | 114 +--
.../internal/executor/string/BitPosExecutor.java | 59 +-
.../internal/executor/string/DecrByExecutor.java | 4 +-
.../internal/executor/string/GetBitExecutor.java | 26 +-
.../internal/executor/string/GetRangeExecutor.java | 33 +-
.../internal/executor/string/GetSetExecutor.java | 2 +-
.../internal/executor/string/IncrByExecutor.java | 5 +-
.../executor/string/IncrByFloatExecutor.java | 60 +-
.../internal/executor/string/MGetExecutor.java | 2 +-
.../internal/executor/string/MSetExecutor.java | 2 +-
.../internal/executor/string/MSetNXExecutor.java | 4 +-
.../executor/string/RedisStringCommands.java | 24 +
.../RedisStringCommandsFunctionExecutor.java | 77 --
.../string/RedisStringCommandsFunctionInvoker.java | 149 +++
.../internal/executor/string/SetBitExecutor.java | 42 +-
.../internal/executor/string/SetEXExecutor.java | 9 +-
.../internal/executor/string/SetExecutor.java | 213 ++--
.../internal/executor/string/SetNXExecutor.java | 6 +-
.../internal/executor/string/SetRangeExecutor.java | 49 +-
.../internal/executor/string/StringExecutor.java | 2 +-
.../internal/executor/string/StrlenExecutor.java | 11 +-
.../geode/redis/internal/gfsh/RedisCommand.java | 4 +-
.../apache/geode/redis/internal/netty/Coder.java | 26 +-
.../apache/geode/redis/internal/netty/Command.java | 34 -
.../internal/netty/ExecutionHandlerContext.java | 125 ++-
.../redis/internal/netty/NettyRedisServer.java | 252 +++++
.../internal/pubsub/AbstractSubscription.java | 4 +-
.../redis/internal/pubsub/ChannelSubscription.java | 18 +-
.../redis/internal/pubsub/PatternSubscription.java | 10 +-
.../apache/geode/redis/internal/pubsub/PubSub.java | 17 +-
.../geode/redis/internal/pubsub/PubSubImpl.java | 40 +-
.../geode/redis/internal/pubsub/Subscription.java | 12 +-
.../geode/redis/internal/pubsub/Subscriptions.java | 41 +-
.../sanctioned-geode-redis-serializables.txt | 2 +
.../geode/redis/internal/CommandJUnitTest.java | 78 --
.../redis/internal/SupportedCommandsJUnitTest.java | 148 ++-
.../geode/redis/internal/data/RedisHashTest.java | 164 +++
.../geode/redis/internal/data/RedisSetTest.java | 154 +++
.../geode/redis/internal/data/RedisStringTest.java | 117 +++
.../executor/key/DelExecutorJUnitTest.java | 10 +-
.../executor/key/ExistsExecutorJUnitTest.java | 10 +-
.../executor/key/ExpireAtExecutorJUnitTest.java | 43 +-
.../executor/key/ExpireExecutorJUnitTest.java | 46 +-
...orJUnitTest.java => KeysExecutorJUnitTest.java} | 25 +-
.../executor/key/PExpireAtExecutorJUnitTest.java | 51 +-
...orJUnitTest.java => PTTLExecutorJUnitTest.java} | 17 +-
.../executor/key/PexpireExecutorJUnitTest.java | 59 +-
...torJUnitTest.java => TTLExecutorJUnitTest.java} | 17 +-
.../string/StringGetExecutorJUnitTest.java | 7 -
.../string/StringSetExecutorJUnitTest.java | 74 +-
.../redis/internal/netty/CommandJUnitTest.java | 71 ++
.../redis/internal/pubsub/PubSubImplJUnitTest.java | 5 +-
.../internal/pubsub/SubscriptionsJUnitTest.java | 27 +-
geode-redis/src/test/resources/expected-pom.xml | 11 +
.../internal/serialization/AbstractVersion.java | 124 +++
.../internal/serialization/UnknownVersion.java | 21 +-
.../geode/internal/serialization/Version.java | 291 +-----
.../internal/serialization/VersionOrdinal.java | 83 ++
.../serialization/VersionedDataStream.java | 13 +-
.../geode/internal/serialization/Versioning.java | 66 ++
.../geode/internal/serialization/VersioningIO.java | 112 ++
.../internal/DSFIDSerializerImpl.java | 19 +-
.../serialization/UnknownVersionJUnitTest.java | 131 +++
.../internal/serialization/VersionJUnitTest.java | 65 +-
.../serialization/VersioningJUnitTest.java | 73 ++
.../TcpServerProductVersionDUnitTest.java | 11 +-
.../distributed/internal/tcpserver/TcpClient.java | 39 +-
.../distributed/internal/tcpserver/TcpServer.java | 20 +-
...SenderWithIsolatedDiskStoreDistributedTest.java | 348 -------
...stenceEnabledGatewaySenderOffHeapDUnitTest.java | 1 +
...ANPersistenceEnabledGatewaySenderDUnitTest.java | 17 +-
...ANPersistenceEnabledGatewaySenderDUnitTest.java | 130 ++-
.../locator/wan/LocatorMembershipListenerImpl.java | 14 +-
.../RemoteParallelGatewaySenderEventProcessor.java | 3 +-
.../locator/wan/LocatorMembershipListenerTest.java | 88 +-
.../client/CreateDiskStoreDUnitTest.java | 346 +++++++
.../rest/DiskStoreManagementIntegrationTest.java | 152 +++
...RedundancyRequestControllerIntegrationTest.java | 174 ++++
.../rest/controllers/DiskStoreController.java | 113 +++
.../RestoreRedundancyOperationController.java | 74 ++
gradle/java.gradle | 18 +-
gradle/publish-java.gradle | 46 +
gradle/sonar.gradle | 24 -
gradle/standard-subproject-configuration.gradle | 15 +-
gradle/test.gradle | 15 +
627 files changed, 22848 insertions(+), 10517 deletions(-)
create mode 100644 ci/bin/concourse_job_performance_requirements.txt
create mode 100755 ci/pipelines/mass-test-run/deploy_pipeline.sh
create mode 100644 ci/pipelines/mass-test-run/jinja.template.yml
rename
extensions/geode-modules-test/src/main/java/org/apache/geode/modules/session/{TestSessionsBase.java
=> AbstractSessionsTest.java} (72%)
rename
extensions/{geode-modules/src/integrationTest/java/org/apache/geode/modules/session/catalina/CommitSessionValveIntegrationTest.java
=>
geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/AbstractCommitSessionValveIntegrationTest.java}
(83%)
create mode 100644
extensions/geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/AbstractDeltaSessionIntegrationTest.java
rename
extensions/geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/{DeltaSessionManagerJUnitTest.java
=> AbstractDeltaSessionManagerTest.java} (70%)
rename
extensions/geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/{DeltaSessionJUnitTest.java
=> AbstractDeltaSessionTest.java} (62%)
rename extensions/{geode-modules/src/integrationTest =>
geode-modules-test/src/main}/java/org/apache/geode/modules/session/catalina/AbstractSessionValveIntegrationTest.java
(100%)
delete mode 100644
extensions/geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/ClientServerSessionCacheJUnitTest.java
rename
extensions/geode-modules-tomcat7/src/integrationTest/java/org/apache/geode/modules/session/{Tomcat7SessionsJUnitTest.java
=> Tomcat7SessionsTest.java} (87%)
create mode 100644
extensions/geode-modules-tomcat7/src/integrationTest/java/org/apache/geode/modules/session/catalina/CommitSessionValveIntegrationTest.java
copy
extensions/{geode-modules/src/main/java/org/apache/geode/modules/session/catalina/SessionManager.java
=>
geode-modules-tomcat7/src/integrationTest/java/org/apache/geode/modules/session/catalina/DeltaSession7Test.java}
(61%)
create mode 100644
extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/Tomcat7CommitSessionOutputBuffer.java
create mode 100644
extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/Tomcat7CommitSessionValve.java
create mode 100644
extensions/geode-modules-tomcat7/src/test/java/org/apache/geode/modules/session/catalina/DeltaSession7Test.java
create mode 100644
extensions/geode-modules-tomcat7/src/test/java/org/apache/geode/modules/session/catalina/Tomcat7CommitSessionOutputBufferTest.java
create mode 100644
extensions/geode-modules-tomcat7/src/test/java/org/apache/geode/modules/session/catalina/Tomcat7CommitSessionValveTest.java
rename
extensions/geode-modules-tomcat7/src/test/java/org/apache/geode/modules/session/catalina/{Tomcat7DeltaSessionManagerJUnitTest.java
=> Tomcat7DeltaSessionManagerTest.java} (95%)
create mode 100644
extensions/geode-modules-tomcat8/src/integrationTest/java/org/apache/geode/modules/session/catalina/CommitSessionValveIntegrationTest.java
copy
extensions/{geode-modules/src/main/java/org/apache/geode/modules/session/catalina/SessionManager.java
=>
geode-modules-tomcat8/src/integrationTest/java/org/apache/geode/modules/session/catalina/DeltaSession8Test.java}
(61%)
create mode 100644
extensions/geode-modules-tomcat8/src/main/java/org/apache/geode/modules/session/catalina/Tomcat8CommitSessionOutputBuffer.java
create mode 100644
extensions/geode-modules-tomcat8/src/main/java/org/apache/geode/modules/session/catalina/Tomcat8CommitSessionValve.java
create mode 100644
extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/catalina/DeltaSession8Test.java
create mode 100644
extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/catalina/Tomcat8CommitSessionOutputBufferTest.java
create mode 100644
extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/catalina/Tomcat8CommitSessionValveTest.java
rename
extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/catalina/{Tomcat8DeltaSessionManagerJUnitTest.java
=> Tomcat8DeltaSessionManagerTest.java} (97%)
create mode 100644
extensions/geode-modules-tomcat9/src/integrationTest/java/org/apache/geode/modules/session/catalina/CommitSessionValveIntegrationTest.java
copy
extensions/{geode-modules/src/main/java/org/apache/geode/modules/session/catalina/SessionManager.java
=>
geode-modules-tomcat9/src/integrationTest/java/org/apache/geode/modules/session/catalina/DeltaSession9Test.java}
(61%)
create mode 100644
extensions/geode-modules-tomcat9/src/main/java/org/apache/geode/modules/session/catalina/Tomcat9CommitSessionOutputBuffer.java
create mode 100644
extensions/geode-modules-tomcat9/src/main/java/org/apache/geode/modules/session/catalina/Tomcat9CommitSessionValve.java
create mode 100644
extensions/geode-modules-tomcat9/src/test/java/org/apache/geode/modules/session/catalina/DeltaSession9Test.java
create mode 100644
extensions/geode-modules-tomcat9/src/test/java/org/apache/geode/modules/session/catalina/Tomcat9CommitSessionOutputBufferTest.java
create mode 100644
extensions/geode-modules-tomcat9/src/test/java/org/apache/geode/modules/session/catalina/Tomcat9CommitSessionValveTest.java
rename
extensions/geode-modules-tomcat9/src/test/java/org/apache/geode/modules/session/catalina/{Tomcat9DeltaSessionManagerJUnitTest.java
=> Tomcat9DeltaSessionManagerTest.java} (97%)
rename
extensions/geode-modules/src/integrationTest/java/org/apache/geode/modules/session/{Tomcat6SessionsJUnitTest.java
=> Tomcat6SessionsTest.java} (88%)
create mode 100644
extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/AbstractCommitSessionValve.java
delete mode 100644
extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/CommitSessionValve.java
copy
extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/{SessionManager.java
=> DeltaSessionManagerConfiguration.java} (57%)
copy
geode-management/src/main/java/org/apache/geode/management/runtime/IndexInfo.java
=>
extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/SessionCommitter.java
(71%)
copy
geode-management/src/main/java/org/apache/geode/management/runtime/IndexInfo.java
=>
extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/Tomcat6CommitSessionValve.java
(72%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/AbstractSessionCacheJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/AbstractSessionCacheTest.java}
(84%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/DeltaSessionFacadeJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/DeltaSessionFacadeTest.java}
(88%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCacheJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCacheTest.java}
(90%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/callback/SessionExpirationCacheListenerJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/callback/SessionExpirationCacheListenerTest.java}
(80%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionAttributeEventBatchJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionAttributeEventBatchTest.java}
(77%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionDestroyAttributeEventJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionDestroyAttributeEventTest.java}
(79%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionStatisticsJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionStatisticsTest.java}
(85%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionUpdateAttributeEventJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/session/catalina/internal/DeltaSessionUpdateAttributeEventTest.java}
(81%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/util/CreateRegionFunctionJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/util/CreateRegionFunctionTest.java}
(85%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/util/TouchPartitionedRegionEntriesFunctionJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/util/TouchPartitionedRegionEntriesFunctionTest.java}
(84%)
rename
extensions/{geode-modules-test/src/main/java/org/apache/geode/modules/util/TouchReplicatedRegionEntriesFunctionJUnitTest.java
=>
geode-modules/src/test/java/org/apache/geode/modules/util/TouchReplicatedRegionEntriesFunctionTest.java}
(79%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/NamedThreadFactory.java
=>
extensions/session-testing-war/src/main/java/org/apache/geode/modules/session/AccessAttributeValueListener.java
(54%)
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/client/sni/GenerateSNIKeyAndTrustStores.java
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/logging/LocatorWithCustomLogConfigAcceptanceTest.java
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/logging/ServerWithCustomLogConfigAcceptanceTest.java
create mode 100644
geode-assembly/src/acceptanceTest/java/org/apache/geode/management/internal/cli/shell/DirectoryTree.java
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/LocatorWithCustomLogConfigAcceptanceTestWithGeodePlugins.xml
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/LocatorWithCustomLogConfigAcceptanceTestWithoutGeodePlugins.xml
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/ServerWithCustomLogConfigAcceptanceTestWithGeodePlugins.xml
create mode 100644
geode-assembly/src/acceptanceTest/resources/org/apache/geode/logging/ServerWithCustomLogConfigAcceptanceTestWithoutGeodePlugins.xml
create mode 100644
geode-assembly/src/distributedTest/java/org/apache/geode/management/internal/rest/RestoreRedundancyManagementDUnitTest.java
create mode 100644
geode-assembly/src/distributedTest/java/org/apache/geode/session/tests/LogChecker.java
create mode 100644
geode-assembly/src/integrationTest/java/org/apache/geode/test/junit/rules/GfshRuleIntegrationTest.java
delete mode 100644
geode-assembly/src/test/java/org/apache/geode/test/junit/rules/GfshRuleTest.java
create mode 100644
geode-core/src/distributedTest/java/org/apache/geode/cache/query/dunit/IndexUsageInJoinQueryDistributedTest.java
create mode 100644
geode-core/src/integrationTest/java/org/apache/geode/distributed/internal/InternalConfigurationPersistenceServiceIntegrationTest.java
rename
geode-core/src/{test/java/org/apache/geode/test/version/VersionManagerJUnitTest.java
=>
integrationTest/java/org/apache/geode/test/version/VersionManagerIntegrationTest.java}
(55%)
delete mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/control/RestoreRedundancyResultsImpl.java
rename
geode-core/src/main/java/org/apache/geode/internal/cache/control/{RegionRedundancyStatusImpl.java
=> SerializableRegionRedundancyStatusImpl.java} (76%)
create mode 100644
geode-core/src/main/java/org/apache/geode/internal/cache/control/SerializableRestoreRedundancyResultsImpl.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/configuration/converters/DiskStoreConverter.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/configuration/mutators/DiskStoreManager.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/configuration/realizers/DiskStoreRealizer.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/configuration/validators/DiskStoreValidator.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/functions/RestoreRedundancyFunction.java
create mode 100644
geode-core/src/main/java/org/apache/geode/management/internal/operation/RestoreRedundancyPerformer.java
create mode 100644
geode-core/src/test/java/org/apache/geode/cache/client/internal/GetAllOpJUnitTest.java
rename
geode-core/src/{integrationTest/java/org/apache/geode/distributed/internal/InternalLocatorClusterManagementServiceIntegrationTest.java
=> test/java/org/apache/geode/distributed/internal/InternalLocatorTest.java}
(85%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/HARegionTest.java
delete mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/OplogEntryIdSetJUnitTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/OplogEntryIdSetTest.java
rename
geode-core/src/test/java/org/apache/geode/internal/cache/control/{RestoreRedundancyResultsImplTest.java
=> SerializableRestoreRedundancyResultsImplTest.java} (51%)
create mode 100644
geode-core/src/test/java/org/apache/geode/internal/cache/ha/QueueRemovalMessageTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/configuration/converters/DiskStoreConverterTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/configuration/mutators/DiskStoreManagerTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/configuration/realizers/DiskStoreRealizerTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/configuration/validators/DiskStoreValidatorTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/functions/RestoreRedundancyFunctionTest.java
create mode 100644
geode-core/src/test/java/org/apache/geode/management/internal/operation/RestoreRedundancyPerformerTest.java
create mode 100644
geode-core/src/upgradeTest/java/org/apache/geode/internal/cache/rollingupgrade/RollingUpgradeWithGfshDUnitTest.java
delete mode 100644
geode-gfsh/src/main/java/org/apache/geode/management/internal/cli/functions/RedundancyCommandFunction.java
delete mode 100644
geode-gfsh/src/test/java/org/apache/geode/management/internal/cli/commands/RedundancyCommandTest.java
delete mode 100644
geode-gfsh/src/test/java/org/apache/geode/management/internal/cli/functions/RedundancyCommandFunctionTest.java
create mode 100644
geode-management/src/main/java/org/apache/geode/management/configuration/DiskDir.java
create mode 100644
geode-management/src/main/java/org/apache/geode/management/configuration/DiskStore.java
create mode 100644
geode-management/src/main/java/org/apache/geode/management/internal/operation/RegionRedundancyStatusImpl.java
create mode 100644
geode-management/src/main/java/org/apache/geode/management/internal/operation/RestoreRedundancyResultsImpl.java
create mode 100644
geode-management/src/main/java/org/apache/geode/management/operation/RestoreRedundancyRequest.java
create mode 100644
geode-management/src/main/java/org/apache/geode/management/runtime/DiskStoreInfo.java
rename {geode-core/src/main/java/org/apache/geode/cache/control =>
geode-management/src/main/java/org/apache/geode/management/runtime}/RegionRedundancyStatus.java
(90%)
rename {geode-core/src/main/java/org/apache/geode/cache/control =>
geode-management/src/main/java/org/apache/geode/management/runtime}/RestoreRedundancyResults.java
(85%)
create mode 100644
geode-management/src/test/java/org/apache/geode/management/internal/operation/RestoreRedundancyResultsImplTest.java
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/pubsub/PublishResult.java
=>
geode-management/src/test/java/org/apache/geode/management/operation/RestoreRedundancyRequestTest.java
(57%)
create mode 100644
geode-membership/src/integrationTest/java/org/apache/geode/distributed/internal/membership/gms/GMSMemberDataVersionJUnitTest.java
create mode 100644 geode-old-versions/README.md
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{PexpireNativeRedisAcceptanceTest.java
=> internal/executor/GlobPatternNativeRedisAcceptanceTest.java} (78%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExpireNativeRedisAcceptanceTest.java
=> internal/executor/connection/AuthNativeRedisAcceptanceTest.java} (64%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExpireNativeRedisAcceptanceTest.java
=> internal/executor/connection/PingNativeRedisAcceptanceTest.java} (79%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/hash}/HashesNativeRedisAcceptanceTest.java (97%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExpireNativeRedisAcceptanceTest.java
=> internal/executor/key/DelNativeRedisAcceptanceTest.java} (79%)
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExistsDockerAcceptanceTest.java
=> internal/executor/key/ExistsNativeRedisAcceptanceTest.java} (92%)
copy geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/key}/ExpireAtNativeRedisAcceptanceTest.java (95%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/key}/ExpireNativeRedisAcceptanceTest.java (95%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{PexpireNativeRedisAcceptanceTest.java
=> internal/executor/key/KeysNativeRedisAcceptanceTest.java} (85%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/key/PTTLNativeRedisAcceptanceTest.java} (77%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/key}/PersistNativeRedisAcceptanceTest.java (95%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/key}/PexpireNativeRedisAcceptanceTest.java (95%)
copy geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/key}/RenameNativeRedisAcceptanceTest.java (97%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/key/TTLNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/key/TypeNativeRedisAcceptanceTest.java} (77%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ =>
internal/executor/pubsub}/PubSubNativeRedisAcceptanceTest.java (97%)
copy geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SDiffNativeRedisAcceptanceTest.java (97%)
copy geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SInterNativeRedisAcceptanceTest.java (97%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SRemNativeRedisAcceptanceTest.java
=> internal/executor/set/SIsMemberNativeRedisAcceptanceTest.java} (84%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SMoveNativeRedisAcceptanceTest.java (97%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SPopNativeRedisAcceptanceTest.java (97%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SRemNativeRedisAcceptanceTest.java (97%)
rename geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SUnionNativeRedisAcceptanceTest.java (97%)
copy geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SetsNativeRedisAcceptanceTest.java (97%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/AppendNativeRedisAcceptanceTest.java} (82%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExpireAtNativeRedisAcceptanceTest.java
=> internal/executor/string/BitCountNativeRedisAcceptanceTest.java} (78%)
mode change 100644 => 100755
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SDiffNativeRedisAcceptanceTest.java
=> internal/executor/string/BitOpNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/BitPosNativeRedisAcceptanceTest.java} (77%)
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{StringsNativeRedisAcceptanceTest.java
=> internal/executor/string/DecrByNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/string/DecrNativeRedisAcceptanceTest.java} (82%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/GetBitNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/string/GetNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExpireAtNativeRedisAcceptanceTest.java
=> internal/executor/string/GetRangeNativeRedisAcceptanceTest.java} (78%)
mode change 100644 => 100755
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/GetSetNativeRedisAcceptanceTest.java} (82%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{RenameNativeRedisAcceptanceTest.java
=> internal/executor/string/IncrByFloatNativeRedisAcceptanceTest.java} (78%)
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{RenameNativeRedisAcceptanceTest.java
=> internal/executor/string/IncrByNativeRedisAcceptanceTest.java} (79%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/string/IncrNativeRedisAcceptanceTest.java} (82%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/string/MGetNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/MSetNXNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/string/MSetNativeRedisAcceptanceTest.java} (82%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/PSetEXNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/SetBitNativeRedisAcceptanceTest.java} (77%)
copy
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SDiffNativeRedisAcceptanceTest.java
=> internal/executor/string/SetExNativeRedisAcceptanceTest.java} (77%)
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SDiffNativeRedisAcceptanceTest.java
=> internal/executor/string/SetNXNativeRedisAcceptanceTest.java} (77%)
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SetsNativeRedisAcceptanceTest.java
=> internal/executor/string/SetNativeRedisAcceptanceTest.java} (81%)
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{ExpireAtNativeRedisAcceptanceTest.java
=> internal/executor/string/SetRangeNativeRedisAcceptanceTest.java} (78%)
mode change 100644 => 100755
rename
geode-redis/src/acceptanceTest/java/org/apache/geode/redis/{sets/SInterNativeRedisAcceptanceTest.java
=> internal/executor/string/StrLenNativeRedisAcceptanceTest.java} (77%)
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors
=> internal/executor}/hash/HMsetDUnitTest.java (92%)
create mode 100644
geode-redis/src/distributedTest/java/org/apache/geode/redis/internal/executor/hash/HashesAndCrashesDUnitTest.java
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors
=> internal/executor}/hash/HsetDUnitTest.java (92%)
rename
geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors/keys =>
internal/executor/key}/ExistsDUnitTest.java (97%)
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors
=> internal/executor/key}/ExpireDUnitTest.java (96%)
rename
geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors/keys =>
internal/executor/key}/PersistDUnitTest.java (98%)
rename
geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors/keys =>
internal/executor/key}/RenameDUnitTest.java (99%)
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{ =>
internal/executor/pubsub}/PubSubDUnitTest.java (99%)
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors
=> internal/executor}/set/SaddDUnitTest.java (90%)
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors
=> internal/executor}/set/SremDUnitTest.java (90%)
rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{executors
=> internal/executor}/string/StringsDUnitTest.java (91%)
delete mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/ConcurrentStartIntegrationTest.java
delete mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/PubSubIntegrationTest.java
delete mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/StringsIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/GlobPatternIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/UnknownIntegrationTest.java} (67%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor/connection}/AuthIntegrationTest.java (56%)
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/connection/PingIntegrationTest.java
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor/hash}/HashesIntegrationTest.java (86%)
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/DelIntegrationTest.java
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor}/key/ExistsIntegrationTest.java (99%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor}/key/ExpireAtIntegrationTest.java (90%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor}/key/ExpireIntegrationTest.java (90%)
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/KeysIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/key/PTTLIntegrationTest.java} (53%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor}/key/PersistIntegrationTest.java (98%)
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor}/key/PexpireIntegrationTest.java (68%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ =>
internal/executor/key}/RenameIntegrationTest.java (88%)
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/key/TTLIntegrationTest.java} (53%)
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/key/TypeIntegrationTest.java
create mode 100644
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/pubsub/PubSubIntegrationTest.java
copy geode-redis/src/integrationTest/java/org/apache/geode/redis/{key =>
internal/executor/server}/FlushAllIntegrationTest.java (97%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{key =>
internal/executor/server}/ShutdownIntegrationTest.java (97%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{key =>
internal/executor/server}/TimeIntegrationTest.java (96%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SDiffIntegrationTest.java (99%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SInterIntegrationTest.java (99%)
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/set/SIsMemberIntegrationTest.java
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SMoveIntegrationTest.java (98%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SPopIntegrationTest.java (99%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SRemIntegrationTest.java (85%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SUnionIntegrationTest.java (99%)
rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{sets =>
internal/executor/set}/SetsIntegrationTest.java (79%)
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/AppendIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/BitCountIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/BitOpIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/BitPosIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/DecrByIntegrationTest.java} (51%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/DecrIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/GetBitIntegrationTest.java} (50%)
mode change 100644 => 100755
rename
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/PexpireIntegrationTest.java
=> internal/executor/string/GetIntegrationTest.java} (51%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/GetRangeIntegrationTest.java
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/GetSetIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/IncrByFloatIntegrationTest.java} (56%)
mode change 100644 => 100755
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/IncrByIntegrationTest.java} (51%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/IncrIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/MGetIntegrationTest.java} (63%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/MSetIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/MSetNXIntegrationTest.java} (57%)
mode change 100644 => 100755
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/PSetEXIntegrationTest.java} (66%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/SetBitIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/SetEXIntegrationTest.java} (66%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/SetIntegrationTest.java
copy
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/SetNXIntegrationTest.java} (61%)
mode change 100644 => 100755
create mode 100755
geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/executor/string/SetRangeIntegrationTest.java
rename
geode-redis/src/integrationTest/java/org/apache/geode/redis/{key/FlushAllIntegrationTest.java
=> internal/executor/string/StrLenIntegrationTest.java} (52%)
mode change 100644 => 100755
rename
geode-redis/src/integrationTest/java/org/apache/geode/redis/{internal/pubsub =>
mocks}/DummySubscription.java (75%)
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/PassiveExpirationManager.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/RedisStats.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/CommandHelper.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/EmptyRedisSet.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisData.java
copy
geode-redis/src/main/java/org/apache/geode/redis/internal/data/{EmptyRedisHash.java
=> NullRedisHash.java} (72%)
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisSet.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/NullRedisString.java
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/data/{EmptyRedisHash.java
=> RedisDataCommandsFunctionExecutor.java} (51%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/data/{RedisHashInRegion.java
=> RedisHashCommandsFunctionExecutor.java} (52%)
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisKeyCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisKeyInRegion.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisSetCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisSetInRegion.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisStringCommandsFunctionExecutor.java
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisStringInRegion.java
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{server =>
connection}/AuthExecutor.java (89%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{server =>
connection}/EchoExecutor.java (96%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{server =>
connection}/PingExecutor.java (80%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{server =>
connection}/QuitExecutor.java (95%)
copy
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{string/AppendExecutor.java
=> hash/HStrLenExecutor.java} (70%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hash/{RedisHashCommandsFunctionExecutor.java
=> RedisHashCommandsFunctionInvoker.java} (69%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/key/{RedisKeyCommandsFunctionExecutor.java
=> RedisKeyCommandsFunctionInvoker.java} (82%)
rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{key
=> server}/DBSizeExecutor.java (95%)
rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{key
=> server}/FlushAllExecutor.java (92%)
rename
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/set/{RedisSetCommandsFunctionExecutor.java
=> RedisSetCommandsFunctionInvoker.java} (74%)
delete mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/RedisStringCommandsFunctionExecutor.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/RedisStringCommandsFunctionInvoker.java
create mode 100644
geode-redis/src/main/java/org/apache/geode/redis/internal/netty/NettyRedisServer.java
delete mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/CommandJUnitTest.java
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/data/RedisHashTest.java
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/data/RedisSetTest.java
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/data/RedisStringTest.java
copy
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/{DelExecutorJUnitTest.java
=> KeysExecutorJUnitTest.java} (68%)
copy
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/{DelExecutorJUnitTest.java
=> PTTLExecutorJUnitTest.java} (75%)
copy
geode-redis/src/test/java/org/apache/geode/redis/internal/executor/key/{DelExecutorJUnitTest.java
=> TTLExecutorJUnitTest.java} (75%)
create mode 100644
geode-redis/src/test/java/org/apache/geode/redis/internal/netty/CommandJUnitTest.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/AbstractVersion.java
copy
geode-management/src/main/java/org/apache/geode/management/runtime/IndexInfo.java
=>
geode-serialization/src/main/java/org/apache/geode/internal/serialization/UnknownVersion.java
(71%)
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/VersionOrdinal.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/Versioning.java
create mode 100644
geode-serialization/src/main/java/org/apache/geode/internal/serialization/VersioningIO.java
create mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/UnknownVersionJUnitTest.java
create mode 100644
geode-serialization/src/test/java/org/apache/geode/internal/serialization/VersioningJUnitTest.java
delete mode 100644
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/PersistentGatewaySenderWithIsolatedDiskStoreDistributedTest.java
create mode 100644
geode-web-management/src/distributedTest/java/org/apache/geode/management/client/CreateDiskStoreDUnitTest.java
create mode 100644
geode-web-management/src/integrationTest/java/org/apache/geode/management/internal/rest/DiskStoreManagementIntegrationTest.java
create mode 100644
geode-web-management/src/integrationTest/java/org/apache/geode/management/internal/rest/RestoreRedundancyRequestControllerIntegrationTest.java
create mode 100644
geode-web-management/src/main/java/org/apache/geode/management/internal/rest/controllers/DiskStoreController.java
create mode 100644
geode-web-management/src/main/java/org/apache/geode/management/internal/rest/controllers/RestoreRedundancyOperationController.java
