From bc48a6aefb4dcbddf8efca8ce8ddd3166448be95 Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer>
Date: Fri, 12 Sep 2014 12:06:54 +0100
Subject: [PATCH] removed force bootstrap as its nolonger required

---
 .../map/AbstractChannelReplicator.java        |  5 -----
 .../openhft/chronicle/map/TcpReplicator.java  | 21 +++++++------------
 .../openhft/chronicle/map/UdpReplicator.java  |  5 -----
 3 files changed, 8 insertions(+), 23 deletions(-)

diff --git a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
index 6d3c6e732..8c0ff4906 100644
--- a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
@@ -134,11 +134,6 @@ abstract class AbstractChannelReplicator implements Closeable {
         }
     }
 
-    /**
-     * forces the TCP and UDP replicators to re-bootstrap
-     * This is called whenever a new CHM is added to a custer
-     */
-    public abstract void forceBootstrap();
 
     void checkThrottleInterval() throws ClosedChannelException {
         if (throttler != null)
diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
index 1089cc697..a6d908685 100644
--- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
@@ -36,8 +36,8 @@ import static java.nio.channels.SelectionKey.*;
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
 
 /**
- * Used with a {@see net.openhft.map.ReplicatedSharedHashMap} to send data between the maps using a
- * socket connection <p/> {@see net.openhft.map.OutSocketReplicator}
+ * Used with a {@see net.openhft.map.ReplicatedSharedHashMap} to send data between the maps using a socket
+ * connection <p/> {@see net.openhft.map.OutSocketReplicator}
  *
  * @author Rob Austin.
  */
@@ -65,9 +65,9 @@ class TcpReplicator extends AbstractChannelReplicator implements Closeable {
 
     /**
      * @param maxEntrySizeBytes used to check that the last entry will fit into the buffer, it can not be
-     *                          smaller than the size of and entry, if it is set smaller the buffer will
-     *                          over flow, it can be larger then the entry, but setting it too large
-     *                          reduces the workable space in the buffer.
+     *                          smaller than the size of and entry, if it is set smaller the buffer will over
+     *                          flow, it can be larger then the entry, but setting it too large reduces the
+     *                          workable space in the buffer.
      * @throws IOException
      */
     TcpReplicator(@NotNull final Replica replica,
@@ -306,11 +306,6 @@ class TcpReplicator extends AbstractChannelReplicator implements Closeable {
         closeEarlyAndQuietly(key.channel());
     }
 
-    @Override
-    public void forceBootstrap() {
-        forceBootstrap.lazySet(true);
-    }
-
     /**
      * called when the selector receives a OP_CONNECT message
      */
@@ -533,9 +528,9 @@ class TcpReplicator extends AbstractChannelReplicator implements Closeable {
 
     /**
      * sets interestOps to "selector keys",The change to interestOps much be on the same thread as the
-     * selector. This  class, allows via {@link AbstractChannelReplicator
-     * .KeyInterestUpdater#set(int)}  to holds a pending change  in interestOps ( via a bitset ), this change
-     * is processed later on the same thread as the selector
+     * selector. This  class, allows via {@link AbstractChannelReplicator .KeyInterestUpdater#set(int)}  to
+     * holds a pending change  in interestOps ( via a bitset ), this change is processed later on the same
+     * thread as the selector
      */
     private static class KeyInterestUpdater {
 
diff --git a/src/main/java/net/openhft/chronicle/map/UdpReplicator.java b/src/main/java/net/openhft/chronicle/map/UdpReplicator.java
index 193463b0b..1703f1a73 100644
--- a/src/main/java/net/openhft/chronicle/map/UdpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/UdpReplicator.java
@@ -91,11 +91,6 @@ class UdpReplicator extends AbstractChannelReplicator implements Replica.Modific
     }
 
 
-    @Override
-    public void forceBootstrap() {
-        modificationIterator = replica.acquireModificationIterator(
-                ChronicleMapBuilder.UDP_REPLICATION_MODIFICATION_ITERATOR_ID, this);
-    }
 
     /**
      * binds to the server socket and process data This method will block until interrupted