You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by al...@apache.org on 2021/03/22 19:21:02 UTC
[geode] branch develop updated (3a9baef -> 841fa06)
This is an automated email from the ASF dual-hosted git repository.
alberto pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git.
from 3a9baef GEODE-9044: Introduce RedisKey as key object for RedisData entries (#6146)
add 841fa06 GEODE-8971: Add grace period when stopping gateway sender with group-… (#6052)
No new revisions were added by this update.
Summary of changes:
.../org/apache/geode/cache/wan/GatewaySender.java | 24 ++-
.../geode/internal/cache/BucketRegionQueue.java | 38 +++-
.../geode/internal/cache/EntryEventImpl.java | 5 +-
.../internal/cache/wan/AbstractGatewaySender.java | 57 ++++--
.../wan/AbstractGatewaySenderEventProcessor.java | 29 ++-
.../internal/cache/wan/GatewaySenderEventImpl.java | 5 +-
...terImpl.java => InternalGatewayQueueEvent.java} | 46 ++---
...currentParallelGatewaySenderEventProcessor.java | 23 ++-
.../ParallelGatewaySenderEventProcessor.java | 22 ++-
.../wan/parallel/ParallelGatewaySenderQueue.java | 142 +++++++++-----
...oncurrentSerialGatewaySenderEventProcessor.java | 34 ++--
.../serial/SerialGatewaySenderEventProcessor.java | 18 +-
.../cache/wan/serial/SerialGatewaySenderQueue.java | 121 +++++++-----
.../internal/cache/BucketRegionQueueJUnitTest.java | 5 +-
.../serial/SerialGatewaySenderQueueJUnitTest.java | 10 +-
.../geode/internal/cache/wan/WANTestBase.java | 17 ++
.../wan/parallel/ParallelWANStatsDUnitTest.java | 199 ++++++++++++++++++-
.../cache/wan/serial/SerialWANStatsDUnitTest.java | 215 ++++++++++++++++++++-
.../wan/parallel/ParallelGatewaySenderImpl.java | 2 +
.../cache/wan/serial/SerialGatewaySenderImpl.java | 2 +
.../parallel/ParallelGatewaySenderImplTest.java | 41 ++++
.../wan/serial/SerialGatewaySenderImplTest.java | 42 ++++
22 files changed, 882 insertions(+), 215 deletions(-)
copy geode-core/src/main/java/org/apache/geode/internal/cache/wan/{GatewayEventFilterImpl.java => InternalGatewayQueueEvent.java} (59%)