This is an automated email from the ASF dual-hosted git repository.
runzhiwang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-ratis.git.
from f5ebbb7 RATIS-1088. SegmentedRaftLogWorker#closeLogSegment should
also roll the open segment maintained in the cache. (#217)
add e99f0d4 RATIS-1099. DataStreamServerRpc should connect other peers
automatically (#225)
No new revisions were added by this update.
Summary of changes:
.../org/apache/ratis/client/DataStreamClient.java | 7 +-
.../java/org/apache/ratis/util/PeerProxyMap.java | 4 +
.../apache/ratis/netty/NettyDataStreamFactory.java | 12 +-
.../ratis/netty/server/NettyServerStreamRpc.java | 166 +++++++++++++--------
.../org/apache/ratis/server/DataStreamServer.java | 9 +-
.../ratis/server/DataStreamServerFactory.java | 17 +--
.../apache/ratis/server/DataStreamServerRpc.java | 16 +-
.../ratis/server/impl/DataStreamServerImpl.java | 28 +---
.../apache/ratis/datastream/TestDataStream.java | 60 ++++----
9 files changed, 161 insertions(+), 158 deletions(-)
