From 4f907b67e9a5619127febe20de2fead6136cf24d Mon Sep 17 00:00:00 2001 From: Mark McClain Date: Mon, 20 Aug 2012 10:18:01 -0400 Subject: [PATCH] Create utility to clean-up netns. Fixes bug 1035366 Adds namespace clean up utility called quantum-netns-cleanup which can be used to remove old namespaces. The --force option can be used to remove all Quantum namespaces and any remaining devices. The force option is should not be run on a live Quantum systems. It is intended for cleaning up devstack a after running unstack.sh (ideally this will be added to unstack.sh in the future). Example cmd line when cleaning up a devstack install: quantum-netns-cleanup --config-file /etc/quantum/quantum.conf \ --config-file /etc/quantum/dhcp_agent.ini --force Change-Id: I6cf153df21e83bff2cde816db12b22102d1ba698 --- bin/quantum-netns-cleanup | 20 ++ quantum/agent/linux/interface.py | 8 + quantum/agent/linux/ip_lib.py | 25 +- quantum/agent/linux/ovs_lib.py | 9 + quantum/agent/netns_cleanup_util.py | 162 ++++++++++++ .../tests/unit/openvswitch/test_ovs_lib.py | 24 +- .../tests/unit/test_agent_netns_cleanup.py | 230 ++++++++++++++++++ quantum/tests/unit/test_linux_ip_lib.py | 66 +++++ setup.py | 1 + 9 files changed, 541 insertions(+), 4 deletions(-) create mode 100755 bin/quantum-netns-cleanup create mode 100644 quantum/agent/netns_cleanup_util.py create mode 100644 quantum/tests/unit/test_agent_netns_cleanup.py diff --git a/bin/quantum-netns-cleanup b/bin/quantum-netns-cleanup new file mode 100755 index 0000000000..63995e3cda --- /dev/null +++ b/bin/quantum-netns-cleanup @@ -0,0 +1,20 @@ +#!/usr/bin/env python +# vim: tabstop=4 shiftwidth=4 softtabstop=4 + +# Copyright (c) 2012 Openstack, LLC. +# All Rights Reserved. +# +# Licensed under the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. You may obtain +# a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +# License for the specific language governing permissions and limitations +# under the License. + +from quantum.agent.netns_cleanup_util import main +main() diff --git a/quantum/agent/linux/interface.py b/quantum/agent/linux/interface.py index 7abfa696d9..a9bfdbcd39 100644 --- a/quantum/agent/linux/interface.py +++ b/quantum/agent/linux/interface.py @@ -154,6 +154,10 @@ class OVSInterfaceDriver(LinuxInterfaceDriver): bridge = ovs_lib.OVSBridge(bridge, self.conf.root_helper) bridge.delete_port(device_name) + if namespace: + ip = ip_lib.IPWrapper(self.conf.root_helper, namespace) + ip.garbage_collect_namespace() + class BridgeInterfaceDriver(LinuxInterfaceDriver): """Driver for creating bridge interfaces.""" @@ -196,6 +200,10 @@ class BridgeInterfaceDriver(LinuxInterfaceDriver): LOG.error(_("Failed unplugging interface '%s'") % device_name) + if namespace: + ip = ip_lib.IPWrapper(self.conf.root_helper, namespace) + ip.garbage_collect_namespace() + class RyuInterfaceDriver(OVSInterfaceDriver): """Driver for creating a Ryu OVS interface.""" diff --git a/quantum/agent/linux/ip_lib.py b/quantum/agent/linux/ip_lib.py index e854d636ce..cdde30a9c3 100644 --- a/quantum/agent/linux/ip_lib.py +++ b/quantum/agent/linux/ip_lib.py @@ -18,6 +18,9 @@ from quantum.agent.linux import utils from quantum.common import exceptions +LOOPBACK_DEVNAME = 'lo' + + class SubProcessBase(object): def __init__(self, root_helper=None, namespace=None): self.root_helper = root_helper @@ -62,7 +65,7 @@ class IPWrapper(SubProcessBase): def device(self, name): return IPDevice(name, self.root_helper, self.namespace) - def get_devices(self): + def get_devices(self, exclude_loopback=False): retval = [] output = self._execute('o', 'link', ('list',), self.root_helper, self.namespace) @@ -71,7 +74,12 @@ class IPWrapper(SubProcessBase): continue tokens = line.split(':', 2) if len(tokens) >= 3: - retval.append(IPDevice(tokens[1].strip(), + name = tokens[1].strip() + + if exclude_loopback and name == LOOPBACK_DEVNAME: + continue + + retval.append(IPDevice(name, self.root_helper, self.namespace)) return retval @@ -90,12 +98,23 @@ class IPWrapper(SubProcessBase): def ensure_namespace(self, name): if not self.netns.exists(name): ip = self.netns.add(name) - lo = ip.device('lo') + lo = ip.device(LOOPBACK_DEVNAME) lo.link.set_up() else: ip = IPWrapper(self.root_helper, name) return ip + def namespace_is_empty(self): + return not self.get_devices(exclude_loopback=True) + + def garbage_collect_namespace(self): + """Conditionally destroy the namespace if it is empty.""" + if self.namespace and self.netns.exists(self.namespace): + if self.namespace_is_empty(): + self.netns.delete(self.namespace) + return True + return False + def add_device_to_namespace(self, device): if self.namespace: device.link.set_netns(self.namespace) diff --git a/quantum/agent/linux/ovs_lib.py b/quantum/agent/linux/ovs_lib.py index f760e66b3d..ab3412619c 100644 --- a/quantum/agent/linux/ovs_lib.py +++ b/quantum/agent/linux/ovs_lib.py @@ -269,3 +269,12 @@ class OVSBridge: except Exception, e: LOG.info("Unable to parse regex results. Exception: %s", e) return + + +def get_bridge_for_iface(root_helper, iface): + args = ["ovs-vsctl", "--timeout=2", "iface-to-br", iface] + try: + return utils.execute(args, root_helper=root_helper).strip() + except Exception, e: + LOG.error(_("iface %s not found. Exception: %s"), iface, e) + return None diff --git a/quantum/agent/netns_cleanup_util.py b/quantum/agent/netns_cleanup_util.py new file mode 100644 index 0000000000..bdfe18b302 --- /dev/null +++ b/quantum/agent/netns_cleanup_util.py @@ -0,0 +1,162 @@ +import logging +import os +import re +import sys +import traceback + +import eventlet + +from quantum.agent import dhcp_agent +from quantum.agent import l3_agent +from quantum.agent.linux import dhcp +from quantum.agent.linux import ip_lib +from quantum.agent.linux import ovs_lib +from quantum.api.v2 import attributes +from quantum.common import config +from quantum.openstack.common import cfg +from quantum.openstack.common import importutils + +LOG = logging.getLogger(__name__) +NS_MANGLING_PATTERN = ('(%s|%s)' % (dhcp_agent.NS_PREFIX, l3_agent.NS_PREFIX) + + attributes.UUID_PATTERN) + + +class NullDelegate(object): + def __getattribute__(self, name): + def noop(*args, **kwargs): + pass + return noop + + +class FakeNetwork(object): + def __init__(self, id): + self.id = id + + +def setup_conf(): + """Setup the cfg for the clean up utility. + + Use separate setup_conf for the utility because there are many options + from the main config that do not apply during clean-up. + """ + + opts = [ + cfg.StrOpt('root_helper', default='sudo'), + cfg.StrOpt('dhcp_driver', + default='quantum.agent.linux.dhcp.Dnsmasq', + help="The driver used to manage the DHCP server."), + cfg.StrOpt('state_path', + default='.', + help='Top-level directory for maintaining dhcp state'), + cfg.BoolOpt('force', + default=False, + help='Delete the namespace by removing all devices.'), + ] + conf = cfg.CommonConfigOpts() + conf.register_opts(opts) + conf.register_opts(dhcp.OPTS) + config.setup_logging(conf) + return conf + + +def kill_dhcp(conf, namespace): + """Disable DHCP for a network if DHCP is still active.""" + network_id = namespace.replace(dhcp_agent.NS_PREFIX, '') + + null_delegate = NullDelegate() + dhcp_driver = importutils.import_object( + conf.dhcp_driver, + conf, + FakeNetwork(network_id), + conf.root_helper, + null_delegate) + + if dhcp_driver.active: + dhcp_driver.disable() + + +def eligible_for_deletion(conf, namespace, force=False): + """Determine whether a namespace is eligible for deletion. + + Eligibility is determined by having only the lo device or if force + is passed as a parameter. + """ + + # filter out namespaces without UUID as the name + if not re.match(NS_MANGLING_PATTERN, namespace): + return False + + ip = ip_lib.IPWrapper(conf.root_helper, namespace) + return force or ip.namespace_is_empty() + + +def unplug_device(conf, device): + try: + device.link.delete() + except RuntimeError: + # Maybe the device is OVS port, so try to delete + bridge_name = ovs_lib.get_bridge_for_iface(conf.root_helper, + device.name) + if bridge_name: + bridge = ovs_lib.OVSBridge(bridge_name, + conf.root_helper) + bridge.delete_port(device.name) + else: + LOG.debug(_('Unable to find bridge for device: %s') % device.name) + + +def destroy_namespace(conf, namespace, force=False): + """Destroy a given namespace. + + If force is True, then dhcp (if it exists) will be disabled and all + devices will be forcibly removed. + """ + + try: + ip = ip_lib.IPWrapper(conf.root_helper, namespace) + + if force: + kill_dhcp(conf, namespace) + # NOTE: The dhcp driver will remove the namespace if is it empty, + # so a second check is required here. + if ip.netns.exists(namespace): + for device in ip.get_devices(exclude_loopback=True): + unplug_device(conf, device) + + ip.garbage_collect_namespace() + except Exception, e: + LOG.exception(_('Error unable to destroy namespace: %s') % namespace) + + +def main(): + """Main method for cleaning up network namespaces. + + This method will make two passes checking for namespaces to delete. The + process will identify candidates, sleep, and call garbage collect. The + garbage collection will re-verify that the namespace meets the criteria for + deletion (ie it is empty). The period of sleep and the 2nd pass allow + time for the namespace state to settle, so that the check prior deletion + will re-confirm the namespace is empty. + + The utility is designed to clean-up after the forced or unexpected + termination of Quantum agents. + + The --force flag should only be used as part of the cleanup of a devstack + installation as it will blindly purge namespaces and their devices. This + option also kills any lingering DHCP instances. + """ + eventlet.monkey_patch() + + conf = setup_conf() + conf(sys.argv) + + # Identify namespaces that are candidates for deletion. + candidates = [ns for ns in + ip_lib.IPWrapper.get_namespaces(conf.root_helper) + if eligible_for_deletion(conf, ns, conf.force)] + + if candidates: + eventlet.sleep(2) + + for namespace in candidates: + destroy_namespace(conf, namespace, conf.force) diff --git a/quantum/tests/unit/openvswitch/test_ovs_lib.py b/quantum/tests/unit/openvswitch/test_ovs_lib.py index 73c6123fe3..e67eb9ba26 100644 --- a/quantum/tests/unit/openvswitch/test_ovs_lib.py +++ b/quantum/tests/unit/openvswitch/test_ovs_lib.py @@ -15,10 +15,10 @@ # under the License. # @author: Dan Wendlandt, Nicira, Inc. -import unittest import uuid import mox +import unittest2 as unittest from quantum.agent.linux import ovs_lib, utils @@ -292,3 +292,25 @@ class OVS_Lib_Test(unittest.TestCase): self.assertEqual(vif_id, '5c1321a7-c73f-4a77-95e6-9f86402e5c8f') self.assertEqual(port_name, 'dhc5c1321a7-c7') self.assertEqual(ofport, 2) + + def test_iface_to_br(self): + iface = 'tap0' + br = 'br-int' + root_helper = 'sudo' + utils.execute(["ovs-vsctl", self.TO, "iface-to-br", iface], + root_helper=root_helper).AndReturn('br-int') + + self.mox.ReplayAll() + self.assertEqual(ovs_lib.get_bridge_for_iface(root_helper, iface), br) + self.mox.VerifyAll() + + def test_iface_to_br(self): + iface = 'tap0' + br = 'br-int' + root_helper = 'sudo' + utils.execute(["ovs-vsctl", self.TO, "iface-to-br", iface], + root_helper=root_helper).AndRaise(Exception) + + self.mox.ReplayAll() + self.assertIsNone(ovs_lib.get_bridge_for_iface(root_helper, iface)) + self.mox.VerifyAll() diff --git a/quantum/tests/unit/test_agent_netns_cleanup.py b/quantum/tests/unit/test_agent_netns_cleanup.py new file mode 100644 index 0000000000..6009945e3a --- /dev/null +++ b/quantum/tests/unit/test_agent_netns_cleanup.py @@ -0,0 +1,230 @@ +import mock +import unittest2 as unittest + +from quantum.agent import netns_cleanup_util as util + + +class TestNetnsCleanup(unittest.TestCase): + def test_setup_conf(self): + conf = util.setup_conf() + self.assertFalse(conf.force) + + def test_kill_dhcp(self, dhcp_active=True): + conf = mock.Mock() + conf.root_helper = 'sudo', + conf.dhcp_driver = 'driver' + + method_to_patch = 'quantum.openstack.common.importutils.import_object' + + with mock.patch(method_to_patch) as import_object: + driver = mock.Mock() + driver.active = dhcp_active + import_object.return_value = driver + + util.kill_dhcp(conf, 'ns') + + import_object.called_once_with('driver', conf, mock.ANY, 'sudo', + mock.ANY) + + if dhcp_active: + driver.assert_has_calls([mock.call.disable()]) + else: + self.assertFalse(driver.called) + + def test_kill_dhcp_no_active(self): + self.test_kill_dhcp(False) + + def test_eligible_for_deletion_ns_not_uuid(self): + ns = 'not_a_uuid' + self.assertFalse(util.eligible_for_deletion(mock.Mock(), ns)) + + def _test_eligible_for_deletion_helper(self, prefix, force, is_empty, + expected): + ns = prefix + '6e322ac7-ab50-4f53-9cdc-d1d3c1164b6d' + conf = mock.Mock() + conf.root_helper = 'sudo' + + with mock.patch('quantum.agent.linux.ip_lib.IPWrapper') as ip_wrap: + ip_wrap.return_value.namespace_is_empty.return_value = is_empty + self.assertEqual(util.eligible_for_deletion(conf, ns, force), + expected) + + expected_calls = [mock.call('sudo', ns)] + if not force: + expected_calls.append(mock.call().namespace_is_empty()) + ip_wrap.assert_has_calls(expected_calls) + + def test_eligible_for_deletion_empty(self): + self._test_eligible_for_deletion_helper('qrouter-', False, True, True) + + def test_eligible_for_deletion_not_empty(self): + self._test_eligible_for_deletion_helper('qdhcp-', False, False, False) + + def test_eligible_for_deletion_not_empty_forced(self): + self._test_eligible_for_deletion_helper('qdhcp-', True, False, True) + + def test_unplug_device_regular_device(self): + conf = mock.Mock() + device = mock.Mock() + + util.unplug_device(conf, device) + device.assert_has_calls([mock.call.link.delete()]) + + def test_unplug_device_ovs_port(self): + conf = mock.Mock() + conf.ovs_integration_bridge = 'br-int' + conf.root_helper = 'sudo' + + device = mock.Mock() + device.name = 'tap1' + device.link.delete.side_effect = RuntimeError + + with mock.patch('quantum.agent.linux.ovs_lib.OVSBridge') as ovs_br_cls: + br_patch = mock.patch( + 'quantum.agent.linux.ovs_lib.get_bridge_for_iface') + with br_patch as mock_get_bridge_for_iface: + mock_get_bridge_for_iface.return_value = 'br-int' + ovs_bridge = mock.Mock() + ovs_br_cls.return_value = ovs_bridge + + util.unplug_device(conf, device) + + mock_get_bridge_for_iface.assert_called_once_with( + conf.root_helper, 'tap1') + ovs_br_cls.called_once_with('br-int', 'sudo') + ovs_bridge.assert_has_calls( + [mock.call.delete_port(device.name)]) + + def test_unplug_device_cannot_determine_bridge_port(self): + conf = mock.Mock() + conf.ovs_integration_bridge = 'br-int' + conf.root_helper = 'sudo' + + device = mock.Mock() + device.name = 'tap1' + device.link.delete.side_effect = RuntimeError + + with mock.patch('quantum.agent.linux.ovs_lib.OVSBridge') as ovs_br_cls: + br_patch = mock.patch( + 'quantum.agent.linux.ovs_lib.get_bridge_for_iface') + with br_patch as mock_get_bridge_for_iface: + with mock.patch.object(util.LOG, 'debug') as debug: + mock_get_bridge_for_iface.return_value = None + ovs_bridge = mock.Mock() + ovs_br_cls.return_value = ovs_bridge + + util.unplug_device(conf, device) + + mock_get_bridge_for_iface.assert_called_once_with( + conf.root_helper, 'tap1') + self.assertEquals(ovs_br_cls.mock_calls, []) + self.assertTrue(debug.called) + + def _test_destroy_namespace_helper(self, force, num_devices): + ns = 'qrouter-6e322ac7-ab50-4f53-9cdc-d1d3c1164b6d' + conf = mock.Mock() + conf.root_helper = 'sudo' + + lo_device = mock.Mock() + lo_device.name = 'lo' + + devices = [lo_device] + + while num_devices: + dev = mock.Mock() + dev.name = 'tap%d' % num_devices + devices.append(dev) + num_devices -= 1 + + with mock.patch('quantum.agent.linux.ip_lib.IPWrapper') as ip_wrap: + ip_wrap.return_value.get_devices.return_value = devices + ip_wrap.return_value.netns.exists.return_value = True + + with mock.patch.object(util, 'unplug_device') as unplug: + + with mock.patch.object(util, 'kill_dhcp') as kill_dhcp: + util.destroy_namespace(conf, ns, force) + expected = [mock.call('sudo', ns)] + + if force: + expected.extend([ + mock.call().netns.exists(ns), + mock.call().get_devices(exclude_loopback=True)]) + self.assertTrue(kill_dhcp.called) + unplug.assert_has_calls( + [mock.call(conf, d) for d in + devices[1:]]) + + expected.append(mock.call().garbage_collect_namespace()) + ip_wrap.assert_has_calls(expected) + + def test_destory_namespace_empty(self): + self._test_destroy_namespace_helper(False, 0) + + def test_destory_namespace_not_empty(self): + self._test_destroy_namespace_helper(False, 1) + + def test_destory_namespace_not_empty_forced(self): + self._test_destroy_namespace_helper(True, 2) + + def test_main(self): + namespaces = ['ns1', 'ns2'] + with mock.patch('quantum.agent.linux.ip_lib.IPWrapper') as ip_wrap: + ip_wrap.get_namespaces.return_value = namespaces + + with mock.patch('eventlet.sleep') as eventlet_sleep: + conf = mock.Mock() + conf.root_helper = 'sudo' + conf.force = False + methods_to_mock = dict( + eligible_for_deletion=mock.DEFAULT, + destroy_namespace=mock.DEFAULT, + setup_conf=mock.DEFAULT) + + with mock.patch.multiple(util, **methods_to_mock) as mocks: + mocks['eligible_for_deletion'].return_value = True + mocks['setup_conf'].return_value = conf + util.main() + + mocks['eligible_for_deletion'].assert_has_calls( + [mock.call(conf, 'ns1', False), + mock.call(conf, 'ns2', False)]) + + mocks['destroy_namespace'].assert_has_calls( + [mock.call(conf, 'ns1', False), + mock.call(conf, 'ns2', False)]) + + ip_wrap.assert_has_calls( + [mock.call.get_namespaces('sudo')]) + + eventlet_sleep.assert_called_once_with(2) + + def test_main_no_candidates(self): + namespaces = ['ns1', 'ns2'] + with mock.patch('quantum.agent.linux.ip_lib.IPWrapper') as ip_wrap: + ip_wrap.get_namespaces.return_value = namespaces + + with mock.patch('eventlet.sleep') as eventlet_sleep: + conf = mock.Mock() + conf.root_helper = 'sudo' + conf.force = False + methods_to_mock = dict( + eligible_for_deletion=mock.DEFAULT, + destroy_namespace=mock.DEFAULT, + setup_conf=mock.DEFAULT) + + with mock.patch.multiple(util, **methods_to_mock) as mocks: + mocks['eligible_for_deletion'].return_value = False + mocks['setup_conf'].return_value = conf + util.main() + + ip_wrap.assert_has_calls( + [mock.call.get_namespaces('sudo')]) + + mocks['eligible_for_deletion'].assert_has_calls( + [mock.call(conf, 'ns1', False), + mock.call(conf, 'ns2', False)]) + + self.assertFalse(mocks['destroy_namespace'].called) + + self.assertFalse(eventlet_sleep.called) diff --git a/quantum/tests/unit/test_linux_ip_lib.py b/quantum/tests/unit/test_linux_ip_lib.py index 73397561c1..18958b6fa6 100644 --- a/quantum/tests/unit/test_linux_ip_lib.py +++ b/quantum/tests/unit/test_linux_ip_lib.py @@ -206,6 +206,72 @@ class TestIpWrapper(unittest.TestCase): self.assertFalse(self.execute.called) self.assertEqual(ns.namespace, 'ns') + def test_namespace_is_empty_no_devices(self): + ip = ip_lib.IPWrapper('sudo', 'ns') + with mock.patch.object(ip, 'get_devices') as get_devices: + get_devices.return_value = [] + + self.assertTrue(ip.namespace_is_empty()) + get_devices.assert_called_once_with(exclude_loopback=True) + + def test_namespace_is_empty(self): + ip = ip_lib.IPWrapper('sudo', 'ns') + with mock.patch.object(ip, 'get_devices') as get_devices: + get_devices.return_value = [mock.Mock()] + + self.assertFalse(ip.namespace_is_empty()) + get_devices.assert_called_once_with(exclude_loopback=True) + + def test_garbage_collect_namespace_does_not_exist(self): + with mock.patch.object(ip_lib, 'IpNetnsCommand') as ip_ns_cmd_cls: + ip_ns_cmd_cls.return_value.exists.return_value = False + ip = ip_lib.IPWrapper('sudo', 'ns') + with mock.patch.object(ip, 'namespace_is_empty') as mock_is_empty: + + self.assertFalse(ip.garbage_collect_namespace()) + ip_ns_cmd_cls.assert_has_calls([mock.call().exists('ns')]) + self.assertNotIn(mock.call().delete('ns'), + ip_ns_cmd_cls.return_value.mock_calls) + self.assertEqual(mock_is_empty.mock_calls, []) + + def test_garbage_collect_namespace_existing_empty_ns(self): + with mock.patch.object(ip_lib, 'IpNetnsCommand') as ip_ns_cmd_cls: + ip_ns_cmd_cls.return_value.exists.return_value = True + + ip = ip_lib.IPWrapper('sudo', 'ns') + + with mock.patch.object(ip, 'namespace_is_empty') as mock_is_empty: + mock_is_empty.return_value = True + self.assertTrue(ip.garbage_collect_namespace()) + + mock_is_empty.assert_called_once_with() + expected = [mock.call().exists('ns'), + mock.call().delete('ns')] + ip_ns_cmd_cls.assert_has_calls(expected) + + def test_garbage_collect_namespace_existing_not_empty(self): + lo_device = mock.Mock() + lo_device.name = 'lo' + tap_device = mock.Mock() + tap_device.name = 'tap1' + + with mock.patch.object(ip_lib, 'IpNetnsCommand') as ip_ns_cmd_cls: + ip_ns_cmd_cls.return_value.exists.return_value = True + + ip = ip_lib.IPWrapper('sudo', 'ns') + + with mock.patch.object(ip, 'namespace_is_empty') as mock_is_empty: + mock_is_empty.return_value = False + + self.assertFalse(ip.garbage_collect_namespace()) + + mock_is_empty.assert_called_once_with() + expected = [mock.call(ip), + mock.call().exists('ns')] + self.assertEqual(ip_ns_cmd_cls.mock_calls, expected) + self.assertNotIn(mock.call().delete('ns'), + ip_ns_cmd_cls.mock_calls) + def test_add_device_to_namespace(self): dev = mock.Mock() ip_lib.IPWrapper('sudo', 'ns').add_device_to_namespace(dev) diff --git a/setup.py b/setup.py index 7abb848b84..98fcbba263 100644 --- a/setup.py +++ b/setup.py @@ -102,6 +102,7 @@ setuptools.setup( 'quantum-dhcp-agent = quantum.agent.dhcp_agent:main', 'quantum-dhcp-agent-dnsmasq-lease-update =' 'quantum.agent.linux.dhcp:Dnsmasq.lease_update', + 'quantum-netns-cleanup = quantum.agent.netns_cleanup_util:main', 'quantum-l3-agent = quantum.agent.l3_nat_agent:main', 'quantum-linuxbridge-agent =' 'quantum.plugins.linuxbridge.agent.linuxbridge_quantum_agent:main',