You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sd...@apache.org on 2022/10/28 10:13:44 UTC

[ignite-3] branch main updated (8277b1ad4c -> 59b134b506)

This is an automated email from the ASF dual-hosted git repository.

sdanilov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


    from 8277b1ad4c IGNITE-18002 Revert accident changes to project files (#1264)
     add 59b134b506 IGNITE-17943 Implement RAFT snapshot TX data sender (#1246)

No new revisions were added by this update.

Summary of changes:
 .../ignite/internal/lock/ReusableLockLockup.java   |   1 +
 .../ignite/distributed/ItTablePersistenceTest.java |   4 +-
 .../distributed/ItTxDistributedTestSingleNode.java |   8 +-
 .../ignite/internal/table/ItColocationTest.java    |   4 +-
 .../internal/table/distributed/TableManager.java   |  20 ++-
 .../distributed/raft/PartitionDataStorage.java     |   5 +-
 .../table/distributed/raft/PartitionListener.java  |  13 +-
 .../snapshot/message/SnapshotTxDataRequest.java    |   6 +
 .../raft/snapshot/outgoing/OutgoingSnapshot.java   | 181 +++++++++++++--------
 .../snapshot/outgoing/OutgoingSnapshotReader.java  |  10 +-
 .../outgoing/OutgoingSnapshotRegistry.java         |  40 -----
 .../outgoing/OutgoingSnapshotsManager.java         |  40 ++---
 .../SnapshotAwarePartitionDataStorage.java         |  22 +--
 .../raft/PartitionCommandListenerTest.java         |   6 +-
 .../incoming/IncomingSnapshotCopierTest.java       |   8 +-
 ...va => OutgoingSnapshotMvDataStreamingTest.java} | 144 +++++++---------
 .../OutgoingSnapshotTxDataStreamingTest.java       | 172 ++++++++++++++++++++
 .../outgoing/OutgoingSnapshotsManagerTest.java     |   6 +-
 .../SnapshotAwarePartitionDataStorageTest.java     |  46 ++----
 .../PartitionReplicaListenerIndexLockingTest.java  |   4 +-
 .../replication/PartitionReplicaListenerTest.java  |   4 +-
 .../table/impl/DummyInternalTableImpl.java         |   4 +-
 .../distributed/TestPartitionDataStorage.java      |   2 +-
 modules/transactions/build.gradle                  |   1 +
 modules/transactions/pom.xml                       |   6 +
 .../internal/tx/storage/state/TxStateStorage.java  |   7 +-
 .../storage/state/TxStateStorageAbstractTest.java  |  54 +++++-
 .../tx/storage/state/UnsignedUuidComparator.java}  |  21 ++-
 ...torageTest.java => TestTxStateStorageTest.java} |   4 +-
 ...TxStateStorage.java => TestTxStateStorage.java} |  19 ++-
 ...leStorage.java => TestTxStateTableStorage.java} |   6 +-
 31 files changed, 539 insertions(+), 329 deletions(-)
 delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshotRegistry.java
 rename modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/{OutgoingSnapshotTest.java => OutgoingSnapshotMvDataStreamingTest.java} (80%)
 create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/outgoing/OutgoingSnapshotTxDataStreamingTest.java
 rename modules/table/src/testFixtures/java/{ => org/apache/ignite}/distributed/TestPartitionDataStorage.java (98%)
 copy modules/{network-api/src/main/java/org/apache/ignite/network/serialization/MessageSerializationRegistryInitializer.java => transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/UnsignedUuidComparator.java} (57%)
 rename modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/{TestConcurrentHashMapTxStateStorageTest.java => TestTxStateStorageTest.java} (89%)
 rename modules/transactions/src/testFixtures/java/org/apache/ignite/internal/tx/storage/state/test/{TestConcurrentHashMapTxStateStorage.java => TestTxStateStorage.java} (84%)
 rename modules/transactions/src/testFixtures/java/org/apache/ignite/internal/tx/storage/state/test/{TestConcurrentHashMapTxStateTableStorage.java => TestTxStateTableStorage.java} (92%)