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
|
import("async.jobgraph")
local function dummy_job() end
function test_group_bridge_reuse(t)
local jobs = jobgraph.new()
jobs:group("foo", function ()
jobs:add("foo/1", dummy_job)
jobs:add("foo/2", dummy_job)
end)
jobs:group("bar", function ()
jobs:add("bar/1", dummy_job)
end)
jobs:add_orders("foo", "bar")
local vertices_before = #jobs._dag:vertices()
jobs:add_orders("foo", "bar")
local vertices_after = #jobs._dag:vertices()
t:are_equal(vertices_before, vertices_after)
end
function test_group_bridge_updates_with_new_job(t)
local jobs = jobgraph.new()
jobs:group("foo", function ()
jobs:add("foo/1", dummy_job)
end)
jobs:group("bar", function ()
jobs:add("bar/1", dummy_job)
end)
jobs:add_orders("foo", "bar")
jobs:group("foo", function ()
jobs:add("foo/2", dummy_job)
end)
local queue = jobs:build()
local first = queue:getfree()
t:require(first.name == "foo/1" or first.name == "foo/2")
queue:remove(first)
local second = queue:getfree()
t:require(second.name == "foo/1" or second.name == "foo/2")
t:require(second.name ~= first.name)
queue:remove(second)
local third = queue:getfree()
t:are_equal(third.name, "bar/1")
end
|
