You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2021/09/13 05:56:52 UTC
[geode] branch develop updated (723429f -> 5cbb203)
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