You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/07/21 10:15:50 UTC
[1/2] ignite git commit: IGNITE-826: Removed
HadoopHashMapSelfTest.testAllocation() as it tested nothing.
Repository: ignite
Updated Branches:
refs/heads/master 54d52efce -> 80b3c4c37
IGNITE-826: Removed HadoopHashMapSelfTest.testAllocation() as it tested nothing.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c0fbed6c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c0fbed6c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c0fbed6c
Branch: refs/heads/master
Commit: c0fbed6c4944044e8baeeca1df349e839322e425
Parents: 54d52ef
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Thu Jul 21 13:15:35 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Thu Jul 21 13:15:35 2016 +0300
----------------------------------------------------------------------
.../collections/HadoopHashMapSelfTest.java | 56 ++------------------
1 file changed, 5 insertions(+), 51 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/c0fbed6c/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
index 2e1f66e..c0f8325 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
@@ -36,60 +36,14 @@ import org.apache.ignite.internal.util.typedef.X;
*
*/
public class HadoopHashMapSelfTest extends HadoopAbstractMapTest {
-
- public void testAllocation() throws Exception {
- fail("https://issues.apache.org/jira/browse/IGNITE-826");
-
- final GridUnsafeMemory mem = new GridUnsafeMemory(0);
-
- long size = 3L * 1024 * 1024 * 1024;
-
- final long chunk = 16;// * 1024;
-
- final int page = 4 * 1024;
-
- final int writes = chunk < page ? 1 : (int)(chunk / page);
-
- final long cnt = size / chunk;
-
- assert cnt < Integer.MAX_VALUE;
-
- final int threads = 4;
-
- long start = System.currentTimeMillis();
-
- multithreaded(new Callable<Object>() {
- @Override public Object call() throws Exception {
- int cnt0 = (int)(cnt / threads);
-
- for (int i = 0; i < cnt0; i++) {
- long ptr = mem.allocate(chunk);
-
- for (int j = 0; j < writes; j++)
- mem.writeInt(ptr + j * page, 100500);
- }
-
- return null;
- }
- }, threads);
-
- X.println("End: " + (System.currentTimeMillis() - start) + " mem: " + mem.allocatedSize() + " cnt: " + cnt);
-
- Thread.sleep(30000);
- }
-
-
- /** */
+ /**
+ * Test simple map.
+ *
+ * @throws Exception If failed.
+ */
public void testMapSimple() throws Exception {
GridUnsafeMemory mem = new GridUnsafeMemory(0);
-// mem.listen(new GridOffHeapEventListener() {
-// @Override public void onEvent(GridOffHeapEvent evt) {
-// if (evt == GridOffHeapEvent.ALLOCATE)
-// U.dumpStack();
-// }
-// });
-
Random rnd = new Random();
int mapSize = 16 << rnd.nextInt(3);
[2/2] ignite git commit: IGNITE-826: Removed
HadoopHashMapSelfTest.testAllocation() as it tested nothing.
Posted by vo...@apache.org.
IGNITE-826: Removed HadoopHashMapSelfTest.testAllocation() as it tested nothing.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/80b3c4c3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/80b3c4c3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/80b3c4c3
Branch: refs/heads/master
Commit: 80b3c4c373e9e5585222e7d04c6285cfe9d4204f
Parents: c0fbed6
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Thu Jul 21 13:15:41 2016 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Thu Jul 21 13:15:41 2016 +0300
----------------------------------------------------------------------
.../shuffle/collections/HadoopHashMapSelfTest.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/80b3c4c3/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
index c0f8325..04585ec 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/internal/processors/hadoop/shuffle/collections/HadoopHashMapSelfTest.java
@@ -19,12 +19,6 @@ package org.apache.ignite.internal.processors.hadoop.shuffle.collections;
import com.google.common.collect.ArrayListMultimap;
import com.google.common.collect.Multimap;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.Map;
-import java.util.Random;
-import java.util.concurrent.Callable;
import org.apache.hadoop.io.IntWritable;
import org.apache.ignite.internal.processors.hadoop.HadoopTaskContext;
import org.apache.ignite.internal.processors.hadoop.HadoopTaskInput;
@@ -32,6 +26,12 @@ import org.apache.ignite.internal.util.GridLongList;
import org.apache.ignite.internal.util.offheap.unsafe.GridUnsafeMemory;
import org.apache.ignite.internal.util.typedef.X;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.Random;
+
/**
*
*/