etri.sdn.controller.module.topologymanager

Class TopologyInstance

java.lang.Object

etri.sdn.controller.module.topologymanager.TopologyInstance

public class TopologyInstance
extends java.lang.Object

A representation of a network topology. Used internally by OFMTopologyManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	TopologyInstance.NodeDist

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Set<Link>	blockedLinks Set of links that are blocked.
protected java.util.Set<NodePortTuple>	blockedPorts Set of switch ports that are marked as blocked.
protected java.util.Set<NodePortTuple>	broadcastDomainPorts
protected java.util.Map<java.lang.Long,java.util.Set<NodePortTuple>>	clusterBroadcastNodePorts
protected java.util.Map<java.lang.Long,BroadcastTree>	clusterBroadcastTrees
protected java.util.Set<Cluster>	clusters
protected java.util.Map<java.lang.Long,BroadcastTree>	destinationRootedTrees
static short	LT_BD_LINK
static short	LT_SH_LINK
static short	LT_TUNNEL
static int	MAX_LINK_WEIGHT
static int	MAX_PATH_WEIGHT
static int	PATH_CACHE_SIZE
protected LRUHashMap<RouteId,Route>	pathcache
protected java.util.Map<java.lang.Long,Cluster>	switchClusterMap
protected java.util.Set<java.lang.Long>	switches
protected java.util.Map<NodePortTuple,java.util.Set<Link>>	switchPortLinks
protected java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>>	switchPorts
protected java.util.Set<NodePortTuple>	tunnelPorts

Constructor Summary

Constructors

