Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

HCOLL-230 - created nextEntry()

Browse Source
This commit is contained in:
Rob Austin
2014-12-08 10:12:19 +00:00
parent 5de792290b
commit b659c56d34
3 changed files with 55 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/net/openhft/chronicle/map/Builder.java
+1 -1
View File
@@ -32,7 +32,7 @@ import java.util.concurrent.TimeUnit;
*/
public class Builder {
public static final int SIZE = 10000;
public static final int SIZE = 1000;
// added to ensure uniqueness
static int count;
static String WIN_OS = "WINDOWS";
src/test/java/net/openhft/chronicle/map/TcpReplicationSoakTest.java
+12 -9
View File
@@ -5,7 +5,10 @@ import net.openhft.lang.io.ByteBufferBytes;
import net.openhft.lang.model.Byteable;
import net.openhft.lang.model.DataValueClasses;
import net.openhft.lang.values.IntValue;
import org.junit.*;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.io.Closeable;
import java.io.IOException;
@@ -100,19 +103,19 @@ public class TcpReplicationSoakTest {
final int select = rnd.nextInt(2);
final ChronicleMap<Integer, CharSequence> map = select > 0 ? map1 : map2;
if (rnd.nextBoolean()) {
map.put(rnd.nextInt(Builder.SIZE), "test" + j);
} else {
map.remove(rnd.nextInt(Builder.SIZE));
if (rnd.nextBoolean()) {
map.put(rnd.nextInt(Builder.SIZE), "test" + j);
} else {
map.remove(rnd.nextInt(Builder.SIZE));
}
}
}
}
Thread.sleep(1000);
Thread.sleep(1000);
System.out.println("\nwaiting till equal");
waitTillEqual(10000);
waitTillEqual(10000);
Assert.assertEquals(new TreeMap(map1), new TreeMap(map2));
Assert.assertEquals(map1, map2);
}