Repository: incubator-ignite Updated Branches: refs/heads/ignite-752 05d5ce68d -> 85d4163c3
review Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/85d4163c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/85d4163c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/85d4163c Branch: refs/heads/ignite-752 Commit: 85d4163c37c16f5a00c1e9e13dc3aa0ca0196529 Parents: 05d5ce6 Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Thu Jul 23 12:49:36 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Thu Jul 23 12:49:36 2015 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 8 ++++---- .../messages/TcpDiscoveryConnectionCheckMessage.java | 12 ++++++------ 2 files changed, 10 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/85d4163c/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java index f6a1cdc..213ea63 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java @@ -5,9 +5,9 @@ * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -1010,7 +1010,7 @@ class ClientImpl extends TcpDiscoveryImpl { log.debug("Failed to get acknowledge for message, will try to reconnect " + "[msg=" + unacked + (spi.failureDetectionThresholdEnabled() ? - ", failureDetectionThershold=" + spi.failureDetectionThreshold() : + ", failureDetectionThreshold=" + spi.failureDetectionThreshold() : ", timeout=" + spi.getAckTimeout()) + ']'); throw new IOException("Failed to get acknowledge for message: " + unacked); @@ -1095,7 +1095,7 @@ class ClientImpl extends TcpDiscoveryImpl { else U.error(log, "Failed to reconnect to cluster (consider increasing 'networkTimeout'" + " configuration property) [networkTimeout=" + spi.netTimeout + ", sock=" + sock + ']'); - + return; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/85d4163c/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryConnectionCheckMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryConnectionCheckMessage.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryConnectionCheckMessage.java index 9c8d7cd..c7e99c8 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryConnectionCheckMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryConnectionCheckMessage.java @@ -48,17 +48,17 @@ public class TcpDiscoveryConnectionCheckMessage extends TcpDiscoveryAbstractMess } /** {@inheritDoc} */ - @Override public String toString() { - return S.toString(TcpDiscoveryConnectionCheckMessage.class, this, "super", super.toString()); + @Override public void writeExternal(ObjectOutput out) throws IOException { + // This method has been left empty intentionally to keep message size at min. } /** {@inheritDoc} */ - @Override public void writeExternal(ObjectOutput out) throws IOException { - // No-op + @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { + // This method has been left empty intentionally to keep message size at min. } /** {@inheritDoc} */ - @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { - // No-op + @Override public String toString() { + return S.toString(TcpDiscoveryConnectionCheckMessage.class, this, "super", super.toString()); } }
