You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2020/11/06 09:36:36 UTC
[shardingsphere] branch master updated (421917b -> 2609c79)
This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 421917b remove dbcp with mock in CenterConfigTest (#8024)
add 2609c79 Refactor DistributionChannel (#8046)
No new revisions were added by this update.
Summary of changes:
.../{Channel.java => AbstractBitSetChannel.java} | 58 +++++-----
...nnel.java => AutoAcknowledgeBitSetChannel.java} | 42 +++----
.../channel/{Channel.java => BitSetChannel.java} | 34 +++++-
...hannel.java => BlockingQueueBitSetChannel.java} | 25 ++---
.../executor/channel/DistributionChannel.java | 123 +++++++++++----------
.../execute/executor/channel/ManualBitSet.java | 123 +++++++++++++++++++++
.../executor/channel/DistributionChannelTest.java | 95 ++++++++++------
7 files changed, 336 insertions(+), 164 deletions(-)
copy shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/executor/channel/{Channel.java => AbstractBitSetChannel.java} (51%)
mode change 100755 => 100644
copy shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/executor/channel/{Channel.java => AutoAcknowledgeBitSetChannel.java} (60%)
mode change 100755 => 100644
copy shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/executor/channel/{Channel.java => BitSetChannel.java} (66%)
mode change 100755 => 100644
copy shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/executor/channel/{MemoryChannel.java => BlockingQueueBitSetChannel.java} (76%)
mode change 100755 => 100644
create mode 100644 shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/execute/executor/channel/ManualBitSet.java