Path Lines of Code dev-support/intellij/runConfigurations/ExampleServer1.xml 16 dev-support/intellij/runConfigurations/ExampleServer2.xml 16 dev-support/intellij/runConfigurations/ExampleServer3.xml 16 dev-support/vagrant/namazu_configs/hdd_config.toml 23 ratis-assembly/src/main/assembly/bin.xml 119 ratis-client/src/main/java/org/apache/ratis/client/AsyncRpcApi.java 8 ratis-client/src/main/java/org/apache/ratis/client/ClientFactory.java 15 ratis-client/src/main/java/org/apache/ratis/client/DataStreamClient.java 77 ratis-client/src/main/java/org/apache/ratis/client/DataStreamClientFactory.java 17 ratis-client/src/main/java/org/apache/ratis/client/DataStreamClientRpc.java 12 ratis-client/src/main/java/org/apache/ratis/client/DataStreamOutputRpc.java 7 ratis-client/src/main/java/org/apache/ratis/client/DataStreamRpcApi.java 7 ratis-client/src/main/java/org/apache/ratis/client/DisabledDataStreamClientFactory.java 19 ratis-client/src/main/java/org/apache/ratis/client/RaftClient.java 106 ratis-client/src/main/java/org/apache/ratis/client/RaftClientConfigKeys.java 119 ratis-client/src/main/java/org/apache/ratis/client/RaftClientRpc.java 26 ratis-client/src/main/java/org/apache/ratis/client/api/AdminApi.java 39 ratis-client/src/main/java/org/apache/ratis/client/api/AsyncApi.java 24 ratis-client/src/main/java/org/apache/ratis/client/api/BlockingApi.java 17 ratis-client/src/main/java/org/apache/ratis/client/api/DataStreamApi.java 11 ratis-client/src/main/java/org/apache/ratis/client/api/DataStreamOutput.java 26 ratis-client/src/main/java/org/apache/ratis/client/api/GroupManagementApi.java 16 ratis-client/src/main/java/org/apache/ratis/client/api/LeaderElectionManagementApi.java 7 ratis-client/src/main/java/org/apache/ratis/client/api/MessageOutputStream.java 11 ratis-client/src/main/java/org/apache/ratis/client/api/MessageStreamApi.java 13 ratis-client/src/main/java/org/apache/ratis/client/api/SnapshotManagementApi.java 12 ratis-client/src/main/java/org/apache/ratis/client/impl/AdminImpl.java 33 ratis-client/src/main/java/org/apache/ratis/client/impl/AsyncImpl.java 53 ratis-client/src/main/java/org/apache/ratis/client/impl/BlockingImpl.java 122 ratis-client/src/main/java/org/apache/ratis/client/impl/ClientImplUtils.java 30 ratis-client/src/main/java/org/apache/ratis/client/impl/ClientProtoUtils.java 652 ratis-client/src/main/java/org/apache/ratis/client/impl/DataStreamClientImpl.java 228 ratis-client/src/main/java/org/apache/ratis/client/impl/GroupManagementImpl.java 57 ratis-client/src/main/java/org/apache/ratis/client/impl/LeaderElectionManagementImpl.java 28 ratis-client/src/main/java/org/apache/ratis/client/impl/MessageStreamImpl.java 68 ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedAsync.java 209 ratis-client/src/main/java/org/apache/ratis/client/impl/OrderedStreamAsync.java 126 ratis-client/src/main/java/org/apache/ratis/client/impl/RaftClientImpl.java 372 ratis-client/src/main/java/org/apache/ratis/client/impl/RaftClientRpcWithProxy.java 29 ratis-client/src/main/java/org/apache/ratis/client/impl/RaftOutputStream.java 98 ratis-client/src/main/java/org/apache/ratis/client/impl/SnapshotManagementImpl.java 24 ratis-client/src/main/java/org/apache/ratis/client/impl/UnorderedAsync.java 109 ratis-client/src/main/java/org/apache/ratis/client/retry/ClientRetryEvent.java 47 ratis-client/src/main/java/org/apache/ratis/client/retry/RequestTypeDependentRetryPolicy.java 70 ratis-common/src/main/java/org/apache/ratis/RaftConfigKeys.java 49 ratis-common/src/main/java/org/apache/ratis/conf/ConfUtils.java 413 ratis-common/src/main/java/org/apache/ratis/conf/Parameters.java 23 ratis-common/src/main/java/org/apache/ratis/conf/RaftProperties.java 341 ratis-common/src/main/java/org/apache/ratis/conf/Reconfigurable.java 10 ratis-common/src/main/java/org/apache/ratis/conf/ReconfigurationBase.java 116 ratis-common/src/main/java/org/apache/ratis/conf/ReconfigurationException.java 26 ratis-common/src/main/java/org/apache/ratis/conf/ReconfigurationStatus.java 81 ratis-common/src/main/java/org/apache/ratis/datastream/DataStreamFactory.java 3 ratis-common/src/main/java/org/apache/ratis/datastream/DataStreamType.java 32 ratis-common/src/main/java/org/apache/ratis/datastream/SupportedDataStreamType.java 33 ratis-common/src/main/java/org/apache/ratis/datastream/impl/DataStreamPacketByteBuffer.java 20 ratis-common/src/main/java/org/apache/ratis/datastream/impl/DataStreamPacketImpl.java 42 ratis-common/src/main/java/org/apache/ratis/datastream/impl/DataStreamReplyByteBuffer.java 103 ratis-common/src/main/java/org/apache/ratis/datastream/impl/DataStreamRequestByteBuf.java 48 ratis-common/src/main/java/org/apache/ratis/datastream/impl/DataStreamRequestByteBuffer.java 19 ratis-common/src/main/java/org/apache/ratis/datastream/impl/DataStreamRequestFilePositionCount.java 26 ratis-common/src/main/java/org/apache/ratis/io/CloseAsync.java 14 ratis-common/src/main/java/org/apache/ratis/io/CorruptedFileException.java 8 ratis-common/src/main/java/org/apache/ratis/io/FilePositionCount.java 24 ratis-common/src/main/java/org/apache/ratis/io/MD5Hash.java 142 ratis-common/src/main/java/org/apache/ratis/io/StandardWriteOption.java 6 ratis-common/src/main/java/org/apache/ratis/io/WriteOption.java 21 ratis-common/src/main/java/org/apache/ratis/protocol/AdminAsynchronousProtocol.java 14 ratis-common/src/main/java/org/apache/ratis/protocol/AdminProtocol.java 13 ratis-common/src/main/java/org/apache/ratis/protocol/ClientId.java 34 ratis-common/src/main/java/org/apache/ratis/protocol/ClientInvocationId.java 51 ratis-common/src/main/java/org/apache/ratis/protocol/DataStreamPacket.java 9 ratis-common/src/main/java/org/apache/ratis/protocol/DataStreamPacketHeader.java 23 ratis-common/src/main/java/org/apache/ratis/protocol/DataStreamReply.java 8 ratis-common/src/main/java/org/apache/ratis/protocol/DataStreamReplyHeader.java 30 ratis-common/src/main/java/org/apache/ratis/protocol/DataStreamRequest.java 10 ratis-common/src/main/java/org/apache/ratis/protocol/DataStreamRequestHeader.java 23 ratis-common/src/main/java/org/apache/ratis/protocol/GroupInfoReply.java 48 ratis-common/src/main/java/org/apache/ratis/protocol/GroupInfoRequest.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/GroupListReply.java 17 ratis-common/src/main/java/org/apache/ratis/protocol/GroupListRequest.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/GroupManagementRequest.java 83 ratis-common/src/main/java/org/apache/ratis/protocol/LeaderElectionManagementRequest.java 44 ratis-common/src/main/java/org/apache/ratis/protocol/Message.java 40 ratis-common/src/main/java/org/apache/ratis/protocol/RaftClientAsynchronousProtocol.java 21 ratis-common/src/main/java/org/apache/ratis/protocol/RaftClientMessage.java 41 ratis-common/src/main/java/org/apache/ratis/protocol/RaftClientProtocol.java 5 ratis-common/src/main/java/org/apache/ratis/protocol/RaftClientReply.java 174 ratis-common/src/main/java/org/apache/ratis/protocol/RaftClientRequest.java 367 ratis-common/src/main/java/org/apache/ratis/protocol/RaftGroup.java 66 ratis-common/src/main/java/org/apache/ratis/protocol/RaftGroupId.java 34 ratis-common/src/main/java/org/apache/ratis/protocol/RaftGroupMemberId.java 39 ratis-common/src/main/java/org/apache/ratis/protocol/RaftId.java 87 ratis-common/src/main/java/org/apache/ratis/protocol/RaftPeer.java 186 ratis-common/src/main/java/org/apache/ratis/protocol/RaftPeerId.java 64 ratis-common/src/main/java/org/apache/ratis/protocol/RaftRpcMessage.java 7 ratis-common/src/main/java/org/apache/ratis/protocol/RoutingTable.java 133 ratis-common/src/main/java/org/apache/ratis/protocol/SetConfigurationRequest.java 143 ratis-common/src/main/java/org/apache/ratis/protocol/SnapshotManagementRequest.java 41 ratis-common/src/main/java/org/apache/ratis/protocol/TransferLeadershipRequest.java 12 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/AlreadyClosedException.java 9 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/AlreadyExistsException.java 11 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ChecksumException.java 13 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/DataStreamException.java 10 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/GroupMismatchException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/LeaderNotReadyException.java 17 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/LeaderSteppingDownException.java 9 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/NotLeaderException.java 23 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/NotReplicatedException.java 34 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/RaftException.java 14 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/RaftRetryFailureException.java 14 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ReadException.java 9 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ReadIndexException.java 9 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ReconfigurationInProgressException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ReconfigurationTimeoutException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ResourceUnavailableException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/ServerNotReadyException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/SetConfigurationException.java 9 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/StaleReadException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/StateMachineException.java 32 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/StreamException.java 6 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/TimeoutIOException.java 11 ratis-common/src/main/java/org/apache/ratis/protocol/exceptions/TransferLeadershipException.java 9 ratis-common/src/main/java/org/apache/ratis/retry/ExceptionDependentRetry.java 73 ratis-common/src/main/java/org/apache/ratis/retry/ExponentialBackoffRetry.java 50 ratis-common/src/main/java/org/apache/ratis/retry/MultipleLinearRandomRetry.java 123 ratis-common/src/main/java/org/apache/ratis/retry/RetryPolicies.java 84 ratis-common/src/main/java/org/apache/ratis/retry/RetryPolicy.java 34 ratis-common/src/main/java/org/apache/ratis/rpc/CallId.java 23 ratis-common/src/main/java/org/apache/ratis/rpc/RpcFactory.java 3 ratis-common/src/main/java/org/apache/ratis/rpc/RpcType.java 32 ratis-common/src/main/java/org/apache/ratis/rpc/SupportedRpcType.java 22 ratis-common/src/main/java/org/apache/ratis/security/TlsConf.java 204 ratis-common/src/main/java/org/apache/ratis/util/AtomicFileOutputStream.java 63 ratis-common/src/main/java/org/apache/ratis/util/AutoCloseableLock.java 39 ratis-common/src/main/java/org/apache/ratis/util/AutoCloseableReadWriteLock.java 43 ratis-common/src/main/java/org/apache/ratis/util/AwaitForSignal.java 53 ratis-common/src/main/java/org/apache/ratis/util/AwaitToRun.java 72 ratis-common/src/main/java/org/apache/ratis/util/BatchLogger.java 87 ratis-common/src/main/java/org/apache/ratis/util/BiWeakValueCache.java 80 ratis-common/src/main/java/org/apache/ratis/util/CodeInjectionForTesting.java 36 ratis-common/src/main/java/org/apache/ratis/util/CollectionUtils.java 134 ratis-common/src/main/java/org/apache/ratis/util/ConcurrentUtils.java 113 ratis-common/src/main/java/org/apache/ratis/util/Daemon.java 35 ratis-common/src/main/java/org/apache/ratis/util/DataBlockingQueue.java 143 ratis-common/src/main/java/org/apache/ratis/util/DataQueue.java 126 ratis-common/src/main/java/org/apache/ratis/util/ExitUtils.java 96 ratis-common/src/main/java/org/apache/ratis/util/FileUtils.java 245 ratis-common/src/main/java/org/apache/ratis/util/IOUtils.java 151 ratis-common/src/main/java/org/apache/ratis/util/JavaUtils.java 228 ratis-common/src/main/java/org/apache/ratis/util/JmxRegister.java 45 ratis-common/src/main/java/org/apache/ratis/util/JvmPauseMonitor.java 157 ratis-common/src/main/java/org/apache/ratis/util/LeakDetector.java 124 ratis-common/src/main/java/org/apache/ratis/util/LifeCycle.java 198 ratis-common/src/main/java/org/apache/ratis/util/LogUtils.java 108 ratis-common/src/main/java/org/apache/ratis/util/LongMinMax.java 43 ratis-common/src/main/java/org/apache/ratis/util/MD5FileUtil.java 114 ratis-common/src/main/java/org/apache/ratis/util/MemoizedCheckedSupplier.java 41 ratis-common/src/main/java/org/apache/ratis/util/MemoizedSupplier.java 37 ratis-common/src/main/java/org/apache/ratis/util/NetUtils.java 127 ratis-common/src/main/java/org/apache/ratis/util/OpenCloseState.java 71 ratis-common/src/main/java/org/apache/ratis/util/PeerProxyMap.java 153 ratis-common/src/main/java/org/apache/ratis/util/PlatformUtils.java 38 ratis-common/src/main/java/org/apache/ratis/util/Preconditions.java 87 ratis-common/src/main/java/org/apache/ratis/util/ProtoUtils.java 199 ratis-common/src/main/java/org/apache/ratis/util/PureJavaCrc32C.java 622 ratis-common/src/main/java/org/apache/ratis/util/RefCountingMap.java 51 ratis-common/src/main/java/org/apache/ratis/util/ReferenceCountedLeakDetector.java 281 ratis-common/src/main/java/org/apache/ratis/util/ReferenceCountedObject.java 87 ratis-common/src/main/java/org/apache/ratis/util/ReflectionUtils.java 159 ratis-common/src/main/java/org/apache/ratis/util/ResourceSemaphore.java 121 ratis-common/src/main/java/org/apache/ratis/util/SizeInBytes.java 53 ratis-common/src/main/java/org/apache/ratis/util/SlidingWindow.java 363 ratis-common/src/main/java/org/apache/ratis/util/StringUtils.java 136 ratis-common/src/main/java/org/apache/ratis/util/TaskQueue.java 65 ratis-common/src/main/java/org/apache/ratis/util/TimeDuration.java 283 ratis-common/src/main/java/org/apache/ratis/util/TimeoutExecutor.java 17 ratis-common/src/main/java/org/apache/ratis/util/TimeoutScheduler.java 132 ratis-common/src/main/java/org/apache/ratis/util/TimeoutTimer.java 74 ratis-common/src/main/java/org/apache/ratis/util/Timestamp.java 63 ratis-common/src/main/java/org/apache/ratis/util/TraditionalBinaryPrefix.java 104 ratis-common/src/main/java/org/apache/ratis/util/UncheckedAutoCloseable.java 6 ratis-common/src/main/java/org/apache/ratis/util/WeakValueCache.java 37 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedBiConsumer.java 5 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedBiFunction.java 5 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedConsumer.java 12 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedFunction.java 5 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedFunctionWithTimeout.java 7 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedRunnable.java 12 ratis-common/src/main/java/org/apache/ratis/util/function/CheckedSupplier.java 5 ratis-common/src/main/java/org/apache/ratis/util/function/FunctionUtils.java 11 ratis-common/src/main/java/org/apache/ratis/util/function/StringSupplier.java 17 ratis-common/src/main/java/org/apache/ratis/util/function/TriConsumer.java 5 ratis-common/src/main/java/org/apache/ratis/util/function/UncheckedAutoCloseableSupplier.java 5 ratis-docs/src/site/site.xml 29 ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/client/ClientFlat.java 90 ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/client/ClientProto.java 87 ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/server/FileTransferFlatbufs.java 38 ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/server/FileTransferProtobufs.java 33 ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/server/ServerFlat.java 25 ratis-experiments/src/main/java/org/apache/ratis/experiments/flatbuffers/server/ServerProto.java 25 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/client/NettyClient.java 104 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/decoders/RequestDecoder.java 34 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/decoders/RequestDecoderComposite.java 38 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/decoders/ResponseDecoder.java 16 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/encoders/RequestEncoder.java 19 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/encoders/ResponseEncoder.java 18 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/objects/RequestData.java 29 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/objects/RequestDataComposite.java 18 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/objects/ResponseData.java 10 ratis-experiments/src/main/java/org/apache/ratis/experiments/nettyzerocopy/server/NettyServer.java 59 ratis-grpc/src/main/java/org/apache/ratis/grpc/GrpcConfigKeys.java 283 ratis-grpc/src/main/java/org/apache/ratis/grpc/GrpcFactory.java 109 ratis-grpc/src/main/java/org/apache/ratis/grpc/GrpcTlsConfig.java 95 ratis-grpc/src/main/java/org/apache/ratis/grpc/GrpcUtil.java 256 ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientProtocolClient.java 333 ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientProtocolProxy.java 77 ratis-grpc/src/main/java/org/apache/ratis/grpc/client/GrpcClientRpc.java 157 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/GrpcServerMetrics.java 92 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/MessageMetrics.java 54 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/ZeroCopyMetrics.java 48 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/intercept/client/MetricClientCall.java 22 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/intercept/client/MetricClientCallListener.java 27 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/intercept/client/MetricClientInterceptor.java 31 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/intercept/server/MetricServerCall.java 23 ratis-grpc/src/main/java/org/apache/ratis/grpc/metrics/intercept/server/MetricServerInterceptor.java 56 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcAdminProtocolService.java 80 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcClientProtocolService.java 368 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcLogAppender.java 799 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServerProtocolClient.java 113 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServerProtocolService.java 314 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServices.java 20 ratis-grpc/src/main/java/org/apache/ratis/grpc/server/GrpcServicesImpl.java 355 ratis-grpc/src/main/java/org/apache/ratis/grpc/util/ResponseNotifyClientInterceptor.java 43 ratis-grpc/src/main/java/org/apache/ratis/grpc/util/StreamObserverWithTimeout.java 102 ratis-grpc/src/main/java/org/apache/ratis/grpc/util/ZeroCopyMessageMarshaller.java 170 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/LongCounter.java 12 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/MetricRegistries.java 27 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/MetricRegistriesLoader.java 47 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/MetricRegistryFactory.java 4 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/MetricRegistryInfo.java 59 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/RatisMetricRegistry.java 9 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/RatisMetrics.java 67 ratis-metrics-api/src/main/java/org/apache/ratis/metrics/Timekeeper.java 21 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/DefaultTimekeeperImpl.java 17 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/JvmMetrics.java 26 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/MetricRegistriesImpl.java 101 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/MetricRegistryFactoryImpl.java 9 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/MetricsReporting.java 51 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/RatisMetricRegistryImpl.java 112 ratis-metrics-default/src/main/java/org/apache/ratis/metrics/impl/RatisObjectNameFactory.java 23 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3JvmMetrics.java 26 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3MetricRegistriesImpl.java 99 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3MetricRegistryFactoryImpl.java 9 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3MetricsReporting.java 51 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3RatisMetricRegistryImpl.java 112 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3RatisObjectNameFactory.java 23 ratis-metrics-dropwizard3/src/main/java/org/apache/ratis/metrics/dropwizard3/Dm3TimekeeperImpl.java 17 ratis-netty/src/main/java/org/apache/ratis/netty/NettyClient.java 49 ratis-netty/src/main/java/org/apache/ratis/netty/NettyConfigKeys.java 183 ratis-netty/src/main/java/org/apache/ratis/netty/NettyDataStreamFactory.java 31 ratis-netty/src/main/java/org/apache/ratis/netty/NettyDataStreamUtils.java 231 ratis-netty/src/main/java/org/apache/ratis/netty/NettyFactory.java 25 ratis-netty/src/main/java/org/apache/ratis/netty/NettyRpcProxy.java 165 ratis-netty/src/main/java/org/apache/ratis/netty/NettyUtils.java 162 ratis-netty/src/main/java/org/apache/ratis/netty/client/NettyClientReplies.java 137 ratis-netty/src/main/java/org/apache/ratis/netty/client/NettyClientRpc.java 106 ratis-netty/src/main/java/org/apache/ratis/netty/client/NettyClientStreamRpc.java 411 ratis-netty/src/main/java/org/apache/ratis/netty/metrics/NettyServerStreamRpcMetrics.java 105 ratis-netty/src/main/java/org/apache/ratis/netty/server/ChannelMap.java 24 ratis-netty/src/main/java/org/apache/ratis/netty/server/DataStreamManagement.java 460 ratis-netty/src/main/java/org/apache/ratis/netty/server/NettyRpcService.java 308 ratis-netty/src/main/java/org/apache/ratis/netty/server/NettyServerStreamRpc.java 270 ratis-netty/src/main/java/org/apache/ratis/netty/server/StreamMap.java 26 ratis-proto/src/main/proto/Examples.proto 71 ratis-proto/src/main/proto/Experiments.proto 33 ratis-proto/src/main/proto/Grpc.proto 61 ratis-proto/src/main/proto/Netty.proto 55 ratis-proto/src/main/proto/RMap.proto 161 ratis-proto/src/main/proto/Raft.proto 473 ratis-proto/src/main/proto/Test.proto 40 ratis-resource-bundle/src/main/resources/supplemental-models.xml 274 ratis-server-api/src/main/java/org/apache/ratis/server/DataStreamMap.java 10 ratis-server-api/src/main/java/org/apache/ratis/server/DataStreamServer.java 5 ratis-server-api/src/main/java/org/apache/ratis/server/DataStreamServerFactory.java 15 ratis-server-api/src/main/java/org/apache/ratis/server/DataStreamServerRpc.java 5 ratis-server-api/src/main/java/org/apache/ratis/server/DivisionInfo.java 31 ratis-server-api/src/main/java/org/apache/ratis/server/DivisionProperties.java 18 ratis-server-api/src/main/java/org/apache/ratis/server/RaftConfiguration.java 21 ratis-server-api/src/main/java/org/apache/ratis/server/RaftServer.java 163 ratis-server-api/src/main/java/org/apache/ratis/server/RaftServerConfigKeys.java 769 ratis-server-api/src/main/java/org/apache/ratis/server/RaftServerMXBean.java 11 ratis-server-api/src/main/java/org/apache/ratis/server/RaftServerRpc.java 25 ratis-server-api/src/main/java/org/apache/ratis/server/RaftServerRpcWithProxy.java 52 ratis-server-api/src/main/java/org/apache/ratis/server/RetryCache.java 23 ratis-server-api/src/main/java/org/apache/ratis/server/ServerFactory.java 19 ratis-server-api/src/main/java/org/apache/ratis/server/ServerRpc.java 8 ratis-server-api/src/main/java/org/apache/ratis/server/leader/FollowerInfo.java 35 ratis-server-api/src/main/java/org/apache/ratis/server/leader/LeaderState.java 26 ratis-server-api/src/main/java/org/apache/ratis/server/leader/LogAppender.java 108 ratis-server-api/src/main/java/org/apache/ratis/server/metrics/RaftLogMetrics.java 9 ratis-server-api/src/main/java/org/apache/ratis/server/metrics/RaftServerMetrics.java 4 ratis-server-api/src/main/java/org/apache/ratis/server/protocol/RaftServerAsynchronousProtocol.java 24 ratis-server-api/src/main/java/org/apache/ratis/server/protocol/RaftServerProtocol.java 17 ratis-server-api/src/main/java/org/apache/ratis/server/protocol/TermIndex.java 76 ratis-server-api/src/main/java/org/apache/ratis/server/raftlog/LogEntryHeader.java 52 ratis-server-api/src/main/java/org/apache/ratis/server/raftlog/RaftLog.java 71 ratis-server-api/src/main/java/org/apache/ratis/server/raftlog/RaftLogIOException.java 13 ratis-server-api/src/main/java/org/apache/ratis/server/raftlog/RaftLogIndex.java 66 ratis-server-api/src/main/java/org/apache/ratis/server/raftlog/RaftLogSequentialOps.java 71 ratis-server-api/src/main/java/org/apache/ratis/server/storage/FileInfo.java 26 ratis-server-api/src/main/java/org/apache/ratis/server/storage/RaftStorage.java 77 ratis-server-api/src/main/java/org/apache/ratis/server/storage/RaftStorageDirectory.java 21 ratis-server-api/src/main/java/org/apache/ratis/server/storage/RaftStorageMetadata.java 46 ratis-server-api/src/main/java/org/apache/ratis/server/storage/RaftStorageMetadataFile.java 6 ratis-server-api/src/main/java/org/apache/ratis/statemachine/SnapshotInfo.java 14 ratis-server-api/src/main/java/org/apache/ratis/statemachine/SnapshotRetentionPolicy.java 7 ratis-server-api/src/main/java/org/apache/ratis/statemachine/StateMachine.java 166 ratis-server-api/src/main/java/org/apache/ratis/statemachine/StateMachineStorage.java 16 ratis-server-api/src/main/java/org/apache/ratis/statemachine/TransactionContext.java 117 ratis-server/src/main/java/org/apache/ratis/server/DisabledDataStreamServerFactory.java 28 ratis-server/src/main/java/org/apache/ratis/server/impl/CommitInfoCache.java 41 ratis-server/src/main/java/org/apache/ratis/server/impl/ConfigurationManager.java 68 ratis-server/src/main/java/org/apache/ratis/server/impl/DataStreamMapImpl.java 32 ratis-server/src/main/java/org/apache/ratis/server/impl/DataStreamServerImpl.java 27 ratis-server/src/main/java/org/apache/ratis/server/impl/DivisionPropertiesImpl.java 36 ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerInfoImpl.java 188 ratis-server/src/main/java/org/apache/ratis/server/impl/FollowerState.java 140 ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderElection.java 374 ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderLease.java 64 ratis-server/src/main/java/org/apache/ratis/server/impl/LeaderStateImpl.java 1013 ratis-server/src/main/java/org/apache/ratis/server/impl/MessageStreamRequests.java 94 ratis-server/src/main/java/org/apache/ratis/server/impl/PeerConfiguration.java 147 ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequest.java 74 ratis-server/src/main/java/org/apache/ratis/server/impl/PendingRequests.java 222 ratis-server/src/main/java/org/apache/ratis/server/impl/PendingStepDown.java 76 ratis-server/src/main/java/org/apache/ratis/server/impl/RaftConfigurationImpl.java 265 ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java 1617 ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerJmxAdapter.java 66 ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerProxy.java 574 ratis-server/src/main/java/org/apache/ratis/server/impl/ReadIndexHeartbeats.java 141 ratis-server/src/main/java/org/apache/ratis/server/impl/ReadRequests.java 79 ratis-server/src/main/java/org/apache/ratis/server/impl/RetryCacheImpl.java 200 ratis-server/src/main/java/org/apache/ratis/server/impl/RoleInfo.java 152 ratis-server/src/main/java/org/apache/ratis/server/impl/ServerImplUtils.java 200 ratis-server/src/main/java/org/apache/ratis/server/impl/ServerProtoUtils.java 157 ratis-server/src/main/java/org/apache/ratis/server/impl/ServerState.java 378 ratis-server/src/main/java/org/apache/ratis/server/impl/SnapshotInstallationHandler.java 312 ratis-server/src/main/java/org/apache/ratis/server/impl/SnapshotManagementRequestHandler.java 84 ratis-server/src/main/java/org/apache/ratis/server/impl/StateMachineMetrics.java 40 ratis-server/src/main/java/org/apache/ratis/server/impl/StateMachineUpdater.java 282 ratis-server/src/main/java/org/apache/ratis/server/impl/TransactionManager.java 46 ratis-server/src/main/java/org/apache/ratis/server/impl/TransferLeadership.java 278 ratis-server/src/main/java/org/apache/ratis/server/impl/VoteContext.java 117 ratis-server/src/main/java/org/apache/ratis/server/impl/WatchRequests.java 174 ratis-server/src/main/java/org/apache/ratis/server/impl/WriteIndexCache.java 40 ratis-server/src/main/java/org/apache/ratis/server/leader/InstallSnapshotRequests.java 109 ratis-server/src/main/java/org/apache/ratis/server/leader/LeaderProtoUtils.java 47 ratis-server/src/main/java/org/apache/ratis/server/leader/LogAppenderBase.java 311 ratis-server/src/main/java/org/apache/ratis/server/leader/LogAppenderDaemon.java 101 ratis-server/src/main/java/org/apache/ratis/server/leader/LogAppenderDefault.java 177 ratis-server/src/main/java/org/apache/ratis/server/metrics/LeaderElectionMetrics.java 54 ratis-server/src/main/java/org/apache/ratis/server/metrics/LogAppenderMetrics.java 30 ratis-server/src/main/java/org/apache/ratis/server/metrics/RaftLogMetricsBase.java 40 ratis-server/src/main/java/org/apache/ratis/server/metrics/RaftServerMetricsImpl.java 227 ratis-server/src/main/java/org/apache/ratis/server/metrics/SegmentedRaftLogMetrics.java 121 ratis-server/src/main/java/org/apache/ratis/server/raftlog/LogProtoUtils.java 195 ratis-server/src/main/java/org/apache/ratis/server/raftlog/RaftLogBase.java 411 ratis-server/src/main/java/org/apache/ratis/server/raftlog/memory/MemoryRaftLog.java 221 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/BufferedWriteChannel.java 140 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/CacheInvalidationPolicy.java 77 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/LogSegment.java 469 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/LogSegmentPath.java 83 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/LogSegmentStartEnd.java 100 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLog.java 502 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogCache.java 623 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogFormat.java 48 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogInputStream.java 174 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogOutputStream.java 117 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogReader.java 253 ratis-server/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java 623 ratis-server/src/main/java/org/apache/ratis/server/storage/FileChunkReader.java 74 ratis-server/src/main/java/org/apache/ratis/server/storage/RaftStorageDirectoryImpl.java 170 ratis-server/src/main/java/org/apache/ratis/server/storage/RaftStorageImpl.java 144 ratis-server/src/main/java/org/apache/ratis/server/storage/RaftStorageMetadataFileImpl.java 80 ratis-server/src/main/java/org/apache/ratis/server/storage/SnapshotManager.java 152 ratis-server/src/main/java/org/apache/ratis/server/storage/StorageImplUtils.java 121 ratis-server/src/main/java/org/apache/ratis/server/util/ServerStringUtils.java 92 ratis-server/src/main/java/org/apache/ratis/statemachine/impl/BaseStateMachine.java 174 ratis-server/src/main/java/org/apache/ratis/statemachine/impl/FileListSnapshotInfo.java 31 ratis-server/src/main/java/org/apache/ratis/statemachine/impl/SimpleStateMachineStorage.java 187 ratis-server/src/main/java/org/apache/ratis/statemachine/impl/SingleFileSnapshotInfo.java 15 ratis-server/src/main/java/org/apache/ratis/statemachine/impl/TransactionContextImpl.java 149 ratis-shell/src/main/java/org/apache/ratis/shell/cli/AbstractShell.java 84 ratis-shell/src/main/java/org/apache/ratis/shell/cli/CliUtils.java 105 ratis-shell/src/main/java/org/apache/ratis/shell/cli/Command.java 47 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/RatisShell.java 77 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/AbstractCommand.java 21 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/AbstractParentCommand.java 31 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/AbstractRatisCommand.java 115 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/Context.java 75 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/ElectionCommand.java 29 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/GroupCommand.java 27 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/LocalCommand.java 26 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/PeerCommand.java 28 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/command/SnapshotCommand.java 25 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/election/PauseCommand.java 66 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/election/ResumeCommand.java 66 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/election/StepDownCommand.java 44 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/election/TransferCommand.java 115 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/group/GroupInfoCommand.java 50 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/group/GroupListCommand.java 74 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/local/RaftMetaConfCommand.java 130 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/peer/AddCommand.java 99 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/peer/RemoveCommand.java 80 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/peer/SetPriorityCommand.java 75 ratis-shell/src/main/java/org/apache/ratis/shell/cli/sh/snapshot/TakeSnapshotCommand.java 78 ratis-tools/src/main/java/org/apache/ratis/tools/DefaultLogDump.java 15 ratis-tools/src/main/java/org/apache/ratis/tools/ParseRatisLog.java 81