debug windows

Author: huixie90

libcxx/src/atomic.cpp

@@ -15,6 +15,7 @@
 #include <new>
 #include <thread>
 #include <type_traits>
+#include <iostream>
 
 #include "include/apple_availability.h"
 
@@ -163,8 +164,10 @@ static void __platform_wait_on_address(void const* __ptr, void const* __val) {
   static auto wait_on_address =
       reinterpret_cast<BOOL(WINAPI*)(void*, PVOID, SIZE_T, DWORD)>(win32_get_synch_api_function("WaitOnAddress"));
   if (wait_on_address != nullptr) {
-    wait_on_address(const_cast<void*>(__ptr), &__val, _Size, INFINITE);
+    std::cerr << "waiting with windows api of size " << _Size << std::endl;
+    wait_on_address(const_cast<void*>(__ptr), __val, _Size, INFINITE);
   } else {
+    std::cerr << "waiting with backoff of size " << _Size << std::endl;
     __libcpp_thread_poll_with_backoff(
         [=]() -> bool { return std::memcmp(const_cast<const void*>(__ptr), __val, _Size) != 0; },
         __libcpp_timed_backoff_policy());
@@ -179,6 +182,7 @@ static void __platform_wake_by_address(void const* __ptr, bool __notify_one) {
     static auto wake_by_address_single =
         reinterpret_cast<void(WINAPI*)(PVOID)>(win32_get_synch_api_function("WakeByAddressSingle"));
     if (wake_by_address_single != nullptr) {
+      std::cerr << "wake one with windows api of size " << _Size << std::endl;
       wake_by_address_single(const_cast<void*>(__ptr));
     } else {
       // The fallback implementation of waking does nothing, as the fallback wait implementation just does polling, so
@@ -189,6 +193,7 @@ static void __platform_wake_by_address(void const* __ptr, bool __notify_one) {
     static auto wake_by_address_all =
         reinterpret_cast<void(WINAPI*)(PVOID)>(win32_get_synch_api_function("WakeByAddressAll"));
     if (wake_by_address_all != nullptr) {
+      std::cerr << "wake all with windows api of size " << _Size << std::endl;
       wake_by_address_all(const_cast<void*>(__ptr));
     } else {
       // The fallback implementation of waking does nothing, as the fallback wait implementation just does polling, so

libcxx/test/std/thread/thread.semaphore/lost_wakeup.pass.cpp

@@ -13,7 +13,10 @@
 
 // <semaphore>
 
+#include <atomic>
 #include <barrier>
+#include <chrono>
+#include <cstdlib>
 #include <semaphore>
 #include <thread>
 #include <vector>
@@ -54,8 +57,22 @@ int main(int, char**) {
 
     threads.push_back(support::make_test_thread(release));
 
+    std::atomic_bool finished = false;
+    auto t                    = support::make_test_thread([&finished]() {
+      auto start = std::chrono::system_clock::now();
+      while (!finished) {
+        auto now = std::chrono::system_clock::now();
+        if (now - start > std::chrono::seconds(60)) {
+          std::quick_exit(42);
+        }
+      }
+    });
+
     for (auto& thread : threads)
       thread.join();
+
+    finished = true;
+    t.join();
   }
 
   return 0;