summaryrefslogtreecommitdiffstats
path: root/xbmc/threads/SharedSection.h
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-10 18:07:22 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-10 18:07:22 +0000
commitc04dcc2e7d834218ef2d4194331e383402495ae1 (patch)
tree7333e38d10d75386e60f336b80c2443c1166031d /xbmc/threads/SharedSection.h
parentInitial commit. (diff)
downloadkodi-c04dcc2e7d834218ef2d4194331e383402495ae1.tar.xz
kodi-c04dcc2e7d834218ef2d4194331e383402495ae1.zip
Adding upstream version 2:20.4+dfsg.upstream/2%20.4+dfsg
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'xbmc/threads/SharedSection.h')
-rw-r--r--xbmc/threads/SharedSection.h54
1 files changed, 54 insertions, 0 deletions
diff --git a/xbmc/threads/SharedSection.h b/xbmc/threads/SharedSection.h
new file mode 100644
index 0000000..dce371d
--- /dev/null
+++ b/xbmc/threads/SharedSection.h
@@ -0,0 +1,54 @@
+/*
+ * Copyright (C) 2005-2018 Team Kodi
+ * This file is part of Kodi - https://kodi.tv
+ *
+ * SPDX-License-Identifier: GPL-2.0-or-later
+ * See LICENSES/README.md for more information.
+ */
+
+#pragma once
+
+#include "threads/Condition.h"
+
+#include <mutex>
+#include <shared_mutex>
+
+/**
+ * A CSharedSection is a mutex that satisfies the Shared Lockable concept (see Lockables.h).
+ */
+class CSharedSection
+{
+ CCriticalSection sec;
+ XbmcThreads::ConditionVariable actualCv;
+
+ unsigned int sharedCount = 0;
+
+public:
+ inline CSharedSection() = default;
+
+ inline void lock()
+ {
+ std::unique_lock<CCriticalSection> l(sec);
+ while (sharedCount)
+ actualCv.wait(l, [this]() { return sharedCount == 0; });
+ sec.lock();
+ }
+ inline bool try_lock() { return (sec.try_lock() ? ((sharedCount == 0) ? true : (sec.unlock(), false)) : false); }
+ inline void unlock() { sec.unlock(); }
+
+ inline void lock_shared()
+ {
+ std::unique_lock<CCriticalSection> l(sec);
+ sharedCount++;
+ }
+ inline bool try_lock_shared() { return (sec.try_lock() ? sharedCount++, sec.unlock(), true : false); }
+ inline void unlock_shared()
+ {
+ std::unique_lock<CCriticalSection> l(sec);
+ sharedCount--;
+ if (!sharedCount)
+ {
+ actualCv.notifyAll();
+ }
+ }
+};