This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a change to branch branch-2
in repository https://gitbox.apache.org/repos/asf/ratis.git
from 256b16ba RATIS-1618. Resolve the stream client concurrent reconnection
problem (#676)
new 2c000736 RATIS-1612. Support starting a server as a Listener. (#673)
new 5e7a7731 RATIS-1605. Do not start RaftServer in
MiniRaftCluster#addNewPeers. (#663)
new 5437186d RATIS-1593. Support CAS mode to setConfiguration (#682)
new 080bb8e4 RATIS-1627. InstallSnapshotRequests add properties :
totalSize (#684)
new 4f4182c3 RATIS-1624. Can't use set configuration to add a new Listener
correctly. (#683)
new b2819e0f RATIS-1629. Fix flaky
TestRaftReconfigurationWithSimulatedRpc#testKillLeaderDuringReconf. (#686)
new 87dfffbd RATIS-1628. Fix 'Address already in use' failure in
TestMultiRaftGroup. (#685)
new e552f290 RATIS-1622. Fix high CPU load when some followers are down
(#680)
new 208800a8 RATIS-1465. Use seperate channel for group heartbeat. (#561)
new 0d723e4e RATIS-1631. Add Raftpeer Info for NotifySnapshotInstalled
(#689)
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/ratis/client/impl/BlockingImpl.java | 4 +-
.../apache/ratis/client/impl/ClientProtoUtils.java | 6 +
.../java/org/apache/ratis/protocol/RaftGroup.java | 6 +-
.../java/org/apache/ratis/protocol/RaftPeer.java | 33 ++++-
.../ratis/protocol/SetConfigurationRequest.java | 39 +++++-
...ception.java => SetConfigurationException.java} | 6 +-
.../org/apache/ratis/util/CollectionUtils.java | 18 +++
.../java/org/apache/ratis/util/ProtoUtils.java | 2 +
.../java/org/apache/ratis/grpc/GrpcConfigKeys.java | 10 ++
.../grpc/client/GrpcClientProtocolClient.java | 2 +-
.../apache/ratis/grpc/server/GrpcLogAppender.java | 83 ++++++++++---
.../grpc/server/GrpcServerProtocolClient.java | 48 ++++++--
.../grpc/server/GrpcServerProtocolService.java | 7 +-
.../org/apache/ratis/grpc/server/GrpcService.java | 28 +++--
.../apache/ratis/netty/server/NettyRpcService.java | 12 +-
ratis-proto/src/main/proto/Raft.proto | 4 +
.../java/org/apache/ratis/server/RaftServer.java | 14 ++-
.../apache/ratis/statemachine/StateMachine.java | 6 +-
.../apache/ratis/server/impl/LeaderElection.java | 2 +-
.../apache/ratis/server/impl/LeaderStateImpl.java | 11 +-
.../ratis/server/impl/PeerConfiguration.java | 2 +-
.../ratis/server/impl/RaftConfigurationImpl.java | 4 +-
.../apache/ratis/server/impl/RaftServerImpl.java | 48 ++++++--
.../org/apache/ratis/server/impl/ServerState.java | 11 +-
.../server/impl/SnapshotInstallationHandler.java | 8 +-
.../server/leader/InstallSnapshotRequests.java | 6 +-
.../ratis/server/leader/LogAppenderBase.java | 14 ++-
.../apache/ratis/server/raftlog/LogProtoUtils.java | 9 +-
.../segmented/SegmentedRaftLogOutputStream.java | 8 +-
.../ratis/server/util/ServerStringUtils.java | 3 +-
.../ratis/InstallSnapshotNotificationTests.java | 13 +-
.../ratis/server/impl/GroupManagementBaseTest.java | 133 +++++++++++----------
.../apache/ratis/server/impl/MiniRaftCluster.java | 9 +-
.../server/impl/RaftReconfigurationBaseTest.java | 73 +++++++++--
.../ratis/server/impl/RaftServerTestUtil.java | 63 ++++++++++
.../ratis/grpc/TestLeaderInstallSnapshot.java | 18 ++-
.../apache/ratis/grpc/TestLogAppenderWithGrpc.java | 13 ++
.../apache/ratis/grpc/TestRaftServerWithGrpc.java | 17 ++-
.../org/apache/ratis/grpc/TestRaftWithGrpc.java | 14 +++
.../apache/ratis/server/ServerRestartTests.java | 6 +-
40 files changed, 621 insertions(+), 192 deletions(-)
copy
ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/{TransferLeadershipException.java
=> SetConfigurationException.java} (82%)
