Implement CLI commands to view and delete SR internal stores
sr-next-dst (renamed from sr-next-hops)
sr-next-port
sr-next-vlan
sr-next-mcast (renamed from sr-mcast-next)
sr-next-pw
sr-next-xconnect
sr-next-invalidate <next-id>
Change-Id: Id5178f786bb97e26ddb86015105dd19604ac0817
diff --git a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/xconnect/impl/XconnectManager.java b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/xconnect/impl/XconnectManager.java
index 696b811..ab4ec53 100644
--- a/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/xconnect/impl/XconnectManager.java
+++ b/apps/segmentrouting/app/src/main/java/org/onosproject/segmentrouting/xconnect/impl/XconnectManager.java
@@ -15,6 +15,7 @@
*/
package org.onosproject.segmentrouting.xconnect.impl;
+import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Sets;
import org.apache.felix.scr.annotations.Activate;
@@ -192,6 +193,24 @@
);
}
+ @Override
+ public ImmutableMap<XconnectKey, NextObjective> getNext() {
+ if (xconnectNextObjStore != null) {
+ return ImmutableMap.copyOf(xconnectNextObjStore.asJavaMap());
+ } else {
+ return ImmutableMap.of();
+ }
+ }
+
+ @Override
+ public void removeNextId(int nextId) {
+ xconnectNextObjStore.entrySet().forEach(e -> {
+ if (e.getValue().value().id() == nextId) {
+ xconnectNextObjStore.remove(e.getKey());
+ }
+ });
+ }
+
private class XconnectMapListener implements MapEventListener<XconnectKey, Set<PortNumber>> {
@Override
public void event(MapEvent<XconnectKey, Set<PortNumber>> event) {