Repository: ignite
Updated Branches:
  refs/heads/ignite-1758 c56bb6328 -> 67484021b


ignite-1758 debug


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/67484021
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/67484021
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/67484021

Branch: refs/heads/ignite-1758
Commit: 67484021b3366cb939f071361cbd26bd99ab6b42
Parents: c56bb63
Author: sboikov <[email protected]>
Authored: Thu Nov 5 17:44:53 2015 +0300
Committer: sboikov <[email protected]>
Committed: Thu Nov 5 17:44:53 2015 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java    | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/67484021/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
index 8b3cf7d..a681a5a 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
@@ -3602,6 +3602,11 @@ class ServerImpl extends TcpDiscoveryImpl {
                     msg.topologyVersion(ring.incrementTopologyVersion());
 
                     debugLog(msg, "Coordinator incremented topVer=" + 
ring.topologyVersion() + " " + msg);
+
+                    for (TcpDiscoveryNode ringNode : ring.allNodes()) {
+                        assert ringNode.internalOrder() >= node.order() || 
ringNode.order() > 0 :
+                            "Invalid node [node=" + node + ", ring=" + ring + 
']';
+                    }
                 }
 
                 msg.verify(locNodeId);

Reply via email to