aboutsummaryrefslogtreecommitdiff
path: root/unit_tests/scripts/lane/tasking_cancelling.lua
diff options
context:
space:
mode:
authorBenoit Germain <benoit.germain@ubisoft.com>2025-03-14 14:53:09 +0100
committerBenoit Germain <benoit.germain@ubisoft.com>2025-03-14 14:53:09 +0100
commit512f4c0b46ea5cc359e673b7379cd81925863121 (patch)
tree1e72167d8d63f44109719db9643d4c0445b17d57 /unit_tests/scripts/lane/tasking_cancelling.lua
parent0aa030db022c57947afbae3b97038a403973e3cd (diff)
downloadlanes-master.tar.gz
lanes-master.tar.bz2
lanes-master.zip
Give a name to all lanes in the testsHEADmaster
Diffstat (limited to 'unit_tests/scripts/lane/tasking_cancelling.lua')
-rw-r--r--unit_tests/scripts/lane/tasking_cancelling.lua8
1 files changed, 4 insertions, 4 deletions
diff --git a/unit_tests/scripts/lane/tasking_cancelling.lua b/unit_tests/scripts/lane/tasking_cancelling.lua
index a4e0fde..85600ab 100644
--- a/unit_tests/scripts/lane/tasking_cancelling.lua
+++ b/unit_tests/scripts/lane/tasking_cancelling.lua
@@ -36,7 +36,7 @@ end
36 36
37PRINT("\n\n", "---=== Tasking (cancelling) ===---", "\n\n") 37PRINT("\n\n", "---=== Tasking (cancelling) ===---", "\n\n")
38 38
39local task_launch2 = lanes_gen("", { globals={hey=true}, gc_cb = gc_cb}, task) 39local task_launch2 = lanes_gen("", { name = 'auto', globals={hey=true}, gc_cb = gc_cb }, task)
40 40
41local N=999999999 41local N=999999999
42local lane9= task_launch2(1,N,1) -- huuuuuuge... 42local lane9= task_launch2(1,N,1) -- huuuuuuge...
@@ -87,7 +87,7 @@ local wait_send = function()
87 a,b = limited:send("key", "bybye") -- infinite timeout, returns only when lane is cancelled 87 a,b = limited:send("key", "bybye") -- infinite timeout, returns only when lane is cancelled
88end 88end
89 89
90local wait_send_lane = lanes.gen("*", wait_send)() 90local wait_send_lane = lanes_gen("*", { name = 'auto' }, wait_send)()
91repeat until wait_send_lane.status == "waiting" 91repeat until wait_send_lane.status == "waiting"
92print "wait_send_lane is waiting" 92print "wait_send_lane is waiting"
93wait_send_lane:cancel() -- hard cancel, 0 timeout 93wait_send_lane:cancel() -- hard cancel, 0 timeout
@@ -100,7 +100,7 @@ local wait_receive = function()
100 k, v = limited:receive("dummy") -- infinite timeout, returns only when lane is cancelled 100 k, v = limited:receive("dummy") -- infinite timeout, returns only when lane is cancelled
101end 101end
102 102
103local wait_receive_lane = lanes.gen("*", wait_receive)() 103local wait_receive_lane = lanes_gen("*", { name = 'auto' }, wait_receive)()
104repeat until wait_receive_lane.status == "waiting" 104repeat until wait_receive_lane.status == "waiting"
105print "wait_receive_lane is waiting" 105print "wait_receive_lane is waiting"
106wait_receive_lane:cancel() -- hard cancel, 0 timeout 106wait_receive_lane:cancel() -- hard cancel, 0 timeout
@@ -113,7 +113,7 @@ local wait_receive_batched = function()
113 k, v1, v2 = limited:receive(limited.batched, "dummy", 2) -- infinite timeout, returns only when lane is cancelled 113 k, v1, v2 = limited:receive(limited.batched, "dummy", 2) -- infinite timeout, returns only when lane is cancelled
114end 114end
115 115
116local wait_receive_batched_lane = lanes.gen("*", wait_receive_batched)() 116local wait_receive_batched_lane = lanes_gen("*", { name = 'auto' }, wait_receive_batched)()
117repeat until wait_receive_batched_lane.status == "waiting" 117repeat until wait_receive_batched_lane.status == "waiting"
118print "wait_receive_batched_lane is waiting" 118print "wait_receive_batched_lane is waiting"
119wait_receive_batched_lane:cancel() -- hard cancel, 0 timeout 119wait_receive_batched_lane:cancel() -- hard cancel, 0 timeout