ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [14/50] [abbrv] ignite git commit: Revert: Prove that problem is not in the onFirstMessage hang
Date Mon, 24 Apr 2017 15:03:37 GMT
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 <akuramshin@gridgain.com>
Authored: Sat Nov 19 23:26:37 2016 +0300
Committer: Alexandr Kuramshin <akuramshin@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();


Mime
View raw message