OFMTopologyManager

java.lang.Object
- etri.sdn.controller.OFModule
- - etri.sdn.controller.module.topologymanager.OFMTopologyManager

All Implemented Interfaces:

IService, ILinkDiscoveryListener, IRoutingService, ITopologyService
```
public class OFMTopologyManager
extends OFModule
implements ITopologyService, ILinkDiscoveryListener, IRoutingService
```
Topology Manager Module. This module implements ITopologyService. Slightly modified by

Author:

SaeHyong Park (labry@etri.re.kr)

Nested Class Summary
- Nested classes/interfaces inherited from interface etri.sdn.controller.module.linkdiscovery.ILinkDiscoveryListener
  ILinkDiscoveryListener.LDUpdate, ILinkDiscoveryListener.UpdateOperation

Field Summary

Fields
Modifier and Type	Field and Description
`protected java.util.List<ILinkDiscoveryListener.LDUpdate>`	`appliedUpdates`
`protected TopologyInstance`	`currentInstance`
`protected TopologyInstance`	`currentInstanceWithoutTunnels`
`protected java.util.Map<NodePortTuple,java.util.Set<Link>>`	`directLinks` Set of direct links
`protected boolean`	`dtLinksUpdated` Flag that indicates if direct or tunnel links were updated as part of LDUpdate.
`private java.util.Date`	`lastUpdateTime`
`protected java.util.concurrent.BlockingQueue<ILinkDiscoveryListener.LDUpdate>`	`ldUpdates`
`protected ILinkDiscoveryService`	`linkDiscovery`
`protected boolean`	`linksUpdated` Flag that indicates if links (direct/tunnel/multihop links) were updated as part of LDUpdate.
`protected java.util.Map<NodePortTuple,java.util.Set<Link>>`	`portBroadcastDomainLinks` set of links that are broadcast domain links.
`private OFProtocol`	`protocol`
`protected java.util.Map<NodePortTuple,java.util.Set<Link>>`	`switchPortLinks` Set of links organized by node port tuple
`protected java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>>`	`switchPorts` Set of ports for each switch
`protected java.util.ArrayList<ITopologyListener>`	`topologyAware`
`private Topology`	`topologyModel`
`protected java.util.Map<NodePortTuple,java.util.Set<Link>>`	`tunnelLinks` set of tunnel links

Fields inherited from class etri.sdn.controller.OFModule
controller

Constructor Summary

Constructors
Constructor and Description

OFMTopologyManager()

Constructors
Constructor and Description
`OFMTopologyManager()`

Method Summary

