1 /* SPDX-License-Identifier: GPL-2.0 */
5 * Linux wait queue related types and methods
7 #include <linux/list.h>
8 #include <linux/stddef.h>
9 #include <linux/spinlock.h>
11 #include <asm/current.h>
13 typedef struct wait_queue_entry wait_queue_entry_t
;
15 typedef int (*wait_queue_func_t
)(struct wait_queue_entry
*wq_entry
, unsigned mode
, int flags
, void *key
);
16 int default_wake_function(struct wait_queue_entry
*wq_entry
, unsigned mode
, int flags
, void *key
);
18 /* wait_queue_entry::flags */
19 #define WQ_FLAG_EXCLUSIVE 0x01
20 #define WQ_FLAG_WOKEN 0x02
21 #define WQ_FLAG_CUSTOM 0x04
22 #define WQ_FLAG_DONE 0x08
23 #define WQ_FLAG_PRIORITY 0x10
26 * A single wait-queue entry structure:
28 struct wait_queue_entry
{
31 wait_queue_func_t func
;
32 struct list_head entry
;
35 struct wait_queue_head
{
37 struct list_head head
;
39 typedef struct wait_queue_head wait_queue_head_t
;
44 * Macros for declaration and initialisaton of the datatypes
47 #define __WAITQUEUE_INITIALIZER(name, tsk) { \
49 .func = default_wake_function, \
50 .entry = { NULL, NULL } }
52 #define DECLARE_WAITQUEUE(name, tsk) \
53 struct wait_queue_entry name = __WAITQUEUE_INITIALIZER(name, tsk)
55 #define __WAIT_QUEUE_HEAD_INITIALIZER(name) { \
56 .lock = __SPIN_LOCK_UNLOCKED(name.lock), \
57 .head = LIST_HEAD_INIT(name.head) }
59 #define DECLARE_WAIT_QUEUE_HEAD(name) \
60 struct wait_queue_head name = __WAIT_QUEUE_HEAD_INITIALIZER(name)
62 extern void __init_waitqueue_head(struct wait_queue_head
*wq_head
, const char *name
, struct lock_class_key
*);
64 #define init_waitqueue_head(wq_head) \
66 static struct lock_class_key __key; \
68 __init_waitqueue_head((wq_head), #wq_head, &__key); \
72 # define __WAIT_QUEUE_HEAD_INIT_ONSTACK(name) \
73 ({ init_waitqueue_head(&name); name; })
74 # define DECLARE_WAIT_QUEUE_HEAD_ONSTACK(name) \
75 struct wait_queue_head name = __WAIT_QUEUE_HEAD_INIT_ONSTACK(name)
77 # define DECLARE_WAIT_QUEUE_HEAD_ONSTACK(name) DECLARE_WAIT_QUEUE_HEAD(name)
80 static inline void init_waitqueue_entry(struct wait_queue_entry
*wq_entry
, struct task_struct
*p
)
83 wq_entry
->private = p
;
84 wq_entry
->func
= default_wake_function
;
88 init_waitqueue_func_entry(struct wait_queue_entry
*wq_entry
, wait_queue_func_t func
)
91 wq_entry
->private = NULL
;
92 wq_entry
->func
= func
;
96 * waitqueue_active -- locklessly test for waiters on the queue
97 * @wq_head: the waitqueue to test for waiters
99 * returns true if the wait list is not empty
101 * NOTE: this function is lockless and requires care, incorrect usage _will_
102 * lead to sporadic and non-obvious failure.
104 * Use either while holding wait_queue_head::lock or when used for wakeups
105 * with an extra smp_mb() like::
107 * CPU0 - waker CPU1 - waiter
110 * @cond = true; prepare_to_wait(&wq_head, &wait, state);
111 * smp_mb(); // smp_mb() from set_current_state()
112 * if (waitqueue_active(wq_head)) if (@cond)
113 * wake_up(wq_head); break;
116 * finish_wait(&wq_head, &wait);
118 * Because without the explicit smp_mb() it's possible for the
119 * waitqueue_active() load to get hoisted over the @cond store such that we'll
120 * observe an empty wait list while the waiter might not observe @cond.
122 * Also note that this 'optimization' trades a spin_lock() for an smp_mb(),
123 * which (when the lock is uncontended) are of roughly equal cost.
125 static inline int waitqueue_active(struct wait_queue_head
*wq_head
)
127 return !list_empty(&wq_head
->head
);
131 * wq_has_single_sleeper - check if there is only one sleeper
132 * @wq_head: wait queue head
134 * Returns true of wq_head has only one sleeper on the list.
136 * Please refer to the comment for waitqueue_active.
138 static inline bool wq_has_single_sleeper(struct wait_queue_head
*wq_head
)
140 return list_is_singular(&wq_head
->head
);
144 * wq_has_sleeper - check if there are any waiting processes
145 * @wq_head: wait queue head
147 * Returns true if wq_head has waiting processes
149 * Please refer to the comment for waitqueue_active.
151 static inline bool wq_has_sleeper(struct wait_queue_head
*wq_head
)
154 * We need to be sure we are in sync with the
155 * add_wait_queue modifications to the wait queue.
157 * This memory barrier should be paired with one on the
161 return waitqueue_active(wq_head
);
164 extern void add_wait_queue(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
);
165 extern void add_wait_queue_exclusive(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
);
166 extern void add_wait_queue_priority(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
);
167 extern void remove_wait_queue(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
);
169 static inline void __add_wait_queue(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
)
171 struct list_head
*head
= &wq_head
->head
;
172 struct wait_queue_entry
*wq
;
174 list_for_each_entry(wq
, &wq_head
->head
, entry
) {
175 if (!(wq
->flags
& WQ_FLAG_PRIORITY
))
179 list_add(&wq_entry
->entry
, head
);
183 * Used for wake-one threads:
186 __add_wait_queue_exclusive(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
)
188 wq_entry
->flags
|= WQ_FLAG_EXCLUSIVE
;
189 __add_wait_queue(wq_head
, wq_entry
);
192 static inline void __add_wait_queue_entry_tail(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
)
194 list_add_tail(&wq_entry
->entry
, &wq_head
->head
);
198 __add_wait_queue_entry_tail_exclusive(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
)
200 wq_entry
->flags
|= WQ_FLAG_EXCLUSIVE
;
201 __add_wait_queue_entry_tail(wq_head
, wq_entry
);
205 __remove_wait_queue(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
)
207 list_del(&wq_entry
->entry
);
210 int __wake_up(struct wait_queue_head
*wq_head
, unsigned int mode
, int nr
, void *key
);
211 void __wake_up_on_current_cpu(struct wait_queue_head
*wq_head
, unsigned int mode
, void *key
);
212 void __wake_up_locked_key(struct wait_queue_head
*wq_head
, unsigned int mode
, void *key
);
213 void __wake_up_sync_key(struct wait_queue_head
*wq_head
, unsigned int mode
, void *key
);
214 void __wake_up_locked_sync_key(struct wait_queue_head
*wq_head
, unsigned int mode
, void *key
);
215 void __wake_up_locked(struct wait_queue_head
*wq_head
, unsigned int mode
, int nr
);
216 void __wake_up_sync(struct wait_queue_head
*wq_head
, unsigned int mode
);
217 void __wake_up_pollfree(struct wait_queue_head
*wq_head
);
219 #define wake_up(x) __wake_up(x, TASK_NORMAL, 1, NULL)
220 #define wake_up_nr(x, nr) __wake_up(x, TASK_NORMAL, nr, NULL)
221 #define wake_up_all(x) __wake_up(x, TASK_NORMAL, 0, NULL)
222 #define wake_up_locked(x) __wake_up_locked((x), TASK_NORMAL, 1)
223 #define wake_up_all_locked(x) __wake_up_locked((x), TASK_NORMAL, 0)
224 #define wake_up_sync(x) __wake_up_sync(x, TASK_NORMAL)
226 #define wake_up_interruptible(x) __wake_up(x, TASK_INTERRUPTIBLE, 1, NULL)
227 #define wake_up_interruptible_nr(x, nr) __wake_up(x, TASK_INTERRUPTIBLE, nr, NULL)
228 #define wake_up_interruptible_all(x) __wake_up(x, TASK_INTERRUPTIBLE, 0, NULL)
229 #define wake_up_interruptible_sync(x) __wake_up_sync((x), TASK_INTERRUPTIBLE)
232 * Wakeup macros to be used to report events to the targets.
234 #define poll_to_key(m) ((void *)(__force uintptr_t)(__poll_t)(m))
235 #define key_to_poll(m) ((__force __poll_t)(uintptr_t)(void *)(m))
236 #define wake_up_poll(x, m) \
237 __wake_up(x, TASK_NORMAL, 1, poll_to_key(m))
238 #define wake_up_poll_on_current_cpu(x, m) \
239 __wake_up_on_current_cpu(x, TASK_NORMAL, poll_to_key(m))
240 #define wake_up_locked_poll(x, m) \
241 __wake_up_locked_key((x), TASK_NORMAL, poll_to_key(m))
242 #define wake_up_interruptible_poll(x, m) \
243 __wake_up(x, TASK_INTERRUPTIBLE, 1, poll_to_key(m))
244 #define wake_up_interruptible_sync_poll(x, m) \
245 __wake_up_sync_key((x), TASK_INTERRUPTIBLE, poll_to_key(m))
246 #define wake_up_interruptible_sync_poll_locked(x, m) \
247 __wake_up_locked_sync_key((x), TASK_INTERRUPTIBLE, poll_to_key(m))
250 * wake_up_pollfree - signal that a polled waitqueue is going away
251 * @wq_head: the wait queue head
253 * In the very rare cases where a ->poll() implementation uses a waitqueue whose
254 * lifetime is tied to a task rather than to the 'struct file' being polled,
255 * this function must be called before the waitqueue is freed so that
256 * non-blocking polls (e.g. epoll) are notified that the queue is going away.
258 * The caller must also RCU-delay the freeing of the wait_queue_head, e.g. via
259 * an explicit synchronize_rcu() or call_rcu(), or via SLAB_TYPESAFE_BY_RCU.
261 static inline void wake_up_pollfree(struct wait_queue_head
*wq_head
)
264 * For performance reasons, we don't always take the queue lock here.
265 * Therefore, we might race with someone removing the last entry from
266 * the queue, and proceed while they still hold the queue lock.
267 * However, rcu_read_lock() is required to be held in such cases, so we
268 * can safely proceed with an RCU-delayed free.
270 if (waitqueue_active(wq_head
))
271 __wake_up_pollfree(wq_head
);
274 #define ___wait_cond_timeout(condition) \
276 bool __cond = (condition); \
277 if (__cond && !__ret) \
282 #define ___wait_is_interruptible(state) \
283 (!__builtin_constant_p(state) || \
284 (state & (TASK_INTERRUPTIBLE | TASK_WAKEKILL)))
286 extern void init_wait_entry(struct wait_queue_entry
*wq_entry
, int flags
);
289 * The below macro ___wait_event() has an explicit shadow of the __ret
290 * variable when used from the wait_event_*() macros.
292 * This is so that both can use the ___wait_cond_timeout() construct
293 * to wrap the condition.
295 * The type inconsistency of the wait_event_*() __ret variable is also
296 * on purpose; we use long where we can return timeout values and int
300 #define ___wait_event(wq_head, condition, state, exclusive, ret, cmd) \
303 struct wait_queue_entry __wq_entry; \
304 long __ret = ret; /* explicit shadow */ \
306 init_wait_entry(&__wq_entry, exclusive ? WQ_FLAG_EXCLUSIVE : 0); \
308 long __int = prepare_to_wait_event(&wq_head, &__wq_entry, state);\
313 if (___wait_is_interruptible(state) && __int) { \
320 finish_wait(&wq_head, &__wq_entry); \
324 #define __wait_event(wq_head, condition) \
325 (void)___wait_event(wq_head, condition, TASK_UNINTERRUPTIBLE, 0, 0, \
329 * wait_event - sleep until a condition gets true
330 * @wq_head: the waitqueue to wait on
331 * @condition: a C expression for the event to wait for
333 * The process is put to sleep (TASK_UNINTERRUPTIBLE) until the
334 * @condition evaluates to true. The @condition is checked each time
335 * the waitqueue @wq_head is woken up.
337 * wake_up() has to be called after changing any variable that could
338 * change the result of the wait condition.
340 #define wait_event(wq_head, condition) \
345 __wait_event(wq_head, condition); \
348 #define __io_wait_event(wq_head, condition) \
349 (void)___wait_event(wq_head, condition, TASK_UNINTERRUPTIBLE, 0, 0, \
353 * io_wait_event() -- like wait_event() but with io_schedule()
355 #define io_wait_event(wq_head, condition) \
360 __io_wait_event(wq_head, condition); \
363 #define __wait_event_freezable(wq_head, condition) \
364 ___wait_event(wq_head, condition, (TASK_INTERRUPTIBLE|TASK_FREEZABLE), \
368 * wait_event_freezable - sleep (or freeze) until a condition gets true
369 * @wq_head: the waitqueue to wait on
370 * @condition: a C expression for the event to wait for
372 * The process is put to sleep (TASK_INTERRUPTIBLE -- so as not to contribute
373 * to system load) until the @condition evaluates to true. The
374 * @condition is checked each time the waitqueue @wq_head is woken up.
376 * wake_up() has to be called after changing any variable that could
377 * change the result of the wait condition.
379 #define wait_event_freezable(wq_head, condition) \
384 __ret = __wait_event_freezable(wq_head, condition); \
388 #define __wait_event_timeout(wq_head, condition, timeout) \
389 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
390 TASK_UNINTERRUPTIBLE, 0, timeout, \
391 __ret = schedule_timeout(__ret))
394 * wait_event_timeout - sleep until a condition gets true or a timeout elapses
395 * @wq_head: the waitqueue to wait on
396 * @condition: a C expression for the event to wait for
397 * @timeout: timeout, in jiffies
399 * The process is put to sleep (TASK_UNINTERRUPTIBLE) until the
400 * @condition evaluates to true. The @condition is checked each time
401 * the waitqueue @wq_head is woken up.
403 * wake_up() has to be called after changing any variable that could
404 * change the result of the wait condition.
407 * 0 if the @condition evaluated to %false after the @timeout elapsed,
408 * 1 if the @condition evaluated to %true after the @timeout elapsed,
409 * or the remaining jiffies (at least 1) if the @condition evaluated
410 * to %true before the @timeout elapsed.
412 #define wait_event_timeout(wq_head, condition, timeout) \
414 long __ret = timeout; \
416 if (!___wait_cond_timeout(condition)) \
417 __ret = __wait_event_timeout(wq_head, condition, timeout); \
421 #define __wait_event_freezable_timeout(wq_head, condition, timeout) \
422 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
423 (TASK_INTERRUPTIBLE|TASK_FREEZABLE), 0, timeout, \
424 __ret = schedule_timeout(__ret))
427 * like wait_event_timeout() -- except it uses TASK_INTERRUPTIBLE to avoid
428 * increasing load and is freezable.
430 #define wait_event_freezable_timeout(wq_head, condition, timeout) \
432 long __ret = timeout; \
434 if (!___wait_cond_timeout(condition)) \
435 __ret = __wait_event_freezable_timeout(wq_head, condition, timeout); \
439 #define __wait_event_exclusive_cmd(wq_head, condition, cmd1, cmd2) \
440 (void)___wait_event(wq_head, condition, TASK_UNINTERRUPTIBLE, 1, 0, \
441 cmd1; schedule(); cmd2)
443 * Just like wait_event_cmd(), except it sets exclusive flag
445 #define wait_event_exclusive_cmd(wq_head, condition, cmd1, cmd2) \
449 __wait_event_exclusive_cmd(wq_head, condition, cmd1, cmd2); \
452 #define __wait_event_cmd(wq_head, condition, cmd1, cmd2) \
453 (void)___wait_event(wq_head, condition, TASK_UNINTERRUPTIBLE, 0, 0, \
454 cmd1; schedule(); cmd2)
457 * wait_event_cmd - sleep until a condition gets true
458 * @wq_head: the waitqueue to wait on
459 * @condition: a C expression for the event to wait for
460 * @cmd1: the command will be executed before sleep
461 * @cmd2: the command will be executed after sleep
463 * The process is put to sleep (TASK_UNINTERRUPTIBLE) until the
464 * @condition evaluates to true. The @condition is checked each time
465 * the waitqueue @wq_head is woken up.
467 * wake_up() has to be called after changing any variable that could
468 * change the result of the wait condition.
470 #define wait_event_cmd(wq_head, condition, cmd1, cmd2) \
474 __wait_event_cmd(wq_head, condition, cmd1, cmd2); \
477 #define __wait_event_interruptible(wq_head, condition) \
478 ___wait_event(wq_head, condition, TASK_INTERRUPTIBLE, 0, 0, \
482 * wait_event_interruptible - sleep until a condition gets true
483 * @wq_head: the waitqueue to wait on
484 * @condition: a C expression for the event to wait for
486 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
487 * @condition evaluates to true or a signal is received.
488 * The @condition is checked each time the waitqueue @wq_head is woken up.
490 * wake_up() has to be called after changing any variable that could
491 * change the result of the wait condition.
493 * The function will return -ERESTARTSYS if it was interrupted by a
494 * signal and 0 if @condition evaluated to true.
496 #define wait_event_interruptible(wq_head, condition) \
501 __ret = __wait_event_interruptible(wq_head, condition); \
505 #define __wait_event_interruptible_timeout(wq_head, condition, timeout) \
506 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
507 TASK_INTERRUPTIBLE, 0, timeout, \
508 __ret = schedule_timeout(__ret))
511 * wait_event_interruptible_timeout - sleep until a condition gets true or a timeout elapses
512 * @wq_head: the waitqueue to wait on
513 * @condition: a C expression for the event to wait for
514 * @timeout: timeout, in jiffies
516 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
517 * @condition evaluates to true or a signal is received.
518 * The @condition is checked each time the waitqueue @wq_head is woken up.
520 * wake_up() has to be called after changing any variable that could
521 * change the result of the wait condition.
524 * 0 if the @condition evaluated to %false after the @timeout elapsed,
525 * 1 if the @condition evaluated to %true after the @timeout elapsed,
526 * the remaining jiffies (at least 1) if the @condition evaluated
527 * to %true before the @timeout elapsed, or -%ERESTARTSYS if it was
528 * interrupted by a signal.
530 #define wait_event_interruptible_timeout(wq_head, condition, timeout) \
532 long __ret = timeout; \
534 if (!___wait_cond_timeout(condition)) \
535 __ret = __wait_event_interruptible_timeout(wq_head, \
536 condition, timeout); \
540 #define __wait_event_hrtimeout(wq_head, condition, timeout, state) \
543 struct hrtimer_sleeper __t; \
545 hrtimer_setup_sleeper_on_stack(&__t, CLOCK_MONOTONIC, \
547 if ((timeout) != KTIME_MAX) { \
548 hrtimer_set_expires_range_ns(&__t.timer, timeout, \
549 current->timer_slack_ns); \
550 hrtimer_sleeper_start_expires(&__t, HRTIMER_MODE_REL); \
553 __ret = ___wait_event(wq_head, condition, state, 0, 0, \
560 hrtimer_cancel(&__t.timer); \
561 destroy_hrtimer_on_stack(&__t.timer); \
566 * wait_event_hrtimeout - sleep until a condition gets true or a timeout elapses
567 * @wq_head: the waitqueue to wait on
568 * @condition: a C expression for the event to wait for
569 * @timeout: timeout, as a ktime_t
571 * The process is put to sleep (TASK_UNINTERRUPTIBLE) until the
572 * @condition evaluates to true or a signal is received.
573 * The @condition is checked each time the waitqueue @wq_head is woken up.
575 * wake_up() has to be called after changing any variable that could
576 * change the result of the wait condition.
578 * The function returns 0 if @condition became true, or -ETIME if the timeout
581 #define wait_event_hrtimeout(wq_head, condition, timeout) \
586 __ret = __wait_event_hrtimeout(wq_head, condition, timeout, \
587 TASK_UNINTERRUPTIBLE); \
592 * wait_event_interruptible_hrtimeout - sleep until a condition gets true or a timeout elapses
593 * @wq: the waitqueue to wait on
594 * @condition: a C expression for the event to wait for
595 * @timeout: timeout, as a ktime_t
597 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
598 * @condition evaluates to true or a signal is received.
599 * The @condition is checked each time the waitqueue @wq is woken up.
601 * wake_up() has to be called after changing any variable that could
602 * change the result of the wait condition.
604 * The function returns 0 if @condition became true, -ERESTARTSYS if it was
605 * interrupted by a signal, or -ETIME if the timeout elapsed.
607 #define wait_event_interruptible_hrtimeout(wq, condition, timeout) \
612 __ret = __wait_event_hrtimeout(wq, condition, timeout, \
613 TASK_INTERRUPTIBLE); \
617 #define __wait_event_interruptible_exclusive(wq, condition) \
618 ___wait_event(wq, condition, TASK_INTERRUPTIBLE, 1, 0, \
621 #define wait_event_interruptible_exclusive(wq, condition) \
626 __ret = __wait_event_interruptible_exclusive(wq, condition); \
630 #define __wait_event_killable_exclusive(wq, condition) \
631 ___wait_event(wq, condition, TASK_KILLABLE, 1, 0, \
634 #define wait_event_killable_exclusive(wq, condition) \
639 __ret = __wait_event_killable_exclusive(wq, condition); \
644 #define __wait_event_freezable_exclusive(wq, condition) \
645 ___wait_event(wq, condition, (TASK_INTERRUPTIBLE|TASK_FREEZABLE), 1, 0,\
648 #define wait_event_freezable_exclusive(wq, condition) \
653 __ret = __wait_event_freezable_exclusive(wq, condition); \
658 * wait_event_idle - wait for a condition without contributing to system load
659 * @wq_head: the waitqueue to wait on
660 * @condition: a C expression for the event to wait for
662 * The process is put to sleep (TASK_IDLE) until the
663 * @condition evaluates to true.
664 * The @condition is checked each time the waitqueue @wq_head is woken up.
666 * wake_up() has to be called after changing any variable that could
667 * change the result of the wait condition.
670 #define wait_event_idle(wq_head, condition) \
674 ___wait_event(wq_head, condition, TASK_IDLE, 0, 0, schedule()); \
678 * wait_event_idle_exclusive - wait for a condition with contributing to system load
679 * @wq_head: the waitqueue to wait on
680 * @condition: a C expression for the event to wait for
682 * The process is put to sleep (TASK_IDLE) until the
683 * @condition evaluates to true.
684 * The @condition is checked each time the waitqueue @wq_head is woken up.
686 * The process is put on the wait queue with an WQ_FLAG_EXCLUSIVE flag
687 * set thus if other processes wait on the same list, when this
688 * process is woken further processes are not considered.
690 * wake_up() has to be called after changing any variable that could
691 * change the result of the wait condition.
694 #define wait_event_idle_exclusive(wq_head, condition) \
698 ___wait_event(wq_head, condition, TASK_IDLE, 1, 0, schedule()); \
701 #define __wait_event_idle_timeout(wq_head, condition, timeout) \
702 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
703 TASK_IDLE, 0, timeout, \
704 __ret = schedule_timeout(__ret))
707 * wait_event_idle_timeout - sleep without load until a condition becomes true or a timeout elapses
708 * @wq_head: the waitqueue to wait on
709 * @condition: a C expression for the event to wait for
710 * @timeout: timeout, in jiffies
712 * The process is put to sleep (TASK_IDLE) until the
713 * @condition evaluates to true. The @condition is checked each time
714 * the waitqueue @wq_head is woken up.
716 * wake_up() has to be called after changing any variable that could
717 * change the result of the wait condition.
720 * 0 if the @condition evaluated to %false after the @timeout elapsed,
721 * 1 if the @condition evaluated to %true after the @timeout elapsed,
722 * or the remaining jiffies (at least 1) if the @condition evaluated
723 * to %true before the @timeout elapsed.
725 #define wait_event_idle_timeout(wq_head, condition, timeout) \
727 long __ret = timeout; \
729 if (!___wait_cond_timeout(condition)) \
730 __ret = __wait_event_idle_timeout(wq_head, condition, timeout); \
734 #define __wait_event_idle_exclusive_timeout(wq_head, condition, timeout) \
735 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
736 TASK_IDLE, 1, timeout, \
737 __ret = schedule_timeout(__ret))
740 * wait_event_idle_exclusive_timeout - sleep without load until a condition becomes true or a timeout elapses
741 * @wq_head: the waitqueue to wait on
742 * @condition: a C expression for the event to wait for
743 * @timeout: timeout, in jiffies
745 * The process is put to sleep (TASK_IDLE) until the
746 * @condition evaluates to true. The @condition is checked each time
747 * the waitqueue @wq_head is woken up.
749 * The process is put on the wait queue with an WQ_FLAG_EXCLUSIVE flag
750 * set thus if other processes wait on the same list, when this
751 * process is woken further processes are not considered.
753 * wake_up() has to be called after changing any variable that could
754 * change the result of the wait condition.
757 * 0 if the @condition evaluated to %false after the @timeout elapsed,
758 * 1 if the @condition evaluated to %true after the @timeout elapsed,
759 * or the remaining jiffies (at least 1) if the @condition evaluated
760 * to %true before the @timeout elapsed.
762 #define wait_event_idle_exclusive_timeout(wq_head, condition, timeout) \
764 long __ret = timeout; \
766 if (!___wait_cond_timeout(condition)) \
767 __ret = __wait_event_idle_exclusive_timeout(wq_head, condition, timeout);\
771 extern int do_wait_intr(wait_queue_head_t
*, wait_queue_entry_t
*);
772 extern int do_wait_intr_irq(wait_queue_head_t
*, wait_queue_entry_t
*);
774 #define __wait_event_interruptible_locked(wq, condition, exclusive, fn) \
777 DEFINE_WAIT(__wait); \
779 __wait.flags |= WQ_FLAG_EXCLUSIVE; \
781 __ret = fn(&(wq), &__wait); \
784 } while (!(condition)); \
785 __remove_wait_queue(&(wq), &__wait); \
786 __set_current_state(TASK_RUNNING); \
792 * wait_event_interruptible_locked - sleep until a condition gets true
793 * @wq: the waitqueue to wait on
794 * @condition: a C expression for the event to wait for
796 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
797 * @condition evaluates to true or a signal is received.
798 * The @condition is checked each time the waitqueue @wq is woken up.
800 * It must be called with wq.lock being held. This spinlock is
801 * unlocked while sleeping but @condition testing is done while lock
802 * is held and when this macro exits the lock is held.
804 * The lock is locked/unlocked using spin_lock()/spin_unlock()
805 * functions which must match the way they are locked/unlocked outside
808 * wake_up_locked() has to be called after changing any variable that could
809 * change the result of the wait condition.
811 * The function will return -ERESTARTSYS if it was interrupted by a
812 * signal and 0 if @condition evaluated to true.
814 #define wait_event_interruptible_locked(wq, condition) \
816 ? 0 : __wait_event_interruptible_locked(wq, condition, 0, do_wait_intr))
819 * wait_event_interruptible_locked_irq - sleep until a condition gets true
820 * @wq: the waitqueue to wait on
821 * @condition: a C expression for the event to wait for
823 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
824 * @condition evaluates to true or a signal is received.
825 * The @condition is checked each time the waitqueue @wq is woken up.
827 * It must be called with wq.lock being held. This spinlock is
828 * unlocked while sleeping but @condition testing is done while lock
829 * is held and when this macro exits the lock is held.
831 * The lock is locked/unlocked using spin_lock_irq()/spin_unlock_irq()
832 * functions which must match the way they are locked/unlocked outside
835 * wake_up_locked() has to be called after changing any variable that could
836 * change the result of the wait condition.
838 * The function will return -ERESTARTSYS if it was interrupted by a
839 * signal and 0 if @condition evaluated to true.
841 #define wait_event_interruptible_locked_irq(wq, condition) \
843 ? 0 : __wait_event_interruptible_locked(wq, condition, 0, do_wait_intr_irq))
846 * wait_event_interruptible_exclusive_locked - sleep exclusively until a condition gets true
847 * @wq: the waitqueue to wait on
848 * @condition: a C expression for the event to wait for
850 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
851 * @condition evaluates to true or a signal is received.
852 * The @condition is checked each time the waitqueue @wq is woken up.
854 * It must be called with wq.lock being held. This spinlock is
855 * unlocked while sleeping but @condition testing is done while lock
856 * is held and when this macro exits the lock is held.
858 * The lock is locked/unlocked using spin_lock()/spin_unlock()
859 * functions which must match the way they are locked/unlocked outside
862 * The process is put on the wait queue with an WQ_FLAG_EXCLUSIVE flag
863 * set thus when other process waits process on the list if this
864 * process is awaken further processes are not considered.
866 * wake_up_locked() has to be called after changing any variable that could
867 * change the result of the wait condition.
869 * The function will return -ERESTARTSYS if it was interrupted by a
870 * signal and 0 if @condition evaluated to true.
872 #define wait_event_interruptible_exclusive_locked(wq, condition) \
874 ? 0 : __wait_event_interruptible_locked(wq, condition, 1, do_wait_intr))
877 * wait_event_interruptible_exclusive_locked_irq - sleep until a condition gets true
878 * @wq: the waitqueue to wait on
879 * @condition: a C expression for the event to wait for
881 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
882 * @condition evaluates to true or a signal is received.
883 * The @condition is checked each time the waitqueue @wq is woken up.
885 * It must be called with wq.lock being held. This spinlock is
886 * unlocked while sleeping but @condition testing is done while lock
887 * is held and when this macro exits the lock is held.
889 * The lock is locked/unlocked using spin_lock_irq()/spin_unlock_irq()
890 * functions which must match the way they are locked/unlocked outside
893 * The process is put on the wait queue with an WQ_FLAG_EXCLUSIVE flag
894 * set thus when other process waits process on the list if this
895 * process is awaken further processes are not considered.
897 * wake_up_locked() has to be called after changing any variable that could
898 * change the result of the wait condition.
900 * The function will return -ERESTARTSYS if it was interrupted by a
901 * signal and 0 if @condition evaluated to true.
903 #define wait_event_interruptible_exclusive_locked_irq(wq, condition) \
905 ? 0 : __wait_event_interruptible_locked(wq, condition, 1, do_wait_intr_irq))
908 #define __wait_event_killable(wq, condition) \
909 ___wait_event(wq, condition, TASK_KILLABLE, 0, 0, schedule())
912 * wait_event_killable - sleep until a condition gets true
913 * @wq_head: the waitqueue to wait on
914 * @condition: a C expression for the event to wait for
916 * The process is put to sleep (TASK_KILLABLE) until the
917 * @condition evaluates to true or a signal is received.
918 * The @condition is checked each time the waitqueue @wq_head is woken up.
920 * wake_up() has to be called after changing any variable that could
921 * change the result of the wait condition.
923 * The function will return -ERESTARTSYS if it was interrupted by a
924 * signal and 0 if @condition evaluated to true.
926 #define wait_event_killable(wq_head, condition) \
931 __ret = __wait_event_killable(wq_head, condition); \
935 #define __wait_event_state(wq, condition, state) \
936 ___wait_event(wq, condition, state, 0, 0, schedule())
939 * wait_event_state - sleep until a condition gets true
940 * @wq_head: the waitqueue to wait on
941 * @condition: a C expression for the event to wait for
942 * @state: state to sleep in
944 * The process is put to sleep (@state) until the @condition evaluates to true
945 * or a signal is received (when allowed by @state). The @condition is checked
946 * each time the waitqueue @wq_head is woken up.
948 * wake_up() has to be called after changing any variable that could
949 * change the result of the wait condition.
951 * The function will return -ERESTARTSYS if it was interrupted by a signal
952 * (when allowed by @state) and 0 if @condition evaluated to true.
954 #define wait_event_state(wq_head, condition, state) \
959 __ret = __wait_event_state(wq_head, condition, state); \
963 #define __wait_event_killable_timeout(wq_head, condition, timeout) \
964 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
965 TASK_KILLABLE, 0, timeout, \
966 __ret = schedule_timeout(__ret))
969 * wait_event_killable_timeout - sleep until a condition gets true or a timeout elapses
970 * @wq_head: the waitqueue to wait on
971 * @condition: a C expression for the event to wait for
972 * @timeout: timeout, in jiffies
974 * The process is put to sleep (TASK_KILLABLE) until the
975 * @condition evaluates to true or a kill signal is received.
976 * The @condition is checked each time the waitqueue @wq_head is woken up.
978 * wake_up() has to be called after changing any variable that could
979 * change the result of the wait condition.
982 * 0 if the @condition evaluated to %false after the @timeout elapsed,
983 * 1 if the @condition evaluated to %true after the @timeout elapsed,
984 * the remaining jiffies (at least 1) if the @condition evaluated
985 * to %true before the @timeout elapsed, or -%ERESTARTSYS if it was
986 * interrupted by a kill signal.
988 * Only kill signals interrupt this process.
990 #define wait_event_killable_timeout(wq_head, condition, timeout) \
992 long __ret = timeout; \
994 if (!___wait_cond_timeout(condition)) \
995 __ret = __wait_event_killable_timeout(wq_head, \
996 condition, timeout); \
1001 #define __wait_event_lock_irq(wq_head, condition, lock, cmd) \
1002 (void)___wait_event(wq_head, condition, TASK_UNINTERRUPTIBLE, 0, 0, \
1003 spin_unlock_irq(&lock); \
1006 spin_lock_irq(&lock))
1009 * wait_event_lock_irq_cmd - sleep until a condition gets true. The
1010 * condition is checked under the lock. This
1011 * is expected to be called with the lock
1013 * @wq_head: the waitqueue to wait on
1014 * @condition: a C expression for the event to wait for
1015 * @lock: a locked spinlock_t, which will be released before cmd
1016 * and schedule() and reacquired afterwards.
1017 * @cmd: a command which is invoked outside the critical section before
1020 * The process is put to sleep (TASK_UNINTERRUPTIBLE) until the
1021 * @condition evaluates to true. The @condition is checked each time
1022 * the waitqueue @wq_head is woken up.
1024 * wake_up() has to be called after changing any variable that could
1025 * change the result of the wait condition.
1027 * This is supposed to be called while holding the lock. The lock is
1028 * dropped before invoking the cmd and going to sleep and is reacquired
1031 #define wait_event_lock_irq_cmd(wq_head, condition, lock, cmd) \
1035 __wait_event_lock_irq(wq_head, condition, lock, cmd); \
1039 * wait_event_lock_irq - sleep until a condition gets true. The
1040 * condition is checked under the lock. This
1041 * is expected to be called with the lock
1043 * @wq_head: the waitqueue to wait on
1044 * @condition: a C expression for the event to wait for
1045 * @lock: a locked spinlock_t, which will be released before schedule()
1046 * and reacquired afterwards.
1048 * The process is put to sleep (TASK_UNINTERRUPTIBLE) until the
1049 * @condition evaluates to true. The @condition is checked each time
1050 * the waitqueue @wq_head is woken up.
1052 * wake_up() has to be called after changing any variable that could
1053 * change the result of the wait condition.
1055 * This is supposed to be called while holding the lock. The lock is
1056 * dropped before going to sleep and is reacquired afterwards.
1058 #define wait_event_lock_irq(wq_head, condition, lock) \
1062 __wait_event_lock_irq(wq_head, condition, lock, ); \
1066 #define __wait_event_interruptible_lock_irq(wq_head, condition, lock, cmd) \
1067 ___wait_event(wq_head, condition, TASK_INTERRUPTIBLE, 0, 0, \
1068 spin_unlock_irq(&lock); \
1071 spin_lock_irq(&lock))
1074 * wait_event_interruptible_lock_irq_cmd - sleep until a condition gets true.
1075 * The condition is checked under the lock. This is expected to
1076 * be called with the lock taken.
1077 * @wq_head: the waitqueue to wait on
1078 * @condition: a C expression for the event to wait for
1079 * @lock: a locked spinlock_t, which will be released before cmd and
1080 * schedule() and reacquired afterwards.
1081 * @cmd: a command which is invoked outside the critical section before
1084 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
1085 * @condition evaluates to true or a signal is received. The @condition is
1086 * checked each time the waitqueue @wq_head is woken up.
1088 * wake_up() has to be called after changing any variable that could
1089 * change the result of the wait condition.
1091 * This is supposed to be called while holding the lock. The lock is
1092 * dropped before invoking the cmd and going to sleep and is reacquired
1095 * The macro will return -ERESTARTSYS if it was interrupted by a signal
1096 * and 0 if @condition evaluated to true.
1098 #define wait_event_interruptible_lock_irq_cmd(wq_head, condition, lock, cmd) \
1102 __ret = __wait_event_interruptible_lock_irq(wq_head, \
1103 condition, lock, cmd); \
1108 * wait_event_interruptible_lock_irq - sleep until a condition gets true.
1109 * The condition is checked under the lock. This is expected
1110 * to be called with the lock taken.
1111 * @wq_head: the waitqueue to wait on
1112 * @condition: a C expression for the event to wait for
1113 * @lock: a locked spinlock_t, which will be released before schedule()
1114 * and reacquired afterwards.
1116 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
1117 * @condition evaluates to true or signal is received. The @condition is
1118 * checked each time the waitqueue @wq_head is woken up.
1120 * wake_up() has to be called after changing any variable that could
1121 * change the result of the wait condition.
1123 * This is supposed to be called while holding the lock. The lock is
1124 * dropped before going to sleep and is reacquired afterwards.
1126 * The macro will return -ERESTARTSYS if it was interrupted by a signal
1127 * and 0 if @condition evaluated to true.
1129 #define wait_event_interruptible_lock_irq(wq_head, condition, lock) \
1133 __ret = __wait_event_interruptible_lock_irq(wq_head, \
1134 condition, lock,); \
1138 #define __wait_event_lock_irq_timeout(wq_head, condition, lock, timeout, state) \
1139 ___wait_event(wq_head, ___wait_cond_timeout(condition), \
1140 state, 0, timeout, \
1141 spin_unlock_irq(&lock); \
1142 __ret = schedule_timeout(__ret); \
1143 spin_lock_irq(&lock));
1146 * wait_event_interruptible_lock_irq_timeout - sleep until a condition gets
1147 * true or a timeout elapses. The condition is checked under
1148 * the lock. This is expected to be called with the lock taken.
1149 * @wq_head: the waitqueue to wait on
1150 * @condition: a C expression for the event to wait for
1151 * @lock: a locked spinlock_t, which will be released before schedule()
1152 * and reacquired afterwards.
1153 * @timeout: timeout, in jiffies
1155 * The process is put to sleep (TASK_INTERRUPTIBLE) until the
1156 * @condition evaluates to true or signal is received. The @condition is
1157 * checked each time the waitqueue @wq_head is woken up.
1159 * wake_up() has to be called after changing any variable that could
1160 * change the result of the wait condition.
1162 * This is supposed to be called while holding the lock. The lock is
1163 * dropped before going to sleep and is reacquired afterwards.
1165 * The function returns 0 if the @timeout elapsed, -ERESTARTSYS if it
1166 * was interrupted by a signal, and the remaining jiffies otherwise
1167 * if the condition evaluated to true before the timeout elapsed.
1169 #define wait_event_interruptible_lock_irq_timeout(wq_head, condition, lock, \
1172 long __ret = timeout; \
1173 if (!___wait_cond_timeout(condition)) \
1174 __ret = __wait_event_lock_irq_timeout( \
1175 wq_head, condition, lock, timeout, \
1176 TASK_INTERRUPTIBLE); \
1180 #define wait_event_lock_irq_timeout(wq_head, condition, lock, timeout) \
1182 long __ret = timeout; \
1183 if (!___wait_cond_timeout(condition)) \
1184 __ret = __wait_event_lock_irq_timeout( \
1185 wq_head, condition, lock, timeout, \
1186 TASK_UNINTERRUPTIBLE); \
1191 * Waitqueues which are removed from the waitqueue_head at wakeup time
1193 void prepare_to_wait(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
, int state
);
1194 bool prepare_to_wait_exclusive(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
, int state
);
1195 long prepare_to_wait_event(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
, int state
);
1196 void finish_wait(struct wait_queue_head
*wq_head
, struct wait_queue_entry
*wq_entry
);
1197 long wait_woken(struct wait_queue_entry
*wq_entry
, unsigned mode
, long timeout
);
1198 int woken_wake_function(struct wait_queue_entry
*wq_entry
, unsigned mode
, int sync
, void *key
);
1199 int autoremove_wake_function(struct wait_queue_entry
*wq_entry
, unsigned mode
, int sync
, void *key
);
1201 #define DEFINE_WAIT_FUNC(name, function) \
1202 struct wait_queue_entry name = { \
1203 .private = current, \
1205 .entry = LIST_HEAD_INIT((name).entry), \
1208 #define DEFINE_WAIT(name) DEFINE_WAIT_FUNC(name, autoremove_wake_function)
1210 #define init_wait(wait) \
1212 (wait)->private = current; \
1213 (wait)->func = autoremove_wake_function; \
1214 INIT_LIST_HEAD(&(wait)->entry); \
1215 (wait)->flags = 0; \
1218 typedef int (*task_call_f
)(struct task_struct
*p
, void *arg
);
1219 extern int task_call_func(struct task_struct
*p
, task_call_f func
, void *arg
);
1221 #endif /* _LINUX_WAIT_H */