You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by dp...@apache.org on 2018/05/10 17:32:28 UTC
[2/5] ignite git commit: IGNITE-5789: code review fixes
IGNITE-5789: code review fixes
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fb1fb643
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fb1fb643
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fb1fb643
Branch: refs/heads/ignite-5789-1
Commit: fb1fb643b41d951bf30e9af77eb6c190b76226cb
Parents: bfa7dc4
Author: vk <ka...@gmail.com>
Authored: Tue Apr 24 18:56:01 2018 +0300
Committer: vk <ka...@gmail.com>
Committed: Tue Apr 24 18:56:01 2018 +0300
----------------------------------------------------------------------
.../dht/preloader/GridDhtPartitionsExchangeFuture.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fb1fb643/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index 31b7776..fb5c107 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -734,16 +734,19 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
*/
private void ensureClientCachesStarted() {
GridCacheProcessor cacheProcessor = cctx.cache();
+
+ Set<String> cacheNames = new HashSet<>(cacheProcessor.cacheNames());
+
List<CacheConfiguration> notStartedCacheConfigs = new ArrayList<>();
+
for (CacheConfiguration cCfg : cctx.gridConfig().getCacheConfiguration()) {
- if (!cacheProcessor.cacheNames().contains(cCfg.getName())) {
+ if (!cacheNames.contains(cCfg.getName())) {
notStartedCacheConfigs.add(cCfg);
}
}
- if (!notStartedCacheConfigs.isEmpty()) {
+ if (!notStartedCacheConfigs.isEmpty())
cacheProcessor.dynamicStartCaches(notStartedCacheConfigs, false, false);
- }
}
/**