Managers refactored to use ConfigOperators:
o Device, Host, and LinkManagers now use respecive ConfigOperator
implementations to combine Descriptions with Network Configs. This
refactors work done in 3a0cdd57e7b2c2bbdc44743b780b072cb0475f2d.
o Touchups on ConfigOperator impls
Change-Id: I735e7e6bfa0c47c8727433aab804cb2782eebfff
diff --git a/core/net/src/main/java/org/onosproject/net/link/impl/BasicLinkOperator.java b/core/net/src/main/java/org/onosproject/net/link/impl/BasicLinkOperator.java
index 37ac066..7bb2da6 100644
--- a/core/net/src/main/java/org/onosproject/net/link/impl/BasicLinkOperator.java
+++ b/core/net/src/main/java/org/onosproject/net/link/impl/BasicLinkOperator.java
@@ -20,6 +20,7 @@
import java.time.Duration;
import org.onosproject.net.AnnotationKeys;
+import org.onosproject.incubator.net.config.ConfigOperator;
import org.onosproject.incubator.net.config.basics.BasicLinkConfig;
import org.onosproject.net.DefaultAnnotations;
import org.onosproject.net.Link;
@@ -32,8 +33,10 @@
* Implementations of merge policies for various sources of link configuration
* information. This includes applications, provides, and network configurations.
*/
-public final class BasicLinkOperator {
+public final class BasicLinkOperator implements ConfigOperator {
+ private static final long DEF_BANDWIDTH = -1L;
+ private static final Duration DEF_DURATION = Duration.ofNanos(-1L);
private static final Logger log = getLogger(BasicLinkOperator.class);
private BasicLinkOperator() {
@@ -72,10 +75,10 @@
*/
public static SparseAnnotations combine(BasicLinkConfig cfg, SparseAnnotations an) {
DefaultAnnotations.Builder b = DefaultAnnotations.builder();
- if (cfg.latency() != Duration.ofNanos(-1)) {
+ if (cfg.latency() != DEF_DURATION) {
b.set(AnnotationKeys.LATENCY, cfg.latency().toString());
}
- if (cfg.bandwidth() != -1) {
+ if (cfg.bandwidth() != DEF_BANDWIDTH) {
b.set(AnnotationKeys.BANDWIDTH, String.valueOf(cfg.bandwidth()));
}
return DefaultAnnotations.union(an, b.build());
diff --git a/core/net/src/main/java/org/onosproject/net/link/impl/LinkManager.java b/core/net/src/main/java/org/onosproject/net/link/impl/LinkManager.java
index b1316f6..e23825d 100644
--- a/core/net/src/main/java/org/onosproject/net/link/impl/LinkManager.java
+++ b/core/net/src/main/java/org/onosproject/net/link/impl/LinkManager.java
@@ -31,17 +31,14 @@
import org.onosproject.incubator.net.config.NetworkConfigService;
import org.onosproject.incubator.net.config.basics.BasicLinkConfig;
import org.onosproject.net.ConnectPoint;
-import org.onosproject.net.DefaultAnnotations;
import org.onosproject.net.DeviceId;
import org.onosproject.net.Link;
import org.onosproject.net.Link.State;
import org.onosproject.net.LinkKey;
import org.onosproject.net.MastershipRole;
-import org.onosproject.net.SparseAnnotations;
import org.onosproject.net.device.DeviceEvent;
import org.onosproject.net.device.DeviceListener;
import org.onosproject.net.device.DeviceService;
-import org.onosproject.net.link.DefaultLinkDescription;
import org.onosproject.net.link.LinkAdminService;
import org.onosproject.net.link.LinkDescription;
import org.onosproject.net.link.LinkEvent;
@@ -55,7 +52,6 @@
import org.onosproject.net.provider.AbstractProviderService;
import org.slf4j.Logger;
-import java.time.Duration;
import java.util.Set;
import static com.google.common.base.Preconditions.checkNotNull;
@@ -206,6 +202,7 @@
removeLinks(getDeviceLinks(deviceId), false);
}
+ @Override
public void removeLink(ConnectPoint src, ConnectPoint dst) {
post(store.removeLink(src, dst));
}
@@ -264,38 +261,8 @@
checkState(cfg == null || cfg.isAllowed(), "Link " + linkDescription.toString() + " is not allowed");
checkState(cfgTwo == null || cfgTwo.isAllowed(), "Link " + linkDescription.toString() + " is not allowed");
- if (cfg != null) {
- SparseAnnotations finalSparse = processAnnotations(cfg, linkDescription);
- // check whether config has a specified type
- if (cfg.type() != Link.Type.DIRECT) {
- linkDescription = new DefaultLinkDescription(linkDescription.src(),
- linkDescription.dst(),
- cfg.type(), finalSparse);
- } else {
- linkDescription = new DefaultLinkDescription(linkDescription.src(),
- linkDescription.dst(),
- linkDescription.type(), finalSparse);
- }
- }
- return linkDescription;
- }
- // supplements or replaces linkDescriptions's annotations with BasicLinkConfig's
- // annotations
- private SparseAnnotations processAnnotations(BasicLinkConfig cfg, LinkDescription linkDescription) {
- SparseAnnotations originalAnnotations = linkDescription.annotations();
- DefaultAnnotations.Builder newBuilder = DefaultAnnotations.builder();
- if (cfg.type() != Link.Type.DIRECT) {
- newBuilder.set(cfg.TYPE, cfg.type().toString());
- }
- if (cfg.latency() != Duration.ofNanos(-1)) {
- newBuilder.set(cfg.LATENCY, cfg.latency().toString());
- }
- if (cfg.bandwidth() != -1) {
- newBuilder.set(cfg.BANDWIDTH, String.valueOf(cfg.bandwidth()));
- }
- DefaultAnnotations newAnnotations = newBuilder.build();
- return DefaultAnnotations.union(originalAnnotations, newAnnotations);
+ return BasicLinkOperator.combine(cfg, linkDescription);
}
@Override