This is an automated email from the ASF dual-hosted git repository.
ascherbakov pushed a change to branch ignite-13885
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from c4c7e91 IGNITE-13885 wip tests.
new a53dd13 IGNITE-13885 wip tests 1.
new 54b30d9 IGNITE-13885 get rid of commons.
new a529ad1 IGNITE-13885 partially working.
The 3 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:
modules/raft/pom.xml | 17 +-
.../java/com/alipay/sofa/jraft/JRaftUtils.java | 3 +-
.../com/alipay/sofa/jraft/RaftGroupService.java | 2 +-
.../java/com/alipay/sofa/jraft/RouteTable.java | 2 +-
.../com/alipay/sofa/jraft/conf/Configuration.java | 2 +-
.../com/alipay/sofa/jraft/core/CliServiceImpl.java | 2 +-
.../jraft/core/DefaultJRaftServiceFactory.java | 2 +-
.../java/com/alipay/sofa/jraft/core/NodeImpl.java | 2 +-
.../sofa/jraft/entity/LocalStorageOutter.java | 3 +-
.../java/com/alipay/sofa/jraft/entity/PeerId.java | 2 +-
.../com/alipay/sofa/jraft/entity/RaftOutter.java | 3 +-
.../com/alipay/sofa/jraft/rpc/CliRequests.java | 2 +-
.../java/com/alipay/sofa/jraft/rpc/Connection.java | 1 -
.../alipay/sofa/jraft/rpc/HasErrorResponse.java | 2 +-
.../sofa/jraft/rpc/MessageBuilderFactory.java | 29 ++-
.../com/alipay/sofa/jraft/rpc/RaftRpcFactory.java | 9 -
.../com/alipay/sofa/jraft/rpc/RpcRequests.java | 26 +--
.../sofa/jraft/rpc/impl/AbstractClientService.java | 11 +-
.../sofa/jraft/rpc/impl/LocalConnection.java | 35 +++
.../sofa/jraft/rpc/impl/LocalRaftRpcFactory.java | 35 ++-
.../alipay/sofa/jraft/rpc/impl/LocalRpcClient.java | 72 +++++-
.../alipay/sofa/jraft/rpc/impl/LocalRpcServer.java | 165 +++++++++++++-
.../rpc/impl/cli/BaseCliRequestProcessor.java | 2 +-
.../rpc/message/AppendEntriesRequestImpl.java | 130 +++++++++++
.../rpc/message/AppendEntriesResponseImpl.java | 47 ++++
.../rpc/message/DefaultMessageBuilderFactory.java | 53 ++++-
.../sofa/jraft/rpc/message/EntryMetaImpl.java | 133 ++++++++++++
.../sofa/jraft/rpc/message/ErrorResponseImpl.java | 32 +++
.../sofa/jraft/rpc/message/PingRequestImpl.java | 21 ++
.../sofa/jraft/rpc/message/PreVoteRequestImpl.java | 87 ++++++++
.../jraft/rpc/message/ReadIndexRequestImpl.java | 76 +++++++
.../jraft/rpc/message/ReadIndexResponseImpl.java | 36 +++
.../jraft/rpc/message/RequestVoteResponseImpl.java | 36 +++
.../alipay/sofa/jraft/rpc/message/StableMeta.java | 32 +++
.../jraft/rpc/message/TimeoutNowRequestImpl.java | 54 +++++
.../jraft/rpc/message/TimeoutNowResponseImpl.java | 36 +++
.../com/alipay/sofa/jraft/storage/LogStorage.java | 1 -
.../sofa/jraft/storage/impl/LocalLogStorage.java | 124 +++++------
.../jraft/storage/impl/LocalRaftMetaStorage.java | 7 +-
.../storage/snapshot/SnapshotExecutorImpl.java | 2 +-
.../snapshot/local/LocalSnapshotCopier.java | 5 +-
.../snapshot/local/LocalSnapshotStorage.java | 17 +-
.../snapshot/local/LocalSnapshotWriter.java | 6 +-
.../com/alipay/sofa/jraft/util/ByteString.java | 4 +
.../sofa/jraft/util/FileOutputSignalHandler.java | 4 +-
.../com/alipay/sofa/jraft/util/JDKMarshaller.java | 40 ++--
.../com/alipay/sofa/jraft/util/Marshaller.java | 4 +-
.../com/alipay/sofa/jraft/util/StringUtils.java | 241 +++++++++++++++++++++
.../java/com/alipay/sofa/jraft/util/Utils.java | 59 ++++-
.../com.alipay.sofa.jraft.JRaftServiceFactory | 1 +
.../com.alipay.sofa.jraft.rpc.RaftRpcFactory | 1 +
.../com.alipay.sofa.jraft.util.JRaftSignalHandler | 3 +
...m.alipay.sofa.jraft.util.timer.RaftTimerFactory | 1 +
.../java/com/alipay/sofa/jraft/RouteTableTest.java | 6 +-
.../com/alipay/sofa/jraft/core/CliServiceTest.java | 6 +-
.../java/com/alipay/sofa/jraft/core/NodeTest.java | 5 +-
.../com/alipay/sofa/jraft/core/TestCluster.java | 9 +-
.../com/alipay/sofa/jraft/rpc/LocalRpcTest.java | 154 +++++++++++++
.../alipay/sofa/jraft/storage/BaseStorageTest.java | 10 +-
.../alipay/sofa/jraft/storage/FileServiceTest.java | 11 +-
.../jraft/storage/impl/BaseLogStorageTest.java | 31 +--
.../impl/LocalLogStorageTest.java} | 17 +-
.../storage/impl/LocalRaftMetaStorageTest.java | 4 +-
.../sofa/jraft/storage/io/LocalFileReaderTest.java | 4 +-
.../snapshot/local/LocalSnapshotMetaTableTest.java | 6 +-
.../snapshot/local/LocalSnapshotReaderTest.java | 3 +-
.../snapshot/local/LocalSnapshotStorageTest.java | 3 +-
.../jraft/util/FileOutputSignalHandlerTest.java | 7 +-
modules/raft/src/test/resources/log4j2.xml | 25 +++
69 files changed, 1767 insertions(+), 256 deletions(-)
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/impl/LocalConnection.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/AppendEntriesRequestImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/AppendEntriesResponseImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/EntryMetaImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/ErrorResponseImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/PingRequestImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/PreVoteRequestImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/ReadIndexRequestImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/ReadIndexResponseImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/RequestVoteResponseImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/StableMeta.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/TimeoutNowRequestImpl.java
create mode 100644
modules/raft/src/main/java/com/alipay/sofa/jraft/rpc/message/TimeoutNowResponseImpl.java
create mode 100644
modules/raft/src/main/resources/META-INF/services/com.alipay.sofa.jraft.JRaftServiceFactory
create mode 100644
modules/raft/src/main/resources/META-INF/services/com.alipay.sofa.jraft.rpc.RaftRpcFactory
create mode 100644
modules/raft/src/main/resources/META-INF/services/com.alipay.sofa.jraft.util.JRaftSignalHandler
create mode 100644
modules/raft/src/main/resources/META-INF/services/com.alipay.sofa.jraft.util.timer.RaftTimerFactory
create mode 100644
modules/raft/src/test/java/com/alipay/sofa/jraft/rpc/LocalRpcTest.java
copy modules/raft/src/test/java/com/alipay/sofa/jraft/{core/MockClosure.java
=> storage/impl/LocalLogStorageTest.java} (70%)
create mode 100644 modules/raft/src/test/resources/log4j2.xml
