Use ONOS LinkTuple instead of link discovery specific Link class
Change-Id: I781d9622b1d796e65fe6a99333529efad52215c6
diff --git a/src/main/java/net/onrc/onos/core/topology/TopologyPublisher.java b/src/main/java/net/onrc/onos/core/topology/TopologyPublisher.java
index 9ef6fa9..5838483 100644
--- a/src/main/java/net/onrc/onos/core/topology/TopologyPublisher.java
+++ b/src/main/java/net/onrc/onos/core/topology/TopologyPublisher.java
@@ -42,6 +42,7 @@
import net.onrc.onos.core.registry.IControllerRegistryService.ControlChangeCallback;
import net.onrc.onos.core.registry.RegistryException;
import net.onrc.onos.core.util.Dpid;
+import net.onrc.onos.core.util.LinkTuple;
import net.onrc.onos.core.util.OnosInstanceId;
import net.onrc.onos.core.util.PortNumberUtils;
import net.onrc.onos.core.util.SwitchPort;
@@ -292,16 +293,18 @@
@Override
public void linkAdded(Link link) {
- LinkConfigStatus ret = networkConfigService.checkLinkConfig(link);
+ LinkTuple linkTuple = new LinkTuple(
+ new SwitchPort(link.getSrc(), link.getSrcPort()),
+ new SwitchPort(link.getDst(), link.getDstPort()));
+
+ LinkConfigStatus ret = networkConfigService.checkLinkConfig(linkTuple);
if (ret.getConfigState() == NetworkConfigState.DENY) {
log.warn("Discovered {} denied by configuration. {} "
+ "Not allowing it to proceed.", link, ret.getMsg());
return;
}
- LinkData linkData = new LinkData(
- new SwitchPort(link.getSrc(), link.getSrcPort()),
- new SwitchPort(link.getDst(), link.getDstPort()));
+ LinkData linkData = new LinkData(linkTuple);
// FIXME should be merging, with existing attrs, etc..
// TODO define attr name as constant somewhere.