Repository: ignite Updated Branches: refs/heads/ignite-5267 0ce28c646 -> 874b1f472
Fixed formatting. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/874b1f47 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/874b1f47 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/874b1f47 Branch: refs/heads/ignite-5267 Commit: 874b1f472cdf866a516f858b2a069a32ce41156f Parents: 0ce28c6 Author: sboikov <[email protected]> Authored: Mon Jun 5 14:57:54 2017 +0300 Committer: sboikov <[email protected]> Committed: Mon Jun 5 14:57:54 2017 +0300 ---------------------------------------------------------------------- .../cache/CacheAffinitySharedManager.java | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/874b1f47/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheAffinitySharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheAffinitySharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheAffinitySharedManager.java index 44bb04f..d8ca177 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheAffinitySharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheAffinitySharedManager.java @@ -405,17 +405,18 @@ public class CacheAffinitySharedManager<K, V> extends GridCacheSharedManagerAdap } } - Set<Integer> gprs = new HashSet<>(); + Set<Integer> gprs = new HashSet<>(); - for (ExchangeActions.ActionData action : exchActions.newAndClientCachesStartRequests()) { - Integer grpId = action.descriptor().groupId(); + for (ExchangeActions.ActionData action : exchActions.newAndClientCachesStartRequests()) { + Integer grpId = action.descriptor().groupId(); - if (gprs.add(grpId)) { - if (crd && lateAffAssign) - initStartedGroupOnCoordinator(fut, action.descriptor().groupDescriptor());else { - CacheGroupContext grp = cctx.cache().cacheGroup(grpId); + if (gprs.add(grpId)) { + if (crd && lateAffAssign) + initStartedGroupOnCoordinator(fut, action.descriptor().groupDescriptor()); + else { + CacheGroupContext grp = cctx.cache().cacheGroup(grpId); - if (grp != null && !grp.isLocal() && grp.localStartVersion().equals(fut.topologyVersion())) { + if (grp != null && !grp.isLocal() && grp.localStartVersion().equals(fut.topologyVersion())) { assert grp.affinity().lastVersion().equals(AffinityTopologyVersion.NONE) : grp.affinity().lastVersion(); initAffinity(registeredGrps.get(grp.groupId()), grp.affinity(), fut);
