drm_wait_netbsd.h revision 1.3 1 /* $NetBSD: drm_wait_netbsd.h,v 1.3 2014/07/16 20:56:25 riastradh Exp $ */
2
3 /*-
4 * Copyright (c) 2013 The NetBSD Foundation, Inc.
5 * All rights reserved.
6 *
7 * This code is derived from software contributed to The NetBSD Foundation
8 * by Taylor R. Campbell.
9 *
10 * Redistribution and use in source and binary forms, with or without
11 * modification, are permitted provided that the following conditions
12 * are met:
13 * 1. Redistributions of source code must retain the above copyright
14 * notice, this list of conditions and the following disclaimer.
15 * 2. Redistributions in binary form must reproduce the above copyright
16 * notice, this list of conditions and the following disclaimer in the
17 * documentation and/or other materials provided with the distribution.
18 *
19 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 * POSSIBILITY OF SUCH DAMAGE.
30 */
31
32 #ifndef _DRM_DRM_WAIT_NETBSD_H_
33 #define _DRM_DRM_WAIT_NETBSD_H_
34
35 #include <sys/param.h>
36 #include <sys/condvar.h>
37 #if DIAGNOSTIC
38 #include <sys/cpu.h> /* cpu_intr_p */
39 #endif
40 #include <sys/kernel.h>
41 #include <sys/mutex.h>
42 #include <sys/systm.h>
43
44 #include <linux/mutex.h>
45 #include <linux/spinlock.h>
46
47 typedef kcondvar_t drm_waitqueue_t;
48
49 #define DRM_HZ hz /* XXX Hurk... */
50
51 static inline void
52 DRM_INIT_WAITQUEUE(drm_waitqueue_t *q, const char *name)
53 {
54 cv_init(q, name);
55 }
56
57 static inline void
58 DRM_DESTROY_WAITQUEUE(drm_waitqueue_t *q)
59 {
60 cv_destroy(q);
61 }
62
63 static inline bool
64 DRM_WAITERS_P(drm_waitqueue_t *q, struct mutex *interlock)
65 {
66 KASSERT(mutex_is_locked(interlock));
67 return cv_has_waiters(q);
68 }
69
70 static inline void
71 DRM_WAKEUP_ONE(drm_waitqueue_t *q, struct mutex *interlock)
72 {
73 KASSERT(mutex_is_locked(interlock));
74 cv_signal(q);
75 }
76
77 static inline void
78 DRM_WAKEUP_ALL(drm_waitqueue_t *q, struct mutex *interlock)
79 {
80 KASSERT(mutex_is_locked(interlock));
81 cv_broadcast(q);
82 }
83
84 static inline bool
85 DRM_SPIN_WAITERS_P(drm_waitqueue_t *q, spinlock_t *interlock)
86 {
87 KASSERT(spin_is_locked(interlock));
88 return cv_has_waiters(q);
89 }
90
91 static inline void
92 DRM_SPIN_WAKEUP_ONE(drm_waitqueue_t *q, spinlock_t *interlock)
93 {
94 KASSERT(spin_is_locked(interlock));
95 cv_signal(q);
96 }
97
98 static inline void
99 DRM_SPIN_WAKEUP_ALL(drm_waitqueue_t *q, spinlock_t *interlock)
100 {
101 KASSERT(spin_is_locked(interlock));
102 cv_broadcast(q);
103 }
104
105 #define _DRM_WAIT_UNTIL(RET, WAIT, Q, INTERLOCK, CONDITION) do \
106 { \
107 KASSERT(mutex_is_locked((INTERLOCK))); \
108 ASSERT_SLEEPABLE(); \
109 KASSERT(!cold); \
110 for (;;) { \
111 if (CONDITION) { \
112 (RET) = 0; \
113 break; \
114 } \
115 /* XXX errno NetBSD->Linux */ \
116 (RET) = -WAIT((Q), &(INTERLOCK)->mtx_lock); \
117 if (RET) \
118 break; \
119 } \
120 } while (0)
121
122 #define cv_wait_nointr(Q, I) (cv_wait((Q), (I)), 0)
123
124 #define DRM_WAIT_NOINTR_UNTIL(RET, Q, I, C) \
125 _DRM_WAIT_UNTIL(RET, cv_wait_nointr, Q, I, C)
126
127 #define DRM_WAIT_UNTIL(RET, Q, I, C) \
128 _DRM_WAIT_UNTIL(RET, cv_wait_sig, Q, I, C)
129
130 #define _DRM_TIMED_WAIT_UNTIL(RET, WAIT, Q, INTERLOCK, TICKS, CONDITION) do \
131 { \
132 extern int hardclock_ticks; \
133 const int _dtwu_start = hardclock_ticks; \
134 int _dtwu_ticks = (TICKS); \
135 KASSERT(mutex_is_locked((INTERLOCK))); \
136 ASSERT_SLEEPABLE(); \
137 KASSERT(!cold); \
138 for (;;) { \
139 if (CONDITION) { \
140 (RET) = _dtwu_ticks; \
141 break; \
142 } \
143 /* XXX errno NetBSD->Linux */ \
144 (RET) = -WAIT((Q), &(INTERLOCK)->mtx_lock, \
145 _dtwu_ticks); \
146 if (RET) \
147 break; \
148 const int _dtwu_now = hardclock_ticks; \
149 KASSERT(_dtwu_start <= _dtwu_now); \
150 if ((_dtwu_now - _dtwu_start) < _dtwu_ticks) { \
151 _dtwu_ticks -= (_dtwu_now - _dtwu_start); \
152 } else { \
153 (RET) = 0; \
154 break; \
155 } \
156 } \
157 } while (0)
158
159 #define DRM_TIMED_WAIT_NOINTR_UNTIL(RET, Q, I, T, C) \
160 _DRM_TIMED_WAIT_UNTIL(RET, cv_timedwait, Q, I, T, C)
161
162 #define DRM_TIMED_WAIT_UNTIL(RET, Q, I, T, C) \
163 _DRM_TIMED_WAIT_UNTIL(RET, cv_timedwait_sig, Q, I, T, C)
164
165 /*
166 * XXX Can't assert sleepable here because we hold a spin lock. At
167 * least we can assert that we're not in (soft) interrupt context, and
168 * hope that nobody tries to use these with a sometimes quickly
169 * satisfied condition while holding a different spin lock.
170 */
171
172 #define _DRM_SPIN_WAIT_UNTIL(RET, WAIT, Q, INTERLOCK, CONDITION) do \
173 { \
174 KASSERT(spin_is_locked((INTERLOCK))); \
175 KASSERT(!cpu_intr_p()); \
176 KASSERT(!cpu_softintr_p()); \
177 KASSERT(!cold); \
178 while (!(CONDITION)) { \
179 /* XXX errno NetBSD->Linux */ \
180 (RET) = -WAIT((Q), &(INTERLOCK)->sl_lock); \
181 if (RET) \
182 break; \
183 } \
184 } while (0)
185
186 #define DRM_SPIN_WAIT_NOINTR_UNTIL(RET, Q, I, C) \
187 _DRM_SPIN_WAIT_UNTIL(RET, cv_wait_nointr, Q, I, C)
188
189 #define DRM_SPIN_WAIT_UNTIL(RET, Q, I, C) \
190 _DRM_SPIN_WAIT_UNTIL(RET, cv_wait_sig, Q, I, C)
191
192 #define _DRM_SPIN_TIMED_WAIT_UNTIL(RET, WAIT, Q, INTERLOCK, TICKS, CONDITION) \
193 do \
194 { \
195 extern int hardclock_ticks; \
196 const int _dstwu_start = hardclock_ticks; \
197 int _dstwu_ticks = (TICKS); \
198 KASSERT(spin_is_locked((INTERLOCK))); \
199 KASSERT(!cpu_intr_p()); \
200 KASSERT(!cpu_softintr_p()); \
201 KASSERT(!cold); \
202 for (;;) { \
203 if (CONDITION) { \
204 (RET) = _dstwu_ticks; \
205 break; \
206 } \
207 /* XXX errno NetBSD->Linux */ \
208 (RET) = -WAIT((Q), &(INTERLOCK)->sl_lock, \
209 _dstwu_ticks); \
210 if (RET) \
211 break; \
212 const int _dstwu_now = hardclock_ticks; \
213 KASSERT(_dstwu_start <= _dstwu_now); \
214 if ((_dstwu_now - _dstwu_start) < _dstwu_ticks) { \
215 _dstwu_ticks -= (_dstwu_now - _dstwu_start); \
216 } else { \
217 (RET) = 0; \
218 break; \
219 } \
220 } \
221 } while (0)
222
223 #define DRM_SPIN_TIMED_WAIT_NOINTR_UNTIL(RET, Q, I, T, C) \
224 _DRM_SPIN_TIMED_WAIT_UNTIL(RET, cv_timedwait, Q, I, T, C)
225
226 #define DRM_SPIN_TIMED_WAIT_UNTIL(RET, Q, I, T, C) \
227 _DRM_SPIN_TIMED_WAIT_UNTIL(RET, cv_timedwait_sig, Q, I, T, C)
228
229 #endif /* _DRM_DRM_WAIT_NETBSD_H_ */
230