This is an automated email from the ASF dual-hosted git repository.
williamsong pushed a change to branch snapshot-3
in repository https://gitbox.apache.org/repos/asf/ratis.git
discard 21f25926e latest snapshot version
discard 2fddd52ae reply ALREADY_INSTALLED
omit c81902a09 RATIS-2066. RaftServerProxy supports close callback (#1072)
omit 192ce4880 RATIS-2090. Bump ratis-thirdparty to 1.0.6 (#1093)
omit 29bba5943 RATIS-2088. Fix name and imports related check in
test-directory (#1092)
omit 599835dba RATIS-2083. Timer thread leak when log level is DEBUG (#1086)
omit 8bc09bbe5 RATIS-2085. Compile Ratis with JDK 17/21 in CI (#1087)
omit 7f04919ff RATIS-2077. Timedout StateMachine retainRead is released
twice (#1081)
omit c10e7bc8d RATIS-2076. Intermittent timeout in
TestRaftWithNetty#testWithLoad. (#1090)
omit 33cb58678 Revert "RATIS-2080. Reuse LeaderElection executor. (#1082)"
omit 0814b896b RATIS-2086. Autolink Ozone issues in PRs (#1088)
omit da9eee0fb RATIS-2087. Remove workaround for GitHub reverse DNS issue
(#1089)
omit 8c9c801e5 RATIS-2080. Reuse LeaderElection executor. (#1082)
omit e17650163 RATIS-2078. Correct timeout unit for tests (#1083)
omit ac05d64f3 RATIS-2074. Intermittent fork timeout in
TestRaftWithNetty#testBasicAppendEntriesKillLeader. (#1080)
omit 388852071 RATIS-2067. Enhance content for concept in ratis-docs.
(#1073)
omit 839f8fb26 RATIS-2073. Enable Surefire process checkers (#1079)
omit 58671923e RATIS-2072. Limit timeout of CI workflow jobs (#1078)
omit 6fc42220b RATIS-2071. Bump Bouncy Castle to 1.78.1 (#1076)
omit cbd9793a0 RATIS-2070. Skip push build for dependabot (#1077)
omit 51244e42c RATIS-2068. Avoid logging raw StateMachine data body. (#1074)
omit 4e3eee7c9 RATIS-2069. RaftMetaConf command sets incorrect peerAddress
pattern. (#1075)
omit 1fe59e07d RATIS-2065. Avoid the out-of-heap memory OOM phenomenon of
frequent creation and deletion of Raft group scenarios. (#1071)
omit b0ec1143c RATIS-2061. Fix setCloseThreshold parameter in
RaftServerConfigKeys (#1070)
omit 7f1b1b6be RATIS-2060 Avoid unexpected shutdown of RaftServerProxy
during membership change (#1069)
omit 8704cd23d RATIS-2055. Move notifyTermIndexUpdated after
leader.checkReady (#1068)
omit ee09075c0 RATIS-2059. Missing reference count when putting log entries
to cache on follower. (#1067)
omit cf9d2292a RATIS-2057. Add back JavaUtils.attemptUntilTrue(..). (#1066)
omit 8913a999d RATIS-2056. Update purge index when snapshot installed.
(#1065)
omit 49b400601 RATIS-1504. Add timeout handling to
DataStreamManagement#checkSuccessRemoteWrite. (#1064)
omit 8638a2ffa Ratis-2040. Fix RaftPeerId generated by command of
"raftMetaConf" to use real PeerId (#1060)
omit bc6221b32 RATIS-1519. When DataStreamManagement#read an exception
occurs, remove DataStream (#596)
omit f40424422 RATIS-2051. Fix Sonar bugs for Ratis. (#1059)
omit c73a3eb8c RATIS-1979. Allow StateMachine.read to return a
ReferentCountedObject (#1062)
omit a99e709fe RATIS-2052. Add docs for triggering snapshot when removing
raftGroup parameter. (#1061)
omit 397c2efdd RATIS-2026. LogAppender to consume log entries with
reference count (#1049)
omit 14dbbf3d7 RATIS-2050. Add creationGap param to snapshot management API
(#1058)
omit 54c2b1f7f RATIS-2049. Suppress Sonar warning for volatile objects
(#1057)
omit 0f631fef4 RATIS-2036. Avoid trigger snapshot when removing raftGroup
(#1055)
omit be497d5c4 RATIS-2048. Fix SimpleStateMachineStorage potential NPE
exception (#1056)
omit c3d615b4f RATIS-2047. Avoid unnecessary warn log when creating raft
group (#1054)
omit 72c060d9c RATIS-2045. SnapshotInstallationHandler doesn't notify
follower when snapshotIndex is -1 and firstAvailableLogIndex is 0 (#1053)
omit 44a4f1fb7 RATIS-2044. Fix ReadIndex loss caused by data race in
AppendEntriesListeners (#1052)
omit 422cb9d4c RATIS-2043. Change toString() of RaftConfigurationImpl
(#1051)
omit e199daaf2 RATIS-2028. Refactor RaftLog to supply log as
ReferenceCountedObject (#1045)
omit 99a833c29 Ratis-2031. Add peer info to response of GroupInfoCommand
CLI (#1047)
omit df436c73f RATIS-2035. Refactor streaming code for Read. (#1046)
omit 1bd451046 RATIS-2038. IllegalStateException when ServerState is closed
before start. (#1048)
omit 53d35c01e RATIS-2020. Refactor TransactionContext to supply
LogEntryProto via a ReferenceCountedObject (#1042)
omit 044b111d9 RATIS-2027. Ratis Streaming: Remote Stream copy data to
heap. (#1044)
omit 67b76509d RATIS-2021. Migrate ratis-test tests to Junit 5 - Part 2.
(#1043)
omit 16b6536e2 RATIS-2025. Move out assert and proto methods from
RaftServerImpl. (#1041)
omit 1d99921ef RATIS-2024. Refactor appendEntries code. (#1040)
omit 775b286c4 RATIS-1997. Refactor StateMachine interface to use
ReferenceCountedObject (#1036)
omit 4f5612fd8 RATIS-2023. Remove duplicate RefCountingMap (#1039)
omit e44de2662 RATIS-1976. Migrate ratis-test tests to Junit 5 - Part 1
(#1038)
omit a2cb49e8c RATIS-1975. Migrate ratis-metrics-dropwizard3 tests to Junit
5. (#1037)
omit c46da2213 RATIS-1978. Add tests assertions to verify all zero-copy
messages are released properly (#1023)
omit d2f1c57fe RATIS-2019 Fixed abnormal exit of StateMachineUpdater (#1033)
omit cf897f029 RATIS-1973. Migrate ratis-examples tests to Junit 5. (#1035)
omit c4b10faa8 RATIS-2018. Zero-copy buffers are not released - 2nd chunk
(#1032)
omit 9cd74a21d RATIS-1974. Migrate ratis-metrics-default tests to Junit 5
(#1034)
omit 035cd968f RATIS-2016. Correct NotificationInstallSnapshot's index
(#1030)
omit 7d587ec03 RATIS-2017: checkAndEvictCache must be done in writeLock.
(#1031)
omit 5560718ab RATIS-2011. When a log entry is truncated, remove
TransactionContext. (#1029)
omit a18d08c89 RATIS-2015. Node.js 16 actions are deprecated (#1028)
omit e2aaddca9 RATIS-2007. Zero-copy buffers are not released (#1027)
omit 79923c2d7 RATIS-2008. Follower should recognize candidate if the
candidate is the same peer as the current valid leader (#1024)
omit ea1341b05 RATIS-2012. Client should not retry after close. (#1025)
omit 0e247578b RATIS-1972. Add junit 5 dependencies in ratis-server. (#1003)
omit c1e0ec284 RATIS-2013. OrderedAsync retry results an
IllegalStateException in GrpcClientProtocolService. (#1026)
omit 561cd6d48 RATIS-2010. Remove dependency on spotbugs-annotations (#1022)
omit d459eb61c RATIS-1934. Support Zero-Copy in GrpcServerProtocolService
(#1014)
omit 82c31eaf3 RATIS-2009. ReferenceCount should work for all LogEntry
types. (#1021)
omit fc5c72560 RATIS-2004. Fix EQ_COMPARETO_USE_OBJECT_EQUALS in LogSegment
(#1020)
omit 82f7b3b85 RATIS-2003. Fix IT_NO_SUCH_ELEMENT in
InstallSnapshotRequests (#1016)
omit 5d4ec6933 RATIS-1990. Refactor appendEntries processing to support
reference count (#1011)
omit 14eb0bf05 RATIS-2002. Fix findbugs warnings in LogSegmentPath (#1017)
omit 859a41074 RATIS-2006. Fix DM_EXIT in filestore Client (#1019)
omit eae0d18eb RATIS-2005. Fix URF_UNREAD_FIELD in MetricServerCallListener
(#1018)
omit 24482561f RATIS-2001. TransactionContext can be wrongly reused. (#1015)
omit 6671ef683 RATIS-1999. Move RaftServerJmxAdapter out from
RaftServerImpl. (#1010)
omit 863c2e8a0 RATIS-1987. Intermittent NPE in TestGrpcZeroCopy. (#1013)
omit 206205810 RATIS-1989. Intermittent timeout in
TestStreamObserverWithTimeout (#1012)
omit 59dfd3549 RATIS-1998. Add watch request metrics (#1009)
omit 84285d3ea RATIS-1925. Support Zero-Copy in GrpcClientProtocolService
(#1007)
omit 5e8ef17e7 RATIS-1994. AsyncApi send() to support optional replication
level. (#1006)
omit 43a02109d RATIS-1983. Refactor client request processing to support
reference count. (#998)
omit 256fc2a51 RATIS-1991. Optimize the reconfig judgment logic in the
ReconfigurationBase class. (#1004)
omit c2dacbd01 RATIS-1988. Provide Jacoco report to Sonar (#1002)
omit 93f46d940 RATIS-1986. Intermittent failure in
TestRaftStorage#testSnapshotCleanup (#1001)
omit ec8efec48 RATIS-1985. Calculate code coverage (#1000)
omit 77bf12917 RATIS-1984. Simplify Maven cache for dependencies in CI
(#999)
add e6f255461 Change version for the version 3.0.1 -rc0
new cc038aea9 RATIS-2013. OrderedAsync retry results an
IllegalStateException in GrpcClientProtocolService. (#1026)
new 1691a3c0f RATIS-2012. Client should not retry after close. (#1025)
new f8f12d890 RATIS-2008. Follower should recognize candidate if the
candidate is the same peer as the current valid leader (#1024)
new 5baff19ff RATIS-2017: checkAndEvictCache must be done in writeLock.
(#1031)
new 5bb9e32e3 RATIS-2019 Fixed abnormal exit of StateMachineUpdater (#1033)
new d2e114eda RATIS-2044. Fix ReadIndex loss caused by data race in
AppendEntriesListeners (#1052)
new 50a5f18a0 RATIS-2047. Avoid unnecessary warn log when creating raft
group (#1054)
new ba6e1604d RATIS-2048. Fix SimpleStateMachineStorage potential NPE
exception (#1056)
new 21271d600 RATIS-2036. Avoid trigger snapshot when removing raftGroup
(#1055)
new cda87cee9 RATIS-2049. Suppress Sonar warning for volatile objects
(#1057)
new 52e8db697 RATIS-2050. Add creationGap param to snapshot management API
(#1058)
new 3e3013b8a RATIS-2052. Add docs for triggering snapshot when removing
raftGroup parameter. (#1061)
new 8eafc4f9f RATIS-2056. Update purge index when snapshot installed.
(#1065)
new 611b80a85 RATIS-2060 Avoid unexpected shutdown of RaftServerProxy
during membership change (#1069)
new c20fe65ad update snapshot version
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 (21f25926e)
\
N -- N -- N refs/heads/snapshot-3 (c20fe65ad)
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 15 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:
.asf.yaml | 4 +-
.github/workflows/post-commit.yml | 209 +++---
.github/workflows/repeat-test.yml | 10 +-
dev-support/checks/build.sh | 10 +-
dev-support/checks/coverage.sh | 61 --
dev-support/checks/findbugs.sh | 6 -
dev-support/checks/sonar.sh | 1 -
dev-support/checks/unit.sh | 12 +-
pom.xml | 53 +-
ratis-assembly/pom.xml | 2 +-
ratis-assembly/src/main/resources/NOTICE | 24 +-
ratis-client/pom.xml | 2 +-
.../java/org/apache/ratis/client/api/AsyncApi.java | 8 +-
.../org/apache/ratis/client/impl/AsyncImpl.java | 4 +-
.../apache/ratis/client/impl/ClientProtoUtils.java | 4 +-
.../ratis/client/impl/DataStreamClientImpl.java | 7 +-
.../org/apache/ratis/client/impl/OrderedAsync.java | 11 +-
.../ratis/client/impl/OrderedStreamAsync.java | 4 -
ratis-common/pom.xml | 9 +-
.../main/java/org/apache/ratis/conf/ConfUtils.java | 2 +-
.../org/apache/ratis/conf/ReconfigurationBase.java | 2 +-
.../org/apache/ratis/protocol/GroupInfoReply.java | 13 +-
.../protocol/RaftClientAsynchronousProtocol.java | 34 +-
.../apache/ratis/protocol/RaftClientRequest.java | 92 +--
.../java/org/apache/ratis/protocol/RaftPeerId.java | 2 +
.../java/org/apache/ratis/util/BatchLogger.java | 12 +-
.../main/java/org/apache/ratis/util/JavaUtils.java | 3 +-
.../java/org/apache/ratis/util/JmxRegister.java | 7 +-
.../java/org/apache/ratis/util/LeakDetector.java | 140 ----
.../java/org/apache/ratis/util/PeerProxyMap.java | 1 -
.../java/org/apache/ratis/util/Preconditions.java | 11 -
.../ratis/util/ReferenceCountedLeakDetector.java | 222 -------
.../apache/ratis/util/ReferenceCountedObject.java | 101 ++-
.../java/org/apache/ratis/util/SlidingWindow.java | 32 +-
.../src/test/java/org/apache/ratis/BaseTest.java | 42 +-
ratis-docs/pom.xml | 2 +-
ratis-docs/src/site/markdown/cli.md | 2 +-
ratis-docs/src/site/markdown/concept/index.md | 66 +-
ratis-docs/src/site/markdown/metrics.md | 53 +-
ratis-docs/src/site/markdown/snapshot.md | 2 -
ratis-examples/pom.xml | 20 +-
.../arithmetic/ArithmeticStateMachine.java | 2 +-
.../counter/server/CounterStateMachine.java | 2 +-
.../apache/ratis/examples/filestore/FileInfo.java | 3 +-
.../examples/filestore/FileStoreStateMachine.java | 29 +-
.../ratis/examples/filestore/cli/Client.java | 5 +-
.../ratis/examples/filestore/cli/DataStream.java | 5 +-
.../ratis/examples/filestore/cli/LoadGen.java | 2 +-
.../java/org/apache/ratis/TestMultiRaftGroup.java | 27 +-
.../ratis/examples/ParameterizedBaseTest.java | 21 +-
.../ratis/examples/arithmetic/TestArithmetic.java | 30 +-
.../examples/arithmetic/TestArithmeticLogDump.java | 24 +-
.../examples/arithmetic/cli/TestAssignCli.java | 30 +-
.../arithmetic/expression/TestExpression.java | 26 +-
.../ratis/examples/common/TestSubCommand.java | 19 +-
.../apache/ratis/examples/counter/TestCounter.java | 21 +-
ratis-experiments/pom.xml | 2 +-
ratis-grpc/pom.xml | 9 +-
.../main/java/org/apache/ratis/grpc/GrpcUtil.java | 34 +-
.../apache/ratis/grpc/metrics/ZeroCopyMetrics.java | 73 ---
...rverCall.java => MetricServerCallListener.java} | 30 +-
.../intercept/server/MetricServerInterceptor.java | 3 +-
.../grpc/server/GrpcClientProtocolService.java | 147 ++---
.../apache/ratis/grpc/server/GrpcLogAppender.java | 62 +-
.../grpc/server/GrpcServerProtocolClient.java | 2 +-
.../grpc/server/GrpcServerProtocolService.java | 137 +---
.../org/apache/ratis/grpc/server/GrpcService.java | 18 +-
.../ratis/grpc/util/StreamObserverWithTimeout.java | 20 +-
.../ratis/grpc/util/ZeroCopyMessageMarshaller.java | 8 +-
.../apache/ratis/grpc/MiniRaftClusterWithGrpc.java | 34 +-
ratis-metrics-api/pom.xml | 2 +-
.../org/apache/ratis/metrics/RatisMetrics.java | 7 -
ratis-metrics-default/pom.xml | 13 +-
.../ratis/metrics/impl/MetricRegistriesImpl.java | 1 -
.../apache/ratis/metrics/impl}/RefCountingMap.java | 20 +-
.../ratis/metrics/TestMetricRegistriesLoader.java | 18 +-
.../ratis/metrics/impl}/TestRefCountingMap.java | 20 +-
ratis-metrics-dropwizard3/pom.xml | 12 +-
.../dropwizard3/Dm3MetricRegistriesImpl.java | 1 -
.../ratis/metrics/dropwizard3}/RefCountingMap.java | 20 +-
.../dropwizard3/TestLoadDm3MetricRegistries.java | 14 +-
.../metrics/dropwizard3}/TestRefCountingMap.java | 22 +-
ratis-netty/pom.xml | 8 +-
.../java/org/apache/ratis/netty/NettyClient.java | 21 +-
.../apache/ratis/netty/NettyDataStreamUtils.java | 16 +-
.../java/org/apache/ratis/netty/NettyRpcProxy.java | 4 +-
.../java/org/apache/ratis/netty/NettyUtils.java | 20 -
.../ratis/netty/client/NettyClientReplies.java | 29 +-
.../ratis/netty/client/NettyClientStreamRpc.java | 21 +-
.../org/apache/ratis/netty/server/ChannelMap.java | 48 --
.../ratis/netty/server/DataStreamManagement.java | 122 ++--
.../netty/server}/DataStreamRequestByteBuf.java | 3 +-
.../ratis/netty/server/NettyServerStreamRpc.java | 12 +-
.../org/apache/ratis/netty/server/StreamMap.java | 55 --
.../ratis/netty/MiniRaftClusterWithNetty.java | 4 +-
ratis-proto/pom.xml | 2 +-
ratis-proto/src/main/proto/Raft.proto | 11 -
ratis-replicated-map/pom.xml | 2 +-
ratis-resource-bundle/pom.xml | 2 +-
ratis-server-api/pom.xml | 9 +-
.../apache/ratis/server/DataStreamServerRpc.java | 10 +-
.../apache/ratis/server/RaftServerConfigKeys.java | 14 +-
.../org/apache/ratis/server/RaftServerRpc.java | 9 +-
.../java/org/apache/ratis/server/ServerRpc.java | 33 -
.../apache/ratis/server/leader/LogAppender.java | 2 -
.../protocol/RaftServerAsynchronousProtocol.java | 29 +-
.../org/apache/ratis/server/raftlog/RaftLog.java | 40 +-
.../ratis/server/raftlog/RaftLogSequentialOps.java | 37 +-
.../apache/ratis/statemachine/StateMachine.java | 64 +-
.../ratis/statemachine/TransactionContext.java | 42 +-
ratis-server/pom.xml | 35 +-
.../ratis/server/impl/ConfigurationManager.java | 6 +-
.../apache/ratis/server/impl/FollowerState.java | 1 -
.../apache/ratis/server/impl/LeaderElection.java | 4 +-
.../org/apache/ratis/server/impl/LeaderLease.java | 2 +-
.../apache/ratis/server/impl/LeaderStateImpl.java | 36 +-
.../ratis/server/impl/MessageStreamRequests.java | 45 +-
.../apache/ratis/server/impl/PendingRequest.java | 26 +-
.../apache/ratis/server/impl/PendingRequests.java | 44 +-
.../ratis/server/impl/RaftConfigurationImpl.java | 3 +-
.../apache/ratis/server/impl/RaftServerImpl.java | 726 ++++++++++++---------
.../ratis/server/impl/RaftServerJmxAdapter.java | 97 ---
.../apache/ratis/server/impl/RaftServerProxy.java | 28 +-
.../org/apache/ratis/server/impl/RoleInfo.java | 60 +-
.../apache/ratis/server/impl/ServerImplUtils.java | 55 +-
.../apache/ratis/server/impl/ServerProtoUtils.java | 4 -
.../org/apache/ratis/server/impl/ServerState.java | 33 +-
.../server/impl/SnapshotInstallationHandler.java | 41 +-
.../ratis/server/impl/StateMachineUpdater.java | 22 +-
.../ratis/server/impl/TransactionManager.java | 54 +-
.../apache/ratis/server/impl/WatchRequests.java | 24 +-
.../server/leader/InstallSnapshotRequests.java | 102 +--
.../ratis/server/leader/LogAppenderBase.java | 65 +-
.../ratis/server/leader/LogAppenderDefault.java | 33 +-
.../server/metrics/LeaderElectionMetrics.java | 1 -
.../server/metrics/RaftServerMetricsImpl.java | 34 -
.../apache/ratis/server/raftlog/LogProtoUtils.java | 63 +-
.../apache/ratis/server/raftlog/RaftLogBase.java | 104 +--
.../ratis/server/raftlog/memory/MemoryRaftLog.java | 75 +--
.../raftlog/segmented/BufferedWriteChannel.java | 2 +
.../ratis/server/raftlog/segmented/LogSegment.java | 169 ++---
.../server/raftlog/segmented/LogSegmentPath.java | 23 +-
.../server/raftlog/segmented/SegmentedRaftLog.java | 89 +--
.../raftlog/segmented/SegmentedRaftLogCache.java | 26 +-
.../raftlog/segmented/SegmentedRaftLogWorker.java | 31 +-
.../server/storage/RaftStorageDirectoryImpl.java | 1 -
.../ratis/server/storage/SnapshotManager.java | 1 -
.../ratis/server/util/ServerStringUtils.java | 14 +-
.../ratis/statemachine/impl/BaseStateMachine.java | 9 +-
.../statemachine/impl/TransactionContextImpl.java | 56 +-
.../ratis/InstallSnapshotFromLeaderTests.java | 101 +--
.../ratis/InstallSnapshotNotificationTests.java | 24 +-
.../java/org/apache/ratis/LogAppenderTests.java | 1 -
.../org/apache/ratis/OutputStreamBaseTest.java | 2 +
.../org/apache/ratis/RaftAsyncExceptionTests.java | 2 +-
.../test/java/org/apache/ratis/RaftAsyncTests.java | 6 +-
.../test/java/org/apache/ratis/RaftBasicTests.java | 43 +-
.../org/apache/ratis/RaftExceptionBaseTest.java | 6 +-
.../test/java/org/apache/ratis/RaftTestUtil.java | 83 +--
.../org/apache/ratis/ReadOnlyRequestTests.java | 8 +-
.../java/org/apache/ratis/RetryCacheTests.java | 22 +-
.../java/org/apache/ratis/WatchRequestTests.java | 55 --
.../ratis/server/impl/GroupManagementBaseTest.java | 10 +-
.../ratis/server/impl/LeaderElectionTests.java | 172 ++---
.../apache/ratis/server/impl/MiniRaftCluster.java | 17 +-
.../server/impl/RaftReconfigurationBaseTest.java | 12 +-
.../ratis/server/impl/RaftServerTestUtil.java | 13 -
.../ratis/server/impl/RetryCacheTestUtil.java | 4 -
.../server/impl/StateMachineShutdownTests.java | 2 +-
.../ratis/server/impl/TestLogAppenderMetrics.java | 20 +-
.../ratis/server/impl/TestRetryCacheMetrics.java | 12 +-
.../server/metrics/TestLeaderElectionMetrics.java | 14 +-
.../ratis/server/simulation/RaftServerReply.java | 1 +
.../ratis/server/storage/RaftStorageTestUtils.java | 16 +-
.../ratis/statemachine/RaftSnapshotBaseTest.java | 3 +-
.../impl/SimpleStateMachine4Testing.java | 26 +-
ratis-shell/pom.xml | 2 +-
.../ratis/shell/cli/sh/group/GroupInfoCommand.java | 1 -
.../shell/cli/sh/local/RaftMetaConfCommand.java | 51 +-
ratis-test/pom.xml | 19 +-
.../org/apache/ratis/RaftLogTruncateTests.java | 95 +--
.../ratis/TestRaftServerNoLeaderTimeout.java | 28 +-
.../ratis/TestRaftServerSlownessDetection.java | 35 +-
.../apache/ratis/client/TestClientProtoUtils.java | 6 +-
.../java/org/apache/ratis/conf/TestConfUtils.java | 2 +-
.../org/apache/ratis/conf/TestRaftProperties.java | 45 +-
.../datastream/DataStreamAsyncClusterTests.java | 12 +-
.../ratis/datastream/DataStreamBaseTest.java | 16 +-
.../ratis/datastream/DataStreamClusterTests.java | 14 +-
.../ratis/datastream/DataStreamTestUtils.java | 61 +-
...usterWithRpcTypeGrpcAndDataStreamTypeNetty.java | 1 +
.../ratis/datastream/TestDataStreamDisabled.java | 10 +-
...amSslWithRpcTypeGrpcAndDataStreamTypeNetty.java | 10 +-
...ettyDataStreamChainTopologyWithGrpcCluster.java | 4 +-
...NettyDataStreamStarTopologyWithGrpcCluster.java | 4 +-
.../datastream/TestNettyDataStreamWithMock.java | 20 +-
.../TestNettyDataStreamWithNettyCluster.java | 5 +-
.../org/apache/ratis/grpc/TestGrpcFactory.java | 8 +-
.../apache/ratis/grpc/TestGrpcMessageMetrics.java | 6 +-
.../ratis/grpc/TestLeaderElectionWithGrpc.java | 4 +-
.../ratis/grpc/TestLeaderInstallSnapshot.java | 29 +-
.../apache/ratis/grpc/TestLogAppenderWithGrpc.java | 35 +-
.../ratis/grpc/TestRaftOutputStreamWithGrpc.java | 6 +-
.../apache/ratis/grpc/TestRaftServerWithGrpc.java | 94 ++-
.../ratis/grpc/TestRaftSnapshotWithGrpc.java | 8 +-
.../org/apache/ratis/grpc/TestRaftWithGrpc.java | 42 +-
.../apache/ratis/grpc/TestRetryCacheWithGrpc.java | 14 +-
.../ratis/grpc/server/TestGrpcServerMetrics.java | 26 +-
.../org/apache/ratis/grpc/util/GrpcTestClient.java | 6 +-
.../org/apache/ratis/grpc/util/GrpcTestServer.java | 23 +-
.../ratis/grpc/util/GrpcZeroCopyTestClient.java | 43 +-
.../ratis/grpc/util/GrpcZeroCopyTestServer.java | 14 +-
.../apache/ratis/grpc/util/TestGrpcZeroCopy.java | 36 +-
.../grpc/util/TestStreamObserverWithTimeout.java | 33 +-
.../ratis/netty/TestLeaderElectionWithNetty.java | 4 +-
.../org/apache/ratis/netty/TestRaftWithNetty.java | 2 +-
.../apache/ratis/netty/TestTlsConfWithNetty.java | 8 +-
.../org/apache/ratis/protocol/TestRaftGroup.java | 16 +-
.../java/org/apache/ratis/protocol/TestRaftId.java | 28 +-
.../apache/ratis/protocol/TestRoutingTable.java | 14 +-
.../ratis/retry/TestExceptionDependentRetry.java | 33 +-
.../ratis/retry/TestExponentialBackoffRetry.java | 14 +-
.../ratis/retry/TestMultipleLinearRandomRetry.java | 18 +-
.../org/apache/ratis/retry/TestRetryPolicy.java | 40 +-
.../apache/ratis/security/SecurityTestUtils.java | 12 +-
.../org/apache/ratis/server/ServerBuilderTest.java | 8 +-
.../apache/ratis/server/ServerRestartTests.java | 48 +-
.../ratis/server/TestRaftServerConfigKeys.java | 24 +-
.../ratis/server/impl/TestPeerConfiguration.java | 6 +-
.../ratis/server/impl/TestRaftConfiguration.java | 28 +-
.../ratis/server/impl/TestRaftServerJmx.java | 27 +-
.../ratis/server/raftlog/TestRaftLogIndex.java | 12 +-
.../ratis/server/raftlog/TestRaftLogMetrics.java | 44 +-
.../server/raftlog/memory/MemoryRaftLogTest.java | 13 +-
.../segmented/TestBufferedWriteChannel.java | 15 +-
.../raftlog/segmented/TestCacheEviction.java | 91 ++-
.../server/raftlog/segmented/TestLogSegment.java | 106 ++-
.../raftlog/segmented/TestRaftLogReadWrite.java | 36 +-
.../raftlog/segmented/TestSegmentedRaftLog.java | 209 +++---
.../segmented/TestSegmentedRaftLogCache.java | 124 ++--
.../ratis/server/storage/TestRaftStorage.java | 150 ++---
.../ratis/server/storage/TestStorageImplUtils.java | 34 +-
.../cli/sh/ElectionCommandIntegrationTest.java | 44 +-
.../shell/cli/sh/GroupCommandIntegrationTest.java | 61 +-
.../shell/cli/sh/LocalCommandIntegrationTest.java | 147 -----
.../shell/cli/sh/PeerCommandIntegrationTest.java | 16 +-
.../cli/sh/SnapshotCommandIntegrationTest.java | 18 +-
.../apache/ratis/shell/cli/sh/TestRatisShell.java | 12 +-
.../ratis/statemachine/TestStateMachine.java | 16 +-
.../apache/ratis/util/TestDataBlockingQueue.java | 33 +-
.../java/org/apache/ratis/util/TestDataQueue.java | 73 +--
.../java/org/apache/ratis/util/TestExitUtils.java | 31 +-
.../java/org/apache/ratis/util/TestLifeCycle.java | 19 +-
.../java/org/apache/ratis/util/TestMinMax.java | 16 +-
.../org/apache/ratis/util/TestPeerProxyMap.java | 15 +-
.../org/apache/ratis/util/TestPreconditions.java | 9 +-
.../ratis/util/TestReferenceCountedObject.java | 45 +-
.../apache/ratis/util/TestResourceSemaphore.java | 14 +-
.../org/apache/ratis/util/TestTimeDuration.java | 60 +-
.../apache/ratis/util/TestTimeoutScheduler.java | 134 ++--
.../ratis/util/TestTraditionalBinaryPrefix.java | 20 +-
ratis-tools/pom.xml | 2 +-
.../java/org/apache/ratis/tools/ParseRatisLog.java | 7 +-
263 files changed, 2992 insertions(+), 5697 deletions(-)
delete mode 100755 dev-support/checks/coverage.sh
delete mode 100644
ratis-common/src/main/java/org/apache/ratis/util/LeakDetector.java
delete mode 100644
ratis-common/src/main/java/org/apache/ratis/util/ReferenceCountedLeakDetector.java
delete mode 100644
ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/ZeroCopyMetrics.java
copy
ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/intercept/server/{MetricServerCall.java
=> MetricServerCallListener.java} (57%)
copy {ratis-common/src/main/java/org/apache/ratis/util =>
ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl}/RefCountingMap.java
(88%)
copy {ratis-common/src/test/java/org/apache/ratis/util =>
ratis-metrics-default/src/test/java/org/apache/ratis/metrics/impl}/TestRefCountingMap.java
(86%)
rename {ratis-common/src/main/java/org/apache/ratis/util =>
ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3}/RefCountingMap.java
(88%)
rename {ratis-common/src/test/java/org/apache/ratis/util =>
ratis-metrics-dropwizard3/src/test/java/org/apache/ratis/metrics/dropwizard3}/TestRefCountingMap.java
(86%)
delete mode 100644
ratis-netty/src/main/java/org/apache/ratis/netty/server/ChannelMap.java
rename {ratis-common/src/main/java/org/apache/ratis/datastream/impl =>
ratis-netty/src/main/java/org/apache/ratis/netty/server}/DataStreamRequestByteBuf.java
(96%)
delete mode 100644
ratis-netty/src/main/java/org/apache/ratis/netty/server/StreamMap.java
delete mode 100644
ratis-server-api/src/main/java/org/apache/ratis/server/ServerRpc.java
delete mode 100644
ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerJmxAdapter.java
delete mode 100644
ratis-test/src/test/java/org/apache/ratis/shell/cli/sh/LocalCommandIntegrationTest.java
