# ignite-sprint-6 fixed NPE in comm spi unit tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/895771a7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/895771a7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/895771a7 Branch: refs/heads/ignite-1026 Commit: 895771a79d8acca3baf06c23bf3f82483ec62d6f Parents: ef4abeb Author: sboikov <sboi...@gridgain.com> Authored: Fri Jun 19 13:06:05 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Jun 19 13:06:05 2015 +0300 ---------------------------------------------------------------------- .../apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/895771a7/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 84c1a57..bbb9b1c 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 @@ -1458,8 +1458,10 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter } }; + boolean clientMode = Boolean.TRUE.equals(ignite.configuration().isClientMode()); + IgniteBiInClosure<GridNioSession, Integer> queueSizeMonitor = - !ignite.configuration().isClientMode() && slowClientQueueLimit > 0 ? + !clientMode && slowClientQueueLimit > 0 ? new CI2<GridNioSession, Integer>() { @Override public void apply(GridNioSession ses, Integer qSize) { checkClientQueueSize(ses, qSize);
