7 files changed, 200 insertions, 106 deletions

diff --git a/src/cancel.h b/src/cancel.h
index 060edb3..10a9804 100644
--- a/src/cancel.h
+++ b/src/cancel.h
@@ -47,7 +47,7 @@ enum class CancelOp
 };
 
 // crc64/we of string "CANCEL_ERROR" generated at http://www.nitrxgen.net/hashgen/
-static constexpr UniqueKey CANCEL_ERROR{ 0xe97d41626cc97577ull }; // 'raise_cancel_error' sentinel
+static constexpr UniqueKey CANCEL_ERROR{ 0xe97d41626cc97577ull, "lanes.cancel_error" }; // 'raise_cancel_error' sentinel
 
 [[nodiscard]] CancelOp which_cancel_op(char const* op_string_);
 [[nodiscard]] CancelResult thread_cancel(Lane* lane_, CancelOp op_, int hook_count_, lua_Duration secs_, bool wake_lindas_);
diff --git a/src/keeper.cpp b/src/keeper.cpp
index f56c50c..61321e1 100644
--- a/src/keeper.cpp
+++ b/src/keeper.cpp
@@ -418,7 +418,7 @@ int keepercall_limit(lua_State* L)
 // ##################################################################################################
 
 // in: linda_ud key [[val] ...]
