diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index 1aebfa359..5bf7b9394 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -52,6 +52,7 @@ import java.util.function.Predicate; import static java.nio.ByteBuffer.allocateDirect; import static java.util.Collections.emptyList; +import static net.openhft.chronicle.engine.client.ClientWiredStatelessTcpConnectionHub.IS_DEBUG; import static net.openhft.chronicle.map.AbstractChannelReplicator.SIZE_OF_SIZE; import static net.openhft.chronicle.map.AbstractChannelReplicator.SIZE_OF_TRANSACTION_ID; import static net.openhft.chronicle.map.StatelessChronicleMap.EventId.*; @@ -84,7 +85,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon private final InetSocketAddress remoteAddress; private final long timeoutMs; private final int tcpBufferSize; - + private Class kClass; private Class vClass; private boolean putReturnsNull; @@ -239,7 +240,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon private void checkTimeout(long timeoutTime) { - if (timeoutTime < System.currentTimeMillis()) + if (timeoutTime < System.currentTimeMillis() && !IS_DEBUG) throw new RemoteCallTimeoutException(); } @@ -385,7 +386,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clon // read a single byte back while (this.connectionOutBuffer.position() <= 0) { int read = clientChannel.read(this.connectionOutBuffer);// the remote identifier - if (read ==-1) + if (read == -1) throw new IOException("server conncetion closed"); checkTimeout(timeoutTime); }