wash/mango
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sched: wait: implement wakeup_n, waitqueue_empty

Browse Source
This commit is contained in:
max 🍓
2026-03-18 20:56:15 +00:00
parent 04d05adbe8
commit b774415f64
2 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
include/kernel/wait.h
View File

@@ -40,6 +40,15 @@ extern void thread_wait_end_nosleep(
struct waitqueue *q); struct waitqueue *q);
extern void wait_on_queue(struct waitqueue *q); extern void wait_on_queue(struct waitqueue *q);
extern void wakeup_queue(struct waitqueue *q); extern void wakeup_queue(struct waitqueue *q);
extern void wakeup_n(struct waitqueue *q, size_t n);
extern void wakeup_one(struct waitqueue *q); extern void wakeup_one(struct waitqueue *q);
static inline bool waitqueue_empty(struct waitqueue *wq)
{
unsigned long flags;
spin_lock_irqsave(&wq->wq_lock, &flags);
bool result = queue_empty(&wq->wq_waiters);
spin_unlock_irqrestore(&wq->wq_lock, flags);
return result;
}
#endif #endif

18
sched/wait.c
View File

@@ -69,6 +69,24 @@ void wakeup_queue(struct waitqueue *q)
spin_unlock_irqrestore(&q->wq_lock, flags); spin_unlock_irqrestore(&q->wq_lock, flags);
} }
void wakeup_n(struct waitqueue *q, size_t nr_waiters)
{
unsigned long flags;
spin_lock_irqsave(&q->wq_lock, &flags);
struct queue_entry *ent = queue_pop_front(&q->wq_waiters);
while (ent && nr_waiters > 0) {
struct wait_item *waiter
= QUEUE_CONTAINER(struct wait_item, w_entry, ent);
struct thread *thr = waiter->w_thread;
thread_awaken(thr);
ent = queue_pop_front(&q->wq_waiters);
nr_waiters--;
}
spin_unlock_irqrestore(&q->wq_lock, flags);
}
void wakeup_one(struct waitqueue *q) void wakeup_one(struct waitqueue *q)
{ {
unsigned long flags; unsigned long flags;