This is an automated email from the ASF dual-hosted git repository. dschneider pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git.
from 723429f GEODE-8626: Omitting field-mapping tag of cache.xml when using Simple JDBC Connector (#5637) add 5cbb203 GEODE-9347: optimize pubSub (#6814) No new revisions were added by this update. Summary of changes: .../pubsub/AbstractSubCommandsIntegrationTest.java | 9 + .../pubsub/SubscriptionsIntegrationTest.java | 97 ++-- .../geode/redis/internal/data/RedisHash.java | 3 +- .../apache/geode/redis/internal/data/RedisSet.java | 4 +- .../geode/redis/internal/executor/GlobPattern.java | 89 ++-- .../redis/internal/executor/RedisResponse.java | 5 + .../internal/executor/connection/PingExecutor.java | 2 +- .../internal/executor/hash/HScanExecutor.java | 4 +- .../executor/key/AbstractScanExecutor.java | 4 +- .../redis/internal/executor/key/KeysExecutor.java | 5 +- .../redis/internal/executor/key/ScanExecutor.java | 8 +- .../executor/pubsub/PsubscribeExecutor.java | 33 +- .../internal/executor/pubsub/PubSubExecutor.java | 28 +- .../internal/executor/pubsub/PublishExecutor.java | 6 +- .../executor/pubsub/PunsubscribeExecutor.java | 47 +- .../executor/pubsub/SubscribeExecutor.java | 30 +- .../executor/pubsub/UnsubscribeExecutor.java | 45 +- .../internal/executor/server/TimeExecutor.java | 8 +- .../redis/internal/executor/set/SScanExecutor.java | 4 +- .../apache/geode/redis/internal/netty/Client.java | 110 ++++- .../apache/geode/redis/internal/netty/Command.java | 8 + .../internal/netty/ExecutionHandlerContext.java | 43 +- .../redis/internal/netty/StringBytesGlossary.java | 22 + .../internal/pubsub/AbstractSubscription.java | 102 ---- .../pubsub/AbstractSubscriptionManager.java | 194 ++++++++ .../pubsub/ChannelClientSubscriptionManager.java | 86 ++++ .../redis/internal/pubsub/ChannelSubscription.java | 68 --- .../pubsub/ChannelSubscriptionManager.java} | 46 +- .../internal/pubsub/ClientSubscriptionManager.java | 71 +++ .../pubsub/PatternClientSubscriptionManager.java | 59 +++ .../redis/internal/pubsub/PatternSubscription.java | 70 --- .../pubsub/PatternSubscriptionManager.java | 66 +++ .../apache/geode/redis/internal/pubsub/PubSub.java | 48 +- .../geode/redis/internal/pubsub/PubSubImpl.java | 105 +++-- .../internal/pubsub/PublishResultCollector.java | 63 --- .../geode/redis/internal/pubsub/Subscription.java | 45 +- .../redis/internal/pubsub/SubscriptionImpl.java | 92 ++++ .../redis/internal/pubsub/SubscriptionManager.java | 78 ++++ .../geode/redis/internal/pubsub/Subscriptions.java | 222 +++++---- ...de-apis-compatible-with-redis-serializables.txt | 1 - .../geode/redis/internal/netty/ClientTest.java | 184 ++++++++ .../redis/internal/netty/CommandJUnitTest.java | 16 + .../ChannelClientSubscriptionManagerTest.java | 124 +++++ .../pubsub/ChannelSubscriptionManagerTest.java} | 26 +- .../PatternClientSubscriptionManagerTest.java} | 25 +- .../pubsub/PatternSubscriptionManagerTest.java | 76 +++ .../redis/internal/pubsub/PubSubImplJUnitTest.java | 100 ---- .../redis/internal/pubsub/PubSubImplTest.java | 53 +++ .../internal/pubsub/SubscriptionImplTest.java | 117 +++++ .../pubsub/SubscriptionManagerTestBase.java | 190 ++++++++ .../internal/pubsub/SubscriptionsJUnitTest.java | 513 +++++++++++++-------- .../execute/PartitionedRegionFunctionExecutor.java | 6 +- 52 files changed, 2228 insertions(+), 1232 deletions(-) delete mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/AbstractSubscription.java create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/AbstractSubscriptionManager.java create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/ChannelClientSubscriptionManager.java delete mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/ChannelSubscription.java rename geode-apis-compatible-with-redis/src/{integrationTest/java/org/apache/geode/redis/mocks/DummySubscription.java => main/java/org/apache/geode/redis/internal/pubsub/ChannelSubscriptionManager.java} (50%) create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/ClientSubscriptionManager.java create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/PatternClientSubscriptionManager.java delete mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/PatternSubscription.java create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/PatternSubscriptionManager.java delete mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/PublishResultCollector.java create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/SubscriptionImpl.java create mode 100644 geode-apis-compatible-with-redis/src/main/java/org/apache/geode/redis/internal/pubsub/SubscriptionManager.java create mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/netty/ClientTest.java create mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/pubsub/ChannelClientSubscriptionManagerTest.java copy geode-apis-compatible-with-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/AbstractScanExecutor.java => test/java/org/apache/geode/redis/internal/pubsub/ChannelSubscriptionManagerTest.java} (52%) mode change 100755 => 100644 copy geode-apis-compatible-with-redis/src/{main/java/org/apache/geode/redis/internal/executor/key/AbstractScanExecutor.java => test/java/org/apache/geode/redis/internal/pubsub/PatternClientSubscriptionManagerTest.java} (52%) mode change 100755 => 100644 create mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/pubsub/PatternSubscriptionManagerTest.java delete mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/pubsub/PubSubImplJUnitTest.java create mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/pubsub/PubSubImplTest.java create mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/pubsub/SubscriptionImplTest.java create mode 100644 geode-apis-compatible-with-redis/src/test/java/org/apache/geode/redis/internal/pubsub/SubscriptionManagerTestBase.java