diff options
author | Benoit Germain <benoit.germain@ubisoft.com> | 2025-03-14 14:53:09 +0100 |
---|---|---|
committer | Benoit Germain <benoit.germain@ubisoft.com> | 2025-03-14 14:53:09 +0100 |
commit | 512f4c0b46ea5cc359e673b7379cd81925863121 (patch) | |
tree | 1e72167d8d63f44109719db9643d4c0445b17d57 /unit_tests/scripts/lane/tasking_cancelling.lua | |
parent | 0aa030db022c57947afbae3b97038a403973e3cd (diff) | |
download | lanes-master.tar.gz lanes-master.tar.bz2 lanes-master.zip |
Diffstat (limited to 'unit_tests/scripts/lane/tasking_cancelling.lua')
-rw-r--r-- | unit_tests/scripts/lane/tasking_cancelling.lua | 8 |
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 | ||
37 | PRINT("\n\n", "---=== Tasking (cancelling) ===---", "\n\n") | 37 | PRINT("\n\n", "---=== Tasking (cancelling) ===---", "\n\n") |
38 | 38 | ||
39 | local task_launch2 = lanes_gen("", { globals={hey=true}, gc_cb = gc_cb}, task) | 39 | local task_launch2 = lanes_gen("", { name = 'auto', globals={hey=true}, gc_cb = gc_cb }, task) |
40 | 40 | ||
41 | local N=999999999 | 41 | local N=999999999 |
42 | local lane9= task_launch2(1,N,1) -- huuuuuuge... | 42 | local 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 |
88 | end | 88 | end |
89 | 89 | ||
90 | local wait_send_lane = lanes.gen("*", wait_send)() | 90 | local wait_send_lane = lanes_gen("*", { name = 'auto' }, wait_send)() |
91 | repeat until wait_send_lane.status == "waiting" | 91 | repeat until wait_send_lane.status == "waiting" |
92 | print "wait_send_lane is waiting" | 92 | print "wait_send_lane is waiting" |
93 | wait_send_lane:cancel() -- hard cancel, 0 timeout | 93 | wait_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 |
101 | end | 101 | end |
102 | 102 | ||
103 | local wait_receive_lane = lanes.gen("*", wait_receive)() | 103 | local wait_receive_lane = lanes_gen("*", { name = 'auto' }, wait_receive)() |
104 | repeat until wait_receive_lane.status == "waiting" | 104 | repeat until wait_receive_lane.status == "waiting" |
105 | print "wait_receive_lane is waiting" | 105 | print "wait_receive_lane is waiting" |
106 | wait_receive_lane:cancel() -- hard cancel, 0 timeout | 106 | wait_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 |
114 | end | 114 | end |
115 | 115 | ||
116 | local wait_receive_batched_lane = lanes.gen("*", wait_receive_batched)() | 116 | local wait_receive_batched_lane = lanes_gen("*", { name = 'auto' }, wait_receive_batched)() |
117 | repeat until wait_receive_batched_lane.status == "waiting" | 117 | repeat until wait_receive_batched_lane.status == "waiting" |
118 | print "wait_receive_batched_lane is waiting" | 118 | print "wait_receive_batched_lane is waiting" |
119 | wait_receive_batched_lane:cancel() -- hard cancel, 0 timeout | 119 | wait_receive_batched_lane:cancel() -- hard cancel, 0 timeout |