import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
private TopologyGraph getGraph(Set<TopologyVertex> removedVertex, Set<TopologyEdge> removedEdges) {
    if (removedVertex != null) {
        vertexes.remove(removedVertex);
        removedVertex.forEach(v ->
        {
            vertexes.remove(v);
        });
    }

    if (removedEdges != null) {
        removedEdges.forEach(e ->
        {
            edges.remove(e);
        });
    }

    return new DefaultTopologyGraph(vertexes, edges);
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
private TopologyGraph getGraph(Set<TopologyVertex> removedVertex, Set<TopologyEdge> removedEdges) {
    if (removedVertex != null) {
        vertexes.remove(removedVertex);
        removedVertex.forEach(new Consumer<TopologyVertex>() {
            @Override
            public void accept(TopologyVertex v) {
                vertexes.remove(v);
            }
        });
    }

    if (removedEdges != null) {
        removedEdges.forEach(new Consumer<TopologyEdge>() {
            @Override
            public void accept(TopologyEdge e) {
                edges.remove(e);
            }
        });
    }

    return new DefaultTopologyGraph(vertexes, edges);
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
/**
 * Get all possible path between Src and Dst using DFS, by Mao.
 * DFS Core, Recursion Part.
 *
 * @param src          Source point per Recursion
 * @param dst          Final Objective
 * @param passedLink   dynamic, record passed links in real time
 * @param passedDevice dynamic, record entered devices in real time, to avoid loop
 * @param topoGraph    represent the whole world
 * @param result       Set of all Paths.
 * @return no use.
 */
private void dfsFindAllRoutes(TopologyVertex src,
                              TopologyVertex dst,
                              List<TopologyEdge> passedLink,
                              List<TopologyVertex> passedDevice,
                              TopologyGraph topoGraph,
                              Set<List<TopologyEdge>> result) {
    if (src.equals(dst)) {
        return;
    }

    passedDevice.add(src);

    Set<TopologyEdge> egressSrc = topoGraph.getEdgesFrom(src);
    egressSrc.forEach(egress -> {
        TopologyVertex vertexDst = egress.dst();
        if (vertexDst.equals(dst)) {
            //Gain a Path
            passedLink.add(egress);
            result.add(ImmutableList.copyOf(passedLink.iterator()));
            passedLink.remove(egress);

        } else if (!passedDevice.contains(vertexDst)) {
            //DFS into
            passedLink.add(egress);
            dfsFindAllRoutes(vertexDst, dst, passedLink, passedDevice, topoGraph, result);
            passedLink.remove(egress);

        } else {
            //means - passedDevice.contains(vertexDst)
            //We hit a loop, NOT go into
        }
    });

    passedDevice.remove(src);
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
/**
 * Tests the TopologyManager.
 */
@Test(dependsOnMethods = {"TestTopologySpecification"})
public void TestTopologyManager() {
    TopologyManager topologyManager = new TopologyManager();
    topologyManager.setTopologySpecification(topologySpecification);

    Topology topology = topologyManager.currentTopology();
    Assert.assertNotNull(topology);

    TopologyGraph topologyGraph = topologyManager.getGraph(topology);
    Assert.assertEquals(topologyGraph.getVertexes().size(), 2);
    Assert.assertEquals(topologyGraph.getEdges().size(), 2);

    TopologyVertex s3 = (TopologyVertex) topologyGraph.getVertexes().toArray()[0];
    Assert.assertTrue(s3.deviceId().equals(
            DeviceId.deviceId("of:0000000000000003")
    ));

    TopologyEdge l1 = (TopologyEdge) topologyGraph.getEdges().toArray()[0];
    Assert.assertTrue(l1.link().dst().equals(
            new ConnectPoint(
                    DeviceId.deviceId("of:0000000000000004"),
                    PortNumber.portNumber(1)
            )
    ));
    Assert.assertTrue(l1.link().src().equals(
            new ConnectPoint(
                    DeviceId.deviceId("of:0000000000000003"),
                    PortNumber.portNumber(2)
            )
    ));
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
private void changeInTopology(TopologyGraph graphModified) {
    graph = graphModified;
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
public MockTopologyService(TopologyGraph g) {
    cur = g;
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
@Override
public TopologyGraph getGraph(Topology topology) {
    return cur;
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
@Override
public TopologyGraph getGraph(Topology topology) {
    checkPermission(TOPOLOGY_READ);
    checkNotNull(topology, TOPOLOGY_NULL);
    return store.getGraph(topology);
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
@Override
public TopologyGraph getGraph(Topology topology) {
    return defaultTopology(topology).getGraph();
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
@Override
public TopologyGraph getGraph(Topology topology) {
    checkNotNull(topology, TOPOLOGY_NULL);
    return store.getGraph(topology);
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
/**
 * Returns the backing topology graph.
 *
 * @return topology graph
 */
public TopologyGraph getGraph() {
    return graph;
}
 

import org.onosproject.net.topology.TopologyGraph; //导入依赖的package包/类
/**
 * Returns the backing topology graph.
 *
 * @return topology graph
 */
TopologyGraph getGraph() {
    return graph;
}