This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a change to branch feature/GEODE-8334
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 882667d apply review comments
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)
add 3e8304c GEODE-7683: introduce BR.cmnClearRegion
add 6174f70 GEODE-7682: add PR.clear API (#4755)
add 23954be PR.clear's event id should be created and used in BR (#4805)
add 2840a19 GEODE-7912: cacheWriter should be triggered when PR.clear
(#4882)
add 32f59fc GEODE-7983: Clear region writer callbacks should not be
invoked for bucket regions (#4954)
add 75ae591 GEODE-7676: Add PR clear with expiration tests (#4970)
add 9bf176c GEODE-7667: Add a 'clear' gfsh command for PR and RR clear
(#4818)
add c78064a GEODE-7676: Conversion of duration to seconds.
add 43192d2 GEODE-7894: Moving expiry tasks to AbstractRegion.
add 2e8c7a8 GEODE-7667: Fixing test to include PR clear help text.
add 8eeaac4 GEODE-7678 (2nd PR) - Support for cache-listener and
client-notification for Partitioned Region Clear operation (#5124)
add b49e67c GEODE-7669 Test coverage for Partitioned Region clear with
Overflow enabled (#5189)
add af4b35a GEODE-8173: Add unit test (coverage) for
PartitionedRegionClear class. (#5208)
add a6a62c6 Merge branch 'feature/GEODE-7665' into feature/GEODE-8334
No new revisions were added by this update.
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
