ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: ignite-80 Fixed dynamic cache start future completion
Date Mon, 28 Sep 2015 07:31:15 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-80-2 5a110a1d7 -> 04889cd72


ignite-80 Fixed dynamic cache start future completion


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

Branch: refs/heads/ignite-80-2
Commit: 04889cd724c9ca5975429e6a119b2b6d9e689ca2
Parents: 5a110a1
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Sep 28 10:31:02 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Sep 28 10:31:02 2015 +0300

----------------------------------------------------------------------
 .../processors/datastructures/DataStructuresProcessor.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/04889cd7/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
index 17f5f8e..ef2c543 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
@@ -883,7 +883,9 @@ public final class DataStructuresProcessor extends GridProcessorAdapter
{
      * @throws IgniteCheckedException If failed.
      */
     private String compatibleConfiguration(CollectionConfiguration cfg) throws IgniteCheckedException
{
-        List<CacheCollectionInfo> caches = utilityDataCache.localPeek(DATA_STRUCTURES_CACHE_KEY,
null, null);
+        List<CacheCollectionInfo> caches = utilityDataCache.context().affinityNode()
?
+            utilityDataCache.localPeek(DATA_STRUCTURES_CACHE_KEY, null, null) :
+            utilityDataCache.get(DATA_STRUCTURES_CACHE_KEY);
 
         String cacheName = findCompatibleConfiguration(cfg, caches);
 


Mime
View raw message