Merge packages asynchronously in Portage.

pym/_emerge/EbuildBuild.py

 # Copyright 1999-2011 Gentoo Foundation
 # Distributed under the terms of the GNU General Public License v2
 
 from _emerge.EbuildExecuter import EbuildExecuter
 from _emerge.EbuildPhase import EbuildPhase
 from _emerge.EbuildBinpkg import EbuildBinpkg
 from _emerge.EbuildFetcher import EbuildFetcher
 from _emerge.CompositeTask import CompositeTask
 from _emerge.EbuildMerge import EbuildMerge
 from _emerge.EbuildFetchonly import EbuildFetchonly
@@ skipping 296 matching lines @@
                 clean_phase = EbuildPhase(background=self.background,
                         phase=phase, scheduler=self.scheduler, settings=self.settings)
                 self._start_task(clean_phase, self._clean_exit)
 
         def _clean_exit(self, clean_phase):
                 if self._final_exit(clean_phase) != os.EX_OK or \
                         self.opts.buildpkgonly:
                         self._unlock_builddir()
                 self.wait()
 
-        def install(self):
+        def install(self, exit_handler):
                 """
                 Install the package and then clean up and release locks.
                 Only call this after the build has completed successfully
                 and neither fetchonly nor buildpkgonly mode are enabled.
                 """
 
                 ldpath_mtimes = self.ldpath_mtimes
                 logger = self.logger
                 pkg = self.pkg
                 pkg_count = self.pkg_count
                 settings = self.settings
                 world_atom = self.world_atom
                 ebuild_path = self._ebuild_path
                 tree = self._tree
 
                 merge = EbuildMerge(find_blockers=self.find_blockers,
                         ldpath_mtimes=ldpath_mtimes, logger=logger, pkg=pkg,
                         pkg_count=pkg_count, pkg_path=ebuild_path,
                         scheduler=self.scheduler,
                         settings=settings, tree=tree, world_atom=world_atom)
 
                 msg = " === (%s of %s) Merging (%s::%s)" % \
                         (pkg_count.curval, pkg_count.maxval,
                         pkg.cpv, ebuild_path)
                 short_msg = "emerge: (%s of %s) %s Merge" % \
                         (pkg_count.curval, pkg_count.maxval, pkg.cpv)
                 logger.log(msg, short_msg=short_msg)
 
-                try:
-                        rval = merge.execute()
-                finally:
-                        self._unlock_builddir()
+                task = merge.create_task()
+                task.addExitListener(self._install_exit)
+                self._start_task(task, exit_handler)
 
-                return rval
+        def _install_exit(self, task):
+                self._unlock_builddir()
+                self._default_final_exit(task)