mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
HCOLL-167 moved classes to hash as they are used for set as well.
This commit is contained in:
@@ -399,7 +399,7 @@ public interface ChronicleHashBuilder<K, C extends ChronicleHash,
|
||||
* consider to be a ClientProxy to {@link ChronicleMap} or {@link ChronicleSet} running on
|
||||
* another host
|
||||
*
|
||||
* @param statelessBuilder true if you want your container to hold no data
|
||||
* @param statelessBuilder Stateless Client Config
|
||||
* @return this builder back
|
||||
*/
|
||||
B stateless(StatelessBuilder statelessBuilder);
|
||||
|
||||
@@ -19,7 +19,7 @@
|
||||
package net.openhft.chronicle.hash;
|
||||
|
||||
import net.openhft.chronicle.map.IdentifierListener;
|
||||
import net.openhft.chronicle.map.ThrottlingConfig;
|
||||
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
@@ -39,7 +39,6 @@ public class TcpReplicationConfig implements ReplicationConfig {
|
||||
private static final long DEFAULT_HEART_BEAT_INTERVAL = 20;
|
||||
private static final TimeUnit DEFAULT_HEART_BEAT_INTERVAL_UNIT = SECONDS;
|
||||
|
||||
|
||||
private int serverPort = DEFAULT_PACKET_SIZE;
|
||||
private Set<InetSocketAddress> endpoints;
|
||||
private int packetSize = DEFAULT_PACKET_SIZE;
|
||||
|
||||
+3
-3
@@ -16,7 +16,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package net.openhft.chronicle.map;
|
||||
package net.openhft.chronicle.hash;
|
||||
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
@@ -143,11 +143,11 @@ public class ThrottlingConfig {
|
||||
}
|
||||
|
||||
|
||||
long bucketInterval() {
|
||||
public long bucketInterval() {
|
||||
return bucketInterval;
|
||||
}
|
||||
|
||||
TimeUnit bucketIntervalUnit() {
|
||||
public TimeUnit bucketIntervalUnit() {
|
||||
return bucketIntervalUnit;
|
||||
}
|
||||
|
||||
@@ -17,8 +17,6 @@
|
||||
*/
|
||||
|
||||
package net.openhft.chronicle.hash;
|
||||
|
||||
import net.openhft.chronicle.map.ThrottlingConfig;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
import org.jetbrains.annotations.Nullable;
|
||||
|
||||
|
||||
@@ -18,6 +18,7 @@
|
||||
|
||||
package net.openhft.chronicle.map;
|
||||
|
||||
import net.openhft.chronicle.hash.ThrottlingConfig;
|
||||
import net.openhft.lang.io.ByteBufferBytes;
|
||||
import net.openhft.lang.io.Bytes;
|
||||
import net.openhft.lang.thread.NamedThreadFactory;
|
||||
@@ -47,7 +48,7 @@ public abstract class AbstractChannelReplicator implements Closeable {
|
||||
public static final int BITS_IN_A_BYTE = 8;
|
||||
|
||||
public static final int SIZE_OF_SIZE = 4;
|
||||
public static final int SIZE_OF_TRANSACTIONID =8;
|
||||
public static final int SIZE_OF_TRANSACTIONID = 8;
|
||||
|
||||
private static final Logger LOG = LoggerFactory.getLogger(AbstractChannelReplicator.class);
|
||||
final Selector selector;
|
||||
|
||||
@@ -19,6 +19,7 @@
|
||||
package net.openhft.chronicle.map;
|
||||
|
||||
import net.openhft.chronicle.hash.TcpReplicationConfig;
|
||||
import net.openhft.chronicle.hash.ThrottlingConfig;
|
||||
import net.openhft.lang.io.ByteBufferBytes;
|
||||
import net.openhft.lang.io.Bytes;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
Reference in New Issue
Block a user