From: Isaku Yamahata <[email protected]>
Signed-off-by: Isaku Yamahata <[email protected]>
---
ryu/lib/ovs/bridge.py | 67 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 67 insertions(+)
diff --git a/ryu/lib/ovs/bridge.py b/ryu/lib/ovs/bridge.py
index 022073d..1fbaa6d 100644
--- a/ryu/lib/ovs/bridge.py
+++ b/ryu/lib/ovs/bridge.py
@@ -36,6 +36,27 @@ class OVSBridgeNotFound(ryu_exc.RyuException):
message = 'no bridge for datapath_id %(datapath_id)s'
+class VifPort(object):
+ def __init__(self, port_name, ofport, vif_id, vif_mac, switch):
+ super(VifPort, self).__init__()
+ self.port_name = port_name
+ self.ofport = ofport
+ self.vif_id = vif_id
+ self.vif_mac = vif_mac
+ self.switch = switch
+
+ def __str__(self):
+ return ('iface-id=%s, '
+ 'vif_mac=%s, '
+ 'port_name=%s, '
+ 'ofport=%d, '
+ 'bridge_name=%s' % (self.vif_id,
+ self.vif_mac,
+ self.port_name,
+ self.ofport,
+ self.switch.br_name))
+
+
class TunnelPort(object):
def __init__(self, port_name, ofport, tunnel_type, local_ip, remote_ip):
super(TunnelPort, self).__init__()
@@ -94,6 +115,11 @@ class OVSBridge(object):
datapath_id=dpid_lib.dpid_to_str(self.datapath_id))
return result[0].name
+ def get_controller(self):
+ command = ovs_vsctl.VSCtlCommand('get-controller', [self.br_name])
+ self.run_command([command])
+ return command.result[0]
+
def set_controller(self, controllers):
command = ovs_vsctl.VSCtlCommand('set-controller', [self.br_name])
command.args.extend(controllers)
@@ -108,6 +134,10 @@ class OVSBridge(object):
'set', (table_name, record, '%s=%s' % (column, value)))
self.run_command([command])
+ def clear_db_attribute(self, table_name, record, column):
+ command = ovs_vsctl.VSCtlCommand('clear', (table_name, record, column))
+ self.run_command([command])
+
def db_get_val(self, table, record, column):
command = ovs_vsctl.VSCtlCommand('get', (table, record, column))
self.run_command([command])
@@ -119,6 +149,9 @@ class OVSBridge(object):
assert type(val) == dict
return val
+ def get_datapath_id(self):
+ return self.db_get_val('Bridge', self.br_name, 'datapath_id')
+
def delete_port(self, port_name):
command = ovs_vsctl.VSCtlCommand(
'del-port', (self.br_name, port_name), ('--if-exists'))
@@ -146,6 +179,9 @@ class OVSBridge(object):
'type=%s' % tunnel_type, 'options=%s' % options))
self.run_command([command_add, command_set])
+ def add_gre_port(self, name, local_ip, remote_ip, key=None):
+ self.add_tunnel_port(name, 'gre', local_ip, remote_ip, key=key)
+
def del_port(self, port_name):
command = ovs_vsctl.VSCtlCommand('del-port', (self.br_name, port_name))
self.run_command([command])
@@ -162,6 +198,37 @@ class OVSBridge(object):
return ports
+ def _vifport(self, name, external_ids):
+ ofport = self.get_ofport(name)
+ return VifPort(name, ofport, external_ids['iface-id'],
+ external_ids['attached-mac'], self)
+
+ def _get_vif_port(self, name):
+ external_ids = self.db_get_map('Interface', name, 'external_ids')
+ if 'iface-id' in external_ids and 'attached-mac' in external_ids:
+ return self._vifport(name, external_ids)
+
+ def get_vif_ports(self):
+ 'returns a VIF object for each VIF port'
+ return self._get_ports(self._get_vif_port)
+
+ def _get_external_port(self, name):
+ # exclude vif ports
+ external_ids = self.db_get_map('Interface', name, 'external_ids')
+ if external_ids:
+ return
+
+ # exclude tunnel ports
+ options = self.db_get_map('Interface', name, 'options')
+ if 'remote_ip' in options:
+ return
+
+ ofport = self.get_ofport(name)
+ return VifPort(name, ofport, None, None, self)
+
+ def get_external_ports(self):
+ return self._get_ports(self._get_external_port)
+
def get_tunnel_port(self, name, tunnel_type='gre'):
type_ = self.db_get_val('Interface', name, 'type')
if type_ != tunnel_type:
--
1.7.12
------------------------------------------------------------------------------
Free Next-Gen Firewall Hardware Offer
Buy your Sophos next-gen firewall before the end March 2013
and get the hardware for free! Learn more.
http://p.sf.net/sfu/sophos-d2d-feb
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel
