ignite-1272: adding additional tests for deployment info
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/22b61337 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/22b61337 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/22b61337 Branch: refs/heads/ignite-1272 Commit: 22b6133702ebee178724f3e3bd40fd2b4c523287 Parents: 889ae67 Author: Denis Magda <[email protected]> Authored: Thu Oct 8 14:16:05 2015 +0300 Committer: Denis Magda <[email protected]> Committed: Thu Oct 8 14:16:05 2015 +0300 ---------------------------------------------------------------------- .../GridCacheConditionalDeploymentSelfTest.java | 120 +++++++++++++++++++ 1 file changed, 120 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/22b61337/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConditionalDeploymentSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConditionalDeploymentSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConditionalDeploymentSelfTest.java new file mode 100644 index 0000000..6489e9b --- /dev/null +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConditionalDeploymentSelfTest.java @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.ignite.internal.processors.cache; + +import java.nio.ByteBuffer; +import java.util.ArrayList; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.GridDirectCollection; +import org.apache.ignite.internal.IgniteKernal; +import org.apache.ignite.plugin.extensions.communication.MessageCollectionItemType; +import org.apache.ignite.plugin.extensions.communication.MessageReader; +import org.apache.ignite.plugin.extensions.communication.MessageWriter; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; +import static org.apache.ignite.cache.CacheMode.PARTITIONED; +import static org.apache.ignite.cache.CacheRebalanceMode.SYNC; +import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC; + +/** + * Cache + conditional deployment test. + */ +public class GridCacheConditionalDeploymentSelfTest extends GridCommonAbstractTest { + /** IP finder. */ + private static final TcpDiscoveryIpFinder IP_FINDER = new TcpDiscoveryVmIpFinder(true); + + /** {@inheritDoc} */ + @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { + IgniteConfiguration cfg = super.getConfiguration(gridName); + + cfg.setCacheConfiguration(cacheConfiguration()); + + TcpDiscoverySpi disco = new TcpDiscoverySpi(); + + disco.setIpFinder(IP_FINDER); + + cfg.setDiscoverySpi(disco); + + return cfg; + } + + /** + * @return Cache configuration. + * @throws Exception In case of error. + */ + protected CacheConfiguration cacheConfiguration() throws Exception { + CacheConfiguration cfg = defaultCacheConfiguration(); + + cfg.setCacheMode(PARTITIONED); + cfg.setWriteSynchronizationMode(FULL_SYNC); + cfg.setRebalanceMode(SYNC); + cfg.setAtomicityMode(TRANSACTIONAL); + cfg.setBackups(1); + + return cfg; + } + + /** {@inheritDoc} */ + @Override protected void afterTest() throws Exception { + Ignition.stopAll(true); + } + + /** + * @throws Exception In case of error. + */ + public void testNoDeploymentInfo() throws Exception { + Ignite ignite0 = startGrid(0); + Ignite ignite1 = startGrid(1); + + GridCacheContext ctx = ((IgniteCacheProxy)ignite0.cache(null)).context(); + + GridCacheIoManager ioMgr = ((IgniteKernal)ignite0).context().cache().context().io(); + + TestMessage msg = new TestMessage(); + + assertNull(msg.depEnabled); + + msg.depEnabled = true; + + ioMgr.send(ignite1.cluster().localNode().id(), msg, ctx.ioPolicy()); + } + + /** + * Test message class. + */ + private static class TestMessage extends GridCacheMessage { + /** */ + public static final byte DIRECT_TYPE = (byte)202; + + @Override public byte directType() { + return DIRECT_TYPE; + } + + @Override public byte fieldsCount() { + return 3; + } + } +}
