From 55763cdb4b1dcf1eacc437478a3326f013c8f617 Mon Sep 17 00:00:00 2001
From: leventov <leventov@ya.ru>
Date: Mon, 19 Jan 2015 07:11:12 +0700
Subject: [PATCH] Fixed some bugs in StatelessClientConnector

---
 src/main/java/net/openhft/chronicle/map/TcpReplicator.java | 6 +++---
 1 file changed, 3 insertions(+), 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 5dce09477..c948b9599 100644
--- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
@@ -1687,7 +1687,7 @@ class StatelessServerConnector<K, V> {
                                       final long sizeLocation, long timestamp, byte id) {
         try {
             writer.ensureBufferSize(1L);
-            bytesMap.replace(reader, reader, reader);
+            writer.in().writeBoolean(bytesMap.replace(reader, reader, reader));
         } catch (Throwable e) {
             return sendException(writer, sizeLocation, e);
         }
@@ -1813,7 +1813,7 @@ class StatelessServerConnector<K, V> {
                              @NotNull TcpReplicator.TcpSocketChannelEntryWriter writer,
                              final long sizeLocation) {
         try {
-            writer.in().writeBoolean(map.containsKey(reader));
+            writer.in().writeBoolean(bytesMap.containsKey(reader));
         } catch (Throwable e) {
             return sendException(writer, sizeLocation, e);
         }
@@ -1843,7 +1843,7 @@ class StatelessServerConnector<K, V> {
                      final long sizeLocation, long transactionId) {
         bytesMap.output = writer;
         try {
-            map.get(reader);
+            bytesMap.get(reader);
         } catch (Throwable e) {
             return sendException(writer, sizeLocation, e);
         } finally {