ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [08/50] [abbrv] ignite git commit: wip
Date Mon, 05 Dec 2016 14:41:30 GMT
wip


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

Branch: refs/heads/ignite-comm-balance-master
Commit: 4a17ba1c49da757c1e5b36ff80b1147811055141
Parents: db25d75
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Tue Nov 8 00:57:08 2016 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Tue Nov 8 00:57:08 2016 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/internal/util/StripedExecutor.java    | 4 ++--
 .../apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/4a17ba1c/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
index 8b7ba13..e4d89c4 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
@@ -51,7 +51,7 @@ public class StripedExecutor {
         stripes = new Stripe[cnt];
 
         for (int i = 0; i < cnt; i++) {
-            Stripe stripe = new StripeConcurrentQueueNoPark();
+            Stripe stripe = new StripeConcurrentQueue();
 
             stripes[i] = stripe;
 
@@ -265,7 +265,7 @@ public class StripedExecutor {
         @Override Runnable take() throws InterruptedException {
             Runnable r;
 
-            for (int i = 0; i < 256; i++) {
+            for (int i = 0; i < 2048; i++) {
                 r = queue.poll();
 
                 if (r != null)

http://git-wip-us.apache.org/repos/asf/ignite/blob/4a17ba1c/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 2473309..5ec1d1e 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
@@ -292,7 +292,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
      * Default count of selectors for TCP server equals to
      * {@code "Math.min(8, Runtime.getRuntime().availableProcessors())"}.
      */
-    public static final int DFLT_SELECTORS_CNT = Math.min(4, Runtime.getRuntime().availableProcessors());
+    public static final int DFLT_SELECTORS_CNT = Math.max(4, Runtime.getRuntime().availableProcessors()
/ 2);
 
     /** Connection index meta for session. */
     private static final int CONN_IDX_META = GridNioSessionMetaKey.nextUniqueKey();


Mime
View raw message