| # Copyright 1999-2018 Gentoo Foundation |
| # Distributed under the terms of the GNU General Public License v2 |
| |
| import functools |
| |
| from _emerge.CompositeTask import CompositeTask |
| from portage import os |
| from portage.dbapi._MergeProcess import MergeProcess |
| from portage.util._async.AsyncTaskFuture import AsyncTaskFuture |
| |
| class EbuildMerge(CompositeTask): |
| |
| __slots__ = ("exit_hook", "find_blockers", "logger", "ldpath_mtimes", |
| "pkg", "pkg_count", "pkg_path", "postinst_failure", "pretend", |
| "settings", "tree", "world_atom") |
| |
| def _start(self): |
| root_config = self.pkg.root_config |
| settings = self.settings |
| mycat = settings["CATEGORY"] |
| mypkg = settings["PF"] |
| pkgloc = settings["D"] |
| infloc = os.path.join(settings["PORTAGE_BUILDDIR"], "build-info") |
| myebuild = settings["EBUILD"] |
| mydbapi = root_config.trees[self.tree].dbapi |
| vartree = root_config.trees["vartree"] |
| background = (settings.get('PORTAGE_BACKGROUND') == '1') |
| logfile = settings.get('PORTAGE_LOG_FILE') |
| |
| merge_task = MergeProcess( |
| mycat=mycat, mypkg=mypkg, settings=settings, |
| treetype=self.tree, vartree=vartree, scheduler=self.scheduler, |
| background=background, blockers=self.find_blockers, pkgloc=pkgloc, |
| infloc=infloc, myebuild=myebuild, mydbapi=mydbapi, |
| prev_mtimes=self.ldpath_mtimes, logfile=logfile) |
| |
| self._start_task(merge_task, self._merge_exit) |
| |
| def _merge_exit(self, merge_task): |
| if self._final_exit(merge_task) != os.EX_OK: |
| self._start_exit_hook(self.returncode) |
| return |
| |
| self.postinst_failure = merge_task.postinst_failure |
| pkg = self.pkg |
| self.world_atom(pkg) |
| pkg_count = self.pkg_count |
| pkg_path = self.pkg_path |
| logger = self.logger |
| if "noclean" not in self.settings.features: |
| short_msg = "emerge: (%s of %s) %s Clean Post" % \ |
| (pkg_count.curval, pkg_count.maxval, pkg.cpv) |
| logger.log((" === (%s of %s) " + \ |
| "Post-Build Cleaning (%s::%s)") % \ |
| (pkg_count.curval, pkg_count.maxval, pkg.cpv, pkg_path), |
| short_msg=short_msg) |
| logger.log(" ::: completed emerge (%s of %s) %s to %s" % \ |
| (pkg_count.curval, pkg_count.maxval, pkg.cpv, pkg.root)) |
| |
| self._start_exit_hook(self.returncode) |
| |
| def _start_exit_hook(self, returncode): |
| """ |
| Start the exit hook, and set returncode after it completes. |
| """ |
| # The returncode will be set after exit hook is complete. |
| self.returncode = None |
| self._start_task( |
| AsyncTaskFuture(future=self.exit_hook(self)), |
| functools.partial(self._exit_hook_exit, returncode)) |
| |
| def _exit_hook_exit(self, returncode, task): |
| self._assert_current(task) |
| self.returncode = returncode |
| self._async_wait() |