Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E5E79174E0 for ; Mon, 6 Apr 2015 18:54:35 +0000 (UTC) Received: (qmail 61500 invoked by uid 500); 6 Apr 2015 18:54:35 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 61460 invoked by uid 500); 6 Apr 2015 18:54:35 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 61451 invoked by uid 99); 6 Apr 2015 18:54:35 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 06 Apr 2015 18:54:35 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 06 Apr 2015 18:54:07 +0000 Received: (qmail 59627 invoked by uid 99); 6 Apr 2015 18:54:04 -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; Mon, 06 Apr 2015 18:54:04 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D9DB3E17E1; Mon, 6 Apr 2015 18:54:03 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: agoncharuk@apache.org To: commits@ignite.incubator.apache.org Date: Mon, 06 Apr 2015 18:54:05 -0000 Message-Id: <2b4cb0e32b3f4781b1a57db011885c5d@git.apache.org> In-Reply-To: <91d966c211f74c76b512d2fe8e0b6c96@git.apache.org> References: <91d966c211f74c76b512d2fe8e0b6c96@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [03/50] incubator-ignite git commit: # ignite-668 X-Virus-Checked: Checked by ClamAV on apache.org # ignite-668 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/682bec6a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/682bec6a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/682bec6a Branch: refs/heads/ignite-477 Commit: 682bec6a5d2df9e91521622c82dd867a58f73be2 Parents: f9af2d5 Author: sboikov Authored: Fri Apr 3 14:53:53 2015 +0300 Committer: sboikov Committed: Fri Apr 3 14:53:53 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheProcessor.java | 10 +++---- .../cache/IgniteInternalCacheTypesTest.java | 29 +++++++++++++++++++- .../processors/igfs/IgfsStartCacheTest.java | 20 +++++++++++++- 3 files changed, 52 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/682bec6a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java index 1d04fd2..0455ff0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java @@ -2302,15 +2302,15 @@ public class GridCacheProcessor extends GridProcessorAdapter { IgniteCache cache = (IgniteCache)jCacheProxies.get(masked); - if (cache == null) { - DynamicCacheDescriptor desc = registeredCaches.get(masked); + DynamicCacheDescriptor desc = registeredCaches.get(masked); + + if (desc != null && !desc.cacheType().userCache()) + throw new IllegalStateException("Failed to get cache because it is a system cache: " + cacheName); + if (cache == null) { if (desc == null || desc.cancelled()) throw new IllegalArgumentException("Cache is not started: " + cacheName); - if (!desc.cacheType().userCache()) - throw new IllegalStateException("Failed to get cache because it is a system cache: " + cacheName); - DynamicCacheChangeRequest req = new DynamicCacheChangeRequest(cacheName, ctx.localNodeId()); req.cacheName(cacheName); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/682bec6a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteInternalCacheTypesTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteInternalCacheTypesTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteInternalCacheTypesTest.java index 37bde6c..c9da7c5 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteInternalCacheTypesTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteInternalCacheTypesTest.java @@ -25,8 +25,11 @@ import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.spi.discovery.tcp.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; +import org.apache.ignite.testframework.*; import org.apache.ignite.testframework.junits.common.*; +import java.util.concurrent.*; + import static org.apache.ignite.internal.managers.communication.GridIoPolicy.*; /** @@ -98,7 +101,31 @@ public class IgniteInternalCacheTypesTest extends GridCommonAbstractTest { * @param ignite Ignite. * @param userCaches User caches. */ - private void checkCacheTypes(Ignite ignite, String... userCaches) { + private void checkCacheTypes(final Ignite ignite, String... userCaches) { + GridTestUtils.assertThrows(log(), new Callable() { + @Override public Object call() throws Exception { + ignite.cache(CU.UTILITY_CACHE_NAME); + + return null; + } + }, IllegalStateException.class, null); + + GridTestUtils.assertThrows(log(), new Callable() { + @Override public Object call() throws Exception { + ignite.cache(CU.MARSH_CACHE_NAME); + + return null; + } + }, IllegalStateException.class, null); + + GridTestUtils.assertThrows(log(), new Callable() { + @Override public Object call() throws Exception { + ignite.cache(CU.ATOMICS_CACHE_NAME); + + return null; + } + }, IllegalStateException.class, null); + checkCache(ignite, CU.UTILITY_CACHE_NAME, UTILITY_CACHE_POOL, false, true); checkCache(ignite, CU.MARSH_CACHE_NAME, MARSH_CACHE_POOL, false, false); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/682bec6a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsStartCacheTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsStartCacheTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsStartCacheTest.java index 09fa455..b5162e2 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsStartCacheTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsStartCacheTest.java @@ -26,8 +26,10 @@ import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.spi.discovery.tcp.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; +import org.apache.ignite.testframework.*; import java.io.*; +import java.util.concurrent.*; import static org.apache.ignite.cache.CacheAtomicityMode.*; import static org.apache.ignite.cache.CacheMode.*; @@ -123,7 +125,23 @@ public class IgfsStartCacheTest extends IgfsCommonAbstractTest { /** * @param ignite Ignite. */ - private void checkIgfsCaches(Ignite ignite) { + private void checkIgfsCaches(final Ignite ignite) { + GridTestUtils.assertThrows(log(), new Callable() { + @Override public Object call() throws Exception { + ignite.cache("dataCache"); + + return null; + } + }, IllegalStateException.class, null); + + GridTestUtils.assertThrows(log(), new Callable() { + @Override public Object call() throws Exception { + ignite.cache("metaCache"); + + return null; + } + }, IllegalStateException.class, null); + checkCache(((IgniteKernal)ignite).internalCache("dataCache")); checkCache(((IgniteKernal)ignite).internalCache("metaCache")); }