ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-1758 Discovery fixes.
Date Thu, 12 Nov 2015 14:29:55 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1758-debug 9b7717c9f -> 946a9887f


ignite-1758 Discovery fixes.


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

Branch: refs/heads/ignite-1758-debug
Commit: 946a9887f9a2b67515c9e5979400b53a7c78d297
Parents: 9b7717c
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Nov 12 17:29:45 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Nov 12 17:29:45 2015 +0300

----------------------------------------------------------------------
 .../main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/946a9887/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 c672bd0..f6a35df 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
@@ -4510,7 +4510,7 @@ class ServerImpl extends TcpDiscoveryImpl {
                         if (nextMsg != null) {
                             try {
                                 TcpDiscoveryCustomEventMessage ackMsg = new TcpDiscoveryCustomEventMessage(
-                                    msg.creatorNodeId(), nextMsg, spi.marsh.marshal(nextMsg));
+                                    getLocalNodeId(), nextMsg, spi.marsh.marshal(nextMsg));
 
                                 ackMsg.topologyVersion(msg.topologyVersion());
 


Mime
View raw message