Repository: ignite Updated Branches: refs/heads/ignite-9273 [created] 3ee58b17c
IGNITE-9273 Debugging Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3ee58b17 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3ee58b17 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3ee58b17 Branch: refs/heads/ignite-9273 Commit: 3ee58b17c1a8a99c146598e1b2babf07fefd4bb5 Parents: 8977038 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Wed Aug 22 14:18:12 2018 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Wed Aug 22 14:18:12 2018 +0300 ---------------------------------------------------------------------- .../cache/persistence/GridCacheDatabaseSharedManager.java | 7 +++++++ .../cache/persistence/wal/FileWriteAheadLogManager.java | 5 +++++ .../cache/persistence/IgnitePdsDynamicCacheTest.java | 6 ++++++ 3 files changed, 18 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3ee58b17/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java index ce914e4..fa1d4c3 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java @@ -131,6 +131,7 @@ import org.apache.ignite.internal.processors.cache.persistence.snapshot.Snapshot import org.apache.ignite.internal.processors.cache.persistence.tree.io.PageIO; import org.apache.ignite.internal.processors.cache.persistence.tree.io.PagePartitionMetaIO; import org.apache.ignite.internal.processors.cache.persistence.wal.FileWALPointer; +import org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager; import org.apache.ignite.internal.processors.cache.persistence.wal.crc.IgniteDataIntegrityViolationException; import org.apache.ignite.internal.processors.cache.persistence.wal.crc.PureJavaCrc32; import org.apache.ignite.internal.processors.port.GridPortRecord; @@ -1936,6 +1937,9 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan if (rec == null) break; + if (FileWriteAheadLogManager.verbose) + log.info("ON RESTORE: " + rec); + switch (rec.type()) { case PAGE_RECORD: if (restoreBinaryState.needApplyBinaryUpdate()) { @@ -2215,6 +2219,9 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan if (rec == null) break; + if (FileWriteAheadLogManager.verbose) + log.info("LAST UPDATE: " + rec); + switch (rec.type()) { case DATA_RECORD: if (metastoreOnly) http://git-wip-us.apache.org/repos/asf/ignite/blob/3ee58b17/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java index e3f5a52..1f0a305 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/FileWriteAheadLogManager.java @@ -360,6 +360,8 @@ public class FileWriteAheadLogManager extends GridCacheSharedManagerAdapter impl /** Wal segment sync worker. */ private WalSegmentSyncer walSegmentSyncWorker; + public static volatile boolean verbose = false; + /** * @param ctx Kernal context. */ @@ -748,6 +750,9 @@ public class FileWriteAheadLogManager extends GridCacheSharedManagerAdapter impl if (serializer == null || mode == WALMode.NONE) return null; + if (verbose) + log.info("Writing WAL: " + rec); + FileWriteHandle currWrHandle = currentHandle(); WALDisableContext isDisable = walDisableContext; http://git-wip-us.apache.org/repos/asf/ignite/blob/3ee58b17/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsDynamicCacheTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsDynamicCacheTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsDynamicCacheTest.java index 42dc563..38659fd 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsDynamicCacheTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsDynamicCacheTest.java @@ -32,6 +32,7 @@ import org.apache.ignite.configuration.DataRegionConfiguration; import org.apache.ignite.configuration.DataStorageConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.configuration.WALMode; +import org.apache.ignite.internal.processors.cache.persistence.wal.FileWriteAheadLogManager; import org.apache.ignite.internal.processors.database.IgniteDbDynamicCacheSelfTest; import org.apache.ignite.internal.util.typedef.internal.U; @@ -79,6 +80,8 @@ public class IgnitePdsDynamicCacheTest extends IgniteDbDynamicCacheSelfTest { System.clearProperty(GridCacheDatabaseSharedManager.IGNITE_PDS_CHECKPOINT_TEST_SKIP_SYNC); cleanPersistenceDir(); + + FileWriteAheadLogManager.verbose = false; } /** @@ -116,6 +119,9 @@ public class IgnitePdsDynamicCacheTest extends IgniteDbDynamicCacheSelfTest { ignite.createCache(ccfg1); ignite.createCache(ccfg2); + + FileWriteAheadLogManager.verbose = true; + ignite.createCache(ccfg3).put(2, 3); int iterations = 20;
