diff options
author | Thomas Snider <tjps636@gmail.com> | 2017-11-18 11:35:14 -0800 |
---|---|---|
committer | Thomas Snider <tjps636@gmail.com> | 2017-11-18 11:35:14 -0800 |
commit | bba9bd0d9dd06f13a6b0c89181864453cab5c858 (patch) | |
tree | b16239a61b68699026e7c7b93c0dad06081abd80 /src/sync.cpp | |
parent | 99bc0b428b03b571afbc311b7f18fd3a707ac5af (diff) |
Switched sync.{cpp,h} to std threading primitives.
Diffstat (limited to 'src/sync.cpp')
-rw-r--r-- | src/sync.cpp | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/src/sync.cpp b/src/sync.cpp index fcc6ddc354..116533eb41 100644 --- a/src/sync.cpp +++ b/src/sync.cpp @@ -4,13 +4,12 @@ #include <sync.h> +#include <set> #include <util.h> #include <utilstrencodings.h> #include <stdio.h> -#include <boost/thread.hpp> - #ifdef DEBUG_LOCKCONTENTION void PrintLockContention(const char* pszName, const char* pszFile, int nLine) { @@ -45,8 +44,8 @@ struct CLockLocation { return mutexName + " " + sourceFile + ":" + itostr(sourceLine) + (fTry ? " (TRY)" : ""); } - bool fTry; private: + bool fTry; std::string mutexName; std::string sourceFile; int sourceLine; @@ -67,10 +66,10 @@ struct LockData { LockOrders lockorders; InvLockOrders invlockorders; - boost::mutex dd_mutex; + std::mutex dd_mutex; } static lockdata; -boost::thread_specific_ptr<LockStack> lockstack; +static thread_local std::unique_ptr<LockStack> lockstack; static void potential_deadlock_detected(const std::pair<void*, void*>& mismatch, const LockStack& s1, const LockStack& s2) { @@ -100,12 +99,12 @@ static void potential_deadlock_detected(const std::pair<void*, void*>& mismatch, static void push_lock(void* c, const CLockLocation& locklocation) { - if (lockstack.get() == nullptr) + if (!lockstack) lockstack.reset(new LockStack); - boost::unique_lock<boost::mutex> lock(lockdata.dd_mutex); + std::lock_guard<std::mutex> lock(lockdata.dd_mutex); - (*lockstack).push_back(std::make_pair(c, locklocation)); + lockstack->push_back(std::make_pair(c, locklocation)); for (const std::pair<void*, CLockLocation> & i : (*lockstack)) { if (i.first == c) @@ -171,7 +170,7 @@ void DeleteLock(void* cs) // We're already shutting down. return; } - boost::unique_lock<boost::mutex> lock(lockdata.dd_mutex); + std::lock_guard<std::mutex> lock(lockdata.dd_mutex); std::pair<void*, void*> item = std::make_pair(cs, nullptr); LockOrders::iterator it = lockdata.lockorders.lower_bound(item); while (it != lockdata.lockorders.end() && it->first.first == cs) { |