Methods
Modifier and Type	Method and Description
`private boolean`	`addLinkToStructure(java.util.Map<NodePortTuple,java.util.Set<Link>> s, Link l)` Add the given link to the data structure.
`void`	`addListener(ITopologyListener listener)`
`void`	`addOrUpdateLink(long srcId, int srcPort, long dstId, int dstPort, ILinkDiscovery.LinkType type)`
`private void`	`addPortToSwitch(long s, int p)`
`void`	`addSwitch(long sid)`
`void`	`applyUpdates()` Updates concerning switch disconnect and port down are not processed.
`void`	`clear()`
`void`	`clearCurrentTopology()` Clears the current topology.
`protected boolean`	`createNewInstance()` This function computes a new topology instance.
`protected void`	`doFloodBDDP(long pinSwitch, org.openflow.protocol.interfaces.OFPacketIn pi)` The BDDP packets are forwarded out of all the ports out of an openflowdomain.
`void`	`doMultiActionPacketOut(byte[] packetData, IOFSwitch sw, java.util.Set<java.lang.Integer> ports)` TODO This method must be moved to a layer below forwarding so that anyone can use it.
`protected boolean`	`dropFilter(long sw, org.openflow.protocol.interfaces.OFPacketIn pi)` If the packet-in switch port is disabled for all data traffic, then the packet will be dropped.
`NodePortTuple`	`getAllowedIncomingBroadcastPort(long src, short srcPort)` If the src broadcast domain port is not allowed for incoming broadcast, this method provides the topologically equivalent incoming broadcast-allowed src port.
`NodePortTuple`	`getAllowedIncomingBroadcastPort(long src, short srcPort, boolean tunnelEnabled)`
`NodePortTuple`	`getAllowedOutgoingBroadcastPort(long src, short srcPort, long dst, short dstPort)` If the dst is not allowed by the higher-level topology, this method provides the topologically equivalent broadcast port.
`NodePortTuple`	`getAllowedOutgoingBroadcastPort(long src, short srcPort, long dst, short dstPort, boolean tunnelEnabled)`
`java.util.Set<NodePortTuple>`	`getBlockedPorts()` Returns a set of blocked ports.
`java.util.Set<NodePortTuple>`	`getBroadcastDomainPorts()` Gets the set of ports that belong to a broadcast domain.
`java.util.Set<java.lang.Short>`	`getBroadcastPorts(long targetSw, long src, short srcPort)` Get broadcast ports on a target switch for a given attachmentpoint point port.
`java.util.Set<java.lang.Short>`	`getBroadcastPorts(long targetSw, long src, short srcPort, boolean tunnelEnabled)`
`TopologyInstance`	`getCurrentInstance()`
`TopologyInstance`	`getCurrentInstance(boolean tunnelEnabled)`
`NodePortTuple`	`getIncomingSwitchPort(long src, short srcPort, long dst, short dstPort)`
`NodePortTuple`	`getIncomingSwitchPort(long src, short srcPort, long dst, short dstPort, boolean tunnelEnabled)`
`protected int`	`getInputPort(org.openflow.protocol.interfaces.OFPacketIn pi)`
`long`	`getL2DomainId(long switchId)` Returns the identifier of the L2 domain of a given switch.
`long`	`getL2DomainId(long switchId, boolean tunnelEnabled)`
`java.util.List<ILinkDiscoveryListener.LDUpdate>`	`getLastLinkUpdates()` ITopologyListener provides topologyChanged notification, but not what the changes were.
`java.util.Date`	`getLastUpdateTime()`
`OFModel[]`	`getModels()` returns the array of all `OFModel` objects associated with this module.
`long`	`getOpenflowDomainId(long switchId)`
`long`	`getOpenflowDomainId(long switchId, boolean tunnelEnabled)`
`NodePortTuple`	`getOutgoingSwitchPort(long src, short srcPort, long dst, short dstPort)` Get the proper outgoing switchport for a given pair of src-dst switchports.
`NodePortTuple`	`getOutgoingSwitchPort(long src, short srcPort, long dst, short dstPort, boolean tunnelEnabled)`
`java.util.Set<java.lang.Integer>`	`getPorts(long sw)` Switch methods
`java.util.Set<java.lang.Integer>`	`getPortsWithLinks(long sw)` Gets a list of ports on a given switch that are known to topology.
`java.util.Set<java.lang.Integer>`	`getPortsWithLinks(long sw, boolean tunnelEnabled)`
`Route`	`getRoute(long src, long dst)` Provides a route between src and dst that allows tunnels.
`Route`	`getRoute(long src, long dst, boolean tunnelEnabled)` Provides a route between src and dst, with option to allow or not allow tunnels in the path.
`Route`	`getRoute(long src, short srcPort, long dst, short dstPort)`
`Route`	`getRoute(long src, short srcPort, long dst, short dstPort, boolean tunnelEnabled)`
`java.util.Set<NodePortTuple>`	`getTunnelPorts()`
`protected boolean`	`handleDisconnect(Connection conn)` Process the disconnection event from a switch.
`boolean`	`handleHandshakedEvent(Connection sw, MessageContext context)` An abstract method that all subclasses should implement.
`boolean`	`handleMessage(Connection conn, MessageContext context, org.openflow.protocol.OFMessage msg, java.util.List<org.openflow.protocol.OFMessage> outgoing)` This is starting point of OFMTopologyManager
`void`	`informListeners()`
`void`	`init()`
`void`	`initialize()` method that initializes this module.
`protected void`	`initiatePeriodicTopologyUpdate()`
`boolean`	`inSameL2Domain(long switch1, long switch2)` Queries whether two switches are in the same island.
`boolean`	`inSameL2Domain(long switch1, long switch2, boolean tunnelEnabled)`
`boolean`	`inSameOpenflowDomain(long switch1, long switch2)` Queries whether two switches are in the same cluster.
`boolean`	`inSameOpenflowDomain(long switch1, long switch2, boolean tunnelEnabled)`
`boolean`	`isAllowed(long sw, short portId)`
`boolean`	`isAllowed(long sw, short portId, boolean tunnelEnabled)`
`boolean`	`isAttachmentPointPort(long switchid, short port)` Query to determine if devices must be learned on a given switch port.
`boolean`	`isAttachmentPointPort(long switchid, short port, boolean tunnelEnabled)`
`boolean`	`isBroadcastDomainPort(long sw, short port)`
`boolean`	`isBroadcastDomainPort(long sw, short port, boolean tunnelEnabled)`
`boolean`	`isConsistent(long oldSw, short oldPort, long newSw, short newPort)` Indicates if an attachment point on the new switch port is consistent with the attachment point on the old switch port or not.
`boolean`	`isConsistent(long oldSw, short oldPort, long newSw, short newPort, boolean tunnelEnabled)`
`boolean`	`isIncomingBroadcastAllowed(long sw, short portId)`
`boolean`	`isIncomingBroadcastAllowed(long sw, short portId, boolean tunnelEnabled)`
`boolean`	`isInSameBroadcastDomain(long s1, short p1, long s2, short p2)` Indicates if the two switch ports are connected to the same broadcast domain or not.
`boolean`	`isInSameBroadcastDomain(long s1, short p1, long s2, short p2, boolean tunnelEnabled)`
`void`	`linkDiscoveryUpdate(ILinkDiscoveryListener.LDUpdate update)` Any class that implements ILinkDiscoveryListener receives link update notifications via this callback method
`private boolean`	`processPacketInMessage(IOFSwitch sw, org.openflow.protocol.interfaces.OFPacketIn pi, MessageContext context, java.util.List<org.openflow.protocol.OFMessage> outgoing)` From the OFPacketIn message received, this method performs following procedures.
`void`	`removeLink(Link link)`
`void`	`removeLink(long srcId, int srcPort, long dstId, int dstPort)`
`private boolean`	`removeLinkFromStructure(java.util.Map<NodePortTuple,java.util.Set<Link>> s, Link l)` Delete the given link from the data strucure.
`boolean`	`routeExists(long src, long dst)` Check if a route exists between src and dst, including tunnel links in the path.
`boolean`	`routeExists(long src, long dst, boolean tunnelEnabled)` Check if a route exists between src and dst, with option to have or not have tunnels as part of the path.
`boolean`	`updateTopology()`

