runqueue.py 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367
  1. #
  2. # BitBake Tests for runqueue task processing
  3. #
  4. # Copyright (C) 2019 Richard Purdie
  5. #
  6. # SPDX-License-Identifier: GPL-2.0-only
  7. #
  8. import unittest
  9. import os
  10. import tempfile
  11. import subprocess
  12. import sys
  13. import time
  14. #
  15. # TODO:
  16. # Add tests on task ordering (X happens before Y after Z)
  17. #
  18. class RunQueueTests(unittest.TestCase):
  19. alltasks = ['package', 'fetch', 'unpack', 'patch', 'prepare_recipe_sysroot', 'configure',
  20. 'compile', 'install', 'packagedata', 'package_qa', 'package_write_rpm', 'package_write_ipk',
  21. 'populate_sysroot', 'build']
  22. a1_sstatevalid = "a1:do_package a1:do_package_qa a1:do_packagedata a1:do_package_write_ipk a1:do_package_write_rpm a1:do_populate_lic a1:do_populate_sysroot"
  23. b1_sstatevalid = "b1:do_package b1:do_package_qa b1:do_packagedata b1:do_package_write_ipk b1:do_package_write_rpm b1:do_populate_lic b1:do_populate_sysroot"
  24. def run_bitbakecmd(self, cmd, builddir, sstatevalid="", slowtasks="", extraenv=None, cleanup=False):
  25. env = os.environ.copy()
  26. env["BBPATH"] = os.path.realpath(os.path.join(os.path.dirname(__file__), "runqueue-tests"))
  27. env["BB_ENV_EXTRAWHITE"] = "SSTATEVALID SLOWTASKS"
  28. env["SSTATEVALID"] = sstatevalid
  29. env["SLOWTASKS"] = slowtasks
  30. if extraenv:
  31. for k in extraenv:
  32. env[k] = extraenv[k]
  33. env["BB_ENV_EXTRAWHITE"] = env["BB_ENV_EXTRAWHITE"] + " " + k
  34. try:
  35. output = subprocess.check_output(cmd, env=env, stderr=subprocess.STDOUT,universal_newlines=True, cwd=builddir)
  36. print(output)
  37. except subprocess.CalledProcessError as e:
  38. self.fail("Command %s failed with %s" % (cmd, e.output))
  39. tasks = []
  40. tasklog = builddir + "/task.log"
  41. if os.path.exists(tasklog):
  42. with open(tasklog, "r") as f:
  43. tasks = [line.rstrip() for line in f]
  44. if cleanup:
  45. os.remove(tasklog)
  46. return tasks
  47. def test_no_setscenevalid(self):
  48. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  49. cmd = ["bitbake", "a1"]
  50. sstatevalid = ""
  51. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  52. expected = ['a1:' + x for x in self.alltasks]
  53. self.assertEqual(set(tasks), set(expected))
  54. def test_single_setscenevalid(self):
  55. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  56. cmd = ["bitbake", "a1"]
  57. sstatevalid = "a1:do_package"
  58. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  59. expected = ['a1:package_setscene', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
  60. 'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_qa', 'a1:package_write_rpm', 'a1:package_write_ipk',
  61. 'a1:populate_sysroot', 'a1:build']
  62. self.assertEqual(set(tasks), set(expected))
  63. def test_intermediate_setscenevalid(self):
  64. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  65. cmd = ["bitbake", "a1"]
  66. sstatevalid = "a1:do_package a1:do_populate_sysroot"
  67. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  68. expected = ['a1:package_setscene', 'a1:packagedata', 'a1:package_qa', 'a1:package_write_rpm', 'a1:package_write_ipk',
  69. 'a1:populate_sysroot_setscene', 'a1:build']
  70. self.assertEqual(set(tasks), set(expected))
  71. def test_intermediate_notcovered(self):
  72. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  73. cmd = ["bitbake", "a1"]
  74. sstatevalid = "a1:do_package_qa a1:do_packagedata a1:do_package_write_ipk a1:do_package_write_rpm a1:do_populate_lic a1:do_populate_sysroot"
  75. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  76. expected = ['a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
  77. 'a1:package_qa_setscene', 'a1:build', 'a1:populate_sysroot_setscene']
  78. self.assertEqual(set(tasks), set(expected))
  79. def test_all_setscenevalid(self):
  80. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  81. cmd = ["bitbake", "a1"]
  82. sstatevalid = self.a1_sstatevalid
  83. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  84. expected = ['a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
  85. 'a1:package_qa_setscene', 'a1:build', 'a1:populate_sysroot_setscene']
  86. self.assertEqual(set(tasks), set(expected))
  87. def test_no_settasks(self):
  88. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  89. cmd = ["bitbake", "a1", "-c", "patch"]
  90. sstatevalid = self.a1_sstatevalid
  91. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  92. expected = ['a1:fetch', 'a1:unpack', 'a1:patch']
  93. self.assertEqual(set(tasks), set(expected))
  94. def test_mix_covered_notcovered(self):
  95. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  96. cmd = ["bitbake", "a1:do_patch", "a1:do_populate_sysroot"]
  97. sstatevalid = self.a1_sstatevalid
  98. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  99. expected = ['a1:fetch', 'a1:unpack', 'a1:patch', 'a1:populate_sysroot_setscene']
  100. self.assertEqual(set(tasks), set(expected))
  101. # Test targets with intermediate setscene tasks alongside a target with no intermediate setscene tasks
  102. def test_mixed_direct_tasks_setscene_tasks(self):
  103. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  104. cmd = ["bitbake", "c1:do_patch", "a1"]
  105. sstatevalid = self.a1_sstatevalid
  106. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  107. expected = ['c1:fetch', 'c1:unpack', 'c1:patch', 'a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
  108. 'a1:package_qa_setscene', 'a1:build', 'a1:populate_sysroot_setscene']
  109. self.assertEqual(set(tasks), set(expected))
  110. # This test slows down the execution of do_package_setscene until after other real tasks have
  111. # started running which tests for a bug where tasks were being lost from the buildable list of real
  112. # tasks if they weren't in tasks_covered or tasks_notcovered
  113. def test_slow_setscene(self):
  114. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  115. cmd = ["bitbake", "a1"]
  116. sstatevalid = "a1:do_package"
  117. slowtasks = "a1:package_setscene"
  118. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, slowtasks)
  119. expected = ['a1:package_setscene', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
  120. 'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_qa', 'a1:package_write_rpm', 'a1:package_write_ipk',
  121. 'a1:populate_sysroot', 'a1:build']
  122. self.assertEqual(set(tasks), set(expected))
  123. def test_setscenewhitelist(self):
  124. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  125. cmd = ["bitbake", "a1"]
  126. extraenv = {
  127. "BB_SETSCENE_ENFORCE" : "1",
  128. "BB_SETSCENE_ENFORCE_WHITELIST" : "a1:do_package_write_rpm a1:do_build"
  129. }
  130. sstatevalid = "a1:do_package a1:do_package_qa a1:do_packagedata a1:do_package_write_ipk a1:do_populate_lic a1:do_populate_sysroot"
  131. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv)
  132. expected = ['a1:packagedata_setscene', 'a1:package_qa_setscene', 'a1:package_write_ipk_setscene',
  133. 'a1:populate_sysroot_setscene', 'a1:package_setscene']
  134. self.assertEqual(set(tasks), set(expected))
  135. # Tests for problems with dependencies between setscene tasks
  136. def test_no_setscenevalid_harddeps(self):
  137. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  138. cmd = ["bitbake", "d1"]
  139. sstatevalid = ""
  140. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  141. expected = ['a1:package', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
  142. 'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
  143. 'a1:populate_sysroot', 'd1:package', 'd1:fetch', 'd1:unpack', 'd1:patch', 'd1:prepare_recipe_sysroot', 'd1:configure',
  144. 'd1:compile', 'd1:install', 'd1:packagedata', 'd1:package_qa', 'd1:package_write_rpm', 'd1:package_write_ipk',
  145. 'd1:populate_sysroot', 'd1:build']
  146. self.assertEqual(set(tasks), set(expected))
  147. def test_no_setscenevalid_withdeps(self):
  148. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  149. cmd = ["bitbake", "b1"]
  150. sstatevalid = ""
  151. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  152. expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
  153. expected.remove('a1:build')
  154. expected.remove('a1:package_qa')
  155. self.assertEqual(set(tasks), set(expected))
  156. def test_single_a1_setscenevalid_withdeps(self):
  157. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  158. cmd = ["bitbake", "b1"]
  159. sstatevalid = "a1:do_package"
  160. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  161. expected = ['a1:package_setscene', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
  162. 'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
  163. 'a1:populate_sysroot'] + ['b1:' + x for x in self.alltasks]
  164. self.assertEqual(set(tasks), set(expected))
  165. def test_single_b1_setscenevalid_withdeps(self):
  166. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  167. cmd = ["bitbake", "b1"]
  168. sstatevalid = "b1:do_package"
  169. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  170. expected = ['a1:package', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
  171. 'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
  172. 'a1:populate_sysroot', 'b1:package_setscene'] + ['b1:' + x for x in self.alltasks]
  173. expected.remove('b1:package')
  174. self.assertEqual(set(tasks), set(expected))
  175. def test_intermediate_setscenevalid_withdeps(self):
  176. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  177. cmd = ["bitbake", "b1"]
  178. sstatevalid = "a1:do_package a1:do_populate_sysroot b1:do_package"
  179. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  180. expected = ['a1:package_setscene', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
  181. 'a1:populate_sysroot_setscene', 'b1:package_setscene'] + ['b1:' + x for x in self.alltasks]
  182. expected.remove('b1:package')
  183. self.assertEqual(set(tasks), set(expected))
  184. def test_all_setscenevalid_withdeps(self):
  185. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  186. cmd = ["bitbake", "b1"]
  187. sstatevalid = self.a1_sstatevalid + " " + self.b1_sstatevalid
  188. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
  189. expected = ['a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
  190. 'b1:build', 'a1:populate_sysroot_setscene', 'b1:package_write_ipk_setscene', 'b1:package_write_rpm_setscene',
  191. 'b1:packagedata_setscene', 'b1:package_qa_setscene', 'b1:populate_sysroot_setscene']
  192. self.assertEqual(set(tasks), set(expected))
  193. def test_multiconfig_setscene_optimise(self):
  194. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  195. extraenv = {
  196. "BBMULTICONFIG" : "mc1 mc2",
  197. "BB_SIGNATURE_HANDLER" : "basic"
  198. }
  199. cmd = ["bitbake", "b1", "mc:mc1:b1", "mc:mc2:b1"]
  200. setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
  201. 'populate_sysroot_setscene', 'package_qa_setscene']
  202. sstatevalid = ""
  203. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv)
  204. expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks] + \
  205. ['mc1:b1:' + x for x in setscenetasks] + ['mc1:a1:' + x for x in setscenetasks] + \
  206. ['mc2:b1:' + x for x in setscenetasks] + ['mc2:a1:' + x for x in setscenetasks] + \
  207. ['mc1:b1:build', 'mc2:b1:build']
  208. for x in ['mc1:a1:package_qa_setscene', 'mc2:a1:package_qa_setscene', 'a1:build', 'a1:package_qa']:
  209. expected.remove(x)
  210. self.assertEqual(set(tasks), set(expected))
  211. def test_multiconfig_bbmask(self):
  212. # This test validates that multiconfigs can independently mask off
  213. # recipes they do not want with BBMASK. It works by having recipes
  214. # that will fail to parse for mc1 and mc2, then making each multiconfig
  215. # build the one that does parse. This ensures that the recipes are in
  216. # each multiconfigs BBFILES, but each is masking only the one that
  217. # doesn't parse
  218. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  219. extraenv = {
  220. "BBMULTICONFIG" : "mc1 mc2",
  221. "BB_SIGNATURE_HANDLER" : "basic",
  222. "EXTRA_BBFILES": "${COREBASE}/recipes/fails-mc/*.bb",
  223. }
  224. cmd = ["bitbake", "mc:mc1:fails-mc2", "mc:mc2:fails-mc1"]
  225. self.run_bitbakecmd(cmd, tempdir, "", extraenv=extraenv)
  226. def test_multiconfig_mcdepends(self):
  227. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  228. extraenv = {
  229. "BBMULTICONFIG" : "mc1 mc2",
  230. "BB_SIGNATURE_HANDLER" : "TestMulticonfigDepends",
  231. "EXTRA_BBFILES": "${COREBASE}/recipes/fails-mc/*.bb",
  232. }
  233. tasks = self.run_bitbakecmd(["bitbake", "mc:mc1:f1"], tempdir, "", extraenv=extraenv, cleanup=True)
  234. expected = ["mc1:f1:%s" % t for t in self.alltasks] + \
  235. ["mc2:a1:%s" % t for t in self.alltasks]
  236. self.assertEqual(set(tasks), set(expected))
  237. # A rebuild does nothing
  238. tasks = self.run_bitbakecmd(["bitbake", "mc:mc1:f1"], tempdir, "", extraenv=extraenv, cleanup=True)
  239. self.assertEqual(set(tasks), set())
  240. # Test that a signature change in the dependent task causes
  241. # mcdepends to rebuild
  242. tasks = self.run_bitbakecmd(["bitbake", "mc:mc2:a1", "-c", "compile", "-f"], tempdir, "", extraenv=extraenv, cleanup=True)
  243. expected = ["mc2:a1:compile"]
  244. self.assertEqual(set(tasks), set(expected))
  245. rerun_tasks = self.alltasks[:]
  246. for x in ("fetch", "unpack", "patch", "prepare_recipe_sysroot", "configure", "compile"):
  247. rerun_tasks.remove(x)
  248. tasks = self.run_bitbakecmd(["bitbake", "mc:mc1:f1"], tempdir, "", extraenv=extraenv, cleanup=True)
  249. expected = ["mc1:f1:%s" % t for t in rerun_tasks] + \
  250. ["mc2:a1:%s" % t for t in rerun_tasks]
  251. self.assertEqual(set(tasks), set(expected))
  252. @unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
  253. def test_hashserv_single(self):
  254. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  255. extraenv = {
  256. "BB_HASHSERVE" : "auto",
  257. "BB_SIGNATURE_HANDLER" : "TestEquivHash"
  258. }
  259. cmd = ["bitbake", "a1", "b1"]
  260. setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
  261. 'populate_sysroot_setscene', 'package_qa_setscene']
  262. sstatevalid = ""
  263. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  264. expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
  265. self.assertEqual(set(tasks), set(expected))
  266. cmd = ["bitbake", "a1", "-c", "install", "-f"]
  267. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  268. expected = ['a1:install']
  269. self.assertEqual(set(tasks), set(expected))
  270. cmd = ["bitbake", "a1", "b1"]
  271. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  272. expected = ['a1:populate_sysroot', 'a1:package', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
  273. 'a1:package_write_ipk_setscene', 'a1:package_qa_setscene', 'a1:build']
  274. self.assertEqual(set(tasks), set(expected))
  275. self.shutdown(tempdir)
  276. @unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
  277. def test_hashserv_double(self):
  278. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  279. extraenv = {
  280. "BB_HASHSERVE" : "auto",
  281. "BB_SIGNATURE_HANDLER" : "TestEquivHash"
  282. }
  283. cmd = ["bitbake", "a1", "b1", "e1"]
  284. setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
  285. 'populate_sysroot_setscene', 'package_qa_setscene']
  286. sstatevalid = ""
  287. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  288. expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks] + ['e1:' + x for x in self.alltasks]
  289. self.assertEqual(set(tasks), set(expected))
  290. cmd = ["bitbake", "a1", "b1", "-c", "install", "-fn"]
  291. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  292. cmd = ["bitbake", "e1"]
  293. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  294. expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
  295. 'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
  296. 'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene']
  297. self.assertEqual(set(tasks), set(expected))
  298. self.shutdown(tempdir)
  299. @unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
  300. def test_hashserv_multiple_setscene(self):
  301. # Runs e1:do_package_setscene twice
  302. with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
  303. extraenv = {
  304. "BB_HASHSERVE" : "auto",
  305. "BB_SIGNATURE_HANDLER" : "TestEquivHash"
  306. }
  307. cmd = ["bitbake", "a1", "b1", "e1"]
  308. setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
  309. 'populate_sysroot_setscene', 'package_qa_setscene']
  310. sstatevalid = ""
  311. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  312. expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks] + ['e1:' + x for x in self.alltasks]
  313. self.assertEqual(set(tasks), set(expected))
  314. cmd = ["bitbake", "a1", "b1", "-c", "install", "-fn"]
  315. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
  316. cmd = ["bitbake", "e1"]
  317. sstatevalid = "e1:do_package"
  318. tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True, slowtasks="a1:populate_sysroot b1:populate_sysroot")
  319. expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
  320. 'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
  321. 'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene',
  322. 'e1:package_setscene']
  323. self.assertEqual(set(tasks), set(expected))
  324. for i in expected:
  325. self.assertEqual(tasks.count(i), 1, "%s not in task list once" % i)
  326. self.shutdown(tempdir)
  327. def shutdown(self, tempdir):
  328. # Wait for the hashserve socket to disappear else we'll see races with the tempdir cleanup
  329. while os.path.exists(tempdir + "/hashserve.sock"):
  330. time.sleep(0.5)