This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from cba48c77ea IGNITE-20272 Clean up of
DistributionZoneManagerWatchListenerTest (#2490)
add acded3fc66 IGNITE-19227 Wait for schema availability outside JRaft
threads (#2450)
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/catalog/CatalogService.java | 2 -
.../org/apache/ignite/internal/util/ByteUtils.java | 2 +-
.../apache/ignite/internal/util/VarIntUtils.java | 103 ++++++++++
.../ignite/internal/util/VarIntUtilsTest.java | 94 +++++++++
.../testframework/TestIgnitionManager.java | 37 +++-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 2 +
.../java/org/apache/ignite/internal/raft/Loza.java | 13 +-
.../internal/raft/server/RaftGroupOptions.java | 23 +++
.../internal/raft/server/impl/JraftServerImpl.java | 30 ++-
.../internal/raft/util/OptimizedMarshaller.java | 14 +-
.../ignite/internal/raft/util/OptimizedStream.java | 2 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 1 +
.../ignite/raft/jraft/option/NodeOptions.java | 14 ++
.../jraft/rpc/impl/ActionRequestProcessor.java | 12 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 11 +-
...r.java => AppendEntriesRequestInterceptor.java} | 37 ++--
...InterceptingAppendEntriesRequestProcessor.java} | 39 ++--
...va => NullAppendEntriesRequestInterceptor.java} | 28 +--
.../apache/ignite/raft/jraft/core/TestCluster.java | 7 +
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 4 +-
.../replicator/message/ReplicaMessageGroup.java | 5 +-
.../storage/ItRebalanceDistributedTest.java | 14 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 79 +-------
.../app/ItIgniteInMemoryNodeRestartTest.java | 2 +
.../runner/app/ItIgniteNodeRestartTest.java | 13 +-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 177 ++++++++++++++++
.../org/apache/ignite/internal/app/IgniteImpl.java | 16 +-
.../java/org/apache/ignite/internal/Cluster.java | 88 +++++++-
.../ignite/internal/ReplicationGroupsUtils.java} | 33 ++-
.../sql/engine/exec/MockedStructuresTest.java | 10 +-
modules/table/build.gradle | 2 +
.../distributed/ItTxDistributedTestSingleNode.java | 4 +
.../internal/table/distributed/TableManager.java | 24 ++-
.../distributed/command/CatalogVersionAware.java} | 16 +-
.../distributed/command/PartitionCommand.java | 8 +-
.../replicator/PartitionReplicaListener.java | 222 +++++++++++++--------
.../distributed/replicator/action/RequestType.java | 38 +---
.../schema/CheckCatalogVersionOnAppendEntries.java | 105 ++++++++++
...-info.java => PartitionCommandsMarshaller.java} | 19 +-
.../schema/PartitionCommandsMarshallerImpl.java | 73 +++++++
.../distributed/schema/SchemaSyncService.java | 8 -
.../distributed/schema/SchemaSyncServiceImpl.java | 11 +-
.../ThreadLocalPartitionCommandsMarshaller.java} | 18 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../PartitionReplicaListenerIndexLockingTest.java | 9 +-
.../replication/PartitionReplicaListenerTest.java | 182 ++++++++++++-----
.../PartitionCommandsMarshallerImplTest.java | 116 +++++++++++
.../schema/SchemaSyncServiceImplTest.java | 14 +-
.../replicator/action/RequestTypes.java} | 95 +++++----
.../table/impl/DummyInternalTableImpl.java | 4 +
50 files changed, 1411 insertions(+), 475 deletions(-)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/VarIntUtils.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/VarIntUtilsTest.java
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/{GetFileRequestProcessor.java
=> AppendEntriesRequestInterceptor.java} (51%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/{TimeoutNowRequestProcessor.java
=> InterceptingAppendEntriesRequestProcessor.java} (55%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/{GetFileRequestProcessor.java
=> NullAppendEntriesRequestInterceptor.java} (55%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/schemasync/ItSchemaSyncAndReplicationTest.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadWriteMultiRowReplicaRequest.java
=>
runner/src/testFixtures/java/org/apache/ignite/internal/ReplicationGroupsUtils.java}
(54%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/MessageListener.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/command/CatalogVersionAware.java}
(70%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/CheckCatalogVersionOnAppendEntries.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/{package-info.java
=> PartitionCommandsMarshaller.java} (63%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/PartitionCommandsMarshallerImpl.java
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/util/ThreadLocalOptimizedMarshaller.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/schema/ThreadLocalPartitionCommandsMarshaller.java}
(67%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/schema/PartitionCommandsMarshallerImplTest.java
copy
modules/table/src/{main/java/org/apache/ignite/internal/table/distributed/replicator/action/RequestType.java
=>
testFixtures/java/org/apache/ignite/distributed/replicator/action/RequestTypes.java}
(51%)