Methods inherited from class etri.sdn.controller.OFModule
getController, getModule, init, processDisconnect, processHandshakeFinished, processMessage, registerFilter, registerModule

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - switchPorts
```
protected java.util.Map<java.lang.Long,java.util.Set<java.lang.Integer>> switchPorts
```
    Set of ports for each switch
  - switchPortLinks
```
protected java.util.Map<NodePortTuple,java.util.Set<Link>> switchPortLinks
```
    Set of links organized by node port tuple
  - directLinks
```
protected java.util.Map<NodePortTuple,java.util.Set<Link>> directLinks
```
    Set of direct links
  - portBroadcastDomainLinks
```
protected java.util.Map<NodePortTuple,java.util.Set<Link>> portBroadcastDomainLinks
```
    set of links that are broadcast domain links.
  - tunnelLinks
```
protected java.util.Map<NodePortTuple,java.util.Set<Link>> tunnelLinks
```
    set of tunnel links
  - currentInstance
```
protected TopologyInstance currentInstance
```
  - currentInstanceWithoutTunnels
```
protected TopologyInstance currentInstanceWithoutTunnels
```
  - linksUpdated
```
protected boolean linksUpdated
```
    Flag that indicates if links (direct/tunnel/multihop links) were updated as part of LDUpdate.
  - dtLinksUpdated
```
protected boolean dtLinksUpdated
```
    Flag that indicates if direct or tunnel links were updated as part of LDUpdate.
  - linkDiscovery
```
protected ILinkDiscoveryService linkDiscovery
```
  - topologyAware
```
protected java.util.ArrayList<ITopologyListener> topologyAware
```
  - ldUpdates
```
protected java.util.concurrent.BlockingQueue<ILinkDiscoveryListener.LDUpdate> ldUpdates
```
  - appliedUpdates
```
protected java.util.List<ILinkDiscoveryListener.LDUpdate> appliedUpdates
```
  - lastUpdateTime
```
private java.util.Date lastUpdateTime
```
  - topologyModel
```
private Topology topologyModel
```
  - protocol
