Fix crash with multi keepers (invalid memory access on close)

4 files changed, 29 insertions, 35 deletions

diff --git a/Makefile b/Makefile
index 7200939..5b5d27a 100644
--- a/Makefile
+++ b/Makefile
@@ -79,7 +79,13 @@ build_DUE:
 # also run a test that shows whether lanes is successfully loaded or not
 run_unit_tests: build_lanes build_unit_tests build_DUE
         @echo =========================================================================================
-        $(_PREFIX) $(_UNITTEST_TARGET) -s
+        $(_PREFIX) $(_UNITTEST_TARGET) --list-tests
+        $(_PREFIX) $(_UNITTEST_TARGET) --rng-seed 0 -s
+
+debug_unit_tests: build_lanes build_unit_tests build_DUE
+        @echo =========================================================================================
+        $(_PREFIX) $(_UNITTEST_TARGET) --list-tests
+        $(_PREFIX) gdb --args $(_UNITTEST_TARGET) --rng-seed 0 -s "lanes.configure.nb_user_keepers"
 
 clean:
         cd src && $(MAKE) -f Lanes.makefile clean
diff --git a/src/keeper.cpp b/src/keeper.cpp
index cad9207..c8c470f 100644
--- a/src/keeper.cpp
+++ b/src/keeper.cpp
@@ -811,22 +811,6 @@ KeeperCallResult keeper_call(KeeperState const K_, keeper_api_t const func_, lua
 // #################################################################################################
 // #################################################################################################
 
-void* Keeper::operator new[](size_t size_, Universe* U_) noexcept
-{
-    // size_ is the memory for the element count followed by the elements themselves
-    return U_->internalAllocator.alloc(size_);
-}
-
-// #################################################################################################
-
-// can't actually delete the operator because the compiler generates stack unwinding code that could call it in case of exception
-void Keeper::operator delete[](void* p_, Universe* U_)
-{
-    U_->internalAllocator.free(p_, *static_cast<size_t*>(p_) * sizeof(Keeper) + sizeof(size_t));
-}
-
-// #################################################################################################
-
 // only used by linda:dump() and linda:__towatch() for debugging purposes
 // table is populated as follows:
 // {
@@ -927,7 +911,7 @@ void Keepers::DeleteKV::operator()(Keeper* const k_) const
     for (auto& _k : std::span<Keeper>(k_, count)) {
         _k.~Keeper();
     }
-    U->internalAllocator.free(k_, count * sizeof(Keeper));
+    U.internalAllocator.free(k_, count * sizeof(Keeper));
 }
 
 // #################################################################################################
@@ -959,8 +943,8 @@ void Keepers::collectGarbage()
         // when keeper N+1 is closed, object is GCed, linda operation is called, which attempts to acquire keeper N, whose Lua state no longer exists
         // in that case, the linda operation should do nothing. which means that these operations must check for keeper acquisition success
         // which is early-outed with a keepers->nbKeepers null-check
-        for (size_t const _i : std::ranges::iota_view{ size_t{ 0 }, _kv.nbKeepers }) {
-            _gcOneKeeper(_kv.keepers[_i]);
+        for (Keeper& _k : std::span<Keeper>{ _kv.keepers.get(), _kv.nbKeepers }) {
+            _gcOneKeeper(_k);
         }
     }
 }
@@ -996,9 +980,8 @@ void Keepers::close()
         // when keeper N+1 is closed, object is GCed, linda operation is called, which attempts to acquire keeper N, whose Lua state no longer exists
         // in that case, the linda operation should do nothing. which means that these operations must check for keeper acquisition success
         // which is early-outed with a keepers->nbKeepers null-check
-        size_t const _nbKeepers{ std::exchange(_kv.nbKeepers, size_t{ 0 }) };
-        for (size_t const _i : std::ranges::iota_view{ size_t{ 0 }, _nbKeepers }) {
-            if (!_closeOneKeeper(_kv.keepers[_i])) {
+        for (Keeper& _k : std::span<Keeper>{ _kv.keepers.get(), std::exchange(_kv.nbKeepers, size_t{ 0 }) }) {
+            if (!_closeOneKeeper(_k)) {
                 // detected partial init: destroy only the mutexes that got initialized properly
                 break;
             }
@@ -1137,11 +1120,14 @@ void Keepers::initialize(Universe& U_, lua_State* L_, size_t const nbKeepers_, i
 
     default:
         KV& _kv = keeper_array.emplace<KV>(
-            std::unique_ptr<Keeper[], DeleteKV>{ new(&U_) Keeper[nbKeepers_], DeleteKV{ &U_, nbKeepers_ } },
+            std::unique_ptr<Keeper, DeleteKV>{ static_cast<Keeper*>(U_.internalAllocator.alloc(sizeof(Keeper) * nbKeepers_)), DeleteKV{ U_, nbKeepers_ } },
             nbKeepers_
         );
-        for (size_t const _i : std::ranges::iota_view{ size_t{ 0 }, nbKeepers_ }) {
-            _initOneKeeper(_kv.keepers[_i], static_cast<int>(_i));
+        // fak. std::ranges::views::enumerate is c++23 (would help having item and index iterated over simultaneously)
+        int _i{};
+        for (Keeper& _k : std::span<Keeper>{ _kv.keepers.get(), nbKeepers_ }) {
+            new (&_k) Keeper{};
+            _initOneKeeper(_k, _i++);
         }
     }
 }
diff --git a/src/keeper.hpp b/src/keeper.hpp
index 5cebe07..f1083b3 100644
--- a/src/keeper.hpp
+++ b/src/keeper.hpp
@@ -26,12 +26,6 @@ struct Keeper
     std::mutex mutex;
     KeeperState K{ static_cast<lua_State*>(nullptr) };
 
-    [[nodiscard]]
-    static void* operator new[](size_t size_, Universe* U_) noexcept;
-    // can't actually delete the operator because the compiler generates stack unwinding code that could call it in case of exception
-    static void operator delete[](void* p_, Universe* U_);
-
-
     ~Keeper() = default;
     Keeper() = default;
     // non-copyable, non-movable
@@ -51,14 +45,15 @@ struct Keepers
     private:
     struct DeleteKV
     {
-        Universe* U{};
+        Universe& U;
         size_t count{};
         void operator()(Keeper* k_) const;
     };
-    // can't use std::vector<Keeper> because Keeper contains a mutex, so we need a raw memory buffer
+    // can't use std::unique_ptr<Keeper[]> because of interactions with placement new and custom deleters
+    // and I'm not using std::vector<Keeper> because I don't have an allocator to plug on the Universe (yet)
     struct KV
     {
-        std::unique_ptr<Keeper[], DeleteKV> keepers;
+        std::unique_ptr<Keeper, DeleteKV> keepers;
         size_t nbKeepers{};
     };
     std::variant<std::monostate, Keeper, KV> keeper_array;
diff --git a/unit_tests/init_and_shutdown.cpp b/unit_tests/init_and_shutdown.cpp
index 53f4a2a..384af43 100644
--- a/unit_tests/init_and_shutdown.cpp
+++ b/unit_tests/init_and_shutdown.cpp
@@ -323,6 +323,13 @@ TEST_CASE("lanes.configure.nb_user_keepers")
 
     // -----------------------------------------------------------------------------------------
 
+    SECTION("nb_user_keepers = 1")
+    {
+        L.requireSuccess("require 'lanes'.configure{nb_user_keepers = 1}");
+    }
+
+    // -----------------------------------------------------------------------------------------
+
     SECTION("nb_user_keepers = 100")
     {
         L.requireSuccess("require 'lanes'.configure{nb_user_keepers = 100}");