1 /*-
2 * Copyright (c) 2010 Isilon Systems, Inc.
3 * Copyright (c) 2010 iX Systems, Inc.
4 * Copyright (c) 2010 Panasas, Inc.
5 * Copyright (c) 2013, 2014 Mellanox Technologies, Ltd.
6 * All rights reserved.
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
10 * are met:
11 * 1. Redistributions of source code must retain the above copyright
12 * notice unmodified, this list of conditions, and the following
13 * disclaimer.
14 * 2. Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in the
16 * documentation and/or other materials provided with the distribution.
17 *
18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
23 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
27 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 *
29 * $FreeBSD$
30 */
31 #ifndef _LINUX_WAIT_H_
32 #define _LINUX_WAIT_H_
33
34 #include <linux/spinlock.h>
35 #include <linux/sched.h>
36 #include <linux/list.h>
37
38 #include <sys/param.h>
39 #include <sys/systm.h>
40 #include <sys/sleepqueue.h>
41 #include <sys/kernel.h>
42 #include <sys/proc.h>
43
44 typedef struct {
45 } wait_queue_t;
46
47 typedef struct {
48 unsigned int wchan;
49 } wait_queue_head_t;
50
51 #define init_waitqueue_head(x) \
52 do { } while (0)
53
54 static inline void
__wake_up(wait_queue_head_t * q,int all)55 __wake_up(wait_queue_head_t *q, int all)
56 {
57 int wakeup_swapper;
58 void *c;
59
60 c = &q->wchan;
61 sleepq_lock(c);
62 if (all)
63 wakeup_swapper = sleepq_broadcast(c, SLEEPQ_SLEEP, 0, 0);
64 else
65 wakeup_swapper = sleepq_signal(c, SLEEPQ_SLEEP, 0, 0);
66 sleepq_release(c);
67 if (wakeup_swapper)
68 kick_proc0();
69 }
70
71 #define wake_up(q) __wake_up(q, 0)
72 #define wake_up_nr(q, nr) __wake_up(q, 1)
73 #define wake_up_all(q) __wake_up(q, 1)
74 #define wake_up_interruptible(q) __wake_up(q, 0)
75 #define wake_up_interruptible_nr(q, nr) __wake_up(q, 1)
76 #define wake_up_interruptible_all(q, nr) __wake_up(q, 1)
77
78 #define wait_event(q, cond) \
79 do { \
80 void *c = &(q).wchan; \
81 if (!(cond)) { \
82 for (;;) { \
83 sleepq_lock(c); \
84 if (cond) { \
85 sleepq_release(c); \
86 break; \
87 } \
88 sleepq_add(c, NULL, "completion", SLEEPQ_SLEEP, 0); \
89 sleepq_wait(c, 0); \
90 } \
91 } \
92 } while (0)
93
94 #define wait_event_interruptible(q, cond) \
95 ({ \
96 void *c = &(q).wchan; \
97 int _error; \
98 \
99 _error = 0; \
100 if (!(cond)) { \
101 for (; _error == 0;) { \
102 sleepq_lock(c); \
103 if (cond) { \
104 sleepq_release(c); \
105 break; \
106 } \
107 sleepq_add(c, NULL, "completion", \
108 SLEEPQ_SLEEP | SLEEPQ_INTERRUPTIBLE, 0); \
109 if (sleepq_wait_sig(c, 0)) \
110 _error = -ERESTARTSYS; \
111 } \
112 } \
113 -_error; \
114 })
115
116 static inline int
waitqueue_active(wait_queue_head_t * q)117 waitqueue_active(wait_queue_head_t *q)
118 {
119 return 0; /* XXX: not really implemented */
120 }
121
122 #define DEFINE_WAIT(name) \
123 wait_queue_t name = {}
124
125 static inline void
prepare_to_wait(wait_queue_head_t * q,wait_queue_t * wait,int state)126 prepare_to_wait(wait_queue_head_t *q, wait_queue_t *wait, int state)
127 {
128 }
129
130 static inline void
finish_wait(wait_queue_head_t * q,wait_queue_t * wait)131 finish_wait(wait_queue_head_t *q, wait_queue_t *wait)
132 {
133 }
134
135 #endif /* _LINUX_WAIT_H_ */
136