waitqueue.h

 
#ifndef KERNEL_WAITQUEUE_H
#define KERNEL_WAITQUEUE_H
 
#include <kernel/process.h>
#include <kernel/spinlock.h>
 
#include <libalgo/queue.h>
 
struct waitqueue {
    spinlock_t lock; /*<! Synchronization lock */
    queue_t queue;   /*<! The queue of waiting threads */
};
 
#define __WAITQUEUE_INIT(_queue)                                             \
    {                                                                        \
        __INIT_SPINLOCK(.lock), .queue = __QUEUE_INIT(&(_queue).queue.head), \
    }
#define WAITQUEUE_INIT(_queue) ((struct waitqueue)__WAITQUEUE_INIT(_queue))
 
#define __INIT_WAITQUEUE(_queue) _queue = __WAITQUEUE_INIT(_queue)
#define INIT_WAITQUEUE(_queue) _queue = WAITQUEUE_INIT(_queue)
 
#define DECLARE_WAITQUEUE(_queue) struct waitqueue INIT_WAITQUEUE(_queue)
 
bool waitqueue_is_empty(struct waitqueue *);
 
void waitqueue_enqueue_locked(struct waitqueue *, struct thread *);
 
#define waitqueue_enqueue(waitqueue, thread)         \
    ({                                               \
        spinlock_acquire(&(waitqueue)->lock);        \
        waitqueue_enqueue_locked(waitqueue, thread); \
    })
 
const struct thread *waitqueue_peek(struct waitqueue *);
 
struct thread *waitqueue_dequeue(struct waitqueue *);
 
size_t waitqueue_dequeue_all(struct waitqueue *);
 
#endif /* KERNEL_WAITQUEUE_H */