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

Inlined UdpReplicationConfigBean

Browse Source
This commit is contained in:
leventov
2014-11-07 08:10:21 +03:00
parent cbe94bcbb2
commit 157891dc9d
1 changed files with 29 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/hash/UdpReplicationConfig.java
+29 -54
View File
@@ -24,61 +24,13 @@ import java.net.InetAddress;
import java.net.NetworkInterface;
public abstract class UdpReplicationConfig implements ReplicationConfig {
/**
* Package-private constructor forbids subclassing from outside of the package
*/
UdpReplicationConfig() {
// nothing to do
}
public static UdpReplicationConfig simple(@NotNull InetAddress address, int port) {
if (address.isMulticastAddress())
throw new IllegalArgumentException();
return create(address, port, null, ThrottlingConfig.noThrottling());
}
public static UdpReplicationConfig multiCast(@NotNull InetAddress address, int port,
@NotNull NetworkInterface networkInterface) {
if (!address.isMulticastAddress() || networkInterface == null)
throw new IllegalArgumentException();
return create(address, port, networkInterface, ThrottlingConfig.noThrottling());
}
static UdpReplicationConfig create(InetAddress address, int port,
NetworkInterface networkInterface,
ThrottlingConfig throttlingConfig) {
return new UdpReplicationConfigBean(address, port, networkInterface,
throttlingConfig);
}
public abstract InetAddress address();
public abstract int port();
@Nullable
public abstract NetworkInterface networkInterface();
public abstract ThrottlingConfig throttlingConfig();
public UdpReplicationConfig throttlingConfig(ThrottlingConfig throttlingConfig) {
ThrottlingConfig.checkMillisecondBucketInterval(throttlingConfig, "UDP");
return create(address(), port(), networkInterface(), throttlingConfig);
}
}
final class UdpReplicationConfigBean extends UdpReplicationConfig {
public final class UdpReplicationConfig implements ReplicationConfig {
private final InetAddress address;
private final int port;
private final NetworkInterface networkInterface;
private final ThrottlingConfig throttlingConfig;
UdpReplicationConfigBean(
private UdpReplicationConfig(
InetAddress address,
int port,
NetworkInterface networkInterface,
@@ -96,22 +48,40 @@ final class UdpReplicationConfigBean extends UdpReplicationConfig {
this.throttlingConfig = throttlingConfig;
}
@Override
public static UdpReplicationConfig simple(@NotNull InetAddress address, int port) {
if (address.isMulticastAddress())
throw new IllegalArgumentException();
return create(address, port, null, ThrottlingConfig.noThrottling());
}
public static UdpReplicationConfig multiCast(@NotNull InetAddress address, int port,
@NotNull NetworkInterface networkInterface) {
if (!address.isMulticastAddress() || networkInterface == null)
throw new IllegalArgumentException();
return create(address, port, networkInterface, ThrottlingConfig.noThrottling());
}
static UdpReplicationConfig create(InetAddress address, int port,
NetworkInterface networkInterface,
ThrottlingConfig throttlingConfig) {
return new UdpReplicationConfig(address, port, networkInterface, throttlingConfig);
}
@NotNull
public InetAddress address() {
return address;
}
@Override
public int port() {
return port;
}
@Override
@Nullable
public NetworkInterface networkInterface() {
return networkInterface;
}
@Override
@NotNull
public ThrottlingConfig throttlingConfig() {
return throttlingConfig;
}
@@ -154,4 +124,9 @@ final class UdpReplicationConfigBean extends UdpReplicationConfig {
h ^= throttlingConfig.hashCode();
return h;
}
public UdpReplicationConfig throttlingConfig(@NotNull ThrottlingConfig throttlingConfig) {
ThrottlingConfig.checkMillisecondBucketInterval(throttlingConfig, "UDP");
return create(address(), port(), networkInterface(), throttlingConfig);
}
}