summaryrefslogtreecommitdiff
path: root/indra/llcommon/llthreadsafequeue.h
diff options
context:
space:
mode:
authorAndrey Lihatskiy <alihatskiy@productengine.com>2024-01-16 16:46:34 +0200
committerAndrey Lihatskiy <alihatskiy@productengine.com>2024-01-16 17:09:02 +0200
commit746788e78901835aeb3ba983840092ce97b257da (patch)
treeb36b030191260023918aac7145b74cd65aee18c2 /indra/llcommon/llthreadsafequeue.h
parent382f9f0786b5225ac6d9648241e6c04f4f94f262 (diff)
Revert "replaces parts of boost to C++ standard."
Diffstat (limited to 'indra/llcommon/llthreadsafequeue.h')
-rw-r--r--indra/llcommon/llthreadsafequeue.h9
1 files changed, 6 insertions, 3 deletions
diff --git a/indra/llcommon/llthreadsafequeue.h b/indra/llcommon/llthreadsafequeue.h
index 0aa75c9b73..f396a71e6f 100644
--- a/indra/llcommon/llthreadsafequeue.h
+++ b/indra/llcommon/llthreadsafequeue.h
@@ -28,6 +28,9 @@
#define LL_LLTHREADSAFEQUEUE_H
#include "llcoros.h"
+#include LLCOROS_MUTEX_HEADER
+#include <boost/fiber/timed_mutex.hpp>
+#include LLCOROS_CONDVAR_HEADER
#include "llexception.h"
#include "mutex.h"
#include <chrono>
@@ -179,10 +182,10 @@ protected:
size_t mCapacity;
bool mClosed;
- std::timed_mutex mLock;
+ boost::fibers::timed_mutex mLock;
typedef std::unique_lock<decltype(mLock)> lock_t;
- std::condition_variable_any mCapacityCond;
- std::condition_variable_any mEmptyCond;
+ boost::fibers::condition_variable_any mCapacityCond;
+ boost::fibers::condition_variable_any mEmptyCond;
enum pop_result { EMPTY, DONE, WAITING, POPPED };
// implementation logic, suitable for passing to tryLockUntil()