rwmutex.h

Go to the documentation of this file.

#pragma once
 
#include <kernel/sched/wait.h>
#include <stdint.h>
 
typedef struct rwmutex rwmutex_t;
 
#define RWMUTEX_READ_SCOPE(mutex) \
    __attribute__((cleanup(rwmutex_read_cleanup))) rwmutex_t* CONCAT(rm, __COUNTER__) = (mutex); \
    rwmutex_read_acquire((mutex))
 
#define RWMUTEX_WRITE_SCOPE(mutex) \
    __attribute__((cleanup(rwmutex_write_cleanup))) rwmutex_t* CONCAT(wm, __COUNTER__) = (mutex); \
    rwmutex_write_acquire((mutex))
 
typedef struct rwmutex
{
    uint16_t activeReaders;
    uint16_t waitingWriters;
    wait_queue_t readerQueue;
    wait_queue_t writerQueue;
    bool hasWriter;
    lock_t lock;
} rwmutex_t;
 
void rwmutex_init(rwmutex_t* mtx);
 
void rwmutex_deinit(rwmutex_t* mtx);
 
void rwmutex_read_acquire(rwmutex_t* mtx);
 
uint64_t rwmutex_read_try_acquire(rwmutex_t* mtx);
 
void rwmutex_read_release(rwmutex_t* mtx);
 
void rwmutex_write_acquire(rwmutex_t* mtx);
 
uint64_t rwmutex_write_try_acquire(rwmutex_t* mtx);
 
void rwmutex_write_release(rwmutex_t* mtx);
 
static inline void rwmutex_read_cleanup(rwmutex_t** mutex)
{
    rwmutex_read_release(*mutex);
}
 
static inline void rwmutex_write_cleanup(rwmutex_t** mutex)
{
    rwmutex_write_release(*mutex);
}