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/28 12:45:25 UTC
[57/64] [abbrv] ignite git commit: Disable striped pool for exchange
messages.
Disable striped pool for exchange messages.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/33f68e27
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/33f68e27
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/33f68e27
Branch: refs/heads/ignite-5075
Commit: 33f68e27b8760fc8ac87278ddc7dd993193bd702
Parents: c096059
Author: sboikov <sb...@gridgain.com>
Authored: Fri Apr 28 09:29:35 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Fri Apr 28 09:29:35 2017 +0300
----------------------------------------------------------------------
.../ignite/internal/managers/communication/GridIoManager.java | 2 +-
.../ignite/internal/managers/communication/GridIoMessage.java | 5 ++++-
.../dht/preloader/GridDhtPartitionsAbstractMessage.java | 6 ++++++
3 files changed, 11 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/33f68e27/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
index c4f7519..9d35c75 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
@@ -824,7 +824,7 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa
return;
}
- if (plc == GridIoPolicy.SYSTEM_POOL && msg.partition() != Integer.MIN_VALUE) {
+ if (plc == GridIoPolicy.SYSTEM_POOL && msg.partition() != GridIoMessage.STRIPE_DISABLED_PART) {
ctx.getStripedExecutorService().execute(msg.partition(), c);
return;
http://git-wip-us.apache.org/repos/asf/ignite/blob/33f68e27/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
index 16eae26..dccd336 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessage.java
@@ -35,6 +35,9 @@ import org.jetbrains.annotations.Nullable;
*/
public class GridIoMessage implements Message {
/** */
+ public static final Integer STRIPE_DISABLED_PART = Integer.MIN_VALUE;
+
+ /** */
private static final long serialVersionUID = 0L;
/** Policy. */
@@ -334,7 +337,7 @@ public class GridIoMessage implements Message {
if (msg instanceof GridCacheMessage)
return ((GridCacheMessage)msg).partition();
else
- return Integer.MIN_VALUE;
+ return STRIPE_DISABLED_PART;
}
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/33f68e27/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java
index 96d7a88..74bbcb0 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsAbstractMessage.java
@@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.cache.distributed.dht.preloader;
import java.io.Externalizable;
import java.nio.ByteBuffer;
import java.util.Map;
+import org.apache.ignite.internal.managers.communication.GridIoMessage;
import org.apache.ignite.internal.processors.cache.GridCacheMessage;
import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
import org.apache.ignite.internal.util.typedef.T2;
@@ -64,6 +65,11 @@ public abstract class GridDhtPartitionsAbstractMessage extends GridCacheMessage
}
/** {@inheritDoc} */
+ @Override public int partition() {
+ return GridIoMessage.STRIPE_DISABLED_PART;
+ }
+
+ /** {@inheritDoc} */
@Override public boolean addDeploymentInfo() {
return false;
}