IGNITE-8965 Add logs in SegmentReservationStorage on exchange process
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ee909a36 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ee909a36 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ee909a36 Branch: refs/heads/ignite-8446 Commit: ee909a36dd88378f9391aff13468a2e1169db7dd Parents: fff979a9 Author: Ivan Rakov <ira...@apache.org> Authored: Wed Jul 11 17:57:53 2018 +0300 Committer: Ivan Rakov <ira...@apache.org> Committed: Wed Jul 11 17:57:53 2018 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/WalStateManager.java | 11 +++++++++-- .../cache/persistence/wal/SegmentReservationStorage.java | 2 +- 2 files changed, 10 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ee909a36/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java index c8276a8..4597798 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/WalStateManager.java @@ -378,6 +378,8 @@ public class WalStateManager extends GridCacheSharedManagerAdapter { boolean hasOwning = false; + int parts = 0; + for (GridDhtLocalPartition locPart : grp.topology().currentLocalPartitions()) { if (locPart.state() == OWNING) { hasOwning = true; @@ -391,11 +393,16 @@ public class WalStateManager extends GridCacheSharedManagerAdapter { break; } } + + parts++; } - if (hasOwning && !grp.localWalEnabled()) { + log.info("Prepare change WAL state, grp=" + grp.cacheOrGroupName() + + ", grpId=" + grp.groupId() + ", hasOwning=" + hasOwning + + ", WALState=" + grp.walEnabled() + ", parts=" + parts); + + if (hasOwning && !grp.localWalEnabled()) grpsToEnableWal.add(grp.groupId()); - } else if (!hasOwning && grp.localWalEnabled()) { grpsToDisableWal.add(grp.groupId()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ee909a36/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/SegmentReservationStorage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/SegmentReservationStorage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/SegmentReservationStorage.java index 17da96d..12c4b4f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/SegmentReservationStorage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/wal/SegmentReservationStorage.java @@ -51,7 +51,7 @@ class SegmentReservationStorage { synchronized void release(long absIdx) { Integer cur = reserved.get(absIdx); - assert cur != null && cur >= 1 : cur; + assert cur != null && cur >= 1 : "cur=" + cur + ", absIdx=" + absIdx; if (cur == 1) reserved.remove(absIdx);
