summaryrefslogtreecommitdiff
path: root/spec/test_jobs.lua
diff options
context:
space:
mode:
Diffstat (limited to 'spec/test_jobs.lua')
-rw-r--r--spec/test_jobs.lua20
1 files changed, 20 insertions, 0 deletions
diff --git a/spec/test_jobs.lua b/spec/test_jobs.lua
index e6ce097..ce0525c 100644
--- a/spec/test_jobs.lua
+++ b/spec/test_jobs.lua
@@ -233,6 +233,26 @@ return {
end)
end },
+ -- close() joins the pump, and a pump parked in a tool batch needs the owner
+ -- thread — the thread close_all itself runs on. So an unsettled job is never
+ -- closed here; it is cancelled, and the drain that sees it settle closes it.
+ { "close_all leaves an unsettled job to close on its own settle", function()
+ with_jobs(function()
+ local start, _, made = starter()
+ local handle = assert(start("alpha", { settle = 99 }))
+
+ jobs.close_all()
+ assert(made.alpha._cancel_requested, "close_all asks a running child to stop")
+ assert(not made.alpha._closed, "close_all must not join a pump that is still up")
+ assert(handle:result() == nil, "close_all does not settle the child itself")
+
+ local results = jobs.await({ handle }, "all")
+ assert(results[1].status == "cancelled", tostring(results[1].status))
+ assert(made.alpha._closed, "the job closes as soon as it settles")
+ assert(handle:result().status == "cancelled", "the result is cached before the close")
+ end)
+ end },
+
{ "a build failure is a nil return, never an exception", function()
with_jobs(function()
local start = starter()