From f02be23f09d8432089f9ca7387152e245ba98024 Mon Sep 17 00:00:00 2001 From: Peter Lawrey Date: Fri, 5 Dec 2014 17:56:07 +0200 Subject: [PATCH] Adding multiple clients to configurable test --- src/main/java/net/openhft/chronicle/map/TcpReplicator.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java index b02c48739..bb8e4d6e5 100644 --- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java +++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java @@ -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;