From 31e6ca97366880dc2a72fa6f4de6c1e7e219ac06 Mon Sep 17 00:00:00 2001 From: Denis Magda Date: Wed, 29 Jul 2015 12:49:57 +0300 Subject: [PATCH] ignite-1164: fixed NPE in tcp discovery --- .../src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 3 +++ 1 file changed, 3 insertions(+) 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 547347c..56078e7 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 @@ -2753,6 +2753,9 @@ class ServerImpl extends TcpDiscoveryImpl { if (routerNode.id().equals(getLocalNodeId())) { ClientMessageWorker worker = clientMsgWorkers.get(node.id()); + if (worker == null) + throw new IgniteSpiException("Client node already disconnected: " + node); + msg.verify(getLocalNodeId()); // Client worker require verified messages. worker.addMessage(msg); -- 1.9.5.msysgit.0