From 933ef796bc55b3836deaf136bf8032a00a1b3714 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Tue, 16 Dec 2014 15:51:39 +0000 Subject: [PATCH] HCOLL-246 soak test appears to work on the mac, so removing the @ignore --- src/test/java/net/openhft/chronicle/map/Builder.java | 2 +- .../chronicle/map/TcpReplicationSoakTest.java | 12 +++++++----- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/src/test/java/net/openhft/chronicle/map/Builder.java b/src/test/java/net/openhft/chronicle/map/Builder.java index 923c0a800..68ac0c64a 100644 --- a/src/test/java/net/openhft/chronicle/map/Builder.java +++ b/src/test/java/net/openhft/chronicle/map/Builder.java @@ -32,7 +32,7 @@ import java.util.concurrent.TimeUnit; */ public class Builder { - public static final int SIZE = 10000; + public static final int SIZE = 10_000; // added to ensure uniqueness static int count; static String WIN_OS = "WINDOWS"; diff --git a/src/test/java/net/openhft/chronicle/map/TcpReplicationSoakTest.java b/src/test/java/net/openhft/chronicle/map/TcpReplicationSoakTest.java index 4b90b4f5f..cf2365f1f 100644 --- a/src/test/java/net/openhft/chronicle/map/TcpReplicationSoakTest.java +++ b/src/test/java/net/openhft/chronicle/map/TcpReplicationSoakTest.java @@ -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; @@ -95,13 +98,12 @@ public class TcpReplicationSoakTest { } - @Ignore @Test public void testSoakTestWithRandomData() throws IOException, InterruptedException { System.out.print("SoakTesting "); for (int j = 1; j < 2 * Builder.SIZE; j++) { - if (j % 100 == 0) + if (j % 1000 == 0) System.out.print("."); Random rnd = new Random(j); for (int i = 1; i < 10; i++) { @@ -115,10 +117,10 @@ public class TcpReplicationSoakTest { } } } - Thread.sleep(1000); + System.out.println("\nwaiting till equal"); - waitTillEqual(10000); + waitTillEqual(15000); Assert.assertEquals(map1, map2);