This is an automated email from the ASF dual-hosted git repository. bschuchardt pushed a change to branch feature/GEODE-8144 in repository https://gitbox.apache.org/repos/asf/geode.git.
omit 6dc29fd sanction used of getCanonicalHostName() in SocketCreator omit 3b4c6a7 removed test shell script omit 2682745 modified SocketCreator to look for a hostname if one is not present and endpoint verification is enabled omit 88e7fd9 GEODE-8144: endpoint identification in servers is not working 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) new 9ffff89 modified SocketCreator to look for a hostname if one is not present and endpoint verification is enabled new 0b53d73 removed test shell script 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 (6dc29fd) \ N -- N -- N refs/heads/feature/GEODE-8144 (0b53d73) 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 | 18 +- .../gradle/plugins/DependencyConstraints.groovy | 5 +- ci/images/alpine-tools/Dockerfile | 22 +- ci/pipelines/meta/jinja.template.yml | 1 + .../integrationTest/resources/assembly_content.txt | 2 +- .../resources/dependency_classpath.txt | 2 +- geode-assembly/src/main/dist/LICENSE | 2 +- .../apache/geode/util/internal/UncheckedUtils.java | 25 +- .../geode/util/internal/UncheckedUtilsTest.java | 60 + .../cache/PartitionedRegionSingleHopDUnitTest.java | 14 +- ...istributedRegionFunctionExecutionDUnitTest.java | 59 +- ...oningWithColocationAndPersistenceDUnitTest.java | 12 +- .../FunctionExecutionOnLonerRegressionTest.java | 27 +- ...elGatewaySenderFlushedCoordinatorJUnitTest.java | 2 +- .../codeAnalysis/sanctionedDataSerializables.txt | 8 +- .../internal/ra/spi/JCAManagedConnection.java | 33 +- .../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 | 56 +- .../internal/DistributionConfigImpl.java | 34 +- .../geode/internal/cache/BucketRegionQueue.java | 31 + .../geode/internal/cache/ColocationHelper.java | 3 +- .../geode/internal/cache/GemFireCacheImpl.java | 49 +- .../cache/InternalCacheForClientAccess.java | 6 +- .../geode/internal/cache/InternalRegion.java | 3 + .../apache/geode/internal/cache/LocalRegion.java | 24 +- .../geode/internal/cache/TXCommitMessage.java | 29 +- .../cache/TXLastEventInTransactionUtils.java | 120 ++ .../org/apache/geode/internal/cache/TXState.java | 24 +- .../cache/execute/util/TypedFunctionService.java | 32 +- .../tier/sockets/CacheClientProxyFactory.java | 4 +- .../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 | 249 ++- ...oncurrentSerialGatewaySenderEventProcessor.java | 24 +- .../serial/SerialGatewaySenderEventProcessor.java | 19 +- .../cache/wan/serial/SerialGatewaySenderQueue.java | 240 ++- .../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 + .../xmlcache/SerialAsyncEventQueueCreation.java | 3 + .../xmlcache/SerialGatewaySenderCreation.java | 3 + .../org/apache/geode/internal/tcp/Connection.java | 20 +- .../geode/management/GatewaySenderMXBean.java | 11 + .../internal/beans/GatewaySenderMBean.java | 10 + .../internal/beans/GatewaySenderMBeanBridge.java | 9 + .../geode/management/internal/i18n/CliStrings.java | 25 +- .../internal/operation/OperationManager.java | 17 +- .../internal/operation/OperationPerformer.java | 22 +- .../operation/RebalanceOperationPerformer.java | 15 +- .../geode.apache.org/schema/cache/cache-1.0.xsd | 1 + .../internal/ClusterAlertMessagingTest.java | 6 +- .../internal/ParallelAsyncEventQueueImplTest.java | 97 + .../internal/SerialAsyncEventQueueImplTest.java | 31 +- .../internal/DistributionConfigJUnitTest.java | 4 +- .../internal/cache/BucketRegionQueueJUnitTest.java | 77 + .../cache/TXLastEventInTransactionUtilsTest.java | 196 ++ ...entParallelGatewaySenderEventProcessorTest.java | 4 +- .../ParallelGatewaySenderEventProcessorTest.java | 5 +- .../wan/parallel/ParallelGatewaySenderHelper.java | 6 +- .../ParallelGatewaySenderQueueJUnitTest.java | 192 +- ...SerialGatewaySenderEventProcessorJUnitTest.java | 2 +- ...SerialGatewaySenderEventProcessorJUnitTest.java | 4 +- .../serial/SerialGatewaySenderQueueJUnitTest.java | 251 +++ .../TestSerialGatewaySenderEventProcessor.java | 6 +- .../apache/geode/internal/tcp/TCPConduitTest.java | 4 +- .../beans/GatewaySenderMBeanBridgeTest.java | 94 + .../internal/beans/GatewaySenderMBeanTest.java | 37 +- .../internal/operation/OperationManagerTest.java | 26 +- .../operation/RebalanceOperationPerformerTest.java | 15 +- .../running/cluster-management-service.html.md.erb | 114 +- geode-docs/reference/topics/cache_xml.html.md.erb | 7 + .../topics/gemfire_properties.html.md.erb | 26 + .../gfsh/command-pages/create.html.md.erb | 15 +- .../gfsh/command-pages/query.html.md.erb | 13 +- .../gfsh/command-pages/start.html.md.erb | 15 +- .../tools_modules/redis_api_for_geode.html.md.erb | 12 +- .../setting_up_a_multisite_system.html.md.erb | 33 + .../multisite_overview.html.md.erb | 7 + .../cli/commands/QueryCommandDUnitTestBase.java | 42 + .../commands/QueryCommandIntegrationTestBase.java | 2 +- .../cli/commands/CreateGatewaySenderCommand.java | 20 +- .../internal/cli/commands/QueryCommand.java | 29 +- .../internal/cli/commands/RebalanceCommand.java | 2 +- .../cli/commands/StartGatewaySenderCommand.java | 13 +- .../internal/cli/commands/StartServerCommand.java | 11 + .../cli/functions/GatewaySenderCreateFunction.java | 5 + .../cli/functions/GatewaySenderFunctionArgs.java | 6 + .../sanctioned-geode-gfsh-serializables.txt | 3 +- .../commands/CreateGatewaySenderCommandTest.java | 25 +- .../internal/cli/commands/QueryCommandTest.java | 76 + .../java/org/apache/geode/test/fake/Fakes.java | 3 + .../src/test/script/update-management-wiki.sh | 18 +- geode-membership/build.gradle | 17 +- .../src/integrationTest/resources/log4j2.xml | 2 +- .../geode/redis/GeoNativeRedisAcceptanceTest.java | 85 - .../redis/RenameNativeRedisAcceptanceTest.java | 74 - .../redis/SortedSetNativeRedisAcceptanceTest.java | 47 - .../redis/StringsNativeRedisAcceptanceTest.java | 5 - .../geode/redis/ConcurrentLoopingThreads.java | 29 +- .../apache/geode/redis/GeodeRedisServerRule.java | 2 +- .../redis/GeodeRedisServerStartupDUnitTest.java | 13 +- .../org/apache/geode/redis/PubSubDUnitTest.java | 5 + .../org/apache/geode/redis/RedisDistDUnitTest.java | 68 +- .../geode/redis/executors/ExpireDUnitTest.java | 4 + .../geode/redis/executors/hash/HMsetDUnitTest.java | 4 + .../geode/redis/executors/hash/HsetDUnitTest.java | 4 + .../redis/executors/keys/ExistsDUnitTest.java | 1 + .../redis/executors/keys/PersistDUnitTest.java | 1 + .../geode/redis/executors/set/SaddDUnitTest.java | 4 + .../geode/redis/executors/set/SremDUnitTest.java | 4 + .../redis/executors/string/StringsDUnitTest.java | 281 +++ .../geode/redis/session/SessionDUnitTest.java | 1 + .../config/SessionListener.java | 9 +- .../redis/CommandPipeliningIntegrationTest.java | 101 ++ .../redis/ConcurrentStartIntegrationTest.java | 2 +- .../org/apache/geode/redis/GeoIntegrationTest.java | 405 ----- .../apache/geode/redis/HashesIntegrationTest.java | 152 +- .../apache/geode/redis/ListsIntegrationTest.java | 235 --- .../geode/redis/RedisServerIntegrationTest.java | 87 - .../apache/geode/redis/RenameIntegrationTest.java | 20 - .../java/org/apache/geode/redis/SSLTest.java | 1 + .../geode/redis/SortedSetsIntegrationTest.java | 415 ----- .../apache/geode/redis/StringsIntegrationTest.java | 102 +- .../geode/redis/general/ExistsIntegrationTest.java | 90 - .../geode/redis/general/ExpireIntegrationTest.java | 89 +- .../redis/general/FlushAllIntegrationTest.java} | 42 +- .../redis/general/PersistIntegrationTest.java | 51 - .../internal/SubscriptionsIntegrationTest.java | 6 - .../apache/geode/codeAnalysis/excludedClasses.txt | 9 - .../codeAnalysis/sanctionedDataSerializables.txt | 3 + .../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 -- .../org/apache/geode/redis/internal/Coder.java | 165 -- .../org/apache/geode/redis/internal/Command.java | 25 +- .../apache/geode/redis/internal/DoubleWrapper.java | 77 - .../redis/internal/ExecutionHandlerContext.java | 246 +-- .../org/apache/geode/redis/internal/Executor.java | 15 +- .../org/apache/geode/redis/internal/GeoCoder.java | 217 --- .../redis/internal/GeoRadiusResponseElement.java | 68 - .../geode/redis/internal/GeodeRedisServer.java | 179 +- .../geode/redis/internal/GeodeRedisService.java | 9 +- .../org/apache/geode/redis/internal/HashArea.java | 30 - .../apache/geode/redis/internal/HashNeighbors.java | 41 - .../apache/geode/redis/internal/KeyRegistrar.java | 48 +- .../geode/redis/internal/RedisCommandType.java | 138 +- .../geode/redis/internal/RedisConstants.java | 102 -- .../apache/geode/redis/internal/RedisDataType.java | 111 +- .../apache/geode/redis/internal/RedisResponse.java | 93 + .../geode/redis/internal/RegionProvider.java | 426 +---- .../redis/internal/executor/AbstractExecutor.java | 62 +- .../internal/executor/AbstractScanExecutor.java | 2 +- .../redis/internal/executor/AuthExecutor.java | 18 +- .../redis/internal/executor/CommandFunction.java | 141 +- .../geode/redis/internal/executor/DelExecutor.java | 30 +- .../redis/internal/executor/EmptyRedisHash.java | 40 +- .../redis/internal/executor/ExistsExecutor.java | 9 +- .../redis/internal/executor/FlushAllExecutor.java | 16 +- .../redis/internal/executor/KeysExecutor.java | 6 - .../geode/redis/internal/executor/ListQuery.java | 71 - .../redis/internal/executor/QuitExecutor.java | 8 +- .../redis/internal/executor/RedisHashInRegion.java | 63 + .../RPushExecutor.java => RedisKeyCommands.java} | 11 +- ....java => RedisKeyCommandsFunctionExecutor.java} | 37 +- .../{ExistsExecutor.java => RedisKeyInRegion.java} | 47 +- .../redis/internal/executor/RenameExecutor.java | 7 +- .../redis/internal/executor/ScanExecutor.java | 6 - .../executor/SingleResultRedisFunction.java | 2 + .../redis/internal/executor/SortedSetQuery.java | 335 ---- .../redis/internal/executor/hash/HDelExecutor.java | 11 +- .../internal/executor/hash/HExistsExecutor.java | 19 +- .../internal/executor/hash/HGetAllExecutor.java | 18 +- .../redis/internal/executor/hash/HGetExecutor.java | 26 +- .../internal/executor/hash/HIncrByExecutor.java | 89 +- .../executor/hash/HIncrByFloatExecutor.java | 82 +- .../internal/executor/hash/HKeysExecutor.java | 17 +- .../redis/internal/executor/hash/HLenExecutor.java | 11 +- .../internal/executor/hash/HMGetExecutor.java | 29 +- .../internal/executor/hash/HMSetExecutor.java | 11 +- .../internal/executor/hash/HScanExecutor.java | 86 +- .../redis/internal/executor/hash/HSetExecutor.java | 10 +- .../internal/executor/hash/HValsExecutor.java | 17 +- .../redis/internal/executor/hash/HashExecutor.java | 71 +- .../redis/internal/executor/hash/RedisHash.java | 167 +- .../internal/executor/hash/RedisHashCommands.java | 19 + .../hash/RedisHashCommandsFunctionExecutor.java | 56 + .../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 --- .../internal/executor/list/LIndexExecutor.java | 114 -- .../internal/executor/list/LInsertExecutor.java | 28 - .../redis/internal/executor/list/LLenExecutor.java | 45 - .../redis/internal/executor/list/LPopExecutor.java | 25 - .../internal/executor/list/LPushExecutor.java | 27 - .../internal/executor/list/LPushXExecutor.java | 24 - .../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 - .../redis/internal/executor/list/RPopExecutor.java | 26 - .../internal/executor/list/RPushXExecutor.java | 23 - .../internal/executor/pubsub/PublishExecutor.java | 37 +- .../redis/internal/executor/set/EmptyRedisSet.java | 21 +- .../redis/internal/executor/set/RedisSet.java | 25 +- .../internal/executor/set/RedisSetCommands.java | 6 + .../set/RedisSetCommandsFunctionExecutor.java | 18 + .../internal/executor/set/RedisSetInRegion.java | 145 ++ .../redis/internal/executor/set/SAddExecutor.java | 10 +- .../redis/internal/executor/set/SCardExecutor.java | 13 +- .../redis/internal/executor/set/SDiffExecutor.java | 19 +- .../internal/executor/set/SInterExecutor.java | 19 +- .../internal/executor/set/SIsMemberExecutor.java | 18 +- .../internal/executor/set/SMembersExecutor.java | 17 +- .../redis/internal/executor/set/SMoveExecutor.java | 72 +- .../redis/internal/executor/set/SPopExecutor.java | 28 +- .../internal/executor/set/SRandMemberExecutor.java | 38 +- .../redis/internal/executor/set/SRemExecutor.java | 14 +- .../redis/internal/executor/set/SScanExecutor.java | 30 +- .../internal/executor/set/SUnionExecutor.java | 12 +- .../redis/internal/executor/set/SetExecutor.java | 30 +- .../redis/internal/executor/set/SetOpExecutor.java | 113 +- .../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 -- .../sortedset/ZRevRangeByScoreExecutor.java | 31 - .../executor/sortedset/ZRevRangeExecutor.java | 32 - .../executor/sortedset/ZRevRankExecutor.java | 30 - .../internal/executor/sortedset/ZScanExecutor.java | 165 -- .../executor/sortedset/ZScoreExecutor.java | 57 - .../internal/executor/string/AppendExecutor.java | 39 +- .../internal/executor/string/BitCountExecutor.java | 6 +- .../internal/executor/string/BitOpExecutor.java | 22 +- .../internal/executor/string/BitPosExecutor.java | 6 +- .../internal/executor/string/DecrByExecutor.java | 14 +- .../internal/executor/string/DecrExecutor.java | 17 +- .../internal/executor/string/GetBitExecutor.java | 8 +- .../internal/executor/string/GetExecutor.java | 27 +- .../internal/executor/string/GetRangeExecutor.java | 8 +- .../internal/executor/string/GetSetExecutor.java | 12 +- .../internal/executor/string/IncrByExecutor.java | 12 +- .../executor/string/IncrByFloatExecutor.java | 13 +- .../internal/executor/string/IncrExecutor.java | 13 +- .../internal/executor/string/MGetExecutor.java | 16 +- .../internal/executor/string/MSetExecutor.java | 10 +- .../internal/executor/string/MSetNXExecutor.java | 9 +- .../internal/executor/string/RedisString.java | 135 ++ .../executor/string/RedisStringCommands.java | 16 +- .../RedisStringCommandsFunctionExecutor.java | 47 + .../executor/string/RedisStringInRegion.java | 74 + .../internal/executor/string/SetBitExecutor.java | 14 +- .../internal/executor/string/SetEXExecutor.java | 5 +- .../internal/executor/string/SetExecutor.java | 211 +-- .../internal/executor/string/SetNXExecutor.java | 6 +- .../redis/internal/executor/string/SetOptions.java | 81 + .../internal/executor/string/SetRangeExecutor.java | 26 +- .../internal/executor/string/StrlenExecutor.java | 8 +- .../executor/transactions/DiscardExecutor.java | 40 - .../executor/transactions/ExecExecutor.java | 88 - .../executor/transactions/MultiExecutor.java | 45 - .../executor/transactions/TransactionExecutor.java | 21 - .../executor/transactions/UnwatchExecutor.java | 30 - .../executor/transactions/WatchExecutor.java | 30 - .../sanctioned-geode-redis-serializables.txt | 77 +- .../internal/ExecutionHandlerContextJUnitTest.java | 2 +- .../geode/redis/internal/PubSubImplJUnitTest.java | 3 +- .../redis/internal/RegionProviderJUnitTest.java | 103 -- .../executor/AbstractExecutorJUnitTest.java | 13 +- .../executor/general/ExistsExecutorJUnitTest.java | 13 +- .../executor/string/DelExecutorJUnitTest.java | 14 +- .../executor/string/GetSetExecutorJUnitTest.java | 3 +- .../string/StringGetExecutorJUnitTest.java | 53 +- .../string/StringSetExecutorJUnitTest.java | 165 +- .../geode/internal/cache/wan/WANTestBase.java | 179 +- ...ParallelGatewaySenderOperation_1_DUnitTest.java | 8 + ...ParallelGatewaySenderOperation_2_DUnitTest.java | 2 + .../cache/wan/disttx/DistTXWANDUnitTest.java | 2 + ...ANPersistenceEnabledGatewaySenderDUnitTest.java | 291 +++ .../wan/parallel/ParallelWANStatsDUnitTest.java | 663 +++++-- ...rialGatewaySenderOperationsDistributedTest.java | 10 +- ...ANPersistenceEnabledGatewaySenderDUnitTest.java | 148 ++ .../cache/wan/serial/SerialWANStatsDUnitTest.java | 383 +++- ...CreateDestroyGatewaySenderCommandDUnitTest.java | 13 +- .../StartGatewaySenderCommandDUnitTest.java | 97 + .../cache/wan/wancommand/WANCommandUtils.java | 6 +- .../cache/wan/misc/WANConfigurationJUnitTest.java | 21 +- .../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 +- 339 files changed, 7008 insertions(+), 13796 deletions(-) rename geode-redis/src/main/java/org/apache/geode/redis/internal/RegionCreationException.java => geode-common/src/main/java/org/apache/geode/util/internal/UncheckedUtils.java (61%) create mode 100644 geode-common/src/test/java/org/apache/geode/util/internal/UncheckedUtilsTest.java create mode 100644 geode-core/src/main/java/org/apache/geode/internal/cache/TXLastEventInTransactionUtils.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/MemberNotFoundException.java => geode-core/src/main/java/org/apache/geode/internal/cache/execute/util/TypedFunctionService.java (54%) rename geode-redis/src/main/java/org/apache/geode/redis/internal/GeoCoord.java => geode-core/src/main/java/org/apache/geode/management/internal/operation/OperationPerformer.java (68%) 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-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 100644 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/distributedTest/java/org/apache/geode/redis/executors/string/StringsDUnitTest.java 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 rename geode-redis/src/{acceptanceTest/java/org/apache/geode/redis/ListsNativeRedisAcceptanceTest.java => integrationTest/java/org/apache/geode/redis/general/FlushAllIntegrationTest.java} (53%) mode change 100755 => 100644 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/GeoCoder.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 create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/RedisResponse.java delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/ListQuery.java rename geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{list/RPushExecutor.java => RedisKeyCommands.java} (78%) mode change 100755 => 100644 copy geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{set/SInterExecutor.java => RedisKeyCommandsFunctionExecutor.java} (54%) mode change 100755 => 100644 copy geode-redis/src/main/java/org/apache/geode/redis/internal/executor/{ExistsExecutor.java => RedisKeyInRegion.java} (50%) mode change 100755 => 100644 delete mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/SortedSetQuery.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 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/LPopExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LPushExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/LPushXExecutor.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/RPopExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/list/RPushXExecutor.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/ZRevRangeByScoreExecutor.java delete mode 100755 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/sortedset/ZRevRangeExecutor.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 create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/RedisString.java rename geode-core/src/main/java/org/apache/geode/internal/cache/util/UncheckedUtils.java => geode-redis/src/main/java/org/apache/geode/redis/internal/executor/string/RedisStringCommands.java (69%) 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/RedisStringInRegion.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/DiscardExecutor.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/MultiExecutor.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 delete mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/RegionProviderJUnitTest.java 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%)