Rename #getNumber -> #getPortNumber
- Part of ONOS-1564
Change-Id: I3c082c384564920c7b5baa8ba74a1cb534f64f6d
diff --git a/src/main/java/net/onrc/onos/core/topology/LinkEvent.java b/src/main/java/net/onrc/onos/core/topology/LinkEvent.java
index f72a429..140e4c7 100644
--- a/src/main/java/net/onrc/onos/core/topology/LinkEvent.java
+++ b/src/main/java/net/onrc/onos/core/topology/LinkEvent.java
@@ -81,8 +81,8 @@
}
public ByteBuffer getIDasByteBuffer() {
- return getLinkID(src.getDpid(), src.getNumber(),
- dst.getDpid(), dst.getNumber());
+ return getLinkID(src.getDpid(), src.getPortNumber(),
+ dst.getDpid(), dst.getPortNumber());
}
@Override
diff --git a/src/main/java/net/onrc/onos/core/topology/PortEvent.java b/src/main/java/net/onrc/onos/core/topology/PortEvent.java
index 8d3c945..114b3ef 100644
--- a/src/main/java/net/onrc/onos/core/topology/PortEvent.java
+++ b/src/main/java/net/onrc/onos/core/topology/PortEvent.java
@@ -43,8 +43,8 @@
return id.getDpid();
}
- public PortNumber getNumber() {
- return id.getNumber();
+ public PortNumber getPortNumber() {
+ return id.getPortNumber();
}
@Override
@@ -68,7 +68,7 @@
@Override
public String toString() {
- return "[PortEvent 0x" + getDpid() + "@" + getNumber() + "]";
+ return "[PortEvent 0x" + getDpid() + "@" + getPortNumber() + "]";
}
public static final int PORTID_BYTES = SwitchEvent.SWITCHID_BYTES + 2 + 8;
@@ -95,7 +95,7 @@
}
public ByteBuffer getIDasByteBuffer() {
- return getPortID(getDpid(), getNumber());
+ return getPortID(getDpid(), getPortNumber());
}
}
diff --git a/src/main/java/net/onrc/onos/core/topology/TopologyDatastore.java b/src/main/java/net/onrc/onos/core/topology/TopologyDatastore.java
index 171e87f..79afc77 100644
--- a/src/main/java/net/onrc/onos/core/topology/TopologyDatastore.java
+++ b/src/main/java/net/onrc/onos/core/topology/TopologyDatastore.java
@@ -47,7 +47,7 @@
groupOp.add(rcSwitch.forceCreateOp(client));
for (PortEvent portEvent : portEvents) {
- KVPort rcPort = new KVPort(sw.getDpid(), portEvent.getNumber());
+ KVPort rcPort = new KVPort(sw.getDpid(), portEvent.getPortNumber());
rcPort.setStatus(KVPort.STATUS.ACTIVE);
groupOp.add(rcPort.forceCreateOp(client));
@@ -87,7 +87,7 @@
groupOp.add(rcSwitch.forceCreateOp(client));
for (PortEvent portEvent : portEvents) {
- KVPort rcPort = new KVPort(sw.getDpid(), portEvent.getNumber());
+ KVPort rcPort = new KVPort(sw.getDpid(), portEvent.getPortNumber());
rcPort.setStatus(KVPort.STATUS.INACTIVE);
groupOp.add(rcPort.forceCreateOp(client));
@@ -107,7 +107,7 @@
public boolean addPort(PortEvent port) {
log.debug("Adding port {}", port);
- KVPort rcPort = new KVPort(port.getDpid(), port.getNumber());
+ KVPort rcPort = new KVPort(port.getDpid(), port.getPortNumber());
rcPort.setStatus(KVPort.STATUS.ACTIVE);
rcPort.forceCreate();
// TODO add description into KVPort
@@ -125,7 +125,7 @@
public boolean deactivatePort(PortEvent port) {
log.debug("Deactivating port {}", port);
- KVPort rcPort = new KVPort(port.getDpid(), port.getNumber());
+ KVPort rcPort = new KVPort(port.getDpid(), port.getPortNumber());
rcPort.setStatus(STATUS.INACTIVE);
rcPort.forceCreate();
@@ -143,9 +143,9 @@
log.debug("Adding link {}", link);
KVLink rcLink = new KVLink(link.getSrc().getDpid(),
- link.getSrc().getNumber(),
+ link.getSrc().getPortNumber(),
link.getDst().getDpid(),
- link.getDst().getNumber());
+ link.getDst().getPortNumber());
// XXX This method is called only by discovery,
// which means what we are trying to write currently is the truth
@@ -161,8 +161,8 @@
public boolean removeLink(LinkEvent linkEvent) {
log.debug("Removing link {}", linkEvent);
- KVLink rcLink = new KVLink(linkEvent.getSrc().getDpid(), linkEvent.getSrc().getNumber(),
- linkEvent.getDst().getDpid(), linkEvent.getDst().getNumber());
+ KVLink rcLink = new KVLink(linkEvent.getSrc().getDpid(), linkEvent.getSrc().getPortNumber(),
+ linkEvent.getDst().getDpid(), linkEvent.getDst().getPortNumber());
rcLink.forceDelete();
return true;
@@ -180,7 +180,7 @@
KVDevice rcDevice = new KVDevice(device.getMac().toBytes());
for (SwitchPort sp : device.getAttachmentPoints()) {
- byte[] portId = KVPort.getPortID(sp.getDpid(), sp.getNumber());
+ byte[] portId = KVPort.getPortID(sp.getDpid(), sp.getPortNumber());
rcDevice.addPortId(portId);
}
diff --git a/src/main/java/net/onrc/onos/core/topology/TopologyManager.java b/src/main/java/net/onrc/onos/core/topology/TopologyManager.java
index 190500f..8302ff3 100644
--- a/src/main/java/net/onrc/onos/core/topology/TopologyManager.java
+++ b/src/main/java/net/onrc/onos/core/topology/TopologyManager.java
@@ -896,9 +896,9 @@
}
SwitchImpl switchImpl = getSwitchImpl(sw);
- Port port = sw.getPort(portEvent.getNumber());
+ Port port = sw.getPort(portEvent.getPortNumber());
if (port == null) {
- port = new PortImpl(topology, sw, portEvent.getNumber());
+ port = new PortImpl(topology, sw, portEvent.getPortNumber());
switchImpl.addPort(port);
} else {
// TODO: Update the port attributes
@@ -921,7 +921,7 @@
return;
}
- Port port = sw.getPort(portEvent.getNumber());
+ Port port = sw.getPort(portEvent.getPortNumber());
if (port == null) {
log.warn("Port {} already removed, ignoring", portEvent);
return;
@@ -980,9 +980,9 @@
@GuardedBy("topology.writeLock")
private void addLink(LinkEvent linkEvent) {
Port srcPort = topology.getPort(linkEvent.getSrc().getDpid(),
- linkEvent.getSrc().getNumber());
+ linkEvent.getSrc().getPortNumber());
Port dstPort = topology.getPort(linkEvent.getDst().getDpid(),
- linkEvent.getDst().getNumber());
+ linkEvent.getDst().getPortNumber());
if ((srcPort == null) || (dstPort == null)) {
log.debug("{} reordered because {} port is null", linkEvent,
(srcPort == null) ? "src" : "dst");
@@ -1037,7 +1037,7 @@
@GuardedBy("topology.writeLock")
private void removeLink(LinkEvent linkEvent) {
Port srcPort = topology.getPort(linkEvent.getSrc().getDpid(),
- linkEvent.getSrc().getNumber());
+ linkEvent.getSrc().getPortNumber());
if (srcPort == null) {
log.warn("Src Port for Link {} already removed, ignoring",
linkEvent);
@@ -1045,7 +1045,7 @@
}
Port dstPort = topology.getPort(linkEvent.getDst().getDpid(),
- linkEvent.getDst().getNumber());
+ linkEvent.getDst().getPortNumber());
if (dstPort == null) {
log.warn("Dst Port for Link {} already removed, ignoring",
linkEvent);
@@ -1098,7 +1098,7 @@
boolean attachmentFound = false;
for (SwitchPort swp : deviceEvent.getAttachmentPoints()) {
// Attached Ports must exist
- Port port = topology.getPort(swp.getDpid(), swp.getNumber());
+ Port port = topology.getPort(swp.getDpid(), swp.getPortNumber());
if (port == null) {
// Reordered event: delay the event in local cache
ByteBuffer id = deviceEvent.getIDasByteBuffer();
@@ -1151,7 +1151,7 @@
// Process each attachment point
for (SwitchPort swp : deviceEvent.getAttachmentPoints()) {
// Attached Ports must exist
- Port port = topology.getPort(swp.getDpid(), swp.getNumber());
+ Port port = topology.getPort(swp.getDpid(), swp.getPortNumber());
if (port == null) {
log.warn("Port for the attachment point {} did not exist. skipping attachment point mutation", swp);
continue;