ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [30/44] incubator-ignite git commit: ignite-629: Remove test for Force transform flag.
Date Tue, 31 Mar 2015 18:02:34 GMT
ignite-629: Remove test for Force transform flag.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/528ea7af
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/528ea7af
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/528ea7af

Branch: refs/heads/gg-9998
Commit: 528ea7afab72f05ed367bd85d0a031f67094574e
Parents: 053d32c
Author: ivasilinets <vasilinetc.ira@gmail.com>
Authored: Tue Mar 31 00:46:47 2015 +0300
Committer: ivasilinets <vasilinetc.ira@gmail.com>
Committed: Tue Mar 31 00:46:47 2015 +0300

----------------------------------------------------------------------
 .../GridCacheReturnValueTransferSelfTest.java   | 205 -------------------
 .../ignite/testsuites/IgniteCacheTestSuite.java |   1 -
 2 files changed, 206 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/528ea7af/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReturnValueTransferSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReturnValueTransferSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReturnValueTransferSelfTest.java
deleted file mode 100644
index 5b3e19d..0000000
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReturnValueTransferSelfTest.java
+++ /dev/null
@@ -1,205 +0,0 @@
-/*
- * 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 org.apache.ignite.*;
-import org.apache.ignite.cache.*;
-import org.apache.ignite.configuration.*;
-import org.apache.ignite.lang.*;
-import org.apache.ignite.testframework.junits.common.*;
-
-import javax.cache.processor.*;
-import java.io.*;
-import java.util.*;
-
-import static org.apache.ignite.cache.CacheAtomicWriteOrderMode.*;
-import static org.apache.ignite.cache.CacheAtomicityMode.*;
-import static org.apache.ignite.cache.CacheMode.*;
-
-/**
- * Tests transform for extra traffic.
- */
-public class GridCacheReturnValueTransferSelfTest extends GridCommonAbstractTest {
-    /** Distribution mode. */
-    private boolean cache;
-
-    /** Atomicity mode. */
-    private CacheAtomicityMode atomicityMode;
-
-    /** Atomic write order mode. */
-    private CacheAtomicWriteOrderMode writeOrderMode;
-
-    /** Number of backups. */
-    private int backups;
-
-    /** Fail deserialization flag. */
-    private static volatile boolean failDeserialization;
-
-    /** {@inheritDoc} */
-    @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception
{
-        IgniteConfiguration cfg = super.getConfiguration(gridName);
-
-        CacheConfiguration ccfg = new CacheConfiguration();
-
-        ccfg.setBackups(backups);
-        ccfg.setCacheMode(PARTITIONED);
-        ccfg.setAtomicityMode(atomicityMode);
-        ccfg.setAtomicWriteOrderMode(writeOrderMode);
-
-        cfg.setCacheConfiguration(ccfg);
-
-        if (!cache)
-            cfg.setClientMode(true);
-
-        return cfg;
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTransformAtomicPrimaryNoBackups() throws Exception {
-        checkTransform(ATOMIC, PRIMARY, 0);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTransformAtomicClockNoBackups() throws Exception {
-        checkTransform(ATOMIC, CLOCK, 0);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTransformAtomicPrimaryOneBackup() throws Exception {
-        checkTransform(ATOMIC, PRIMARY, 1);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTransformAtomicClockOneBackup() throws Exception {
-        checkTransform(ATOMIC, CLOCK, 1);
-    }
-
-    /**
-     * @throws Exception If failed.
-     * TODO gg-8273 enable when fixed
-     */
-    public void _testTransformTransactionalNoBackups() throws Exception {
-        checkTransform(TRANSACTIONAL, PRIMARY, 0);
-    }
-
-    /**
-     * @throws Exception If failed.
-     * TODO gg-8273 enable when fixed
-     */
-    public void _testTransformTransactionalOneBackup() throws Exception {
-        checkTransform(TRANSACTIONAL, PRIMARY, 1);
-    }
-
-    /**
-     * @param mode Atomicity mode.
-     * @param order Atomic cache write order mode.
-     * @param b Number of backups.
-     * @throws Exception If failed.
-     */
-    private void checkTransform(CacheAtomicityMode mode, CacheAtomicWriteOrderMode order,
int b)
-        throws Exception {
-        try {
-            atomicityMode = mode;
-
-            backups = b;
-
-            writeOrderMode = order;
-
-            cache = true;
-
-            startGrids(2);
-
-            cache = false;
-
-            startGrid(2);
-
-            failDeserialization = false;
-
-            // Get client grid.
-            IgniteCache<Integer, TestObject> cache = grid(2).cache(null);
-
-            for (int i = 0; i < 100; i++)
-                cache.put(i, new TestObject());
-
-            failDeserialization = true;
-
-            info(">>>>>> Transforming");
-
-            // Transform (check non-existent keys also).
-            for (int i = 0; i < 200; i++)
-                cache.invoke(i, new Transform());
-
-            Set<Integer> keys = new HashSet<>();
-
-            // Check transformAll.
-            for (int i = 0; i < 300; i++)
-                keys.add(i);
-
-            cache.invokeAll(keys, new Transform());
-
-            // Avoid errors during stop.
-            failDeserialization = false;
-        }
-        finally {
-            stopAllGrids();
-        }
-    }
-
-    /**
-     *
-     */
-    private static class Transform implements EntryProcessor<Integer, TestObject, Void>,
Serializable {
-        /** {@inheritDoc} */
-        @Override public Void process(MutableEntry<Integer, TestObject> entry, Object...
args) {
-            entry.setValue(new TestObject());
-
-            return null;
-        }
-    }
-
-    /**
-     *
-     */
-    @IgniteImmutable
-    private static class TestObject implements Externalizable {
-        /**
-         *
-         */
-        public TestObject() {
-            // No-op.
-        }
-
-        /** {@inheritDoc} */
-        @Override public void writeExternal(ObjectOutput out) throws IOException {
-            assert !failDeserialization;
-        }
-
-        /** {@inheritDoc} */
-        @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
{
-            assert !failDeserialization;
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/528ea7af/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
index 8cf9d2b..e3fefc8 100644
--- a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
+++ b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
@@ -238,7 +238,6 @@ public class IgniteCacheTestSuite extends TestSuite {
         suite.addTest(new TestSuite(GridCacheNearExpiredEntriesPreloadSelfTest.class));
         suite.addTest(new TestSuite(GridCacheAtomicExpiredEntriesPreloadSelfTest.class));
 
-        suite.addTest(new TestSuite(GridCacheReturnValueTransferSelfTest.class));
         suite.addTest(new TestSuite(GridCacheOffheapUpdateSelfTest.class));
 
         // TODO: GG-7242, GG-7243: Enabled when fixed.


Mime
View raw message