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 2A82617857 for ; Wed, 4 Mar 2015 00:49:37 +0000 (UTC) Received: (qmail 72401 invoked by uid 500); 4 Mar 2015 00:49:37 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 72368 invoked by uid 500); 4 Mar 2015 00:49:37 -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 72359 invoked by uid 99); 4 Mar 2015 00:49:37 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 04 Mar 2015 00:49:37 +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; Wed, 04 Mar 2015 00:49:34 +0000 Received: (qmail 69135 invoked by uid 99); 4 Mar 2015 00:49:14 -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; Wed, 04 Mar 2015 00:49:14 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 9ECAFE01BD; Wed, 4 Mar 2015 00:49:14 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vkulichenko@apache.org To: commits@ignite.incubator.apache.org Date: Wed, 04 Mar 2015 00:49:15 -0000 Message-Id: <752ca848423b4b939d795921e0df2602@git.apache.org> In-Reply-To: <8a3042a1de30437cbffedb7d548ebbc0@git.apache.org> References: <8a3042a1de30437cbffedb7d548ebbc0@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [2/6] incubator-ignite git commit: IGNITE-141 - Marshallers refactoring X-Virus-Checked: Checked by ClamAV on apache.org IGNITE-141 - Marshallers refactoring Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/74078f6a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/74078f6a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/74078f6a Branch: refs/heads/ignite-141 Commit: 74078f6ad397a823bb5d5a687213d72fb31899d1 Parents: a06dc4a Author: Valentin Kulichenko Authored: Tue Mar 3 15:25:23 2015 -0800 Committer: Valentin Kulichenko Committed: Tue Mar 3 15:25:23 2015 -0800 ---------------------------------------------------------------------- .../ignite/internal/GridEventConsumeHandler.java | 11 ++++++++++- .../ignite/internal/GridMessageListenHandler.java | 11 ++++++++++- .../cache/query/GridCacheQueryManager.java | 3 ++- .../continuous/CacheContinuousQueryHandler.java | 11 ++++++++++- .../continuous/GridContinuousHandler.java | 9 ++++++++- .../continuous/GridContinuousProcessor.java | 8 +++----- .../continuous/GridEventConsumeSelfTest.java | 3 ++- .../internal/processors/igfs/IgfsSizeSelfTest.java | 17 ----------------- 8 files changed, 45 insertions(+), 28 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java index 68d8c0b..fda5ebd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridEventConsumeHandler.java @@ -24,7 +24,6 @@ import org.apache.ignite.internal.managers.deployment.*; import org.apache.ignite.internal.managers.eventstorage.*; import org.apache.ignite.internal.processors.cache.*; import org.apache.ignite.internal.processors.continuous.*; -import org.apache.ignite.internal.util.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.lang.*; @@ -283,6 +282,16 @@ class GridEventConsumeHandler implements GridContinuousHandler { } /** {@inheritDoc} */ + @Override public GridContinuousHandler clone() { + try { + return (GridContinuousHandler)super.clone(); + } + catch (CloneNotSupportedException e) { + throw new IllegalStateException(e); + } + } + + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { boolean b = filterBytes != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java index 199d0ac..6412b63 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridMessageListenHandler.java @@ -20,7 +20,6 @@ package org.apache.ignite.internal; import org.apache.ignite.*; import org.apache.ignite.internal.managers.deployment.*; import org.apache.ignite.internal.processors.continuous.*; -import org.apache.ignite.internal.util.*; import org.apache.ignite.internal.util.lang.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.apache.ignite.lang.*; @@ -163,6 +162,16 @@ public class GridMessageListenHandler implements GridContinuousHandler { } /** {@inheritDoc} */ + @Override public GridContinuousHandler clone() { + try { + return (GridContinuousHandler)super.clone(); + } + catch (CloneNotSupportedException e) { + throw new IllegalStateException(e); + } + } + + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { out.writeBoolean(depEnabled); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java index 8fa48aa..0d03e36 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java @@ -1958,7 +1958,8 @@ public abstract class GridCacheQueryManager extends GridCacheManagerAdapte }, new P1>() { @Override public boolean apply(GridCache c) { - return !CU.UTILITY_CACHE_NAME.equals(c.name()) && !CU.ATOMICS_CACHE_NAME.equals(c.name()); + return !CU.MARSH_CACHE_NAME.equals(c.name()) && !CU.UTILITY_CACHE_NAME.equals(c.name()) && + !CU.ATOMICS_CACHE_NAME.equals(c.name()); } } ); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index 9502b3f..69e12b5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -25,7 +25,6 @@ import org.apache.ignite.internal.managers.deployment.*; import org.apache.ignite.internal.processors.cache.*; import org.apache.ignite.internal.processors.cache.query.*; import org.apache.ignite.internal.processors.continuous.*; -import org.apache.ignite.internal.util.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; import org.jetbrains.annotations.*; @@ -370,6 +369,16 @@ class CacheContinuousQueryHandler implements GridContinuousHandler { } /** {@inheritDoc} */ + @Override public GridContinuousHandler clone() { + try { + return (GridContinuousHandler)super.clone(); + } + catch (CloneNotSupportedException e) { + throw new IllegalStateException(e); + } + } + + /** {@inheritDoc} */ @Override public void writeExternal(ObjectOutput out) throws IOException { U.writeString(out, cacheName); out.writeObject(topic); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java index 17c7a0a..69639c0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousHandler.java @@ -27,7 +27,7 @@ import java.util.*; /** * Continuous routine handler. */ -public interface GridContinuousHandler extends Externalizable { +public interface GridContinuousHandler extends Externalizable, Cloneable { /** * Registers listener. * @@ -89,6 +89,13 @@ public interface GridContinuousHandler extends Externalizable { @Nullable public Object orderedTopic(); /** + * Clones this handler. + * + * @return Clone of this handler. + */ + public GridContinuousHandler clone(); + + /** * @return {@code True} if for events. */ public boolean isForEvents(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java index eed273d..0948211 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java @@ -355,9 +355,6 @@ public class GridContinuousProcessor extends GridProcessorAdapter { // Register handler only if local node passes projection predicate. if (item.prjPred == null || item.prjPred.apply(ctx.discovery().localNode())) { try { - if (ctx.config().isPeerClassLoadingEnabled()) - item.hnd.p2pUnmarshal(data.nodeId, ctx); - if (registerHandler(data.nodeId, item.routineId, item.hnd, item.bufSize, item.interval, item.autoUnsubscribe, false)) item.hnd.onListenerRegistered(item.routineId, ctx); @@ -394,7 +391,7 @@ public class GridContinuousProcessor extends GridProcessorAdapter { // Generate ID. final UUID routineId = UUID.randomUUID(); - StartRequestData reqData = new StartRequestData(prjPred, hnd, bufSize, interval, autoUnsubscribe); + StartRequestData reqData = new StartRequestData(prjPred, hnd.clone(), bufSize, interval, autoUnsubscribe); try { if (ctx.config().isPeerClassLoadingEnabled()) { @@ -416,7 +413,7 @@ public class GridContinuousProcessor extends GridProcessorAdapter { } // Handle peer deployment for other handler-specific objects. - hnd.p2pMarshal(ctx); + reqData.hnd.p2pMarshal(ctx); } } catch (IgniteCheckedException e) { @@ -520,6 +517,7 @@ public class GridContinuousProcessor extends GridProcessorAdapter { if (!nodes.isEmpty()) { // Do not send projection predicate (nodes already filtered). reqData.prjPred = null; + reqData.prjPredBytes = null; // Send start requests. try { http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java index 459786c..a51d1a8 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java @@ -30,6 +30,7 @@ import org.apache.ignite.marshaller.optimized.*; import org.apache.ignite.resources.*; import org.apache.ignite.testframework.junits.common.*; +import java.io.*; import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.*; @@ -41,7 +42,7 @@ import static org.apache.ignite.internal.processors.continuous.GridContinuousPro /** * Event consume test. */ -public class GridEventConsumeSelfTest extends GridCommonAbstractTest { +public class GridEventConsumeSelfTest extends GridCommonAbstractTest implements Serializable { /** */ private static final String PRJ_PRED_CLS_NAME = "org.apache.ignite.tests.p2p.GridEventConsumeProjectionPredicate"; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/74078f6a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSizeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSizeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSizeSelfTest.java index b212f02..40bb2ac 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSizeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsSizeSelfTest.java @@ -21,7 +21,6 @@ import org.apache.ignite.*; import org.apache.ignite.cache.*; import org.apache.ignite.cluster.*; import org.apache.ignite.configuration.*; -import org.apache.ignite.events.*; import org.apache.ignite.igfs.*; import org.apache.ignite.internal.*; import org.apache.ignite.internal.processors.cache.*; @@ -44,7 +43,6 @@ import static org.apache.ignite.cache.CacheAtomicityMode.*; import static org.apache.ignite.cache.CacheDistributionMode.*; import static org.apache.ignite.cache.CacheMode.*; import static org.apache.ignite.cache.CachePreloadMode.*; -import static org.apache.ignite.events.EventType.*; import static org.apache.ignite.internal.processors.igfs.IgfsFileInfo.*; import static org.apache.ignite.transactions.TransactionConcurrency.*; import static org.apache.ignite.transactions.TransactionIsolation.*; @@ -600,25 +598,10 @@ public class IgfsSizeSelfTest extends IgfsCommonAbstractTest { assertEquals(expSize, cache.igfsDataSpaceUsed()); } - // Start a node. - final CountDownLatch latch = new CountDownLatch(GRID_CNT - 1); - - for (int i = 0; i < GRID_CNT - 1; i++) { - grid(0).events().localListen(new IgnitePredicate() { - @Override public boolean apply(Event evt) { - latch.countDown(); - - return true; - } - }, EVT_CACHE_PRELOAD_STOPPED); - } - Ignite g = startGrid(GRID_CNT); info("Started grid: " + g.cluster().localNode().id()); - U.awaitQuiet(latch); - // Wait partitions are evicted. awaitPartitionMapExchange();