ignite-comm-balance-master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/abc5d7a7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/abc5d7a7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/abc5d7a7 Branch: refs/heads/ignite-4371 Commit: abc5d7a7ee219b2c2c815aff916cb77aa7d516e2 Parents: 622f045 Author: sboikov <[email protected]> Authored: Thu Dec 8 11:09:26 2016 +0300 Committer: sboikov <[email protected]> Committed: Thu Dec 8 11:09:26 2016 +0300 ---------------------------------------------------------------------- .../ignite/spi/communication/tcp/TcpCommunicationSpi.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/abc5d7a7/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 b16169c..8f5fc74 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 @@ -2600,7 +2600,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter * @return Client. * @throws IgniteCheckedException If failed. */ - @Nullable protected GridCommunicationClient createShmemClient(ClusterNode node, + @Nullable private GridCommunicationClient createShmemClient(ClusterNode node, int connIdx, Integer port) throws IgniteCheckedException { int attempt = 1; @@ -2715,9 +2715,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter ", clientNode=" + node + ", slowClientQueueLimit=" + slowClientQueueLimit + ']'; - U.quietAndWarn( - log, - msg); + U.quietAndWarn(log, msg); getSpiContext().failNode(id.nodeId(), msg); }
