Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

removed force bootstrap as its nolonger required

Browse Source
This commit is contained in:
Rob Austin
2014-09-12 12:06:54 +01:00
parent 41de20b5e3
commit bc48a6aefb
3 changed files with 8 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+8 -13
View File
@@ -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 {