ignite-support804 - switched to a system pool
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/23377fe0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/23377fe0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/23377fe0 Branch: refs/heads/ignite-946 Commit: 23377fe02157c749d64941f0ce1dcd58c8445d04 Parents: 77e3976 Author: S.Vladykin <svlady...@gridgain.com> Authored: Thu Jul 30 11:51:34 2015 +0300 Committer: S.Vladykin <svlady...@gridgain.com> Committed: Thu Jul 30 11:51:34 2015 +0300 ---------------------------------------------------------------------- .../processors/query/h2/twostep/GridMapQueryExecutor.java | 7 ++++--- .../processors/query/h2/twostep/GridReduceQueryExecutor.java | 7 +++++-- 2 files changed, 9 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/23377fe0/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridMapQueryExecutor.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridMapQueryExecutor.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridMapQueryExecutor.java index 0f38353..6ab1a1b 100644 --- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridMapQueryExecutor.java +++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridMapQueryExecutor.java @@ -50,6 +50,7 @@ import java.util.concurrent.atomic.*; import static org.apache.ignite.events.EventType.*; import static org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion.*; import static org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionState.*; +import static org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor.*; import static org.apache.ignite.internal.processors.query.h2.twostep.msg.GridH2ValueMessageFactory.*; /** @@ -495,7 +496,7 @@ public class GridMapQueryExecutor { if (node.isLocal()) h2.reduceQueryExecutor().onMessage(ctx.localNodeId(), msg); else - ctx.io().send(node, GridTopic.TOPIC_QUERY, msg, GridIoPolicy.PUBLIC_POOL); + ctx.io().send(node, GridTopic.TOPIC_QUERY, msg, QUERY_POOL); } catch (Exception e) { e.addSuppressed(err); @@ -556,7 +557,7 @@ public class GridMapQueryExecutor { if (loc) h2.reduceQueryExecutor().onMessage(ctx.localNodeId(), msg); else - ctx.io().send(node, GridTopic.TOPIC_QUERY, msg, GridIoPolicy.PUBLIC_POOL); + ctx.io().send(node, GridTopic.TOPIC_QUERY, msg, QUERY_POOL); } catch (IgniteCheckedException e) { log.error("Failed to send message.", e); @@ -583,7 +584,7 @@ public class GridMapQueryExecutor { if (loc) h2.reduceQueryExecutor().onMessage(ctx.localNodeId(), msg); else - ctx.io().send(node, GridTopic.TOPIC_QUERY, msg, GridIoPolicy.PUBLIC_POOL); + ctx.io().send(node, GridTopic.TOPIC_QUERY, msg, QUERY_POOL); } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/23377fe0/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java index 32d1c95..ffa2bc0 100644 --- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java +++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/twostep/GridReduceQueryExecutor.java @@ -63,6 +63,9 @@ import static org.apache.ignite.internal.processors.affinity.AffinityTopologyVer * Reduce query executor. */ public class GridReduceQueryExecutor { + /** Thread pool to process query messages. */ + public static final byte QUERY_POOL = GridIoPolicy.SYSTEM_POOL; + /** */ private GridKernalContext ctx; @@ -248,7 +251,7 @@ public class GridReduceQueryExecutor { if (node.isLocal()) h2.mapQueryExecutor().onMessage(ctx.localNodeId(), msg0); else - ctx.io().send(node, GridTopic.TOPIC_QUERY, msg0, GridIoPolicy.PUBLIC_POOL); + ctx.io().send(node, GridTopic.TOPIC_QUERY, msg0, QUERY_POOL); } catch (IgniteCheckedException e) { throw new CacheException("Failed to fetch data from node: " + node.id(), e); @@ -855,7 +858,7 @@ public class GridReduceQueryExecutor { } try { - ctx.io().send(node, GridTopic.TOPIC_QUERY, copy(msg, node, partsMap), GridIoPolicy.PUBLIC_POOL); + ctx.io().send(node, GridTopic.TOPIC_QUERY, copy(msg, node, partsMap), QUERY_POOL); } catch (IgniteCheckedException e) { ok = false;
