mirror of
https://git.yoctoproject.org/poky
synced 2026-02-12 19:53:03 +01:00
20f032338f
Reworks the hash equivalence server to address performance issues that were encountered with the REST mechanism used previously, particularly during the heavy request load encountered during signature generation. Notable changes are: 1) The server protocol is no longer HTTP based. Instead, it uses a simpler JSON over a streaming protocol link. This protocol has much lower overhead than HTTP since it eliminates the HTTP headers. 2) The hash equivalence server can either bind to a TCP port, or a Unix domain socket. Unix domain sockets are more efficient for local communication, and so are preferred if the user enables hash equivalence only for the local build. The arguments to the 'bitbake-hashserve' command have been updated accordingly. 3) The value to which BB_HASHSERVE should be set to enable a local hash equivalence server is changed to "auto" instead of "localhost:0". The latter didn't make sense when the local server was using a Unix domain socket. 4) Clients are expected to keep a persistent connection to the server instead of creating a new connection each time a request is made for optimal performance. 5) Most of the client logic has been moved to the hashserve module in bitbake. This makes it easier to share the client code. 6) A new bitbake command has been added called 'bitbake-hashclient'. This command can be used to query a hash equivalence server, including fetching the statistics and running a performance stress test. 7) The table indexes in the SQLite database have been updated to optimize hash lookups. This change is backward compatible, as the database will delete the old indexes first if they exist. 8) The server has been reworked to use python async to maximize performance with persistently connected clients. This requires Python 3.5 or later. (Bitbake rev: 2124eec3a5830afe8e07ffb6f2a0df6a417ac973) Signed-off-by: Joshua Watt <JPEWhacker@gmail.com> Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
404 lines
24 KiB
Python
404 lines
24 KiB
Python
#
|
|
# BitBake Tests for runqueue task processing
|
|
#
|
|
# Copyright (C) 2019 Richard Purdie
|
|
#
|
|
# SPDX-License-Identifier: GPL-2.0-only
|
|
#
|
|
|
|
import unittest
|
|
import bb
|
|
import os
|
|
import tempfile
|
|
import subprocess
|
|
import sys
|
|
|
|
#
|
|
# TODO:
|
|
# Add tests on task ordering (X happens before Y after Z)
|
|
#
|
|
|
|
class RunQueueTests(unittest.TestCase):
|
|
|
|
alltasks = ['package', 'fetch', 'unpack', 'patch', 'prepare_recipe_sysroot', 'configure',
|
|
'compile', 'install', 'packagedata', 'package_qa', 'package_write_rpm', 'package_write_ipk',
|
|
'populate_sysroot', 'build']
|
|
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"
|
|
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"
|
|
|
|
def run_bitbakecmd(self, cmd, builddir, sstatevalid="", slowtasks="", extraenv=None, cleanup=False):
|
|
env = os.environ.copy()
|
|
env["BBPATH"] = os.path.realpath(os.path.join(os.path.dirname(__file__), "runqueue-tests"))
|
|
env["BB_ENV_EXTRAWHITE"] = "SSTATEVALID SLOWTASKS"
|
|
env["SSTATEVALID"] = sstatevalid
|
|
env["SLOWTASKS"] = slowtasks
|
|
if extraenv:
|
|
for k in extraenv:
|
|
env[k] = extraenv[k]
|
|
env["BB_ENV_EXTRAWHITE"] = env["BB_ENV_EXTRAWHITE"] + " " + k
|
|
try:
|
|
output = subprocess.check_output(cmd, env=env, stderr=subprocess.STDOUT,universal_newlines=True, cwd=builddir)
|
|
print(output)
|
|
except subprocess.CalledProcessError as e:
|
|
self.fail("Command %s failed with %s" % (cmd, e.output))
|
|
tasks = []
|
|
tasklog = builddir + "/task.log"
|
|
if os.path.exists(tasklog):
|
|
with open(tasklog, "r") as f:
|
|
tasks = [line.rstrip() for line in f]
|
|
if cleanup:
|
|
os.remove(tasklog)
|
|
return tasks
|
|
|
|
def test_no_setscenevalid(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_single_setscenevalid(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
sstatevalid = "a1:do_package"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_setscene', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
|
|
'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_qa', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot', 'a1:build']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_intermediate_setscenevalid(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
sstatevalid = "a1:do_package a1:do_populate_sysroot"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_setscene', 'a1:packagedata', 'a1:package_qa', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot_setscene', 'a1:build']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_intermediate_notcovered(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
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"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
|
|
'a1:package_qa_setscene', 'a1:build', 'a1:populate_sysroot_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_all_setscenevalid(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
sstatevalid = self.a1_sstatevalid
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
|
|
'a1:package_qa_setscene', 'a1:build', 'a1:populate_sysroot_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_no_settasks(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1", "-c", "patch"]
|
|
sstatevalid = self.a1_sstatevalid
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:fetch', 'a1:unpack', 'a1:patch']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_mix_covered_notcovered(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1:do_patch", "a1:do_populate_sysroot"]
|
|
sstatevalid = self.a1_sstatevalid
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:fetch', 'a1:unpack', 'a1:patch', 'a1:populate_sysroot_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
|
|
# Test targets with intermediate setscene tasks alongside a target with no intermediate setscene tasks
|
|
def test_mixed_direct_tasks_setscene_tasks(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "c1:do_patch", "a1"]
|
|
sstatevalid = self.a1_sstatevalid
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['c1:fetch', 'c1:unpack', 'c1:patch', 'a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
|
|
'a1:package_qa_setscene', 'a1:build', 'a1:populate_sysroot_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
# This test slows down the execution of do_package_setscene until after other real tasks have
|
|
# started running which tests for a bug where tasks were being lost from the buildable list of real
|
|
# tasks if they weren't in tasks_covered or tasks_notcovered
|
|
def test_slow_setscene(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
sstatevalid = "a1:do_package"
|
|
slowtasks = "a1:package_setscene"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, slowtasks)
|
|
expected = ['a1:package_setscene', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
|
|
'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_qa', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot', 'a1:build']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_setscenewhitelist(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "a1"]
|
|
extraenv = {
|
|
"BB_SETSCENE_ENFORCE" : "1",
|
|
"BB_SETSCENE_ENFORCE_WHITELIST" : "a1:do_package_write_rpm a1:do_build"
|
|
}
|
|
sstatevalid = "a1:do_package a1:do_package_qa a1:do_packagedata a1:do_package_write_ipk a1:do_populate_lic a1:do_populate_sysroot"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv)
|
|
expected = ['a1:packagedata_setscene', 'a1:package_qa_setscene', 'a1:package_write_ipk_setscene',
|
|
'a1:populate_sysroot_setscene', 'a1:package_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
# Tests for problems with dependencies between setscene tasks
|
|
def test_no_setscenevalid_harddeps(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "d1"]
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
|
|
'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot', 'd1:package', 'd1:fetch', 'd1:unpack', 'd1:patch', 'd1:prepare_recipe_sysroot', 'd1:configure',
|
|
'd1:compile', 'd1:install', 'd1:packagedata', 'd1:package_qa', 'd1:package_write_rpm', 'd1:package_write_ipk',
|
|
'd1:populate_sysroot', 'd1:build']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_no_setscenevalid_withdeps(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "b1"]
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
|
|
expected.remove('a1:build')
|
|
expected.remove('a1:package_qa')
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_single_a1_setscenevalid_withdeps(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "b1"]
|
|
sstatevalid = "a1:do_package"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_setscene', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
|
|
'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot'] + ['b1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_single_b1_setscenevalid_withdeps(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "b1"]
|
|
sstatevalid = "b1:do_package"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package', 'a1:fetch', 'a1:unpack', 'a1:patch', 'a1:prepare_recipe_sysroot', 'a1:configure',
|
|
'a1:compile', 'a1:install', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot', 'b1:package_setscene'] + ['b1:' + x for x in self.alltasks]
|
|
expected.remove('b1:package')
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_intermediate_setscenevalid_withdeps(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "b1"]
|
|
sstatevalid = "a1:do_package a1:do_populate_sysroot b1:do_package"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_setscene', 'a1:packagedata', 'a1:package_write_rpm', 'a1:package_write_ipk',
|
|
'a1:populate_sysroot_setscene', 'b1:package_setscene'] + ['b1:' + x for x in self.alltasks]
|
|
expected.remove('b1:package')
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_all_setscenevalid_withdeps(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
cmd = ["bitbake", "b1"]
|
|
sstatevalid = self.a1_sstatevalid + " " + self.b1_sstatevalid
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid)
|
|
expected = ['a1:package_write_ipk_setscene', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
|
|
'b1:build', 'a1:populate_sysroot_setscene', 'b1:package_write_ipk_setscene', 'b1:package_write_rpm_setscene',
|
|
'b1:packagedata_setscene', 'b1:package_qa_setscene', 'b1:populate_sysroot_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
def test_multiconfig_setscene_optimise(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BBMULTICONFIG" : "mc1 mc2",
|
|
"BB_SIGNATURE_HANDLER" : "basic"
|
|
}
|
|
cmd = ["bitbake", "b1", "mc:mc1:b1", "mc:mc2:b1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks] + \
|
|
['mc1:b1:' + x for x in setscenetasks] + ['mc1:a1:' + x for x in setscenetasks] + \
|
|
['mc2:b1:' + x for x in setscenetasks] + ['mc2:a1:' + x for x in setscenetasks] + \
|
|
['mc1:b1:build', 'mc2:b1:build']
|
|
for x in ['mc1:a1:package_qa_setscene', 'mc2:a1:package_qa_setscene', 'a1:build', 'a1:package_qa']:
|
|
expected.remove(x)
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
|
|
@unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
|
|
def test_hashserv_single(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BB_HASHSERVE" : "auto",
|
|
"BB_SIGNATURE_HANDLER" : "TestEquivHash"
|
|
}
|
|
cmd = ["bitbake", "a1", "b1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
cmd = ["bitbake", "a1", "-c", "install", "-f"]
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:install']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
cmd = ["bitbake", "a1", "b1"]
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:populate_sysroot', 'a1:package', 'a1:package_write_rpm_setscene', 'a1:packagedata_setscene',
|
|
'a1:package_write_ipk_setscene', 'a1:package_qa_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
@unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
|
|
def test_hashserv_double(self):
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BB_HASHSERVE" : "auto",
|
|
"BB_SIGNATURE_HANDLER" : "TestEquivHash"
|
|
}
|
|
cmd = ["bitbake", "a1", "b1", "e1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks] + ['e1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
cmd = ["bitbake", "a1", "b1", "-c", "install", "-fn"]
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
cmd = ["bitbake", "e1"]
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
|
|
'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
|
|
'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
|
|
@unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
|
|
def test_hashserv_multiple_setscene(self):
|
|
# Runs e1:do_package_setscene twice
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BB_HASHSERVE" : "auto",
|
|
"BB_SIGNATURE_HANDLER" : "TestEquivHash"
|
|
}
|
|
cmd = ["bitbake", "a1", "b1", "e1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks] + ['e1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
cmd = ["bitbake", "a1", "b1", "-c", "install", "-fn"]
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
cmd = ["bitbake", "e1"]
|
|
sstatevalid = "e1:do_package"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True, slowtasks="a1:populate_sysroot b1:populate_sysroot")
|
|
expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
|
|
'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
|
|
'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene',
|
|
'e1:package_setscene']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
for i in expected:
|
|
if i in ["e1:package_setscene"]:
|
|
self.assertEqual(tasks.count(i), 4, "%s not in task list four times" % i)
|
|
else:
|
|
self.assertEqual(tasks.count(i), 1, "%s not in task list once" % i)
|
|
|
|
@unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
|
|
def test_hashserv_partial_match(self):
|
|
# e1:do_package matches initial built but not second hash value
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BB_HASHSERVE" : "auto",
|
|
"BB_SIGNATURE_HANDLER" : "TestEquivHash"
|
|
}
|
|
cmd = ["bitbake", "a1", "b1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
with open(tempdir + "/stamps/a1.do_install.taint", "w") as f:
|
|
f.write("d460a29e-903f-4b76-a96b-3bcc22a65994")
|
|
with open(tempdir + "/stamps/b1.do_install.taint", "w") as f:
|
|
f.write("ed36d46a-2977-458a-b3de-eef885bc1817")
|
|
cmd = ["bitbake", "e1"]
|
|
sstatevalid = "e1:do_package:685e69a026b2f029483fdefe6a11e1e06641dd2a0f6f86e27b9b550f8f21229d"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
|
|
'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
|
|
'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene',
|
|
'e1:package_setscene'] + ['e1:' + x for x in self.alltasks]
|
|
expected.remove('e1:package')
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
@unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
|
|
def test_hashserv_partial_match2(self):
|
|
# e1:do_package + e1:do_populate_sysroot matches initial built but not second hash value
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BB_HASHSERVE" : "auto",
|
|
"BB_SIGNATURE_HANDLER" : "TestEquivHash"
|
|
}
|
|
cmd = ["bitbake", "a1", "b1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
with open(tempdir + "/stamps/a1.do_install.taint", "w") as f:
|
|
f.write("d460a29e-903f-4b76-a96b-3bcc22a65994")
|
|
with open(tempdir + "/stamps/b1.do_install.taint", "w") as f:
|
|
f.write("ed36d46a-2977-458a-b3de-eef885bc1817")
|
|
cmd = ["bitbake", "e1"]
|
|
sstatevalid = "e1:do_package:685e69a026b2f029483fdefe6a11e1e06641dd2a0f6f86e27b9b550f8f21229d e1:do_populate_sysroot:ef7dc0e2dd55d0534e75cba50731ff42f949818b6f29a65d72bc05856e56711d"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
|
|
'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
|
|
'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene',
|
|
'e1:package_setscene', 'e1:populate_sysroot_setscene', 'e1:build', 'e1:package_qa', 'e1:package_write_rpm', 'e1:package_write_ipk', 'e1:packagedata']
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
@unittest.skipIf(sys.version_info < (3, 5, 0), 'Python 3.5 or later required')
|
|
def test_hashserv_partial_match3(self):
|
|
# e1:do_package is valid for a1 but not after b1
|
|
# In former buggy code, this triggered e1:do_fetch, then e1:do_populate_sysroot to run
|
|
# with none of the intermediate tasks which is a serious bug
|
|
with tempfile.TemporaryDirectory(prefix="runqueuetest") as tempdir:
|
|
extraenv = {
|
|
"BB_HASHSERVE" : "auto",
|
|
"BB_SIGNATURE_HANDLER" : "TestEquivHash"
|
|
}
|
|
cmd = ["bitbake", "a1", "b1"]
|
|
setscenetasks = ['package_write_ipk_setscene', 'package_write_rpm_setscene', 'packagedata_setscene',
|
|
'populate_sysroot_setscene', 'package_qa_setscene']
|
|
sstatevalid = ""
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True)
|
|
expected = ['a1:' + x for x in self.alltasks] + ['b1:' + x for x in self.alltasks]
|
|
self.assertEqual(set(tasks), set(expected))
|
|
with open(tempdir + "/stamps/a1.do_install.taint", "w") as f:
|
|
f.write("d460a29e-903f-4b76-a96b-3bcc22a65994")
|
|
with open(tempdir + "/stamps/b1.do_install.taint", "w") as f:
|
|
f.write("ed36d46a-2977-458a-b3de-eef885bc1817")
|
|
cmd = ["bitbake", "e1", "-DD"]
|
|
sstatevalid = "e1:do_package:af056eae12a733a6a8c4f4da8c6757e588e13565852c94e2aad4d953a3989c13 e1:do_package:a3677703db82b22d28d57c1820a47851dd780104580863f5bd32e66e003a779d"
|
|
tasks = self.run_bitbakecmd(cmd, tempdir, sstatevalid, extraenv=extraenv, cleanup=True, slowtasks="e1:fetch b1:install")
|
|
expected = ['a1:package', 'a1:install', 'b1:package', 'b1:install', 'a1:populate_sysroot', 'b1:populate_sysroot',
|
|
'a1:package_write_ipk_setscene', 'b1:packagedata_setscene', 'b1:package_write_rpm_setscene',
|
|
'a1:package_write_rpm_setscene', 'b1:package_write_ipk_setscene', 'a1:packagedata_setscene',
|
|
'e1:package_setscene'] + ['e1:' + x for x in self.alltasks]
|
|
expected.remove('e1:package')
|
|
self.assertEqual(set(tasks), set(expected))
|
|
|
|
|