This is an automated email from the ASF dual-hosted git repository. jensdeppe pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git.
from c841359 GEODE-7727: modify sender thread to detect relese of connection (#4751) add 0c06008 GEODE-7828: Convert backing store for Redis Hashes and Sets to single regions (#4781) No new revisions were added by this update. Summary of changes: geode-redis/build.gradle | 3 - ... AnalyzeRedisSerializablesIntegrationTest.java} | 2 +- ...AuthJUnitTest.java => AuthIntegrationTest.java} | 2 +- ...st.java => ConcurrentStartIntegrationTest.java} | 2 +- ...CoderTest.java => GeoCoderIntegrationTest.java} | 2 +- .../{GeoJUnitTest.java => GeoIntegrationTest.java} | 13 +- .../apache/geode/redis/HashesIntegrationTest.java | 769 +++++++++++++++++++++ .../org/apache/geode/redis/HashesJUnitTest.java | 188 ----- ...stsJUnitTest.java => ListsIntegrationTest.java} | 8 +- ...{PubSubTest.java => PubSubIntegrationTest.java} | 2 +- .../geode/redis/RedisServerIntegrationTest.java | 4 +- ... => SetCommandNegativeCaseIntegrationTest.java} | 2 +- .../apache/geode/redis/SetsIntegrationTest.java | 756 ++++++++++++++++++++ .../java/org/apache/geode/redis/SetsJUnitTest.java | 243 ------- ...nitTest.java => SortedSetsIntegrationTest.java} | 2 +- ...sJunitTest.java => StringsIntegrationTest.java} | 2 +- .../java/org/apache/geode/internal/hll/Bits.java | 3 +- .../internal/hll/CardinalityMergeException.java | 1 - .../org/apache/geode/internal/hll/HyperLogLog.java | 9 +- .../apache/geode/internal/hll/HyperLogLogPlus.java | 3 +- .../org/apache/geode/redis/GeodeRedisServer.java | 46 +- .../{Extendable.java => AutoCloseableLock.java} | 25 +- .../geode/redis/internal/ByteArrayWrapper.java | 25 +- .../geode/redis/internal/ByteToCommandDecoder.java | 58 +- .../org/apache/geode/redis/internal/Coder.java | 5 + .../org/apache/geode/redis/internal/Command.java | 27 +- .../apache/geode/redis/internal/DoubleWrapper.java | 15 +- .../redis/internal/ExecutionHandlerContext.java | 71 +- .../org/apache/geode/redis/internal/Executor.java | 2 - .../apache/geode/redis/internal/Extendable.java | 2 - .../org/apache/geode/redis/internal/GeoCoder.java | 3 +- .../geode/redis/internal/GeodeRedisService.java | 3 +- .../apache/geode/redis/internal/KeyRegistrar.java | 5 +- .../internal/RedisCommandParserException.java | 2 - .../geode/redis/internal/RedisCommandType.java | 7 +- .../geode/redis/internal/RedisConstants.java | 2 +- .../apache/geode/redis/internal/RedisDataType.java | 5 +- .../internal/RedisDataTypeMismatchException.java | 2 - .../geode/redis/internal/RedisLockService.java | 93 +++ .../redis/internal/RegionCreationException.java | 6 +- .../geode/redis/internal/RegionProvider.java | 113 ++- .../redis/internal/executor/AbstractExecutor.java | 42 +- .../geode/redis/internal/executor/DelExecutor.java | 6 +- .../redis/internal/executor/ExistsExecutor.java | 5 +- .../redis/internal/executor/ExpireAtExecutor.java | 13 +- .../redis/internal/executor/ExpireExecutor.java | 14 +- .../redis/internal/executor/FlushAllExecutor.java | 3 +- .../redis/internal/executor/KeysExecutor.java | 8 +- .../redis/internal/executor/PersistExecutor.java | 5 +- .../redis/internal/executor/ScanExecutor.java | 12 +- .../geode/redis/internal/executor/TTLExecutor.java | 6 +- .../redis/internal/executor/TypeExecutor.java | 5 +- .../redis/internal/executor/UnkownExecutor.java | 23 +- .../redis/internal/executor/hash/HDelExecutor.java | 60 +- .../internal/executor/hash/HExistsExecutor.java | 58 +- .../internal/executor/hash/HGetAllExecutor.java | 57 +- .../redis/internal/executor/hash/HGetExecutor.java | 42 +- .../internal/executor/hash/HIncrByExecutor.java | 120 ++-- .../executor/hash/HIncrByFloatExecutor.java | 102 ++- .../internal/executor/hash/HKeysExecutor.java | 45 +- .../redis/internal/executor/hash/HLenExecutor.java | 43 +- .../internal/executor/hash/HMGetExecutor.java | 31 +- .../internal/executor/hash/HMSetExecutor.java | 59 +- .../internal/executor/hash/HScanExecutor.java | 29 +- .../redis/internal/executor/hash/HSetExecutor.java | 80 ++- .../internal/executor/hash/HSetNXExecutor.java | 18 +- .../internal/executor/hash/HValsExecutor.java | 33 +- .../redis/internal/executor/hash/HashExecutor.java | 64 +- .../redis/internal/executor/hll/PFAddExecutor.java | 11 +- .../internal/executor/hll/PFCountExecutor.java | 3 +- .../internal/executor/hll/PFMergeExecutor.java | 6 +- .../geode/redis/internal/executor/hll/Varint.java | 4 +- .../internal/executor/list/LIndexExecutor.java | 9 +- .../internal/executor/list/LRangeExecutor.java | 8 +- .../redis/internal/executor/list/LRemExecutor.java | 5 +- .../redis/internal/executor/list/LSetExecutor.java | 7 +- .../internal/executor/list/LTrimExecutor.java | 4 +- .../redis/internal/executor/list/ListExecutor.java | 22 +- .../redis/internal/executor/list/PopExecutor.java | 12 +- .../redis/internal/executor/set/SAddExecutor.java | 50 +- .../redis/internal/executor/set/SCardExecutor.java | 14 +- .../redis/internal/executor/set/SDiffExecutor.java | 12 +- .../internal/executor/set/SInterExecutor.java | 12 +- .../internal/executor/set/SIsMemberExecutor.java | 29 +- .../internal/executor/set/SMembersExecutor.java | 41 +- .../redis/internal/executor/set/SMoveExecutor.java | 95 ++- .../redis/internal/executor/set/SPopExecutor.java | 80 ++- .../internal/executor/set/SRandMemberExecutor.java | 104 +-- .../redis/internal/executor/set/SRemExecutor.java | 41 +- .../redis/internal/executor/set/SScanExecutor.java | 27 +- .../internal/executor/set/SUnionExecutor.java | 6 +- .../redis/internal/executor/set/SetExecutor.java | 25 + .../redis/internal/executor/set/SetOpExecutor.java | 99 +-- .../executor/sortedset/GeoAddExecutor.java | 3 +- .../executor/sortedset/GeoRadiusExecutor.java | 3 +- .../executor/sortedset/GeoRadiusParameters.java | 19 +- .../internal/executor/sortedset/ZAddExecutor.java | 3 +- .../internal/executor/sortedset/ZCardExecutor.java | 7 +- .../executor/sortedset/ZCountExecutor.java | 14 +- .../executor/sortedset/ZLexCountExecutor.java | 9 +- .../executor/sortedset/ZRangeByLexExecutor.java | 23 +- .../executor/sortedset/ZRangeByScoreExecutor.java | 28 +- .../executor/sortedset/ZRangeExecutor.java | 9 +- .../internal/executor/sortedset/ZRankExecutor.java | 5 +- .../internal/executor/sortedset/ZRemExecutor.java | 6 +- .../executor/sortedset/ZRemRangeByLexExecutor.java | 14 +- .../sortedset/ZRemRangeByRankExecutor.java | 14 +- .../sortedset/ZRemRangeByScoreExecutor.java | 17 +- .../internal/executor/sortedset/ZScanExecutor.java | 8 +- .../internal/executor/string/AppendExecutor.java | 2 +- .../internal/executor/string/BitCountExecutor.java | 20 +- .../internal/executor/string/BitOpExecutor.java | 34 +- .../internal/executor/string/BitPosExecutor.java | 40 +- .../internal/executor/string/DecrExecutor.java | 2 +- .../internal/executor/string/GetBitExecutor.java | 3 +- .../internal/executor/string/GetRangeExecutor.java | 4 +- .../executor/string/IncrByFloatExecutor.java | 1 - .../internal/executor/string/IncrExecutor.java | 1 - .../internal/executor/string/MGetExecutor.java | 3 +- .../internal/executor/string/SetBitExecutor.java | 8 +- .../internal/executor/string/SetEXExecutor.java | 3 +- .../internal/executor/string/SetExecutor.java | 6 +- .../internal/executor/string/SetNXExecutor.java | 5 +- .../internal/executor/string/SetRangeExecutor.java | 3 +- .../internal/executor/string/StrlenExecutor.java | 6 +- .../executor/transactions/ExecExecutor.java | 7 +- .../internal/org/apache/hadoop/fs/GlobPattern.java | 4 +- .../geode/redis/internal/CommandJUnitTest.java | 77 +++ .../internal/ExecutionHandlerContextJUnitTest.java | 73 ++ .../redis/internal/RedisLockServiceJUnitTest.java | 168 +++++ .../redis/internal/RegionProviderJUnitTest.java | 108 +++ ...ptionsTest.java => SubscriptionsJUnitTest.java} | 2 +- .../executor/AbstractExecutorJUnitTest.java | 61 ++ ...est.java => AbstractScanExecutorJUnitTest.java} | 2 +- .../executor/UnkownExecutorJUnitTest.java} | 36 +- .../executor/hash/HDelExecutorJUnitTest.java} | 36 +- .../executor/set/SetExecutorJUnitTest.java | 374 ++++++++++ ...orTest.java => StringSetExecutorJUnitTest.java} | 2 +- 138 files changed, 4262 insertions(+), 1253 deletions(-) rename geode-redis/src/integrationTest/java/org/apache/geode/codeAnalysis/{AnalyzeRedisSerializablesJUnitTest.java => AnalyzeRedisSerializablesIntegrationTest.java} (91%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{AuthJUnitTest.java => AuthIntegrationTest.java} (99%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ConcurrentStartTest.java => ConcurrentStartIntegrationTest.java} (98%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{GeoCoderTest.java => GeoCoderIntegrationTest.java} (97%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{GeoJUnitTest.java => GeoIntegrationTest.java} (99%) create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/HashesIntegrationTest.java delete mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/HashesJUnitTest.java rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{ListsJUnitTest.java => ListsIntegrationTest.java} (96%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{PubSubTest.java => PubSubIntegrationTest.java} (99%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{SetCommandNegativeCaseTest.java => SetCommandNegativeCaseIntegrationTest.java} (98%) create mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/SetsIntegrationTest.java delete mode 100755 geode-redis/src/integrationTest/java/org/apache/geode/redis/SetsJUnitTest.java rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{SortedSetsJUnitTest.java => SortedSetsIntegrationTest.java} (99%) rename geode-redis/src/integrationTest/java/org/apache/geode/redis/{StringsJunitTest.java => StringsIntegrationTest.java} (99%) copy geode-redis/src/main/java/org/apache/geode/redis/internal/{Extendable.java => AutoCloseableLock.java} (69%) create mode 100644 geode-redis/src/main/java/org/apache/geode/redis/internal/RedisLockService.java create mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/CommandJUnitTest.java create mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/ExecutionHandlerContextJUnitTest.java create mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/RedisLockServiceJUnitTest.java create mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/RegionProviderJUnitTest.java rename geode-redis/src/test/java/org/apache/geode/redis/internal/{SubscriptionsTest.java => SubscriptionsJUnitTest.java} (99%) create 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/{AbstractScanExecutorTest.java => AbstractScanExecutorJUnitTest.java} (97%) copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/UnkownExecutor.java => test/java/org/apache/geode/redis/internal/executor/UnkownExecutorJUnitTest.java} (56%) mode change 100755 => 100644 copy geode-redis/src/{main/java/org/apache/geode/redis/internal/executor/UnkownExecutor.java => test/java/org/apache/geode/redis/internal/executor/hash/HDelExecutorJUnitTest.java} (53%) mode change 100755 => 100644 create mode 100644 geode-redis/src/test/java/org/apache/geode/redis/internal/executor/set/SetExecutorJUnitTest.java rename geode-redis/src/test/java/org/apache/geode/redis/internal/executor/string/{SetExecutorTest.java => StringSetExecutorJUnitTest.java} (99%)