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-191 added missing close to the test case

Browse Source
This commit is contained in:
Rob Austin
2014-11-06 18:30:56 +00:00
parent 2c6b9b0020
commit 07aa6d883b
1 changed files with 56 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/net/openhft/chronicle/map/EventListenerTestWithTCPSocketReplication.java
+56 -52
View File
@@ -26,6 +26,7 @@ import org.junit.Test;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.concurrent.atomic.AtomicBoolean;
/**
* Test ReplicatedChronicleMap where the Replicated is over a TCP Socket
*
@@ -35,64 +36,67 @@ import java.util.concurrent.atomic.AtomicBoolean;
public class EventListenerTestWithTCPSocketReplication {
@Test
public void test() throws IOException, InterruptedException {
@Test
public void test() throws IOException, InterruptedException {
ChronicleMap<Integer, CharSequence> map1;
ChronicleMap<Integer, CharSequence> map2;
final AtomicBoolean putWasCalled = new AtomicBoolean(false);
ChronicleMap<Integer, CharSequence> map1;
ChronicleMap<Integer, CharSequence> map2;
final AtomicBoolean putWasCalled = new AtomicBoolean(false);
int udpPort = 1234;
MapEventListener<Integer, CharSequence, ChronicleMap<Integer, CharSequence>> eventListener = new MapEventListener<Integer, CharSequence, ChronicleMap<Integer, CharSequence>>() {
private static final long serialVersionUID = 1L;
int udpPort = 1234;
MapEventListener<Integer, CharSequence, ChronicleMap<Integer, CharSequence>> eventListener = new MapEventListener<Integer, CharSequence, ChronicleMap<Integer, CharSequence>>() {
private static final long serialVersionUID = 1L;
@Override
public void onPut(ChronicleMap<Integer, CharSequence> map, Bytes entry, int metaDataBytes, boolean added, Integer key,
CharSequence value) {
putWasCalled.getAndSet(true);
}
};
// ---------- SERVER1 1 ----------
{
// we connect the maps via a TCP socket connection on port 8077
TcpReplicationConfig tcpConfig = TcpReplicationConfig.of(8076, new InetSocketAddress("localhost", 8077));
ChronicleMapBuilder<Integer, CharSequence> map1Builder =
ChronicleMapBuilder.of(Integer.class, CharSequence.class)
.entries(20000L)
.replicators((byte) 1, tcpConfig);
map1 = map1Builder.create();
@Override
public void onPut(ChronicleMap<Integer, CharSequence> map, Bytes entry, int metaDataBytes, boolean added, Integer key,
CharSequence value) {
putWasCalled.getAndSet(true);
}
// ---------- SERVER2 2 on the same server as ----------
};
{
TcpReplicationConfig tcpConfig = TcpReplicationConfig.of(8077);
ChronicleMapBuilder<Integer, CharSequence> map2Builder =
ChronicleMapBuilder.of(Integer.class, CharSequence.class)
.entries(20000L)
.replicators((byte) 2, tcpConfig)
.eventListener(eventListener);
// ---------- SERVER1 1 ----------
{
map2 = map2Builder.create();
}
// we connect the maps via a TCP socket connection on port 8077
// we will stores some data into one map here
map1.put(5, "EXAMPLE");
int t = 0;
for (; t < 5000; t++) {
if (map1.equals(map2)) {
break;
}
Thread.sleep(1);
}
TcpReplicationConfig tcpConfig = TcpReplicationConfig.of(8076, new InetSocketAddress("localhost", 8077));
ChronicleMapBuilder<Integer, CharSequence> map1Builder =
ChronicleMapBuilder.of(Integer.class, CharSequence.class)
.entries(20000L)
.replicators((byte) 1, tcpConfig);
Assert.assertEquals("Maps should be equal", map1, map2);
Assert.assertTrue("Map 1 should not be empty", !map1.isEmpty());
Assert.assertTrue("Map 2 should not be empty", !map2.isEmpty());
Assert.assertTrue("The eventListener.onPut should have been called", putWasCalled.get());
map1 = map1Builder.create();
}
}
// ---------- SERVER2 2 on the same server as ----------
{
TcpReplicationConfig tcpConfig = TcpReplicationConfig.of(8077);
ChronicleMapBuilder<Integer, CharSequence> map2Builder =
ChronicleMapBuilder.of(Integer.class, CharSequence.class)
.entries(20000L)
.replicators((byte) 2, tcpConfig)
.eventListener(eventListener);
map2 = map2Builder.create();
}
// we will stores some data into one map here
map1.put(5, "EXAMPLE");
int t = 0;
for (; t < 5000; t++) {
if (map1.equals(map2)) {
break;
}
Thread.sleep(1);
}
Assert.assertEquals("Maps should be equal", map1, map2);
Assert.assertTrue("Map 1 should not be empty", !map1.isEmpty());
Assert.assertTrue("Map 2 should not be empty", !map2.isEmpty());
Assert.assertTrue("The eventListener.onPut should have been called", putWasCalled.get());
map1.close();
map2.close();
}
}