control.py 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307
  1. # Copyright (c) 2013 The Chromium OS Authors.
  2. #
  3. # SPDX-License-Identifier: GPL-2.0+
  4. #
  5. import multiprocessing
  6. import os
  7. import shutil
  8. import sys
  9. import board
  10. import bsettings
  11. from builder import Builder
  12. import gitutil
  13. import patchstream
  14. import terminal
  15. from terminal import Print
  16. import toolchain
  17. import command
  18. import subprocess
  19. def GetPlural(count):
  20. """Returns a plural 's' if count is not 1"""
  21. return 's' if count != 1 else ''
  22. def GetActionSummary(is_summary, commits, selected, options):
  23. """Return a string summarising the intended action.
  24. Returns:
  25. Summary string.
  26. """
  27. if commits:
  28. count = len(commits)
  29. count = (count + options.step - 1) / options.step
  30. commit_str = '%d commit%s' % (count, GetPlural(count))
  31. else:
  32. commit_str = 'current source'
  33. str = '%s %s for %d boards' % (
  34. 'Summary of' if is_summary else 'Building', commit_str,
  35. len(selected))
  36. str += ' (%d thread%s, %d job%s per thread)' % (options.threads,
  37. GetPlural(options.threads), options.jobs, GetPlural(options.jobs))
  38. return str
  39. def ShowActions(series, why_selected, boards_selected, builder, options):
  40. """Display a list of actions that we would take, if not a dry run.
  41. Args:
  42. series: Series object
  43. why_selected: Dictionary where each key is a buildman argument
  44. provided by the user, and the value is the boards brought
  45. in by that argument. For example, 'arm' might bring in
  46. 400 boards, so in this case the key would be 'arm' and
  47. the value would be a list of board names.
  48. boards_selected: Dict of selected boards, key is target name,
  49. value is Board object
  50. builder: The builder that will be used to build the commits
  51. options: Command line options object
  52. """
  53. col = terminal.Color()
  54. print 'Dry run, so not doing much. But I would do this:'
  55. print
  56. if series:
  57. commits = series.commits
  58. else:
  59. commits = None
  60. print GetActionSummary(False, commits, boards_selected,
  61. options)
  62. print 'Build directory: %s' % builder.base_dir
  63. if commits:
  64. for upto in range(0, len(series.commits), options.step):
  65. commit = series.commits[upto]
  66. print ' ', col.Color(col.YELLOW, commit.hash[:8], bright=False),
  67. print commit.subject
  68. print
  69. for arg in why_selected:
  70. if arg != 'all':
  71. print arg, ': %d boards' % why_selected[arg]
  72. print ('Total boards to build for each commit: %d\n' %
  73. why_selected['all'])
  74. def DoBuildman(options, args, toolchains=None, make_func=None, boards=None,
  75. clean_dir=False):
  76. """The main control code for buildman
  77. Args:
  78. options: Command line options object
  79. args: Command line arguments (list of strings)
  80. toolchains: Toolchains to use - this should be a Toolchains()
  81. object. If None, then it will be created and scanned
  82. make_func: Make function to use for the builder. This is called
  83. to execute 'make'. If this is None, the normal function
  84. will be used, which calls the 'make' tool with suitable
  85. arguments. This setting is useful for tests.
  86. board: Boards() object to use, containing a list of available
  87. boards. If this is None it will be created and scanned.
  88. """
  89. global builder
  90. if options.full_help:
  91. pager = os.getenv('PAGER')
  92. if not pager:
  93. pager = 'more'
  94. fname = os.path.join(os.path.dirname(os.path.realpath(sys.argv[0])),
  95. 'README')
  96. command.Run(pager, fname)
  97. return 0
  98. gitutil.Setup()
  99. col = terminal.Color()
  100. options.git_dir = os.path.join(options.git, '.git')
  101. no_toolchains = toolchains is None
  102. if no_toolchains:
  103. toolchains = toolchain.Toolchains()
  104. if options.fetch_arch:
  105. if options.fetch_arch == 'list':
  106. sorted_list = toolchains.ListArchs()
  107. print col.Color(col.BLUE, 'Available architectures: %s\n' %
  108. ' '.join(sorted_list))
  109. return 0
  110. else:
  111. fetch_arch = options.fetch_arch
  112. if fetch_arch == 'all':
  113. fetch_arch = ','.join(toolchains.ListArchs())
  114. print col.Color(col.CYAN, '\nDownloading toolchains: %s' %
  115. fetch_arch)
  116. for arch in fetch_arch.split(','):
  117. print
  118. ret = toolchains.FetchAndInstall(arch)
  119. if ret:
  120. return ret
  121. return 0
  122. if no_toolchains:
  123. toolchains.GetSettings()
  124. toolchains.Scan(options.list_tool_chains)
  125. if options.list_tool_chains:
  126. toolchains.List()
  127. print
  128. return 0
  129. # Work out how many commits to build. We want to build everything on the
  130. # branch. We also build the upstream commit as a control so we can see
  131. # problems introduced by the first commit on the branch.
  132. count = options.count
  133. has_range = options.branch and '..' in options.branch
  134. if count == -1:
  135. if not options.branch:
  136. count = 1
  137. else:
  138. if has_range:
  139. count, msg = gitutil.CountCommitsInRange(options.git_dir,
  140. options.branch)
  141. else:
  142. count, msg = gitutil.CountCommitsInBranch(options.git_dir,
  143. options.branch)
  144. if count is None:
  145. sys.exit(col.Color(col.RED, msg))
  146. elif count == 0:
  147. sys.exit(col.Color(col.RED, "Range '%s' has no commits" %
  148. options.branch))
  149. if msg:
  150. print col.Color(col.YELLOW, msg)
  151. count += 1 # Build upstream commit also
  152. if not count:
  153. str = ("No commits found to process in branch '%s': "
  154. "set branch's upstream or use -c flag" % options.branch)
  155. sys.exit(col.Color(col.RED, str))
  156. # Work out what subset of the boards we are building
  157. if not boards:
  158. board_file = os.path.join(options.git, 'boards.cfg')
  159. status = subprocess.call([os.path.join(options.git,
  160. 'tools/genboardscfg.py')])
  161. if status != 0:
  162. sys.exit("Failed to generate boards.cfg")
  163. boards = board.Boards()
  164. boards.ReadBoards(os.path.join(options.git, 'boards.cfg'))
  165. exclude = []
  166. if options.exclude:
  167. for arg in options.exclude:
  168. exclude += arg.split(',')
  169. why_selected = boards.SelectBoards(args, exclude)
  170. selected = boards.GetSelected()
  171. if not len(selected):
  172. sys.exit(col.Color(col.RED, 'No matching boards found'))
  173. # Read the metadata from the commits. First look at the upstream commit,
  174. # then the ones in the branch. We would like to do something like
  175. # upstream/master~..branch but that isn't possible if upstream/master is
  176. # a merge commit (it will list all the commits that form part of the
  177. # merge)
  178. # Conflicting tags are not a problem for buildman, since it does not use
  179. # them. For example, Series-version is not useful for buildman. On the
  180. # other hand conflicting tags will cause an error. So allow later tags
  181. # to overwrite earlier ones by setting allow_overwrite=True
  182. if options.branch:
  183. if count == -1:
  184. if has_range:
  185. range_expr = options.branch
  186. else:
  187. range_expr = gitutil.GetRangeInBranch(options.git_dir,
  188. options.branch)
  189. upstream_commit = gitutil.GetUpstream(options.git_dir,
  190. options.branch)
  191. series = patchstream.GetMetaDataForList(upstream_commit,
  192. options.git_dir, 1, series=None, allow_overwrite=True)
  193. series = patchstream.GetMetaDataForList(range_expr,
  194. options.git_dir, None, series, allow_overwrite=True)
  195. else:
  196. # Honour the count
  197. series = patchstream.GetMetaDataForList(options.branch,
  198. options.git_dir, count, series=None, allow_overwrite=True)
  199. else:
  200. series = None
  201. options.verbose = True
  202. if not options.summary:
  203. options.show_errors = True
  204. # By default we have one thread per CPU. But if there are not enough jobs
  205. # we can have fewer threads and use a high '-j' value for make.
  206. if not options.threads:
  207. options.threads = min(multiprocessing.cpu_count(), len(selected))
  208. if not options.jobs:
  209. options.jobs = max(1, (multiprocessing.cpu_count() +
  210. len(selected) - 1) / len(selected))
  211. if not options.step:
  212. options.step = len(series.commits) - 1
  213. gnu_make = command.Output(os.path.join(options.git,
  214. 'scripts/show-gnu-make'), raise_on_error=False).rstrip()
  215. if not gnu_make:
  216. sys.exit('GNU Make not found')
  217. # Create a new builder with the selected options.
  218. output_dir = options.output_dir
  219. if options.branch:
  220. dirname = options.branch.replace('/', '_')
  221. # As a special case allow the board directory to be placed in the
  222. # output directory itself rather than any subdirectory.
  223. if not options.no_subdirs:
  224. output_dir = os.path.join(options.output_dir, dirname)
  225. if (clean_dir and output_dir != options.output_dir and
  226. os.path.exists(output_dir)):
  227. shutil.rmtree(output_dir)
  228. builder = Builder(toolchains, output_dir, options.git_dir,
  229. options.threads, options.jobs, gnu_make=gnu_make, checkout=True,
  230. show_unknown=options.show_unknown, step=options.step,
  231. no_subdirs=options.no_subdirs, full_path=options.full_path,
  232. verbose_build=options.verbose_build,
  233. incremental=options.incremental,
  234. per_board_out_dir=options.per_board_out_dir,
  235. config_only=options.config_only,
  236. squash_config_y=not options.preserve_config_y)
  237. builder.force_config_on_failure = not options.quick
  238. if make_func:
  239. builder.do_make = make_func
  240. # For a dry run, just show our actions as a sanity check
  241. if options.dry_run:
  242. ShowActions(series, why_selected, selected, builder, options)
  243. else:
  244. builder.force_build = options.force_build
  245. builder.force_build_failures = options.force_build_failures
  246. builder.force_reconfig = options.force_reconfig
  247. builder.in_tree = options.in_tree
  248. # Work out which boards to build
  249. board_selected = boards.GetSelectedDict()
  250. if series:
  251. commits = series.commits
  252. # Number the commits for test purposes
  253. for commit in range(len(commits)):
  254. commits[commit].sequence = commit
  255. else:
  256. commits = None
  257. Print(GetActionSummary(options.summary, commits, board_selected,
  258. options))
  259. # We can't show function sizes without board details at present
  260. if options.show_bloat:
  261. options.show_detail = True
  262. builder.SetDisplayOptions(options.show_errors, options.show_sizes,
  263. options.show_detail, options.show_bloat,
  264. options.list_error_boards,
  265. options.show_config)
  266. if options.summary:
  267. builder.ShowSummary(commits, board_selected)
  268. else:
  269. fail, warned = builder.BuildBoards(commits, board_selected,
  270. options.keep_outputs, options.verbose)
  271. if fail:
  272. return 128
  273. elif warned:
  274. return 129
  275. return 0