You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/06/05 11:57:59 UTC
ignite git commit: Fixed formatting.
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 <sb...@gridgain.com>
Authored: Mon Jun 5 14:57:54 2017 +0300
Committer: sboikov <sb...@gridgain.com>
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);