Merge packages asynchronously in Portage.

pym/_emerge/MergeListItem.py

 # Copyright 1999-2009 Gentoo Foundation
 # Distributed under the terms of the GNU General Public License v2
 
 from portage import os
 from portage.output import colorize
 
 from _emerge.Binpkg import Binpkg
 from _emerge.CompositeTask import CompositeTask
 from _emerge.EbuildBuild import EbuildBuild
 from _emerge.PackageUninstall import PackageUninstall
@@ skipping 93 matching lines @@
                         return
 
         def _poll(self):
                 self._install_task.poll()
                 return self.returncode
 
         def _wait(self):
                 self._install_task.wait()
                 return self.returncode
 
-        def merge(self):
+        def merge(self, exit_handler):
 
                 pkg = self.pkg
                 build_opts = self.build_opts
                 find_blockers = self.find_blockers
                 logger = self.logger
                 mtimedb = self.mtimedb
                 pkg_count = self.pkg_count
                 prefetcher = self.prefetcher
                 scheduler = self.scheduler
                 settings = self.settings
                 world_atom = self.world_atom
                 ldpath_mtimes = mtimedb["ldpath"]
 
                 if pkg.installed:
                         if not (build_opts.buildpkgonly or \
                                 build_opts.fetchonly or build_opts.pretend):
 
                                 uninstall = PackageUninstall(background=self.background,
                                         ldpath_mtimes=ldpath_mtimes, opts=self.emerge_opts,
                                         pkg=pkg, scheduler=scheduler, settings=settings,
                                         world_atom=world_atom)
 
                                 uninstall.start()
-                                retval = uninstall.wait()
-                                if retval != os.EX_OK:
-                                        return retval
-                        return os.EX_OK
+                                self.returncode = uninstall.wait()
+                        else:
+                                self.returncode = os.EX_OK
+                        exit_handler(self)
+                elif build_opts.fetchonly or \
+                        build_opts.buildpkgonly:
+                        exit_handler(self)
+                else:
+                        self._current_task = self._install_task
+                        self._install_task.install(exit_handler)
 
-                if build_opts.fetchonly or \
-                        build_opts.buildpkgonly:
-                        return self.returncode
-
-                retval = self._install_task.install()
-                return retval
-