def heal():
+ # This is needed else the heal script will start spewing
+ # a lot of pointless warning messages from alembic.
LOG.setLevel(logging.INFO)
if context.is_offline_mode():
return
#
# @author: Sumit Naiksatam, Cisco Systems, Inc.
-import logging as LOG
from neutron.plugins.cisco.common import cisco_constants as const
from neutron.plugins.cisco.common import cisco_exceptions as cexc
from neutron.plugins.cisco.common import config
from neutron.plugins.cisco.db import network_db_v2 as cdb
-LOG.basicConfig(level=LOG.WARN)
-LOG.getLogger(const.LOGGER_COMPONENT_NAME)
-
class Store(object):
"""Credential Store."""
#
import inspect
-import logging
import sys
from neutron.api.v2 import attributes
from neutron.extensions import providernet as provider
from neutron import neutron_plugin_base_v2
from neutron.openstack.common import importutils
+from neutron.openstack.common import log as logging
from neutron.plugins.cisco.common import cisco_constants as const
from neutron.plugins.cisco.common import cisco_credentials_v2 as cred
from neutron.plugins.cisco.common import cisco_exceptions as cexc
#
# @author: Sumit Naiksatam, Cisco Systems, Inc.
-import logging
import webob.exc as wexc
from neutron.api.v2 import base
from neutron.db import db_base_plugin_v2
from neutron.openstack.common import importutils
+from neutron.openstack.common import log as logging
from neutron.plugins.cisco.common import cisco_exceptions as cexc
from neutron.plugins.cisco.common import config
from neutron.plugins.cisco.db import network_db_v2 as cdb
Implements a Nexus-OS NETCONF over SSHv2 API Client
"""
-import logging
from ncclient import manager
from neutron.openstack.common import excutils
+from neutron.openstack.common import log as logging
from neutron.plugins.cisco.common import cisco_constants as const
from neutron.plugins.cisco.common import cisco_credentials_v2 as cred
from neutron.plugins.cisco.common import cisco_exceptions as cexc
PlugIn for Nexus OS driver
"""
-import logging
from neutron.openstack.common import excutils
from neutron.openstack.common import importutils
+from neutron.openstack.common import log as logging
from neutron.plugins.cisco.common import cisco_constants as const
from neutron.plugins.cisco.common import cisco_exceptions as cisco_exc
from neutron.plugins.cisco.common import config as conf
Nexus-OS XML-based configuration snippets
"""
-import logging
-
-
-LOG = logging.getLogger(__name__)
-
# The following are standard strings, messages used to communicate with Nexus,
EXEC_CONF_SNIPPET = """
Cisco Nexus-OS XML-based configuration snippets.
"""
-import logging
-
-
-LOG = logging.getLogger(__name__)
-
# The following are standard strings, messages used to communicate with Nexus.
EXEC_CONF_SNIPPET = """
# License for the specific language governing permissions and limitations
# under the License.
-import logging
import uuid
from oslo.config import cfg
from neutron.extensions import providernet as pnet
from neutron.extensions import securitygroup as ext_sg
from neutron.openstack.common import excutils
+from neutron.openstack.common.gettextutils import _LE
from neutron.openstack.common import lockutils
+from neutron.openstack.common import log as logging
from neutron.plugins.common import constants as plugin_const
from neutron.plugins import vmware
from neutron.plugins.vmware.api_client import exception as api_exc
def _get_nsx_device_id(self, context, device_id):
return self._get_gateway_device(context, device_id)['nsx_id']
- def _rollback_gw_device(self, context, device_id,
- gw_data=None, new_status=None,
- is_create=False, log_level=logging.ERROR):
- LOG.log(log_level,
- _("Rolling back database changes for gateway device %s "
- "because of an error in the NSX backend"), device_id)
+ def _rollback_gw_device(self, context, device_id, gw_data=None,
+ new_status=None, is_create=False):
+ LOG.error(_LE("Rolling back database changes for gateway device %s "
+ "because of an error in the NSX backend"), device_id)
with context.session.begin(subtransactions=True):
query = self._model_query(
context, networkgw_db.NetworkGatewayDevice).filter(
import contextlib
import gc
-import logging
+import logging as std_logging
import os
import os.path
import sys
def setUp(self):
super(BaseTestCase, self).setUp()
-
# Ensure plugin cleanup is triggered last so that
# test-specific cleanup has a chance to release references.
self.addCleanup(self.cleanup_core_plugin)
self.addOnException(post_mortem_debug.exception_handler)
if os.environ.get('OS_DEBUG') in TRUE_STRING:
- _level = logging.DEBUG
+ _level = std_logging.DEBUG
else:
- _level = logging.INFO
+ _level = std_logging.INFO
capture_logs = os.environ.get('OS_LOG_CAPTURE') in TRUE_STRING
if not capture_logs:
- logging.basicConfig(format=LOG_FORMAT, level=_level)
+ std_logging.basicConfig(format=LOG_FORMAT, level=_level)
self.log_fixture = self.useFixture(
fixtures.FakeLogger(
format=LOG_FORMAT,
fixtures.FakeLogger(
name='neutron.api.extensions',
format=LOG_FORMAT,
- level=logging.ERROR,
+ level=std_logging.ERROR,
nuke_handlers=capture_logs,
))
import contextlib
import copy
import inspect
-import logging
+import logging as std_logging
import mock
import six
from neutron.extensions import providernet as provider
from neutron import manager
from neutron.openstack.common import gettextutils
+from neutron.openstack.common import log as logging
from neutron.plugins.cisco.common import cisco_constants as const
from neutron.plugins.cisco.common import cisco_exceptions as c_exc
from neutron.plugins.cisco.common import config as cisco_config
*args, **kwargs)
patched_plugin.side_effect = side_effect
res = self._create_network_bulk(self.fmt, 2, 'test', True)
- LOG.debug("response is %s" % res)
+ LOG.debug('response is %s', res)
# We expect an internal server error as we injected a fault
self._validate_behavior_on_bulk_failure(
res,
def _count_exception_logs(*args, **kwargs):
self.log_exc_count += 1
- mock.patch.object(logging.LoggerAdapter, 'exception',
+ mock.patch.object(std_logging.LoggerAdapter, 'exception',
autospec=True,
side_effect=_count_exception_logs,
- wraps=logging.LoggerAdapter.exception).start()
+ wraps=std_logging.LoggerAdapter.exception).start()
super(TestCiscoRouterInterfacesV2, self).setUp()
ext_mgr = extensions.PluginAwareExtensionManager.get_instance()
self.ext_api = test_extensions.setup_extensions_middleware(ext_mgr)
# @author: Sumit Naiksatam, sumitnaiksatam@gmail.com, Big Switch Networks, Inc.
import contextlib
-import logging
import mock
import webob.exc
from neutron.tests.unit import test_db_plugin
-LOG = logging.getLogger(__name__)
DB_FW_PLUGIN_KLASS = (
"neutron.db.firewall.firewall_db.Firewall_db_mixin"
)
# limitations under the License.
import contextlib
-import logging
import mock
from oslo.config import cfg
from neutron.tests.unit import test_db_plugin
-LOG = logging.getLogger(__name__)
-
DB_CORE_PLUGIN_KLASS = 'neutron.db.db_base_plugin_v2.NeutronDbPluginV2'
DB_LB_PLUGIN_KLASS = (
"neutron.services.loadbalancer."
# under the License.
import contextlib
-import logging
import webob.exc
from neutron.services.metering import metering_plugin
from neutron.tests.unit import test_db_plugin
-LOG = logging.getLogger(__name__)
-
DB_METERING_PLUGIN_KLASS = (
"neutron.services.metering."
"metering_plugin.MeteringPlugin"
# under the License.
import fixtures
-import logging
+import logging as std_logging
import mock
from sqlalchemy.orm import query
fixtures.FakeLogger(
name=helpers.__name__,
format=base.LOG_FORMAT,
- level=logging.DEBUG
+ level=std_logging.DEBUG
))
def check_raw_segment(self, expected, observed):
# @author: Salvatore Orlando, VMware
#
-import logging
-
import mock
from oslo.config import cfg
import webob.exc as webexc
from neutron.tests.unit import testlib_api
-LOG = logging.getLogger(__name__)
DEFAULT_SERVICE_DEFS = [{'service_class': constants.DUMMY,
'plugin': dp.DUMMY_PLUGIN_NAME}]
# under the License.
import httplib
-import logging
import new
import random
from eventlet.green import urllib2
import mock
+from neutron.openstack.common.gettextutils import _LI
+from neutron.openstack.common import log as logging
from neutron.plugins.vmware.api_client import eventlet_client as client
from neutron.plugins.vmware.api_client import eventlet_request as request
from neutron.tests import base
from neutron.tests.unit import vmware
-logging.basicConfig(level=logging.DEBUG)
LOG = logging.getLogger("test_api_request_eventlet")
def test_apirequest_spawn(self):
def x(id):
eventlet.greenthread.sleep(random.random())
- LOG.info('spawned: %d' % id)
+ LOG.info(_LI('spawned: %d'), id)
for i in range(10):
request.EventletApiRequest._spawn(x, i)
a._handle_request = mock.Mock()
a.start()
eventlet.greenthread.sleep(0.1)
- logging.info('_handle_request called: %s' %
- a._handle_request.called)
+ LOG.info(_LI('_handle_request called: %s'),
+ a._handle_request.called)
request.EventletApiRequest.joinall()
def test_join_with_handle_request(self):