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-403 removed another filter that was preventing all the message to be sent ( from all the nodes on bootstrap )

Browse Source
This commit is contained in:
rob
2015-10-14 10:46:58 +01:00
parent dd16bf6cde
commit d1d1d2daff
2 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ReplicatedChronicleMap.java
+1 -4
View File
@@ -667,10 +667,7 @@ final class ReplicatedChronicleMap<K, KI, MKI extends MetaBytesInterop<K, ? supe
final long timeStamp = entry.readLong();
final byte identifier = entry.readByte();
if (identifier != localIdentifier) {
// although unlikely, this may occur if the entry has been updated
return;
}
final boolean isDeleted = entry.readBoolean();
long valueSize;
src/test/java/net/openhft/chronicle/map/TCPSocketReplicationAfterNodeFailure.java
+10 -2
View File
@@ -72,6 +72,7 @@ public class TCPSocketReplicationAfterNodeFailure {
TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig
.of(8021)
.name("peter") // naming the config helps with debugging
.heartBeatInterval(1, TimeUnit.SECONDS);
hubOnServer1 = ReplicationHub.builder()
@@ -105,7 +106,9 @@ public class TCPSocketReplicationAfterNodeFailure {
byte identifier = (byte) 2;
TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig
.of(8022, new InetSocketAddress("localhost", 8021)).heartBeatInterval(1, TimeUnit.SECONDS);
.of(8022, new InetSocketAddress("localhost", 8021))
.name("rob").
heartBeatInterval(1, TimeUnit.SECONDS);
hubOnServer2 = ReplicationHub.builder()
.tcpTransportAndNetwork(tcpConfig)
@@ -142,7 +145,11 @@ public class TCPSocketReplicationAfterNodeFailure {
byte identifier = (byte) 3;
TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig
.of(8023, new InetSocketAddress("localhost", 8021)).heartBeatInterval(1, TimeUnit.SECONDS);
.of(8023,
new InetSocketAddress("localhost", 8021),
new InetSocketAddress("localhost", 8022)) // this wont be available but just added for completeness
.name("ozan").
heartBeatInterval(1, TimeUnit.SECONDS);
hubOnServer3 = ReplicationHub.builder()
.tcpTransportAndNetwork(tcpConfig)
@@ -165,6 +172,7 @@ public class TCPSocketReplicationAfterNodeFailure {
assertEquals(3, favoriteComputerServer1.size());
favoriteComputerServer1.close();
favoriteComputerServer3.close();
}