ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [57/64] [abbrv] ignite git commit: Disable striped pool for exchange messages.
Date Fri, 28 Apr 2017 12:45:25 GMT
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 <sboikov@gridgain.com>
Authored: Fri Apr 28 09:29:35 2017 +0300
Committer: sboikov <sboikov@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;
     }


Mime
View raw message