Merge packages asynchronously in Portage.

pym/_emerge/Binpkg.py

 # Copyright 1999-2011 Gentoo Foundation
 # Distributed under the terms of the GNU General Public License v2
 
 from _emerge.EbuildPhase import EbuildPhase
 from _emerge.BinpkgFetcher import BinpkgFetcher
 from _emerge.BinpkgEnvExtractor import BinpkgEnvExtractor
 from _emerge.BinpkgExtractorAsync import BinpkgExtractorAsync
 from _emerge.CompositeTask import CompositeTask
 from _emerge.BinpkgVerifier import BinpkgVerifier
 from _emerge.EbuildMerge import EbuildMerge
@@ skipping 289 matching lines @@
                         self._writemsg_level("!!! Error Extracting '%s'\n" % \
                                 self._pkg_path, noiselevel=-1, level=logging.ERROR)
                 self.wait()
 
         def _unlock_builddir(self):
                 if self.opts.pretend or self.opts.fetchonly:
                         return
                 portage.elog.elog_process(self.pkg.cpv, self.settings)
                 self._build_dir.unlock()
 
-        def install(self):
+        def install(self, handler):
 
                 # This gives bashrc users an opportunity to do various things
                 # such as remove binary packages after they're installed.
                 settings = self.settings
                 settings["PORTAGE_BINPKG_FILE"] = self._pkg_path
                 settings.backup_changes("PORTAGE_BINPKG_FILE")
 
                 merge = EbuildMerge(find_blockers=self.find_blockers,
                         ldpath_mtimes=self.ldpath_mtimes, logger=self.logger,
                         pkg=self.pkg, pkg_count=self.pkg_count,
                         pkg_path=self._pkg_path, scheduler=self.scheduler,
                         settings=settings, tree=self._tree, world_atom=self.world_atom)
+                task = merge.create_task()
+                task.addExitListener(self._install_exit)
+                self._start_task(task, handler)
 
-                try:
-                        retval = merge.execute()
-                finally:
-                        settings.pop("PORTAGE_BINPKG_FILE", None)
-                        self._unlock_builddir()
+        def _install_exit(self, task):
+                self.settings.pop("PORTAGE_BINPKG_FILE", None)
+                self._unlock_builddir()
 
-                if retval == os.EX_OK and \
-                        'binpkg-logs' not in self.settings.features and \
+                if self._default_final_exit(task) != os.EX_OK:
+                        return
+
+                if 'binpkg-logs' not in self.settings.features and \
                         self.settings.get("PORTAGE_LOG_FILE"):
                         try:
                                 os.unlink(self.settings["PORTAGE_LOG_FILE"])
                         except OSError:
                                 pass
-                return retval
-