Added more info in assert message.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8d627378 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8d627378 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8d627378 Branch: refs/heads/ignite-1232-1 Commit: 8d6273780bdb63397dfddaf7b7c1e65a8b717e8d Parents: a648e88 Author: sboikov <[email protected]> Authored: Fri Jul 15 16:40:31 2016 +0300 Committer: sboikov <[email protected]> Committed: Fri Jul 15 16:40:31 2016 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8d627378/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java index 868e9db..c95817d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java @@ -255,7 +255,8 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { try { assert exchId.topologyVersion().compareTo(topVer) > 0 : "Invalid topology version [topVer=" + topVer + - ", exchId=" + exchId + ']'; + ", exchId=" + exchId + + ", fut=" + exchFut + ']'; this.stopping = stopping; @@ -337,11 +338,13 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { assert topVer.equals(exchFut.topologyVersion()) : "Invalid topology [topVer=" + topVer + ", cache=" + cctx.name() + - ", futVer=" + exchFut.topologyVersion() + ']'; + ", futVer=" + exchFut.topologyVersion() + + ", fut=" + exchFut + ']'; assert cctx.affinity().affinityTopologyVersion().equals(exchFut.topologyVersion()) : "Invalid affinity [topVer=" + cctx.affinity().affinityTopologyVersion() + ", cache=" + cctx.name() + - ", futVer=" + exchFut.topologyVersion() + ']'; + ", futVer=" + exchFut.topologyVersion() + + ", fut=" + exchFut + ']'; List<List<ClusterNode>> aff = cctx.affinity().assignments(exchFut.topologyVersion());