Constructor and Description
TopologyInstance()
TopologyInstance(java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>> switchPorts, java.util.Map<NodePortTuple,java.util.Set<Link>> switchPortLinks)
TopologyInstance(java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>> switchPorts, java.util.Set<NodePortTuple> blockedPorts, java.util.Map<NodePortTuple,java.util.Set<Link>> switchPortLinks, java.util.Set<NodePortTuple> broadcastDomainPorts, java.util.Set<NodePortTuple> tunnelPorts)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addLinksToOpenflowDomains()
protected Route	buildroute(RouteId id, long srcId, long dstId)
protected void	calculateBroadcastNodePortsInClusters()
protected void	calculateBroadcastTreeInClusters()
protected void	calculateShortestPathTreeInClusters()
void	compute()
private long	dfsTraverse(long parentIndex, long currIndex, long currSw, java.util.Map<java.lang.Long,ClusterDFS> dfsList, java.util.Set<java.lang.Long> currSet)
protected BroadcastTree	dijkstra(Cluster c, java.lang.Long root, java.util.Map<Link,java.lang.Integer> linkCost, boolean isDstRooted)
NodePortTuple	getAllowedIncomingBroadcastPort(long src, short srcPort)
NodePortTuple	getAllowedOutgoingBroadcastPort(long src, short srcPort, long dst, short dstPort)
protected java.util.Set<Link>	getBlockedLinks()
java.util.Set<NodePortTuple>	getBlockedPorts()
protected java.util.Set<NodePortTuple>	getBroadcastNodePortsInCluster(long sw)
java.util.Set<java.lang.Short>	getBroadcastPorts(long targetSw, long src, short srcPort)
protected BroadcastTree	getBroadcastTreeForCluster(long clusterId)
protected java.util.Set<Cluster>	getClusters()
protected int	getCost(long srcId, long dstId)
NodePortTuple	getIncomingSwitchPort(long src, short srcPort, long dst, short dstPort)
protected long	getL2DomainId(long switchId)
protected long	getOpenflowDomainId(long switchId)
NodePortTuple	getOutgoingSwitchPort(long src, short srcPort, long dst, short dstPort)
java.util.Set<java.lang.Integer>	getPortsWithLinks(long sw)
protected Route	getRoute(long srcId, long dstId)
protected Route	getRoute(long srcId, short srcPort, long dstId, short dstPort)
java.util.Set<java.lang.Long>	getSwitches()
protected java.util.Set<java.lang.Long>	getSwitchesInOpenflowDomain(long switchId)
void	identifyOpenflowDomains()
boolean	inSameBroadcastDomain(long s1, short p1, long s2, short p2)
boolean	inSameL2Domain(long switch1, long switch2)
protected boolean	inSameOpenflowDomain(long switch1, long switch2)
boolean	isAllowed(long sw, short portId)
boolean	isAttachmentPointPort(long switchid, short port)
protected boolean	isBlockedLink(Link l) Returns true if a link has either one of its switch ports blocked.
protected boolean	isBlockedPort(NodePortTuple npt)
boolean	isBroadcastDomainLink(Link l)
boolean	isBroadcastDomainPort(NodePortTuple npt)
boolean	isConsistent(long oldSw, short oldPort, long newSw, short newPort)
protected boolean	isIncomingBroadcastAllowedOnSwitchPort(long sw, short portId)
protected boolean	isInternalToOpenflowDomain(long switchid, short port)
protected boolean	isTunnelLink(Link l)
protected boolean	isTunnelPort(NodePortTuple npt)
void	printTopology()
protected void	removeLinksOnBlockedPorts() Go through every link and identify it is a blocked link or not.
protected boolean	routeExists(long srcId, long dstId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LT_SH_LINK

public static final short LT_SH_LINK

See Also:

Constant Field Values

LT_BD_LINK

public static final short LT_BD_LINK

See Also:

Constant Field Values

LT_TUNNEL

public static final short LT_TUNNEL

See Also:

Constant Field Values

MAX_LINK_WEIGHT

public static final int MAX_LINK_WEIGHT

See Also:

Constant Field Values

MAX_PATH_WEIGHT

public static final int MAX_PATH_WEIGHT

See Also:

Constant Field Values

PATH_CACHE_SIZE

public static final int PATH_CACHE_SIZE

See Also:

Constant Field Values

switchPorts

protected java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>> switchPorts

blockedPorts

protected java.util.Set<NodePortTuple> blockedPorts

Set of switch ports that are marked as blocked. A set of blocked switch ports may be provided at the time of instantiation. In addition, we may add additional ports to this set.

switchPortLinks

protected java.util.Map<NodePortTuple,java.util.Set<Link>> switchPortLinks

blockedLinks

protected java.util.Set<Link> blockedLinks

Set of links that are blocked.

switches

protected java.util.Set<java.lang.Long> switches

broadcastDomainPorts

protected java.util.Set<NodePortTuple> broadcastDomainPorts

tunnelPorts

protected java.util.Set<NodePortTuple> tunnelPorts

clusters

protected java.util.Set<Cluster> clusters

switchClusterMap

protected java.util.Map<java.lang.Long,Cluster> switchClusterMap

destinationRootedTrees

protected java.util.Map<java.lang.Long,BroadcastTree> destinationRootedTrees

clusterBroadcastNodePorts

protected java.util.Map<java.lang.Long,java.util.Set<NodePortTuple>> clusterBroadcastNodePorts

clusterBroadcastTrees

protected java.util.Map<java.lang.Long,BroadcastTree> clusterBroadcastTrees

pathcache

protected LRUHashMap<RouteId,Route> pathcache

Constructor Detail

TopologyInstance

public TopologyInstance()

TopologyInstance

public TopologyInstance(java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>> switchPorts,
                java.util.Map<NodePortTuple,java.util.Set<Link>> switchPortLinks)

TopologyInstance

public TopologyInstance(java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>> switchPorts,
                java.util.Set<NodePortTuple> blockedPorts,
                java.util.Map<NodePortTuple,java.util.Set<Link>> switchPortLinks,
                java.util.Set<NodePortTuple> broadcastDomainPorts,
                java.util.Set<NodePortTuple> tunnelPorts)

Method Detail

compute

public void compute()

printTopology

public void printTopology()

addLinksToOpenflowDomains

protected void addLinksToOpenflowDomains()

identifyOpenflowDomains

public void identifyOpenflowDomains()

dfsTraverse

private long dfsTraverse(long parentIndex,
               long currIndex,
               long currSw,
               java.util.Map<java.lang.Long,ClusterDFS> dfsList,
               java.util.Set<java.lang.Long> currSet)

Parameters:

parentIndex - DFS index of the parent node

currIndex - DFS index to be assigned to a newly visited node

currSw - ID of the current switch

dfsList - HashMap of DFS data structure for each switch

currSet - Set of nodes in the current cluster in formation

removeLinksOnBlockedPorts

protected void removeLinksOnBlockedPorts()

Go through every link and identify it is a blocked link or not. If blocked, remove it from the switchport links and put them in the blocked link category. Note that we do not update the tunnel ports and broadcast domain port structures. We need those to still answer the question if the ports are tunnel or broadcast domain ports. If we add additional ports to blocked ports later on, we may simply call this method again to remove the links on the newly blocked ports.

getBlockedPorts

public java.util.Set<NodePortTuple> getBlockedPorts()

getBlockedLinks

protected java.util.Set<Link> getBlockedLinks()

isBlockedLink

protected boolean isBlockedLink(Link l)

Returns true if a link has either one of its switch ports blocked.

Parameters:

l - Link object

Returns:

true if blocked, false otherwise

isBlockedPort

protected boolean isBlockedPort(NodePortTuple npt)

isTunnelPort

protected boolean isTunnelPort(NodePortTuple npt)

isTunnelLink

protected boolean isTunnelLink(Link l)

isBroadcastDomainLink

public boolean isBroadcastDomainLink(Link l)

isBroadcastDomainPort

public boolean isBroadcastDomainPort(NodePortTuple npt)

dijkstra

protected BroadcastTree dijkstra(Cluster c,
                     java.lang.Long root,
                     java.util.Map<Link,java.lang.Integer> linkCost,
                     boolean isDstRooted)

calculateShortestPathTreeInClusters

protected void calculateShortestPathTreeInClusters()

calculateBroadcastTreeInClusters

protected void calculateBroadcastTreeInClusters()

calculateBroadcastNodePortsInClusters

protected void calculateBroadcastNodePortsInClusters()

buildroute

protected Route buildroute(RouteId id,
               long srcId,
               long dstId)

getCost

protected int getCost(long srcId,
          long dstId)

getClusters

protected java.util.Set<Cluster> getClusters()

routeExists

protected boolean routeExists(long srcId,
                  long dstId)

getRoute

protected Route getRoute(long srcId,
             short srcPort,
             long dstId,
             short dstPort)

getRoute

protected Route getRoute(long srcId,
             long dstId)

getBroadcastTreeForCluster

protected BroadcastTree getBroadcastTreeForCluster(long clusterId)

isInternalToOpenflowDomain

protected boolean isInternalToOpenflowDomain(long switchid,
                                 short port)

isAttachmentPointPort

public boolean isAttachmentPointPort(long switchid,
                            short port)

getOpenflowDomainId

protected long getOpenflowDomainId(long switchId)

getL2DomainId

protected long getL2DomainId(long switchId)

getSwitchesInOpenflowDomain

protected java.util.Set<java.lang.Long> getSwitchesInOpenflowDomain(long switchId)

inSameOpenflowDomain

protected boolean inSameOpenflowDomain(long switch1,
                           long switch2)

isAllowed

public boolean isAllowed(long sw,
                short portId)

isIncomingBroadcastAllowedOnSwitchPort

protected boolean isIncomingBroadcastAllowedOnSwitchPort(long sw,
                                             short portId)

isConsistent

public boolean isConsistent(long oldSw,
                   short oldPort,
                   long newSw,
                   short newPort)

getBroadcastNodePortsInCluster

protected java.util.Set<NodePortTuple> getBroadcastNodePortsInCluster(long sw)

inSameBroadcastDomain

public boolean inSameBroadcastDomain(long s1,
                            short p1,
                            long s2,
                            short p2)

inSameL2Domain

public boolean inSameL2Domain(long switch1,
                     long switch2)

getOutgoingSwitchPort

public NodePortTuple getOutgoingSwitchPort(long src,
                                  short srcPort,
                                  long dst,
                                  short dstPort)

getIncomingSwitchPort

public NodePortTuple getIncomingSwitchPort(long src,
                                  short srcPort,
                                  long dst,
                                  short dstPort)

getSwitches

public java.util.Set<java.lang.Long> getSwitches()

getPortsWithLinks

public java.util.Set<java.lang.Integer> getPortsWithLinks(long sw)

getBroadcastPorts

public java.util.Set<java.lang.Short> getBroadcastPorts(long targetSw,
                                               long src,
                                               short srcPort)

getAllowedOutgoingBroadcastPort

public NodePortTuple getAllowedOutgoingBroadcastPort(long src,
                                            short srcPort,
                                            long dst,
                                            short dstPort)

getAllowedIncomingBroadcastPort

public NodePortTuple getAllowedIncomingBroadcastPort(long src,
                                            short srcPort)