control.py 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299
  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. options.git_dir = os.path.join(options.git, '.git')
  100. if not toolchains:
  101. toolchains = toolchain.Toolchains()
  102. toolchains.GetSettings()
  103. toolchains.Scan(options.list_tool_chains)
  104. if options.list_tool_chains:
  105. toolchains.List()
  106. print
  107. return 0
  108. if options.fetch_arch:
  109. if options.fetch_arch == 'list':
  110. sorted_list = toolchains.ListArchs()
  111. print 'Available architectures: %s\n' % ' '.join(sorted_list)
  112. return 0
  113. else:
  114. fetch_arch = options.fetch_arch
  115. if fetch_arch == 'all':
  116. fetch_arch = ','.join(toolchains.ListArchs())
  117. print 'Downloading toolchains: %s\n' % fetch_arch
  118. for arch in fetch_arch.split(','):
  119. ret = toolchains.FetchAndInstall(arch)
  120. if ret:
  121. return ret
  122. return 0
  123. # Work out how many commits to build. We want to build everything on the
  124. # branch. We also build the upstream commit as a control so we can see
  125. # problems introduced by the first commit on the branch.
  126. col = terminal.Color()
  127. count = options.count
  128. has_range = options.branch and '..' in options.branch
  129. if count == -1:
  130. if not options.branch:
  131. count = 1
  132. else:
  133. if has_range:
  134. count, msg = gitutil.CountCommitsInRange(options.git_dir,
  135. options.branch)
  136. else:
  137. count, msg = gitutil.CountCommitsInBranch(options.git_dir,
  138. options.branch)
  139. if count is None:
  140. sys.exit(col.Color(col.RED, msg))
  141. elif count == 0:
  142. sys.exit(col.Color(col.RED, "Range '%s' has no commits" %
  143. options.branch))
  144. if msg:
  145. print col.Color(col.YELLOW, msg)
  146. count += 1 # Build upstream commit also
  147. if not count:
  148. str = ("No commits found to process in branch '%s': "
  149. "set branch's upstream or use -c flag" % options.branch)
  150. sys.exit(col.Color(col.RED, str))
  151. # Work out what subset of the boards we are building
  152. if not boards:
  153. board_file = os.path.join(options.git, 'boards.cfg')
  154. status = subprocess.call([os.path.join(options.git,
  155. 'tools/genboardscfg.py')])
  156. if status != 0:
  157. sys.exit("Failed to generate boards.cfg")
  158. boards = board.Boards()
  159. boards.ReadBoards(os.path.join(options.git, 'boards.cfg'))
  160. exclude = []
  161. if options.exclude:
  162. for arg in options.exclude:
  163. exclude += arg.split(',')
  164. why_selected = boards.SelectBoards(args, exclude)
  165. selected = boards.GetSelected()
  166. if not len(selected):
  167. sys.exit(col.Color(col.RED, 'No matching boards found'))
  168. # Read the metadata from the commits. First look at the upstream commit,
  169. # then the ones in the branch. We would like to do something like
  170. # upstream/master~..branch but that isn't possible if upstream/master is
  171. # a merge commit (it will list all the commits that form part of the
  172. # merge)
  173. # Conflicting tags are not a problem for buildman, since it does not use
  174. # them. For example, Series-version is not useful for buildman. On the
  175. # other hand conflicting tags will cause an error. So allow later tags
  176. # to overwrite earlier ones by setting allow_overwrite=True
  177. if options.branch:
  178. if count == -1:
  179. if has_range:
  180. range_expr = options.branch
  181. else:
  182. range_expr = gitutil.GetRangeInBranch(options.git_dir,
  183. options.branch)
  184. upstream_commit = gitutil.GetUpstream(options.git_dir,
  185. options.branch)
  186. series = patchstream.GetMetaDataForList(upstream_commit,
  187. options.git_dir, 1, series=None, allow_overwrite=True)
  188. series = patchstream.GetMetaDataForList(range_expr,
  189. options.git_dir, None, series, allow_overwrite=True)
  190. else:
  191. # Honour the count
  192. series = patchstream.GetMetaDataForList(options.branch,
  193. options.git_dir, count, series=None, allow_overwrite=True)
  194. else:
  195. series = None
  196. options.verbose = True
  197. if not options.summary:
  198. options.show_errors = True
  199. # By default we have one thread per CPU. But if there are not enough jobs
  200. # we can have fewer threads and use a high '-j' value for make.
  201. if not options.threads:
  202. options.threads = min(multiprocessing.cpu_count(), len(selected))
  203. if not options.jobs:
  204. options.jobs = max(1, (multiprocessing.cpu_count() +
  205. len(selected) - 1) / len(selected))
  206. if not options.step:
  207. options.step = len(series.commits) - 1
  208. gnu_make = command.Output(os.path.join(options.git,
  209. 'scripts/show-gnu-make')).rstrip()
  210. if not gnu_make:
  211. sys.exit('GNU Make not found')
  212. # Create a new builder with the selected options.
  213. output_dir = options.output_dir
  214. if options.branch:
  215. dirname = options.branch.replace('/', '_')
  216. # As a special case allow the board directory to be placed in the
  217. # output directory itself rather than any subdirectory.
  218. if not options.no_subdirs:
  219. output_dir = os.path.join(options.output_dir, dirname)
  220. if (clean_dir and output_dir != options.output_dir and
  221. os.path.exists(output_dir)):
  222. shutil.rmtree(output_dir)
  223. builder = Builder(toolchains, output_dir, options.git_dir,
  224. options.threads, options.jobs, gnu_make=gnu_make, checkout=True,
  225. show_unknown=options.show_unknown, step=options.step,
  226. no_subdirs=options.no_subdirs, full_path=options.full_path,
  227. verbose_build=options.verbose_build,
  228. incremental=options.incremental,
  229. per_board_out_dir=options.per_board_out_dir,)
  230. builder.force_config_on_failure = not options.quick
  231. if make_func:
  232. builder.do_make = make_func
  233. # For a dry run, just show our actions as a sanity check
  234. if options.dry_run:
  235. ShowActions(series, why_selected, selected, builder, options)
  236. else:
  237. builder.force_build = options.force_build
  238. builder.force_build_failures = options.force_build_failures
  239. builder.force_reconfig = options.force_reconfig
  240. builder.in_tree = options.in_tree
  241. # Work out which boards to build
  242. board_selected = boards.GetSelectedDict()
  243. if series:
  244. commits = series.commits
  245. # Number the commits for test purposes
  246. for commit in range(len(commits)):
  247. commits[commit].sequence = commit
  248. else:
  249. commits = None
  250. Print(GetActionSummary(options.summary, commits, board_selected,
  251. options))
  252. # We can't show function sizes without board details at present
  253. if options.show_bloat:
  254. options.show_detail = True
  255. builder.SetDisplayOptions(options.show_errors, options.show_sizes,
  256. options.show_detail, options.show_bloat,
  257. options.list_error_boards,
  258. options.show_config)
  259. if options.summary:
  260. builder.ShowSummary(commits, board_selected)
  261. else:
  262. fail, warned = builder.BuildBoards(commits, board_selected,
  263. options.keep_outputs, options.verbose)
  264. if fail:
  265. return 128
  266. elif warned:
  267. return 129
  268. return 0