-//out: true or nil
+//out: true if the linda was full but it's no longer the case, else nothing
 int keepercall_set(lua_State* L)
 {
     bool should_wake_writers{ false };
@@ -826,35 +826,35 @@ void keeper_toggle_nil_sentinels(lua_State* L, int val_i_, LookupMode const mode
 * 'linda':          deep Linda pointer (used only as a unique table key, first parameter)
 * 'starting_index': first of the rest of parameters (none if 0)
 *
-* Returns: number of return values (pushed to 'L') or -1 in case of error
+* Returns: number of return values (pushed to 'L'), unset in case of error
 */
-int keeper_call(Universe* U, lua_State* K, keeper_api_t func_, lua_State* L, void* linda, int starting_index)
+KeeperCallResult keeper_call(Universe* U, lua_State* K, keeper_api_t func_, lua_State* L, void* linda, int starting_index)
 {
+    KeeperCallResult result;
     int const args{ starting_index ? (lua_gettop(L) - starting_index + 1) : 0 };
-    int const Ktos{ lua_gettop(K) };
-    int retvals = -1;
+    int const top_K{ lua_gettop(K) };
 
     STACK_GROW(K, 2);
 
-    PUSH_KEEPER_FUNC(K, func_);
+    PUSH_KEEPER_FUNC(K, func_);                                                                                            // func_
 
-    lua_pushlightuserdata(K, linda);
+    lua_pushlightuserdata(K, linda);                                                                                       // func_ linda
 
-    if ((args == 0) || luaG_inter_copy(U, Source{ L }, Dest{ K }, args, LookupMode::ToKeeper) == InterCopyResult::Success) // L->K
+    if ((args == 0) || luaG_inter_copy(U, Source{ L }, Dest{ K }, args, LookupMode::ToKeeper) == InterCopyResult::Success) // func_ linda args...
     {
-        lua_call(K, 1 + args, LUA_MULTRET);
-        retvals = lua_gettop(K) - Ktos;
+        lua_call(K, 1 + args, LUA_MULTRET);                                                                                // result...
+        int const retvals{ lua_gettop(K) - top_K };
         // note that this can raise a luaL_error while the keeper state (and its mutex) is acquired
         // this may interrupt a lane, causing the destruction of the underlying OS thread
         // after this, another lane making use of this keeper can get an error code from the mutex-locking function
         // when attempting to grab the mutex again (WINVER <= 0x400 does this, but locks just fine, I don't know about pthread)
-        if ((retvals > 0) && luaG_inter_move(U, Source{ K }, Dest{ L }, retvals, LookupMode::FromKeeper) != InterCopyResult::Success) // K->L
+        if ((retvals == 0) || (luaG_inter_move(U, Source{ K }, Dest{ L }, retvals, LookupMode::FromKeeper) == InterCopyResult::Success)) // K->L
         {
-            retvals = -1;
+            result.emplace(retvals);
         }
     }
     // whatever happens, restore the stack to where it was at the origin
-    lua_settop(K, Ktos);
+    lua_settop(K, top_K);
 
     // don't do this for this particular function, as it is only called during Linda destruction, and we don't want to raise an error, ever
     if (func_ != KEEPER_API(clear)) [[unlikely]]
@@ -880,5 +880,5 @@ int keeper_call(Universe* U, lua_State* K, keeper_api_t func_, lua_State* L, voi
         }
     }
 
-    return retvals;
+    return result;
 }
diff --git a/src/keeper.h b/src/keeper.h
index 627c7ea..7ec8b15 100644
--- a/src/keeper.h
+++ b/src/keeper.h
@@ -11,6 +11,7 @@ extern "C" {
 #include "threading.h"
 #include "uniquekey.h"
 
+#include <optional>
 #include <mutex>
 
 // forwards
@@ -33,7 +34,7 @@ struct Keepers
 
 static constexpr uintptr_t KEEPER_MAGIC_SHIFT{ 3 };
 // crc64/we of string "NIL_SENTINEL" generated at http://www.nitrxgen.net/hashgen/
-static constexpr UniqueKey NIL_SENTINEL{ 0x7eaafa003a1d11a1ull };
+static constexpr UniqueKey NIL_SENTINEL{ 0x7eaafa003a1d11a1ull, "internal nil sentinel" };
 
 void init_keepers(Universe* U, lua_State* L);
 void close_keepers(Universe* U);
@@ -57,4 +58,5 @@ using keeper_api_t = lua_CFunction;
 [[nodiscard]] int keepercall_set(lua_State* L);
 [[nodiscard]] int keepercall_count(lua_State* L);
 
-[[nodiscard]] int keeper_call(Universe* U, lua_State* K, keeper_api_t _func, lua_State* L, void* linda, int starting_index);
+using KeeperCallResult = Unique<std::optional<int>>;
+[[nodiscard]] KeeperCallResult keeper_call(Universe* U, lua_State* K, keeper_api_t _func, lua_State* L, void* linda, int starting_index);
diff --git a/src/linda.cpp b/src/linda.cpp
index e749f52..dbd6b21 100644
--- a/src/linda.cpp
+++ b/src/linda.cpp
@@ -39,8 +39,12 @@ THE SOFTWARE.
 #include "universe.h"
 
 #include <array>
+#include <functional>
 #include <variant>
 
+// xxh64 of string "CANCEL_ERROR" generated at https://www.pelock.com/products/hash-calculator
+static constexpr UniqueKey BATCH_SENTINEL{ 0x2DDFEE0968C62AA7ull, "linda.batched" };
+
 /*
 * Actual data is kept within a keeper state, which is hashed by the 'Linda'
 * pointer (which is same to all userdatas pointing to it).
@@ -140,14 +144,14 @@ class Linda : public DeepPrelude // Deep userdata MUST start with this header
 [[nodiscard]] static void* linda_id(lua_State*, DeepOp);
 
 template<bool OPT>
-[[nodiscard]] static inline Linda* lua_toLinda(lua_State* L, int idx_)
+[[nodiscard]] static inline Linda* ToLinda(lua_State* L, int idx_)
 {
     Linda* const linda{ static_cast<Linda*>(luaG_todeep(L, linda_id, idx_)) };
-    if (!OPT)
+    if constexpr (!OPT)
     {
         luaL_argcheck(L, linda != nullptr, idx_, "expecting a linda object");
+        ASSERT_L(linda->U == universe_get(L));
     }
-    ASSERT_L(linda->U == universe_get(L));
     return linda;
 }
 
@@ -157,10 +161,28 @@ static void check_key_types(lua_State* L, int start_, int end_)
 {
     for (int i{ start_ }; i <= end_; ++i)
     {
-        int const t{ lua_type(L, i) };
-        if (t == LUA_TBOOLEAN || t == LUA_TNUMBER || t == LUA_TSTRING || t == LUA_TLIGHTUSERDATA)
+        LuaType const t{ lua_type_as_enum(L, i) };
+        switch (t)
         {
+            case LuaType::BOOLEAN:
+            case LuaType::NUMBER:
+            case LuaType::STRING:
             continue;
+
+            case LuaType::LIGHTUSERDATA:
+            {
+                // NIL_SENTINEL isn't publicly exposed, but it doesn't hurt to check
+                static constexpr std::array<std::reference_wrapper<UniqueKey const>, 3> to_check{ BATCH_SENTINEL, CANCEL_ERROR, NIL_SENTINEL };
+                for (UniqueKey const& key : to_check)
+                {
+                    if (key.equals(L, i))
+                    {
+                        luaL_error(L, "argument #%d: can't use %s as a key", i, key.m_debugName); // doesn't return
+                        break;
+                    }
+                }
+            }
+            break;
         }
         luaL_error(L, "argument #%d: invalid key type (not a boolean, string, number or light userdata)", i); // doesn't return
     }
@@ -170,7 +192,7 @@ static void check_key_types(lua_State* L, int start_, int end_)
 
 LUAG_FUNC(linda_protected_call)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
 
     // acquire the keeper
     Keeper* const K{ keeper_acquire(linda->U->keepers, linda->hashSeed()) };
@@ -209,7 +231,7 @@ LUAG_FUNC(linda_protected_call)
 */
 LUAG_FUNC(linda_send)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     std::chrono::time_point<std::chrono::steady_clock> until{ std::chrono::time_point<std::chrono::steady_clock>::max() };
     int key_i{ 2 }; // index of first key, if timeout not there
 
@@ -257,7 +279,7 @@ LUAG_FUNC(linda_send)
     keeper_toggle_nil_sentinels(L, key_i + 1, LookupMode::ToKeeper);
     bool ret{ false };
     CancelRequest cancel{ CancelRequest::None };
-    int pushed{ 0 };
+    KeeperCallResult pushed;
     {
         Lane* const lane{ LANE_POINTER_REGKEY.readLightUserDataValue<Lane>(L) };
         Keeper* const K{ which_keeper(linda->U->keepers, linda->hashSeed()) };
@@ -276,17 +298,17 @@ LUAG_FUNC(linda_send)
             // if user wants to cancel, or looped because of a timeout, the call returns without sending anything
             if (!try_again || cancel != CancelRequest::None)
             {
-                pushed = 0;
+                pushed.emplace(0);
                 break;
             }
 
             STACK_CHECK(KL, 0);
             pushed = keeper_call(linda->U, KL, KEEPER_API(send), L, linda, key_i);
-            if (pushed < 0)
+            if (!pushed.has_value())
             {
                 break;
             }
-            ASSERT_L(pushed == 1);
+            ASSERT_L(pushed.value() == 1);
 
             ret = lua_toboolean(L, -1) ? true : false;
             lua_pop(L, 1);
@@ -331,9 +353,9 @@ LUAG_FUNC(linda_send)
         STACK_CHECK(KL, 0);
     }
 
-    if (pushed < 0)
+    if (!pushed.has_value())
     {
-        return luaL_error(L, "tried to copy unsupported types");
+        luaL_error(L, "tried to copy unsupported types"); // doesn't return
     }
 
     switch (cancel)
@@ -366,11 +388,9 @@ LUAG_FUNC(linda_send)
  * returns the actual consumed values, or nil if there weren't enough values to consume
  *
  */
-// xxh64 of string "CANCEL_ERROR" generated at https://www.pelock.com/products/hash-calculator
-static constexpr UniqueKey BATCH_SENTINEL{ 0x2DDFEE0968C62AA7ull };
 LUAG_FUNC(linda_receive)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     std::chrono::time_point<std::chrono::steady_clock> until{ std::chrono::time_point<std::chrono::steady_clock>::max() };
     int key_i{ 2 }; // index of first key, if timeout not there
 
@@ -430,7 +450,7 @@ LUAG_FUNC(linda_receive)
         return 0;
 
     CancelRequest cancel{ CancelRequest::None };
-    int pushed{ 0 };
+    KeeperCallResult pushed;
     STACK_CHECK_START_REL(KL, 0);
     for (bool try_again{ true };;)
     {
@@ -442,21 +462,21 @@ LUAG_FUNC(linda_receive)
         // if user wants to cancel, or looped because of a timeout, the call returns without sending anything
         if (!try_again || cancel != CancelRequest::None)
         {
-            pushed = 0;
+            pushed.emplace(0);
             break;
         }
 
         // all arguments of receive() but the first are passed to the keeper's receive function
         pushed = keeper_call(linda->U, KL, selected_keeper_receive, L, linda, key_i);
-        if (pushed < 0)
+        if (!pushed.has_value())
         {
             break;
         }
-        if (pushed > 0)
+        if (pushed.value() > 0)
         {
-            ASSERT_L(pushed >= expected_pushed_min && pushed <= expected_pushed_max);
+            ASSERT_L(pushed.value() >= expected_pushed_min && pushed.value() <= expected_pushed_max);
             // replace sentinels with real nils
-            keeper_toggle_nil_sentinels(L, lua_gettop(L) - pushed, LookupMode::FromKeeper);
+            keeper_toggle_nil_sentinels(L, lua_gettop(L) - pushed.value(), LookupMode::FromKeeper);
             // To be done from within the 'K' locking area
             //
             linda->m_read_happened.notify_all();
@@ -494,7 +514,7 @@ LUAG_FUNC(linda_receive)
     }
     STACK_CHECK(KL, 0);
 
-    if (pushed < 0)
+    if (!pushed.has_value())
     {
         return luaL_error(L, "tried to copy unsupported types");
     }
@@ -511,7 +531,7 @@ LUAG_FUNC(linda_receive)
         raise_cancel_error(L); // raises an error and doesn't return
 
         default:
-        return pushed;
+        return pushed.value();
     }
 }
 
@@ -527,13 +547,13 @@ LUAG_FUNC(linda_receive)
 */
 LUAG_FUNC(linda_set)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     bool const has_value{ lua_gettop(L) > 2 };
     // make sure the key is of a valid type (throws an error if not the case)
     check_key_types(L, 2, 2);
 
     Keeper* const K{ which_keeper(linda->U->keepers, linda->hashSeed()) };
-    int pushed{ 0 };
+    KeeperCallResult pushed;
     if (linda->simulate_cancel == CancelRequest::None)
     {
         if (has_value)
@@ -542,16 +562,16 @@ LUAG_FUNC(linda_set)
             keeper_toggle_nil_sentinels(L, 3, LookupMode::ToKeeper);
         }
         pushed = keeper_call(linda->U, K->L, KEEPER_API(set), L, linda, 2);
-        if (pushed >= 0) // no error?
+        if (pushed.has_value()) // no error?
         {
-            ASSERT_L(pushed == 0 || pushed == 1);
+            ASSERT_L(pushed.value() == 0 || pushed.value() == 1);
 
             if (has_value)
             {
                 // we put some data in the slot, tell readers that they should wake
                 linda->m_write_happened.notify_all(); // To be done from within the 'K' locking area
             }
-            if (pushed == 1)
+            if (pushed.value() == 1)
             {
                 // the key was full, but it is no longer the case, tell writers they should wake
                 ASSERT_L(lua_type(L, -1) == LUA_TBOOLEAN && lua_toboolean(L, -1) == 1);
@@ -563,11 +583,11 @@ LUAG_FUNC(linda_set)
     {
         // do nothing and return lanes.cancel_error
         CANCEL_ERROR.pushKey(L);
-        pushed = 1;
+        pushed.emplace(1);
     }
 
     // must trigger any error after keeper state has been released
-    return (pushed < 0) ? luaL_error(L, "tried to copy unsupported types") : pushed;
+    return OptionalValue(pushed, L, "tried to copy unsupported types");
 }
 
 // #################################################################################################
@@ -579,17 +599,13 @@ LUAG_FUNC(linda_set)
  */
 LUAG_FUNC(linda_count)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     // make sure the keys are of a valid type
     check_key_types(L, 2, lua_gettop(L));
 
     Keeper* const K{ which_keeper(linda->U->keepers, linda->hashSeed()) };
-    int const pushed{ keeper_call(linda->U, K->L, KEEPER_API(count), L, linda, 2) };
-    if (pushed < 0)
-    {
-        return luaL_error(L, "tried to count an invalid key");
-    }
-    return pushed;
+    KeeperCallResult const pushed{ keeper_call(linda->U, K->L, KEEPER_API(count), L, linda, 2) };
+    return OptionalValue(pushed, L, "tried to count an invalid key");
 }
 
 // #################################################################################################
@@ -601,36 +617,31 @@ LUAG_FUNC(linda_count)
 */
 LUAG_FUNC(linda_get)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     lua_Integer const count{ luaL_optinteger(L, 3, 1) };
     luaL_argcheck(L, count >= 1, 3, "count should be >= 1");
     luaL_argcheck(L, lua_gettop(L) <= 3, 4, "too many arguments");
     // make sure the key is of a valid type (throws an error if not the case)
     check_key_types(L, 2, 2);
 
-    int pushed{ 0 };
+    KeeperCallResult pushed;
     if (linda->simulate_cancel == CancelRequest::None)
     {
         Keeper* const K{ which_keeper(linda->U->keepers, linda->hashSeed()) };
         pushed = keeper_call(linda->U, K->L, KEEPER_API(get), L, linda, 2);
-        if (pushed > 0)
+        if (pushed.value_or(0) > 0)
         {
-            keeper_toggle_nil_sentinels(L, lua_gettop(L) - pushed, LookupMode::FromKeeper);
+            keeper_toggle_nil_sentinels(L, lua_gettop(L) - pushed.value(), LookupMode::FromKeeper);
         }
     }
     else // linda is cancelled
     {
         // do nothing and return lanes.cancel_error
         CANCEL_ERROR.pushKey(L);
-        pushed = 1;
+        pushed.emplace(1);
     }
     // an error can be raised if we attempt to read an unregistered function
-    if (pushed < 0)
-    {
-        return luaL_error(L, "tried to copy unsupported types");
-    }
-
-    return pushed;
+    return OptionalValue(pushed, L, "tried to copy unsupported types");
 }
 
 // #################################################################################################
