NuKVM/virt-manager
3
0
Fork 0
mirror of https://github.com/virt-manager/virt-manager.git synced 2025-02-25 18:55:27 -06:00
Code Issues Packages Projects Releases Wiki Activity

Use node device lifecycle events

Browse Source 
API will be available in upcoming libvirt 2.2.0
This commit is contained in:
Jovanka Gulicoska 2016-08-11 16:10:09 +02:00 committed by Cole Robinson
parent f55772845a
commit ead5fdffff
2 changed files with 34 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
virtManager/connection.py
View File

@ -215,6 +215,8 @@ class vmmConnection(vmmGObject):
self._network_cb_ids = [] self._network_cb_ids = []
self.using_storage_pool_events = False self.using_storage_pool_events = False
self._storage_pool_cb_ids = [] self._storage_pool_cb_ids = []
self.using_node_device_events = False
self._node_device_cb_ids = []
self._xml_flags = {} self._xml_flags = {}
@ -796,6 +798,17 @@ class vmmConnection(vmmGObject):
else: else:
self.schedule_priority_tick(pollpool=True, force=True) self.schedule_priority_tick(pollpool=True, force=True)
def _node_device_lifecycle_event(self, conn, dev,
event, reason, userdata):
ignore = conn
ignore = userdata
name = dev.name()
logging.debug("node device lifecycle event: device=%s event=%s "
"reason=%s", name, event, reason)
self.schedule_priority_tick(pollnodedev=True, force=True)
def _add_conn_events(self): def _add_conn_events(self):
if not self.check_support(support.SUPPORT_CONN_WORKING_XEN_EVENTS): if not self.check_support(support.SUPPORT_CONN_WORKING_XEN_EVENTS):
return return
@ -866,6 +879,20 @@ class vmmConnection(vmmGObject):
self.using_storage_pool_events = False self.using_storage_pool_events = False
logging.debug("Error registering storage pool events: %s", e) logging.debug("Error registering storage pool events: %s", e)
try:
if FORCE_DISABLE_EVENTS:
raise RuntimeError("FORCE_DISABLE_EVENTS = True")
eventid = getattr(libvirt, "VIR_NODE_DEVICE_EVENT_ID_LIFECYCLE", 0)
self._node_device_cb_ids.append(
self.get_backend().nodeDeviceEventRegisterAny(
None, eventid, self._node_device_lifecycle_event, None))
self.using_node_device_events = True
logging.debug("Using node device events")
except Exception, e:
self.using_network_events = False
logging.debug("Error registering node device events: %s", e)
###################################### ######################################
# Connection closing/opening methods # # Connection closing/opening methods #
@ -888,6 +915,8 @@ class vmmConnection(vmmGObject):
self._backend.networkEventDeregisterAny(eid) self._backend.networkEventDeregisterAny(eid)
for eid in self._storage_pool_cb_ids: for eid in self._storage_pool_cb_ids:
self._backend.storagePoolEventDeregisterAny(eid) self._backend.storagePoolEventDeregisterAny(eid)
for eid in self._node_device_cb_ids:
self._backend.nodeDeviceEventDeregisterAny(eid)
except: except:
logging.debug("Failed to deregister events in conn cleanup", logging.debug("Failed to deregister events in conn cleanup",
exc_info=True) exc_info=True)
@ -895,6 +924,7 @@ class vmmConnection(vmmGObject):
self._domain_cb_ids = [] self._domain_cb_ids = []
self._network_cb_ids = [] self._network_cb_ids = []
self._storage_pool_cb_ids = [] self._storage_pool_cb_ids = []
self._node_device_cb_ids = []
self._backend.close() self._backend.close()
self._stats = [] self._stats = []
@ -1227,6 +1257,8 @@ class vmmConnection(vmmGObject):
pollnet = False pollnet = False
if self.using_storage_pool_events and not force: if self.using_storage_pool_events and not force:
pollpool = False pollpool = False
if self.using_node_device_events and not force:
pollnodedev = False
self._hostinfo = self._backend.getInfo() self._hostinfo = self._backend.getInfo()

2
virtManager/nodedev.py
View File

@ -44,6 +44,8 @@ class vmmNodeDevice(vmmLibvirtObject):
return self.get_connkey() return self.get_connkey()
def is_active(self): def is_active(self):
return True return True
def _using_events(self):
return self.conn.using_node_device_events
def tick(self, stats_update=True): def tick(self, stats_update=True):
# Deliberately empty # Deliberately empty