This is an automated email from the ASF dual-hosted git repository. mhanson pushed a change to branch mass-test-run in repository https://gitbox.apache.org/repos/asf/geode.git.
discard 7eaf4a5 remove meta-* jobs that we won't use for mass-test-run discard 7dba154 Mass-test-run branch, no windows or publication jobs add ba8a552 GEODE-8132: Remove ability to set Redis region type (#5117) add a235c7c GEODE-8078: log and report error at the correct place. (#5111) add 4fff1f9 GEODE-8094: Create HA test to ensure Spring Boot sessions expire correctly (#5079) add 32a0177 GEODE-8133: Fix task chaining for 'devBuild' (#5118) add e084aa4 GEODE-8130: use a single region for redis Sets and Hashes (#5120) add 0d602cc GEODE-8035: Parallel Disk Store Recovery when Cluster Restarts (#5014) add 334e24f GEODE-8096: Providing unique names for the JARs in the tests (#5119) add fff9853 GEODE-8069: fix release script issues (#5050) add 4c12d70 GEODE-8122: Update Geode Redis API docs (#5122) add b38ae30 GEODE-7792: configure logging for geode-membership integration tests (#5116) add 1af3be3 GEODE-8100: update cluster-management-service documentation (#5121) add 6aa2420 Introduce RedisResponse to SET executors (#5114) add 7e222df GEODE-8147: change redis DELETE and EXISTS to use Function+Delta (#5128) add 47a5709 GEODE-8095: refactor operation BiFunction into a specific OperationPerformer interface (#5135) add aca029e GEODE-8100: Update cluster management service docs - style edit (#5141) add 7538de5 GEODE-8167: bump spring security to recommended version (#5144) add 19d5f78 GEODE-7458: Adding option in gfsh command "start gateway sender" to control clearing of existing queues (#4387) add c3c226a GEODE-8119:closing threads when offline disk store is executed (#5106) add 07bf3dd GEODE-8150: Downgrade classgraph to 4.8.52 (#5138) add d08847b GEODE-8112: Add --member option in query command. (#5102) add 9a0563e GEODE-8170: change all hash and set commands to use function (#5125) add 0f8da9e GEODE-8145: Add Redis configuration properties to gemfire_properties.html (#5130) add f2392d0 GEODE-8146: use latest winrm in tools image (#5134) add 358fd70 GEODE-8131: reader thread blocked attempting to issue an alert (#5132) add e0cbd78 GEODE-8127: ensure that redis function executes on primary (#5133) add d47e073 GEODE-8138: Improve semantics of the redis-port option (#5142) add 0a7f8ae GEODE-8168: Redis pipelined command responses can be corrupted (#5145) add af1ea6d GEODE-8151: Convert hash commands to return RedisResponse (#5140) add f243c4d Revert GEODE-8127: the test is flakey (#5153) add a05b86d GEODE-8175: remove unsupported redis commands (#5146) add 03355b9 GEODE-8175: fix compile error (#5156) add e5e803e GEODE-8180: add 1.14 to management wiki (#5154) add 99b12ed GEODE-8108: Remove System.out.println calls from geode-redis (#5149) add c79905f Revert "GEODE-8119:closing threads when offline disk store is executed (#5106)" (#5158) add e432855 GEODE-7971: Gw sender deliver TX events atomically to Gw receivers (#4928) add b22df8c GEODE-8144: endpoint identification in servers is not working (#5131) add 253d667 GEODE-8136: Move UncheckedUtils to geode-common (#5123) add 5e00b10 GEODE-8134: convert String commands to use Function+Delta (#5160) add bef07b3 GEODE-8174: Fix ConcurrentModificationException when using JTA transaction. (#5161) add 17dd67a GEODE-8182: change String commands to use one region (#5165) add a185267 Feature/geode 8144 (#5164) add 53d1631 GEODE-8171: javadoc for putAll need to have accurate exception (#5147) add 42c1164 GEODE-8144 another attempt to fix a failing test (#5172) add dd990e8 GEODE-8193: Broken link in statistics list (#5166) add bd2d118 GEODE-7864: Override the default implementation of write(byte[],int,int) (#4871) add 0fd56e4 GEODE-7846: Replace all uses of hardcoded / with Region.SEPARATOR (#5157) add 2d85af4 GEODE-8166: reimplement redis expiration to use new data model (#5174) add 83b40f5 The RedisData region name now starts with "__". (#5181) add 343e114 GEODE-8127: Reintroduces changes that account for primary bucket changing (#5179) add 973750e ByteArrayWrapper now implementes DataSerializableFixedID which should save us 40 bytes each time it is serialized. (#5180) add 57cc3c7 GEODE-6070: Fix ShutdownCommandOverHttpDUnitTest flakiness (#5162) add 2883e97 GEODE-8205: feature flag unsupported Redis commands (#5185) add 0fdcd5b GEODE-8211: fix flaky ShutdownIntegrationTest (#5193) add 4090cef repackaged GlobPattern (#5190) add 426d7fd GEODE-8206: CI Failure: ReconnectWithClusterConfigurationDUnitTest.testReconnectAfterMeltdown hang (#5192) add c7bb1f3 GEODE-7759: Print out the Passing token file contents. (#4665) add 4f559fc GEODE-8203: Provide ability to prevent disabling geode console appender (#5183) add 270722f fixup: image for gcs-json-resource was doubly-merged into CI (#5198) add 371ee4e GEODE-8203: Removed camel casing for system property (#5197) add da0b1de GEODE-7956: correct legal region names (#5159) add 0f0ac4e GEODE-8215: start server should fail if redis fails to start (#5202) add 589b978 GEODE-8127: Remove statics from test function and re-enable tests (#5205) add 71e4097 GEODE-8203: Adding standard-output-always-on (#5200) add 62e7c54 GEODE-8211: fix flaky shutdown test (#5209) add 1d71714 GEODE-8211: ignore flaky test (#5210) add a9304cd GEODE-8147: change rename to use Function-Delta (#5152) add e00a85b GEODE-7801: UG 'Querying' chapters reordering (#5201) add 259e203 GEODE-8158: change redis to listen on all local addresses by default (#5204) add 229fb54 GEODE-8218: documentdefault redis-bind-address behavior (#5207) add ac6c65f GEODE-8222: fix flakey passive expiration (#5211) add 80ad8dd GEODE-8219: Apply RedisResponse to all redis string commands (#5206) add 77d4bf8 GEODE-8211: Fix flaky test by increasing client timeout (#5213) add 9098002 GEODE-8198: Revise docs description of putAll() (#5191) add 41f3d4e GEODE-8224: repackage redis classes (#5212) add fb45d22 GEODE-8186: UG add example for query --member option (#5203) add 917f4c9 Feature/GEODE-7414_2_redo (#5115) new 631f33b Mass-test-run branch, no windows or publication jobs new 7843270 remove meta-* jobs that we won't use for mass-test-run 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 (7eaf4a5) \ N -- N -- N refs/heads/mass-test-run (7843270) 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 2 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 | 24 +- build.gradle | 1 + buildSrc/build.gradle | 2 +- .../gradle/japicmp/GeodeApiRegressionRule.groovy | 45 + .../gradle/plugins/DependencyConstraints.groovy | 6 +- .../src/main/resources/japicmp_exceptions.json | 4 + ci/images/alpine-tools/Dockerfile | 22 +- ci/pipelines/geode-build/jinja.template.yml | 7 + ci/pipelines/meta/deploy_meta.sh | 1 - ci/pipelines/meta/jinja.template.yml | 1 + ci/pipelines/shared/jinja.variables.yml | 2 +- dev-tools/release/commit_rc.sh | 5 +- dev-tools/release/create_support_branches.sh | 43 +- dev-tools/release/end_of_support.sh | 2 +- dev-tools/release/license_review.sh | 4 +- dev-tools/release/prepare_rc.sh | 14 +- dev-tools/release/promote_rc.sh | 12 +- dev-tools/release/set_copyright.sh | 2 +- dev-tools/release/set_versions.sh | 36 +- .../modules/util/RegionHelperIntegrationTest.java | 3 +- ...icatedRegionEntriesFunctionIntegrationTest.java | 3 +- .../web/controllers/AddFreeItemToOrders.java | 5 +- .../web/controllers/GetDeliveredOrders.java | 5 +- .../MissingDiskStoreAcceptanceTest.java | 3 +- .../client/sni/ClientSNICQAcceptanceTest.java | 3 +- .../client/sni/DualServerSNIAcceptanceTest.java | 3 +- .../client/sni/SingleServerSNIAcceptanceTest.java | 3 +- ...rStartupRedundancyRecoveryNotificationTest.java | 7 +- .../cli/commands/ConfigureEvictionThroughGfsh.java | 46 +- .../org/apache/geode/client/sni/docker-compose.yml | 1 + .../client/sni/geode-config/gemfire.properties | 1 + .../client/sni/geode-config/gfsecurity.properties | 2 +- .../sni/geode-config/locator-maeve-keystore.jks | Bin 2048 -> 3525 bytes .../geode-config/server-clementine-keystore.jks | Bin 2059 -> 3537 bytes .../sni/geode-config/server-dolores-keystore.jks | Bin 2050 -> 3528 bytes .../geode/client/sni/geode-config/truststore.jks | Bin 8095 -> 1126 bytes .../geode/client/sni/scripts/geode-starter-2.gfsh | 8 +- .../geode/client/sni/scripts/geode-starter.gfsh | 6 +- .../management/JQFilterVerificationDUnitTest.java | 3 +- .../cli/commands/RunOutOfMemoryFunction.java | 4 +- .../rest/ClientClusterManagementSSLTest.java | 3 +- .../rest/ListIndexManagementDUnitTest.java | 25 +- .../rest/ListIndexOnPartitionRegionTest.java | 5 +- .../rest/RebalanceManagementDunitTest.java | 7 +- .../internal/rest/RegionManagementDunitTest.java | 3 +- .../controllers/RestAPIsAndInterOpsDUnitTest.java | 9 +- .../rest/internal/web/RestRegionAPIDUnitTest.java | 11 +- .../web/RestSecurityPostProcessorTest.java | 6 +- .../pulse/EmbeddedPulseClusterSecurityTest.java | 3 +- .../geode/tools/pulse/PulseDataExportTest.java | 12 +- .../integrationTest/resources/assembly_content.txt | 3 +- .../resources/dependency_classpath.txt | 2 +- geode-assembly/src/main/dist/LICENSE | 2 +- .../tools/pulse/ui/PulseAcceptanceAuthTest.java | 4 +- .../tools/pulse/ui/PulseAcceptanceNoAuthTest.java | 4 +- .../tools/pulse/ui/PulseAcceptanceTestBase.java | 7 +- geode-book/config.yml | 1 + .../source/subnavs/geode-subnav.erb | 26 +- .../apache/geode/internal/inet/LocalHostUtil.java | 11 + .../geode/util/internal/TeeOutputStream.java | 9 + .../geode/util/internal}/UncheckedUtils.java | 19 +- .../geode/util/internal/GeodeConverterTest.java | 1 + .../geode/util/internal/GeodeJsonMapperTest.java | 1 + .../geode/util/internal/UncheckedUtilsTest.java | 60 + .../internal/cli/CreateMappingCommandTest.java | 5 +- .../jdbc/internal/xml/ElementTypeTest.java | 3 +- .../xml/JdbcConnectorServiceXmlParserTest.java | 3 +- .../geode/cache/ConnectionPoolDUnitTest.java | 17 +- .../ClientServerRegisterInterestsDUnitTest.java | 7 +- ...tServerHostNameVerificationDistributedTest.java | 3 +- .../internal/CustomSSLProviderDistributedTest.java | 3 +- .../query/dunit/CompactRangeIndexDUnitTest.java | 6 +- .../query/dunit/CorruptedIndexIntegrationTest.java | 24 +- .../cache/query/dunit/HashIndexDUnitTest.java | 4 +- ...MultiServerPartitionedRegionQueryDUnitTest.java | 7 +- .../geode/cache/query/dunit/PdxQueryDUnitTest.java | 23 +- ...PersistentRegionCompactRangeIndexDUnitTest.java | 44 +- .../dunit/QueryDataInconsistencyDUnitTest.java | 27 +- .../cache/query/dunit/QueryIndexDUnitTest.java | 122 +- .../query/dunit/QueryIndexUsingXMLDUnitTest.java | 40 +- .../dunit/QueryUsingFunctionContextDUnitTest.java | 28 +- .../cache/query/dunit/RemoteQueryDUnitTest.java | 3 +- .../ResourceManagerWithQueryMonitorDUnitTest.java | 24 +- .../query/dunit/SelectStarQueryDUnitTest.java | 52 +- ...igurationServiceConstraintsDistributedTest.java | 6 +- .../AggregateFunctionsQueryDUnitTest.java | 263 +- ...ntIndexOperationsOnOverflowRegionDUnitTest.java | 12 +- .../internal/index/CopyOnReadIndexDUnitTest.java | 47 +- .../index/IndexTrackingQueryObserverDUnitTest.java | 5 +- .../InitializeIndexEntryDestroyQueryDUnitTest.java | 5 +- .../PRBasicMultiIndexCreationDUnitTest.java | 4 +- .../query/partitioned/PRBasicQueryDUnitTest.java | 3 +- .../partitioned/PRColocatedEquiJoinDUnitTest.java | 26 +- .../query/partitioned/PRQueryDUnitHelper.java | 327 ++- .../cache/query/partitioned/PRQueryDUnitTest.java | 29 +- .../PRQueryRemoteNodeExceptionDUnitTest.java | 11 +- .../apache/geode/cache30/CacheXml66DUnitTest.java | 13 +- .../apache/geode/cache30/CacheXml70DUnitTest.java | 9 +- .../apache/geode/cache30/CacheXml80DUnitTest.java | 30 +- .../geode/cache30/DynamicRegionDUnitTest.java | 7 +- .../apache/geode/cache30/ReconnectDUnitTest.java | 9 +- ...ReconnectWithClusterConfigurationDUnitTest.java | 33 +- .../geode/cache30/SearchAndLoadDUnitTest.java | 5 +- .../org/apache/geode/cache30/TXOrderDUnitTest.java | 11 +- .../internal/CacheConfigDAODUnitTest.java | 3 +- ...lusterDistributionManagerForAdminDUnitTest.java | 3 +- ...onCreateBeforeInitializationRegressionTest.java | 5 +- .../cache/ConcurrentDestroySubRegionDUnitTest.java | 9 +- .../cache/HAOverflowMemObjectSizerDUnitTest.java | 7 +- .../geode/internal/cache/MapClearGIIDUnitTest.java | 3 +- .../cache/P2PDeltaPropagationDUnitTest.java | 25 +- .../PRQueryWithIndexAndPdxDistributedTest.java | 13 +- .../cache/ParallelDiskStoreRecoveryDUnitTest.java | 309 +++ .../cache/PartitionedRegionAPIDUnitTest.java | 3 +- .../cache/PartitionedRegionDestroyDUnitTest.java | 3 +- .../cache/PartitionedRegionSingleHopDUnitTest.java | 14 +- .../PrepareAndFinishBackupDistributedTest.java | 3 +- .../control/RebalanceOperationDistributedTest.java | 9 +- ...istributedRegionFunctionExecutionDUnitTest.java | 59 +- .../execute/LocalDataSetIndexingDUnitTest.java | 14 +- .../cache/execute/PRColocationDUnitTest.java | 165 +- .../cache/execute/PRSetOperationJTADUnitTest.java | 15 +- .../cache/execute/PRSetOperationTXDUnitTest.java | 9 +- .../cache/execute/PRTransactionDUnitTest.java | 45 +- .../cache/functions/LocalDataSetFunction.java | 10 +- .../cache/ha/EventIdOptimizationDUnitTest.java | 13 +- .../internal/cache/ha/HABugInPutDUnitTest.java | 5 +- .../geode/internal/cache/ha/HAClearDUnitTest.java | 33 +- .../internal/cache/ha/HAConflationDUnitTest.java | 10 +- .../internal/cache/ha/HADuplicateDUnitTest.java | 7 +- .../cache/ha/HAEventIdPropagationDUnitTest.java | 21 +- .../geode/internal/cache/ha/HAExpiryDUnitTest.java | 6 +- .../geode/internal/cache/ha/HAGIIBugDUnitTest.java | 11 +- .../geode/internal/cache/ha/HARegionDUnitTest.java | 13 +- .../internal/cache/ha/HARegionQueueDUnitTest.java | 15 +- .../geode/internal/cache/ha/PutAllDUnitTest.java | 9 +- .../geode/internal/cache/ha/StatsBugDUnitTest.java | 3 +- .../cache/locks/TXLockServiceDUnitTest.java | 14 +- ...PersistentPartitionedRegionDistributedTest.java | 2 +- .../fixed/FixedPartitioningTestBase.java | 45 +- ...oningWithColocationAndPersistenceDUnitTest.java | 12 +- .../sockets/CacheServerTransactionsDUnitTest.java | 19 +- .../tier/sockets/ClearPropagationDUnitTest.java | 21 +- .../tier/sockets/ClientConflationDUnitTest.java | 17 +- .../sockets/ClientInterestNotifyDUnitTest.java | 25 +- .../tier/sockets/ClientServerMiscDUnitTest.java | 3 +- .../ClientWithInterestFailoverDistributedTest.java | 9 +- .../cache/tier/sockets/ConflationDUnitTest.java | 47 +- .../sockets/DestroyEntryPropagationDUnitTest.java | 17 +- .../sockets/DurableResponseMatrixDUnitTest.java | 63 +- .../cache/tier/sockets/HABug36738DUnitTest.java | 5 +- .../cache/tier/sockets/HAInterestTestCase.java | 16 +- .../cache/tier/sockets/InterestListDUnitTest.java | 36 +- .../sockets/InterestRegrListenerDUnitTest.java | 4 +- .../sockets/InterestResultPolicyDUnitTest.java | 9 +- .../tier/sockets/NewRegionAttributesDUnitTest.java | 17 +- .../sockets/RedundancyLevelPart1DUnitTest.java | 5 +- .../tier/sockets/RedundancyLevelTestBase.java | 13 +- ...isterInterestBeforeRegionCreationDUnitTest.java | 4 +- .../sockets/RegisterInterestKeysDUnitTest.java | 5 +- .../tier/sockets/ReliableMessagingDUnitTest.java | 7 +- .../tier/sockets/UpdatePropagationDUnitTest.java | 11 +- ...ifyUpdatesFromNonInterestEndPointDUnitTest.java | 11 +- .../cache/tx/SetOperationJTADistributedTest.java | 7 +- .../asyncqueue/AsyncEventQueueStatsDUnitTest.java | 3 +- .../wan/misc/CommonAsyncEventQueueDUnitTest.java | 3 +- .../jta/dunit/TxnManagerMultiThreadDUnitTest.java | 5 +- .../management/ClientHealthStatsDUnitTest.java | 7 +- ...stemMXBeanWithNotificationsDistributedTest.java | 4 +- .../management/JMXMBeanReconnectDUnitTest.java | 7 +- .../MemberMXBeanAttributesDistributedTest.java | 13 +- .../geode/management/QueryDataDUnitTest.java | 53 +- .../geode/management/QueryPdxDataDUnitTest.java | 4 +- .../internal/JMXMBeanFederationDUnitTest.java | 3 +- .../ClusterConfigLocatorRestartDUnitTest.java | 3 +- .../ClusterConfigWithCallbacksDUnitTest.java | 3 +- .../internal/pulse/TestSubscriptionsDUnitTest.java | 5 +- .../security/MultiUserAuthenticationDUnitTest.java | 5 +- .../internal/util/ManagementUtilsDUnitTest.java | 17 +- .../NoShowValue1PostProcessorDUnitTest.java | 3 +- .../PDXGfshPostProcessorOnRemoteServerTest.java | 3 +- .../geode/security/PDXPostProcessorDUnitTest.java | 6 +- .../geode/security/PostProcessorDUnitTest.java | 3 +- .../query/PdxQuerySecurityDistributedTest.java | 13 +- ...QuerySecurityAllowedQueriesDistributedTest.java | 76 +- ...erySecurityForbiddenQueriesDistributedTest.java | 86 +- .../java/org/apache/geode/TXJUnitTest.java | 5 +- .../org/apache/geode/cache/ProxyJUnitTest.java | 5 +- .../cache/client/ClientRegionFactoryJUnitTest.java | 3 +- .../cache/query/JoinQueriesIntegrationTest.java | 38 +- .../cache/query/LocalQueryServiceJUnitTest.java | 7 +- .../geode/cache/query/PdxStringQueryJUnitTest.java | 199 +- .../apache/geode/cache/query/QueryJUnitTest.java | 103 +- .../geode/cache/query/QueryServiceJUnitTest.java | 90 +- .../cache/query/QueryServiceRegressionTest.java | 88 +- .../QueryWithBucketParameterIntegrationTest.java | 3 +- .../apache/geode/cache/query/RegionJUnitTest.java | 27 +- .../geode/cache/query/TypedIteratorJUnitTest.java | 15 +- .../functional/ComparisonOperatorsJUnitTest.java | 13 +- .../cache/query/functional/ConstantsJUnitTest.java | 13 +- .../functional/CustomerOptimizationsJUnitTest.java | 202 +- .../DistinctAndNonDistinctQueryJUnitTest.java | 16 +- ...tinctResultsWithDupValuesInRegionJUnitTest.java | 21 +- .../cache/query/functional/FunctionJUnitTest.java | 17 +- .../query/functional/INOperatorJUnitTest.java | 40 +- .../query/functional/IUM6Bug32345ReJUnitTest.java | 12 +- .../geode/cache/query/functional/IUMJUnitTest.java | 11 +- .../functional/IUMRCompositeIteratorJUnitTest.java | 11 +- .../IUMRMultiIndexesMultiRegionJUnitTest.java | 196 +- .../functional/IUMRShuffleIteratorsJUnitTest.java | 56 +- .../functional/IUMRSingleRegionJUnitTest.java | 108 +- ...IndependentOperandsInWhereClause2JUnitTest.java | 125 +- .../functional/IndexCreationDeadLockJUnitTest.java | 5 +- .../query/functional/IndexCreationJUnitTest.java | 229 +- .../IndexMaintenanceAsynchJUnitTest.java | 7 +- .../query/functional/IndexOnEntrySetJUnitTest.java | 14 +- .../functional/IndexPrimaryKeyUsageJUnitTest.java | 55 +- .../IndexUsageInNestedQueryJUnitTest.java | 35 +- ...IndexUsageInNestedQueryWithParamsJUnitTest.java | 11 +- .../IndexUsageWithAliasAsProjAtrbtJUnitTest.java | 16 +- .../IndexUseMultFrmSnglCondJUnitTest.java | 17 +- .../IndexWithSngleFrmAndMultCondQryJUnitTest.java | 100 +- .../functional/IteratorTypeDefEmpJUnitTest.java | 4 +- .../query/functional/IteratorTypeDefJUnitTest.java | 24 +- .../functional/IumMultConditionJUnitTest.java | 12 +- .../query/functional/LikePredicateJUnitTest.java | 474 ++-- .../query/functional/LimitClauseJUnitTest.java | 226 +- .../cache/query/functional/MiscJUnitTest.java | 111 +- .../functional/MultiRegionIndexUsageJUnitTest.java | 125 +- .../query/functional/MultipleRegionsJUnitTest.java | 22 +- .../functional/NegativeNumberQueriesJUnitTest.java | 11 +- .../query/functional/NestedQueryJUnitTest.java | 136 +- .../NonDistinctOrderByPartitionedJUnitTest.java | 151 +- .../NonDistinctOrderByReplicatedJUnitTest.java | 36 +- .../query/functional/NumericQueryJUnitTest.java | 45 +- .../functional/OrderByReplicatedJUnitTest.java | 399 +-- .../functional/ParameterBindingJUnitTest.java | 19 +- .../functional/QRegionInterfaceJUnitTest.java | 34 +- .../QueryREUpdateInProgressJUnitTest.java | 81 +- .../query/functional/QueryUndefinedJUnitTest.java | 36 +- .../functional/ReservedKeywordsJUnitTest.java | 7 +- .../ResultsDataSerializabilityJUnitTest.java | 3 +- .../query/functional/SelectToDateJUnitTest.java | 31 +- .../functional/StructMemberAccessJUnitTest.java | 59 +- .../TestNewFunctionSSorRSIntegrationTest.java | 10 +- .../ArithmeticOperationsIntegrationTest.java | 55 +- .../CompiledGroupBySelectIntegrationTest.java | 205 +- .../CompiledJunctionInternalsJUnitTest.java | 102 +- .../query/internal/CopyOnReadQueryJUnitTest.java | 10 +- .../DefaultQuerySecurityIntegrationTest.java | 21 +- .../internal/ExecutionContextIntegrationTest.java | 30 +- .../internal/GroupJunctionIntegrationTest.java | 16 +- .../query/internal/IndexManagerJUnitTest.java | 27 +- .../query/internal/OrderByComparatorJUnitTest.java | 11 +- .../internal/ProjectionAttributeJUnitTest.java | 78 +- .../QueryFromClauseCanonicalizationJUnitTest.java | 29 +- .../internal/QueryMonitorIntegrationTest.java | 4 +- .../query/internal/QueryObserverCallbacksTest.java | 114 +- .../cache/query/internal/QueryTraceJUnitTest.java | 33 +- .../cache/query/internal/QueryUtilsJUnitTest.java | 8 +- .../internal/aggregate/AvgIntegrationTest.java | 96 +- .../internal/aggregate/CountIntegrationTest.java | 118 +- .../internal/aggregate/MaxIntegrationTest.java | 148 +- .../internal/aggregate/MinIntegrationTest.java | 148 +- .../internal/aggregate/SumIntegrationTest.java | 98 +- .../AbstractIndexMaintenanceIntegrationTest.java | 11 +- .../index/AsynchIndexMaintenanceJUnitTest.java | 13 +- .../index/CompactRangeIndexIndexMapJUnitTest.java | 35 +- .../internal/index/CompactRangeIndexJUnitTest.java | 61 +- .../CompactRangeIndexQueryIntegrationTest.java | 19 +- .../index/DeclarativeIndexCreationJUnitTest.java | 9 +- .../internal/index/EquiJoinIntegrationTest.java | 143 +- .../index/HashIndexMaintenanceIntegrationTest.java | 11 +- .../index/HashIndexQueryIntegrationTest.java | 241 +- .../index/IndexCreationInternalsJUnitTest.java | 5 +- .../query/internal/index/IndexHintJUnitTest.java | 131 +- .../cache/query/internal/index/IndexJUnitTest.java | 6 +- .../internal/index/IndexMaintainceJUnitTest.java | 105 +- .../internal/index/IndexMaintenanceJUnitTest.java | 80 +- .../internal/index/IndexStatisticsJUnitTest.java | 45 +- .../index/IndexTrackingQueryObserverJUnitTest.java | 9 +- .../query/internal/index/IndexUseJUnitTest.java | 369 +-- .../IndexedMergeEquiJoinScenariosJUnitTest.java | 351 ++- .../internal/index/MapIndexStoreJUnitTest.java | 4 +- .../index/MapRangeIndexMaintenanceJUnitTest.java | 250 +- .../NewDeclarativeIndexCreationJUnitTest.java | 15 +- .../PartitionedRegionEquiJoinIntegrationTest.java | 5 +- .../index/PdxCopyOnReadQueryJUnitTest.java | 7 +- .../internal/index/RangeIndexAPIJUnitTest.java | 57 +- .../query/partitioned/PRColocatedEquiJoinTest.java | 11 +- .../partitioned/PRIndexStatisticsJUnitTest.java | 41 +- .../cache/query/partitioned/PRQueryJUnitTest.java | 11 +- .../partitioned/PRQueryNumThreadsJUnitTest.java | 8 +- .../query/transaction/QueryAndJtaJUnitTest.java | 75 +- .../RestrictUseOfInetAddressJUnitTest.java | 1 + .../geode/internal/ClassPathLoaderJUnitTest.java | 239 +- ...ionCreateNotBeforeRegionInitRegressionTest.java | 4 +- ...tMessagesRegionCreationAndDestroyJUnitTest.java | 8 +- .../geode/internal/cache/ColocatedPRJUnitTest.java | 3 +- .../internal/cache/DiskRegCacheXmlJUnitTest.java | 34 +- .../LIFOEvictionAlgoEnabledRegionJUnitTest.java | 15 +- ...FOEvictionAlgoMemoryEnabledRegionJUnitTest.java | 15 +- ...rtitionedRegionSerializableObjectJUnitTest.java | 5 +- ...itionedRegionSingleNodeOperationsJUnitTest.java | 3 +- .../backup/BackupFileCopierIntegrationTest.java | 3 +- .../FunctionExecutionOnLonerRegressionTest.java | 27 +- .../ModifyColocationIntegrationTest.java | 11 +- .../tier/sockets/RedundancyLevelJUnitTest.java | 3 +- ...elGatewaySenderFlushedCoordinatorJUnitTest.java | 2 +- .../geode/internal/jta/DataSourceJTAJUnitTest.java | 9 +- .../internal/jta/SetOperationJTAJUnitTest.java | 5 +- .../internal/jta/functional/CacheJUnitTest.java | 2 +- .../internal/offheap/OffHeapIndexJUnitTest.java | 11 +- .../management/DataQueryEngineIntegrationTest.java | 9 +- .../bean/stats/RegionStatsJUnitTest.java | 4 +- .../internal/beans/RegionMBeanAttributesTest.java | 4 +- .../security/GfshCommandsPostProcessorTest.java | 3 +- ...SSLSocketParameterExtensionIntegrationTest.java | 9 +- .../apache/geode/pdx/PdxSerializableJUnitTest.java | 9 +- .../codeAnalysis/sanctionedDataSerializables.txt | 8 +- .../internal/ra/spi/JCAManagedConnection.java | 33 +- .../geode/cache/RangeQueryWithIndexBenchmark.java | 7 +- .../geode/admin/internal/InetAddressUtils.java | 9 + .../admin/internal/SystemMemberRegionImpl.java | 4 +- .../jmx/internal/MemberInfoWithStatsMBean.java | 3 +- .../main/java/org/apache/geode/cache/Region.java | 68 +- .../internal/ParallelAsyncEventQueueImpl.java | 12 +- .../internal/SerialAsyncEventQueueImpl.java | 19 +- .../client/internal/ClientMetadataService.java | 4 +- .../geode/cache/configuration/CacheConfig.java | 13 + .../org/apache/geode/cache/wan/GatewaySender.java | 34 + .../geode/cache/wan/GatewaySenderFactory.java | 13 + .../geode/distributed/ConfigurationProperties.java | 50 +- .../internal/AbstractDistributionConfig.java | 11 +- .../distributed/internal/DistributionConfig.java | 60 +- .../internal/DistributionConfigImpl.java | 34 +- .../InternalConfigurationPersistenceService.java | 3 +- .../internal/InternalDistributedSystem.java | 3 +- .../distributed/internal/InternalLocator.java | 2 +- .../geode/internal/InternalDataSerializer.java | 5 + .../org/apache/geode/internal/admin/SSLConfig.java | 13 +- .../geode/internal/cache/BucketRegionQueue.java | 31 + .../geode/internal/cache/ColocationHelper.java | 3 +- .../geode/internal/cache/DiskStoreFactoryImpl.java | 7 +- .../geode/internal/cache/GemFireCacheImpl.java | 130 +- .../apache/geode/internal/cache/InternalCache.java | 4 + .../cache/InternalCacheForClientAccess.java | 16 +- .../geode/internal/cache/InternalRegion.java | 3 + .../apache/geode/internal/cache/LocalRegion.java | 35 +- .../geode/internal/cache/PartitionedRegion.java | 26 +- .../internal/cache/PartitionedRegionHelper.java | 16 +- .../geode/internal/cache/ProxyBucketRegion.java | 5 +- .../geode/internal/cache/RegionNameValidation.java | 9 +- .../geode/internal/cache/TXCommitMessage.java | 29 +- .../cache/TXLastEventInTransactionUtils.java | 120 + .../org/apache/geode/internal/cache/TXState.java | 24 +- .../util/TypedFunctionService.java} | 20 +- .../cache/tier/sockets/CacheClientNotifier.java | 4 +- .../tier/sockets/CacheClientProxyFactory.java | 4 +- .../tier/sockets/ClientProxyMembershipID.java | 5 +- .../internal/cache/wan/AbstractGatewaySender.java | 18 +- .../wan/AbstractGatewaySenderEventProcessor.java | 37 +- .../cache/wan/GatewaySenderAttributes.java | 6 + .../internal/cache/wan/GatewaySenderEventImpl.java | 74 +- ...currentParallelGatewaySenderEventProcessor.java | 19 +- .../ConcurrentParallelGatewaySenderQueue.java | 6 + .../ParallelGatewaySenderEventProcessor.java | 20 +- .../wan/parallel/ParallelGatewaySenderQueue.java | 252 +- .../wan/parallel/ParallelQueueRemovalMessage.java | 4 +- ...oncurrentSerialGatewaySenderEventProcessor.java | 24 +- .../serial/SerialGatewaySenderEventProcessor.java | 19 +- .../cache/wan/serial/SerialGatewaySenderQueue.java | 240 +- .../internal/cache/xmlcache/CacheCreation.java | 41 +- .../geode/internal/cache/xmlcache/CacheXml.java | 2 + .../internal/cache/xmlcache/CacheXmlGenerator.java | 10 + .../internal/cache/xmlcache/CacheXmlParser.java | 10 + .../xmlcache/ParallelAsyncEventQueueCreation.java | 3 + .../xmlcache/ParallelGatewaySenderCreation.java | 3 + .../internal/cache/xmlcache/RegionCreation.java | 4 +- .../xmlcache/SerialAsyncEventQueueCreation.java | 3 + .../xmlcache/SerialGatewaySenderCreation.java | 3 + .../geode/internal/io/CompositeOutputStream.java | 8 + .../geode/internal/lang/SystemPropertyHelper.java | 6 + .../apache/geode/internal/net/SocketCreator.java | 33 +- .../sequencelog/io/GemfireLogConverter.java | 10 +- .../org/apache/geode/internal/tcp/Connection.java | 20 +- .../geode/logging/internal/LoggingSession.java | 16 +- .../geode/management/GatewaySenderMXBean.java | 11 + .../api/LocatorClusterManagementService.java | 4 +- .../management/internal/beans/DataQueryEngine.java | 4 +- .../internal/beans/GatewaySenderMBean.java | 10 + .../internal/beans/GatewaySenderMBeanBridge.java | 9 + .../functions/CacheRealizationFunction.java | 47 +- .../geode/management/internal/i18n/CliStrings.java | 25 +- .../internal/operation/OperationManager.java | 17 +- .../internal/operation/OperationPerformer.java} | 17 +- .../operation/RebalanceOperationPerformer.java | 15 +- .../management/internal/util/ManagementUtils.java | 6 +- .../geode/management/internal/util/RegionPath.java | 16 +- .../apache/geode/net/SSLParameterExtension.java | 7 +- .../geode/net/SSLParameterExtensionContext.java | 11 +- .../internal/SSLParameterExtensionContextImpl.java | 18 +- .../apache/geode/security/ResourcePermission.java | 5 +- .../geode.apache.org/schema/cache/cache-1.0.xsd | 1 + .../BaseLineAndCompareQueryPerfJUnitTest.java | 96 +- .../internal/ClusterAlertMessagingTest.java | 6 +- .../internal/ParallelAsyncEventQueueImplTest.java | 97 + .../internal/SerialAsyncEventQueueImplTest.java | 31 +- .../geode/cache/configuration/CacheConfigTest.java | 13 +- .../org/apache/geode/cache/query/PerfQuery.java | 17 +- .../geode/cache/query/internal/QCompilerTest.java | 73 +- .../internal/index/CompactRangeIndexTest.java | 8 +- .../cache/query/internal/parse/OQLParserTest.java | 7 +- .../internal/DistributionConfigJUnitTest.java | 4 +- .../geode/internal/cache/BucketAdvisorTest.java | 28 +- .../cache/BucketPersistenceAdvisorTest.java | 3 +- .../internal/cache/BucketRegionQueueJUnitTest.java | 81 +- .../geode/internal/cache/ColocationHelperTest.java | 5 +- .../geode/internal/cache/GemFireCacheImplTest.java | 42 + .../internal/cache/PRHARedundancyProviderTest.java | 3 +- .../cache/PartitionedRegionHelperJUnitTest.java | 12 +- .../internal/cache/RegionNameValidationTest.java | 40 + .../cache/TXLastEventInTransactionUtilsTest.java | 196 ++ .../RestoreRedundancyOperationImplTest.java | 7 +- .../cache/execute/LocalDataSetFunction.java | 10 +- .../SingleThreadColocationLoggerTest.java | 22 +- .../persistence/PersistenceAdvisorImplTest.java | 5 +- ...entParallelGatewaySenderEventProcessorTest.java | 4 +- ...rallelGatewaySenderEventProcessorJUnitTest.java | 11 +- .../ParallelGatewaySenderEventProcessorTest.java | 5 +- .../wan/parallel/ParallelGatewaySenderHelper.java | 10 +- .../ParallelGatewaySenderQueueJUnitTest.java | 192 +- .../ParallelQueueRemovalMessageJUnitTest.java | 4 +- ...SerialGatewaySenderEventProcessorJUnitTest.java | 2 +- ...SerialGatewaySenderEventProcessorJUnitTest.java | 13 +- .../serial/SerialGatewaySenderQueueJUnitTest.java | 251 ++ .../TestSerialGatewaySenderEventProcessor.java | 6 +- .../io/CompositeOutputStreamJUnitTest.java | 55 +- .../internal/lang/SystemPropertyHelperTest.java | 51 + .../apache/geode/internal/tcp/TCPConduitTest.java | 4 +- .../geode/logging/internal/LoggingSessionTest.java | 22 + .../beans/GatewaySenderMBeanBridgeTest.java | 94 + .../internal/beans/GatewaySenderMBeanTest.java | 37 +- .../QueryDataFunctionApplyLimitClauseTest.java | 8 +- .../mutators/IndexConfigManagerTest.java | 5 +- .../configuration/realizers/IndexRealizerTest.java | 9 +- .../realizers/RegionConfigRealizerTest.java | 7 +- .../functions/CacheRealizationFunctionTest.java | 129 + .../internal/operation/OperationManagerTest.java | 26 +- .../operation/RebalanceOperationPerformerTest.java | 26 +- .../internal/security/ResourcePermissionTest.java | 5 +- .../RollingUpgrade2DUnitTestBase.java | 3 +- .../rollingupgrade/RollingUpgradeTracePRQuery.java | 4 +- ...ientStatisticsPublicationSecurityDUnitTest.java | 3 +- .../geode/cache/query/cq/CQDistributedTest.java | 16 +- .../cq/ContinuousQueryValidationDUnitTest.java | 47 +- .../cache/query/cq/dunit/CqDataDUnitTest.java | 25 +- .../query/cq/dunit/CqDataUsingPoolDUnitTest.java | 123 +- .../cache/query/cq/dunit/CqQueryDUnitTest.java | 111 +- .../query/cq/dunit/CqQueryUsingPoolDUnitTest.java | 67 +- .../cq/dunit/CqResultSetUsingPoolDUnitTest.java | 86 +- ...esultSetUsingPoolOptimizedExecuteDUnitTest.java | 13 +- .../cache/query/cq/dunit/CqStateDUnitTest.java | 3 +- .../cache/query/cq/dunit/CqStatsDUnitTest.java | 13 +- .../query/cq/dunit/CqStatsUsingPoolDUnitTest.java | 13 +- .../DestroyPartitionedRegionMessageDUnitTest.java | 4 +- ...nvalidatePartitionedRegionMessageDUnitTest.java | 4 +- .../dunit/PartitionedRegionCqQueryDUnitTest.java | 37 +- .../query/cq/dunit/PrCqUsingPoolDUnitTest.java | 39 +- ...tyExecutionContextTamperingDistributedTest.java | 4 +- .../query/dunit/QueryIndexUpdateRIDUnitTest.java | 34 +- .../cache/query/dunit/QueryMonitorDUnitTest.java | 151 +- ...igurationServiceConstraintsDistributedTest.java | 3 +- .../cache/snapshot/ClientSnapshotDUnitTest.java | 7 +- .../cache/PRDeltaPropagationDUnitTest.java | 3 +- .../cache/PutAllClientServerDistributedTest.java | 214 +- .../internal/cache/ha/CQListGIIDUnitTest.java | 29 +- .../internal/cache/ha/HADispatcherDUnitTest.java | 9 +- .../tier/sockets/ClientToServerDeltaDUnitTest.java | 9 +- .../sockets/DeltaPropagationWithCQDUnitTest.java | 3 +- ...ltaToRegionRelationCQRegistrationDUnitTest.java | 10 +- .../tier/sockets/DurableClientCQDUnitTest.java | 107 +- .../sockets/DurableClientHAQueuedDUnitTest.java | 151 +- .../tier/sockets/DurableClientSimpleDUnitTest.java | 16 +- .../management/CacheServerManagementDUnitTest.java | 4 +- .../AlterQueryServiceCommandDistributedTest.java | 4 +- .../commands/DescribeClientCommandDUnitTest.java | 9 +- .../commands/DurableClientCommandsDUnitTest.java | 9 +- .../security/CQPDXPostProcessorDUnitTest.java | 3 +- .../geode/security/CQPostProcessorDunitTest.java | 5 +- .../geode/security/ClientCQAuthDUnitTest.java | 3 +- .../geode/security/ClientQueryAuthDUnitTest.java | 3 +- .../geode/security/MultiUserAPIDUnitTest.java | 5 +- .../CqSecurityAllowedUsersDistributedTest.java | 21 +- .../CqSecurityForbiddenUsersDistributedTest.java | 13 +- .../cache/query/cq/internal/ServerCQImplTest.java | 4 +- .../tier/sockets/ClientServerMiscBCDUnitTest.java | 3 +- .../managing_data_entries.html.md.erb | 87 +- .../data_regions/region_naming.html.md.erb | 4 +- .../running/cluster-management-service.html.md.erb | 114 +- .../query_additional/advanced_querying.html.md.erb | 4 + .../querying-a-specific-member.html.md.erb | 78 + .../querying_basics/chapter_overview.html.md.erb | 4 + .../oql_compared_to_sql.html.md.erb | 31 - .../querying_basics/query_basics.html.md.erb | 10 + .../querying_basics/running_a_query.html.md.erb | 16 +- geode-docs/images/redis_api_for_geode.png | Bin 0 -> 62103 bytes ...timize_availability_and_performance.html.md.erb | 5 + geode-docs/reference/statistics_list.html.md.erb | 2 +- geode-docs/reference/topics/cache_xml.html.md.erb | 7 + .../topics/gemfire_properties.html.md.erb | 33 + geode-docs/tools_modules/book_intro.html.md.erb | 4 +- .../gfsh/command-pages/create.html.md.erb | 15 +- .../gfsh/command-pages/query.html.md.erb | 13 +- .../gfsh/command-pages/start.html.md.erb | 15 +- geode-docs/tools_modules/redis_adapter.html.md.erb | 90 - .../tools_modules/redis_api_for_geode.html.md.erb | 89 + .../setting_up_a_multisite_system.html.md.erb | 33 + .../multisite_overview.html.md.erb | 7 + .../apache/geode/cache/query/QueryTestUtils.java | 2575 +++++++++++++------- .../OrderByPartitionedJUnitTestBase.java | 367 +-- .../functional/OrderByTestImplementation.java | 300 ++- .../geode/cache30/MultiVMRegionTestCase.java | 3 +- .../org/apache/geode/cache30/RegionTestCase.java | 20 +- .../cache/wan/AsyncEventQueueTestBase.java | 18 +- .../commands/FunctionCommandsDUnitTestBase.java | 7 +- .../commands/GemfireDataCommandsDUnitTestBase.java | 16 +- .../commands/IndexCommandsIntegrationTestBase.java | 9 +- .../commands/ListIndexCommandDUnitTestBase.java | 4 +- ...tedQueryClassCastExceptionFailureDUnitTest.java | 12 +- .../cli/commands/QueryCommandDUnitTestBase.java | 42 + .../commands/QueryCommandIntegrationTestBase.java | 39 +- .../RegionMembershipMBeanDUnitTestBase.java | 21 +- .../security/GfshCommandsSecurityTestBase.java | 3 +- .../generator/XmlAuthzCredentialGenerator.java | 4 +- .../AbstractQuerySecurityDistributedTest.java | 3 +- .../geode/security/templates/XmlAuthorization.java | 10 +- .../driver/PostProcessingIntegrationTest.java | 4 +- .../driver/QueryServiceIntegrationTest.java | 4 +- .../apache/geode/experimental/driver/SSLTest.java | 5 +- .../management/internal/cli/CliUtilDUnitTest.java | 7 +- .../cli/commands/AlterRegionCommandDUnitTest.java | 9 +- .../cli/commands/CreateIndexCommandDUnitTest.java | 19 +- .../cli/commands/CreateRegionCommandDUnitTest.java | 122 +- ...egionCommandPersistsConfigurationDUnitTest.java | 6 +- ...eRegionCommandWithNoClusterConfigDUnitTest.java | 3 +- .../commands/CreateRegionSecurityDUnitTest.java | 7 +- .../commands/DestroyIndexCommandsDUnitTest.java | 3 +- .../commands/DestroyRegionCommandDUnitTest.java | 22 +- .../cli/commands/DiskStoreCommandsDUnitTest.java | 3 +- .../commands/ExecuteFunctionCommandDUnitTest.java | 30 +- .../GfshHostNameVerificationDistributedTest.java | 15 +- .../cli/commands/LocateEntryDUnitTest.java | 15 +- .../cli/commands/RebalanceCommandDUnitTest.java | 2 +- .../commands/RebalanceMembersColocationTest.java | 2 +- .../cli/commands/RemoveCommandDUnitTest.java | 2 +- .../cli/commands/RepeatedRebalanceDUnitTest.java | 86 +- .../cli/commands/ShowMetricsDUnitTest.java | 3 +- .../internal/cli/GfshParserConverterTest.java | 8 +- .../internal/cli/GfshParserParsingTest.java | 25 +- .../AlterRegionCommandIntegrationTest.java | 20 +- .../CreateRegionCommandIntegrationTest.java | 279 ++- .../cli/commands/ExportDataIntegrationTest.java | 5 +- .../cli/commands/GetCommandIntegrationTest.java | 4 +- .../cli/commands/ImportDataIntegrationTest.java | 5 +- .../cli/commands/PutCommandIntegrationTest.java | 24 +- .../ShowMetricsCommandIntegrationTest.java | 5 +- .../cli/domain/IndexDetailsIntegrationTest.java | 3 +- .../DataCommandFunctionWithPDXJUnitTest.java | 12 +- .../cli/commands/CreateGatewaySenderCommand.java | 20 +- .../internal/cli/commands/CreateRegionCommand.java | 6 +- .../commands/DescribeOfflineDiskStoreCommand.java | 5 +- .../internal/cli/commands/QueryCommand.java | 33 +- .../internal/cli/commands/RebalanceCommand.java | 2 +- .../cli/commands/StartGatewaySenderCommand.java | 13 +- .../internal/cli/commands/StartServerCommand.java | 11 + .../cli/converters/RegionPathConverter.java | 9 +- .../cli/functions/DataCommandFunction.java | 4 +- .../cli/functions/GatewaySenderCreateFunction.java | 5 + .../cli/functions/GatewaySenderFunctionArgs.java | 6 + .../cli/functions/RegionDestroyFunction.java | 4 +- .../sanctioned-geode-gfsh-serializables.txt | 3 +- .../cli/CommandSeparatorEscapeJUnitTest.java | 35 +- .../internal/cli/GfshParserJUnitTest.java | 11 +- .../cli/commands/AlterRegionCommandTest.java | 15 +- .../commands/CreateGatewaySenderCommandTest.java | 25 +- .../cli/commands/CreateIndexCommandTest.java | 26 +- .../cli/commands/CreateRegionCommandTest.java | 5 +- .../cli/commands/DescribeRegionJUnitTest.java | 3 +- .../cli/commands/DestroyRegionCommandTest.java | 7 +- .../cli/commands/ListIndexCommandJUnitTest.java | 3 +- .../internal/cli/commands/QueryCommandTest.java | 76 + .../converters/RegionPathConverterJUnitTest.java | 28 +- .../CreateDefinedIndexesFunctionTest.java | 7 +- .../DescribeDiskStoreFunctionJUnitTest.java | 61 +- .../cli/functions/GetRegionsFunctionTest.java | 3 +- .../cli/functions/ListIndexFunctionJUnitTest.java | 20 +- .../functions/RegionCreateFunctionJUnitTest.java | 5 +- .../ShowMissingDiskStoresFunctionTest.java | 13 +- .../cli/functions/UserFunctionExecutionTest.java | 10 +- .../internal/cli/util/HyphenFormatterTest.java | 13 +- .../internal/cli/util/RegionPathTest.java | 20 +- .../NonDistinctOrderByTestImplementation.java | 520 ++-- .../management/internal/security/TestCommand.java | 10 +- .../java/org/apache/geode/test/fake/Fakes.java | 3 + .../cache/lucene/test/LuceneTestUtilities.java | 34 +- .../cli/DestroyLuceneIndexCommandsDUnitTest.java | 21 +- .../cache/lucene/LuceneQueriesIntegrationTest.java | 4 +- .../cli/LuceneIndexCommandsIntegrationTest.java | 12 +- .../LuceneIndexXmlParserIntegrationJUnitTest.java | 9 +- .../CreateLuceneCommandParametersValidator.java | 6 +- .../lucene/internal/DestroyLuceneIndexMessage.java | 5 +- .../internal/LuceneIndexForPartitionedRegion.java | 4 +- .../internal/management/LuceneServiceBridge.java | 7 +- .../IndexRepositoryImplPerformanceTest.java | 8 +- .../PartitionedRepositoryManagerJUnitTest.java | 5 +- .../RawLuceneRepositoryManagerJUnitTest.java | 5 +- .../internal/ValidateCommandParametersTest.java | 15 +- .../internal/cli/LuceneIndexCommandsJUnitTest.java | 33 +- .../LuceneCreateIndexFunctionJUnitTest.java | 14 +- .../LuceneDescribeIndexFunctionJUnitTest.java | 5 +- .../LuceneDestroyIndexFunctionJUnitTest.java | 19 +- .../LuceneListIndexFunctionJUnitTest.java | 3 +- .../distributed/LuceneQueryFunctionJUnitTest.java | 3 +- .../WaitUntilFlushedFunctionJUnitTest.java | 3 +- .../xml/LuceneIndexXmlParserJUnitTest.java | 3 +- .../geode/management/configuration/Index.java | 5 +- .../geode/management/configuration/Region.java | 7 +- .../geode/management/configuration/IndexTest.java | 15 +- .../geode/management/configuration/RegionTest.java | 9 +- .../src/test/script/update-management-wiki.sh | 18 +- geode-membership/build.gradle | 17 +- .../src/integrationTest/resources/log4j2.xml | 2 +- .../protobuf/v1/AuthorizationIntegrationTest.java | 4 +- ...ueryRequestOperationHandlerIntegrationTest.java | 11 +- .../protobuf/security/SecureCacheImplTest.java | 9 +- .../OqlQueryRequestOperationHandlerJUnitTest.java | 3 +- .../geode/tools/pulse/tests/PulseTestData.java | 4 +- .../tools/pulse/tests/junit/BaseServiceTest.java | 12 +- .../junit/ClusterSelectedRegionServiceTest.java | 8 +- .../ClusterSelectedRegionsMemberServiceTest.java | 6 +- .../geode/tools/pulse/tests/ui/PulseBase.java | 19 +- geode-redis/README.md | 4 +- geode-redis/build.gradle | 8 +- .../geode/redis/ExistsDockerAcceptanceTest.java | 2 +- .../redis/ExpireAtNativeRedisAcceptanceTest.java | 2 +- .../redis/ExpireNativeRedisAcceptanceTest.java | 2 +- .../geode/redis/GeoNativeRedisAcceptanceTest.java | 85 - .../redis/ListsNativeRedisAcceptanceTest.java | 48 - .../redis/PersistNativeRedisAcceptanceTest.java | 2 +- .../redis/PexpireNativeRedisAcceptanceTest.java | 2 +- .../redis/RenameNativeRedisAcceptanceTest.java | 41 +- .../redis/SortedSetNativeRedisAcceptanceTest.java | 47 - .../redis/StringsNativeRedisAcceptanceTest.java | 11 - .../geode/redis/ConcurrentLoopingThreads.java | 29 +- .../apache/geode/redis/GeodeRedisServerRule.java | 26 +- .../test/dunit/rules/RedisClusterStartupRule.java | 74 + .../geode/redis/CheckPrimaryBucketFunction.java | 125 + .../redis/EnsurePrimaryStaysPutDUnitTest.java | 202 ++ .../redis/GeodeRedisServerStartupDUnitTest.java | 115 +- .../org/apache/geode/redis/PubSubDUnitTest.java | 104 +- .../org/apache/geode/redis/RedisDistDUnitTest.java | 93 +- .../geode/redis/RedisSessionDistDUnitTest.java | 256 -- .../redis/RedisUsePersistentRegionDUnitTest.java | 57 - .../geode/redis/executors/ExpireDUnitTest.java | 117 +- .../geode/redis/executors/hash/HMsetDUnitTest.java | 75 +- .../geode/redis/executors/hash/HsetDUnitTest.java | 75 +- .../redis/executors/keys/ExistsDUnitTest.java | 23 +- .../redis/executors/keys/PersistDUnitTest.java | 30 +- .../redis/executors/keys/RenameDUnitTest.java | 220 ++ .../geode/redis/executors/set/SaddDUnitTest.java | 75 +- .../geode/redis/executors/set/SremDUnitTest.java | 75 +- .../redis/executors/string/StringsDUnitTest.java | 253 ++ .../redis/session/RedisSessionDistDUnitTest.java | 118 + .../geode/redis/session/SessionDUnitTest.java | 174 ++ .../redis/session/SessionExpirationDUnitTest.java | 100 + .../RedisSpringTestApplication.java | 2 +- .../SessionController.java | 15 +- .../config/DUnitSocketAddressResolver.java | 2 +- .../config/SessionListener.java | 20 +- .../config/WebMvcConfig.java | 2 +- .../redis/CommandPipeliningIntegrationTest.java | 101 + .../redis/ConcurrentStartIntegrationTest.java | 2 +- .../org/apache/geode/redis/GeoIntegrationTest.java | 405 --- .../apache/geode/redis/HashesIntegrationTest.java | 236 +- .../apache/geode/redis/ListsIntegrationTest.java | 235 -- .../geode/redis/RedisServerIntegrationTest.java | 96 - .../apache/geode/redis/RenameIntegrationTest.java | 230 +- .../java/org/apache/geode/redis/SSLTest.java | 1 + .../geode/redis/SortedSetsIntegrationTest.java | 415 ---- .../apache/geode/redis/StringsIntegrationTest.java | 102 +- .../internal/{ => pubsub}/DummySubscription.java | 4 +- .../{ => pubsub}/SubscriptionsIntegrationTest.java | 10 +- .../{general => key}/ExistsIntegrationTest.java | 92 +- .../{general => key}/ExpireAtIntegrationTest.java | 2 +- .../{general => key}/ExpireIntegrationTest.java | 120 +- .../FlushAllIntegrationTest.java} | 33 +- .../{general => key}/PersistIntegrationTest.java | 53 +- .../{general => key}/PexpireIntegrationTest.java | 2 +- .../geode/redis/key/ShutdownIntegrationTest.java | 70 + .../geode/redis/sets/SRemIntegrationTest.java | 63 - .../geode/redis/sets/SetsIntegrationTest.java | 4 +- .../apache/geode/codeAnalysis/excludedClasses.txt | 9 - .../codeAnalysis/sanctionedDataSerializables.txt | 24 +- .../java/org/apache/geode/internal/hll/Bits.java | 46 - .../internal/hll/CardinalityMergeException.java | 23 - .../org/apache/geode/internal/hll/HyperLogLog.java | 337 --- .../apache/geode/internal/hll/HyperLogLogPlus.java | 1865 -------------- .../org/apache/geode/internal/hll/IBuilder.java | 22 - .../apache/geode/internal/hll/ICardinality.java | 73 - .../org/apache/geode/internal/hll/MurmurHash.java | 214 -- .../org/apache/geode/internal/hll/RegisterSet.java | 108 - .../apache/geode/redis/internal/DoubleWrapper.java | 77 - .../redis/internal/ExecutionHandlerContext.java | 406 --- .../org/apache/geode/redis/internal/GeoCoder.java | 217 -- .../org/apache/geode/redis/internal/GeoCoord.java | 34 - .../redis/internal/GeoRadiusResponseElement.java | 68 - .../geode/redis/internal/GeodeRedisServer.java | 500 ++-- .../geode/redis/internal/GeodeRedisService.java | 26 +- .../org/apache/geode/redis/internal/HashArea.java | 30 - .../apache/geode/redis/internal/HashNeighbors.java | 41 - .../geode/redis/internal/KeyHashIdentifier.java | 70 - .../apache/geode/redis/internal/KeyRegistrar.java | 108 - .../NamedThreadFactory.java | 3 +- .../EvenParameterRequirements.java | 4 +- .../ExactParameterRequirements.java | 4 +- .../MaximumParameterRequirements.java | 4 +- .../MinimumParameterRequirements.java | 4 +- .../MultipleParameterRequirements.java | 4 +- .../ParameterRequirements.java | 4 +- .../SpopParameterRequirements.java | 4 +- .../UnspecifiedParameterRequirements.java | 4 +- .../geode/redis/internal/RedisCommandType.java | 363 ++- .../geode/redis/internal/RedisConstants.java | 113 +- .../apache/geode/redis/internal/RedisDataType.java | 124 - .../geode/redis/internal/RedisLockService.java | 110 - .../redis/internal/RedisLockServiceMBean.java | 33 - .../redis/internal/RegionCreationException.java | 35 - .../geode/redis/internal/RegionProvider.java | 584 +---- .../redis/internal/data/AbstractRedisData.java | 186 ++ .../internal/{ => data}/ByteArrayWrapper.java | 81 +- .../{executor => data}/EmptyRedisHash.java | 24 +- .../{executor/set => data}/EmptyRedisSet.java | 31 +- .../geode/redis/internal/data/RedisData.java} | 38 +- .../RedisDataType.java} | 22 +- .../{ => data}/RedisDataTypeMismatchException.java | 5 +- .../geode/redis/internal/data/RedisHash.java | 290 +++ .../redis/internal/data/RedisHashInRegion.java | 133 + .../redis/internal/data/RedisKeyInRegion.java | 117 + .../internal/{executor/set => data}/RedisSet.java | 139 +- .../redis/internal/data/RedisSetInRegion.java | 256 ++ .../geode/redis/internal/data/RedisString.java | 153 ++ .../redis/internal/data/RedisStringInRegion.java | 191 ++ .../geode/redis/internal/delta/AddsDeltaInfo.java | 43 +- .../AppendDeltaInfo.java} | 26 +- .../LPopExecutor.java => delta/DeltaInfo.java} | 13 +- .../RPopExecutor.java => delta/DeltaType.java} | 16 +- .../geode/redis/internal/delta/RemsDeltaInfo.java | 43 +- .../TimestampDeltaInfo.java} | 27 +- .../redis/internal/executor/AbstractExecutor.java | 116 +- .../redis/internal/executor/CommandFunction.java | 190 +- .../geode/redis/internal/executor/DelExecutor.java | 55 - .../redis/internal/{ => executor}/Executor.java | 21 +- .../internal/executor/ExpirationExecutor.java | 41 - .../redis/internal/{ => executor}/Extendable.java | 3 +- .../redis/internal/executor/FlushAllExecutor.java | 48 - .../apache/hadoop/fs => executor}/GlobPattern.java | 11 +- .../geode/redis/internal/executor/ListQuery.java | 71 - .../redis/internal/executor/RedisHashInRegion.java | 63 - .../redis/internal/executor/RedisResponse.java | 109 + .../redis/internal/executor/RenameExecutor.java | 90 - .../executor/{set => }/SingleResultCollector.java | 3 +- .../executor/SingleResultRedisFunction.java | 26 +- .../redis/internal/executor/SortedSetQuery.java | 335 --- .../executor/{set => }/StripedExecutor.java | 9 +- .../{set => }/SynchronizedStripedExecutor.java | 25 +- .../{UnkownExecutor.java => UnknownExecutor.java} | 11 +- .../redis/internal/executor/hash/HDelExecutor.java | 24 +- .../internal/executor/hash/HExistsExecutor.java | 39 +- .../internal/executor/hash/HGetAllExecutor.java | 24 +- .../redis/internal/executor/hash/HGetExecutor.java | 32 +- .../internal/executor/hash/HIncrByExecutor.java | 96 +- .../executor/hash/HIncrByFloatExecutor.java | 88 +- .../internal/executor/hash/HKeysExecutor.java | 38 +- .../redis/internal/executor/hash/HLenExecutor.java | 32 +- .../internal/executor/hash/HMGetExecutor.java | 38 +- .../internal/executor/hash/HMSetExecutor.java | 19 +- .../internal/executor/hash/HScanExecutor.java | 97 +- .../redis/internal/executor/hash/HSetExecutor.java | 18 +- .../internal/executor/hash/HValsExecutor.java | 31 +- .../redis/internal/executor/hash/HashExecutor.java | 61 +- .../redis/internal/executor/hash/RedisHash.java | 204 -- .../internal/executor/hash/RedisHashCommands.java | 24 +- .../hash/RedisHashCommandsFunctionExecutor.java | 68 +- .../redis/internal/executor/hll/HllExecutor.java | 32 - .../redis/internal/executor/hll/PFAddExecutor.java | 68 - .../internal/executor/hll/PFCountExecutor.java | 70 - .../internal/executor/hll/PFMergeExecutor.java | 75 - .../geode/redis/internal/executor/hll/Varint.java | 238 -- .../executor/{ => key}/AbstractScanExecutor.java | 8 +- .../executor/{ => key}/DBSizeExecutor.java | 12 +- .../{ExistsExecutor.java => key/DelExecutor.java} | 26 +- .../executor/{ => key}/ExistsExecutor.java | 20 +- .../executor/{ => key}/ExpireAtExecutor.java | 61 +- .../executor/{ => key}/ExpireExecutor.java | 44 +- .../FlushAllExecutor.java} | 26 +- .../internal/executor/{ => key}/KeysExecutor.java | 23 +- .../executor/{ => key}/PExpireAtExecutor.java | 3 +- .../executor/{ => key}/PExpireExecutor.java | 3 +- .../internal/executor/{ => key}/PTTLExecutor.java | 3 +- .../executor/{ => key}/PersistExecutor.java | 31 +- .../RedisKeyCommands.java} | 20 +- .../key/RedisKeyCommandsFunctionExecutor.java | 101 + .../MultiExecutor.java => key/RenameExecutor.java} | 47 +- .../internal/executor/key/RenameFunction.java | 249 ++ .../internal/executor/{ => key}/ScanExecutor.java | 19 +- .../internal/executor/{ => key}/TTLExecutor.java | 51 +- .../internal/executor/{ => key}/TypeExecutor.java | 22 +- .../internal/executor/list/LIndexExecutor.java | 114 - .../internal/executor/list/LInsertExecutor.java | 28 - .../redis/internal/executor/list/LLenExecutor.java | 45 - .../internal/executor/list/LRangeExecutor.java | 106 - .../redis/internal/executor/list/LRemExecutor.java | 109 - .../redis/internal/executor/list/LSetExecutor.java | 104 - .../internal/executor/list/LTrimExecutor.java | 118 - .../redis/internal/executor/list/ListExecutor.java | 138 -- .../redis/internal/executor/list/PopExecutor.java | 123 - .../redis/internal/executor/list/PushExecutor.java | 47 - .../internal/executor/list/PushXExecutor.java | 51 - .../internal/executor/list/RPushExecutor.java | 25 - .../internal/executor/list/RPushXExecutor.java | 23 - .../executor/pubsub/PsubscribeExecutor.java | 10 +- .../internal/executor/pubsub/PublishExecutor.java | 41 +- .../executor/pubsub/PunsubscribeExecutor.java | 10 +- .../executor/pubsub/SubscribeExecutor.java | 8 +- .../executor/pubsub/UnsubscribeExecutor.java | 8 +- .../executor/{ => server}/AuthExecutor.java | 27 +- .../executor/{ => server}/EchoExecutor.java | 10 +- .../executor/{ => server}/PingExecutor.java | 10 +- .../executor/{ => server}/QuitExecutor.java | 16 +- .../executor/{ => server}/ShutDownExecutor.java | 8 +- .../executor/{ => server}/TimeExecutor.java | 10 +- .../internal/executor/set/RedisSetCommands.java | 14 +- .../set/RedisSetCommandsFunctionExecutor.java | 44 +- .../internal/executor/set/RedisSetInRegion.java | 106 - .../redis/internal/executor/set/SAddExecutor.java | 20 +- .../redis/internal/executor/set/SCardExecutor.java | 19 +- .../redis/internal/executor/set/SDiffExecutor.java | 21 +- .../internal/executor/set/SInterExecutor.java | 21 +- .../internal/executor/set/SIsMemberExecutor.java | 38 +- .../internal/executor/set/SMembersExecutor.java | 26 +- .../redis/internal/executor/set/SMoveExecutor.java | 89 +- .../redis/internal/executor/set/SPopExecutor.java | 34 +- .../internal/executor/set/SRandMemberExecutor.java | 46 +- .../redis/internal/executor/set/SRemExecutor.java | 38 +- .../redis/internal/executor/set/SScanExecutor.java | 42 +- .../internal/executor/set/SUnionExecutor.java | 14 +- .../redis/internal/executor/set/SetExecutor.java | 31 +- .../redis/internal/executor/set/SetOpExecutor.java | 120 +- .../executor/sortedset/GeoAddExecutor.java | 77 - .../executor/sortedset/GeoDistExecutor.java | 58 - .../executor/sortedset/GeoHashExecutor.java | 57 - .../executor/sortedset/GeoPosExecutor.java | 60 - .../sortedset/GeoRadiusByMemberExecutor.java | 126 - .../executor/sortedset/GeoRadiusExecutor.java | 121 - .../executor/sortedset/GeoRadiusParameters.java | 137 -- .../executor/sortedset/GeoSortedSetExecutor.java | 95 - .../executor/sortedset/SortedSetExecutor.java | 47 - .../internal/executor/sortedset/ZAddExecutor.java | 91 - .../internal/executor/sortedset/ZCardExecutor.java | 54 - .../executor/sortedset/ZCountExecutor.java | 146 -- .../executor/sortedset/ZIncrByExecutor.java | 76 - .../executor/sortedset/ZLexCountExecutor.java | 149 -- .../executor/sortedset/ZRangeByLexExecutor.java | 229 -- .../executor/sortedset/ZRangeByScoreExecutor.java | 220 -- .../executor/sortedset/ZRangeExecutor.java | 125 - .../internal/executor/sortedset/ZRankExecutor.java | 98 - .../internal/executor/sortedset/ZRemExecutor.java | 64 - .../executor/sortedset/ZRemRangeByLexExecutor.java | 165 -- .../sortedset/ZRemRangeByRankExecutor.java | 125 - .../sortedset/ZRemRangeByScoreExecutor.java | 150 -- .../executor/sortedset/ZRevRankExecutor.java | 30 - .../internal/executor/sortedset/ZScanExecutor.java | 165 -- .../executor/sortedset/ZScoreExecutor.java | 57 - .../internal/executor/string/AppendExecutor.java | 49 +- .../internal/executor/string/BitCountExecutor.java | 37 +- .../internal/executor/string/BitOpExecutor.java | 55 +- .../internal/executor/string/BitPosExecutor.java | 52 +- .../internal/executor/string/DecrByExecutor.java | 80 +- .../internal/executor/string/DecrExecutor.java | 85 +- .../internal/executor/string/GetBitExecutor.java | 37 +- .../internal/executor/string/GetExecutor.java | 30 +- .../internal/executor/string/GetRangeExecutor.java | 36 +- .../internal/executor/string/GetSetExecutor.java | 55 +- .../internal/executor/string/IncrByExecutor.java | 77 +- .../executor/string/IncrByFloatExecutor.java | 57 +- .../internal/executor/string/IncrExecutor.java | 80 +- .../internal/executor/string/MGetExecutor.java | 41 +- .../internal/executor/string/MSetExecutor.java | 52 +- .../internal/executor/string/MSetNXExecutor.java | 69 +- .../string/RedisStringCommands.java} | 31 +- .../RedisStringCommandsFunctionExecutor.java | 77 + .../internal/executor/string/SetBitExecutor.java | 78 +- .../internal/executor/string/SetEXExecutor.java | 45 +- .../internal/executor/string/SetExecutor.java | 232 +- .../internal/executor/string/SetNXExecutor.java | 34 +- .../redis/internal/executor/string/SetOptions.java | 69 + .../internal/executor/string/SetRangeExecutor.java | 80 +- .../internal/executor/string/StringExecutor.java | 19 +- .../internal/executor/string/StrlenExecutor.java | 33 +- .../executor/transactions/ExecExecutor.java | 88 - .../executor/transactions/TransactionExecutor.java | 21 - .../executor/transactions/UnwatchExecutor.java | 30 - .../executor/transactions/WatchExecutor.java | 30 - .../internal/{ => netty}/ByteToCommandDecoder.java | 3 +- .../geode/redis/internal/{ => netty}/Client.java | 3 +- .../geode/redis/internal/{ => netty}/Coder.java | 171 +- .../redis/internal/{ => netty}/CoderException.java | 3 +- .../geode/redis/internal/{ => netty}/Command.java | 51 +- .../internal/netty/ExecutionHandlerContext.java | 332 +++ .../{ => netty}/RedisCommandParserException.java | 3 +- .../{ => pubsub}/AbstractSubscription.java | 6 +- .../internal/{ => pubsub}/ChannelSubscription.java | 5 +- .../internal/{ => pubsub}/PatternSubscription.java | 6 +- .../geode/redis/internal/{ => pubsub}/PubSub.java | 6 +- .../redis/internal/{ => pubsub}/PubSubImpl.java | 6 +- .../redis/internal/{ => pubsub}/PublishResult.java | 5 +- .../{ => pubsub}/PublishResultCollector.java | 5 +- .../redis/internal/{ => pubsub}/Subscription.java | 4 +- .../redis/internal/{ => pubsub}/Subscriptions.java | 4 +- .../sanctioned-geode-redis-serializables.txt | 86 +- .../geode/redis/internal/CommandJUnitTest.java | 3 +- .../internal/ExecutionHandlerContextJUnitTest.java | 8 +- .../redis/internal/KeyHashIdentifierTest.java | 44 - .../redis/internal/RedisLockServiceJUnitTest.java | 211 -- .../redis/internal/RegionProviderJUnitTest.java | 108 - .../redis/internal/SupportedCommandsJUnitTest.java | 155 ++ .../executor/AbstractExecutorJUnitTest.java | 61 - ...UnitTest.java => UnknownExecutorJUnitTest.java} | 8 +- .../{ => key}/AbstractScanExecutorJUnitTest.java | 3 +- .../{string => key}/DelExecutorJUnitTest.java | 20 +- .../{general => key}/ExistsExecutorJUnitTest.java | 20 +- .../ExpireAtExecutorJUnitTest.java | 8 +- .../{general => key}/ExpireExecutorJUnitTest.java | 10 +- .../PExpireAtExecutorJUnitTest.java | 8 +- .../{general => key}/PersistExecutorJUnitTest.java | 10 +- .../{general => key}/PexpireExecutorJUnitTest.java | 7 +- .../executor/set/SetExecutorJUnitTest.java | 4 +- .../executor/string/GetRangeExecutorJUnitTest.java | 24 +- .../executor/string/GetSetExecutorJUnitTest.java | 29 +- .../executor/string/IncrExecutorJUnitTest.java | 17 +- .../string/StringGetExecutorJUnitTest.java | 59 +- .../string/StringMGetExecutorJUnitTest.java | 14 +- .../string/StringMSetExecutorJUnitTest.java | 17 +- .../string/StringSetExecutorJUnitTest.java | 206 +- .../executor/string/StrlenExecutorJUnitTest.java | 16 +- .../internal/{ => pubsub}/PubSubImplJUnitTest.java | 9 +- .../{ => pubsub}/SubscriptionsJUnitTest.java | 6 +- .../serialization/DataSerializableFixedID.java | 2 +- .../geode/internal/cache/wan/WANTestBase.java | 231 +- ...ParallelGatewaySenderOperation_1_DUnitTest.java | 8 + ...ParallelGatewaySenderOperation_2_DUnitTest.java | 4 +- .../cache/wan/disttx/DistTXWANDUnitTest.java | 2 + .../NewWANConcurrencyCheckForDestroyDUnitTest.java | 15 +- .../wan/misc/NewWanAuthenticationDUnitTest.java | 5 +- .../cache/wan/misc/PDXNewWanDUnitTest.java | 9 +- ...atedRegion_ParallelWANPropagationDUnitTest.java | 7 +- .../internal/cache/wan/misc/WANSSLDUnitTest.java | 3 +- ...ANPersistenceEnabledGatewaySenderDUnitTest.java | 291 +++ .../wan/parallel/ParallelWANStatsDUnitTest.java | 663 +++-- ...lGatewaySenderDistributedDeadlockDUnitTest.java | 5 +- ...rialGatewaySenderOperationsDistributedTest.java | 17 +- ...ANPersistenceEnabledGatewaySenderDUnitTest.java | 148 ++ .../cache/wan/serial/SerialWANStatsDUnitTest.java | 383 ++- .../WANHostNameVerificationDistributedTest.java | 9 +- ...CreateDestroyGatewaySenderCommandDUnitTest.java | 13 +- .../StartGatewaySenderCommandDUnitTest.java | 97 + .../cache/wan/wancommand/WANCommandUtils.java | 6 +- .../cli/commands/AlterRegionCommandDUnitTest.java | 22 +- .../AlterRegionCommandWithRemoteLocator.java | 67 +- .../cli/commands/CreateRegionCommandDUnitTest.java | 9 +- .../cache/wan/misc/WANConfigurationJUnitTest.java | 25 +- .../wan/GatewaySenderEventRemoteDispatcher.java | 4 +- .../cache/wan/GatewaySenderFactoryImpl.java | 13 + .../wan/parallel/ParallelGatewaySenderImpl.java | 12 +- ...currentParallelGatewaySenderEventProcessor.java | 9 +- .../RemoteParallelGatewaySenderEventProcessor.java | 9 +- ...oncurrentSerialGatewaySenderEventProcessor.java | 8 +- .../RemoteSerialGatewaySenderEventProcessor.java | 4 +- .../cache/wan/serial/SerialGatewaySenderImpl.java | 34 +- .../parallel/ParallelGatewaySenderImplTest.java | 92 + .../wan/serial/SerialGatewaySenderImplTest.java | 89 +- .../web/controllers/AddFreeItemToOrders.java | 5 +- .../web/controllers/RestAccessControllerTest.java | 49 +- .../CustomMappingJackson2HttpMessageConverter.java | 6 + .../management/client/GetStartingMemberTest.java | 93 + .../MemberManagementServiceRestDUnitTest.java} | 6 +- .../rest/RegionManagementIntegrationTest.java | 3 +- .../CustomMappingJackson2HttpMessageConverter.java | 6 + .../commands/ShutdownCommandOverHttpDUnitTest.java | 44 +- gradle/japicmp.gradle | 5 + gradle/standard-subproject-configuration.gradle | 2 +- 1002 files changed, 24232 insertions(+), 25329 deletions(-) create mode 100644 buildSrc/src/main/groovy/org/apache/geode/gradle/japicmp/GeodeApiRegressionRule.groovy create mode 100755 buildSrc/src/main/resources/japicmp_exceptions.json copy {geode-core/src/main/java/org/apache/geode/internal/cache/util => geode-common/src/main/java/org/apache/geode/util/internal}/UncheckedUtils.java (68%) create mode 100644 geode-common/src/test/java/org/apache/geode/util/internal/UncheckedUtilsTest.java create mode 100644 geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ParallelDiskStoreRecoveryDUnitTest.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/TXLastEventInTransactionUtils.java copy geode-core/src/main/java/org/apache/geode/internal/cache/{util/UncheckedUtils.java => execute/util/TypedFunctionService.java} (61%) rename geode-core/src/main/java/org/apache/geode/{internal/cache/util/UncheckedUtils.java => management/internal/operation/OperationPerformer.java} (68%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LPushXExecutor.java => geode-core/src/main/java/org/apache/geode/net/SSLParameterExtensionContext.java (80%) mode change 100755 => 100644 rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRevRangeByScoreExecutor.java => geode-core/src/main/java/org/apache/geode/net/internal/SSLParameterExtensionContextImpl.java (66%) mode change 100755 => 100644 create mode 100644 geode-core/src/test/java/org/apache/geode/cache/asyncqueue/internal/ParallelAsyncEventQueueImplTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/TXLastEventInTransactionUtilsTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueueJUnitTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/beans/GatewaySenderMBeanBridgeTest.java rename geode-redis/src/test/java/org/apache/geode/redis/internal/GeoCoderJUnitTest.java => geode-core/src/test/java/org/apache/geode/management/internal/beans/GatewaySenderMBeanTest.java (52%) create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/functions/CacheRealizationFunctionTest.java create mode 100644 geode-docs/developing/query_additional/querying-a-specific-member.html.md.erb delete mode 100644 geode-docs/developing/querying_basics/oql_compared_to_sql.html.md.erb create mode 100644 geode-docs/images/redis_api_for_geode.png delete mode 100644 geode-docs/tools_modules/redis_adapter.html.md.erb create mode 100644 geode-docs/tools_modules/redis_api_for_geode.html.md.erb create mode 100644 geode-gfsh/src/test/java/org/apache/geode/management/internal/cli/commands/QueryCommandTest.java delete mode 100755 geode-redis/src/acceptanceTest/java/org/apache/geode/redis/GeoNativeRedisAcceptanceTest.java delete mode 100755 geode-redis/src/acceptanceTest/java/org/apache/geode/redis/ListsNativeRedisAcceptanceTest.java mode change 100644 => 100755 geode-redis/src/acceptanceTest/java/org/apache/geode/redis/RenameNativeRedisAcceptanceTest.java delete mode 100755 geode-redis/src/acceptanceTest/java/org/apache/geode/redis/SortedSetNativeRedisAcceptanceTest.java create mode 100644 geode-redis/src/commonTest/java/org/apache/geode/test/dunit/rules/RedisClusterStartupRule.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/CheckPrimaryBucketFunction.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/EnsurePrimaryStaysPutDUnitTest.java delete mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/RedisSessionDistDUnitTest.java delete mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/RedisUsePersistentRegionDUnitTest.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/executors/keys/RenameDUnitTest.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/executors/string/StringsDUnitTest.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/session/RedisSessionDistDUnitTest.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/session/SessionDUnitTest.java create mode 100644 geode-redis/src/distributedTest/java/org/apache/geode/redis/session/SessionExpirationDUnitTest.java rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{ => session}/springRedisTestApplication/RedisSpringTestApplication.java (94%) rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{ => session}/springRedisTestApplication/SessionController.java (85%) rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{ => session}/springRedisTestApplication/config/DUnitSocketAddressResolver.java (95%) rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{ => session}/springRedisTestApplication/config/SessionListener.java (62%) rename geode-redis/src/distributedTest/java/org/apache/geode/redis/{ => session}/springRedisTestApplication/config/WebMvcConfig.java (95%) create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/CommandPipeliningIntegrationTest.java delete mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/GeoIntegrationTest.java delete mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/ListsIntegrationTest.java delete mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/RedisServerIntegrationTest.java delete mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/SortedSetsIntegrationTest.java copy geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/{ => pubsub}/DummySubscription.java (93%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/internal/{ => pubsub}/SubscriptionsIntegrationTest.java (97%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{general => key}/ExistsIntegrationTest.java (69%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{general => key}/ExpireAtIntegrationTest.java (98%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{general => key}/ExpireIntegrationTest.java (76%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{RedisLockServiceIntegrationTest.java => key/FlushAllIntegrationTest.java} (61%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{general => key}/PersistIntegrationTest.java (74%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{general => key}/PexpireIntegrationTest.java (97%) create mode 100644 geode-redis/src/integrationTest/java/org/apache/geode/redis/key/ShutdownIntegrationTest.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/Bits.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/CardinalityMergeException.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/HyperLogLog.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/HyperLogLogPlus.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/IBuilder.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/ICardinality.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/MurmurHash.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/internal/hll/RegisterSet.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/DoubleWrapper.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/ExecutionHandlerContext.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/GeoCoder.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/GeoCoord.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/GeoRadiusResponseElement.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/HashArea.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/HashNeighbors.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/KeyHashIdentifier.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/KeyRegistrar.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{serverinitializer => }/NamedThreadFactory.java (96%) delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/RedisDataType.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/RedisLockService.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/RedisLockServiceMBean.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/RegionCreationException.java create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/data/AbstractRedisData.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => data}/ByteArrayWrapper.java (72%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{executor => data}/EmptyRedisHash.java (62%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{executor/set => data}/EmptyRedisSet.java (59%) rename geode-redis/src/{integrationTest/java/org/apache/geode/redis/internal/DummySubscription.java => main/java/org/apache/geode/redis/internal/data/RedisData.java} (56%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{executor/sortedset/ZRevRangeExecutor.java => data/RedisDataType.java} (71%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => data}/RedisDataTypeMismatchException.java (88%) create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisHash.java create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisHashInRegion.java create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisKeyInRegion.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{executor/set => data}/RedisSet.java (61%) create 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/RedisString.java create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/data/RedisStringInRegion.java copy geode-core/src/main/java/org/apache/geode/net/SSLParameterExtension.java => geode-redis/src/main/java/org/apache/geode/redis/internal/delta/AddsDeltaInfo.java (52%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{MemberNotFoundException.java => delta/AppendDeltaInfo.java} (60%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{executor/list/LPopExecutor.java => delta/DeltaInfo.java} (80%) mode change 100755 => 100644 rename geode-redis/src/main/java/org/apache/geode/redis/internal/{executor/list/RPopExecutor.java => delta/DeltaType.java} (80%) mode change 100755 => 100644 copy geode-core/src/main/java/org/apache/geode/net/SSLParameterExtension.java => geode-redis/src/main/java/org/apache/geode/redis/internal/delta/RemsDeltaInfo.java (52%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{AutoCloseableLock.java => delta/TimestampDeltaInfo.java} (63%) delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/DelExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => executor}/Executor.java (64%) delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/ExpirationExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => executor}/Extendable.java (95%) delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/FlushAllExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{org/apache/hadoop/fs => executor}/GlobPattern.java (97%) delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/ListQuery.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisHashInRegion.java create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RedisResponse.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/RenameExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{set => }/SingleResultCollector.java (97%) delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/SortedSetQuery.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{set => }/StripedExecutor.java (84%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{set => }/SynchronizedStripedExecutor.java (71%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{UnkownExecutor.java => UnknownExecutor.java} (83%) mode change 100755 => 100644 delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hash/RedisHash.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hll/HllExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hll/PFAddExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hll/PFCountExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hll/PFMergeExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/hll/Varint.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/AbstractScanExecutor.java (85%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/DBSizeExecutor.java (73%) copy geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ExistsExecutor.java => key/DelExecutor.java} (62%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/ExistsExecutor.java (69%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/ExpireAtExecutor.java (55%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/ExpireExecutor.java (62%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{transactions/DiscardExecutor.java => key/FlushAllExecutor.java} (60%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/KeysExecutor.java (76%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/PExpireAtExecutor.java (94%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/PExpireExecutor.java (94%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/PTTLExecutor.java (94%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/PersistExecutor.java (64%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{list/LPushExecutor.java => key/RedisKeyCommands.java} (63%) mode change 100755 => 100644 create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/key/RedisKeyCommandsFunctionExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{transactions/MultiExecutor.java => key/RenameExecutor.java} (50%) mode change 100755 => 100644 create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/key/RenameFunction.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/ScanExecutor.java (87%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/TTLExecutor.java (55%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => key}/TypeExecutor.java (70%) delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LIndexExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LInsertExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LLenExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LRangeExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LRemExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LSetExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LTrimExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/ListExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/PopExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/PushExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/PushXExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/RPushExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/RPushXExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => server}/AuthExecutor.java (62%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => server}/EchoExecutor.java (81%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => server}/PingExecutor.java (78%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => server}/QuitExecutor.java (65%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => server}/ShutDownExecutor.java (79%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ => server}/TimeExecutor.java (86%) delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/set/RedisSetInRegion.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoAddExecutor.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoDistExecutor.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoHashExecutor.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoPosExecutor.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoRadiusByMemberExecutor.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoRadiusExecutor.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoRadiusParameters.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/GeoSortedSetExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/SortedSetExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZAddExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZCardExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZCountExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZIncrByExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZLexCountExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRangeByLexExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRangeByScoreExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRangeExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRankExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRemExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRemRangeByLexExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRemRangeByRankExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRemRangeByScoreExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRevRankExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZScanExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZScoreExecutor.java copy geode-redis/src/main/java/org/apache/geode/redis/internal/{RedisCommandParserException.java => executor/string/RedisStringCommands.java} (56%) mode change 100755 => 100644 create 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/SetOptions.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/transactions/ExecExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/transactions/TransactionExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/transactions/UnwatchExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/transactions/WatchExecutor.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => netty}/ByteToCommandDecoder.java (99%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => netty}/Client.java (96%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => netty}/Coder.java (69%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => netty}/CoderException.java (95%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => netty}/Command.java (77%) create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/netty/ExecutionHandlerContext.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => netty}/RedisCommandParserException.java (96%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/AbstractSubscription.java (91%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/ChannelSubscription.java (90%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/PatternSubscription.java (88%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/PubSub.java (91%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/PubSubImpl.java (95%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/PublishResult.java (92%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/PublishResultCollector.java (94%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/Subscription.java (94%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/{ => pubsub}/Subscriptions.java (96%) delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/KeyHashIdentifierTest.java delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/RedisLockServiceJUnitTest.java delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/RegionProviderJUnitTest.java create mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/SupportedCommandsJUnitTest.java delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/AbstractExecutorJUnitTest.java rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{UnkownExecutorJUnitTest.java => UnknownExecutorJUnitTest.java} (87%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{ => key}/AbstractScanExecutorJUnitTest.java (96%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{string => key}/DelExecutorJUnitTest.java (69%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{general => key}/ExistsExecutorJUnitTest.java (75%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{general => key}/ExpireAtExecutorJUnitTest.java (93%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{general => key}/ExpireExecutorJUnitTest.java (92%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{general => key}/PExpireAtExecutorJUnitTest.java (93%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{general => key}/PersistExecutorJUnitTest.java (92%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/{general => key}/PexpireExecutorJUnitTest.java (82%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/{ => pubsub}/PubSubImplJUnitTest.java (91%) rename geode-redis/src/test/java/org/apache/geode/redis/internal/{ => pubsub}/SubscriptionsJUnitTest.java (96%) create mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderImplTest.java copy geode-core/src/test/java/org/apache/geode/cache/asyncqueue/internal/SerialAsyncEventQueueImplTest.java => geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderImplTest.java (54%) create mode 100644 geode-web-management/src/distributedTest/java/org/apache/geode/management/client/GetStartingMemberTest.java rename geode-web-management/src/{integrationTest/java/org/apache/geode/management/internal/rest/MemberManagementServiceRestIntegrationTest.java => distributedTest/java/org/apache/geode/management/client/MemberManagementServiceRestDUnitTest.java} (96%)