ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [3/3] incubator-ignite git commit: # GG-10298: Review.
Date Fri, 26 Jun 2015 07:00:41 GMT
# 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-gg-10298
Commit: 9c7e1dc14d9df3236d45515bbcaf984b8a3d6024
Parents: 8f57eca
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Fri Jun 26 10:00:48 2015 +0300
Committer: vozerov-gridgain <vozerov@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;
 


Mime
View raw message