[ignite] branch master updated: IGNITE-11293 Fix of NPE in TcpCommunicationSpi caused by simultaneous node stopping. - Fixes #6081.

[dg...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dgovorukhin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new a1ec83a  IGNITE-11293 Fix of NPE in TcpCommunicationSpi caused by simultaneous node stopping. - Fixes #6081.
a1ec83a is described below

commit a1ec83a826f1a87b88dd16f93d0ee3b3168439b9
Author: ibessonov <be...@gmail.com>
AuthorDate: Tue Feb 12 15:58:09 2019 +0300

    IGNITE-11293 Fix of NPE in TcpCommunicationSpi caused by simultaneous node stopping. - Fixes #6081.
    
    Signed-off-by: Dmitriy Govorukhin <dm...@gmail.com>
---
 .../org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java   | 3 +++
 1 file changed, 3 insertions(+)

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 15bc0d5..243f707 100755
--- 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
@@ -2781,6 +2781,9 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter implements Communicati
                 while (retry);
             }
             catch (Throwable t) {
+                if (stopping)
+                    throw new IgniteSpiException("Node is stopping.", t);
+
                 log.error("Failed to send message to remote node [node=" + node + ", msg=" + msg + ']', t);
 
                 if (t instanceof Error)