1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
# 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: ({} of {}) {} Clean Post".format(
pkg_count.curval,
pkg_count.maxval,
pkg.cpv,
)
logger.log(
f" === ({pkg_count.curval} of {pkg_count.maxval}) "
f"Post-Build Cleaning ({pkg.cpv}::{pkg_path})",
short_msg=short_msg,
)
logger.log(
f" ::: completed emerge ({pkg_count.curval} of {pkg_count.maxval}) "
f"{pkg.cpv} to {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()
|
GitWeb