shaba/virt-manager
1
0
Fork 0
mirror of https://github.com/virt-manager/virt-manager.git synced 2024-12-25 23:21:45 +03:00
Code Issues Projects Releases Wiki Activity

packagekit: Allow cancelling package search

Browse Source
This commit is contained in:
Cole Robinson 2013-06-13 17:37:12 -04:00
parent 1c22ea92df
commit 8a0bee44dc
1 changed files with 21 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
virtManager/packageutils.py
View File

@ -59,10 +59,11 @@ def check_packagekit(errbox, packages, ishv):
else:
msg = _("Checking for installed package '%s'") % packages[0]
found = []
cancellable = Gio.Cancellable()
progWin = vmmAsyncJob(_do_async_search,
[bus, pk_control, packages], msg, msg,
errbox.get_parent(), async=False)
[bus, pk_control, packages, cancellable], msg, msg,
errbox.get_parent(), async=False,
cancel_cb=[_cancel_search, cancellable])
error, ignore = progWin.run()
if error:
return
@ -109,16 +110,25 @@ def check_packagekit(errbox, packages, ishv):
return do_install
def _do_async_search(asyncjob, bus, pk_control, packages):
def _cancel_search(asyncjob, cancellable):
cancellable.cancel()
asyncjob.job_cancelled = True
def _do_async_search(asyncjob, bus, pk_control, packages, cancellable):
found = []
try:
for name in packages:
ret_found = packagekit_search(bus, pk_control, name, packages)
ret_found = packagekit_search(bus, pk_control, name, packages,
cancellable)
found += ret_found
except Exception, e:
logging.exception("Error searching for installed packages")
asyncjob.set_error(str(e), "".join(traceback.format_exc()))
if cancellable.is_cancelled():
logging.debug("Package search cancelled by user")
asyncjob.set_error("Package search cancelled by user")
else:
logging.exception("Error searching for installed packages")
asyncjob.set_error(str(e), "".join(traceback.format_exc()))
asyncjob.set_extra_data(found)
@ -138,11 +148,12 @@ def packagekit_install(package_list):
timeout=timeout)
def packagekit_search(bus, pk_control, package_name, packages):
def packagekit_search(bus, pk_control, package_name, packages, cancellable):
tid = pk_control.CreateTransaction()
pk_trans = Gio.DBusProxy.new_sync(bus, 0, None,
"org.freedesktop.PackageKit", tid,
"org.freedesktop.PackageKit.Transaction", None)
"org.freedesktop.PackageKit.Transaction",
cancellable)
found = []
def package(info, package_id, summary):