Improvement In 'show router port', added 'show router adjacency', renamed some diplay name in CLI
diff --git a/src/main/java/net/onrc/onos/apps/segmentrouting/web/SegmentRouterResource.java b/src/main/java/net/onrc/onos/apps/segmentrouting/web/SegmentRouterResource.java
new file mode 100644
index 0000000..a34f47a
--- /dev/null
+++ b/src/main/java/net/onrc/onos/apps/segmentrouting/web/SegmentRouterResource.java
@@ -0,0 +1,154 @@
+package net.onrc.onos.apps.segmentrouting.web;
+
+
+
+import static net.onrc.onos.core.topology.web.TopologyResource.eval;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+import net.onrc.onos.apps.segmentrouting.ISegmentRoutingService;
+import net.onrc.onos.core.topology.ITopologyService;
+import net.onrc.onos.core.topology.MutableTopology;
+import net.onrc.onos.core.topology.Port;
+import net.onrc.onos.core.topology.Switch;
+import net.onrc.onos.core.util.Dpid;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+
+import org.projectfloodlight.openflow.util.HexString;
+import org.restlet.representation.Representation;
+import org.restlet.resource.Get;
+import org.restlet.resource.ServerResource;
+/**
+ * Base class for return router statistics
+ *
+ */
+public class SegmentRouterResource extends ServerResource {
+ /**
+ * Gets the switches/routers and ports information from the network topology.
+ *
+ * @return a Representation of a Collection of switches/routers from the network
+ * topology. Each switch contains the switch ports.
+ */
+ @Get("json")
+ public Object retrieve() {
+ String routerId = (String) getRequestAttributes().get("routerId");
+ String statsType = (String) getRequestAttributes().get("statsType");
+ ITopologyService topologyService =
+ (ITopologyService) getContext().getAttributes()
+ .get(ITopologyService.class.getCanonicalName());
+
+ MutableTopology mutableTopology = topologyService.getTopology();
+ mutableTopology.acquireReadLock();
+ try {
+ if (routerId == null && statsType == null){
+ return eval(toRepresentation(mutableTopology.getSwitches(), null));
+ }
+ else if(routerId != null && statsType.equals("port")){
+ Switch sw = mutableTopology
+ .getSwitch(new Dpid(HexString.toLong(routerId)));
+ if(sw ==null){
+ //TODO: Add exception
+ return null;
+ }
+ ISegmentRoutingService segmentRoutingService =
+ (ISegmentRoutingService) getContext().getAttributes().
+ get(ISegmentRoutingService.class.getCanonicalName());
+ Map <String, List<SegmentRouterPortInfo>> result = new HashMap <String, List<SegmentRouterPortInfo>>();
+ List<SegmentRouterPortInfo> listPortInfo = new ArrayList<SegmentRouterPortInfo>();
+ Collection<Port> portList =sw.getPorts();
+ String subnets = null;
+ if (sw.getAllStringAttributes().containsKey("subnets")){
+ subnets = sw.getAllStringAttributes().get("subnets");
+ JSONArray subnetArray = JSONArray.fromObject(subnets);
+ Iterator<Port> pI = portList.iterator();
+ int nodeSid = Integer.parseInt(sw.getStringAttribute("nodeSid"));
+ HashMap<Integer, List<Integer>> adjPortInfo = segmentRoutingService.getAdjacencyInfo(nodeSid);
+ while(pI.hasNext()){
+ Port p = pI.next();
+ Iterator<Integer> keyIt = adjPortInfo.keySet().iterator();
+ Iterator<?> sI = subnetArray.iterator();
+ List<Integer> adjacency = new ArrayList<Integer>();
+ while(keyIt.hasNext()){
+ Integer adj = keyIt.next();
+ List<Integer> adjPortList = adjPortInfo.get(adj);
+ if(adjPortList.contains(Integer.valueOf(p.getNumber().shortValue()))){
+ adjacency.add(adj);
+ }
+ }
+ String subnet = null;
+ while(sI.hasNext()){
+ JSONObject portSubnetIp = (JSONObject) sI.next();
+ subnet = null;
+ if(portSubnetIp.getString("portNo").equals(p.getNumber().toString())){
+ subnet = portSubnetIp.getString("subnetIp");
+ break;
+ }
+ }
+ listPortInfo.add( new SegmentRouterPortInfo(subnet,p, adjacency));
+ }
+ result.put(routerId, listPortInfo);
+ return eval(toRepresentation(result,null));
+ }
+ else{
+ Iterator<Port> pI = portList.iterator();
+ int nodeSid = Integer.parseInt(sw.getStringAttribute("nodeSid"));
+ HashMap<Integer, List<Integer>> adjPortInfo = segmentRoutingService.getAdjacencyInfo(nodeSid);
+ while(pI.hasNext()){
+ Port p = pI.next();
+ String subnet = null;
+ Iterator<Integer> keyIt = adjPortInfo.keySet().iterator();
+ List<Integer> adjacency = new ArrayList<Integer>();
+ while(keyIt.hasNext()){
+ Integer adj = keyIt.next();
+ List<Integer> adjPortList = adjPortInfo.get(adj);
+ if(adjPortList.contains(Integer.valueOf(p.getNumber().shortValue()))){
+ adjacency.add(adj);
+ }
+ }
+ listPortInfo.add( new SegmentRouterPortInfo(subnet,p, adjacency));
+ }
+ result.put(routerId, listPortInfo);
+ return eval(toRepresentation(result,null));
+ }
+ }
+ else if(routerId != null && statsType.equals("adjacency")){
+ ISegmentRoutingService segmentRoutingService =
+ (ISegmentRoutingService) getContext().getAttributes().
+ get(ISegmentRoutingService.class.getCanonicalName());
+ Switch sw = mutableTopology
+ .getSwitch(new Dpid(HexString.toLong(routerId)));
+ if(sw ==null){
+ //TODO: Add exception
+ return null;
+ }
+ int nodeSid = Integer.parseInt(sw.getStringAttribute("nodeSid"));
+ HashMap<Integer, List<Integer>> adjPortInfo = segmentRoutingService.getAdjacencyInfo(nodeSid);
+ Iterator<Integer> aPIt = adjPortInfo.keySet().iterator();
+ List<SegmentRouterAdjacencyInfo> result= new ArrayList<SegmentRouterAdjacencyInfo>();
+ while(aPIt.hasNext()){
+ Integer adj = aPIt.next();
+ result.add( new SegmentRouterAdjacencyInfo(adj,
+ adjPortInfo.get(adj)));
+ }
+ /*HashMap<String,HashMap<Integer, List<Integer>>> dpidAdjPortMap =
+ new HashMap<String,HashMap<Integer, List<Integer>>>();
+ dpidAdjPortMap.put(routerId, adjPortInfo);
+ List<HashMap<String,HashMap<Integer, List<Integer>>>> result =
+ new ArrayList<HashMap<String,HashMap<Integer, List<Integer>>>>();
+ result.add(dpidAdjPortMap);*/
+
+ return result;
+ }
+ } finally {
+ mutableTopology.releaseReadLock();
+ }
+ //Should Never get to this point.
+ return null;
+ }
+}