Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@ignite.incubator.apache.org
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: Wed, 01 Apr 2015 08:38:21 -0000
Message-Id: <aeed1ade26b542c6a3a49aa76789682b@git.apache.org>
In-Reply-To: <fbf76599cef445e3a5014541d91294b2@git.apache.org>
References: <fbf76599cef445e3a5014541d91294b2@git.apache.org>
Subject: [35/49] incubator-ignite git commit: ignite-629: Revert
 GridCacheReturnValueTransferSelfTest.

ignite-629: Revert GridCacheReturnValueTransferSelfTest.


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

Branch: refs/heads/ignite-645
Commit: 885643ac03f52a4b4d97f1535be3c6a1e344a100
Parents: a9996d8
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Tue Mar 31 12:11:39 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Tue Mar 31 12:11:39 2015 +0300

----------------------------------------------------------------------
 .../GridCacheReturnValueTransferSelfTest.java   | 191 +++++++++++++++++++
 1 file changed, 191 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/885643ac/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
new file mode 100644
index 0000000..4761e21
--- /dev/null
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheReturnValueTransferSelfTest.java
@@ -0,0 +1,191 @@
+/*
+ * 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.
+     * 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;
+        }
+    }
+}