You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/04/24 15:03:37 UTC
[14/50] [abbrv] ignite git commit: Revert: Prove that problem is not
in the onFirstMessage hang
Revert: Prove that problem is not in the onFirstMessage hang
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f8076edb
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f8076edb
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f8076edb
Branch: refs/heads/ignite-3054
Commit: f8076edba097f6077229b2090ee3ff1a3369878c
Parents: c2c1819
Author: Alexandr Kuramshin <ak...@gridgain.com>
Authored: Sat Nov 19 23:26:37 2016 +0300
Committer: Alexandr Kuramshin <ak...@gridgain.com>
Committed: Sat Nov 19 23:26:37 2016 +0300
----------------------------------------------------------------------
.../spi/communication/tcp/TcpCommunicationSpi.java | 12 ------------
1 file changed, 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f8076edb/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 ae276dd..afd4db2 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
@@ -46,7 +46,6 @@ import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.atomic.AtomicInteger;
import javax.net.ssl.SSLEngine;
import javax.net.ssl.SSLException;
import org.apache.ignite.Ignite;
@@ -239,12 +238,6 @@ import static org.apache.ignite.internal.util.nio.GridNioSessionMetaKey.SSL_META
@IgniteSpiConsistencyChecked(optional = false)
public class TcpCommunicationSpi extends IgniteSpiAdapter
implements CommunicationSpi<Message>, TcpCommunicationSpiMBean {
-
- /** */
- public static final AtomicInteger FIRST_MESSAGE_STARTED_COUNT = new AtomicInteger();
- /** */
- public static final AtomicInteger FIRST_MESSAGE_ACTIVE_COUNT = new AtomicInteger();
-
/** IPC error message. */
public static final String OUT_OF_RESOURCES_TCP_MSG = "Failed to allocate shared memory segment " +
"(switching to TCP, may be slower).";
@@ -554,12 +547,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
}
try {
- log.error("onFirstMessage enter, node = " + getLocalNodeId());
- FIRST_MESSAGE_STARTED_COUNT.incrementAndGet();
- FIRST_MESSAGE_ACTIVE_COUNT.incrementAndGet();
onFirstMessage(ses, msg);
- FIRST_MESSAGE_ACTIVE_COUNT.decrementAndGet();
- log.error("onFirstMessage exit, node = " + getLocalNodeId());
}
finally {
connectGate.leave();