ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-6149
Date Fri, 15 Sep 2017 10:52:57 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-6149 06ce6871b -> fcf4e3037


ignite-6149


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

Branch: refs/heads/ignite-6149
Commit: fcf4e3037b0d32efc525ca101a98d506bd372fc5
Parents: 06ce687
Author: sboikov <sboikov@gridgain.com>
Authored: Fri Sep 15 13:52:49 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Fri Sep 15 13:52:49 2017 +0300

----------------------------------------------------------------------
 .../internal/managers/communication/GridIoManager.java  | 12 ++++++++++++
 1 file changed, 12 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/fcf4e303/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 f63f5f0..5c2dfd7 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
@@ -65,6 +65,7 @@ import org.apache.ignite.internal.managers.GridManagerAdapter;
 import org.apache.ignite.internal.managers.deployment.GridDeployment;
 import org.apache.ignite.internal.managers.eventstorage.GridEventStorageManager;
 import org.apache.ignite.internal.managers.eventstorage.GridLocalEventListener;
+import org.apache.ignite.internal.processors.cache.mvcc.MvccCoordinatorMessage;
 import org.apache.ignite.internal.processors.platform.message.PlatformMessageFilter;
 import org.apache.ignite.internal.processors.pool.PoolProcessor;
 import org.apache.ignite.internal.processors.timeout.GridTimeoutObject;
@@ -102,6 +103,7 @@ import org.jsr166.LongAdder8;
 import static org.apache.ignite.events.EventType.EVT_NODE_FAILED;
 import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
 import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;
+import static org.apache.ignite.internal.GridTopic.TOPIC_CACHE_COORDINATOR;
 import static org.apache.ignite.internal.GridTopic.TOPIC_COMM_USER;
 import static org.apache.ignite.internal.GridTopic.TOPIC_IO_TEST;
 import static org.apache.ignite.internal.managers.communication.GridIoPolicy.AFFINITY_POOL;
@@ -1111,6 +1113,16 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa
 
             return;
         }
+        if (msg.topicOrdinal() == TOPIC_CACHE_COORDINATOR.ordinal()) {
+            MvccCoordinatorMessage msg0 = (MvccCoordinatorMessage)msg.message();
+
+            if (msg0.processedOnCoordinator())
+                c.run();
+            else
+                ctx.getStripedExecutorService().execute(-1, c);
+
+            return;
+        }
 
         if (plc == GridIoPolicy.SYSTEM_POOL && msg.partition() != GridIoMessage.STRIPE_DISABLED_PART)
{
             ctx.getStripedExecutorService().execute(msg.partition(), c);


Mime
View raw message