ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject [1/2] ignite git commit: IGNITE-2004 Updated javadoc.
Date Thu, 17 Mar 2016 17:51:00 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2004 8c13516d7 -> e2f44db8e


IGNITE-2004 Updated javadoc.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7dbf106a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7dbf106a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7dbf106a

Branch: refs/heads/ignite-2004
Commit: 7dbf106aa62c7280fb645a80e6b3d7b4bb93fc78
Parents: 8c13516
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Thu Mar 17 15:29:26 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Thu Mar 17 15:29:26 2016 +0300

----------------------------------------------------------------------
 .../configuration/IgniteConfiguration.java      | 26 ++++++++++++--------
 .../continuous/CacheContinuousQueryManager.java |  6 ++---
 2 files changed, 19 insertions(+), 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/7dbf106a/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 f34f530..abad527 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
@@ -713,7 +713,9 @@ public class IgniteConfiguration {
     }
 
     /**
-     * TODO: add javadoc
+     * Size of thread pool that is in charge of processing continuous query events.
+     * <p>
+     * If not provided, executor service will have size {@link #DFLT_PUBLIC_THREAD_CNT}.
      *
      * @return Thread pool size to be used
      */
@@ -722,15 +724,6 @@ public class IgniteConfiguration {
     }
 
     /**
-     * TODO: add javadoc
-     *
-     * @param conQryPoolSize
-     */
-    public void setContinuousQueryPoolSize(int conQryPoolSize) {
-        this.conQryPoolSize = conQryPoolSize;
-    }
-
-    /**
      * Size of thread pool that is in charge of processing internal and Visor
      * {@link ComputeJob GridJobs}.
      * <p>
@@ -839,6 +832,19 @@ public class IgniteConfiguration {
     }
 
     /**
+     * Sets continuous query thread pool size to use within grid.
+     *
+     * @param poolSize Thread pool size to use within grid.
+     * @return {@code this} for chaining.
+     * @see IgniteConfiguration#getContinuousQueryPoolSize()
+     */
+    public IgniteConfiguration setContinuousQueryPoolSize(int poolSize) {
+        this.conQryPoolSize = poolSize;
+
+        return this;
+    }
+
+    /**
      * Sets management thread pool size to use within grid.
      *
      * @param poolSize Thread pool size to use within grid.

http://git-wip-us.apache.org/repos/asf/ignite/blob/7dbf106a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
index 5c81988..1c4d1f3 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -1052,7 +1052,7 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter
{
                 try {
                     switch (evt.getEventType()) {
                         case CREATED:
-                            assert impl instanceof CacheEntryCreatedListener;
+                            assert impl instanceof CacheEntryCreatedListener : evt;
 
                             ((CacheEntryCreatedListener<K, V>)impl).onCreated(singleton(evt));
 
@@ -1066,14 +1066,14 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter
{
                             break;
 
                         case REMOVED:
-                            assert impl instanceof CacheEntryRemovedListener;
+                            assert impl instanceof CacheEntryRemovedListener : evt;
 
                             ((CacheEntryRemovedListener<K, V>)impl).onRemoved(singleton(evt));
 
                             break;
 
                         case EXPIRED:
-                            assert impl instanceof CacheEntryExpiredListener;
+                            assert impl instanceof CacheEntryExpiredListener : evt;
 
                             ((CacheEntryExpiredListener<K, V>)impl).onExpired(singleton(evt));
 


Mime
View raw message