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 3209818F54 for ; Tue, 28 Apr 2015 12:33:38 +0000 (UTC) Received: (qmail 12433 invoked by uid 500); 28 Apr 2015 12:33:38 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 12402 invoked by uid 500); 28 Apr 2015 12:33:38 -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 12376 invoked by uid 99); 28 Apr 2015 12:33:38 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 28 Apr 2015 12:33:38 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of root@apache.org designates 54.76.25.247 as permitted sender) Received: from [54.76.25.247] (HELO mx1-eu-west.apache.org) (54.76.25.247) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 28 Apr 2015 12:33:12 +0000 Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with SMTP id DE8EF2AA7E for ; Tue, 28 Apr 2015 12:32:47 +0000 (UTC) Received: (qmail 10698 invoked by uid 99); 28 Apr 2015 12:32:44 -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, 28 Apr 2015 12:32:44 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 798FBE0A21; Tue, 28 Apr 2015 12:32:44 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.incubator.apache.org Date: Tue, 28 Apr 2015 12:33:16 -0000 Message-Id: <96402a6cd976496eb95bc4a959217dfb@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [34/50] incubator-ignite git commit: ignite-800: Fixed. X-Virus-Checked: Checked by ClamAV on apache.org ignite-800: Fixed. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/3e8db5b9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/3e8db5b9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/3e8db5b9 Branch: refs/heads/ignite-676 Commit: 3e8db5b94b3526defd4d86b7429a111f0d0b0143 Parents: cf55393 Author: Artem Shutak Authored: Mon Apr 27 16:18:47 2015 +0300 Committer: Artem Shutak Committed: Mon Apr 27 16:18:47 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/CacheInvokeResult.java | 24 ++++++++++++++++---- .../processors/cache/GridCacheAdapter.java | 2 +- .../processors/cache/GridCacheMapEntry.java | 4 ++-- .../processors/cache/GridCacheReturn.java | 5 ++-- .../dht/atomic/GridDhtAtomicCache.java | 3 +-- .../local/atomic/GridLocalAtomicCache.java | 6 ++--- .../GridSwapSpaceSpiAbstractSelfTest.java | 2 +- 7 files changed, 31 insertions(+), 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java index 422b763..21dad67 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheInvokeResult.java @@ -45,17 +45,33 @@ public class CacheInvokeResult implements EntryProcessorResult, Externaliz } /** + * Static constructor. + * * @param res Computed result. + * @return New instance. */ - public CacheInvokeResult(T res) { - this.res = res; + public static CacheInvokeResult fromResult(T res) { + CacheInvokeResult cacheRes = new CacheInvokeResult<>(); + + cacheRes.res = res; + + return cacheRes; } /** + * Static constructor. + * * @param err Exception thrown by {@link EntryProcessor#process(MutableEntry, Object...)}. + * @return New instance. */ - public CacheInvokeResult(Exception err) { - this.err = err; + public static CacheInvokeResult fromError(Exception err) { + assert err != null; + + CacheInvokeResult res = new CacheInvokeResult<>(); + + res.err = err; + + return res; } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index c246661..3f4e97b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -2098,7 +2098,7 @@ public abstract class GridCacheAdapter implements IgniteInternalCache((T)null); + return res != null ? res : new CacheInvokeResult(); } }); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java index c9f55f5..3dcd0ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java @@ -1402,12 +1402,12 @@ public abstract class GridCacheMapEntry implements GridCacheEntryEx { key0 = entry.key(); - invokeRes = computed != null ? new CacheInvokeResult<>(cctx.unwrapTemporary(computed)) : null; + invokeRes = computed != null ? CacheInvokeResult.fromResult(cctx.unwrapTemporary(computed)) : null; } catch (Exception e) { updated = old; - invokeRes = new CacheInvokeResult<>(e); + invokeRes = CacheInvokeResult.fromError(e); } if (!entry.modified()) { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java index c21dcef..743d42c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheReturn.java @@ -223,7 +223,7 @@ public class GridCacheReturn implements Externalizable, Message { v = resMap; } - CacheInvokeResult res0 = err == null ? new CacheInvokeResult(res) : new CacheInvokeResult(err); + CacheInvokeResult res0 = err == null ? CacheInvokeResult.fromResult(res) : CacheInvokeResult.fromError(err); resMap.put(key0 != null ? key0 : CU.value(key, cctx, true), res0); } @@ -313,7 +313,8 @@ public class GridCacheReturn implements Externalizable, Message { for (CacheInvokeDirectResult res : invokeResCol) { CacheInvokeResult res0 = res.error() == null ? - new CacheInvokeResult<>(CU.value(res.result(), ctx, false)) : new CacheInvokeResult<>(res.error()); + CacheInvokeResult.fromResult(CU.value(res.result(), ctx, false)) : + CacheInvokeResult.fromError(res.error()); map0.put(res.key().value(ctx.cacheObjectContext(), false), res0); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index ccacca1..905f7bf 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -21,7 +21,6 @@ import org.apache.ignite.*; import org.apache.ignite.cluster.*; import org.apache.ignite.internal.*; import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.managers.communication.*; import org.apache.ignite.internal.processors.affinity.*; import org.apache.ignite.internal.processors.cache.*; import org.apache.ignite.internal.processors.cache.distributed.dht.*; @@ -604,7 +603,7 @@ public class GridDhtAtomicCache extends GridDhtCacheAdapter { throws IgniteCheckedException { EntryProcessorResult res = invokeAsync(key, entryProcessor, args).get(); - return res != null ? res : new CacheInvokeResult<>((T)null); + return res != null ? res : new CacheInvokeResult(); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java index 8095600..936ed9d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java @@ -570,7 +570,7 @@ public class GridLocalAtomicCache extends GridCacheAdapter { Object... args) throws IgniteCheckedException { EntryProcessorResult res = invokeAsync(key, entryProcessor, args).get(); - return res != null ? res : new CacheInvokeResult<>((T)null); + return res != null ? res : new CacheInvokeResult(); } /** {@inheritDoc} */ @@ -1056,10 +1056,10 @@ public class GridLocalAtomicCache extends GridCacheAdapter { updated = ctx.toCacheObject(updatedVal); if (computed != null) - invokeRes = new CacheInvokeResult<>(ctx.unwrapTemporary(computed)); + invokeRes = CacheInvokeResult.fromResult(ctx.unwrapTemporary(computed)); } catch (Exception e) { - invokeRes = new CacheInvokeResult<>(e); + invokeRes = CacheInvokeResult.fromError(e); updated = old; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3e8db5b9/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java index da673d9..5740915 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/swapspace/GridSwapSpaceSpiAbstractSelfTest.java @@ -608,7 +608,7 @@ public abstract class GridSwapSpaceSpiAbstractSelfTest extends GridCommonAbstrac /** * Key. */ - private static class Key { + private static class Key implements Serializable { /** Index. */ private final int i;