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

inspection: add vmmInspection.vm_refresh helper

Browse Source 
Add a simple helper to force a new inspection of a VM.
This commit is contained in:
Pino Toscano 2017-02-23 11:22:25 +01:00 committed by Cole Robinson
parent 67ed3e86df
commit 45d0be9805
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
virtManager/inspection.py
View File

@ -71,6 +71,10 @@ class vmmInspection(vmmGObject):
obj = ("vm_added", conn.get_uri(), connkey) obj = ("vm_added", conn.get_uri(), connkey)
self._q.put(obj) self._q.put(obj)
def vm_refresh(self, vm):
obj = ("vm_refresh", vm.conn.get_uri(), vm.get_name(), vm.get_uuid())
self._q.put(obj)
def start(self): def start(self):
# Wait a few seconds before we do anything. This prevents # Wait a few seconds before we do anything. This prevents
# inspection from being a burden for initial virt-manager # inspection from being a burden for initial virt-manager
@ -105,7 +109,7 @@ class vmmInspection(vmmGObject):
elif obj[0] == "conn_removed": elif obj[0] == "conn_removed":
uri = obj[1] uri = obj[1]
del self._conns[uri] del self._conns[uri]
elif obj[0] == "vm_added": elif obj[0] == "vm_added" or obj[0] == "vm_refresh":
uri = obj[1] uri = obj[1]
if not (uri in self._conns): if not (uri in self._conns):
# This connection disappeared in the meanwhile. # This connection disappeared in the meanwhile.
@ -118,6 +122,13 @@ class vmmInspection(vmmGObject):
if not vm: if not vm:
# The VM was removed in the meanwhile. # The VM was removed in the meanwhile.
return return
if obj[0] == "vm_refresh":
vmuuid = obj[3]
# When refreshing the inspection data of a VM,
# all we need is to remove it from the "seen" cache,
# as the data itself will be replaced once the new
# results are available.
del self._vmseen[vmuuid]
self._process_vm(conn, vm) self._process_vm(conn, vm)
# Try processing a single VM, keeping into account whether it was # Try processing a single VM, keeping into account whether it was