Repository: ignite Updated Branches: refs/heads/ignite-1537 63db1e1d3 -> e8bc4c94f
ignite-1.5 Should not wait on preloader sync future for system caches callbacks. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e8bc4c94 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e8bc4c94 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e8bc4c94 Branch: refs/heads/ignite-1537 Commit: e8bc4c94f92fe9e7686e3d47c22a8f5cd6b7566c Parents: 63db1e1 Author: sboikov <sboi...@gridgain.com> Authored: Tue Dec 1 11:52:08 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Dec 1 11:52:08 2015 +0300 ---------------------------------------------------------------------- .../apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e8bc4c94/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index f0c6908..e5885a6 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -2303,8 +2303,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter if (sockSndBuf > 0) ch.socket().setSendBufferSize(sockSndBuf); - GridNioRecoveryDescriptor recoveryDesc = recoveryDescriptor(node); - if (getSpiContext().node(node.id()) == null) { U.closeQuiet(ch); @@ -2312,6 +2310,8 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter "(node left topology): " + node); } + GridNioRecoveryDescriptor recoveryDesc = recoveryDescriptor(node); + if (!recoveryDesc.reserve()) { U.closeQuiet(ch);