@@ -641,9 +652,9 @@ LUAG_FUNC(linda_get)
 * Set limit to 1 Linda keys.
 * Optionally wake threads waiting to write on the linda, in case the limit enables them to do so
 */
-LUAG_FUNC( linda_limit)
+LUAG_FUNC(linda_limit)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     // make sure we got 3 arguments: the linda, a key and a limit
     luaL_argcheck( L, lua_gettop( L) == 3, 2, "wrong number of arguments");
     // make sure we got a numeric limit
@@ -651,13 +662,13 @@ LUAG_FUNC( linda_limit)
     // make sure the key is of a valid type
     check_key_types( L, 2, 2);
 
-    int pushed{ 0 };
+    KeeperCallResult pushed;
     if (linda->simulate_cancel == CancelRequest::None)
     {
         Keeper* const K{ which_keeper(linda->U->keepers, linda->hashSeed()) };
         pushed = keeper_call(linda->U, K->L, KEEPER_API(limit), L, linda, 2);
-        ASSERT_L( pushed == 0 || pushed == 1); // no error, optional boolean value saying if we should wake blocked writer threads
-        if( pushed == 1)
+        ASSERT_L( pushed.has_value() && (pushed.value() == 0 || pushed.value() == 1)); // no error, optional boolean value saying if we should wake blocked writer threads
+        if (pushed.value() == 1)
         {
             ASSERT_L( lua_type( L, -1) == LUA_TBOOLEAN && lua_toboolean( L, -1) == 1);
             linda->m_read_happened.notify_all(); // To be done from within the 'K' locking area
@@ -667,10 +678,10 @@ LUAG_FUNC( linda_limit)
     {
         // do nothing and return lanes.cancel_error
         CANCEL_ERROR.pushKey(L);
-        pushed = 1;
+        pushed.emplace(1);
     }
     // propagate pushed boolean if any
-    return pushed;
+    return pushed.value();
 }
 
 // #################################################################################################
@@ -682,7 +693,7 @@ LUAG_FUNC( linda_limit)
 */
 LUAG_FUNC(linda_cancel)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     char const* who = luaL_optstring(L, 2, "both");
     // make sure we got 3 arguments: the linda, a key and a limit
     luaL_argcheck(L, lua_gettop(L) <= 2, 2, "wrong number of arguments");
@@ -726,7 +737,7 @@ LUAG_FUNC(linda_cancel)
 */
 LUAG_FUNC(linda_deep)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     lua_pushlightuserdata(L, linda); // just the address
     return 1;
 }
