From 3aa7da740c78476f581232bec8c5e294cd81f8ad Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer>
Date: Tue, 21 Oct 2014 17:31:17 +0100
Subject: [PATCH] HCOLL-167 added timout time

---
 .../java/net/openhft/chronicle/map/StatelessChronicleMap.java  | 3 +++
 1 file changed, 3 insertions(+)

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<K, V> implements ChronicleMap<K, V>, 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<K, V> implements ChronicleMap<K, V>, Closeable, Clos
 
         while (in.buffer().position() <= 0) {
             clientChannel.read(in.buffer());
+            checkTimeout(timeoutTime);
         }
 
         in.limit(in.buffer().position());