You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ti...@apache.org on 2023/01/20 18:35:56 UTC
[ignite] branch IGNITE-17177_inc_snapshots updated (c34fa583eb1 -> de3d7c8def4)
This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a change to branch IGNITE-17177_inc_snapshots
in repository https://gitbox.apache.org/repos/asf/ignite.git
from c34fa583eb1 IGNITE-18573 DistributedProcess should have an option to await client node results (#10483)
add de3d7c8def4 IGNITE-17029 Incremental snapshot creation implemented (#10314)
No new revisions were added by this update.
Summary of changes:
.../ignite/codegen/MessageCodeGenerator.java | 2 +
.../communication/GridIoMessageFactory.java | 9 +-
.../record/IncrementalSnapshotFinishRecord.java | 101 ++++++
.../wal/record/IncrementalSnapshotStartRecord.java | 51 +++
.../internal/pagemem/wal/record/WALRecord.java | 8 +-
.../processors/cache/GridCacheIoManager.java | 14 +
.../processors/cache/GridCacheProcessor.java | 6 +-
.../distributed/dht/GridDhtTxFinishFuture.java | 2 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 4 +-
...dNearOptimisticSerializableTxPrepareFuture.java | 2 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 2 +-
.../near/GridNearPessimisticTxPrepareFuture.java | 2 +-
.../distributed/near/GridNearTxFinishFuture.java | 2 +-
.../cache/distributed/near/GridNearTxLocal.java | 3 +
.../snapshot/IgniteSnapshotManager.java | 179 +++++++---
.../snapshot/IncrementalSnapshotAwareMessage.java | 181 ++++++++++
.../snapshot/IncrementalSnapshotFutureTask.java | 29 +-
.../snapshot/IncrementalSnapshotMarkWalFuture.java | 186 +++++++++++
.../snapshot/IncrementalSnapshotMetadata.java | 24 +-
.../wal/serializer/RecordDataV1Serializer.java | 75 +++++
.../cache/transactions/IgniteInternalTx.java | 10 +
.../cache/transactions/IgniteTxAdapter.java | 23 ++
.../cache/transactions/IgniteTxHandler.java | 112 ++++++-
.../cache/transactions/IgniteTxManager.java | 52 +++
.../snapshot/AbstractSnapshotSelfTest.java | 53 ++-
.../AbstractIncrementalSnapshotBlockingTest.java | 372 +++++++++++++++++++++
...actIncrementalSnapshotMessagesBlockingTest.java | 172 ++++++++++
.../AbstractIncrementalSnapshotTest.java | 296 ++++++++++++++++
...AbstractIncrementalSnapshotWalBlockingTest.java | 77 +++++
.../ConcurrentTxsIncrementalSnapshotTest.java | 267 +++++++++++++++
...mentalSnapshotNoBackupMessagesBlockingTest.java | 82 +++++
...IncrementalSnapshotNoBackupWALBlockingTest.java | 91 +++++
.../IncrementalSnapshotNodeFailureTest.java | 170 ++++++++++
...alSnapshotSingleBackupMessagesBlockingTest.java | 81 +++++
...ementalSnapshotSingleBackupWALBlockingTest.java | 41 +++
...entalSnapshotTwoBackupMessagesBlockingTest.java | 85 +++++
...ncrementalSnapshotTwoBackupWALBlockingTest.java | 31 ++
.../IncrementalSnapshotTxRecoveryTest.java | 184 ++++++++++
.../snapshot/incremental/TransactionTestCase.java | 143 ++++++++
.../testframework/wal/record/RecordUtils.java | 19 ++
.../ignite/testsuites/IgniteSnapshotTestSuite.java | 3 +-
.../testsuites/IncrementalSnapshotsTestSuite.java | 50 +++
42 files changed, 3199 insertions(+), 97 deletions(-)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/IncrementalSnapshotFinishRecord.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/IncrementalSnapshotStartRecord.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IncrementalSnapshotAwareMessage.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IncrementalSnapshotMarkWalFuture.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/AbstractIncrementalSnapshotBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/AbstractIncrementalSnapshotMessagesBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/AbstractIncrementalSnapshotTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/AbstractIncrementalSnapshotWalBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/ConcurrentTxsIncrementalSnapshotTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotNoBackupMessagesBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotNoBackupWALBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotNodeFailureTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotSingleBackupMessagesBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotSingleBackupWALBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotTwoBackupMessagesBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotTwoBackupWALBlockingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/IncrementalSnapshotTxRecoveryTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/incremental/TransactionTestCase.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/testsuites/IncrementalSnapshotsTestSuite.java