This is an automated email from the ASF dual-hosted git repository.
dragonyliu pushed a change to branch branch-2
in repository https://gitbox.apache.org/repos/asf/ratis.git
from f5d15922a RATIS-1637. Improve the log message with fallback value in
conf. (#695)
new ce5357a2e RATIS-1640. Add unit-test of listener related to
setConfiguration and takeSnapshot (#697)
new 8d44e8893 RATIS-1639. Added getting started document (#696)
new d5e3d413b RATIS-1655. Fix OrderedStreamAsync#scheduleWithTimeout to
report a correct timeout value (#701)
new 6cd8ef3d9 RATIS-1657. Intermittent failure in
TestLogAppenderWithGrpc#testPendingLimits due to
ConcurrentModificationException at SlidingWindow$Client.trySendDelayed. (#703)
new 0c2ecd615 RATIS-1603. TimeoutScheduler can have a huge amount of
threads and cause OOM. (#666)
new 2afee9379 RATIS-1656. Leftover usage of ForkJoinPool.commonPool() in
RaftServerImpl (#702)
new 396d69654 RATIS-1661. Support configurable hostname in GrpcService
(#707)
new 07f04cbd2 RATIS-1641. Cleanup the Counter example and revise the
"Getting Started" doc. (#698)
new d80d95520 RATIS-1665. RaftLog avoid converting list (#708)
new 8a9963c8f RATIS-1660. Fix wrong ratis package (#705)
new bb0f0021f RATIS-1663. Record call id for board casting a heartbeat.
(#706)
new 3bfaa496e RATIS-1669. Combine shell lib folder and root jars folder
(#711)
The 12 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:
.gitignore | 1 +
pom.xml | 7 +
ratis-assembly/pom.xml | 41 +-
.../src/main/assembly/bin-pkg.xml | 31 +-
ratis-assembly/src/main/assembly/bin.xml | 33 +-
ratis-assembly/src/main/assembly/examples-bin.xml | 16 +-
ratis-assembly/src/main/assembly/shell-bin.xml | 15 +-
.../ratis/client/impl/OrderedStreamAsync.java | 6 +-
.../apache/ratis/client/impl/RaftClientImpl.java | 7 +-
.../src/main/java/org/apache/ratis/rpc/CallId.java | 12 +
.../org/apache/ratis/util/CollectionUtils.java | 14 +-
.../java/org/apache/ratis/util/SlidingWindow.java | 58 ++-
.../org/apache/ratis/util/TimeoutExecutor.java | 50 ++
.../org/apache/ratis/util/TimeoutScheduler.java | 22 +-
.../java/org/apache/ratis/util/TimeoutTimer.java | 109 +++++
ratis-docs/src/site/markdown/index.md | 42 +-
ratis-docs/src/site/markdown/start/index.md | 509 ++++++++++++++++++++-
ratis-examples/pom.xml | 5 +-
.../apache/ratis/examples/common/Constants.java | 5 +-
.../ratis/examples/counter/CounterCommand.java | 26 +-
.../examples/counter/client/CounterClient.java | 118 +++--
.../examples/counter/server/CounterServer.java | 59 ++-
.../counter/server/CounterStateMachine.java | 205 +++++----
.../apache/ratis/examples/counter/TestCounter.java | 10 +-
.../java/org/apache/ratis/grpc/GrpcConfigKeys.java | 34 ++
.../grpc/client/GrpcClientProtocolClient.java | 5 +-
.../apache/ratis/grpc/server/GrpcLogAppender.java | 30 +-
.../org/apache/ratis/grpc/server/GrpcService.java | 30 +-
.../ratis/netty/client/NettyClientStreamRpc.java | 4 +-
.../apache/ratis/server/leader/LogAppender.java | 7 +
.../ratis/server/raftlog/RaftLogSequentialOps.java | 13 +-
.../apache/ratis/server/impl/LeaderStateImpl.java | 2 +-
.../apache/ratis/server/impl/PendingStepDown.java | 4 +-
.../apache/ratis/server/impl/RaftServerImpl.java | 51 ++-
.../apache/ratis/server/impl/RaftServerProxy.java | 4 +-
.../org/apache/ratis/server/impl/ReadRequests.java | 66 +++
.../org/apache/ratis/server/impl/ServerState.java | 8 +-
.../impl/SnapshotManagementRequestHandler.java | 4 +-
.../ratis/server/impl/TransferLeadership.java | 4 +-
.../apache/ratis/server/impl/WatchRequests.java | 2 +-
.../ratis/server/leader/LogAppenderDefault.java | 16 +-
.../apache/ratis/server/raftlog/LogProtoUtils.java | 7 +-
.../apache/ratis/server/raftlog/RaftLogBase.java | 4 +-
.../ratis/server/raftlog/memory/MemoryRaftLog.java | 21 +-
.../server/raftlog/segmented/SegmentedRaftLog.java | 12 +-
.../raftlog/segmented/SegmentedRaftLogCache.java | 15 +-
.../ratis/statemachine/impl/BaseStateMachine.java | 9 +-
.../ratis/InstallSnapshotNotificationTests.java | 7 +-
.../ratis/server/impl/LeaderElectionTests.java | 88 ++++
.../apache/ratis/server/impl/MiniRaftCluster.java | 6 +
.../ratis/statemachine/SnapshotManagementTest.java | 30 ++
ratis-shell/pom.xml | 41 +-
ratis-shell/src/main/libexec/ratis-shell-config.sh | 11 +
.../server/raftlog/memory/MemoryRaftLogTest.java | 30 +-
.../raftlog/segmented/TestCacheEviction.java | 6 +-
.../raftlog/segmented/TestSegmentedRaftLog.java | 2 +-
.../apache/ratis/util/TestTimeoutScheduler.java | 4 +-
57 files changed, 1516 insertions(+), 462 deletions(-)
copy ratis-docs/pom.xml => ratis-assembly/src/main/assembly/bin-pkg.xml (50%)
create mode 100644
ratis-common/src/main/java/org/apache/ratis/util/TimeoutExecutor.java
create mode 100644
ratis-common/src/main/java/org/apache/ratis/util/TimeoutTimer.java
copy
ratis-server-api/src/main/java/org/apache/ratis/server/raftlog/RaftLogIOException.java
=>
ratis-examples/src/main/java/org/apache/ratis/examples/counter/CounterCommand.java
(61%)
create mode 100644
ratis-server/src/main/java/org/apache/ratis/server/impl/ReadRequests.java