```
private OFProtocol protocol
```
- Constructor Detail
  - OFMTopologyManager
```
public OFMTopologyManager()
```
- Method Detail
  - initialize
```
public void initialize()
```
    Description copied from class: OFModule
    
    method that initializes this module. Subclass of OFModule must implement this method. You can find the example of this method in OFMLinkDiscovery.initialize().
    
    Specified by:
    
    initialize in class OFModule
  - initiatePeriodicTopologyUpdate
```
protected void initiatePeriodicTopologyUpdate()
```
  - init
```
public void init()
```
  - updateTopology
```
public boolean updateTopology()
```
  - handleMessage
```
public boolean handleMessage(Connection conn,
                    MessageContext context,
                    org.openflow.protocol.OFMessage msg,
                    java.util.List<org.openflow.protocol.OFMessage> outgoing)
```
    This is starting point of OFMTopologyManager
    
    Specified by:
    
    handleMessage in class OFModule
    
    Parameters:
    conn -
    context - MessageContext
    outgoing - list of OFMessage objects to be delivered to switches after this method ends the execution
    msg - the actual message object
    
    Returns:
    true to further process the message, or false.
  - handleDisconnect
```
protected boolean handleDisconnect(Connection conn)
```
    Description copied from class: OFModule
    
    Process the disconnection event from a switch. This callback method is called by OFModule.processDisconnect(Connection). All subclasses of OFModule should implement this method.
    
    Specified by:
    
    handleDisconnect in class OFModule
    
    Parameters:
    conn - connection that the event has occurred
    
    Returns:
    true if the event has been correctly processed. false otherwise.
  - getCurrentInstance
```
public TopologyInstance getCurrentInstance(boolean tunnelEnabled)
```
  - getCurrentInstance
```
public TopologyInstance getCurrentInstance()
```
  - isAllowed
```
public boolean isAllowed(long sw,
                short portId)
```
    Specified by:
    
    isAllowed in interface ITopologyService
  - isAllowed
```
public boolean isAllowed(long sw,
                short portId,
                boolean tunnelEnabled)
```
    Specified by:
    
    isAllowed in interface ITopologyService
  - getInputPort
```
protected int getInputPort(org.openflow.protocol.interfaces.OFPacketIn pi)
```
  - dropFilter
```
protected boolean dropFilter(long sw,
                 org.openflow.protocol.interfaces.OFPacketIn pi)
```
    If the packet-in switch port is disabled for all data traffic, then the packet will be dropped. Otherwise, the packet will follow the normal processing chain.
    
    Parameters:
    sw - switch
    pi - Packet-IN message
    
    Returns:
    true if correctly enforced, false otherwise
  - doMultiActionPacketOut
```
public void doMultiActionPacketOut(byte[] packetData,
                          IOFSwitch sw,
                          java.util.Set<java.lang.Integer> ports)
```
    TODO This method must be moved to a layer below forwarding so that anyone can use it.
    
    Parameters:
    packetData -
    sw -
    ports -
  - doFloodBDDP
```
protected void doFloodBDDP(long pinSwitch,
               org.openflow.protocol.interfaces.OFPacketIn pi)
```
    The BDDP packets are forwarded out of all the ports out of an openflowdomain. Get all the switches in the same openflow domain as the sw (disabling tunnels). Then get all the external switch ports and send these packets out.
    
    Parameters:
    pinSwitch - switch datapath id
    pi - packet-in message
  - processPacketInMessage
```
private boolean processPacketInMessage(IOFSwitch sw,
                             org.openflow.protocol.interfaces.OFPacketIn pi,
                             MessageContext context,
                             java.util.List<org.openflow.protocol.OFMessage> outgoing)
```
    From the OFPacketIn message received, this method performs following procedures.
    1. parse Ethernet header
    2. check is the OFPacketIn is a BSN (BigSwitch Network) LLDP message
    3. in case BSN LLDP, call doFloodBDDP
    Parameters:
    sw - the switch that the pi message is received
    pi - OFPacketIn message itself
    context - MessageContext.
    outgoing - list of OFMessage objects to be delivered to switches after this method ends the execution.
    
    Returns:
    true to further process the message, or false.
  - addSwitch
```
public void addSwitch(long sid)
```
  - addPortToSwitch
```
private void addPortToSwitch(long s,
                   int p)
```
  - applyUpdates
