2 files changed, 32 insertions, 2 deletions

diff --git a/tests/cancel.lua b/tests/cancel.lua
index a5f1dab..6429487 100644
--- a/tests/cancel.lua
+++ b/tests/cancel.lua
@@ -2,6 +2,33 @@ local lanes = require "lanes" .configure{ with_timers = false}
 
 local linda = lanes.linda()
 
+--####################################################################
+print "\n\n####################################################################\nbegin genlock & genatomic cancel test\n"
+
+-- get a lock and a atomic operator
+local lock = lanes.genlock( linda, "lock", 1)
+local atomic = lanes.genatomic( linda, "atomic")
+
+-- check that cancelled lindas give cancel_error as they should
+linda:cancel()
+assert( linda:get( "empty") == lanes.cancel_error)
+assert( lanes.genlock( linda, "any", 1) == lanes.cancel_error)
+assert( lanes.genatomic( linda, "any") == lanes.cancel_error)
+
+-- check that lock and atomic functions return cancel_error if the linda was cancelled
+assert( lock( 1) == lanes.cancel_error)
+assert( lock( -1) == lanes.cancel_error)
+assert( atomic( 1) == lanes.cancel_error)
+
+-- reset the linda so that the other tests work
+linda:cancel( "none")
+linda:limit( "lock", -1)
+linda:set( "lock")
+linda:limit( "atomic", -1)
+linda:set( "atomic")
+
+--####################################################################
+
 local laneBody = function( timeout_)
         set_finalizer( function( err, stk)
                 if err == lanes.cancel_error then
@@ -105,4 +132,7 @@ linda:cancel( "both")
 print "wait 5s"
 linda:receive( 5, "yeah")
 
+--####################################################################
+
 print "\ndone"
+
diff --git a/tests/linda_perf.lua b/tests/linda_perf.lua
index 1d92c8e..1a44d07 100644
--- a/tests/linda_perf.lua
+++ b/tests/linda_perf.lua
@@ -31,8 +31,8 @@ local batched = function( l, loop, batch)
         print( val)
 end
 
-local lane_eater_gen = lanes.gen( "*", eater)
-local lane_batched_gen = lanes.gen( "*", batched)
+local lane_eater_gen = lanes.gen( "*", {priority = 3}, eater)
+local lane_batched_gen = lanes.gen( "*", {priority = 3}, batched)
 
 -- main thread writes data while a lane reads it
 local function ziva( preloop, loop, batch)