net.onrc.openvirtex.elements.datapath

Class OVXBigSwitch

java.lang.Object

net.onrc.openvirtex.elements.datapath.Switch<OVXPort>

net.onrc.openvirtex.elements.datapath.OVXSwitch

net.onrc.openvirtex.elements.datapath.OVXBigSwitch

All Implemented Interfaces:

OVXEventHandler, OVXSendMsg, Persistable

public class OVXBigSwitch
extends OVXSwitch

The Class OVXBigSwitch.

Field Summary

Fields inherited from class net.onrc.openvirtex.elements.datapath.OVXSwitch

bufferDimension, bufferMap, capabilities, DPDESCSTRING, flowTable, isActive, missSendLen, supportedActions, tenantId

Fields inherited from class net.onrc.openvirtex.elements.datapath.Switch

channel, DB_KEY, desc, featuresReply, isConnected, map, portMap, switchId, switchName

Constructor Summary

Constructors

Constructor and Description
OVXBigSwitch(long switchId, int tenantId)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	boot() Boots virtual switch by connecting it to the controller.
SwitchRoute	createRoute(OVXPort ingress, OVXPort egress, List<PhysicalLink> path, List<PhysicalLink> revpath, byte priority)
SwitchRoute	createRoute(OVXPort ingress, OVXPort egress, List<PhysicalLink> path, List<PhysicalLink> revpath, byte priority, int routeId) Adds a route between two edge ports of the big switch.
RoutingAlgorithms	getAlg() Gets the routing algorithm used by the big switch.
HashSet<PhysicalLink>	getAllLinks()
Map<String,Object>	getDBObject()
OVXPort	getPort(Short portNumber) Gets the port.
SwitchRoute	getRoute(OVXPort srcPort, OVXPort dstPort) Get the route between source and destination ports.
Set<SwitchRoute>	getRoutebyId(Integer routeId) Fetches a bi-directional route based on the routeId.
Set<SwitchRoute>	getRoutebyPort(OVXPort port) Fetches all routes associated with a specific port, assuming that the routes are duplex.
ConcurrentHashMap<OVXPort,ConcurrentHashMap<OVXPort,SwitchRoute>>	getRouteMap() Gets map of all routes for big switch.
boolean	removePort(Short portNumber) Removes the port.
void	sendSouth(OFMessage msg, OVXPort inPort) Sends a message towards the physical network, via the PhysicalSwitch mapped to this OVXSwitch.
void	setAlg(RoutingAlgorithms alg) Sets the routing algorithm used by the big switch.
String	toString()
int	translate(OFMessage ofm, OVXPort inPort) Generates a new XID for messages destined for the physical network.
boolean	tryRecovery(PhysicalSwitch phySwitch) Tries to gracefully disable the parts of this big switch that map to the specified physical switch.
void	unregister() Unregisters switch from persistent storage, from the mapping, and removes all virtual elements that rely on this switch.
boolean	unregisterRoute(Integer routeId) Unregister route identified by routeId.

Methods inherited from class net.onrc.openvirtex.elements.datapath.OVXSwitch

addDefaultPort, addToBufferMap, deleteFlowMod, equals, generateFeaturesReply, getDBIndex, getDBKey, getDBName, getFlowMod, getFlowTable, getFromBufferMap, getMissSendLen, getNextPortNumber, getPhysicalPortNumber, getTenantId, handleIO, handleRoleIO, hashCode, incrementBackOff, isActive, register, relesePortNumber, removeChannel, resetBackOff, sendMsg, setActive, setChannel, setMissSendLen, tearDown

Methods inherited from class net.onrc.openvirtex.elements.datapath.Switch

addPort, getFeaturesReply, getMap, getName, getPorts, getSwitchId, getSwitchName, setConnected, setDescriptionStats, setFeaturesReply

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

OVXBigSwitch

public OVXBigSwitch(long switchId,
            int tenantId)

Method Detail

getAlg

public RoutingAlgorithms getAlg()

Gets the routing algorithm used by the big switch.

Returns:

the routing algorithm

setAlg

public void setAlg(RoutingAlgorithms alg)

Sets the routing algorithm used by the big switch.

Parameters:

alg - the routing algorithm

getRoute

public SwitchRoute getRoute(OVXPort srcPort,
                   OVXPort dstPort)

