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%)