ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [23/30] incubator-ignite git commit: # ignite-sprint-3 Added support for nodes filters and minor cleanup of configs.
Date Tue, 31 Mar 2015 09:15:13 GMT
# ignite-sprint-3 Added support for nodes filters and minor cleanup of configs.


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

Branch: refs/heads/ignite-443
Commit: 768ca6aab93c63f37e506318065bb491870ee8f4
Parents: bca4198
Author: AKuznetsov <akuznetsov@gridgain.com>
Authored: Tue Mar 31 11:44:10 2015 +0700
Committer: AKuznetsov <akuznetsov@gridgain.com>
Committed: Tue Mar 31 11:44:10 2015 +0700

----------------------------------------------------------------------
 .../visor/cache/VisorCacheStoreConfiguration.java | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/768ca6aa/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java
b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java
index 7284b7d..a4a2235 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCacheStoreConfiguration.java
@@ -22,6 +22,7 @@ import org.apache.ignite.cache.store.*;
 import org.apache.ignite.cache.store.jdbc.*;
 import org.apache.ignite.configuration.*;
 import org.apache.ignite.internal.*;
+import org.apache.ignite.internal.processors.cache.*;
 import org.apache.ignite.internal.util.typedef.internal.*;
 import org.jetbrains.annotations.*;
 
@@ -67,13 +68,16 @@ public class VisorCacheStoreConfiguration implements Serializable {
     private int flushThreadCnt;
 
     /**
+     * @param ignite Ignite instance.
      * @param ccfg Cache configuration.
      * @return Data transfer object for cache store configuration properties.
      */
     public static VisorCacheStoreConfiguration from(Ignite ignite, CacheConfiguration ccfg)
{
         VisorCacheStoreConfiguration cfg = new VisorCacheStoreConfiguration();
 
-        CacheStore store = ((IgniteKernal)ignite).internalCache(ccfg.getName()).context().store().configuredStore();
+        GridCacheAdapter<Object, Object> c = ((IgniteKernal)ignite).internalCache(ccfg.getName());
+
+        CacheStore store = c != null && c.context().started() ? c.context().store().configuredStore()
: null;
 
         cfg.jdbcStore = store instanceof CacheAbstractJdbcStore;
 
@@ -156,10 +160,10 @@ public class VisorCacheStoreConfiguration implements Serializable {
     }
 
     /**
-     * @param batchSize New maximum batch size for write-behind cache store operations.
+     * @param batchSz New maximum batch size for write-behind cache store operations.
      */
-    public void batchSize(int batchSize) {
-        this.batchSz = batchSize;
+    public void batchSize(int batchSz) {
+        this.batchSz = batchSz;
     }
 
     /**
@@ -184,10 +188,10 @@ public class VisorCacheStoreConfiguration implements Serializable {
     }
 
     /**
-     * @param flushSize New maximum object count in write-behind cache.
+     * @param flushSz New maximum object count in write-behind cache.
      */
-    public void flushSize(int flushSize) {
-        this.flushSz = flushSize;
+    public void flushSize(int flushSz) {
+        this.flushSz = flushSz;
     }
 
     /**


Mime
View raw message