# GG-10298: corrections by review results.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/64fb6e7c Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/64fb6e7c Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/64fb6e7c Branch: refs/heads/ignite-1058 Commit: 64fb6e7c8b95f7d3fdfaf3949c9c9d86fc0ae7ad Parents: b8604cb Author: iveselovskiy <[email protected]> Authored: Fri Jun 26 13:32:42 2015 +0300 Committer: iveselovskiy <[email protected]> Committed: Fri Jun 26 13:32:42 2015 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/configuration/IgniteConfiguration.java | 4 ---- .../src/main/java/org/apache/ignite/internal/IgnitionEx.java | 3 +-- .../ignite/internal/managers/communication/GridIoManager.java | 5 ----- 3 files changed, 1 insertion(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/64fb6e7c/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 62df015..6e55a35 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 @@ -156,10 +156,6 @@ public class IgniteConfiguration { /** Default max queue capacity of system thread pool. */ 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. */ public static final int DFLT_P2P_THREAD_CNT = 2; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/64fb6e7c/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 4ed3932..590a6df 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,8 +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)); + new LinkedBlockingQueue<Runnable>(DFLT_SYSTEM_THREADPOOL_QUEUE_CAP)); // Register Ignite MBean for current grid instance. registerFactoryMbean(myCfg.getMBeanServer()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/64fb6e7c/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 5e8da51..2203be8 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 @@ -545,11 +545,6 @@ 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() + ']'); } } catch (IgniteCheckedException e) {
