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

Adding multiple clients to configurable test

Browse Source
This commit is contained in:
Peter Lawrey
2014-12-05 17:56:07 +02:00
parent 83f214263e
commit f02be23f09
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/TcpReplicator.java
-3
View File
@@ -449,7 +449,6 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable
attached.entryReader = new TcpSocketChannelEntryReader();
attached.entryWriter = new TcpSocketChannelEntryWriter();
attached.writeBarrier = true;
key.interestOps(OP_WRITE | OP_READ);
@@ -493,7 +492,6 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable
attached.entryWriter.identifierToBuffer(localIdentifier);
attached.isServer = true;
attached.writeBarrier = true;
channel.register(selector, OP_READ, attached);
@@ -907,7 +905,6 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable
public boolean isServer; // the frequency the remote node will send a heartbeat
public boolean handShakingComplete;
public long remoteHeartbeatInterval = heartBeatIntervalMillis;
public volatile boolean writeBarrier;
boolean isHandShakingComplete() {
return handShakingComplete;