import os
import stat
-from oslo.concurrency import processutils
from oslo.config import cfg
+from oslo_concurrency import processutils
from cinder.backup.driver import BackupDriver
from cinder import exception
and root_helper settings, so this provides that hook.
"""
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
class Executor(object):
import socket
import time
-from oslo.concurrency import lockutils
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import lockutils
+from oslo_concurrency import processutils as putils
from cinder.brick import exception
from cinder.brick import executor
import errno
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder.brick.initiator import linuxscsi
from cinder.i18n import _LW
import os
import re
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder.brick import executor
from cinder.i18n import _, _LW
import stat
import time
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
+from oslo_concurrency import processutils as putils
import six
from cinder.brick import exception
import re
import time
-from oslo.concurrency import processutils as putils
from oslo.utils import excutils
+from oslo_concurrency import processutils as putils
from cinder.brick import exception
from cinder.brick import executor
import os
import re
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
import six
from cinder.brick import exception
import os
import tempfile
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import timeutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _
import os
import random
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.db import exception as db_exc
from oslo import messaging
from oslo.utils import importutils
+from oslo_concurrency import processutils
import osprofiler.notifier
from osprofiler import profiler
import osprofiler.web
import fixtures
import mock
import mox
-from oslo.concurrency import lockutils
from oslo.config import cfg
from oslo.config import fixture as config_fixture
from oslo.i18n import _lazy
from oslo.messaging import conffixture as messaging_conffixture
from oslo.utils import strutils
from oslo.utils import timeutils
+from oslo_concurrency import lockutils
import stubout
import testtools
import ast
import fixtures
-from oslo.concurrency import lockutils
from oslo.config import cfg
from oslo.config import fixture as config_fixture
from oslo.serialization import jsonutils
from oslo.utils import timeutils
+from oslo_concurrency import lockutils
import webob
from webob import exc
import tempfile
import time
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder.brick import exception
from cinder.brick.initiator import connector
# under the License.
import mox
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder.brick import exception
from cinder.brick.local_dev import lvm as brick
import re
from eventlet import greenthread
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder.openstack.common import log as logging
from cinder import utils
import uuid
import mock
-from oslo.concurrency import processutils
from oslo.serialization import jsonutils
+from oslo_concurrency import processutils
import six
from cinder.backup import driver
import os
import posix
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder.backup.drivers import tsm
from cinder import context
import re
import mock
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder import test
fake_cli.assert_has_calls(expect_cmd)
@mock.patch(
- "oslo.concurrency.processutils.execute",
+ "oslo_concurrency.processutils.execute",
mock.Mock(
return_value=(
"fakeportal iqn.1992-04.fake.com:fake.apm00123907237.a8", 0)))
return None
@mock.patch(
- "oslo.concurrency.processutils.execute",
+ "oslo_concurrency.processutils.execute",
mock.Mock(
return_value=(
"fakeportal iqn.1992-04.fake.com:fake.apm00123907237.a8", 0)))
import time
import mox
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
import paramiko
from cinder import context
from mox import IgnoreArg
from mox import IsA
from mox import stubout
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils as putils
from cinder import brick
from cinder import compute
import tempfile
import mock
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import context
from cinder import exception
"""
import mock
-from oslo.concurrency import processutils
from oslo.utils import excutils
from oslo.utils import units
+from oslo_concurrency import processutils
import six
import random
@mock.patch('cinder.volume.drivers.ibm.ibmnas.IBMNAS_NFSDriver.'
'_ssh_operation')
- @mock.patch('oslo.concurrency.processutils.execute')
+ @mock.patch('oslo_concurrency.processutils.execute')
def test_create_ibmnas_snap_mount_point_provided(self, mock_ssh,
mock_execute):
"""Create ibmnas snap if mount point is provided."""
@mock.patch('cinder.volume.drivers.ibm.ibmnas.IBMNAS_NFSDriver.'
'_ssh_operation')
- @mock.patch('oslo.concurrency.processutils.execute')
+ @mock.patch('oslo_concurrency.processutils.execute')
def test_create_ibmnas_snap_nas_gpfs(self, mock_execute, mock_ssh):
"""Create ibmnas snap if mount point is provided."""
self.TEST_EXTEND_SIZE_IN_GB)
@mock.patch('cinder.volume.drivers.ibm.ibmnas.IBMNAS_NFSDriver._run_ssh')
- @mock.patch('oslo.concurrency.processutils.execute')
+ @mock.patch('oslo_concurrency.processutils.execute')
def test_delete_snapfiles(self, mock_execute, mock_ssh):
"""Delete_snapfiles test case."""
self.TEST_MNT_POINT)
@mock.patch('cinder.volume.drivers.ibm.ibmnas.IBMNAS_NFSDriver._run_ssh')
- @mock.patch('oslo.concurrency.processutils.execute')
+ @mock.patch('oslo_concurrency.processutils.execute')
def test_delete_snapfiles_nas_gpfs(self, mock_execute, mock_ssh):
"""Delete_snapfiles for gpfs-nas platform test case."""
'_get_provider_location')
@mock.patch('cinder.volume.drivers.ibm.ibmnas.IBMNAS_NFSDriver.'
'_get_mount_point_for_share')
- @mock.patch('oslo.concurrency.processutils.execute')
+ @mock.patch('oslo_concurrency.processutils.execute')
def test_delete_snapshot(self, mock_execute, mock_mount, mock_provider):
"""Delete snapshot simple test case."""
"""Unit tests for image utils."""
import mock
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.image import image_utils
import string
import tempfile
-from oslo.concurrency import processutils
from oslo.config import cfg
+from oslo_concurrency import processutils
from cinder.brick.iscsi import iscsi
from cinder import test
import urllib2
import mock
-from oslo.concurrency import processutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder import test
from mox import IgnoreArg
from mox import IsA
from mox import stubout
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils as putils
from cinder import context
from cinder import exception
import mock
import mox
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.db import exception as db_exc
+from oslo_concurrency import processutils
from cinder import context
from cinder import db
import contextlib
-from oslo.concurrency import processutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder.image import image_utils
from cinder import test
"""
import mock
-from oslo.concurrency import processutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import context
from cinder import exception
self.fake_execute)
self.assertTrue(self.thin_vg.supports_thin_provisioning('sudo'))
self.thin_vg.update_volume_group_info = mock.MagicMock()
- with mock.patch('oslo.concurrency.processutils.execute'):
+ with mock.patch('oslo_concurrency.processutils.execute'):
executor = mock.MagicMock()
self.thin_vg._execute = executor
self.thin_vg.extend_thin_pool()
import time
import mock
-from oslo.concurrency import processutils
from oslo.utils import excutils
from oslo.utils import importutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import context
from cinder import exception
import uuid
import mock
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import timeutils
+from oslo_concurrency import processutils as putils
import paramiko
import six
"""Tests For miscellaneous util methods used with volume."""
import mock
-from oslo.concurrency import processutils
from oslo.config import cfg
+from oslo_concurrency import processutils
from cinder import exception
from cinder.openstack.common import log as logging
import platform
import mock
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder import exception
from cinder import test
import mock
from mock import patch
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.openstack.common import log as logging
"""Unit tests for Cisco fc zone client cli."""
from mock import patch
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder import test
"""Unit tests for Cisco FC zone driver."""
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import importutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder import test
from xml.sax import expatreader
from xml.sax import saxutils
-from oslo.concurrency import lockutils
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import importutils
from oslo.utils import timeutils
+from oslo_concurrency import lockutils
+from oslo_concurrency import processutils
import six
from cinder.brick.initiator import connector
import time
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import excutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE, _LW
import urllib
import urllib2
-from oslo.concurrency import lockutils
from oslo.config import cfg
from oslo.serialization import jsonutils
from oslo.utils import units
+from oslo_concurrency import lockutils
import six.moves.urllib.parse as urlparse
from cinder import exception
import re
import time
-from oslo.concurrency import lockutils
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.serialization import jsonutils as json
from oslo.utils import excutils
from oslo.utils import timeutils
+from oslo_concurrency import lockutils
+from oslo_concurrency import processutils
import six
from cinder import exception
import eventlet
from eventlet import greenthread
import greenlet
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import excutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE, _LW, _LI
FC Drivers for ETERNUS DX arrays based on SMI-S.
"""
-from oslo.concurrency import lockutils
+from oslo_concurrency import lockutils
import six
from cinder import context
ISCSI Drivers for ETERNUS DX arrays based on SMI-S.
"""
-from oslo.concurrency import lockutils
+from oslo_concurrency import lockutils
import six
from cinder import context
import os
import stat
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder.brick.remotefs import remotefs as remotefs_brick
from cinder import exception
import time
from xml.etree import ElementTree as ETree
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import excutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE, _LI
import os
import shlex
-from oslo.concurrency import lockutils
-from oslo.concurrency import processutils as putils
from oslo.utils import excutils
+from oslo_concurrency import lockutils
+from oslo_concurrency import processutils as putils
import six
from cinder import exception
import threading
import time
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import excutils
+from oslo_concurrency import processutils as putils
import six
from cinder import exception
import string
import threading
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import excutils
from oslo.utils import units
+from oslo_concurrency import processutils
import six
from cinder import context
import re
import shutil
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE
import os
import re
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LI, _LW
import re
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE
import os
import socket
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder.brick import exception as brick_exception
from cinder.brick.local_dev import lvm as lvm
from threading import Timer
import time
-from oslo.concurrency import processutils
from oslo.utils import excutils
from oslo.utils import units
+from oslo_concurrency import processutils
import six.moves.urllib.parse as urlparse
from cinder import exception
import platform
import socket
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
import six
from cinder import context
import os
import time
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils as putils
import six
from cinder.brick.remotefs import remotefs as remotefs_brick
import urllib2
import uuid
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import excutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _LE, _LI, _LW
import errno
import os
-from oslo.concurrency import processutils
from oslo.config import cfg
+from oslo_concurrency import processutils
import xattr
from cinder import compute
import tempfile
import time
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils as putils
from cinder import compute
from cinder import db
"""
from lxml import etree
-from oslo.concurrency import processutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE
import random
from eventlet import greenthread
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import excutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE
"""
import re
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE
import os
import re
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import units
+from oslo_concurrency import processutils as putils
from cinder.brick.remotefs import remotefs
from cinder import exception
import sys
import time
-from oslo.concurrency import lockutils
-from oslo.concurrency import processutils as putils
from oslo.config import cfg
from oslo.utils import excutils
from oslo.utils import units
+from oslo_concurrency import lockutils
+from oslo_concurrency import processutils as putils
import six
from cinder.brick.local_dev import lvm
import traceback
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import timeutils
+from oslo_concurrency import processutils
import taskflow.engines
from taskflow.patterns import linear_flow
from taskflow.utils import misc
import os
import re
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder.brick.iscsi import iscsi
from cinder import exception
import abc
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
import six
# under the License.
-from oslo.concurrency import processutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LW, _LE
# License for the specific language governing permissions and limitations
# under the License.
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
from cinder import exception
from cinder.i18n import _, _LE, _LI, _LW
import re
import time
-from oslo.concurrency import processutils as putils
+from oslo_concurrency import processutils as putils
import six
from cinder import exception
import math
from Crypto.Random import random
-from oslo.concurrency import processutils
from oslo.config import cfg
from oslo.utils import strutils
from oslo.utils import timeutils
from oslo.utils import units
+from oslo_concurrency import processutils
from cinder.brick.local_dev import lvm as brick_lvm
from cinder import exception
import re
from eventlet import greenthread
-from oslo.concurrency import processutils
from oslo.utils import excutils
+from oslo_concurrency import processutils
from cinder import exception
from cinder.i18n import _, _LE
"""
-from oslo.concurrency import lockutils
from oslo.config import cfg
from oslo.utils import excutils
from oslo.utils import importutils
+from oslo_concurrency import lockutils
from cinder import exception
from cinder.i18n import _, _LE, _LI
import random
from eventlet import greenthread
-from oslo.concurrency import processutils
from oslo.utils import excutils
+from oslo_concurrency import processutils
import six
from cinder import exception
import re
from eventlet import greenthread
-from oslo.concurrency import processutils
from oslo.utils import excutils
+from oslo_concurrency import processutils
import six
from cinder import exception
:zone_name_prefix: Used by: class: 'FCZoneDriver'. Defaults to 'openstack'
"""
-from oslo.concurrency import lockutils
from oslo.config import cfg
from oslo.utils import excutils
from oslo.utils import importutils
+from oslo_concurrency import lockutils
import six
from cinder import exception