spinlock.hpp

Go to the documentation of this file.

// SPDX-License-Identifier: GPL-3.0-or-later
 
#pragma once
 
#include "mos/platform/platform_defs.hpp"
 
#include <mos/mos_global.h>
#include <mos/types.hpp>
 
#define barrier() MOS_PLATFORM_MEMORY_BARRIER()
 
class SpinLocker;
struct spinlock_t
{
    bool flag = false;
#if MOS_DEBUG_FEATURE(spinlock)
    const char *file = nullptr;
    int line = 0;
#endif
 
    SpinLocker lock();
};
 
#define spinlock_init(lock)                                                                                                                                              \
    do                                                                                                                                                                   \
    {                                                                                                                                                                    \
        (lock)->flag = 0;                                                                                                                                                \
    } while (0)
 
// clang-format off
#define SPINLOCK_INIT { 0 }
// clang-format on
 
#define _spinlock_real_acquire(lock)                                                                                                                                     \
    do                                                                                                                                                                   \
    {                                                                                                                                                                    \
        barrier();                                                                                                                                                       \
        while (__atomic_test_and_set(&(lock)->flag, __ATOMIC_ACQUIRE))                                                                                                   \
            ;                                                                                                                                                            \
    } while (0)
 
#define _spinlock_real_release(lock)                                                                                                                                     \
    do                                                                                                                                                                   \
    {                                                                                                                                                                    \
        __atomic_clear(&(lock)->flag, __ATOMIC_RELEASE);                                                                                                                 \
    } while (0)
 
#if MOS_DEBUG_FEATURE(spinlock)
#define spinlock_acquire(lock)                                                                                                                                           \
    do                                                                                                                                                                   \
    {                                                                                                                                                                    \
        _spinlock_real_acquire(lock);                                                                                                                                    \
        (lock)->file = __FILE__;                                                                                                                                         \
        (lock)->line = __LINE__;                                                                                                                                         \
    } while (0)
#define spinlock_release(lock)                                                                                                                                           \
    do                                                                                                                                                                   \
    {                                                                                                                                                                    \
        (lock)->file = NULL;                                                                                                                                             \
        (lock)->line = 0;                                                                                                                                                \
        _spinlock_real_release(lock);                                                                                                                                    \
    } while (0)
#else
#define spinlock_acquire(lock) _spinlock_real_acquire(lock)
#define spinlock_release(lock) _spinlock_real_release(lock)
#endif
 
#define spinlock_acquire_nodebug(lock) _spinlock_real_acquire(lock)
#define spinlock_release_nodebug(lock) _spinlock_real_release(lock)
 
should_inline bool spinlock_is_locked(const spinlock_t *lock)
{
    return lock->flag;
}
 
typedef struct
{
    spinlock_t lock;
    void *owner;
    size_t count;
} recursive_spinlock_t;
 
// clang-format off
#define RECURSIVE_SPINLOCK_INIT { SPINLOCK_INIT, NULL, 0 }
// clang-format on
 
should_inline void recursive_spinlock_acquire(recursive_spinlock_t *lock, void *owner)
{
    if (lock->owner == owner)
    {
        lock->count++;
    }
    else
    {
        spinlock_acquire(&lock->lock);
        lock->owner = owner;
        lock->count = 1;
    }
}
 
should_inline void recursive_spinlock_release(recursive_spinlock_t *lock, void *owner)
{
    if (lock->owner == owner)
    {
        lock->count--;
        if (lock->count == 0)
        {
            lock->owner = NULL;
            spinlock_release(&lock->lock);
        }
    }
}
 
should_inline bool recursive_spinlock_is_locked(recursive_spinlock_t *lock)
{
    return lock->lock.flag;
}
 
class [[nodiscard("don't discard")]] SpinLocker
{
  public:
    SpinLocker(spinlock_t *lock) : m_lock(lock)
    {
        spinlock_acquire(m_lock);
    }
 
    SpinLocker(const SpinLocker &) = delete;
    SpinLocker &operator=(const SpinLocker &) = delete;
 
    // move constructor
    SpinLocker(SpinLocker &&other) : m_lock(other.m_lock)
    {
        other.m_lock = nullptr;
    }
 
    // move assignment
    SpinLocker &operator=(SpinLocker &&other)
    {
        if (this != &other)
        {
            m_lock = other.m_lock;
            other.m_lock = nullptr;
        }
        return *this;
    }
 
    ~SpinLocker()
    {
        if (m_lock)
            spinlock_release(m_lock);
    }
 
  private:
    spinlock_t *m_lock;
};
 
inline SpinLocker spinlock_t::lock()
{
    return SpinLocker(this);
}