]> review.fuel-infra Code Review - openstack-build/neutron-build.git/commitdiff
Configure agents using neutron.common.config.init (formerly .parse)
authorIhar Hrachyshka <ihrachys@redhat.com>
Tue, 3 Jun 2014 10:39:17 +0000 (12:39 +0200)
committerIhar Hrachyshka <ihrachys@redhat.com>
Tue, 17 Jun 2014 19:56:24 +0000 (21:56 +0200)
After oslo.messaging port is done, we'll need to initialize RPC layer
from all RPC agents. We'll put initialization into init() function, so
the first step for migration is to make agents use it.

The function is renamed to be explicit about the fact that we don't just
parse configuration by calling it, but also do other common
initializations, like setting RPC layer.

blueprint oslo-messaging

Change-Id: I71c62f270ac7a1ff1426a3f49a32133b65580e35

29 files changed:
neutron/agent/dhcp_agent.py
neutron/agent/l3_agent.py
neutron/agent/metadata/agent.py
neutron/cmd/sanity_check.py
neutron/cmd/usage_audit.py
neutron/common/config.py
neutron/plugins/bigswitch/agent/restproxy_agent.py
neutron/plugins/hyperv/agent/hyperv_neutron_agent.py
neutron/plugins/ibm/agent/sdnve_neutron_agent.py
neutron/plugins/linuxbridge/agent/linuxbridge_neutron_agent.py
neutron/plugins/mlnx/agent/eswitch_neutron_agent.py
neutron/plugins/nec/agent/nec_neutron_agent.py
neutron/plugins/oneconvergence/agent/nvsd_neutron_agent.py
neutron/plugins/openvswitch/agent/ovs_neutron_agent.py
neutron/plugins/ryu/agent/ryu_neutron_agent.py
neutron/plugins/vmware/check_nsx_config.py
neutron/server/__init__.py
neutron/services/firewall/agents/varmour/varmour_router.py
neutron/services/loadbalancer/agent/agent.py
neutron/services/metering/agents/metering_agent.py
neutron/tests/base.py
neutron/tests/unit/bigswitch/test_restproxy_agent.py
neutron/tests/unit/hyperv/test_hyperv_neutron_agent.py
neutron/tests/unit/ml2/drivers/cisco/apic/test_cisco_apic_common.py
neutron/tests/unit/nec/test_nec_agent.py
neutron/tests/unit/oneconvergence/test_nvsd_agent.py
neutron/tests/unit/ryu/test_ryu_agent.py
neutron/tests/unit/test_debug_commands.py
neutron/tests/unit/test_dhcp_agent.py

index 4b62e0dd85d5d625301248dae3242fd2008291eb..5cdb30d0e6a8a8041f9e0bbf11da4a40afb9cea8 100644 (file)
@@ -16,6 +16,7 @@
 #    under the License.
 
 import os
+import sys
 
 import eventlet
 eventlet.monkey_patch()
@@ -29,6 +30,7 @@ from neutron.agent.linux import external_process
 from neutron.agent.linux import interface
 from neutron.agent.linux import ovs_lib  # noqa
 from neutron.agent import rpc as agent_rpc
+from neutron.common import config as common_config
 from neutron.common import constants
 from neutron.common import exceptions
 from neutron.common import rpc_compat
@@ -610,7 +612,7 @@ def register_options():
 
 def main():
     register_options()
