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%)