```
public void applyUpdates()
```
    Updates concerning switch disconnect and port down are not processed. LinkDiscoveryManager is expected to process those messages and send multiple link removed messages. However, all the updates from LinkDiscoveryManager would be propagated to the listeners of topology.
  - addOrUpdateLink
```
public void addOrUpdateLink(long srcId,
                   int srcPort,
                   long dstId,
                   int dstPort,
                   ILinkDiscovery.LinkType type)
```
  - removeLink
```
public void removeLink(Link link)
```
  - removeLink
```
public void removeLink(long srcId,
              int srcPort,
              long dstId,
              int dstPort)
```
  - clear
```
public void clear()
```
  - clearCurrentTopology
```
public void clearCurrentTopology()
```
    Clears the current topology. Note that this does NOT send out updates.
  - addLinkToStructure
```
private boolean addLinkToStructure(java.util.Map<NodePortTuple,java.util.Set<Link>> s,
                         Link l)
```
    Add the given link to the data structure. Returns true if a link was added.
    
    Parameters:
    s - Map>
    l - Link
    
    Returns:
    true if link is successfully added, false otherwise
  - removeLinkFromStructure
```
private boolean removeLinkFromStructure(java.util.Map<NodePortTuple,java.util.Set<Link>> s,
                              Link l)
```
    Delete the given link from the data strucure. Returns true if the link was deleted.
    
    Parameters:
    s - Map>
    l - Link
    
    Returns:
    true if successfully removed, false otherwise
  - createNewInstance
```
protected boolean createNewInstance()
```
    This function computes a new topology instance. It ignores links connected to all broadcast domain ports and tunnel ports. The method returns if a new instance of topology was created or not.
  - informListeners
```
public void informListeners()
```
  - handleHandshakedEvent
```
public boolean handleHandshakedEvent(Connection sw,
                            MessageContext context)
```
    Description copied from class: OFModule
    
    An abstract method that all subclasses should implement. This method is called after FEATURE-REQUEST and FEATURE-REPLY is correct exchanged, by OFModule.processHandshakeFinished(Connection, MessageContext). Normally, most of modules have very simple implementation for this method, only returning true.
    
    Specified by:
    
    handleHandshakedEvent in class OFModule
    
    Parameters:
    sw - connection that the event has occurred
    context - message context for the handshaking messages
    
    Returns:
    true is returned when the event has been correctly processed. false otherwise.
  - linkDiscoveryUpdate
```
public void linkDiscoveryUpdate(ILinkDiscoveryListener.LDUpdate update)
```
    Description copied from interface: ILinkDiscoveryListener
    
    Any class that implements ILinkDiscoveryListener receives link update notifications via this callback method
    
    Specified by:
    
    linkDiscoveryUpdate in interface ILinkDiscoveryListener
    
    Parameters:
    update - ILinkDiscoveryListener.LDUpdate
  - addListener
```
public void addListener(ITopologyListener listener)
```
    Specified by:
    
    addListener in interface ITopologyService
  - getLastUpdateTime
```
public java.util.Date getLastUpdateTime()
```
    Specified by:
    
    getLastUpdateTime in interface ITopologyService
  - isAttachmentPointPort
```
public boolean isAttachmentPointPort(long switchid,
                            short port)
```
    Description copied from interface: ITopologyService
    
    Query to determine if devices must be learned on a given switch port.
    
    Specified by:
    
    isAttachmentPointPort in interface ITopologyService
  - isAttachmentPointPort
```
public boolean isAttachmentPointPort(long switchid,
                            short port,
                            boolean tunnelEnabled)
```
    Specified by:
    
    isAttachmentPointPort in interface ITopologyService
  - getOpenflowDomainId
```
public long getOpenflowDomainId(long switchId)
```
    Specified by:
    
    getOpenflowDomainId in interface ITopologyService
  - getOpenflowDomainId
```
public long getOpenflowDomainId(long switchId,
                       boolean tunnelEnabled)
```
    Specified by:
    
    getOpenflowDomainId in interface ITopologyService
  - getL2DomainId
```
public long getL2DomainId(long switchId)
```
    Description copied from interface: ITopologyService
    
    Returns the identifier of the L2 domain of a given switch.
    
    Specified by:
    
    getL2DomainId in interface ITopologyService
    
    Parameters:
    switchId - The DPID of the switch in long form
    
    Returns:
    The DPID of the switch that is the key for the cluster
  - getL2DomainId
