]> review.fuel-infra Code Review - openstack-build/neutron-build.git/commitdiff
Enforce log hints in neutron.services.metering
authorCedric Brandily <zzelle@gmail.com>
Tue, 11 Nov 2014 16:11:28 +0000 (17:11 +0100)
committerRomil Gupta <romilg@hp.com>
Sat, 22 Nov 2014 17:42:58 +0000 (09:42 -0800)
This change enforces log hints use and removes debug level log
translation, modifications are validated through a hacking rule.

Validate that hacking rules apply to directories:
    - neutron/services/metering

Change-Id: Ic763e81e8b06973013115af45c7c09a3e69c673b
Partial-bug: #1320867

neutron/hacking/checks.py
neutron/services/metering/agents/metering_agent.py
neutron/services/metering/drivers/iptables/iptables_driver.py

index 9976d48312ababa4b6d6af476dfd44877fa4cfd7..3dd3f826015314929714a335a89a1d930a5459d4 100644 (file)
@@ -59,7 +59,8 @@ def _directory_to_check_translation(filename):
             "neutron/server",
             "neutron/services/firewall",
             "neutron/services/l3_router",
-            "neutron/services/loadbalancer"]
+            "neutron/services/loadbalancer",
+            "neutron/services/metering"]
     return any([dir in filename for dir in dirs])
 
 
index c860bdb93b889307e100a3a59a2c0e0f21e6a74a..d4229d5833f7d17d8012e49e19da8956e8334814 100644 (file)
@@ -29,6 +29,7 @@ from neutron.common import topics
 from neutron.common import utils
 from neutron import context
 from neutron import manager
+from neutron.openstack.common.gettextutils import _LE, _LI, _LW
 from neutron.openstack.common import importutils
 from neutron.openstack.common import log as logging
 from neutron.openstack.common import loopingcall
@@ -56,7 +57,7 @@ class MeteringPluginRpc(n_rpc.RpcProxy):
                                            host=self.host),
                              topic=topics.METERING_PLUGIN)
         except Exception:
-            LOG.exception(_("Failed synchronizing routers"))
+            LOG.exception(_LE("Failed synchronizing routers"))
 
 
 class MeteringAgent(MeteringPluginRpc, manager.Manager):
@@ -93,7 +94,7 @@ class MeteringAgent(MeteringPluginRpc, manager.Manager):
 
     def _load_drivers(self):
         """Loads plugin-driver from configuration."""
-        LOG.info(_("Loading Metering driver %s"), self.conf.driver)
+        LOG.info(_LI("Loading Metering driver %s"), self.conf.driver)
         if not self.conf.driver:
             raise SystemExit(_('A metering driver must be specified'))
         self.metering_driver = importutils.import_object(
@@ -110,7 +111,7 @@ class MeteringAgent(MeteringPluginRpc, manager.Manager):
                     'last_update': info['last_update'],
                     'host': self.host}
 
-            LOG.debug(_("Send metering report: %s"), data)
+            LOG.debug("Send metering report: %s", data)
             notifier = n_rpc.get_notifier('metering')
             notifier.info(self.context, 'l3.meter', data)
             info['pkts'] = 0
@@ -174,11 +175,11 @@ class MeteringAgent(MeteringPluginRpc, manager.Manager):
         try:
             return getattr(self.metering_driver, func_name)(context, meterings)
         except AttributeError:
-            LOG.exception(_("Driver %(driver)s does not implement %(func)s"),
+            LOG.exception(_LE("Driver %(driver)s does not implement %(func)s"),
                           {'driver': self.conf.driver,
                            'func': func_name})
         except RuntimeError:
-            LOG.exception(_("Driver %(driver)s:%(func)s runtime error"),
+            LOG.exception(_LE("Driver %(driver)s:%(func)s runtime error"),
                           {'driver': self.conf.driver,
                            'func': func_name})
 
@@ -213,23 +214,23 @@ class MeteringAgent(MeteringPluginRpc, manager.Manager):
                                    'update_routers')
 
     def _get_traffic_counters(self, context, routers):
-        LOG.debug(_("Get router traffic counters"))
+        LOG.debug("Get router traffic counters")
         return self._invoke_driver(context, routers, 'get_traffic_counters')
 
     def update_metering_label_rules(self, context, routers):
-        LOG.debug(_("Update metering rules from agent"))
+        LOG.debug("Update metering rules from agent")
         return self._invoke_driver(context, routers,
                                    'update_metering_label_rules')
 
     def add_metering_label(self, context, routers):
-        LOG.debug(_("Creating a metering label from agent"))
+        LOG.debug("Creating a metering label from agent")
         return self._invoke_driver(context, routers,
                                    'add_metering_label')
 
     def remove_metering_label(self, context, routers):
         self._add_metering_infos()
 
-        LOG.debug(_("Delete a metering label from agent"))
+        LOG.debug("Delete a metering label from agent")
         return self._invoke_driver(context, routers,
                                    'remove_metering_label')
 
@@ -267,15 +268,15 @@ class MeteringAgentWithStateReport(MeteringAgent):
             self.use_call = False
         except AttributeError:
             # This means the server does not support report_state
-            LOG.warn(_("Neutron server does not support state report."
-                       " State report for this agent will be disabled."))
+            LOG.warn(_LW("Neutron server does not support state report."
+                         " State report for this agent will be disabled."))
             self.heartbeat.stop()
             return
         except Exception:
-            LOG.exception(_("Failed reporting state!"))
+            LOG.exception(_LE("Failed reporting state!"))
 
     def agent_updated(self, context, payload):
-        LOG.info(_("agent_updated by server side %s!"), payload)
+        LOG.info(_LI("agent_updated by server side %s!"), payload)
 
 
 def main():
index 40af40f3a409d6dab71ec0e07a2f10ae27f1a22f..aed58028dcadbd195a5402c43aad5edba0abe517 100644 (file)
@@ -21,6 +21,7 @@ from neutron.agent.linux import iptables_manager
 from neutron.common import constants as constants
 from neutron.common import ipv6_utils
 from neutron.common import log
+from neutron.openstack.common.gettextutils import _LI
 from neutron.openstack.common import importutils
 from neutron.openstack.common import log as logging
 from neutron.services.metering.drivers import abstract_driver
@@ -88,7 +89,8 @@ class IptablesMeteringDriver(abstract_driver.MeteringAbstractDriver):
 
         if not self.conf.interface_driver:
             raise SystemExit(_('An interface driver must be specified'))
-        LOG.info(_("Loading interface driver %s"), self.conf.interface_driver)
+        LOG.info(_LI("Loading interface driver %s"),
+                 self.conf.interface_driver)
         self.driver = importutils.import_object(self.conf.interface_driver,
                                                 self.conf)