# GG-10298: Review.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/9c7e1dc1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/9c7e1dc1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/9c7e1dc1 Branch: refs/heads/ignite-1058 Commit: 9c7e1dc14d9df3236d45515bbcaf984b8a3d6024 Parents: 8f57eca Author: vozerov-gridgain <voze...@gridgain.com> Authored: Fri Jun 26 10:00:48 2015 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Fri Jun 26 10:00:48 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/configuration/IgniteConfiguration.java | 1 + .../core/src/main/java/org/apache/ignite/internal/IgnitionEx.java | 1 + .../ignite/internal/managers/communication/GridIoManager.java | 2 +- 3 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9c7e1dc1/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java index 73d0c80..62df015 100644 --- a/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java @@ -157,6 +157,7 @@ public class IgniteConfiguration { public static final int DFLT_SYSTEM_THREADPOOL_QUEUE_CAP = Integer.MAX_VALUE; /** Default max queue capacity of DR (Data Replication) thread pool. */ + // TODO: Remove public static final int DFLT_DR_THREADPOOL_QUEUE_CAP = 40; /** Default size of peer class loading thread pool. */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9c7e1dc1/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java index b502f14..4ed3932 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java @@ -1532,6 +1532,7 @@ public class IgnitionEx { cfg.getDrThreadPoolSize(), cfg.getDrThreadPoolSize(), DFLT_PUBLIC_KEEP_ALIVE_TIME, + // TODO: Use DFLT_SYSTEM_THREADPOOL_QUEUE_CAP instead. new LinkedBlockingQueue<Runnable>(DFLT_DR_THREADPOOL_QUEUE_CAP)); // Register Ignite MBean for current grid instance. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9c7e1dc1/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 3d90a51..5e8da51 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 @@ -546,6 +546,7 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa break; } + // TODO: Remove. default: throw new IllegalStateException("Failed to process message due to " + "unknown policy, [policy=" + msg.policy() + ']'); @@ -577,7 +578,6 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa return mgmtPool; case AFFINITY_POOL: return affPool; - case DR_POOL: return drPool;