```
public long getL2DomainId(long switchId,
                 boolean tunnelEnabled)
```
    Specified by:
    
    getL2DomainId in interface ITopologyService
  - inSameOpenflowDomain
```
public boolean inSameOpenflowDomain(long switch1,
                           long switch2)
```
    Description copied from interface: ITopologyService
    
    Queries whether two switches are in the same cluster.
    
    Specified by:
    
    inSameOpenflowDomain in interface ITopologyService
    
    Returns:
    true if the switches are in the same cluster
  - inSameOpenflowDomain
```
public boolean inSameOpenflowDomain(long switch1,
                           long switch2,
                           boolean tunnelEnabled)
```
    Specified by:
    
    inSameOpenflowDomain in interface ITopologyService
  - inSameL2Domain
```
public boolean inSameL2Domain(long switch1,
                     long switch2)
```
    Description copied from interface: ITopologyService
    
    Queries whether two switches are in the same island. Currently, island and cluster are the same. In future, islands could be different than clusters.
    
    Specified by:
    
    inSameL2Domain in interface ITopologyService
    
    Returns:
    True of they are in the same island, false otherwise
  - inSameL2Domain
```
public boolean inSameL2Domain(long switch1,
                     long switch2,
                     boolean tunnelEnabled)
```
    Specified by:
    
    inSameL2Domain in interface ITopologyService
  - isBroadcastDomainPort
```
public boolean isBroadcastDomainPort(long sw,
                            short port)
```
    Specified by:
    
    isBroadcastDomainPort in interface ITopologyService
  - isBroadcastDomainPort
```
public boolean isBroadcastDomainPort(long sw,
                            short port,
                            boolean tunnelEnabled)
```
    Specified by:
    
    isBroadcastDomainPort in interface ITopologyService
  - isConsistent
```
public boolean isConsistent(long oldSw,
                   short oldPort,
                   long newSw,
                   short newPort)
```
    Description copied from interface: ITopologyService
    
    Indicates if an attachment point on the new switch port is consistent with the attachment point on the old switch port or not.
    
    Specified by:
    
    isConsistent in interface ITopologyService
  - isConsistent
```
public boolean isConsistent(long oldSw,
                   short oldPort,
                   long newSw,
                   short newPort,
                   boolean tunnelEnabled)
```
    Specified by:
    
    isConsistent in interface ITopologyService
  - isInSameBroadcastDomain
```
public boolean isInSameBroadcastDomain(long s1,
                              short p1,
                              long s2,
                              short p2)
```
    Description copied from interface: ITopologyService
    
    Indicates if the two switch ports are connected to the same broadcast domain or not.
    
    Specified by:
    
    isInSameBroadcastDomain in interface ITopologyService
    
    Returns:
    true if two switch port is in the same broadcast domain, false otherwise
  - isInSameBroadcastDomain
```
public boolean isInSameBroadcastDomain(long s1,
                              short p1,
                              long s2,
                              short p2,
                              boolean tunnelEnabled)
```
    Specified by:
    
    isInSameBroadcastDomain in interface ITopologyService
  - getPortsWithLinks
```
public java.util.Set<java.lang.Integer> getPortsWithLinks(long sw)
```
    Description copied from interface: ITopologyService
    
    Gets a list of ports on a given switch that are known to topology.
    
    Specified by:
    
    getPortsWithLinks in interface ITopologyService
    
    Parameters:
    sw - The switch DPID in long
    
    Returns:
    The set of ports on this switch
  - getPortsWithLinks
```
public java.util.Set<java.lang.Integer> getPortsWithLinks(long sw,
                                                 boolean tunnelEnabled)
```
    Specified by:
    
    getPortsWithLinks in interface ITopologyService
  - getBroadcastPorts
```
public java.util.Set<java.lang.Short> getBroadcastPorts(long targetSw,
                                               long src,
                                               short srcPort)
```
    Description copied from interface: ITopologyService
    
    Get broadcast ports on a target switch for a given attachmentpoint point port.
    
    Specified by:
    
    getBroadcastPorts in interface ITopologyService
  - getBroadcastPorts
