ignite-1.5 Correction for commit 59f3726.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c850ae47 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c850ae47 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c850ae47 Branch: refs/heads/master Commit: c850ae474e1d60bf4e927206b580af19e7f208bb Parents: e11e4cb Author: sboikov <sboi...@gridgain.com> Authored: Tue Dec 1 14:17:59 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Dec 1 14:17:59 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/c850ae47/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 e5885a6..09e4877 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 @@ -360,7 +360,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter clients.remove(id, rmv)) { rmv.forceClose(); - if (!isNodeStopping()) { + if (!stopping) { GridNioRecoveryDescriptor recoveryData = ses.recoveryDescriptor(); if (recoveryData != null) { @@ -1761,7 +1761,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter /** {@inheritDoc} */ @Override public void spiStop() throws IgniteSpiException { - assert isNodeStopping(); + assert stopping; unregisterMBean();