You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by ms...@apache.org on 2019/12/06 04:08:36 UTC
[incubator-ratis] 01/01: Merge commit
'ce699ba3f36b034ff283a21de2645f98bb92a876' into ratis-ozone
This is an automated email from the ASF dual-hosted git repository.
msingh pushed a commit to branch ratis-ozone
in repository https://gitbox.apache.org/repos/asf/incubator-ratis.git
commit 222bbb7eab620dd59fbf11bad8a5114db19cb4b6
Merge: 401b691 ce699ba
Author: Mukul Kumar Singh <mu...@cloudera.com>
AuthorDate: Fri Dec 6 09:37:20 2019 +0530
Merge commit 'ce699ba3f36b034ff283a21de2645f98bb92a876' into ratis-ozone
LICENSE | 126 ++++++-----
dev-support/make_rc.sh | 175 +++++++++++----
pom.xml | 18 +-
.../org/apache/ratis/client/ClientRetryEvent.java | 56 +++++
.../org/apache/ratis/client/impl/OrderedAsync.java | 20 +-
.../apache/ratis/client/impl/RaftClientImpl.java | 18 +-
.../apache/ratis/client/impl/UnorderedAsync.java | 13 +-
.../retry/RequestTypeDependentRetryPolicy.java | 87 ++++++++
.../java/org/apache/ratis/conf/RaftProperties.java | 234 +++++----------------
.../src/main/java/org/apache/ratis/io/MD5Hash.java | 26 ++-
.../org/apache/ratis/protocol/GroupInfoReply.java | 1 +
.../ratis/protocol/GroupManagementRequest.java | 4 +-
.../java/org/apache/ratis/protocol/Message.java | 12 +-
.../org/apache/ratis/protocol/RaftClientReply.java | 6 +-
.../ratis/retry/MultipleLinearRandomRetry.java | 188 +++++++++++++++++
.../java/org/apache/ratis/retry/RetryPolicies.java | 113 ++--------
.../java/org/apache/ratis/retry/RetryPolicy.java | 51 +++--
.../org/apache/ratis/rpc/SupportedRpcType.java | 1 -
.../apache/ratis/util/AtomicFileOutputStream.java | 7 +-
.../java/org/apache/ratis/util/AtomicUtils.java | 7 +-
.../org/apache/ratis/util/AutoCloseableLock.java | 2 +-
.../ratis/util/AutoCloseableReadWriteLock.java | 10 +-
.../apache/ratis/util/CodeInjectionForTesting.java | 6 +-
.../org/apache/ratis/util/CollectionUtils.java | 6 +-
.../main/java/org/apache/ratis/util/DataQueue.java | 2 +-
.../main/java/org/apache/ratis/util/IOUtils.java | 2 +-
.../main/java/org/apache/ratis/util/LifeCycle.java | 44 ++--
.../main/java/org/apache/ratis/util/LogUtils.java | 12 --
.../java/org/apache/ratis/util/MD5FileUtil.java | 14 +-
.../org/apache/ratis/util/MemoizedSupplier.java | 2 +-
.../java/org/apache/ratis/util/NativeCrc32.java | 16 +-
.../apache/ratis/util/NativeLibraryChecker.java | 5 +-
.../main/java/org/apache/ratis/util/NetUtils.java | 8 +-
.../java/org/apache/ratis/util/ProtoUtils.java | 4 +-
.../org/apache/ratis/util/ResourceSemaphore.java | 117 ++++++++++-
.../java/org/apache/ratis/util/SizeInBytes.java | 2 +-
.../java/org/apache/ratis/util/StringUtils.java | 5 +-
.../java/org/apache/ratis/util/TimeDuration.java | 114 +++++++++-
.../apache/ratis/util/TraditionalBinaryPrefix.java | 8 +-
.../ratis/util/function/CheckedBiFunction.java | 20 +-
.../src/test/java/org/apache/ratis/BaseTest.java | 6 +-
.../java/org/apache/ratis/util/Log4jUtils.java | 23 +-
ratis-examples/pom.xml | 15 ++
.../org/apache/ratis/examples/common/Runner.java | 17 +-
ratis-examples/src/main/resources/log4j.properties | 2 +
.../java/org/apache/ratis/TestMultiRaftGroup.java | 4 +-
.../ratis/examples/arithmetic/TestArithmetic.java | 4 +-
ratis-grpc/pom.xml | 4 +
.../ratis/grpc/metrics/GrpcServerMetrics.java | 17 +-
.../apache/ratis/grpc/server/GrpcLogAppender.java | 33 +--
ratis-hadoop/pom.xml | 4 +
.../hadooprpc/TestLeaderElectionWithHadoopRpc.java | 4 +-
.../ratis/hadooprpc/TestRaftWithHadoopRpc.java | 4 +-
ratis-logservice/pom.xml | 4 +
ratis-metrics/pom.xml | 4 +
ratis-netty/pom.xml | 4 +
.../java/org/apache/ratis/netty/NettyClient.java | 3 +-
ratis-proto/src/main/proto/Raft.proto | 1 +
ratis-replicated-map/pom.xml | 4 +
ratis-server/pom.xml | 9 +
.../apache/ratis/server/RaftServerConfigKeys.java | 10 +
.../org/apache/ratis/server/impl/FollowerInfo.java | 3 +-
.../apache/ratis/server/impl/FollowerState.java | 3 -
.../org/apache/ratis/server/impl/LeaderState.java | 11 +-
.../org/apache/ratis/server/impl/LogAppender.java | 4 +-
.../apache/ratis/server/impl/PendingRequests.java | 53 +++--
.../apache/ratis/server/impl/RaftServerImpl.java | 28 +--
.../ratis/server/impl/RaftServerMetrics.java | 23 +-
.../apache/ratis/server/impl/ServerProtoUtils.java | 5 +-
.../org/apache/ratis/server/impl/ServerState.java | 2 +-
.../ratis/server/impl/StateMachineMetrics.java | 10 +
.../ratis/server/impl/StateMachineUpdater.java | 10 +-
.../ratis/server/metrics/LogAppenderMetrics.java | 47 +++++
.../ratis/server/metrics/RaftLogMetrics.java | 6 +-
.../ratis/server/metrics/RatisMetricNames.java | 33 ++-
.../apache/ratis/server/metrics/RatisMetrics.java | 7 +
.../org/apache/ratis/server/raftlog/RaftLog.java | 10 +-
.../raftlog/segmented/SegmentedRaftLogWorker.java | 4 +-
.../ratis/statemachine/impl/BaseStateMachine.java | 18 +-
.../ratis/InstallSnapshotNotificationTests.java | 4 +-
.../java/org/apache/ratis/LogAppenderTests.java | 4 +-
.../org/apache/ratis/RaftAsyncExceptionTests.java | 4 +-
.../test/java/org/apache/ratis/RaftAsyncTests.java | 62 +++---
.../test/java/org/apache/ratis/RaftBasicTests.java | 10 +-
.../org/apache/ratis/RaftExceptionBaseTest.java | 8 +-
.../apache/ratis/RequestLimitAsyncBaseTest.java | 6 +-
.../java/org/apache/ratis/RetryCacheTests.java | 4 +-
.../java/org/apache/ratis/WatchRequestTests.java | 13 +-
.../ratis/server/impl/GroupInfoBaseTest.java | 6 +-
.../ratis/server/impl/GroupManagementBaseTest.java | 8 +-
.../ratis/server/impl/LeaderElectionTests.java | 6 +-
.../server/impl/RaftReconfigurationBaseTest.java | 4 +-
.../ratis/server/impl/RaftServerTestUtil.java | 6 +-
.../impl/RaftStateMachineExceptionTests.java | 8 +-
.../server/impl/StateMachineShutdownTests.java | 2 +
.../ratis/server/impl/TestLogAppenderMetrics.java | 86 ++++++++
.../segmented/SegmentedRaftLogTestUtils.java | 4 +-
.../ratis/statemachine/RaftSnapshotBaseTest.java | 32 ++-
.../statemachine/SimpleStateMachine4Testing.java | 4 +-
ratis-test/pom.xml | 9 +
.../ratis/TestRaftServerNoLeaderTimeout.java | 6 +-
.../ratis/TestRaftServerSlownessDetection.java | 4 +-
.../apache/ratis/client/TestClientProtoUtils.java | 97 +++++++++
.../apache/ratis/grpc/TestGrpcOutputStream.java | 4 +-
.../ratis/grpc/TestRaftOutputStreamWithGrpc.java | 4 +-
.../apache/ratis/grpc/TestRaftServerWithGrpc.java | 6 +-
.../ratis/grpc/TestRaftSnapshotWithGrpc.java | 21 ++
.../ratis/grpc/TestWatchRequestWithGrpc.java | 10 +-
.../ratis/retry/TestMultipleLinearRandomRetry.java | 85 ++++++++
.../apache/ratis/{ => retry}/TestRetryPolicy.java | 57 +++--
.../apache/ratis/server/ServerRestartTests.java | 4 +-
.../ratis/server/raftlog/TestRaftLogMetrics.java | 2 +-
.../raftlog/segmented/TestSegmentedRaftLog.java | 25 ++-
.../ratis/statemachine/TestStateMachine.java | 7 +-
.../apache/ratis/util/TestResourceSemaphore.java | 65 ++++++
.../org/apache/ratis/util/TestTimeDuration.java | 114 +++++++++-
.../apache/ratis/util/TestTimeoutScheduler.java | 2 +-
117 files changed, 2020 insertions(+), 798 deletions(-)