summaryrefslogtreecommitdiffhomepage
path: root/Kernel/KernelKit/LockDelegate.hxx
diff options
context:
space:
mode:
authorAmlal EL Mahrouss <amlalelmahrouss@icloud.com>2024-08-02 20:11:24 +0200
committerAmlal EL Mahrouss <amlalelmahrouss@icloud.com>2024-08-02 20:11:24 +0200
commit59578978610f6af245f571a011694a51d94dc530 (patch)
tree3553807ef1c8095248520ee823c1426aef8738d8 /Kernel/KernelKit/LockDelegate.hxx
parent9afcd1c001703c32964fed5906f36a2d913e91e9 (diff)
[unstable] [META] refactor whole project.
Signed-off-by: Amlal EL Mahrouss <amlalelmahrouss@icloud.com>
Diffstat (limited to 'Kernel/KernelKit/LockDelegate.hxx')
-rw-r--r--Kernel/KernelKit/LockDelegate.hxx67
1 files changed, 67 insertions, 0 deletions
diff --git a/Kernel/KernelKit/LockDelegate.hxx b/Kernel/KernelKit/LockDelegate.hxx
new file mode 100644
index 00000000..adf4e492
--- /dev/null
+++ b/Kernel/KernelKit/LockDelegate.hxx
@@ -0,0 +1,67 @@
+/* -------------------------------------------
+
+ Copyright ZKA Technologies
+
+------------------------------------------- */
+
+#pragma once
+
+#include <NewKit/Atom.hxx>
+#include <NewKit/Defines.hxx>
+
+namespace Kernel
+{
+ enum
+ {
+ kLockDone = 200,
+ kLockTimedOut,
+ };
+
+ /// @brief Lock condition pointer.
+ typedef Boolean* LockPtr;
+
+ /// @brief Locking delegate class, hangs until limit.
+ /// @tparam N the amount of cycles to wait.
+ template <SizeT N>
+ class LockDelegate final
+ {
+ public:
+ LockDelegate() = delete;
+
+ public:
+ explicit LockDelegate(LockPtr expr)
+ {
+ auto spin = 0U;
+
+ while (spin != N)
+ {
+ if (*expr)
+ {
+ fLockStatus | kLockDone;
+ break;
+ }
+ }
+
+ if (spin == N)
+ fLockStatus | kLockTimedOut;
+ }
+
+ ~LockDelegate() = default;
+
+ LockDelegate& operator=(const LockDelegate&) = delete;
+ LockDelegate(const LockDelegate&) = delete;
+
+ bool Done()
+ {
+ return fLockStatus[kLockDone] == kLockDone;
+ }
+
+ bool HasTimedOut()
+ {
+ return fLockStatus[kLockTimedOut] != kLockTimedOut;
+ }
+
+ private:
+ Atom<UInt> fLockStatus;
+ };
+} // namespace Kernel