oss/luanti
oss/luanti
1
0
Fork 0
mirror of https://github.com/luanti-org/luanti.git synced 2025-07-02 16:38:41 +00:00
Code Wiki Activity

Use IPC to unblock async

Browse source
This commit is contained in:
y5nw 2024-11-22 15:45:20 +01:00
parent 1c05dd067e
commit 9c77b2afae
1 changed files with 9 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

17
games/devtest/mods/unittests/async_env.lua
View file

@ -208,20 +208,20 @@ local function test_vector_preserve(cb)
end end
unittests.register("test_async_vector", test_vector_preserve, {async=true}) unittests.register("test_async_vector", test_vector_preserve, {async=true})
-- FIXME: this code is racy and can be improved once Lua IPC is supported local function test_async_job_replacement(cb)
local function fill_async()
local capacity = core.get_async_threading_capacity() local capacity = core.get_async_threading_capacity()
local running = capacity
for _ = 1, capacity do for _ = 1, capacity do
core.handle_async(function() core.handle_async(function()
local t = core.get_us_time() local t = core.get_us_time()
while core.get_us_time() < t + 100000 do core.ipc_poll("unittests:end_blocking", 100)
end, function()
running = running - 1
if running <= 0 then
core.ipc_set("unittests:end_blocking", nil)
end end
end, function() end) end)
end end
end
local function test_async_job_replacement(cb)
fill_async()
local job = core.handle_async(function(x) local job = core.handle_async(function(x)
return x return x
end, function() end, function()
@ -230,6 +230,7 @@ local function test_async_job_replacement(cb)
if not job:cancel() then if not job:cancel() then
return cb("AsyncJob:cancel sanity check failed") return cb("AsyncJob:cancel sanity check failed")
end end
core.ipc_set("unittests:end_blocking", true)
-- Try to cancel a job that is already run. -- Try to cancel a job that is already run.
job = core.handle_async(function(x) job = core.handle_async(function(x)