Index: include/llvm/Support/Threading.h =================================================================== --- include/llvm/Support/Threading.h +++ include/llvm/Support/Threading.h @@ -15,6 +15,13 @@ #ifndef LLVM_SUPPORT_THREADING_H #define LLVM_SUPPORT_THREADING_H +#if !defined(__MINGW32__) +#include +#else +#include "llvm/Support/Atomic.h" +#include "llvm/Support/Valgrind.h" +#endif + namespace llvm { /// Returns true if LLVM is compiled with support for multi-threading, and /// false otherwise. @@ -33,6 +40,34 @@ /// the thread stack. void llvm_execute_on_thread(void (*UserFn)(void*), void *UserData, unsigned RequestedStackSize = 0); + +template void llvm_call_once() { + +#if !defined(__MINGW32__) + static std::once_flag flag; + std::call_once(flag, UserFn); + +#else + static volatile sys::cas_flag initialized = 0; + sys::cas_flag old_val = sys::CompareAndSwap(&initialized, 1, 0); + if (old_val == 0) { + UserFn(); + sys::MemoryFence(); + TsanIgnoreWritesBegin(); + TsanHappensBefore(&initialized); + initialized = 2; + TsanIgnoreWritesEnd(); + } else { + sys::cas_flag tmp = initialized; + sys::MemoryFence(); + while (tmp != 2) { + tmp = initialized; + sys::MemoryFence(); + } + } + TsanHappensAfter(&initialized); +#endif +} } #endif Index: lib/Support/ManagedStatic.cpp =================================================================== --- lib/Support/ManagedStatic.cpp +++ lib/Support/ManagedStatic.cpp @@ -16,16 +16,22 @@ #include "llvm/Support/Atomic.h" #include "llvm/Support/Mutex.h" #include "llvm/Support/MutexGuard.h" +#include "llvm/Support/Threading.h" #include using namespace llvm; static const ManagedStaticBase *StaticList = nullptr; +static sys::Mutex *ManagedStaticMutex = nullptr; -static sys::Mutex& getManagedStaticMutex() { +static void initializeMutex() { + ManagedStaticMutex = new sys::Mutex(); +} + +static sys::Mutex* getManagedStaticMutex() { // We need to use a function local static here, since this can get called // during a static constructor and we need to guarantee that it's initialized // correctly. - static sys::Mutex ManagedStaticMutex; + llvm_call_once(); return ManagedStaticMutex; } @@ -33,7 +39,7 @@ void (*Deleter)(void*)) const { assert(Creator); if (llvm_is_multithreaded()) { - MutexGuard Lock(getManagedStaticMutex()); + MutexGuard Lock(*getManagedStaticMutex()); if (!Ptr) { void* tmp = Creator(); @@ -83,8 +89,13 @@ /// llvm_shutdown - Deallocate and destroy all ManagedStatic variables. void llvm::llvm_shutdown() { - MutexGuard Lock(getManagedStaticMutex()); + { + MutexGuard Lock(*getManagedStaticMutex()); + + while (StaticList) + StaticList->destroy(); + } - while (StaticList) - StaticList->destroy(); + delete ManagedStaticMutex; + ManagedStaticMutex = nullptr; }