diff options
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 |