mirror of
git://sourceware.org/git/lvm2.git
synced 2025-03-11 20:58:50 +03:00
6204955347
When VDO support is available we will create VG object instances which will allow the API user to create VDO pool LVs.
104 lines
2.6 KiB
Python
104 lines
2.6 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/>.
|
|
|
|
import os
|
|
import multiprocessing
|
|
import queue
|
|
import itertools
|
|
|
|
from lvmdbusd import path
|
|
|
|
LVM_CMD = os.getenv('LVM_BINARY', path.LVM_BINARY)
|
|
|
|
# This is the global object manager
|
|
om = None
|
|
|
|
# This is the global bus connection
|
|
bus = None
|
|
|
|
# Command line args
|
|
args = None
|
|
|
|
# Set to true if we are depending on external events for updates
|
|
got_external_event = False
|
|
|
|
# Shared state variable across all processes
|
|
run = multiprocessing.Value('i', 1)
|
|
|
|
# If this is set to true, the current setup support lvm shell and we are
|
|
# running in that mode of operation
|
|
SHELL_IN_USE = None
|
|
|
|
# Lock used by pprint
|
|
stdout_lock = multiprocessing.Lock()
|
|
|
|
worker_q = queue.Queue()
|
|
|
|
# Main event loop
|
|
loop = None
|
|
|
|
BUS_NAME = os.getenv('LVM_DBUS_NAME', 'com.redhat.lvmdbus1')
|
|
BASE_INTERFACE = 'com.redhat.lvmdbus1'
|
|
PV_INTERFACE = BASE_INTERFACE + '.Pv'
|
|
VG_INTERFACE = BASE_INTERFACE + '.Vg'
|
|
VG_VDO_INTERFACE = BASE_INTERFACE + '.VgVdo'
|
|
LV_INTERFACE = BASE_INTERFACE + '.Lv'
|
|
LV_COMMON_INTERFACE = BASE_INTERFACE + '.LvCommon'
|
|
THIN_POOL_INTERFACE = BASE_INTERFACE + '.ThinPool'
|
|
CACHE_POOL_INTERFACE = BASE_INTERFACE + '.CachePool'
|
|
LV_CACHED = BASE_INTERFACE + '.CachedLv'
|
|
SNAPSHOT_INTERFACE = BASE_INTERFACE + '.Snapshot'
|
|
MANAGER_INTERFACE = BASE_INTERFACE + '.Manager'
|
|
JOB_INTERFACE = BASE_INTERFACE + '.Job'
|
|
|
|
BASE_OBJ_PATH = '/' + BASE_INTERFACE.replace('.', '/')
|
|
PV_OBJ_PATH = BASE_OBJ_PATH + '/Pv'
|
|
VG_OBJ_PATH = BASE_OBJ_PATH + '/Vg'
|
|
LV_OBJ_PATH = BASE_OBJ_PATH + '/Lv'
|
|
THIN_POOL_PATH = BASE_OBJ_PATH + "/ThinPool"
|
|
CACHE_POOL_PATH = BASE_OBJ_PATH + "/CachePool"
|
|
HIDDEN_LV_PATH = BASE_OBJ_PATH + "/HiddenLv"
|
|
MANAGER_OBJ_PATH = BASE_OBJ_PATH + '/Manager'
|
|
JOB_OBJ_PATH = BASE_OBJ_PATH + '/Job'
|
|
|
|
# Counters for object path generation
|
|
pv_id = itertools.count()
|
|
vg_id = itertools.count()
|
|
lv_id = itertools.count()
|
|
thin_id = itertools.count()
|
|
cache_pool_id = itertools.count()
|
|
job_id = itertools.count()
|
|
hidden_lv = itertools.count()
|
|
|
|
# Used to prevent circular imports...
|
|
load = None
|
|
event = None
|
|
|
|
# Boolean to denote if lvm supports VDO integration
|
|
vdo_support = False
|
|
|
|
# Global cached state
|
|
db = None
|
|
|
|
# lvm flight recorder
|
|
blackbox = None
|
|
|
|
# RequestEntry ctor
|
|
create_request_entry = None
|
|
|
|
|
|
def exit_daemon():
|
|
"""
|
|
Exit the daemon cleanly
|
|
:return:
|
|
"""
|
|
if run and loop:
|
|
run.value = 0
|
|
loop.quit()
|