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 <[email protected]> Authored: Fri Sep 15 13:52:49 2017 +0300 Committer: sboikov <[email protected]> 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);
