Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 717F6200CBB for ; Tue, 4 Jul 2017 12:02:11 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 7047E160C43; Tue, 4 Jul 2017 10:02:11 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id AAE21160C2E for ; Tue, 4 Jul 2017 12:02:10 +0200 (CEST) Received: (qmail 50683 invoked by uid 500); 4 Jul 2017 10:02:09 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 50612 invoked by uid 99); 4 Jul 2017 10:02:09 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 04 Jul 2017 10:02:09 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 70DF2F551C; Tue, 4 Jul 2017 10:02:07 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vozerov@apache.org To: commits@ignite.apache.org Date: Tue, 04 Jul 2017 10:02:20 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [14/50] ignite git commit: Merge remote-tracking branch 'remotes/origin/master' into ignite-2.1.2 archived-at: Tue, 04 Jul 2017 10:02:11 -0000 Merge remote-tracking branch 'remotes/origin/master' into ignite-2.1.2 # Conflicts: # modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java # modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite2.java Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fd09d301 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fd09d301 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fd09d301 Branch: refs/heads/master Commit: fd09d301b14a2e20774503359bcef4280a67da92 Parents: a9db2ad Author: sboikov Authored: Tue Jun 27 12:27:45 2017 +0300 Committer: sboikov Committed: Tue Jun 27 12:27:45 2017 +0300 ---------------------------------------------------------------------- .../cache/IgniteCacheOffheapManagerImpl.java | 38 ++++++++++---------- 1 file changed, 20 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fd09d301/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java index d64d19c..b51fc10 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java @@ -447,31 +447,33 @@ public class IgniteCacheOffheapManagerImpl implements IgniteCacheOffheapManager @Override public void clearCache(GridCacheContext cctx, boolean readers) { GridCacheVersion obsoleteVer = null; - try (GridCloseableIterator it = grp.isLocal() ?iterator(cctx.cacheId(), cacheDataStores().iterator()): -evictionSafeIterator(cctx.cacheId(), cacheDataStores().iterator())) { - while (it.hasNext()) { - cctx.shared().database().checkpointReadLock(); + try (GridCloseableIterator it = grp.isLocal() ? iterator(cctx.cacheId(), cacheDataStores().iterator()) : + evictionSafeIterator(cctx.cacheId(), cacheDataStores().iterator())) { + while (it.hasNext()) { + cctx.shared().database().checkpointReadLock(); - try {KeyCacheObject key = it.next().key(); + try{ + KeyCacheObject key = it.next().key(); - try { - if (obsoleteVer == null) - obsoleteVer = ctx.versions().next(); + try { + if (obsoleteVer == null) + obsoleteVer = ctx.versions().next(); - GridCacheEntryEx entry = cctx.cache().entryEx(key); + GridCacheEntryEx entry = cctx.cache().entryEx(key); - entry.clear(obsoleteVer, readers); - } - catch (GridDhtInvalidPartitionException ignore) { - // Ignore. + entry.clear(obsoleteVer, readers); + } + catch (GridDhtInvalidPartitionException ignore) { + // Ignore. + } + catch (IgniteCheckedException e) { + U.error(log, "Failed to clear cache entry: " + key, e); + } } - catch (IgniteCheckedException e) { - U.error(log, "Failed to clear cache entry: " + key, e); + finally { + cctx.shared().database().checkpointReadUnlock(); } } - finally { - cctx.shared().database().checkpointReadUnlock(); - } } catch (IgniteCheckedException e) { U.error(log, "Failed to close iterator", e);