```
public java.util.Set<java.lang.Short> getBroadcastPorts(long targetSw,
                                               long src,
                                               short srcPort,
                                               boolean tunnelEnabled)
```
    Specified by:
    
    getBroadcastPorts in interface ITopologyService
  - isIncomingBroadcastAllowed
```
public boolean isIncomingBroadcastAllowed(long sw,
                                 short portId)
```
    Specified by:
    
    isIncomingBroadcastAllowed in interface ITopologyService
  - isIncomingBroadcastAllowed
```
public boolean isIncomingBroadcastAllowed(long sw,
                                 short portId,
                                 boolean tunnelEnabled)
```
    Specified by:
    
    isIncomingBroadcastAllowed in interface ITopologyService
  - getOutgoingSwitchPort
```
public NodePortTuple getOutgoingSwitchPort(long src,
                                  short srcPort,
                                  long dst,
                                  short dstPort)
```
    Description copied from interface: ITopologyService
    
    Get the proper outgoing switchport for a given pair of src-dst switchports.
    
    Specified by:
    
    getOutgoingSwitchPort in interface ITopologyService
  - getOutgoingSwitchPort
```
public NodePortTuple getOutgoingSwitchPort(long src,
                                  short srcPort,
                                  long dst,
                                  short dstPort,
                                  boolean tunnelEnabled)
```
    Specified by:
    
    getOutgoingSwitchPort in interface ITopologyService
  - getIncomingSwitchPort
```
public NodePortTuple getIncomingSwitchPort(long src,
                                  short srcPort,
                                  long dst,
                                  short dstPort)
```
    Specified by:
    
    getIncomingSwitchPort in interface ITopologyService
  - getIncomingSwitchPort
```
public NodePortTuple getIncomingSwitchPort(long src,
                                  short srcPort,
                                  long dst,
                                  short dstPort,
                                  boolean tunnelEnabled)
```
    Specified by:
    
    getIncomingSwitchPort in interface ITopologyService
  - getAllowedOutgoingBroadcastPort
```
public NodePortTuple getAllowedOutgoingBroadcastPort(long src,
                                            short srcPort,
                                            long dst,
                                            short dstPort)
```
    Description copied from interface: ITopologyService
    
    If the dst is not allowed by the higher-level topology, this method provides the topologically equivalent broadcast port.
    
    Specified by:
    
    getAllowedOutgoingBroadcastPort in interface ITopologyService
    
    Returns:
    the allowed broadcast port
  - getAllowedOutgoingBroadcastPort
```
public NodePortTuple getAllowedOutgoingBroadcastPort(long src,
                                            short srcPort,
                                            long dst,
                                            short dstPort,
                                            boolean tunnelEnabled)
```
    Specified by:
    
    getAllowedOutgoingBroadcastPort in interface ITopologyService
  - getAllowedIncomingBroadcastPort
```
public NodePortTuple getAllowedIncomingBroadcastPort(long src,
                                            short srcPort)
```
    Description copied from interface: ITopologyService
    
    If the src broadcast domain port is not allowed for incoming broadcast, this method provides the topologically equivalent incoming broadcast-allowed src port.
    
    Specified by:
    
    getAllowedIncomingBroadcastPort in interface ITopologyService
    
    Returns:
    the allowed broadcast port
  - getAllowedIncomingBroadcastPort
```
public NodePortTuple getAllowedIncomingBroadcastPort(long src,
                                            short srcPort,
                                            boolean tunnelEnabled)
```
    Specified by:
    
    getAllowedIncomingBroadcastPort in interface ITopologyService
  - getBroadcastDomainPorts
```
public java.util.Set<NodePortTuple> getBroadcastDomainPorts()
```
    Description copied from interface: ITopologyService
    
    Gets the set of ports that belong to a broadcast domain.
    
    Specified by:
    
    getBroadcastDomainPorts in interface ITopologyService
    
    Returns:
    The set of ports that belong to a broadcast domain.
  - getTunnelPorts
```
public java.util.Set<NodePortTuple> getTunnelPorts()
```
    Specified by:
    
    getTunnelPorts in interface ITopologyService
  - getBlockedPorts
```
public java.util.Set<NodePortTuple> getBlockedPorts()
```
    Description copied from interface: ITopologyService
    
    Returns a set of blocked ports. The set of blocked ports is the union of all the blocked ports across all instances.
    
    Specified by:
    
    getBlockedPorts in interface ITopologyService
    
    Returns:
    Set
  - getLastLinkUpdates
