IGNITE-96 - Changed portable processor start order.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/04927740 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/04927740 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/04927740 Branch: refs/heads/ignite-sql-tests Commit: 04927740bccae57ba6e9c9b440c18b8a191f9fa4 Parents: 49cddf4 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Wed Feb 11 14:06:12 2015 -0800 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Wed Feb 11 14:06:12 2015 -0800 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheProcessor.java | 2 ++ .../internal/processors/portable/GridPortableProcessor.java | 3 +++ .../processors/portable/os/GridOsPortableProcessor.java | 5 +++++ 3 files changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04927740/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 1c2499d..81a271e 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 @@ -1338,6 +1338,8 @@ public class GridCacheProcessor extends GridProcessorAdapter { cache.preloader().syncFuture().get(); } } + + ctx.portable().onCacheProcessorStarted(); } /** {@inheritDoc} */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04927740/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/GridPortableProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/GridPortableProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/GridPortableProcessor.java index 291caa0..668709f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/GridPortableProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/GridPortableProcessor.java @@ -29,6 +29,9 @@ import java.nio.*; * Portable processor. */ public interface GridPortableProcessor extends GridProcessor { + /** {@inheritDoc} */ + public void onCacheProcessorStarted(); + /** * @param typeName Type name. * @return Type ID. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04927740/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/os/GridOsPortableProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/os/GridOsPortableProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/os/GridOsPortableProcessor.java index 1ac3077..db5357a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/os/GridOsPortableProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/portable/os/GridOsPortableProcessor.java @@ -39,6 +39,11 @@ public class GridOsPortableProcessor extends GridProcessorAdapter implements Gri } /** {@inheritDoc} */ + @Override public void onCacheProcessorStarted() { + // No-op. + } + + /** {@inheritDoc} */ @Override public int typeId(String typeName) { return 0; }
