diff --git a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java index dbeae6b22..a2a80cefd 100644 --- a/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java +++ b/src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java @@ -111,8 +111,10 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clos ByteBuffer buffer = out.buffer().slice(); buffer.position(0); buffer.limit(1); + long timeoutTime = System.currentTimeMillis() + builder.timeoutMs(); while (buffer.hasRemaining()) { clientChannel.write(buffer); + checkTimeout(timeoutTime); } @@ -123,6 +125,7 @@ class StatelessChronicleMap implements ChronicleMap, Closeable, Clos while (in.buffer().position() <= 0) { clientChannel.read(in.buffer()); + checkTimeout(timeoutTime); } in.limit(in.buffer().position());