You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/06/29 19:49:38 UTC
[07/12] incubator-ignite git commit: # GG-10298: corrections by
review results.
# 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 <iv...@gridgain.com>
Authored: Fri Jun 26 13:32:42 2015 +0300
Committer: iveselovskiy <iv...@gridgain.com>
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) {