From 37c9c439b72a81c031ebfce8a594e0325b8c56a8 Mon Sep 17 00:00:00 2001
From: Peter Lawrey <peter.lawrey@higherfrequencytrading.com>
Date: Wed, 12 Nov 2014 19:32:10 +0000
Subject: [PATCH] Demostrate regular and stateless maps.

---
 .../chronicle/map/example/ServersMapMain.java | 22 +++++++++++++++----
 1 file changed, 18 insertions(+), 4 deletions(-)

diff --git a/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java b/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java
index 3dfda60d6..2d3832de6 100644
--- a/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java
+++ b/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java
@@ -34,6 +34,7 @@ public class ServersMapMain {
     static final int port = Integer.getInteger("port", 8989);
     static final int entries = Integer.getInteger("entries", 100000);
     static final int runs = Integer.getInteger("runs", 5);
+    static final boolean stateless = Boolean.getBoolean("stateless");
 
     public static void startServer() throws IOException {
         File file = File.createTempFile("testServersMapMain", ".deleteme");
@@ -49,10 +50,23 @@ public class ServersMapMain {
     }
 
     public static void startRemoteClient(String hostname) throws IOException {
-        final ChronicleMap<byte[], byte[]> map = ChronicleMapBuilder.of(
-                byte[].class, byte[].class)
-                .putReturnsNull(true)
-                .statelessClient(new InetSocketAddress(hostname, port)).create();
+        final ChronicleMap<byte[], byte[]> map;
+        if (stateless) {
+            map = ChronicleMapBuilder.of(
+                    byte[].class, byte[].class)
+                    .putReturnsNull(true)
+                    .statelessClient(new InetSocketAddress(hostname, port)).create();
+        } else {
+            File file = File.createTempFile("testServersMapMain", ".deleteme");
+            file.deleteOnExit();
+            TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig.of(port, new InetSocketAddress(hostname, port));
+
+            map = ChronicleMapBuilder.of(
+                    byte[].class, byte[].class)
+                    .putReturnsNull(true)
+                    .replication((byte) 1, tcpConfig)
+                    .createPersistedTo(file);
+        }
         ByteBuffer key = ByteBuffer.allocate(8);
         ByteBuffer value = ByteBuffer.allocate(32);
         double lastAveragePut = Double.POSITIVE_INFINITY, lastAverageGet = Double.POSITIVE_INFINITY;