summaryrefslogtreecommitdiffstats
path: root/os_net_config
diff options
context:
space:
mode:
Diffstat (limited to 'os_net_config')
-rw-r--r--os_net_config/impl_eni.py5
-rw-r--r--os_net_config/impl_ifcfg.py67
-rw-r--r--os_net_config/objects.py21
-rw-r--r--os_net_config/tests/test_impl_eni.py2
-rw-r--r--os_net_config/tests/test_impl_ifcfg.py54
5 files changed, 113 insertions, 36 deletions
diff --git a/os_net_config/impl_eni.py b/os_net_config/impl_eni.py
index 79671d0..20677da 100644
--- a/os_net_config/impl_eni.py
+++ b/os_net_config/impl_eni.py
@@ -15,6 +15,7 @@
import netaddr
import os_net_config
+from os_net_config import objects
from os_net_config import utils
from os_net_config.openstack.common import processutils
@@ -61,7 +62,7 @@ class ENINetConfig(os_net_config.NetConfig):
else:
_iface += "manual\n"
data = ""
- if interface.type == 'ovs_bridge':
+ if isinstance(interface, objects.OvsBridge):
data += "allow-ovs %s\n" % interface.name
data += _iface
data += _static_addresses(_v4, _v6)
@@ -71,7 +72,7 @@ class ENINetConfig(os_net_config.NetConfig):
for i in interface.members:
data += " %s" % i.name
data += "\n"
- elif interface.type == 'ovs_port':
+ elif interface.ovs_port:
data += "allow-%s %s\n" % (interface.bridge_name, interface.name)
data += _iface
data += _static_addresses(_v4, _v6)
diff --git a/os_net_config/impl_ifcfg.py b/os_net_config/impl_ifcfg.py
index b4da7bc..e9715b8 100644
--- a/os_net_config/impl_ifcfg.py
+++ b/os_net_config/impl_ifcfg.py
@@ -13,6 +13,7 @@
# under the License.
import os_net_config
+from os_net_config import objects
from os_net_config import utils
@@ -40,68 +41,80 @@ class IfcfgNetConfig(os_net_config.NetConfig):
self.routes = {}
self.bridges = {}
- def _addCommon(self, interface):
- data = "DEVICE=%s\n" % interface.name
+ def _addCommon(self, base_opt):
+ data = "DEVICE=%s\n" % base_opt.name
data += "ONBOOT=yes\n"
data += "HOTPLUG=no\n"
- if interface.type == 'ovs_port':
+ if isinstance(base_opt, objects.Vlan):
+ data += "VLAN=yes\n"
+ data += "PHYSDEV=%s\n" % base_opt.device
+ if base_opt.ovs_port:
data += "DEVICETYPE=ovs\n"
- if interface.bridge_name:
- data += "TYPE=OVSPort\n"
- data += "OVS_BRIDGE=%s\n" % interface.bridge_name
- if interface.type == 'ovs_bridge':
+ if base_opt.bridge_name:
+ if isinstance(base_opt, objects.Vlan):
+ data += "TYPE=OVSIntPort\n"
+ data += "OVS_BRIDGE=%s\n" % base_opt.bridge_name
+ data += "OVS_OPTIONS=\"tag=%s\"\n" % base_opt.vlan_id
+ data += "OVS_EXTRA=\"set Interface $DEVICE "
+ data += "external-ids:iface-id=$(hostname -s)"
+ data += "-$DEVICE-vif\"\n"
+ else:
+ data += "TYPE=OVSPort\n"
+ data += "OVS_BRIDGE=%s\n" % base_opt.bridge_name
+ if isinstance(base_opt, objects.OvsBridge):
data += "DEVICETYPE=ovs\n"
data += "TYPE=OVSBridge\n"
- if interface.use_dhcp:
+ if base_opt.use_dhcp:
data += "OVSBOOTPROTO=dhcp\n"
- if interface.members:
- members = [member.name for member in interface.members]
+ if base_opt.members:
+ members = [member.name for member in base_opt.members]
data += ("OVSDHCPINTERFACES=%s\n" % " ".join(members))
else:
- if interface.use_dhcp:
+ if base_opt.use_dhcp:
data += "BOOTPROTO=dhcp\n"
- elif not interface.addresses:
+ elif not base_opt.addresses:
data += "BOOTPROTO=none\n"
- if interface.mtu != 1500:
- data += "MTU=%i\n" % interface.mtu
- if interface.use_dhcpv6 or interface.v6_addresses():
+ if base_opt.mtu != 1500:
+ data += "MTU=%i\n" % base_opt.mtu
+ if base_opt.use_dhcpv6 or base_opt.v6_addresses():
data += "IPV6INIT=yes\n"
- if interface.mtu != 1500:
- data += "IPV6_MTU=%i\n" % interface.mtu
- if interface.use_dhcpv6:
+ if base_opt.mtu != 1500:
+ data += "IPV6_MTU=%i\n" % base_opt.mtu
+ if base_opt.use_dhcpv6:
data += "DHCPV6C=yes\n"
- elif interface.addresses:
- #TODO(dprince): support multiple addresses for each type
- v4_addresses = interface.v4_addresses()
+ elif base_opt.addresses:
+ #TODO(dprince): Do we want to support multiple addresses?
+ v4_addresses = base_opt.v4_addresses()
if v4_addresses:
first_v4 = v4_addresses[0]
data += "BOOTPROTO=static\n"
data += "IPADDR=%s\n" % first_v4.ip
data += "NETMASK=%s\n" % first_v4.netmask
- v6_addresses = interface.v6_addresses()
+ v6_addresses = base_opt.v6_addresses()
if v6_addresses:
first_v6 = v6_addresses[0]
data += "IPV6_AUTOCONF=no\n"
data += "IPV6ADDR=%s\n" % first_v6.ip
-
return data
def addInterface(self, interface):
data = self._addCommon(interface)
-
self.interfaces[interface.name] = data
if interface.routes:
self._addRoutes(interface.name, interface.routes)
+ def addVlan(self, vlan):
+ data = self._addCommon(vlan)
+ self.interfaces[vlan.name] = data
+ if vlan.routes:
+ self._addRoutes(vlan.name, vlan.routes)
+
def addBridge(self, bridge):
data = self._addCommon(bridge)
-
self.bridges[bridge.name] = data
if bridge.routes:
self._addRoutes(bridge.name, bridge.routes)
- if bridge.routes:
- self._addRoutes(bridge.name, bridge.routes)
def _addRoutes(self, interface_name, routes=[]):
data = ""
diff --git a/os_net_config/objects.py b/os_net_config/objects.py
index c4f5600..81f441b 100644
--- a/os_net_config/objects.py
+++ b/os_net_config/objects.py
@@ -52,7 +52,7 @@ class _BaseOpts(object):
self.addresses = addresses
self.routes = routes
self.bridge_name = None
- self.type = None
+ self.ovs_port = False
def v4_addresses(self):
v4_addresses = []
@@ -80,6 +80,22 @@ class Interface(_BaseOpts):
routes, mtu)
+class Vlan(_BaseOpts):
+ """Base class for VLANs.
+
+ NOTE: the name parameter must be formated w/ vlan#### where ####
+ matches the vlan ID being used. Example: vlan5
+ """
+
+ def __init__(self, device, vlan_id, use_dhcp=False, use_dhcpv6=False,
+ addresses=[], routes=[], mtu=1500):
+ name = 'vlan%i' % vlan_id
+ super(Vlan, self).__init__(name, use_dhcp, use_dhcpv6, addresses,
+ routes, mtu)
+ self.vlan_id = int(vlan_id)
+ self.device = device
+
+
class OvsBridge(_BaseOpts):
"""Base class for OVS bridges."""
@@ -87,8 +103,7 @@ class OvsBridge(_BaseOpts):
routes=[], members=[], mtu=1500):
super(OvsBridge, self).__init__(name, use_dhcp, use_dhcpv6, addresses,
routes, mtu)
- self.type = 'ovs_bridge'
self.members = members
for member in self.members:
member.bridge_name = name
- member.type = 'ovs_port'
+ member.ovs_port = True
diff --git a/os_net_config/tests/test_impl_eni.py b/os_net_config/tests/test_impl_eni.py
index ff4f827..55c9c44 100644
--- a/os_net_config/tests/test_impl_eni.py
+++ b/os_net_config/tests/test_impl_eni.py
@@ -82,7 +82,7 @@ class TestENINetConfig(base.TestCase):
def test_add_ovs_port_interface(self):
interface = self._default_interface()
- interface.type = 'ovs_port'
+ interface.ovs_port = True
interface.bridge_name = 'br0'
interface.use_dhcp = True
self.provider.addInterface(interface)
diff --git a/os_net_config/tests/test_impl_ifcfg.py b/os_net_config/tests/test_impl_ifcfg.py
index e0df5b4..1c64abb 100644
--- a/os_net_config/tests/test_impl_ifcfg.py
+++ b/os_net_config/tests/test_impl_ifcfg.py
@@ -63,6 +63,27 @@ OVSBOOTPROTO=dhcp
OVSDHCPINTERFACES=em1
"""
+_BASE_VLAN = """DEVICE=vlan5
+ONBOOT=yes
+HOTPLUG=no
+VLAN=yes
+PHYSDEV=em1
+"""
+
+_VLAN_NO_IP = _BASE_VLAN + "BOOTPROTO=none\n"
+
+
+_VLAN_OVS = _BASE_VLAN + "DEVICETYPE=ovs\nBOOTPROTO=none\n"
+
+
+VLAN_EXTRA = "\"set Interface $DEVICE external-ids:iface-id=$(hostname -s" + \
+ ")-$DEVICE-vif\"\n"
+_VLAN_OVS_BRIDGE = _BASE_VLAN + """DEVICETYPE=ovs
+TYPE=OVSIntPort
+OVS_BRIDGE=br-ctlplane
+OVS_OPTIONS="tag=5"
+OVS_EXTRA=""" + VLAN_EXTRA + "BOOTPROTO=none\n"
+
class TestIfcfgNetConfig(base.TestCase):
@@ -74,8 +95,8 @@ class TestIfcfgNetConfig(base.TestCase):
def tearDown(self):
super(TestIfcfgNetConfig, self).tearDown()
- def get_interface_config(self):
- return self.provider.interfaces['em1']
+ def get_interface_config(self, name='em1'):
+ return self.provider.interfaces[name]
def get_route_config(self):
return self.provider.routes['em1']
@@ -87,7 +108,7 @@ class TestIfcfgNetConfig(base.TestCase):
def test_add_ovs_interface(self):
interface = objects.Interface('em1')
- interface.type = 'ovs_port'
+ interface.ovs_port = True
self.provider.addInterface(interface)
self.assertEqual(_OVS_IFCFG, self.get_interface_config())
@@ -122,6 +143,25 @@ class TestIfcfgNetConfig(base.TestCase):
self.assertEqual(_OVS_BRIDGE_DHCP,
self.provider.bridges['br-ctlplane'])
+ def test_add_vlan(self):
+ vlan = objects.Vlan('em1', 5)
+ self.provider.addVlan(vlan)
+ self.assertEqual(_VLAN_NO_IP, self.get_interface_config('vlan5'))
+
+ def test_add_vlan_ovs(self):
+ vlan = objects.Vlan('em1', 5)
+ vlan.ovs_port = True
+ self.provider.addVlan(vlan)
+ self.assertEqual(_VLAN_OVS, self.get_interface_config('vlan5'))
+
+ def test_add_ovs_bridge_with_vlan(self):
+ vlan = objects.Vlan('em1', 5)
+ bridge = objects.OvsBridge('br-ctlplane', use_dhcp=True,
+ members=[vlan])
+ self.provider.addVlan(vlan)
+ self.provider.addBridge(bridge)
+ self.assertEqual(_VLAN_OVS_BRIDGE, self.get_interface_config('vlan5'))
+
class TestIfcfgNetConfigApply(base.TestCase):
@@ -182,3 +222,11 @@ class TestIfcfgNetConfigApply(base.TestCase):
self.assertEqual(_OVS_INTERFACE, ifcfg_data)
bridge_data = utils.get_file_data(self.temp_bridge_file.name)
self.assertEqual(_OVS_BRIDGE_DHCP, bridge_data)
+
+ def test_vlan_apply(self):
+ vlan = objects.Vlan('em1', 5)
+ self.provider.addVlan(vlan)
+ self.provider.apply()
+
+ ifcfg_data = utils.get_file_data(self.temp_ifcfg_file.name)
+ self.assertEqual(_VLAN_NO_IP, ifcfg_data)