This is an automated email from the ASF dual-hosted git repository.
williamsong pushed a change to branch feature/leaderlease
in repository https://gitbox.apache.org/repos/asf/ratis.git
omit 97220fe9f RATIS-1865. Add leader lease bound ratio configuration (#897)
add 903995983 RATIS-1550. Rewrite stream client reply queue. (#740)
add 95b51e512 RATIS-1705. Fix metrics leak (#744)
add ea6faa47a RATIS-1867. To uniformly manage the timeout parameters for
detecting gc. (#899)
add f3a5d4de6 RATIS-1868. Handling Netty back pressure when streaming
ratis log (#900)
add c8f4c46b0 RATIS-1870. Refactor hasMajority code during configuration
changes. (#902)
add f9584b8c2 RATIS-1871. Auto format RaftStorage when there is only one
directory configured. (#903)
add a6719dc63 RATIS-1873. Remove RetryCache assertion that doesn't hold
(#904)
add c1fd4e5dc RATIS-1872. HeartbeatAck use in-correct callId as minCallId.
(#905)
add 9095c895b RATIS-1860. Add ratis-shell cmd to generate a new
raft-meta.conf. (#901)
add c3f78faed RATIS-1874. Add notifyLeaderReady function in IStateMachine
(#906)
add 670a4ee71 RATIS-1876. NPE in GrpcLogAppender.resetClient. (#908)
add 9be3f02a0 RATIS-1877. In JvmPauseMonitor, sleepTime should not be
larger than sleepDeviationThreshold (#907)
add b06f82a94 RATIS-1878. checkstyle fails with
UnsupportedClassVersionError. (#909)
add 1b54bfab0 RATIS-1881. In LeaderStateImpl, set placeHolderIndex from
the log. (#912)
add 88405b037 RATIS-1882. Support read-after-write consistency (#913)
add 4e5443a4f RATIS-1873. Fix retry cache warning condition (#915)
add 1dc6c3524 Revert "RATIS-1873. Fix retry cache warning condition
(#915)" for fixing commit message.
add a483bd4bf RATIS-1884. Fix retry cache warning condition (#915)
add b8ce6d1f6 RATIS-1883. Next Index should be always larger than Match
Index in GrpcLogAppender (#914)
new 078b11554 RATIS-1865. Add leader lease bound ratio configuration (#897)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (97220fe9f)
\
N -- N -- N refs/heads/feature/leaderlease (078b11554)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 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:
pom.xml | 14 +-
.../java/org/apache/ratis/client/api/AsyncApi.java | 9 ++
.../org/apache/ratis/client/api/BlockingApi.java | 8 +
.../org/apache/ratis/client/impl/AsyncImpl.java | 5 +
.../org/apache/ratis/client/impl/BlockingImpl.java | 5 +
.../ratis/client/impl/OrderedStreamAsync.java | 21 ---
.../apache/ratis/protocol/RaftClientRequest.java | 19 ++-
.../org/apache/ratis/util/JvmPauseMonitor.java | 61 ++++++-
.../java/org/apache/ratis/util/TimeDuration.java | 9 ++
ratis-docs/src/site/markdown/cli.md | 12 ++
ratis-docs/src/site/markdown/configurations.md | 2 +
.../ratis/server/impl/TestReadAfterWrite.java | 160 ++++++++++++++++++
.../apache/ratis/grpc/metrics/MessageMetrics.java | 8 +
.../apache/ratis/grpc/server/GrpcLogAppender.java | 71 +++++---
.../grpc/server/GrpcServerProtocolClient.java | 7 +-
.../ratis/metrics/impl/MetricRegistriesImpl.java | 14 +-
.../dropwizard3/Dm3MetricRegistriesImpl.java | 12 +-
.../ratis/netty/client/NettyClientReplies.java | 179 +++++++++++++++++++++
.../ratis/netty/client/NettyClientStreamRpc.java | 144 +++++++----------
ratis-proto/src/main/proto/Raft.proto | 2 +
.../apache/ratis/server/RaftServerConfigKeys.java | 18 +++
.../apache/ratis/statemachine/StateMachine.java | 5 +
.../apache/ratis/server/impl/LeaderStateImpl.java | 126 +++++++--------
.../ratis/server/impl/PeerConfiguration.java | 16 +-
.../ratis/server/impl/RaftConfigurationImpl.java | 20 +++
.../apache/ratis/server/impl/RaftServerImpl.java | 53 +++---
.../apache/ratis/server/impl/RaftServerProxy.java | 9 +-
.../ratis/server/impl/ReadIndexHeartbeats.java | 10 +-
.../apache/ratis/server/impl/ServerProtoUtils.java | 4 +-
.../apache/ratis/server/impl/WriteIndexCache.java | 68 ++++++++
.../ratis/server/storage/StorageImplUtils.java | 10 +-
.../statemachine/impl/TransactionContextImpl.java | 10 ++
.../org/apache/ratis/ReadOnlyRequestTests.java | 32 ++++
.../server/impl/RaftReconfigurationBaseTest.java | 6 +-
.../shell/cli/sh/command/AbstractCommand.java | 59 +++++++
.../cli/sh/command/AbstractParentCommand.java | 5 +-
.../shell/cli/sh/command/AbstractRatisCommand.java | 33 +---
.../shell/cli/sh/command/ElectionCommand.java | 3 +-
.../ratis/shell/cli/sh/command/GroupCommand.java | 3 +-
.../{SnapshotCommand.java => LocalCommand.java} | 19 ++-
.../ratis/shell/cli/sh/command/PeerCommand.java | 3 +-
.../shell/cli/sh/command/SnapshotCommand.java | 3 +-
.../shell/cli/sh/local/RaftMetaConfCommand.java | 132 +++++++++++++++
.../ratis/server/storage/TestStorageImplUtils.java | 48 +++++-
44 files changed, 1145 insertions(+), 312 deletions(-)
create mode 100644
ratis-examples/src/test/java/org/apache/ratis/server/impl/TestReadAfterWrite.java
create mode 100644
ratis-netty/src/main/java/org/apache/ratis/netty/client/NettyClientReplies.java
create mode 100644
ratis-server/src/main/java/org/apache/ratis/server/impl/WriteIndexCache.java
create mode 100644
ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/AbstractCommand.java
copy
ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/{SnapshotCommand.java
=> LocalCommand.java} (69%)
create mode 100644
ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/local/RaftMetaConfCommand.java
