This is an automated email from the ASF dual-hosted git repository.
williamsong pushed a change to branch release-3.1.0
in repository https://gitbox.apache.org/repos/asf/ratis.git
omit bfd029cf4 Change version for the version 3.1.0 -rc0
omit 924a0cdf4 RATIS-2084. Follower reply ALREADY_INSTALLED when install
old snapshots from leader (#1091)
omit bd4ab145d RATIS-2102. AsyncApi#send() is not handling retry and reply
correctly for replication levels higher than MAJORITY (#1104)
omit dd75ffbfb RATIS-2089. Add CommitInfoProto in NotReplicatedException
(#1105)
omit 640749bb3 RATIS-2100. The `closeFuture` never completed while closing
from the `NEW` state (#1102)
omit 93eb32a86 RATIS-2101. Move TermIndex.PRIVATE_CACHE to Util.CACHE
(#1103)
omit e0025875e RATIS-2093. Decouple metadata and configuration entries from
appendEntries buffer for stateMachineCache' (#1096)
omit 26385f31a RATIS-2096. Add a conf to enable/disable zero copy. (#1099)
omit 1782cd9f1 RATIS-2099. Cache TermIndexImpl instead of using anonymous
class (#1100)
omit 64ae88f01 RATIS-2097 Add a conf to enable/disable Metadata entries.
(#1101)
omit 53d5af75a RATIS-2092. Add metrics to expose number of zero-copy
unclosed messages (#1095)
omit 16f2508d0 RATIS-2098. RaftLogTruncateTests may fail. (#1097)
omit 8c7c444ca RATIS-2081. Comment that we skip checkstyle on test
directory on purpose (#1084)
omit 9cfd1bf71 RATIS-2091. Fix other checkstyle issues in test-directory
(#1094)
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)
add be63821f4 RATIS-1991. Optimize the reconfig judgment logic in the
ReconfigurationBase class. (#1004)
add 85a049586 RATIS-1983. Refactor client request processing to support
reference count. (#998)
add beb6ff386 RATIS-1994. AsyncApi send() to support optional replication
level. (#1006)
add 1514b94bb RATIS-1998. Add watch request metrics (#1009)
add 64a760af8 RATIS-1989. Intermittent timeout in
TestStreamObserverWithTimeout (#1012)
add 116e26551 RATIS-1987. Intermittent NPE in TestGrpcZeroCopy. (#1013)
add 0976ff0c0 RATIS-1999. Move RaftServerJmxAdapter out from
RaftServerImpl. (#1010)
add 54bf00125 RATIS-2001. TransactionContext can be wrongly reused. (#1015)
add d551886a6 RATIS-2005. Fix URF_UNREAD_FIELD in MetricServerCallListener
(#1018)
add 7e27ea34e RATIS-2006. Fix DM_EXIT in filestore Client (#1019)
add 92f34c45f RATIS-2002. Fix findbugs warnings in LogSegmentPath (#1017)
add 2d47771b3 RATIS-2003. Fix IT_NO_SUCH_ELEMENT in
InstallSnapshotRequests (#1016)
add 6a528f594 RATIS-2004. Fix EQ_COMPARETO_USE_OBJECT_EQUALS in LogSegment
(#1020)
add 975ee8d2f RATIS-2010. Remove dependency on spotbugs-annotations (#1022)
add 95a176ea8 RATIS-2013. OrderedAsync retry results an
IllegalStateException in GrpcClientProtocolService. (#1026)
add 2a73d1226 RATIS-1972. Add junit 5 dependencies in ratis-server. (#1003)
add 4640d0214 RATIS-2012. Client should not retry after close. (#1025)
add 0a199ec59 RATIS-2008. Follower should recognize candidate if the
candidate is the same peer as the current valid leader (#1024)
add e8b883eeb RATIS-2015. Node.js 16 actions are deprecated (#1028)
add 044e51a4d RATIS-2011. When a log entry is truncated, remove
TransactionContext. (#1029)
add 851f771c6 RATIS-2017: checkAndEvictCache must be done in writeLock.
(#1031)
add 3c2c0bbd1 RATIS-2016. Correct NotificationInstallSnapshot's index
(#1030)
add 134976af9 RATIS-1974. Migrate ratis-metrics-default tests to Junit 5
(#1034)
add c3ef39278 RATIS-1973. Migrate ratis-examples tests to Junit 5. (#1035)
add efd651cda RATIS-2019 Fixed abnormal exit of StateMachineUpdater (#1033)
add 4b2531c89 RATIS-1975. Migrate ratis-metrics-dropwizard3 tests to Junit
5. (#1037)
add fb17caf38 RATIS-1976. Migrate ratis-test tests to Junit 5 - Part 1
(#1038)
add b5115a70a RATIS-2023. Remove duplicate RefCountingMap (#1039)
add ee0038bb7 RATIS-2021. Migrate ratis-test tests to Junit 5 - Part 2.
(#1043)
add 1db425cda RATIS-2038. IllegalStateException when ServerState is closed
before start. (#1048)
add 8a74750cc RATIS-2044. Fix ReadIndex loss caused by data race in
AppendEntriesListeners (#1052)
add 7710a7126 RATIS-2045. SnapshotInstallationHandler doesn't notify
follower when snapshotIndex is -1 and firstAvailableLogIndex is 0 (#1053)
add 5b7726633 RATIS-2047. Avoid unnecessary warn log when creating raft
group (#1054)
add 4f6da6cf3 RATIS-2048. Fix SimpleStateMachineStorage potential NPE
exception (#1056)
add a072e83f7 RATIS-2036. Avoid trigger snapshot when removing raftGroup
(#1055)
add 7bbf37520 RATIS-2049. Suppress Sonar warning for volatile objects
(#1057)
add 4c4e2de9c RATIS-2050. Add creationGap param to snapshot management API
(#1058)
add 9f5d1dce3 RATIS-2052. Add docs for triggering snapshot when removing
raftGroup parameter. (#1061)
add bb2260e84 RATIS-2056. Update purge index when snapshot installed.
(#1065)
add 39fc27b0c RATIS-2057. Add back JavaUtils.attemptUntilTrue(..). (#1066)
add 7afb6a844 RATIS-2060 Avoid unexpected shutdown of RaftServerProxy
during membership change (#1069)
add 7929fd149 RATIS-2061. Fix setCloseThreshold parameter in
RaftServerConfigKeys (#1070)
add 1c8b92289 RATIS-2065. Avoid the out-of-heap memory OOM phenomenon of
frequent creation and deletion of Raft group scenarios. (#1071)
add 9e1ee0cc8 RATIS-2070. Skip push build for dependabot (#1077)
add 1c653eab7 RATIS-2071. Bump Bouncy Castle to 1.78.1 (#1076)
add 8454a3a4c RATIS-2072. Limit timeout of CI workflow jobs (#1078)
add 9b9a206c2 RATIS-2073. Enable Surefire process checkers (#1079)
add 9fa30e1b5 RATIS-2067. Enhance content for concept in ratis-docs.
(#1073)
add 6f85c6689 RATIS-2074. Intermittent fork timeout in
TestRaftWithNetty#testBasicAppendEntriesKillLeader. (#1080)
add 1e322389e RATIS-2078. Correct timeout unit for tests (#1083)
add d04bfcdb1 RATIS-2085. Compile Ratis with JDK 17/21 in CI (#1087)
add 6c3a120ab RATIS-2083. Timer thread leak when log level is DEBUG (#1086)
add 1110a9510 RATIS-2090. Bump ratis-thirdparty to 1.0.6 (#1093)
add 5ac4c58a3 RATIS-2066. RaftServerProxy supports close callback (#1072)
add 12db83fdb RATIS-2097 Add a conf to enable/disable Metadata entries.
(#1101)
add d9f2ac93f RATIS-2099. Cache TermIndexImpl instead of using anonymous
class (#1100)
add 543b7d391 RATIS-2101. Move TermIndex.PRIVATE_CACHE to Util.CACHE
(#1103)
add 890541c5f RATIS-2100. The `closeFuture` never completed while closing
from the `NEW` state (#1102)
add 5edfc438a RATIS-2089. Add CommitInfoProto in NotReplicatedException
(#1105)
add 98c3350c4 RATIS-2102. AsyncApi#send() is not handling retry and reply
correctly for replication levels higher than MAJORITY (#1104)
add aae246ac7 RATIS-2084. Follower reply ALREADY_INSTALLED when install
old snapshots from leader (#1091)
add f1725e244 RATIS-2106. Add configuration reference for RaftClient
(#1107)
add f3b9d123b RATIS-2109. RaftLogBase#updateCommitIndex should return true
only if commitIndex is increased (#1109)
add 2a0d56950 RATIS-2084. Follower reply ALREADY_INSTALLED when install
old snapshots from leader (#1091)
add 9ed4e3eca Change version for the version 3.1.0 -rc1
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 (bfd029cf4)
\
N -- N -- N refs/heads/release-3.1.0 (9ed4e3eca)
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.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 4 +-
.github/workflows/post-commit.yml | 5 +
pom.xml | 4 +-
.../apache/ratis/client/RaftClientConfigKeys.java | 7 +-
.../apache/ratis/client/impl/ClientProtoUtils.java | 4 +-
.../ratis/client/impl/DataStreamClientImpl.java | 7 +-
.../ratis/client/impl/OrderedStreamAsync.java | 4 -
.../org/apache/ratis/protocol/GroupInfoReply.java | 13 +-
.../protocol/RaftClientAsynchronousProtocol.java | 6 +-
.../apache/ratis/protocol/RaftClientRequest.java | 10 +-
.../java/org/apache/ratis/util/LeakDetector.java | 140 ------
.../java/org/apache/ratis/util/PeerProxyMap.java | 1 -
.../java/org/apache/ratis/util/Preconditions.java | 5 -
.../ratis/util/ReferenceCountedLeakDetector.java | 222 ---------
.../apache/ratis/util/ReferenceCountedObject.java | 81 ++--
.../java/org/apache/ratis/util/SlidingWindow.java | 28 +-
.../src/test/java/org/apache/ratis/BaseTest.java | 4 +-
.../org/apache/ratis/util/TestRefCountingMap.java | 1 +
ratis-docs/src/site/markdown/cli.md | 2 +-
ratis-docs/src/site/markdown/configurations.md | 63 ++-
.../arithmetic/ArithmeticStateMachine.java | 2 +-
.../counter/server/CounterStateMachine.java | 2 +-
.../apache/ratis/examples/filestore/FileInfo.java | 3 +-
.../examples/filestore/FileStoreStateMachine.java | 11 +-
.../ratis/examples/ParameterizedBaseTest.java | 8 +-
.../ratis/examples/arithmetic/TestArithmetic.java | 3 +-
.../examples/arithmetic/TestArithmeticLogDump.java | 8 +-
.../ratis/examples/common/TestSubCommand.java | 3 +
.../ratis/examples/filestore/FileStoreWriter.java | 2 +-
.../TestFileStoreStreamingWithGrpcCluster.java | 3 +-
.../java/org/apache/ratis/grpc/GrpcConfigKeys.java | 9 -
.../main/java/org/apache/ratis/grpc/GrpcUtil.java | 34 +-
.../apache/ratis/grpc/metrics/ZeroCopyMetrics.java | 79 ----
.../grpc/server/GrpcClientProtocolService.java | 154 ++-----
.../apache/ratis/grpc/server/GrpcLogAppender.java | 30 +-
.../grpc/server/GrpcServerProtocolService.java | 145 ++----
.../org/apache/ratis/grpc/server/GrpcService.java | 24 +-
.../ratis/grpc/util/ZeroCopyMessageMarshaller.java | 12 +-
.../apache/ratis/grpc/MiniRaftClusterWithGrpc.java | 36 +-
.../ratis/metrics/TestMetricRegistriesLoader.java | 2 +-
.../apache/ratis/netty/NettyDataStreamUtils.java | 16 +-
.../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/src/main/proto/Raft.proto | 10 -
.../apache/ratis/server/DataStreamServerRpc.java | 10 +-
.../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 | 49 --
.../ratis/statemachine/TransactionContext.java | 34 +-
.../ratis/server/impl/ConfigurationManager.java | 2 -
.../apache/ratis/server/impl/FollowerState.java | 1 -
.../apache/ratis/server/impl/LeaderElection.java | 2 +-
.../org/apache/ratis/server/impl/LeaderLease.java | 2 +-
.../apache/ratis/server/impl/LeaderStateImpl.java | 17 +-
.../ratis/server/impl/MessageStreamRequests.java | 45 +-
.../apache/ratis/server/impl/PendingRequest.java | 2 +-
.../ratis/server/impl/RaftConfigurationImpl.java | 3 +-
.../apache/ratis/server/impl/RaftServerImpl.java | 498 +++++++++++----------
.../apache/ratis/server/impl/RaftServerProxy.java | 14 +-
.../org/apache/ratis/server/impl/RoleInfo.java | 57 ---
.../apache/ratis/server/impl/ServerImplUtils.java | 55 +--
.../apache/ratis/server/impl/ServerProtoUtils.java | 4 -
.../org/apache/ratis/server/impl/ServerState.java | 27 +-
.../server/impl/SnapshotInstallationHandler.java | 33 +-
.../ratis/server/impl/StateMachineUpdater.java | 20 +-
.../ratis/server/leader/LogAppenderBase.java | 65 +--
.../ratis/server/leader/LogAppenderDefault.java | 33 +-
.../server/metrics/LeaderElectionMetrics.java | 1 -
.../apache/ratis/server/raftlog/LogProtoUtils.java | 47 +-
.../apache/ratis/server/raftlog/RaftLogBase.java | 107 +----
.../ratis/server/raftlog/memory/MemoryRaftLog.java | 75 +---
.../ratis/server/raftlog/segmented/LogSegment.java | 28 +-
.../server/raftlog/segmented/SegmentedRaftLog.java | 86 +---
.../raftlog/segmented/SegmentedRaftLogCache.java | 15 +-
.../raftlog/segmented/SegmentedRaftLogWorker.java | 25 +-
.../server/storage/RaftStorageDirectoryImpl.java | 1 -
.../ratis/server/storage/SnapshotManager.java | 1 -
.../ratis/server/util/ServerStringUtils.java | 14 +-
.../ratis/statemachine/impl/BaseStateMachine.java | 7 +-
.../statemachine/impl/TransactionContextImpl.java | 37 +-
.../ratis/InstallSnapshotFromLeaderTests.java | 9 +-
.../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 | 60 +--
.../org/apache/ratis/RaftExceptionBaseTest.java | 6 +-
.../test/java/org/apache/ratis/RaftTestUtil.java | 27 +-
.../org/apache/ratis/ReadOnlyRequestTests.java | 8 +-
.../java/org/apache/ratis/RetryCacheTests.java | 3 +-
.../java/org/apache/ratis/WatchRequestTests.java | 71 +--
.../server/impl/BlockRequestHandlingInjection.java | 2 +-
.../ratis/server/impl/GroupManagementBaseTest.java | 10 +-
.../ratis/server/impl/LeaderElectionTests.java | 14 +-
.../apache/ratis/server/impl/MiniRaftCluster.java | 101 ++---
.../server/impl/RaftReconfigurationBaseTest.java | 12 +-
.../ratis/server/impl/RaftServerTestUtil.java | 8 +-
.../ratis/server/impl/RetryCacheTestUtil.java | 6 +-
.../server/impl/StateMachineShutdownTests.java | 2 +-
.../ratis/server/impl/TestLogAppenderMetrics.java | 8 +-
.../MiniRaftClusterWithSimulatedRpc.java | 2 +-
.../ratis/server/simulation/RaftServerReply.java | 1 +
.../ratis/server/storage/RaftStorageTestUtils.java | 16 +-
.../ratis/statemachine/RaftSnapshotBaseTest.java | 3 +-
.../impl/SimpleStateMachine4Testing.java | 32 +-
.../ratis/shell/cli/sh/group/GroupInfoCommand.java | 1 -
.../shell/cli/sh/local/RaftMetaConfCommand.java | 51 +--
.../org/apache/ratis/RaftLogTruncateTests.java | 28 +-
.../ratis/TestRaftServerNoLeaderTimeout.java | 8 +-
.../ratis/TestRaftServerSlownessDetection.java | 8 +-
.../datastream/DataStreamAsyncClusterTests.java | 9 +-
.../ratis/datastream/DataStreamBaseTest.java | 24 +-
.../ratis/datastream/DataStreamTestUtils.java | 16 +-
...usterWithRpcTypeGrpcAndDataStreamTypeNetty.java | 9 +-
...sterWithRpcTypeNettyAndDataStreamTypeNetty.java | 5 +-
...amSslWithRpcTypeGrpcAndDataStreamTypeNetty.java | 8 +-
.../datastream/TestNettyDataStreamWithMock.java | 14 +-
.../apache/ratis/grpc/TestGrpcMessageMetrics.java | 6 +-
.../ratis/grpc/TestLeaderElectionWithGrpc.java | 2 +-
.../apache/ratis/grpc/TestRaftServerWithGrpc.java | 2 +-
.../apache/ratis/grpc/TestRetryCacheWithGrpc.java | 3 +-
.../ratis/grpc/util/GrpcZeroCopyTestServer.java | 4 +-
.../apache/ratis/grpc/util/TestGrpcZeroCopy.java | 20 +-
.../ratis/netty/TestLeaderElectionWithNetty.java | 2 +-
.../apache/ratis/netty/TestTlsConfWithNetty.java | 2 +-
.../apache/ratis/server/ServerRestartTests.java | 19 +-
.../ratis/server/TestRaftServerConfigKeys.java | 8 +-
.../ratis/server/impl/TestRaftConfiguration.java | 4 +-
.../ratis/server/impl/TestRaftServerJmx.java | 33 +-
.../ratis/server/raftlog/TestRaftLogMetrics.java | 15 +-
.../server/raftlog/memory/MemoryRaftLogTest.java | 9 +-
.../segmented/TestBufferedWriteChannel.java | 14 +-
.../raftlog/segmented/TestCacheEviction.java | 33 +-
.../server/raftlog/segmented/TestLogSegment.java | 7 +-
.../raftlog/segmented/TestSegmentedRaftLog.java | 54 +--
.../segmented/TestSegmentedRaftLogCache.java | 8 +-
.../ratis/server/storage/TestStorageImplUtils.java | 12 +-
.../shell/cli/sh/GroupCommandIntegrationTest.java | 49 --
.../shell/cli/sh/LocalCommandIntegrationTest.java | 149 ------
.../ratis/statemachine/TestStateMachine.java | 2 +-
.../java/org/apache/ratis/util/TestLifeCycle.java | 3 +-
.../java/org/apache/ratis/util/TestMinMax.java | 3 +-
153 files changed, 1222 insertions(+), 2926 deletions(-)
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
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-test/src/test/java/org/apache/ratis/shell/cli/sh/LocalCommandIntegrationTest.java
