aboutsummaryrefslogtreecommitdiff
path: root/tests/basic.lua
diff options
context:
space:
mode:
Diffstat (limited to 'tests/basic.lua')
-rw-r--r--tests/basic.lua10
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/basic.lua b/tests/basic.lua
index 020fe78..6fcfd53 100644
--- a/tests/basic.lua
+++ b/tests/basic.lua
@@ -114,7 +114,7 @@ collectgarbage()
114 114
115PRINT( "\n\n", "---=== Tasking (cancelling) ===---", "\n\n") 115PRINT( "\n\n", "---=== Tasking (cancelling) ===---", "\n\n")
116 116
117local task_launch2= lanes_gen( "", { cancelstep=100, globals={hey=true}, gc_cb = gc_cb}, task ) 117local task_launch2= lanes_gen( "", { globals={hey=true}, gc_cb = gc_cb}, task )
118 118
119local N=999999999 119local N=999999999
120local lane9= task_launch2(1,N,1) -- huuuuuuge... 120local lane9= task_launch2(1,N,1) -- huuuuuuge...
@@ -138,7 +138,7 @@ if st=="done" then
138end 138end
139assert( st=="running" ) 139assert( st=="running" )
140 140
141lane9:cancel() 141lane9:cancel( "count", 100) -- 0 timeout, 100 instructions count hook
142 142
143local t0= os.time() 143local t0= os.time()
144while os.time()-t0 < 5 do 144while os.time()-t0 < 5 do
@@ -166,7 +166,7 @@ end
166local wait_send_lane = lanes.gen( "*", wait_send)() 166local wait_send_lane = lanes.gen( "*", wait_send)()
167repeat until wait_send_lane.status == "waiting" 167repeat until wait_send_lane.status == "waiting"
168print "wait_send_lane is waiting" 168print "wait_send_lane is waiting"
169wait_send_lane:cancel() 169wait_send_lane:cancel() -- hard cancel, 0 timeout
170repeat until wait_send_lane.status == "cancelled" 170repeat until wait_send_lane.status == "cancelled"
171print "wait_send_lane is cancelled" 171print "wait_send_lane is cancelled"
172--################################################]] 172--################################################]]
@@ -179,7 +179,7 @@ end
179local wait_receive_lane = lanes.gen( "*", wait_receive)() 179local wait_receive_lane = lanes.gen( "*", wait_receive)()
180repeat until wait_receive_lane.status == "waiting" 180repeat until wait_receive_lane.status == "waiting"
181print "wait_receive_lane is waiting" 181print "wait_receive_lane is waiting"
182wait_receive_lane:cancel() 182wait_receive_lane:cancel() -- hard cancel, 0 timeout
183repeat until wait_receive_lane.status == "cancelled" 183repeat until wait_receive_lane.status == "cancelled"
184print "wait_receive_lane is cancelled" 184print "wait_receive_lane is cancelled"
185--################################################]] 185--################################################]]
@@ -192,7 +192,7 @@ end
192local wait_receive_batched_lane = lanes.gen( "*", wait_receive_batched)() 192local wait_receive_batched_lane = lanes.gen( "*", wait_receive_batched)()
193repeat until wait_receive_batched_lane.status == "waiting" 193repeat until wait_receive_batched_lane.status == "waiting"
194print "wait_receive_batched_lane is waiting" 194print "wait_receive_batched_lane is waiting"
195wait_receive_batched_lane:cancel() 195wait_receive_batched_lane:cancel() -- hard cancel, 0 timeout
196repeat until wait_receive_batched_lane.status == "cancelled" 196repeat until wait_receive_batched_lane.status == "cancelled"
197print "wait_receive_batched_lane is cancelled" 197print "wait_receive_batched_lane is cancelled"
198--################################################]] 198--################################################]]