Repository: ignite Updated Branches: refs/heads/ignite-5272 217f8dbd7 -> faa4d37bf
ignite-5272 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/faa4d37b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/faa4d37b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/faa4d37b Branch: refs/heads/ignite-5272 Commit: faa4d37bfe571aa0a123a667ca4d196a81557c70 Parents: 217f8db Author: sboikov <[email protected]> Authored: Wed Jun 14 15:15:42 2017 +0300 Committer: sboikov <[email protected]> Committed: Wed Jun 14 15:15:42 2017 +0300 ---------------------------------------------------------------------- .../cache/ClientCacheChangeDiscoveryMessage.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/faa4d37b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java index 8639ffe..37eb927 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ClientCacheChangeDiscoveryMessage.java @@ -68,7 +68,7 @@ public class ClientCacheChangeDiscoveryMessage implements DiscoveryCustomMessage if (startedCaches != null) { if (startedCaches0 == null) - startedCaches0 = new HashMap<>(); + this.startedCaches = startedCaches0 = new HashMap<>(); for (Map.Entry<Integer, Boolean> e : startedCaches.entrySet()) { if (closedCaches0 != null && closedCaches0.remove(e.getKey())) @@ -78,24 +78,20 @@ public class ClientCacheChangeDiscoveryMessage implements DiscoveryCustomMessage assert old == null : e.getKey(); } - - this.startedCaches = startedCaches0; } if (closedCaches != null) { if (closedCaches0 == null) - closedCaches0 = new HashSet<>(); + this.closedCaches = closedCaches0 = new HashSet<>(); for (Integer cacheId : closedCaches) { - if (startedCaches0 != null && startedCaches0.remove(cacheId)) + if (startedCaches0 != null && startedCaches0.remove(cacheId) != null) continue; boolean add = closedCaches0.add(cacheId); assert add : cacheId; } - - this.closedCaches = closedCaches0; } }