-    cfg.CONF(project='neutron')
+    common_config.init(sys.argv[1:])
     config.setup_logging(cfg.CONF)
     server = neutron_service.Service.create(
         binary='neutron-dhcp-agent',
index 7b3df470ed86ce3947ce80e653987e934c4e6407..7dcb81e3b40fd6fbf03ff724ba9e89b47986a6ac 100644 (file)
@@ -13,6 +13,8 @@
 #    under the License.
 #
 
+import sys
+
 import eventlet
 eventlet.monkey_patch()
 
@@ -26,6 +28,7 @@ from neutron.agent.linux import ip_lib
 from neutron.agent.linux import iptables_manager
 from neutron.agent.linux import ovs_lib  # noqa
 from neutron.agent import rpc as agent_rpc
+from neutron.common import config as common_config
 from neutron.common import constants as l3_constants
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -977,7 +980,7 @@ def main(manager='neutron.agent.l3_agent.L3NATAgentWithStateReport'):
     config.register_root_helper(conf)
     conf.register_opts(interface.OPTS)
     conf.register_opts(external_process.OPTS)
-    conf(project='neutron')
+    common_config.init(sys.argv[1:])
     config.setup_logging(conf)
     server = neutron_service.Service.create(
         binary='neutron-l3-agent',
index c38e4fe4bfb119eaafb0b0638151e7a51b2cf2ed..52ffa91210272093c1b6bceb47243250f3c7830c 100644 (file)
@@ -20,6 +20,7 @@ import hashlib
 import hmac
 import os
 import socket
+import sys
 
 import eventlet
 eventlet.monkey_patch()
@@ -384,7 +385,7 @@ def main():
     cache.register_oslo_configs(cfg.CONF)
     cfg.CONF.set_default(name='cache_url', default='memory://?default_ttl=5')
     agent_conf.register_agent_state_opts_helper(cfg.CONF)
-    cfg.CONF(project='neutron')
+    config.init(sys.argv[1:])
     config.setup_logging(cfg.CONF)
     utils.log_opt_values(LOG)
     proxy = UnixDomainMetadataProxy(cfg.CONF)
index aab8d96c07f396af45624807e161dc6e313d1052..b068fcb00b2f0dbe122a93efe590e1512750f6ba 100644 (file)
@@ -85,7 +85,7 @@ def main():
     cfg.CONF.register_cli_opts(OPTS)
     cfg.CONF.set_override('use_stderr', True)
     config.setup_logging(cfg.CONF)
-    config.parse(sys.argv[1:], default_config_files=[])
+    config.init(sys.argv[1:], default_config_files=[])
 
     if cfg.CONF.config_file:
         enable_tests_from_config()
index 01e77c77a23b1a577f6eb5cd27f2d8561796bea4..f48e0c691c3864d6e83c6613cc386a1b2669e5cc 100644 (file)
@@ -21,6 +21,8 @@ subnets.
 
 """
 
+import sys
+
 from oslo.config import cfg
 
 from neutron.common import config
@@ -30,7 +32,7 @@ from neutron.openstack.common.notifier import api as notifier_api
 
 
 def main():
-    cfg.CONF(project='neutron')
+    config.init(sys.argv[1:])
     config.setup_logging(cfg.CONF)
 
     cxt = context.get_admin_context()
index 1340ef2aede695086dc32f02f4fc0e95de0f6428..a7b7a9559474724fda84d5f3aab1a43e908340fc 100644 (file)
@@ -134,7 +134,7 @@ db_options.set_defaults(sql_connection=_SQL_CONNECTION_DEFAULT,
                         max_overflow=20, pool_timeout=10)
 
 
-def parse(args, **kwargs):
+def init(args, **kwargs):
     cfg.CONF(args=args, project='neutron',
              version='%%prog %s' % version.version_info.release_string(),
              **kwargs)
index 7b95f3554d3ce27426ed42c1154a8b12aed7fe7a..a9c1e6653a74cc5b52ff1527f5177ae0002b19fb 100644 (file)
@@ -166,7 +166,7 @@ class RestProxyAgent(rpc_compat.RpcCallback,
 
 
 def main():
-    cfg.CONF(project='neutron')
+    config.init(sys.argv[1:])
     config.setup_logging(cfg.CONF)
     pl_config.register_config()
 
index df9673cd77911c9cd376edb63e6a94ee4747379e..34473562570d2ca76f4c3ec86d3a5301fff3de7c 100644 (file)
@@ -20,6 +20,7 @@
 
 import platform
 import re
+import sys
 import time
 
 import eventlet
@@ -30,7 +31,7 @@ from oslo.config import cfg
 from neutron.agent.common import config
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import constants as n_const
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -472,8 +473,8 @@ class HyperVNeutronAgent(rpc_compat.RpcCallback):
 
 
 def main():
-    cfg.CONF(project='neutron')
-    logging_config.setup_logging(cfg.CONF)
+    common_config.init(sys.argv[1:])
+    common_config.setup_logging(cfg.CONF)
 
     plugin = HyperVNeutronAgent()
 
index e4f296fc4c78db8d38108338271a2a80eabe430d..1a5190d90e49d7d2c090a4ef2278abb732cf7be8 100644 (file)
@@ -18,6 +18,7 @@
 
 
 import socket
+import sys
 import time
 
 import eventlet
@@ -28,7 +29,7 @@ from oslo.config import cfg
 from neutron.agent.linux import ip_lib
 from neutron.agent.linux import ovs_lib
 from neutron.agent import rpc as agent_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import constants as n_const
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -257,8 +258,8 @@ def create_agent_config_map(config):
 
 def main():
     cfg.CONF.register_opts(ip_lib.OPTS)
-    cfg.CONF(project='neutron')
-    logging_config.setup_logging(cfg.CONF)
+    common_config.init(sys.argv[1:])
+    common_config.setup_logging(cfg.CONF)
 
     try:
         agent_config = create_agent_config_map(cfg.CONF)
index 06357a493ba193d4f49007c85c0c68fd0949d4f0..d586b2eb9e94d0554aff30575b7cf2f0ecb49d3d 100755 (executable)
@@ -36,7 +36,7 @@ from neutron.agent.linux import ip_lib
 from neutron.agent.linux import utils
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import constants
 from neutron.common import exceptions
 from neutron.common import rpc_compat
@@ -1029,9 +1029,9 @@ class LinuxBridgeNeutronAgentRPC(sg_rpc.SecurityGroupAgentRpcMixin):
 
 
 def main():
-    cfg.CONF(project='neutron')
+    common_config.init(sys.argv[1:])
 
-    logging_config.setup_logging(cfg.CONF)
+    common_config.setup_logging(cfg.CONF)
     try:
         interface_mappings = q_utils.parse_mappings(
             cfg.CONF.LINUX_BRIDGE.physical_interface_mappings)
index 56366724d9cf3631316573ec09027524f4f85f8b..90a97ce443f461bbe9a5abbbf51752953d6f0d97 100644 (file)
@@ -27,7 +27,7 @@ from oslo.config import cfg
 
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import constants as q_constants
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -421,8 +421,8 @@ class MlnxEswitchNeutronAgent(sg_rpc.SecurityGroupAgentRpcMixin):
 
 
 def main():
-    cfg.CONF(project='neutron')
-    logging_config.setup_logging(cfg.CONF)
+    common_config.init(sys.argv[1:])
+    common_config.setup_logging(cfg.CONF)
 
     try:
         interface_mappings = q_utils.parse_mappings(
index 5a5faff7f969af148b8cb4e5f30dd176647ec13e..38b13b5b7c377a1a59c4f4286a1ad3ddf92bb138 100755 (executable)
@@ -21,6 +21,7 @@
 # @author: Akihiro MOTOKI
 
 import socket
+import sys
 import time
 
 import eventlet
@@ -29,7 +30,7 @@ eventlet.monkey_patch()
 from neutron.agent.linux import ovs_lib
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import constants as q_const
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -234,9 +235,9 @@ class NECNeutronAgent(object):
 
 
 def main():
-    config.CONF(project='neutron')
+    common_config.init(sys.argv[1:])
 
-    logging_config.setup_logging(config.CONF)
+    common_config.setup_logging(config.CONF)
 
     # Determine which agent type to use.
     integ_br = config.OVS.integration_bridge
index d291df508d8da3e10aab1e386922e335f91c6175..d1d3daf6efdf941a52bdae4f21ce47ce599b478b 100644 (file)
@@ -17,6 +17,7 @@
 """NVSD agent code for security group events."""
 
 import socket
+import sys
 import time
 
 import eventlet
@@ -25,7 +26,7 @@ eventlet.monkey_patch()
 from neutron.agent.linux import ovs_lib
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import rpc_compat
 from neutron.common import topics
 from neutron import context as n_context
@@ -164,8 +165,8 @@ class NVSDNeutronAgent(rpc_compat.RpcCallback):
 
 
 def main():
-    config.CONF(project='neutron')
-    logging_config.setup_logging(config.CONF)
+    common_config.init(sys.argv[1:])
+    common_config.setup_logging(config.CONF)
 
     integ_br = config.AGENT.integration_bridge
     root_helper = config.AGENT.root_helper
index 3ee1e4278d0d217604b97613a4df938dcb43419c..c44fd191d5a8c4f9e2d7f13d5ef1622695978db7 100644 (file)
@@ -33,7 +33,7 @@ from neutron.agent.linux import polling
 from neutron.agent.linux import utils
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import constants as q_const
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -1502,8 +1502,8 @@ def create_agent_config_map(config):
 
 def main():
     cfg.CONF.register_opts(ip_lib.OPTS)
-    cfg.CONF(project='neutron')
-    logging_config.setup_logging(cfg.CONF)
+    common_config.init(sys.argv[1:])
+    common_config.setup_logging(cfg.CONF)
     q_utils.log_opt_values(LOG)
 
     try:
index 092dc8702e526d4adbbb3b994ffdf51a6065f330..746a0c2f54cd131a337863c59db8c9ba043dd060 100755 (executable)
@@ -35,7 +35,7 @@ from neutron.agent.linux import ip_lib
 from neutron.agent.linux import ovs_lib
 from neutron.agent import rpc as agent_rpc
 from neutron.agent import securitygroups_rpc as sg_rpc
-from neutron.common import config as logging_config
+from neutron.common import config as common_config
 from neutron.common import exceptions as n_exc
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -286,9 +286,9 @@ class OVSNeutronOFPRyuAgent(rpc_compat.RpcCallback,
 
 
 def main():
-    cfg.CONF(project='neutron')
+    common_config.init(sys.argv[1:])
 
-    logging_config.setup_logging(cfg.CONF)
+    common_config.setup_logging(cfg.CONF)
 
     integ_br = cfg.CONF.OVS.integration_bridge
     polling_interval = cfg.CONF.AGENT.polling_interval
index 4fdcdc7ecdae07f0d6d983f4e27077c063b76ae9..14eca41cb322316d1bb2b6a243c72d504c660891 100644 (file)
@@ -90,7 +90,7 @@ def main():
         help(sys.argv[0])
     args = ['--config-file']
     args.append(sys.argv[1])
-    config.parse(args)
+    config.init(args)
     print("----------------------- Database Options -----------------------")
     print("\tconnection: %s" % cfg.CONF.database.connection)
     print("\tretry_interval: %d" % cfg.CONF.database.retry_interval)
index fedefa079d8d8a0cd158149c08b298cc0004fb11..eb34ad8510b8a5bd489d53dedc97e42d4e5cacf4 100755 (executable)
@@ -37,7 +37,7 @@ LOG = logging.getLogger(__name__)
 
 def main():
     # the configuration will be read into the cfg.CONF global data structure
-    config.parse(sys.argv[1:])
+    config.init(sys.argv[1:])
     if not cfg.CONF.config_file:
         sys.exit(_("ERROR: Unable to find configuration file via the default"
                    " search paths (~/.neutron/, ~/, /etc/neutron/, /etc/) and"
index 881127b151d21f5c120af9781b0cec228b519d35..952a452b1dab363854b074e02d868d5861b9b8b9 100755 (executable)
@@ -18,6 +18,8 @@
 # @author: Gary Duan, vArmour Networks Inc.
 #
 
+import sys
+
 import eventlet
 eventlet.monkey_patch()
 
@@ -29,6 +31,7 @@ from neutron.agent import l3_agent
 from neutron.agent.linux import external_process
 from neutron.agent.linux import interface
 from neutron.agent.linux import ip_lib
+from neutron.common import config as common_config
 from neutron.common import constants as l3_constants
 from neutron.common import topics
 from neutron.openstack.common import log as logging
@@ -337,7 +340,7 @@ def main():
     config.register_root_helper(conf)
     conf.register_opts(interface.OPTS)
     conf.register_opts(external_process.OPTS)
-    conf(project='neutron')
+    common_config.init(sys.argv[1:])
     config.setup_logging(conf)
     server = neutron_service.Service.create(
         binary='neutron-l3-agent',
index 7a830c63150b6508cb71eb1a77aa9f899f61f0e6..84de61b131a0e3ec4efda6f287f366d24ed8b645 100644 (file)
@@ -16,6 +16,8 @@
 #
 # @author: Mark McClain, DreamHost
 
+import sys
+
 import eventlet
 eventlet.monkey_patch()
 
@@ -23,6 +25,7 @@ from oslo.config import cfg
 
 from neutron.agent.common import config
 from neutron.agent.linux import interface
+from neutron.common import config as common_config
 from neutron.common import rpc_compat
 from neutron.common import topics
 from neutron.openstack.common import service
@@ -57,7 +60,7 @@ def main():
     config.register_agent_state_opts_helper(cfg.CONF)
     config.register_root_helper(cfg.CONF)
 
-    cfg.CONF(project='neutron')
+    common_config.init(sys.argv[1:])
     config.setup_logging(cfg.CONF)
 
     mgr = manager.LbaasAgentManager(cfg.CONF)
index d1bd3c965da1509d0f4324468502243dac424e85..ba1fe6bac231e78a55cb4b0dce1ad213ed4e9dbd 100644 (file)
@@ -14,6 +14,7 @@
 # License for the specific language governing permissions and limitations
 # under the License.
 
+import sys
 import time
 
 import eventlet
@@ -23,6 +24,7 @@ from oslo.config import cfg
 
 from neutron.agent.common import config
 from neutron.agent import rpc as agent_rpc
+from neutron.common import config as common_config
 from neutron.common import constants as constants
 from neutron.common import rpc_compat
 from neutron.common import topics
@@ -287,7 +289,7 @@ def main():
     conf.register_opts(MeteringAgent.Opts)
     config.register_agent_state_opts_helper(conf)
     config.register_root_helper(conf)
-    conf(project='neutron')
+    common_config.init(sys.argv[1:])
     config.setup_logging(conf)
     server = neutron_service.Service.create(
         binary='neutron-metering-agent',
index eb1611af843bbefcb2d09e9bdf82789255847935..87412f92444445cc5160bda75ca2786a1e00eba7 100644 (file)
@@ -109,7 +109,7 @@ class BaseTestCase(testtools.TestCase):
         if args is None:
             args = ['--config-file', etcdir('neutron.conf.test')]
         if conf is None:
-            config.parse(args=args)
+            config.init(args=args)
         else:
             conf(args)
 
index 258ab1a0a82d6e960743b21ed6491df04ecacde0..4c961df7df62d490a2deedb522d44247ceab76c0 100644 (file)
@@ -166,9 +166,10 @@ class TestRestProxyAgent(BaseAgentTestCase):
                      'CONF.AGENT.root_helper': 'helper'}
         with contextlib.nested(
             mock.patch(AGENTMOD + '.cfg', **cfg_attrs),
+            mock.patch(AGENTMOD + '.config.init'),
             mock.patch(NEUTRONCFG),
             mock.patch(PLCONFIG),
-        ) as (mock_conf, mock_log_conf, mock_pluginconf):
+        ) as (mock_conf, mock_init, mock_log_conf, mock_pluginconf):
             self.mod_agent.main()
 
         mock_log_conf.assert_has_calls([
index 8b472e8cbc952dcfbc724f91b70c0ad12583c5c5..5d2a24c0d51ab091ca67742baca391e744465e3f 100644 (file)
@@ -212,13 +212,10 @@ class TestHyperVNeutronAgent(base.BaseTestCase):
     def test_main(self):
         with mock.patch.object(hyperv_neutron_agent,
                                'HyperVNeutronAgent') as plugin:
-            with mock.patch.object(hyperv_neutron_agent.cfg, 'CONF') as cfg:
-                with mock.patch.object(
-                    hyperv_neutron_agent,
-                    'logging_config') as logging_config:
+            with mock.patch.object(hyperv_neutron_agent,
+                                   'common_config') as common_config:
+                hyperv_neutron_agent.main()
 
-                    hyperv_neutron_agent.main()
-
-                    self.assertTrue(cfg.called)
-                    self.assertTrue(logging_config.setup_logging.called)
-                    plugin.assert_has_calls([mock.call().daemon_loop()])
+                self.assertTrue(common_config.init.called)
+                self.assertTrue(common_config.setup_logging.called)
+                plugin.assert_has_calls([mock.call().daemon_loop()])
index 7a8f8e9d5913708f8cf86abfff1e3fe9ad7a3849..e150c1f093010c8350fdb7e1fa5e1d225a223c80 100644 (file)
@@ -170,7 +170,7 @@ class ConfigMixin(object):
     def set_up_mocks(self):
         # Mock the configuration file
         args = ['--config-file', base.etcdir('neutron.conf.test')]
-        neutron_config.parse(args=args)
+        neutron_config.init(args=args)
 
         # Configure the ML2 mechanism drivers and network types
         ml2_opts = {
index 16e4031c57f04754fc2e5ce2527d099be79fd15d..26396aeb9a662460b38651fd6ad83460bcfb987c 100644 (file)
@@ -350,16 +350,16 @@ class TestNecAgentMain(base.BaseTestCase):
     def test_main(self):
         with contextlib.nested(
             mock.patch.object(nec_neutron_agent, 'NECNeutronAgent'),
-            mock.patch.object(nec_neutron_agent, 'logging_config'),
+            mock.patch.object(nec_neutron_agent, 'common_config'),
             mock.patch.object(nec_neutron_agent, 'config')
-        ) as (agent, logging_config, cfg):
+        ) as (agent, common_config, cfg):
             cfg.OVS.integration_bridge = 'br-int-x'
             cfg.AGENT.root_helper = 'dummy-helper'
             cfg.AGENT.polling_interval = 10
 
             nec_neutron_agent.main()
 
-            self.assertTrue(logging_config.setup_logging.called)
+            self.assertTrue(common_config.setup_logging.called)
             agent.assert_has_calls([
                 mock.call('br-int-x', 'dummy-helper', 10),
                 mock.call().daemon_loop()
index 1a98c1274cdaa5f22a1271cdcad8a75575db0aae..f04d2fecb11bc14a1b30d27f16779aa3c9dc33e4 100644 (file)
@@ -161,16 +161,16 @@ class TestOneConvergenceAgentMain(base.BaseTestCase):
     def test_main(self):
         with contextlib.nested(
             mock.patch.object(nvsd_neutron_agent, 'NVSDNeutronAgent'),
-            mock.patch.object(nvsd_neutron_agent, 'logging_config'),
+            mock.patch.object(nvsd_neutron_agent, 'common_config'),
             mock.patch.object(nvsd_neutron_agent, 'config')
-        ) as (agent, logging_config, config):
+        ) as (agent, common_config, config):
             config.AGENT.integration_bridge = 'br-int-dummy'
             config.AGENT.root_helper = 'root-helper'
             config.AGENT.polling_interval = 5
 
             nvsd_neutron_agent.main()
 
-            self.assertTrue(logging_config.setup_logging.called)
+            self.assertTrue(common_config.setup_logging.called)
             agent.assert_has_calls([
                 mock.call('br-int-dummy', 'root-helper', 5),
                 mock.call().daemon_loop()
index 415e90135cf299c80f756530778488e5eec98cd1..756b39d0459b5a7bb03d163026b73bf5b861de58 100644 (file)
@@ -610,15 +610,15 @@ class TestRyuNeutronAgent(RyuAgentTestCase):
                      'CONF.AGENT.root_helper': 'helper'}
         with contextlib.nested(
             mock.patch(self._AGENT_NAME + '.cfg', **cfg_attrs),
-            mock.patch(self._AGENT_NAME + '.logging_config'),
+            mock.patch(self._AGENT_NAME + '.common_config'),
             mock.patch(self._AGENT_NAME + '._get_tunnel_ip',
                        return_value='10.0.0.1'),
             mock.patch(self._AGENT_NAME + '._get_ovsdb_ip',
                        return_value='172.16.0.1'),
-        ) as (mock_conf, mock_log_conf, _tun, _ovsdb):
+        ) as (mock_conf, mock_common_conf, _tun, _ovsdb):
             self.mod_agent.main()
 
-        mock_log_conf.assert_has_calls([
+        mock_common_conf.assert_has_calls([
             mock.call(mock_conf)
         ])
 
index 85f777356012a72cf133012d99fc718028c912ac..16b6c8dda3329bc512be772175310af0cc200c97 100644 (file)
@@ -22,6 +22,7 @@ from oslo.config import cfg
 
 from neutron.agent.common import config
 from neutron.agent.linux import interface
+from neutron.common import config as common_config
 from neutron.debug import commands
 from neutron.debug import debug_agent
 from neutron.tests import base
@@ -37,7 +38,7 @@ class TestDebugCommands(base.BaseTestCase):
         super(TestDebugCommands, self).setUp()
         cfg.CONF.register_opts(interface.OPTS)
         cfg.CONF.register_opts(debug_agent.NeutronDebugAgent.OPTS)
-        cfg.CONF(args=[], project='neutron')
+        common_config.init([])
         config.register_interface_driver_opts_helper(cfg.CONF)
         config.register_use_namespaces_opts_helper(cfg.CONF)
         config.register_root_helper(cfg.CONF)
index 0ef431838a0450db31b8d7322ad15e3ab125caab..0b0826bb9e982516279939bb73470983b0685140 100644 (file)
@@ -28,6 +28,7 @@ from neutron.agent.common import config
 from neutron.agent import dhcp_agent
 from neutron.agent.linux import dhcp
 from neutron.agent.linux import interface
+from neutron.common import config as common_config
 from neutron.common import constants as const
 from neutron.common import exceptions
 from neutron.common import rpc_compat
@@ -157,7 +158,7 @@ class TestDhcpAgent(base.BaseTestCase):
                         config.register_root_helper(cfg.CONF)
                         cfg.CONF.register_opts(dhcp.OPTS)
                         cfg.CONF.register_opts(interface.OPTS)
-                        cfg.CONF(project='neutron')
+                        common_config.init(sys.argv[1:])
                         agent_mgr = dhcp_agent.DhcpAgentWithStateReport(
                             'testhost')
                         eventlet.greenthread.sleep(1)