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

updated test case

Browse Source
This commit is contained in:
Rob Austin
2014-12-22 19:52:36 +00:00
parent c033f6ecb1
commit f1ecdc937a
1 changed files with 24 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/net/openhft/chronicle/map/TcpReplicationSoakTest.java
+24 -20
View File
@@ -29,7 +29,7 @@ public class TcpReplicationSoakTest {
private ChronicleMap<Integer, CharSequence> map1;
private ChronicleMap<Integer, CharSequence> map2;
private IntValue value;
static int s_port = 8010;
static int s_port = 8093;
@Before
public void setup() throws IOException {
@@ -100,30 +100,34 @@ public class TcpReplicationSoakTest {
@Test
public void testSoakTestWithRandomData() throws IOException, InterruptedException {
try {
System.out.print("SoakTesting ");
for (int j = 1; j < 2 * Builder.SIZE; j++) {
if (j % 1000 == 0)
System.out.print(".");
Random rnd = new Random(j);
for (int i = 1; i < 10; i++) {
final int select = rnd.nextInt(2);
final ChronicleMap<Integer, CharSequence> map = select > 0 ? map1 : map2;
System.out.print("SoakTesting ");
for (int j = 1; j < 2 * Builder.SIZE; j++) {
if (j % 1000 == 0)
System.out.print(".");
Random rnd = new Random(j);
for (int i = 1; i < 10; i++) {
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));
}
}
}
System.out.println("\nwaiting till equal");
waitTillEqual(15000);
Assert.assertEquals(map1, map2);
} finally {
map1.close();
map2.close();
}
System.out.println("\nwaiting till equal");
waitTillEqual(15000);
Assert.assertEquals(map1, map2);
}