mirror of
https://github.com/virt-manager/virt-manager.git
synced 2024-12-22 13:34:07 +03:00
73 lines
2.0 KiB
Python
73 lines
2.0 KiB
Python
#
|
|
# Copyright (C) 2013 Red Hat, Inc.
|
|
#
|
|
# This work is licensed under the GNU GPLv2 or later.
|
|
# See the COPYING file in the top-level directory.
|
|
#
|
|
|
|
from .logger import log
|
|
|
|
|
|
def _new_poll_helper(origmap, typename, list_cb, build_cb, support_cb):
|
|
"""
|
|
Helper for new style listAll* APIs
|
|
"""
|
|
current = {}
|
|
new = {}
|
|
objs = []
|
|
|
|
try:
|
|
if support_cb():
|
|
objs = list_cb()
|
|
except Exception as e: # pragma: no cover
|
|
log.debug("Unable to list all %ss: %s", typename, e)
|
|
|
|
for obj in objs:
|
|
connkey = obj.name()
|
|
|
|
if connkey not in origmap:
|
|
# Object is brand new this period
|
|
current[connkey] = build_cb(obj, connkey)
|
|
new[connkey] = current[connkey]
|
|
else:
|
|
# Previously known object
|
|
current[connkey] = origmap[connkey]
|
|
del(origmap[connkey])
|
|
|
|
return (list(origmap.values()), list(new.values()), list(current.values()))
|
|
|
|
|
|
def fetch_nets(backend, origmap, build_cb):
|
|
name = "network"
|
|
list_cb = backend.listAllNetworks
|
|
support_cb = backend.support.conn_network
|
|
return _new_poll_helper(origmap, name, list_cb, build_cb, support_cb)
|
|
|
|
|
|
def fetch_pools(backend, origmap, build_cb):
|
|
name = "pool"
|
|
list_cb = backend.listAllStoragePools
|
|
support_cb = backend.support.conn_storage
|
|
return _new_poll_helper(origmap, name, list_cb, build_cb, support_cb)
|
|
|
|
|
|
def fetch_volumes(backend, pool, origmap, build_cb):
|
|
name = "volume"
|
|
list_cb = pool.listAllVolumes
|
|
support_cb = backend.support.conn_storage
|
|
return _new_poll_helper(origmap, name, list_cb, build_cb, support_cb)
|
|
|
|
|
|
def fetch_nodedevs(backend, origmap, build_cb):
|
|
name = "nodedev"
|
|
list_cb = backend.listAllDevices
|
|
support_cb = backend.support.conn_nodedev
|
|
return _new_poll_helper(origmap, name, list_cb, build_cb, support_cb)
|
|
|
|
|
|
def fetch_vms(backend, origmap, build_cb):
|
|
name = "domain"
|
|
list_cb = backend.listAllDomains
|
|
support_cb = backend.support.conn_domain
|
|
return _new_poll_helper(origmap, name, list_cb, build_cb, support_cb)
|