Function TEST

tests/gtest_blackboard_thread_safety.cpp:27–60

BUG-2: Blackboard::set() existing-entry path takes a raw reference to the Entry, then unlocks storage_mutex_. If another thread calls unset() on the same key in that window, the shared_ptr in the map is erased and the Entry may be destroyed, leaving a dangling reference. This test hammers concurrent set() + unset() on the same key. Under TSan it will report a data race / use-after-free before the

// This test hammers concurrent set() + unset() on the same key.
// Under TSan it will report a data race / use-after-free before the fix.
TEST(BlackboardThreadSafety, SetAndUnsetRace_Bug2)
{
  auto bb = Blackboard::create();

  // Pre-create the entry so set() takes the existing-entry branch
  bb->set("key", 0);

  std::atomic<bool> stop{ false };
  constexpr int kIterations = 5000;

  auto setter = [&]() {
    for(int i = 0; i < kIterations && !stop; i++)
    {
      // This creates the entry if it was unset, or updates it
      bb->set("key", i);
    }
  };

  auto unsetter = [&]() {
    for(int i = 0; i < kIterations && !stop; i++)
    {
      bb->unset("key");
    }
  };

  std::thread t1(setter);
  std::thread t2(unsetter);

  t1.join();
  t2.join();

  // If we get here without crashing/TSan error, the test passes
  SUCCEED();
}

// BUG-1 + BUG-8: Blackboard::set() new-entry path.
// After createEntryImpl() inserts the entry into storage_, the code writes