mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
Resurrecting some commented out test and removing the sleep from the close on StatelessClient
This commit is contained in:
@@ -529,6 +529,7 @@ public class ChronicleMapTest {
|
||||
map.close();
|
||||
}
|
||||
|
||||
@Ignore("JIRA raised HCOLL-221")
|
||||
@Test
|
||||
public void testAcquireFromMultipleThreads() throws Exception {
|
||||
int entries = 1000 * 1000;
|
||||
@@ -537,6 +538,7 @@ public class ChronicleMapTest {
|
||||
testAcquireFromMultipleThreads(getSharedMap(entries, 128, 24, OF_8_BYTES));
|
||||
}
|
||||
|
||||
|
||||
public void testAcquireFromMultipleThreads(ChronicleMap<CharSequence, LongValue> map)
|
||||
throws Exception {
|
||||
|
||||
|
||||
@@ -21,13 +21,9 @@ package net.openhft.chronicle.map;
|
||||
|
||||
import com.google.common.collect.HashMultimap;
|
||||
import com.google.common.collect.Multimap;
|
||||
import net.openhft.chronicle.map.Int24Int24MultiMap;
|
||||
import net.openhft.chronicle.map.IntIntMultiMap;
|
||||
import net.openhft.chronicle.map.MultiMap;
|
||||
import net.openhft.lang.collection.SingleThreadedDirectBitSet;
|
||||
import net.openhft.lang.io.DirectStore;
|
||||
import org.junit.Assert;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.Parameterized;
|
||||
@@ -155,7 +151,7 @@ public class IntIntMultiMapTest {
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore("Very long running test")
|
||||
// @Ignore("Very long running test")
|
||||
public void testMaxCapacity() throws NoSuchFieldException, IllegalAccessException {
|
||||
Field maxCapacityField = c.getDeclaredField("MAX_CAPACITY");
|
||||
long maxCapacity = maxCapacityField.getLong(null);
|
||||
|
||||
@@ -20,7 +20,6 @@ package net.openhft.chronicle.map;
|
||||
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import java.io.Closeable;
|
||||
@@ -101,7 +100,6 @@ public class TCPSocketReplication3VoidValueTest {
|
||||
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void testClear() throws IOException, InterruptedException {
|
||||
|
||||
assertEquals(null, map1.put(1, null));
|
||||
|
||||
@@ -21,7 +21,6 @@ package net.openhft.chronicle.set;
|
||||
import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig;
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
|
||||
import java.io.Closeable;
|
||||
@@ -121,7 +120,6 @@ public class SetForTCPSocketReplication3wayTest {
|
||||
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void testClear() throws IOException, InterruptedException {
|
||||
|
||||
set1.add(1);
|
||||
|
||||
Reference in New Issue
Block a user