Repository: ignite Updated Branches: refs/heads/ignite-6149 16e52541e -> 9d90972df
ignite-6149 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9d90972d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9d90972d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9d90972d Branch: refs/heads/ignite-6149 Commit: 9d90972df23a0266246baf6b41774184542233e9 Parents: 16e5254 Author: sboikov <[email protected]> Authored: Wed Sep 13 11:49:39 2017 +0300 Committer: sboikov <[email protected]> Committed: Wed Sep 13 11:49:39 2017 +0300 ---------------------------------------------------------------------- .../processors/cache/mvcc/CacheCoordinatorsSharedManager.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9d90972d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsSharedManager.java index c82633f..0989fdb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/mvcc/CacheCoordinatorsSharedManager.java @@ -496,8 +496,11 @@ public class CacheCoordinatorsSharedManager<K, V> extends GridCacheSharedManager assert left >= 0 : left; - if (left == 0) - activeQueries.remove(mvccCntr); + if (left == 0) { + Integer rmvd = activeQueries.remove(mvccCntr); + + assert rmvd != null; + } } /** */
