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:39 UTC
[16/50] [abbrv] ignite git commit: Revert: pushing unnecessary
changes to the master
Revert: pushing unnecessary changes to the master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6e1f2dfc
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6e1f2dfc
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6e1f2dfc
Branch: refs/heads/ignite-3054
Commit: 6e1f2dfc2acb3dbb8f24aa51ed67b2ee447b4585
Parents: f8076ed
Author: Alexandr Kuramshin <ak...@gridgain.com>
Authored: Mon Nov 21 11:55:09 2016 +0300
Committer: Alexandr Kuramshin <ak...@gridgain.com>
Committed: Mon Nov 21 11:55:09 2016 +0300
----------------------------------------------------------------------
.../apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/6e1f2dfc/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 afd4db2..1fe437c 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
@@ -501,7 +501,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
GridTcpNioCommunicationClient client =
connected(recoveryDesc, ses, rmtNode, msg0.received(), true, !hasShmemClient);
- // here the RecoveryLastReceivedMessage is in the session queue
fut.onDone(client);
}
finally {
@@ -2747,7 +2746,6 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
i += read;
}
- // will got here rcvCnt = 0 if read timeout have been occurred and the channel was closed
rcvCnt = buf.getLong(1);
}