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 2016/12/05 14:41:30 UTC
[08/50] [abbrv] ignite git commit: wip
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 <yz...@gridgain.com>
Authored: Tue Nov 8 00:57:08 2016 +0300
Committer: Yakov Zhdanov <yz...@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();