mirror of
git://sourceware.org/git/lvm2.git
synced 2025-01-03 05:18:29 +03:00
fa444906bb
In preparation to have more than one thread issuing commands to lvm at the same time we need to serialize updates to the dbus state and retrieving the global lvm state. To achieve this we have one thread handling this with a thread safe queue taking and coalescing requests.
248 lines
6.8 KiB
Python
248 lines
6.8 KiB
Python
# Copyright (C) 2015-2016 Red Hat, Inc. All rights reserved.
|
|
#
|
|
# This copyrighted material is made available to anyone wishing to use,
|
|
# modify, copy, or redistribute it subject to the terms and conditions
|
|
# of the GNU General Public License v.2.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
from .automatedproperties import AutomatedProperties
|
|
|
|
from . import utils
|
|
from .cfg import MANAGER_INTERFACE
|
|
import dbus
|
|
from . import cfg
|
|
from . import cmdhandler
|
|
from .request import RequestEntry
|
|
from . import udevwatch
|
|
|
|
|
|
# noinspection PyPep8Naming
|
|
class Manager(AutomatedProperties):
|
|
_Version_meta = ("s", MANAGER_INTERFACE)
|
|
|
|
def __init__(self, object_path):
|
|
super(Manager, self).__init__(object_path)
|
|
self.set_interface(MANAGER_INTERFACE)
|
|
|
|
@property
|
|
def Version(self):
|
|
return dbus.String('1.0.0')
|
|
|
|
@staticmethod
|
|
def _pv_create(device, create_options):
|
|
|
|
# Check to see if we are already trying to create a PV for an existing
|
|
# PV
|
|
pv = cfg.om.get_object_path_by_uuid_lvm_id(device, device)
|
|
if pv:
|
|
raise dbus.exceptions.DBusException(
|
|
MANAGER_INTERFACE, "PV Already exists!")
|
|
|
|
rc, out, err = cmdhandler.pv_create(create_options, [device])
|
|
if rc == 0:
|
|
cfg.load()
|
|
created_pv = cfg.om.get_object_path_by_lvm_id(device)
|
|
else:
|
|
raise dbus.exceptions.DBusException(
|
|
MANAGER_INTERFACE,
|
|
'Exit code %s, stderr = %s' % (str(rc), err))
|
|
|
|
return created_pv
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
in_signature='sia{sv}',
|
|
out_signature='(oo)',
|
|
async_callbacks=('cb', 'cbe'))
|
|
def PvCreate(self, device, tmo, create_options, cb, cbe):
|
|
utils.validate_device_path(MANAGER_INTERFACE, device)
|
|
r = RequestEntry(
|
|
tmo, Manager._pv_create,
|
|
(device, create_options), cb, cbe)
|
|
cfg.worker_q.put(r)
|
|
|
|
@staticmethod
|
|
def _create_vg(name, pv_object_paths, create_options):
|
|
pv_devices = []
|
|
|
|
for p in pv_object_paths:
|
|
pv = cfg.om.get_object_by_path(p)
|
|
if pv:
|
|
pv_devices.append(pv.Name)
|
|
else:
|
|
raise dbus.exceptions.DBusException(
|
|
MANAGER_INTERFACE, 'object path = %s not found' % p)
|
|
|
|
rc, out, err = cmdhandler.vg_create(create_options, pv_devices, name)
|
|
|
|
if rc == 0:
|
|
cfg.load()
|
|
return cfg.om.get_object_path_by_lvm_id(name)
|
|
else:
|
|
raise dbus.exceptions.DBusException(
|
|
MANAGER_INTERFACE,
|
|
'Exit code %s, stderr = %s' % (str(rc), err))
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
in_signature='saoia{sv}',
|
|
out_signature='(oo)',
|
|
async_callbacks=('cb', 'cbe'))
|
|
def VgCreate(self, name, pv_object_paths, tmo, create_options, cb, cbe):
|
|
utils.validate_vg_name(MANAGER_INTERFACE, name)
|
|
r = RequestEntry(
|
|
tmo, Manager._create_vg,
|
|
(name, pv_object_paths, create_options,),
|
|
cb, cbe)
|
|
cfg.worker_q.put(r)
|
|
|
|
@staticmethod
|
|
def _refresh():
|
|
utils.log_debug('Manager.Refresh - entry')
|
|
|
|
# This is a diagnostic and should not be run in normal operation, so
|
|
# lets remove the log entries for refresh as it's implied.
|
|
|
|
# Run an internal diagnostic on the object manager look up tables
|
|
lc = cfg.om.validate_lookups()
|
|
|
|
rc = cfg.load(log=False)
|
|
|
|
if rc != 0:
|
|
utils.log_debug('Manager.Refresh - exit %d' % (rc),
|
|
'bg_black', 'fg_light_red')
|
|
else:
|
|
utils.log_debug('Manager.Refresh - exit %d' % (rc))
|
|
return rc + lc
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
out_signature='t',
|
|
async_callbacks=('cb', 'cbe'))
|
|
def Refresh(self, cb, cbe):
|
|
"""
|
|
Take all the objects we know about and go out and grab the latest
|
|
more of a test method at the moment to make sure we are handling object
|
|
paths correctly.
|
|
|
|
:param cb Callback for result
|
|
:param cbe Callback for errors
|
|
|
|
Returns the number of changes, object add/remove/properties changed
|
|
"""
|
|
r = RequestEntry(-1, Manager._refresh, (), cb, cbe, False)
|
|
cfg.worker_q.put(r)
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
in_signature='s',
|
|
out_signature='o')
|
|
def LookUpByLvmId(self, key):
|
|
"""
|
|
Given a lvm id in one of the forms:
|
|
|
|
/dev/sda
|
|
some_vg
|
|
some_vg/some_lv
|
|
Oe1rPX-Pf0W-15E5-n41N-ZmtF-jXS0-Osg8fn
|
|
|
|
return the object path in O(1) time.
|
|
|
|
:param key: The lookup value
|
|
:return: Return the object path. If object not found you will get '/'
|
|
"""
|
|
p = cfg.om.get_object_path_by_uuid_lvm_id(key, key)
|
|
if p:
|
|
return p
|
|
return '/'
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
in_signature='b', out_signature='b')
|
|
def UseLvmShell(self, yes_no):
|
|
"""
|
|
Allow the client to enable/disable lvm shell, used for testing
|
|
:param yes_no:
|
|
:return: Nothing
|
|
"""
|
|
return dbus.Boolean(cmdhandler.set_execution(yes_no))
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
in_signature='s', out_signature='i')
|
|
def ExternalEvent(self, command):
|
|
|
|
# If a user didn't explicitly specify udev, we will turn it off now.
|
|
if not cfg.args.use_udev:
|
|
if udevwatch.remove():
|
|
utils.log_debug("ExternalEvent received, disabling "
|
|
"udev monitoring")
|
|
# We are dependent on external events now to stay current!
|
|
cfg.ee = True
|
|
utils.log_debug("ExternalEvent %s" % command)
|
|
cfg.event()
|
|
return dbus.Int32(0)
|
|
|
|
@staticmethod
|
|
def _pv_scan(activate, cache, device_path, major_minor, scan_options):
|
|
|
|
rc, out, err = cmdhandler.pv_scan(
|
|
activate, cache, device_path,
|
|
major_minor, scan_options)
|
|
|
|
if rc == 0:
|
|
# This could potentially change the state quite a bit, so lets
|
|
# update everything to be safe
|
|
cfg.load()
|
|
return '/'
|
|
else:
|
|
raise dbus.exceptions.DBusException(
|
|
MANAGER_INTERFACE,
|
|
'Exit code %s, stderr = %s' % (str(rc), err))
|
|
|
|
@dbus.service.method(
|
|
dbus_interface=MANAGER_INTERFACE,
|
|
in_signature='bbasa(ii)ia{sv}',
|
|
out_signature='o',
|
|
async_callbacks=('cb', 'cbe'))
|
|
def PvScan(self, activate, cache, device_paths, major_minors,
|
|
tmo, scan_options, cb, cbe):
|
|
"""
|
|
Scan all supported LVM block devices in the system for physical volumes
|
|
NOTE: major_minors & device_paths only usable when cache == True
|
|
:param activate: If True, activate any newly found LVs
|
|
:param cache: If True, update lvmetad
|
|
:param device_paths: Array of device paths or empty
|
|
:param major_minors: Array of structures (major,minor)
|
|
:param tmo: Timeout for operation
|
|
:param scan_options: Additional options to pvscan
|
|
:param cb: Not visible in API (used for async. callback)
|
|
:param cbe: Not visible in API (used for async. error callback)
|
|
:return: '/' if operation done, else job path
|
|
"""
|
|
for d in device_paths:
|
|
utils.validate_device_path(MANAGER_INTERFACE, d)
|
|
|
|
r = RequestEntry(
|
|
tmo, Manager._pv_scan,
|
|
(activate, cache, device_paths, major_minors,
|
|
scan_options), cb, cbe, False)
|
|
cfg.worker_q.put(r)
|
|
|
|
@property
|
|
def lvm_id(self):
|
|
"""
|
|
Intended to be overridden by classes that inherit
|
|
"""
|
|
return str(id(self))
|
|
|
|
@property
|
|
def Uuid(self):
|
|
"""
|
|
Intended to be overridden by classes that inherit
|
|
"""
|
|
import uuid
|
|
return uuid.uuid1()
|