Clean up javadoc excludes

This commit is contained in:
leventov
2015-11-27 18:56:32 +03:00
parent 7cd0a36229
commit 8311cb5ce2
3 changed files with 13 additions and 16 deletions
@@ -51,22 +51,13 @@ import static net.openhft.chronicle.algo.MemoryUnit.*;
import static net.openhft.chronicle.algo.bytes.Access.checkedBytesStoreAccess;
import static net.openhft.chronicle.hash.impl.util.BuildVersion.version;
interface Work {
/**
* @param in the buffer that we will fill up
* @return true when all the work is complete
*/
boolean doWork(@NotNull Bytes in);
}
/**
* Used with a {@link net.openhft.chronicle.map.ReplicatedChronicleMap} to send data between the
* maps using a socket connection {@link net.openhft.chronicle.map.TcpReplicator}
*
* @author Rob Austin.
*/
public final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Closeable {
final class TcpReplicator extends AbstractChannelReplicator implements Closeable {
public static final long TIMESTAMP_FACTOR = 10000;
private static final int STATELESS_CLIENT = -127;
@@ -1437,5 +1428,14 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
return (entryOut.readRemaining() >= 8) ? entryOut.readLong() : Long.MIN_VALUE;
}
}
interface Work {
/**
* @param in the buffer that we will fill up
* @return true when all the work is complete
*/
boolean doWork(@NotNull Bytes in);
}
}
@@ -33,7 +33,8 @@ import java.nio.channels.DatagramChannel;
* receive the data before it becomes available on TCP/IP. In order to not miss data, UdpReplicator
* should be used in conjunction with the TCP Replicator.
*/
final class UdpReplicator extends UdpChannelReplicator implements Replica.ModificationNotifier, Closeable {
final class UdpReplicator extends UdpChannelReplicator
implements Replica.ModificationNotifier, Closeable {
private static final Logger LOG =
LoggerFactory.getLogger(UdpReplicator.class.getName());