Get the route between source and destination ports.

Parameters:

srcPort - the ingress port on the big switch

dstPort - the egress port on the big switch

Returns:

The route

getRoutebyPort

public Set<SwitchRoute> getRoutebyPort(OVXPort port)

Fetches all routes associated with a specific port, assuming that the routes are duplex. Does not account for the use of backups for now...

Parameters:

port - the switch port

Returns:

all routes associated to the switch port

getRoutebyId

public Set<SwitchRoute> getRoutebyId(Integer routeId)

Fetches a bi-directional route based on the routeId.

Parameters:

routeId - the unique route ID

Returns:

the set of routes

getRouteMap

public ConcurrentHashMap<OVXPort,ConcurrentHashMap<OVXPort,SwitchRoute>> getRouteMap()

Gets map of all routes for big switch.

Returns:

map of all routes for big switch

removePort

public boolean removePort(Short portNumber)

Description copied from class: Switch

Removes the port.

Overrides:

removePort in class Switch<OVXPort>

Parameters:

portNumber - the port number

Returns:

true, if successful

boot

public boolean boot()

Description copied from class: OVXSwitch

Boots virtual switch by connecting it to the controller.

Overrides:

boot in class OVXSwitch

Returns:

true if successful, false otherwise

unregisterRoute

public boolean unregisterRoute(Integer routeId)

Unregister route identified by routeId. Release routeId index, remove virtual/physical route mappings from map, and remove virtual port-pair to route mapping from the switch.

Parameters:

routeId - unique route ID

Returns:

True if successful, false if route doesn't exist.

unregister

public void unregister()

Description copied from class: OVXSwitch

Unregisters switch from persistent storage, from the mapping, and removes all virtual elements that rely on this switch.

Overrides:

unregister in class OVXSwitch

tryRecovery

public boolean tryRecovery(PhysicalSwitch phySwitch)

Tries to gracefully disable the parts of this big switch that map to the specified physical switch. This method returns True if the shutdown of the PhysicalSwitch does not compromise this switch's functions, e.g., a backup path can be found through the switch.

Parameters:

phySwitch - the physical switch

Returns:

True for success, false otherwise

getPort

public OVXPort getPort(Short portNumber)

Description copied from class: Switch

Gets the port.

Overrides:

getPort in class Switch<OVXPort>

Parameters:

portNumber - the port number

Returns:

the port instance

toString

public String toString()

Overrides:

toString in class OVXSwitch

sendSouth

public void sendSouth(OFMessage msg,
             OVXPort inPort)

Description copied from class: OVXSwitch

Sends a message towards the physical network, via the PhysicalSwitch mapped to this OVXSwitch.

Specified by:

sendSouth in class OVXSwitch

Parameters:

msg - The OFMessage being translated

inPort - The ingress port, used to identify the PhysicalSwitch underlying an OVXBigSwitch. May be null. Sends a message towards the physical network

createRoute

public SwitchRoute createRoute(OVXPort ingress,
                      OVXPort egress,
                      List<PhysicalLink> path,
                      List<PhysicalLink> revpath,
                      byte priority,
                      int routeId)
                        throws IndexOutOfBoundException

Adds a route between two edge ports of the big switch.

Parameters:

ingress - ingress port

egress - egress port

path - list of links

revpath - the reverse path from egress to ingress

priority - priority value

routeId - unique route ID

Returns:

the unique route ID of the new route

Throws:

IndexOutOfBoundException - if insufficient space to store new route

createRoute

public SwitchRoute createRoute(OVXPort ingress,
                      OVXPort egress,
                      List<PhysicalLink> path,
                      List<PhysicalLink> revpath,
                      byte priority)
                        throws IndexOutOfBoundException

Throws:

IndexOutOfBoundException

translate

public int translate(OFMessage ofm,
            OVXPort inPort)

Description copied from class: OVXSwitch

Generates a new XID for messages destined for the physical network.

Specified by:

translate in class OVXSwitch

Parameters:

ofm - The OFMessage being translated

inPort - The ingress port

Returns:

the new transaction ID

getAllLinks

public HashSet<PhysicalLink> getAllLinks()

getDBObject

public Map<String,Object> getDBObject()

Specified by:

getDBObject in interface Persistable

Overrides:

getDBObject in class OVXSwitch