ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: test
Date Tue, 27 Dec 2016 13:29:29 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1.8.2-balance faac0887d -> dc038fca6


test


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/dc038fca
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/dc038fca
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/dc038fca

Branch: refs/heads/ignite-1.8.2-balance
Commit: dc038fca67a8e087b94902e69bc0538700acbc10
Parents: faac088
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Dec 27 16:10:47 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Dec 27 16:10:47 2016 +0300

----------------------------------------------------------------------
 .../apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/dc038fca/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 c35b5ef..02b976a 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
@@ -2057,7 +2057,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
                         .writerFactory(writerFactory)
                         .skipRecoveryPredicate(skipRecoveryPred)
                         .messageQueueSizeListener(queueSizeMonitor)
-                        .balancing(usePairedConnections) // Current balancing logic assumes
separate in/out connections.
+                        .balancing(true) // Current balancing logic assumes separate in/out
connections.
                         .build();
 
                 boundTcpPort = port;


Mime
View raw message