Repository: geode Updated Branches: refs/heads/feature/GEODE-2444 [created] 2c70249cb
Merge branch 'feature/GEODE-2449' into feature/GEODE-2444 Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/2c70249c Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/2c70249c Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/2c70249c Branch: refs/heads/feature/GEODE-2444 Commit: 2c70249cb44267ecda8bfa40e4ff1d808e4e1b50 Parents: caafea3 2fbdb0c Author: Bruce Schuchardt <bschucha...@trout.gemstone.com> Authored: Wed Feb 15 11:15:49 2017 -0800 Committer: Bruce Schuchardt <bschucha...@trout.gemstone.com> Committed: Wed Feb 15 11:15:49 2017 -0800 ---------------------------------------------------------------------- geode-core/build.gradle | 4 - .../distributed/ConfigurationProperties.java | 14 +- .../internal/DistributionConfig.java | 4 +- .../internal/DistributionConfigImpl.java | 1 - .../geode/internal/cache/GemFireCacheImpl.java | 274 +- .../org/apache/geode/internal/hll/Bits.java | 0 .../internal/hll/CardinalityMergeException.java | 2 - .../apache/geode/internal/hll/HyperLogLog.java | 11 +- .../geode/internal/hll/HyperLogLogPlus.java | 2 - .../org/apache/geode/internal/hll/IBuilder.java | 0 .../apache/geode/internal/hll/ICardinality.java | 0 .../apache/geode/internal/hll/MurmurHash.java | 0 .../apache/geode/internal/hll/RegisterSet.java | 0 .../org/apache/geode/internal/hll/Varint.java | 238 ++ .../domain/FixedPartitionAttributesInfo.java | 1 - .../apache/geode/redis/GeodeRedisServer.java | 729 ----- .../apache/geode/redis/GeodeRedisService.java | 33 + .../geode/redis/internal/ByteArrayWrapper.java | 174 -- .../redis/internal/ByteToCommandDecoder.java | 188 -- .../org/apache/geode/redis/internal/Coder.java | 521 ---- .../apache/geode/redis/internal/Command.java | 145 - .../geode/redis/internal/DoubleWrapper.java | 76 - .../redis/internal/ExecutionHandlerContext.java | 392 --- .../apache/geode/redis/internal/Executor.java | 34 - .../apache/geode/redis/internal/Extendable.java | 31 - .../internal/RedisCommandParserException.java | 42 - .../geode/redis/internal/RedisCommandType.java | 2896 ------------------ .../geode/redis/internal/RedisConstants.java | 308 -- .../geode/redis/internal/RedisDataType.java | 116 - .../RedisDataTypeMismatchException.java | 35 - .../redis/internal/RegionCreationException.java | 37 - .../geode/redis/internal/RegionProvider.java | 567 ---- .../internal/executor/AbstractExecutor.java | 138 - .../internal/executor/AbstractScanExecutor.java | 47 - .../redis/internal/executor/AuthExecutor.java | 54 - .../redis/internal/executor/DBSizeExecutor.java | 29 - .../redis/internal/executor/DelExecutor.java | 53 - .../redis/internal/executor/EchoExecutor.java | 38 - .../redis/internal/executor/ExistsExecutor.java | 47 - .../internal/executor/ExpirationExecutor.java | 39 - .../internal/executor/ExpireAtExecutor.java | 92 - .../redis/internal/executor/ExpireExecutor.java | 92 - .../internal/executor/FlushAllExecutor.java | 47 - .../redis/internal/executor/KeysExecutor.java | 69 - .../redis/internal/executor/ListQuery.java | 64 - .../internal/executor/PExpireAtExecutor.java | 30 - .../internal/executor/PExpireExecutor.java | 30 - .../redis/internal/executor/PTTLExecutor.java | 31 - .../internal/executor/PersistExecutor.java | 51 - .../redis/internal/executor/PingExecutor.java | 30 - .../redis/internal/executor/QuitExecutor.java | 30 - .../redis/internal/executor/ScanExecutor.java | 145 - .../internal/executor/ShutDownExecutor.java | 25 - .../redis/internal/executor/SortedSetQuery.java | 283 -- .../redis/internal/executor/TTLExecutor.java | 75 - .../redis/internal/executor/TimeExecutor.java | 49 - .../redis/internal/executor/TypeExecutor.java | 47 - .../redis/internal/executor/UnkownExecutor.java | 30 - .../internal/executor/hash/HDelExecutor.java | 65 - .../internal/executor/hash/HExistsExecutor.java | 64 - .../internal/executor/hash/HGetAllExecutor.java | 62 - .../internal/executor/hash/HGetExecutor.java | 61 - .../internal/executor/hash/HIncrByExecutor.java | 111 - .../executor/hash/HIncrByFloatExecutor.java | 104 - .../internal/executor/hash/HKeysExecutor.java | 61 - .../internal/executor/hash/HLenExecutor.java | 55 - .../internal/executor/hash/HMGetExecutor.java | 71 - .../internal/executor/hash/HMSetExecutor.java | 61 - .../internal/executor/hash/HScanExecutor.java | 166 - .../internal/executor/hash/HSetExecutor.java | 77 - .../internal/executor/hash/HSetNXExecutor.java | 31 - .../internal/executor/hash/HValsExecutor.java | 60 - .../internal/executor/hash/HashExecutor.java | 40 - .../internal/executor/hll/HllExecutor.java | 37 - .../internal/executor/hll/PFAddExecutor.java | 65 - .../internal/executor/hll/PFCountExecutor.java | 69 - .../internal/executor/hll/PFMergeExecutor.java | 73 - .../redis/internal/executor/hll/Varint.java | 238 -- .../internal/executor/list/LIndexExecutor.java | 118 - .../internal/executor/list/LInsertExecutor.java | 28 - .../internal/executor/list/LLenExecutor.java | 56 - .../internal/executor/list/LPopExecutor.java | 32 - .../internal/executor/list/LPushExecutor.java | 32 - .../internal/executor/list/LPushXExecutor.java | 32 - .../internal/executor/list/LRangeExecutor.java | 113 - .../internal/executor/list/LRemExecutor.java | 115 - .../internal/executor/list/LSetExecutor.java | 108 - .../internal/executor/list/LTrimExecutor.java | 123 - .../internal/executor/list/ListExecutor.java | 141 - .../internal/executor/list/PopExecutor.java | 134 - .../internal/executor/list/PushExecutor.java | 54 - .../internal/executor/list/PushXExecutor.java | 57 - .../internal/executor/list/RPopExecutor.java | 32 - .../internal/executor/list/RPushExecutor.java | 32 - .../internal/executor/list/RPushXExecutor.java | 32 - .../internal/executor/set/SAddExecutor.java | 60 - .../internal/executor/set/SCardExecutor.java | 54 - .../internal/executor/set/SDiffExecutor.java | 45 - .../executor/set/SDiffStoreExecutor.java | 31 - .../internal/executor/set/SInterExecutor.java | 48 - .../executor/set/SInterStoreExecutor.java | 32 - .../executor/set/SIsMemberExecutor.java | 62 - .../internal/executor/set/SMembersExecutor.java | 55 - .../internal/executor/set/SMoveExecutor.java | 74 - .../internal/executor/set/SPopExecutor.java | 60 - .../executor/set/SRandMemberExecutor.java | 101 - .../internal/executor/set/SRemExecutor.java | 62 - .../internal/executor/set/SScanExecutor.java | 157 - .../internal/executor/set/SUnionExecutor.java | 50 - .../executor/set/SUnionStoreExecutor.java | 32 - .../internal/executor/set/SetExecutor.java | 21 - .../internal/executor/set/SetOpExecutor.java | 114 - .../executor/sortedset/SortedSetExecutor.java | 43 - .../executor/sortedset/ZAddExecutor.java | 90 - .../executor/sortedset/ZCardExecutor.java | 53 - .../executor/sortedset/ZCountExecutor.java | 146 - .../executor/sortedset/ZIncrByExecutor.java | 76 - .../executor/sortedset/ZLexCountExecutor.java | 148 - .../executor/sortedset/ZRangeByLexExecutor.java | 221 -- .../sortedset/ZRangeByScoreExecutor.java | 214 -- .../executor/sortedset/ZRangeExecutor.java | 124 - .../executor/sortedset/ZRankExecutor.java | 97 - .../executor/sortedset/ZRemExecutor.java | 62 - .../sortedset/ZRemRangeByLexExecutor.java | 161 - .../sortedset/ZRemRangeByRankExecutor.java | 121 - .../sortedset/ZRemRangeByScoreExecutor.java | 145 - .../sortedset/ZRevRangeByScoreExecutor.java | 31 - .../executor/sortedset/ZRevRangeExecutor.java | 32 - .../executor/sortedset/ZRevRankExecutor.java | 30 - .../executor/sortedset/ZScanExecutor.java | 164 - .../executor/sortedset/ZScoreExecutor.java | 58 - .../executor/string/AppendExecutor.java | 68 - .../executor/string/BitCountExecutor.java | 97 - .../internal/executor/string/BitOpExecutor.java | 154 - .../executor/string/BitPosExecutor.java | 140 - .../executor/string/DecrByExecutor.java | 113 - .../internal/executor/string/DecrExecutor.java | 95 - .../executor/string/GetBitExecutor.java | 80 - .../internal/executor/string/GetExecutor.java | 51 - .../executor/string/GetRangeExecutor.java | 96 - .../executor/string/GetSetExecutor.java | 58 - .../executor/string/IncrByExecutor.java | 108 - .../executor/string/IncrByFloatExecutor.java | 128 - .../internal/executor/string/IncrExecutor.java | 91 - .../internal/executor/string/MGetExecutor.java | 67 - .../internal/executor/string/MSetExecutor.java | 62 - .../executor/string/MSetNXExecutor.java | 86 - .../executor/string/PSetEXExecutor.java | 32 - .../executor/string/SetBitExecutor.java | 108 - .../internal/executor/string/SetEXExecutor.java | 90 - .../internal/executor/string/SetExecutor.java | 155 - .../internal/executor/string/SetNXExecutor.java | 58 - .../executor/string/SetRangeExecutor.java | 96 - .../executor/string/StringExecutor.java | 45 - .../executor/string/StrlenExecutor.java | 56 - .../executor/transactions/DiscardExecutor.java | 40 - .../executor/transactions/ExecExecutor.java | 87 - .../executor/transactions/MultiExecutor.java | 45 - .../transactions/TransactionExecutor.java | 21 - .../executor/transactions/UnwatchExecutor.java | 30 - .../executor/transactions/WatchExecutor.java | 30 - .../org/apache/hadoop/fs/GlobPattern.java | 165 - .../org/apache/geode/redis/AuthJUnitTest.java | 160 - .../apache/geode/redis/ConcurrentStartTest.java | 100 - .../org/apache/geode/redis/HashesJUnitTest.java | 185 -- .../org/apache/geode/redis/ListsJUnitTest.java | 251 -- .../apache/geode/redis/RedisDistDUnitTest.java | 265 -- .../org/apache/geode/redis/RedisServerTest.java | 84 - .../org/apache/geode/redis/SetsJUnitTest.java | 257 -- .../apache/geode/redis/SortedSetsJUnitTest.java | 420 --- .../apache/geode/redis/StringsJunitTest.java | 304 -- .../sanctionedDataSerializables.txt | 8 - geode-redis/build.gradle | 29 + .../apache/geode/redis/GeodeRedisServer.java | 189 ++ .../geode/redis/GeodeRedisServiceImpl.java | 599 ++++ .../geode/redis/internal/ByteArrayWrapper.java | 174 ++ .../redis/internal/ByteToCommandDecoder.java | 188 ++ .../org/apache/geode/redis/internal/Coder.java | 521 ++++ .../apache/geode/redis/internal/Command.java | 145 + .../geode/redis/internal/DoubleWrapper.java | 76 + .../redis/internal/ExecutionHandlerContext.java | 392 +++ .../apache/geode/redis/internal/Executor.java | 34 + .../apache/geode/redis/internal/Extendable.java | 31 + .../internal/RedisCommandParserException.java | 42 + .../geode/redis/internal/RedisCommandType.java | 2896 ++++++++++++++++++ .../geode/redis/internal/RedisConstants.java | 308 ++ .../geode/redis/internal/RedisDataType.java | 116 + .../RedisDataTypeMismatchException.java | 35 + .../redis/internal/RegionCreationException.java | 37 + .../geode/redis/internal/RegionProvider.java | 567 ++++ .../internal/executor/AbstractExecutor.java | 139 + .../internal/executor/AbstractScanExecutor.java | 47 + .../redis/internal/executor/AuthExecutor.java | 54 + .../redis/internal/executor/DBSizeExecutor.java | 29 + .../redis/internal/executor/DelExecutor.java | 53 + .../redis/internal/executor/EchoExecutor.java | 38 + .../redis/internal/executor/ExistsExecutor.java | 47 + .../internal/executor/ExpirationExecutor.java | 39 + .../internal/executor/ExpireAtExecutor.java | 92 + .../redis/internal/executor/ExpireExecutor.java | 92 + .../internal/executor/FlushAllExecutor.java | 47 + .../redis/internal/executor/KeysExecutor.java | 69 + .../redis/internal/executor/ListQuery.java | 64 + .../internal/executor/PExpireAtExecutor.java | 30 + .../internal/executor/PExpireExecutor.java | 30 + .../redis/internal/executor/PTTLExecutor.java | 31 + .../internal/executor/PersistExecutor.java | 51 + .../redis/internal/executor/PingExecutor.java | 30 + .../redis/internal/executor/QuitExecutor.java | 30 + .../redis/internal/executor/ScanExecutor.java | 146 + .../internal/executor/ShutDownExecutor.java | 25 + .../redis/internal/executor/SortedSetQuery.java | 283 ++ .../redis/internal/executor/TTLExecutor.java | 75 + .../redis/internal/executor/TimeExecutor.java | 48 + .../redis/internal/executor/TypeExecutor.java | 47 + .../redis/internal/executor/UnkownExecutor.java | 30 + .../internal/executor/hash/HDelExecutor.java | 65 + .../internal/executor/hash/HExistsExecutor.java | 64 + .../internal/executor/hash/HGetAllExecutor.java | 62 + .../internal/executor/hash/HGetExecutor.java | 61 + .../internal/executor/hash/HIncrByExecutor.java | 111 + .../executor/hash/HIncrByFloatExecutor.java | 104 + .../internal/executor/hash/HKeysExecutor.java | 61 + .../internal/executor/hash/HLenExecutor.java | 55 + .../internal/executor/hash/HMGetExecutor.java | 71 + .../internal/executor/hash/HMSetExecutor.java | 61 + .../internal/executor/hash/HScanExecutor.java | 166 + .../internal/executor/hash/HSetExecutor.java | 77 + .../internal/executor/hash/HSetNXExecutor.java | 31 + .../internal/executor/hash/HValsExecutor.java | 60 + .../internal/executor/hash/HashExecutor.java | 40 + .../internal/executor/hll/HllExecutor.java | 33 + .../internal/executor/hll/PFAddExecutor.java | 67 + .../internal/executor/hll/PFCountExecutor.java | 69 + .../internal/executor/hll/PFMergeExecutor.java | 75 + .../internal/executor/list/LIndexExecutor.java | 118 + .../internal/executor/list/LInsertExecutor.java | 28 + .../internal/executor/list/LLenExecutor.java | 56 + .../internal/executor/list/LPopExecutor.java | 32 + .../internal/executor/list/LPushExecutor.java | 32 + .../internal/executor/list/LPushXExecutor.java | 32 + .../internal/executor/list/LRangeExecutor.java | 113 + .../internal/executor/list/LRemExecutor.java | 115 + .../internal/executor/list/LSetExecutor.java | 108 + .../internal/executor/list/LTrimExecutor.java | 123 + .../internal/executor/list/ListExecutor.java | 141 + .../internal/executor/list/PopExecutor.java | 133 + .../internal/executor/list/PushExecutor.java | 54 + .../internal/executor/list/PushXExecutor.java | 57 + .../internal/executor/list/RPopExecutor.java | 32 + .../internal/executor/list/RPushExecutor.java | 32 + .../internal/executor/list/RPushXExecutor.java | 32 + .../internal/executor/set/SAddExecutor.java | 60 + .../internal/executor/set/SCardExecutor.java | 54 + .../internal/executor/set/SDiffExecutor.java | 45 + .../executor/set/SDiffStoreExecutor.java | 31 + .../internal/executor/set/SInterExecutor.java | 48 + .../executor/set/SInterStoreExecutor.java | 32 + .../executor/set/SIsMemberExecutor.java | 62 + .../internal/executor/set/SMembersExecutor.java | 55 + .../internal/executor/set/SMoveExecutor.java | 74 + .../internal/executor/set/SPopExecutor.java | 60 + .../executor/set/SRandMemberExecutor.java | 101 + .../internal/executor/set/SRemExecutor.java | 62 + .../internal/executor/set/SScanExecutor.java | 157 + .../internal/executor/set/SUnionExecutor.java | 50 + .../executor/set/SUnionStoreExecutor.java | 32 + .../internal/executor/set/SetExecutor.java | 21 + .../internal/executor/set/SetOpExecutor.java | 114 + .../executor/sortedset/SortedSetExecutor.java | 43 + .../executor/sortedset/ZAddExecutor.java | 90 + .../executor/sortedset/ZCardExecutor.java | 53 + .../executor/sortedset/ZCountExecutor.java | 146 + .../executor/sortedset/ZIncrByExecutor.java | 76 + .../executor/sortedset/ZLexCountExecutor.java | 148 + .../executor/sortedset/ZRangeByLexExecutor.java | 220 ++ .../sortedset/ZRangeByScoreExecutor.java | 214 ++ .../executor/sortedset/ZRangeExecutor.java | 124 + .../executor/sortedset/ZRankExecutor.java | 97 + .../executor/sortedset/ZRemExecutor.java | 62 + .../sortedset/ZRemRangeByLexExecutor.java | 161 + .../sortedset/ZRemRangeByRankExecutor.java | 121 + .../sortedset/ZRemRangeByScoreExecutor.java | 145 + .../sortedset/ZRevRangeByScoreExecutor.java | 31 + .../executor/sortedset/ZRevRangeExecutor.java | 32 + .../executor/sortedset/ZRevRankExecutor.java | 30 + .../executor/sortedset/ZScanExecutor.java | 164 + .../executor/sortedset/ZScoreExecutor.java | 58 + .../executor/string/AppendExecutor.java | 68 + .../executor/string/BitCountExecutor.java | 97 + .../internal/executor/string/BitOpExecutor.java | 154 + .../executor/string/BitPosExecutor.java | 140 + .../executor/string/DecrByExecutor.java | 113 + .../internal/executor/string/DecrExecutor.java | 95 + .../executor/string/GetBitExecutor.java | 80 + .../internal/executor/string/GetExecutor.java | 51 + .../executor/string/GetRangeExecutor.java | 96 + .../executor/string/GetSetExecutor.java | 58 + .../executor/string/IncrByExecutor.java | 108 + .../executor/string/IncrByFloatExecutor.java | 128 + .../internal/executor/string/IncrExecutor.java | 91 + .../internal/executor/string/MGetExecutor.java | 67 + .../internal/executor/string/MSetExecutor.java | 62 + .../executor/string/MSetNXExecutor.java | 86 + .../executor/string/PSetEXExecutor.java | 32 + .../executor/string/SetBitExecutor.java | 108 + .../internal/executor/string/SetEXExecutor.java | 90 + .../internal/executor/string/SetExecutor.java | 155 + .../internal/executor/string/SetNXExecutor.java | 58 + .../executor/string/SetRangeExecutor.java | 96 + .../executor/string/StringExecutor.java | 45 + .../executor/string/StrlenExecutor.java | 56 + .../executor/transactions/DiscardExecutor.java | 40 + .../executor/transactions/ExecExecutor.java | 86 + .../executor/transactions/MultiExecutor.java | 45 + .../transactions/TransactionExecutor.java | 21 + .../executor/transactions/UnwatchExecutor.java | 30 + .../executor/transactions/WatchExecutor.java | 30 + .../org/apache/hadoop/fs/GlobPattern.java | 165 + ...org.apache.geode.internal.cache.CacheService | 1 + .../org/apache/geode/redis/AuthJUnitTest.java | 120 + .../apache/geode/redis/ConcurrentStartTest.java | 99 + .../org/apache/geode/redis/HashesJUnitTest.java | 147 + .../org/apache/geode/redis/ListsJUnitTest.java | 212 ++ .../apache/geode/redis/RedisDistDUnitTest.java | 266 ++ .../org/apache/geode/redis/RedisServerTest.java | 54 + .../org/apache/geode/redis/RedisTestBase.java | 101 + .../org/apache/geode/redis/SetsJUnitTest.java | 194 ++ .../apache/geode/redis/SortedSetsJUnitTest.java | 417 +++ .../apache/geode/redis/StringsJunitTest.java | 287 ++ gradle/dependency-versions.properties | 2 +- settings.gradle | 2 + 332 files changed, 18580 insertions(+), 18572 deletions(-) ----------------------------------------------------------------------
