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

Remove stateless clients traces in TcpReplicator

Browse Source
This commit is contained in:
leventov
2015-12-28 19:03:30 +03:00
parent 1221f11097
commit 19fadf5628
2 changed files with 3 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
+3 -2
View File
@@ -57,8 +57,9 @@ abstract class AbstractChannelReplicator implements Closeable {
private static final Logger LOG = LoggerFactory.getLogger(AbstractChannelReplicator.class);
// currently this is not safe to use as it wont work with the stateless client
static boolean useJavaNIOSelectionKeys = Boolean.valueOf(System.getProperty("useJavaNIOSelectionKeys"));
// this was not safe to use as it wont work with the stateless client
static boolean useJavaNIOSelectionKeys =
Boolean.valueOf(System.getProperty("useJavaNIOSelectionKeys"));
final SelectedSelectionKeySet selectedKeys = new SelectedSelectionKeySet();
src/main/java/net/openhft/chronicle/map/TcpReplicator.java
-8
View File
@@ -59,8 +59,6 @@ import static net.openhft.chronicle.hash.impl.util.BuildVersion.version;
*/
final class TcpReplicator extends AbstractChannelReplicator implements Closeable {
public static final long TIMESTAMP_FACTOR = 10000;
private static final int STATELESS_CLIENT = -127;
private static final byte HEARTBEAT = 0;
private static final byte NOT_SET = 0;//(byte) HEARTBEAT.ordinal();
private static final Logger LOG = LoggerFactory.getLogger(TcpReplicator.class.getName());
@@ -606,12 +604,6 @@ final class TcpReplicator extends AbstractChannelReplicator implements Closeable
if (attached.remoteIdentifier == Byte.MIN_VALUE) {
final byte remoteIdentifier = reader.identifierFromBuffer();
if (remoteIdentifier == STATELESS_CLIENT) {
attached.handShakingComplete = true;
attached.hasRemoteHeartbeatInterval = false;
return;
}
if (remoteIdentifier == Byte.MIN_VALUE)
return;