@@ -742,9 +753,9 @@ LUAG_FUNC(linda_deep)
 */
 
 template <bool OPT>
-[[nodiscard]] static int linda_tostring(lua_State* L, int idx_)
+[[nodiscard]] static int LindaToString(lua_State* L, int idx_)
 {
-    Linda* const linda{ lua_toLinda<OPT>(L, idx_) };
+    Linda* const linda{ ToLinda<OPT>(L, idx_) };
     if (linda != nullptr)
     {
         char text[128];
@@ -761,7 +772,7 @@ template <bool OPT>
 
 LUAG_FUNC(linda_tostring)
 {
-    return linda_tostring<false>(L, 1);
+    return LindaToString<false>(L, 1);
 }
 
 // #################################################################################################
@@ -777,12 +788,12 @@ LUAG_FUNC(linda_concat)
 { // linda1? linda2?
     bool atLeastOneLinda{ false };
     // Lua semantics enforce that one of the 2 arguments is a Linda, but not necessarily both.
-    if (linda_tostring<true>(L, 1))
+    if (LindaToString<true>(L, 1))
     {
         atLeastOneLinda = true;
         lua_replace(L, 1);
     }
-    if (linda_tostring<true>(L, 2))
+    if (LindaToString<true>(L, 2))
     {
         atLeastOneLinda = true;
         lua_replace(L, 2);
@@ -803,7 +814,7 @@ LUAG_FUNC(linda_concat)
  */
 LUAG_FUNC(linda_dump)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     return keeper_push_linda_storage(linda->U, Dest{ L }, linda, linda->hashSeed());
 }
 
@@ -815,12 +826,12 @@ LUAG_FUNC(linda_dump)
  */
 LUAG_FUNC(linda_towatch)
 {
-    Linda* const linda{ lua_toLinda<false>(L, 1) };
+    Linda* const linda{ ToLinda<false>(L, 1) };
     int pushed{ keeper_push_linda_storage(linda->U, Dest{ L }, linda, linda->hashSeed()) };
     if (pushed == 0)
     {
         // if the linda is empty, don't return nil
-        pushed = linda_tostring<false>(L, 1);
+        pushed = LindaToString<false>(L, 1);
     }
     return pushed;
 }
@@ -907,7 +918,8 @@ LUAG_FUNC(linda_towatch)
                 // Clean associated structures in the keeper state.
                 Keeper* const K{ need_acquire_release ? keeper_acquire(linda->U->keepers, linda->hashSeed()) : myK };
                 // hopefully this won't ever raise an error as we would jump to the closest pcall site while forgetting to release the keeper mutex...
-                std::ignore = keeper_call(linda->U, K->L, KEEPER_API(clear), L, linda, 0);
+                [[maybe_unused]] KeeperCallResult const result{ keeper_call(linda->U, K->L, KEEPER_API(clear), L, linda, 0) };
+                ASSERT_L(result.has_value() && result.value() == 0);
                 if (need_acquire_release)
                 {
                     keeper_release(K);
@@ -943,6 +955,7 @@ LUAG_FUNC(linda_towatch)
             // protected calls, to ensure associated keeper is always released even in case of error
             // all function are the protected call wrapper, where the actual operation is provided as upvalue
             // note that this kind of thing can break function lookup as we use the function pointer here and there
+            // TODO: change that and use different functions!
 
             lua_pushcfunction(L, LG_linda_send);
             lua_pushcclosure(L, LG_linda_protected_call, 1);
diff --git a/src/macros_and_utils.h b/src/macros_and_utils.h
index e8d5ab5..77bcfe2 100644
--- a/src/macros_and_utils.h
+++ b/src/macros_and_utils.h
@@ -178,16 +178,48 @@ using lua_Duration = std::chrono::template duration<lua_Number>;
 // #################################################################################################
 
 // A unique type generator
-template <typename T, auto = []{}>
-struct Unique
+template <typename T, auto = [] {}, typename specialization = void>
+class Unique
 {
+    private:
+
     T m_val;
-    constexpr Unique() = default;
-    constexpr operator T() const { return m_val; }
-    constexpr explicit Unique(T b_) : m_val{ b_ } {}
+
+    public:
+
+    Unique() = default;
+    operator T() const { return m_val; }
+    explicit Unique(T b_) : m_val{ b_ } {}
+};
+
+template <typename T, auto lambda>
+class Unique<T, lambda, std::enable_if_t<!std::is_scalar_v<T>>> : public T
+{
+    public:
+
+    using T::T;
+    explicit Unique(T const& b_) : T{ b_ } {}
 };
 
 // #################################################################################################
 
 using Source = Unique<lua_State*>;
-using Dest = Unique<lua_State*>;
\ No newline at end of file
+using Dest = Unique<lua_State*>;
+
+// #################################################################################################
+
+// A helper to issue an error if the provided optional doesn't contain a value
+// we can't use std::optional::value_or(luaL_error(...)), because the 'or' value is always evaluated
+template <typename T>
+concept IsOptional = requires(T x){ x.value_or(T{}); };
+
+template<typename T, typename ...Ts>
+requires IsOptional<T>
+typename T::value_type const& OptionalValue(T const& x_, Ts... args_)
+{
+    if (!x_.has_value())
+    {
+        luaL_error(std::forward<Ts>(args_)...); // doesn't return
+    }
+    return x_.value();
+}
diff --git a/src/uniquekey.h b/src/uniquekey.h
index a89ecd3..78c0765 100644
--- a/src/uniquekey.h
+++ b/src/uniquekey.h
@@ -13,12 +13,15 @@ class UniqueKey
 
     public:
 
-    constexpr explicit UniqueKey(uint64_t val_)
+    char const* m_debugName{ nullptr };
+
+    constexpr explicit UniqueKey(uint64_t val_, char const* debugName_ = nullptr)
 #if LUAJIT_FLAVOR() == 64 // building against LuaJIT headers for 64 bits, light userdata is restricted to 47 significant bits, because LuaJIT uses the other bits for internal optimizations
     : m_storage{ static_cast<uintptr_t>(val_ & 0x7fffffffffffull) }
 #else // LUAJIT_FLAVOR()
     : m_storage{ static_cast<uintptr_t>(val_) }
 #endif // LUAJIT_FLAVOR()
+    , m_debugName{ debugName_ }
     {
     }
     constexpr UniqueKey(UniqueKey const& rhs_) = default;
diff --git a/tests/errhangtest.lua b/tests/errhangtest.lua
index d26dcef..811601e 100644
--- a/tests/errhangtest.lua
+++ b/tests/errhangtest.lua
@@ -1,22 +1,66 @@
 local lanes = require "lanes".configure{with_timers=false}
-
 local linda = lanes.linda()
 
-local coro = coroutine.create(function() end)
+-- we are not allowed to send coroutines through a lane
+-- however, this should raise an error, not hang the program...
+if true then
+        print "#### coro set"
+        local coro = coroutine.create(function() end)
+        print(pcall(linda.set, linda, 'test', coro))
+        assert(linda:get("test") == nil)
+        print "OK"
+end
+
+if true then
+        print "\n#### reserved sentinels"
+        print(pcall(linda.set, linda, lanes.cancel_error))
+        print(pcall(linda.set, linda, linda.batched))
+        assert(linda:get("test") == nil)
+        print "OK"
+end
 
-local fun = function() print "fun" end
-local t_in = { [fun] = fun, fun = fun }
+-- get/set a few values
+if true then
+        print "\n#### set 3 -> receive batched"
+        local fun = function() print "function test ok" end
+        print(pcall(linda.set, linda, 'test', true, nil, fun))
+        local k,b,n,f = linda:receive(linda.batched, 'test', 3) -- read back the contents
+        assert(linda:get("test") == nil)
+        print(k, b, n)
+        f()
+        print "OK"
+end
 
--- send a string
-print( pcall(linda.send,linda, 'test', "oh boy"))
 -- send a table that contains a function
-print( pcall(linda.send,linda, 'test', t_in))
--- we are not allowed to send coroutines through a lanes
+if true then
+        print "\n#### send table with a function"
+        local fun = function() print "function test ok" end
+        local t_in = { [fun] = fun, fun = fun }
+        print(pcall(linda.send, linda, 'test', t_in))
+        local k,t_out = linda:receive('test') -- read the contents successfully sent
+        t_out.fun()
+        -- TODO: t_out should contain a single entry, as [fun] = fun should have been discarded because functions are not acceptable keys
+        print "OK"
+end
+
+-- send a string
+if true then
+        print "\n#### send string"
+        print(pcall(linda.send, linda, 'test', "string test ok"))
+        local k,str = linda:receive('test') -- read the contents successfully sent
+        print(str)
+        print "OK"
+end
+
+-- we are not allowed to send coroutines through a lane
 -- however, this should raise an error, not hang the program...
-print( pcall(linda.send,linda, 'test', coro))
-k,str = linda:receive('test') -- read the contents successfully sent
-print( str) -- "oh boy"
-k,t_out = linda:receive('test') -- read the contents successfully sent
-t_out.fun() -- "fun"
--- linda:send( 'test', coro)
-print "SUCCESS"
\ No newline at end of file
+if true then
+        print "\n#### coro send"
+        local coro = coroutine.create(function() end)
+        print(pcall(linda.send, linda, 'test', coro))
+        assert(linda:get("test") == nil)
+        print "OK"
+end
+
+-- done
+print "\nSUCCESS"
\ No newline at end of file