```
public java.util.List<ILinkDiscoveryListener.LDUpdate> getLastLinkUpdates()
```
    Description copied from interface: ITopologyService
    
    ITopologyListener provides topologyChanged notification, but not *what* the changes were. This method returns the delta in the linkUpdates between the current and the previous topology instance.
    
    Specified by:
    
    getLastLinkUpdates in interface ITopologyService
    
    Returns:
    List
  - getPorts
```
public java.util.Set<java.lang.Integer> getPorts(long sw)
```
    Description copied from interface: ITopologyService
    
    Switch methods
    
    Specified by:
    
    getPorts in interface ITopologyService
  - getRoute
```
public Route getRoute(long src,
             long dst)
```
    Description copied from interface: IRoutingService
    
    Provides a route between src and dst that allows tunnels.
    
    Specified by:
    
    getRoute in interface IRoutingService
  - getRoute
```
public Route getRoute(long src,
             long dst,
             boolean tunnelEnabled)
```
    Description copied from interface: IRoutingService
    
    Provides a route between src and dst, with option to allow or not allow tunnels in the path.
    
    Specified by:
    
    getRoute in interface IRoutingService
  - getRoute
```
public Route getRoute(long src,
             short srcPort,
             long dst,
             short dstPort)
```
    Specified by:
    
    getRoute in interface IRoutingService
  - getRoute
```
public Route getRoute(long src,
             short srcPort,
             long dst,
             short dstPort,
             boolean tunnelEnabled)
```
    Specified by:
    
    getRoute in interface IRoutingService
  - routeExists
```
public boolean routeExists(long src,
                  long dst)
```
    Description copied from interface: IRoutingService
    
    Check if a route exists between src and dst, including tunnel links in the path.
    
    Specified by:
    
    routeExists in interface IRoutingService
  - routeExists
```
public boolean routeExists(long src,
                  long dst,
                  boolean tunnelEnabled)
```
    Description copied from interface: IRoutingService
    
    Check if a route exists between src and dst, with option to have or not have tunnels as part of the path.
    
    Specified by:
    
    routeExists in interface IRoutingService
  - getModels
```
public OFModel[] getModels()
```
    Description copied from class: OFModule
    
    returns the array of all OFModel objects associated with this module. Normally the size of the array is one, but not limited to.
    
    Specified by:
    
    getModels in class OFModule
    
    Returns:
    the array of OFModel objects

Class OFMTopologyManager

Nested Class Summary

Nested classes/interfaces inherited from interface etri.sdn.controller.module.linkdiscovery.ILinkDiscoveryListener

Field Summary

Fields inherited from class etri.sdn.controller.OFModule

Constructor Summary

Method Summary

Methods inherited from class etri.sdn.controller.OFModule

Methods inherited from class java.lang.Object

Field Detail

switchPorts

switchPortLinks

directLinks

portBroadcastDomainLinks

tunnelLinks

currentInstance

currentInstanceWithoutTunnels

linksUpdated

dtLinksUpdated

linkDiscovery

topologyAware

ldUpdates

appliedUpdates

lastUpdateTime

topologyModel

protocol

Constructor Detail

OFMTopologyManager

Method Detail

initialize

initiatePeriodicTopologyUpdate

init

updateTopology

handleMessage

handleDisconnect

getCurrentInstance

getCurrentInstance

isAllowed

isAllowed

getInputPort

dropFilter

doMultiActionPacketOut

doFloodBDDP

processPacketInMessage

addSwitch

addPortToSwitch

applyUpdates

addOrUpdateLink

removeLink

removeLink

clear

clearCurrentTopology

addLinkToStructure

removeLinkFromStructure

createNewInstance

informListeners

handleHandshakedEvent

linkDiscoveryUpdate

addListener

getLastUpdateTime

isAttachmentPointPort

isAttachmentPointPort

getOpenflowDomainId

getOpenflowDomainId

getL2DomainId

getL2DomainId

inSameOpenflowDomain

inSameOpenflowDomain

inSameL2Domain

inSameL2Domain

isBroadcastDomainPort

isBroadcastDomainPort

isConsistent

isConsistent

isInSameBroadcastDomain

isInSameBroadcastDomain

getPortsWithLinks

getPortsWithLinks

getBroadcastPorts

getBroadcastPorts