subr_lockdebug.c revision 1.56 1 1.56 pgoyette /* $NetBSD: subr_lockdebug.c,v 1.56 2017/05/01 21:35:26 pgoyette Exp $ */
2 1.2 ad
3 1.2 ad /*-
4 1.28 ad * Copyright (c) 2006, 2007, 2008 The NetBSD Foundation, Inc.
5 1.2 ad * All rights reserved.
6 1.2 ad *
7 1.2 ad * This code is derived from software contributed to The NetBSD Foundation
8 1.2 ad * by Andrew Doran.
9 1.2 ad *
10 1.2 ad * Redistribution and use in source and binary forms, with or without
11 1.2 ad * modification, are permitted provided that the following conditions
12 1.2 ad * are met:
13 1.2 ad * 1. Redistributions of source code must retain the above copyright
14 1.2 ad * notice, this list of conditions and the following disclaimer.
15 1.2 ad * 2. Redistributions in binary form must reproduce the above copyright
16 1.2 ad * notice, this list of conditions and the following disclaimer in the
17 1.2 ad * documentation and/or other materials provided with the distribution.
18 1.2 ad *
19 1.2 ad * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.2 ad * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.2 ad * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.2 ad * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.2 ad * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.2 ad * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.2 ad * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.2 ad * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.2 ad * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.2 ad * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.2 ad * POSSIBILITY OF SUCH DAMAGE.
30 1.2 ad */
31 1.2 ad
32 1.2 ad /*
33 1.11 ad * Basic lock debugging code shared among lock primitives.
34 1.2 ad */
35 1.2 ad
36 1.9 dsl #include <sys/cdefs.h>
37 1.56 pgoyette __KERNEL_RCSID(0, "$NetBSD: subr_lockdebug.c,v 1.56 2017/05/01 21:35:26 pgoyette Exp $");
38 1.9 dsl
39 1.54 ozaki #ifdef _KERNEL_OPT
40 1.2 ad #include "opt_ddb.h"
41 1.54 ozaki #endif
42 1.2 ad
43 1.2 ad #include <sys/param.h>
44 1.2 ad #include <sys/proc.h>
45 1.2 ad #include <sys/systm.h>
46 1.10 ad #include <sys/kernel.h>
47 1.2 ad #include <sys/kmem.h>
48 1.2 ad #include <sys/lockdebug.h>
49 1.2 ad #include <sys/sleepq.h>
50 1.10 ad #include <sys/cpu.h>
51 1.22 ad #include <sys/atomic.h>
52 1.26 ad #include <sys/lock.h>
53 1.43 matt #include <sys/rbtree.h>
54 1.16 yamt
55 1.25 ad #include <machine/lock.h>
56 1.25 ad
57 1.28 ad unsigned int ld_panic;
58 1.28 ad
59 1.2 ad #ifdef LOCKDEBUG
60 1.2 ad
61 1.2 ad #define LD_BATCH_SHIFT 9
62 1.2 ad #define LD_BATCH (1 << LD_BATCH_SHIFT)
63 1.2 ad #define LD_BATCH_MASK (LD_BATCH - 1)
64 1.2 ad #define LD_MAX_LOCKS 1048576
65 1.2 ad #define LD_SLOP 16
66 1.2 ad
67 1.2 ad #define LD_LOCKED 0x01
68 1.2 ad #define LD_SLEEPER 0x02
69 1.2 ad
70 1.23 ad #define LD_WRITE_LOCK 0x80000000
71 1.23 ad
72 1.2 ad typedef struct lockdebug {
73 1.42 rmind struct rb_node ld_rb_node;
74 1.34 ad __cpu_simple_lock_t ld_spinlock;
75 1.2 ad _TAILQ_ENTRY(struct lockdebug, volatile) ld_chain;
76 1.2 ad _TAILQ_ENTRY(struct lockdebug, volatile) ld_achain;
77 1.2 ad volatile void *ld_lock;
78 1.2 ad lockops_t *ld_lockops;
79 1.2 ad struct lwp *ld_lwp;
80 1.2 ad uintptr_t ld_locked;
81 1.2 ad uintptr_t ld_unlocked;
82 1.10 ad uintptr_t ld_initaddr;
83 1.2 ad uint16_t ld_shares;
84 1.2 ad uint16_t ld_cpu;
85 1.2 ad uint8_t ld_flags;
86 1.2 ad uint8_t ld_shwant; /* advisory */
87 1.2 ad uint8_t ld_exwant; /* advisory */
88 1.2 ad uint8_t ld_unused;
89 1.2 ad } volatile lockdebug_t;
90 1.2 ad
91 1.2 ad typedef _TAILQ_HEAD(lockdebuglist, struct lockdebug, volatile) lockdebuglist_t;
92 1.2 ad
93 1.34 ad __cpu_simple_lock_t ld_mod_lk;
94 1.13 matt lockdebuglist_t ld_free = TAILQ_HEAD_INITIALIZER(ld_free);
95 1.13 matt lockdebuglist_t ld_all = TAILQ_HEAD_INITIALIZER(ld_all);
96 1.2 ad int ld_nfree;
97 1.2 ad int ld_freeptr;
98 1.2 ad int ld_recurse;
99 1.5 ad bool ld_nomore;
100 1.2 ad lockdebug_t ld_prime[LD_BATCH];
101 1.2 ad
102 1.55 christos static void lockdebug_abort1(const char *, size_t, lockdebug_t *, int,
103 1.55 christos const char *, bool);
104 1.34 ad static int lockdebug_more(int);
105 1.5 ad static void lockdebug_init(void);
106 1.52 christos static void lockdebug_dump(lockdebug_t *, void (*)(const char *, ...)
107 1.52 christos __printflike(1, 2));
108 1.2 ad
109 1.16 yamt static signed int
110 1.42 rmind ld_rbto_compare_nodes(void *ctx, const void *n1, const void *n2)
111 1.16 yamt {
112 1.42 rmind const lockdebug_t *ld1 = n1;
113 1.42 rmind const lockdebug_t *ld2 = n2;
114 1.20 yamt const uintptr_t a = (uintptr_t)ld1->ld_lock;
115 1.20 yamt const uintptr_t b = (uintptr_t)ld2->ld_lock;
116 1.20 yamt
117 1.20 yamt if (a < b)
118 1.42 rmind return -1;
119 1.42 rmind if (a > b)
120 1.20 yamt return 1;
121 1.16 yamt return 0;
122 1.16 yamt }
123 1.16 yamt
124 1.16 yamt static signed int
125 1.42 rmind ld_rbto_compare_key(void *ctx, const void *n, const void *key)
126 1.16 yamt {
127 1.42 rmind const lockdebug_t *ld = n;
128 1.20 yamt const uintptr_t a = (uintptr_t)ld->ld_lock;
129 1.20 yamt const uintptr_t b = (uintptr_t)key;
130 1.20 yamt
131 1.20 yamt if (a < b)
132 1.42 rmind return -1;
133 1.42 rmind if (a > b)
134 1.20 yamt return 1;
135 1.16 yamt return 0;
136 1.16 yamt }
137 1.16 yamt
138 1.42 rmind static rb_tree_t ld_rb_tree;
139 1.16 yamt
140 1.42 rmind static const rb_tree_ops_t ld_rb_tree_ops = {
141 1.37 matt .rbto_compare_nodes = ld_rbto_compare_nodes,
142 1.37 matt .rbto_compare_key = ld_rbto_compare_key,
143 1.42 rmind .rbto_node_offset = offsetof(lockdebug_t, ld_rb_node),
144 1.42 rmind .rbto_context = NULL
145 1.16 yamt };
146 1.16 yamt
147 1.34 ad static inline lockdebug_t *
148 1.34 ad lockdebug_lookup1(volatile void *lock)
149 1.23 ad {
150 1.34 ad lockdebug_t *ld;
151 1.34 ad struct cpu_info *ci;
152 1.23 ad
153 1.34 ad ci = curcpu();
154 1.34 ad __cpu_simple_lock(&ci->ci_data.cpu_ld_lock);
155 1.34 ad ld = (lockdebug_t *)rb_tree_find_node(&ld_rb_tree, __UNVOLATILE(lock));
156 1.34 ad __cpu_simple_unlock(&ci->ci_data.cpu_ld_lock);
157 1.34 ad if (ld == NULL) {
158 1.34 ad return NULL;
159 1.34 ad }
160 1.34 ad __cpu_simple_lock(&ld->ld_spinlock);
161 1.23 ad
162 1.34 ad return ld;
163 1.2 ad }
164 1.2 ad
165 1.23 ad static void
166 1.34 ad lockdebug_lock_cpus(void)
167 1.2 ad {
168 1.34 ad CPU_INFO_ITERATOR cii;
169 1.34 ad struct cpu_info *ci;
170 1.2 ad
171 1.34 ad for (CPU_INFO_FOREACH(cii, ci)) {
172 1.34 ad __cpu_simple_lock(&ci->ci_data.cpu_ld_lock);
173 1.34 ad }
174 1.23 ad }
175 1.23 ad
176 1.23 ad static void
177 1.34 ad lockdebug_unlock_cpus(void)
178 1.23 ad {
179 1.34 ad CPU_INFO_ITERATOR cii;
180 1.34 ad struct cpu_info *ci;
181 1.23 ad
182 1.34 ad for (CPU_INFO_FOREACH(cii, ci)) {
183 1.34 ad __cpu_simple_unlock(&ci->ci_data.cpu_ld_lock);
184 1.34 ad }
185 1.2 ad }
186 1.2 ad
187 1.2 ad /*
188 1.19 yamt * lockdebug_lookup:
189 1.19 yamt *
190 1.19 yamt * Find a lockdebug structure by a pointer to a lock and return it locked.
191 1.19 yamt */
192 1.19 yamt static inline lockdebug_t *
193 1.55 christos lockdebug_lookup(const char *func, size_t line, volatile void *lock,
194 1.55 christos uintptr_t where)
195 1.19 yamt {
196 1.19 yamt lockdebug_t *ld;
197 1.19 yamt
198 1.34 ad ld = lockdebug_lookup1(lock);
199 1.42 rmind if (ld == NULL) {
200 1.55 christos panic("%s,%zu: uninitialized lock (lock=%p, from=%08"
201 1.55 christos PRIxPTR ")", func, line, lock, where);
202 1.42 rmind }
203 1.19 yamt return ld;
204 1.19 yamt }
205 1.19 yamt
206 1.19 yamt /*
207 1.2 ad * lockdebug_init:
208 1.2 ad *
209 1.2 ad * Initialize the lockdebug system. Allocate an initial pool of
210 1.2 ad * lockdebug structures before the VM system is up and running.
211 1.2 ad */
212 1.5 ad static void
213 1.2 ad lockdebug_init(void)
214 1.2 ad {
215 1.2 ad lockdebug_t *ld;
216 1.2 ad int i;
217 1.2 ad
218 1.34 ad TAILQ_INIT(&curcpu()->ci_data.cpu_ld_locks);
219 1.34 ad TAILQ_INIT(&curlwp->l_ld_locks);
220 1.34 ad __cpu_simple_lock_init(&curcpu()->ci_data.cpu_ld_lock);
221 1.34 ad __cpu_simple_lock_init(&ld_mod_lk);
222 1.15 matt
223 1.16 yamt rb_tree_init(&ld_rb_tree, &ld_rb_tree_ops);
224 1.16 yamt
225 1.2 ad ld = ld_prime;
226 1.2 ad for (i = 1, ld++; i < LD_BATCH; i++, ld++) {
227 1.34 ad __cpu_simple_lock_init(&ld->ld_spinlock);
228 1.2 ad TAILQ_INSERT_TAIL(&ld_free, ld, ld_chain);
229 1.2 ad TAILQ_INSERT_TAIL(&ld_all, ld, ld_achain);
230 1.2 ad }
231 1.2 ad ld_freeptr = 1;
232 1.2 ad ld_nfree = LD_BATCH - 1;
233 1.2 ad }
234 1.2 ad
235 1.2 ad /*
236 1.2 ad * lockdebug_alloc:
237 1.2 ad *
238 1.2 ad * A lock is being initialized, so allocate an associated debug
239 1.2 ad * structure.
240 1.2 ad */
241 1.16 yamt bool
242 1.55 christos lockdebug_alloc(const char *func, size_t line, volatile void *lock,
243 1.55 christos lockops_t *lo, uintptr_t initaddr)
244 1.2 ad {
245 1.2 ad struct cpu_info *ci;
246 1.2 ad lockdebug_t *ld;
247 1.34 ad int s;
248 1.2 ad
249 1.27 ad if (lo == NULL || panicstr != NULL || ld_panic)
250 1.16 yamt return false;
251 1.5 ad if (ld_freeptr == 0)
252 1.5 ad lockdebug_init();
253 1.2 ad
254 1.34 ad s = splhigh();
255 1.34 ad __cpu_simple_lock(&ld_mod_lk);
256 1.34 ad if ((ld = lockdebug_lookup1(lock)) != NULL) {
257 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
258 1.55 christos lockdebug_abort1(func, line, ld, s, "already initialized",
259 1.55 christos true);
260 1.27 ad return false;
261 1.19 yamt }
262 1.19 yamt
263 1.2 ad /*
264 1.2 ad * Pinch a new debug structure. We may recurse because we call
265 1.2 ad * kmem_alloc(), which may need to initialize new locks somewhere
266 1.7 skrll * down the path. If not recursing, we try to maintain at least
267 1.2 ad * LD_SLOP structures free, which should hopefully be enough to
268 1.2 ad * satisfy kmem_alloc(). If we can't provide a structure, not to
269 1.2 ad * worry: we'll just mark the lock as not having an ID.
270 1.2 ad */
271 1.23 ad ci = curcpu();
272 1.2 ad ci->ci_lkdebug_recurse++;
273 1.2 ad if (TAILQ_EMPTY(&ld_free)) {
274 1.5 ad if (ci->ci_lkdebug_recurse > 1 || ld_nomore) {
275 1.2 ad ci->ci_lkdebug_recurse--;
276 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
277 1.34 ad splx(s);
278 1.16 yamt return false;
279 1.2 ad }
280 1.34 ad s = lockdebug_more(s);
281 1.34 ad } else if (ci->ci_lkdebug_recurse == 1 && ld_nfree < LD_SLOP) {
282 1.34 ad s = lockdebug_more(s);
283 1.34 ad }
284 1.2 ad if ((ld = TAILQ_FIRST(&ld_free)) == NULL) {
285 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
286 1.34 ad splx(s);
287 1.16 yamt return false;
288 1.2 ad }
289 1.2 ad TAILQ_REMOVE(&ld_free, ld, ld_chain);
290 1.2 ad ld_nfree--;
291 1.2 ad ci->ci_lkdebug_recurse--;
292 1.2 ad
293 1.34 ad if (ld->ld_lock != NULL) {
294 1.55 christos panic("%s,%zu: corrupt table ld %p", func, line, ld);
295 1.34 ad }
296 1.2 ad
297 1.2 ad /* Initialise the structure. */
298 1.2 ad ld->ld_lock = lock;
299 1.2 ad ld->ld_lockops = lo;
300 1.2 ad ld->ld_locked = 0;
301 1.2 ad ld->ld_unlocked = 0;
302 1.2 ad ld->ld_lwp = NULL;
303 1.10 ad ld->ld_initaddr = initaddr;
304 1.35 ad ld->ld_flags = (lo->lo_type == LOCKOPS_SLEEP ? LD_SLEEPER : 0);
305 1.34 ad lockdebug_lock_cpus();
306 1.42 rmind (void)rb_tree_insert_node(&ld_rb_tree, __UNVOLATILE(ld));
307 1.34 ad lockdebug_unlock_cpus();
308 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
309 1.2 ad
310 1.34 ad splx(s);
311 1.16 yamt return true;
312 1.2 ad }
313 1.2 ad
314 1.2 ad /*
315 1.2 ad * lockdebug_free:
316 1.2 ad *
317 1.2 ad * A lock is being destroyed, so release debugging resources.
318 1.2 ad */
319 1.2 ad void
320 1.55 christos lockdebug_free(const char *func, size_t line, volatile void *lock)
321 1.2 ad {
322 1.2 ad lockdebug_t *ld;
323 1.34 ad int s;
324 1.2 ad
325 1.27 ad if (panicstr != NULL || ld_panic)
326 1.2 ad return;
327 1.2 ad
328 1.34 ad s = splhigh();
329 1.34 ad __cpu_simple_lock(&ld_mod_lk);
330 1.55 christos ld = lockdebug_lookup(func, line, lock,
331 1.55 christos (uintptr_t) __builtin_return_address(0));
332 1.16 yamt if (ld == NULL) {
333 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
334 1.55 christos panic("%s,%zu: destroying uninitialized object %p"
335 1.55 christos "(ld_lock=%p)", func, line, lock, ld->ld_lock);
336 1.27 ad return;
337 1.2 ad }
338 1.27 ad if ((ld->ld_flags & LD_LOCKED) != 0 || ld->ld_shares != 0) {
339 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
340 1.55 christos lockdebug_abort1(func, line, ld, s, "is locked or in use",
341 1.55 christos true);
342 1.27 ad return;
343 1.27 ad }
344 1.34 ad lockdebug_lock_cpus();
345 1.42 rmind rb_tree_remove_node(&ld_rb_tree, __UNVOLATILE(ld));
346 1.34 ad lockdebug_unlock_cpus();
347 1.2 ad ld->ld_lock = NULL;
348 1.2 ad TAILQ_INSERT_TAIL(&ld_free, ld, ld_chain);
349 1.2 ad ld_nfree++;
350 1.34 ad __cpu_simple_unlock(&ld->ld_spinlock);
351 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
352 1.34 ad splx(s);
353 1.2 ad }
354 1.2 ad
355 1.2 ad /*
356 1.2 ad * lockdebug_more:
357 1.2 ad *
358 1.2 ad * Allocate a batch of debug structures and add to the free list.
359 1.34 ad * Must be called with ld_mod_lk held.
360 1.2 ad */
361 1.34 ad static int
362 1.34 ad lockdebug_more(int s)
363 1.2 ad {
364 1.2 ad lockdebug_t *ld;
365 1.2 ad void *block;
366 1.5 ad int i, base, m;
367 1.2 ad
368 1.35 ad /*
369 1.35 ad * Can't call kmem_alloc() if in interrupt context. XXX We could
370 1.35 ad * deadlock, because we don't know which locks the caller holds.
371 1.35 ad */
372 1.35 ad if (cpu_intr_p() || (curlwp->l_pflag & LP_INTR) != 0) {
373 1.35 ad return s;
374 1.35 ad }
375 1.35 ad
376 1.2 ad while (ld_nfree < LD_SLOP) {
377 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
378 1.34 ad splx(s);
379 1.2 ad block = kmem_zalloc(LD_BATCH * sizeof(lockdebug_t), KM_SLEEP);
380 1.34 ad s = splhigh();
381 1.34 ad __cpu_simple_lock(&ld_mod_lk);
382 1.2 ad
383 1.2 ad if (block == NULL)
384 1.34 ad return s;
385 1.2 ad
386 1.2 ad if (ld_nfree > LD_SLOP) {
387 1.2 ad /* Somebody beat us to it. */
388 1.34 ad __cpu_simple_unlock(&ld_mod_lk);
389 1.34 ad splx(s);
390 1.2 ad kmem_free(block, LD_BATCH * sizeof(lockdebug_t));
391 1.34 ad s = splhigh();
392 1.34 ad __cpu_simple_lock(&ld_mod_lk);
393 1.2 ad continue;
394 1.2 ad }
395 1.2 ad
396 1.2 ad base = ld_freeptr;
397 1.2 ad ld_nfree += LD_BATCH;
398 1.2 ad ld = block;
399 1.2 ad base <<= LD_BATCH_SHIFT;
400 1.5 ad m = min(LD_MAX_LOCKS, base + LD_BATCH);
401 1.5 ad
402 1.5 ad if (m == LD_MAX_LOCKS)
403 1.5 ad ld_nomore = true;
404 1.2 ad
405 1.5 ad for (i = base; i < m; i++, ld++) {
406 1.34 ad __cpu_simple_lock_init(&ld->ld_spinlock);
407 1.2 ad TAILQ_INSERT_TAIL(&ld_free, ld, ld_chain);
408 1.2 ad TAILQ_INSERT_TAIL(&ld_all, ld, ld_achain);
409 1.2 ad }
410 1.2 ad
411 1.22 ad membar_producer();
412 1.2 ad }
413 1.34 ad
414 1.34 ad return s;
415 1.2 ad }
416 1.2 ad
417 1.2 ad /*
418 1.2 ad * lockdebug_wantlock:
419 1.2 ad *
420 1.56 pgoyette * Process the preamble to a lock acquire. The "shared"
421 1.56 pgoyette * parameter controls which ld_{ex,sh}want counter is
422 1.56 pgoyette * updated; a negative value of shared updates neither.
423 1.2 ad */
424 1.2 ad void
425 1.55 christos lockdebug_wantlock(const char *func, size_t line,
426 1.55 christos volatile void *lock, uintptr_t where, int shared)
427 1.2 ad {
428 1.2 ad struct lwp *l = curlwp;
429 1.2 ad lockdebug_t *ld;
430 1.3 thorpej bool recurse;
431 1.34 ad int s;
432 1.2 ad
433 1.2 ad (void)shared;
434 1.4 thorpej recurse = false;
435 1.2 ad
436 1.27 ad if (panicstr != NULL || ld_panic)
437 1.2 ad return;
438 1.2 ad
439 1.34 ad s = splhigh();
440 1.55 christos if ((ld = lockdebug_lookup(func, line, lock, where)) == NULL) {
441 1.34 ad splx(s);
442 1.2 ad return;
443 1.34 ad }
444 1.32 yamt if ((ld->ld_flags & LD_LOCKED) != 0 || ld->ld_shares != 0) {
445 1.2 ad if ((ld->ld_flags & LD_SLEEPER) != 0) {
446 1.49 mlelstv if (ld->ld_lwp == l)
447 1.4 thorpej recurse = true;
448 1.40 rmind } else if (ld->ld_cpu == (uint16_t)cpu_index(curcpu()))
449 1.4 thorpej recurse = true;
450 1.2 ad }
451 1.10 ad if (cpu_intr_p()) {
452 1.27 ad if ((ld->ld_flags & LD_SLEEPER) != 0) {
453 1.55 christos lockdebug_abort1(func, line, ld, s,
454 1.10 ad "acquiring sleep lock from interrupt context",
455 1.10 ad true);
456 1.27 ad return;
457 1.27 ad }
458 1.10 ad }
459 1.56 pgoyette if (shared > 0)
460 1.2 ad ld->ld_shwant++;
461 1.56 pgoyette else if (shared == 0)
462 1.2 ad ld->ld_exwant++;
463 1.27 ad if (recurse) {
464 1.55 christos lockdebug_abort1(func, line, ld, s, "locking against myself",
465 1.10 ad true);
466 1.27 ad return;
467 1.27 ad }
468 1.34 ad __cpu_simple_unlock(&ld->ld_spinlock);
469 1.34 ad splx(s);
470 1.2 ad }
471 1.2 ad
472 1.2 ad /*
473 1.2 ad * lockdebug_locked:
474 1.2 ad *
475 1.2 ad * Process a lock acquire operation.
476 1.2 ad */
477 1.2 ad void
478 1.55 christos lockdebug_locked(const char *func, size_t line,
479 1.55 christos volatile void *lock, void *cvlock, uintptr_t where, int shared)
480 1.2 ad {
481 1.2 ad struct lwp *l = curlwp;
482 1.2 ad lockdebug_t *ld;
483 1.34 ad int s;
484 1.2 ad
485 1.27 ad if (panicstr != NULL || ld_panic)
486 1.2 ad return;
487 1.2 ad
488 1.34 ad s = splhigh();
489 1.55 christos if ((ld = lockdebug_lookup(func, line, lock, where)) == NULL) {
490 1.34 ad splx(s);
491 1.2 ad return;
492 1.34 ad }
493 1.35 ad if (cvlock) {
494 1.35 ad KASSERT(ld->ld_lockops->lo_type == LOCKOPS_CV);
495 1.35 ad if (lock == (void *)&lbolt) {
496 1.35 ad /* nothing */
497 1.35 ad } else if (ld->ld_shares++ == 0) {
498 1.35 ad ld->ld_locked = (uintptr_t)cvlock;
499 1.35 ad } else if (cvlock != (void *)ld->ld_locked) {
500 1.55 christos lockdebug_abort1(func, line, ld, s,
501 1.55 christos "multiple locks used with condition variable",
502 1.55 christos true);
503 1.35 ad return;
504 1.35 ad }
505 1.35 ad } else if (shared) {
506 1.2 ad l->l_shlocks++;
507 1.45 yamt ld->ld_locked = where;
508 1.2 ad ld->ld_shares++;
509 1.2 ad ld->ld_shwant--;
510 1.2 ad } else {
511 1.27 ad if ((ld->ld_flags & LD_LOCKED) != 0) {
512 1.55 christos lockdebug_abort1(func, line, ld, s, "already locked",
513 1.34 ad true);
514 1.27 ad return;
515 1.27 ad }
516 1.2 ad ld->ld_flags |= LD_LOCKED;
517 1.2 ad ld->ld_locked = where;
518 1.2 ad ld->ld_exwant--;
519 1.2 ad if ((ld->ld_flags & LD_SLEEPER) != 0) {
520 1.34 ad TAILQ_INSERT_TAIL(&l->l_ld_locks, ld, ld_chain);
521 1.2 ad } else {
522 1.34 ad TAILQ_INSERT_TAIL(&curcpu()->ci_data.cpu_ld_locks,
523 1.34 ad ld, ld_chain);
524 1.2 ad }
525 1.2 ad }
526 1.40 rmind ld->ld_cpu = (uint16_t)cpu_index(curcpu());
527 1.32 yamt ld->ld_lwp = l;
528 1.34 ad __cpu_simple_unlock(&ld->ld_spinlock);
529 1.34 ad splx(s);
530 1.2 ad }
531 1.2 ad
532 1.2 ad /*
533 1.2 ad * lockdebug_unlocked:
534 1.2 ad *
535 1.2 ad * Process a lock release operation.
536 1.2 ad */
537 1.2 ad void
538 1.55 christos lockdebug_unlocked(const char *func, size_t line,
539 1.55 christos volatile void *lock, uintptr_t where, int shared)
540 1.2 ad {
541 1.2 ad struct lwp *l = curlwp;
542 1.2 ad lockdebug_t *ld;
543 1.34 ad int s;
544 1.2 ad
545 1.27 ad if (panicstr != NULL || ld_panic)
546 1.2 ad return;
547 1.2 ad
548 1.34 ad s = splhigh();
549 1.55 christos if ((ld = lockdebug_lookup(func, line, lock, where)) == NULL) {
550 1.34 ad splx(s);
551 1.2 ad return;
552 1.34 ad }
553 1.35 ad if (ld->ld_lockops->lo_type == LOCKOPS_CV) {
554 1.35 ad if (lock == (void *)&lbolt) {
555 1.35 ad /* nothing */
556 1.35 ad } else {
557 1.35 ad ld->ld_shares--;
558 1.35 ad }
559 1.35 ad } else if (shared) {
560 1.27 ad if (l->l_shlocks == 0) {
561 1.55 christos lockdebug_abort1(func, line, ld, s,
562 1.10 ad "no shared locks held by LWP", true);
563 1.27 ad return;
564 1.27 ad }
565 1.27 ad if (ld->ld_shares == 0) {
566 1.55 christos lockdebug_abort1(func, line, ld, s,
567 1.10 ad "no shared holds on this lock", true);
568 1.27 ad return;
569 1.27 ad }
570 1.2 ad l->l_shlocks--;
571 1.2 ad ld->ld_shares--;
572 1.45 yamt if (ld->ld_lwp == l) {
573 1.45 yamt ld->ld_unlocked = where;
574 1.32 yamt ld->ld_lwp = NULL;
575 1.45 yamt }
576 1.40 rmind if (ld->ld_cpu == (uint16_t)cpu_index(curcpu()))
577 1.32 yamt ld->ld_cpu = (uint16_t)-1;
578 1.2 ad } else {
579 1.27 ad if ((ld->ld_flags & LD_LOCKED) == 0) {
580 1.55 christos lockdebug_abort1(func, line, ld, s, "not locked", true);
581 1.27 ad return;
582 1.27 ad }
583 1.2 ad
584 1.2 ad if ((ld->ld_flags & LD_SLEEPER) != 0) {
585 1.27 ad if (ld->ld_lwp != curlwp) {
586 1.55 christos lockdebug_abort1(func, line, ld, s,
587 1.10 ad "not held by current LWP", true);
588 1.27 ad return;
589 1.27 ad }
590 1.34 ad TAILQ_REMOVE(&l->l_ld_locks, ld, ld_chain);
591 1.2 ad } else {
592 1.40 rmind if (ld->ld_cpu != (uint16_t)cpu_index(curcpu())) {
593 1.55 christos lockdebug_abort1(func, line, ld, s,
594 1.10 ad "not held by current CPU", true);
595 1.27 ad return;
596 1.27 ad }
597 1.34 ad TAILQ_REMOVE(&curcpu()->ci_data.cpu_ld_locks, ld,
598 1.34 ad ld_chain);
599 1.2 ad }
600 1.44 matt ld->ld_flags &= ~LD_LOCKED;
601 1.44 matt ld->ld_unlocked = where;
602 1.44 matt ld->ld_lwp = NULL;
603 1.2 ad }
604 1.34 ad __cpu_simple_unlock(&ld->ld_spinlock);
605 1.34 ad splx(s);
606 1.2 ad }
607 1.2 ad
608 1.2 ad /*
609 1.35 ad * lockdebug_wakeup:
610 1.35 ad *
611 1.35 ad * Process a wakeup on a condition variable.
612 1.35 ad */
613 1.35 ad void
614 1.55 christos lockdebug_wakeup(const char *func, size_t line, volatile void *lock,
615 1.55 christos uintptr_t where)
616 1.35 ad {
617 1.35 ad lockdebug_t *ld;
618 1.35 ad int s;
619 1.35 ad
620 1.35 ad if (panicstr != NULL || ld_panic || lock == (void *)&lbolt)
621 1.35 ad return;
622 1.35 ad
623 1.35 ad s = splhigh();
624 1.35 ad /* Find the CV... */
625 1.55 christos if ((ld = lockdebug_lookup(func, line, lock, where)) == NULL) {
626 1.35 ad splx(s);
627 1.35 ad return;
628 1.35 ad }
629 1.35 ad /*
630 1.35 ad * If it has any waiters, ensure that they are using the
631 1.35 ad * same interlock.
632 1.35 ad */
633 1.35 ad if (ld->ld_shares != 0 && !mutex_owned((kmutex_t *)ld->ld_locked)) {
634 1.55 christos lockdebug_abort1(func, line, ld, s, "interlocking mutex not "
635 1.35 ad "held during wakeup", true);
636 1.35 ad return;
637 1.35 ad }
638 1.35 ad __cpu_simple_unlock(&ld->ld_spinlock);
639 1.35 ad splx(s);
640 1.35 ad }
641 1.35 ad
642 1.35 ad /*
643 1.2 ad * lockdebug_barrier:
644 1.2 ad *
645 1.2 ad * Panic if we hold more than one specified spin lock, and optionally,
646 1.2 ad * if we hold sleep locks.
647 1.2 ad */
648 1.2 ad void
649 1.55 christos lockdebug_barrier(const char *func, size_t line, volatile void *spinlock,
650 1.55 christos int slplocks)
651 1.2 ad {
652 1.2 ad struct lwp *l = curlwp;
653 1.2 ad lockdebug_t *ld;
654 1.34 ad int s;
655 1.2 ad
656 1.27 ad if (panicstr != NULL || ld_panic)
657 1.2 ad return;
658 1.2 ad
659 1.34 ad s = splhigh();
660 1.34 ad if ((l->l_pflag & LP_INTR) == 0) {
661 1.34 ad TAILQ_FOREACH(ld, &curcpu()->ci_data.cpu_ld_locks, ld_chain) {
662 1.2 ad if (ld->ld_lock == spinlock) {
663 1.2 ad continue;
664 1.2 ad }
665 1.34 ad __cpu_simple_lock(&ld->ld_spinlock);
666 1.55 christos lockdebug_abort1(func, line, ld, s,
667 1.34 ad "spin lock held", true);
668 1.34 ad return;
669 1.2 ad }
670 1.2 ad }
671 1.34 ad if (slplocks) {
672 1.34 ad splx(s);
673 1.34 ad return;
674 1.34 ad }
675 1.34 ad if ((ld = TAILQ_FIRST(&l->l_ld_locks)) != NULL) {
676 1.34 ad __cpu_simple_lock(&ld->ld_spinlock);
677 1.55 christos lockdebug_abort1(func, line, ld, s, "sleep lock held", true);
678 1.34 ad return;
679 1.34 ad }
680 1.34 ad splx(s);
681 1.34 ad if (l->l_shlocks != 0) {
682 1.52 christos TAILQ_FOREACH(ld, &ld_all, ld_achain) {
683 1.52 christos if (ld->ld_lockops->lo_type == LOCKOPS_CV)
684 1.52 christos continue;
685 1.52 christos if (ld->ld_lwp == l)
686 1.52 christos lockdebug_dump(ld, printf);
687 1.52 christos }
688 1.55 christos panic("%s,%zu: holding %d shared locks", func, line,
689 1.55 christos l->l_shlocks);
690 1.2 ad }
691 1.2 ad }
692 1.2 ad
693 1.2 ad /*
694 1.10 ad * lockdebug_mem_check:
695 1.10 ad *
696 1.10 ad * Check for in-use locks within a memory region that is
697 1.16 yamt * being freed.
698 1.10 ad */
699 1.10 ad void
700 1.55 christos lockdebug_mem_check(const char *func, size_t line, void *base, size_t sz)
701 1.10 ad {
702 1.16 yamt lockdebug_t *ld;
703 1.34 ad struct cpu_info *ci;
704 1.23 ad int s;
705 1.10 ad
706 1.27 ad if (panicstr != NULL || ld_panic)
707 1.24 ad return;
708 1.24 ad
709 1.34 ad s = splhigh();
710 1.34 ad ci = curcpu();
711 1.34 ad __cpu_simple_lock(&ci->ci_data.cpu_ld_lock);
712 1.16 yamt ld = (lockdebug_t *)rb_tree_find_node_geq(&ld_rb_tree, base);
713 1.23 ad if (ld != NULL) {
714 1.23 ad const uintptr_t lock = (uintptr_t)ld->ld_lock;
715 1.23 ad
716 1.23 ad if ((uintptr_t)base > lock)
717 1.55 christos panic("%s,%zu: corrupt tree ld=%p, base=%p, sz=%zu",
718 1.55 christos func, line, ld, base, sz);
719 1.23 ad if (lock >= (uintptr_t)base + sz)
720 1.23 ad ld = NULL;
721 1.23 ad }
722 1.34 ad __cpu_simple_unlock(&ci->ci_data.cpu_ld_lock);
723 1.34 ad if (ld != NULL) {
724 1.34 ad __cpu_simple_lock(&ld->ld_spinlock);
725 1.55 christos lockdebug_abort1(func, line, ld, s,
726 1.34 ad "allocation contains active lock", !cold);
727 1.16 yamt return;
728 1.34 ad }
729 1.34 ad splx(s);
730 1.10 ad }
731 1.10 ad
732 1.10 ad /*
733 1.2 ad * lockdebug_dump:
734 1.2 ad *
735 1.2 ad * Dump information about a lock on panic, or for DDB.
736 1.2 ad */
737 1.2 ad static void
738 1.47 christos lockdebug_dump(lockdebug_t *ld, void (*pr)(const char *, ...)
739 1.47 christos __printflike(1, 2))
740 1.2 ad {
741 1.2 ad int sleeper = (ld->ld_flags & LD_SLEEPER);
742 1.2 ad
743 1.2 ad (*pr)(
744 1.2 ad "lock address : %#018lx type : %18s\n"
745 1.35 ad "initialized : %#018lx",
746 1.2 ad (long)ld->ld_lock, (sleeper ? "sleep/adaptive" : "spin"),
747 1.10 ad (long)ld->ld_initaddr);
748 1.2 ad
749 1.35 ad if (ld->ld_lockops->lo_type == LOCKOPS_CV) {
750 1.48 njoly (*pr)(" interlock: %#018lx\n", (long)ld->ld_locked);
751 1.35 ad } else {
752 1.35 ad (*pr)("\n"
753 1.35 ad "shared holds : %18u exclusive: %18u\n"
754 1.35 ad "shares wanted: %18u exclusive: %18u\n"
755 1.35 ad "current cpu : %18u last held: %18u\n"
756 1.35 ad "current lwp : %#018lx last held: %#018lx\n"
757 1.44 matt "last locked%c : %#018lx unlocked%c: %#018lx\n",
758 1.35 ad (unsigned)ld->ld_shares, ((ld->ld_flags & LD_LOCKED) != 0),
759 1.35 ad (unsigned)ld->ld_shwant, (unsigned)ld->ld_exwant,
760 1.40 rmind (unsigned)cpu_index(curcpu()), (unsigned)ld->ld_cpu,
761 1.35 ad (long)curlwp, (long)ld->ld_lwp,
762 1.44 matt ((ld->ld_flags & LD_LOCKED) ? '*' : ' '),
763 1.44 matt (long)ld->ld_locked,
764 1.44 matt ((ld->ld_flags & LD_LOCKED) ? ' ' : '*'),
765 1.44 matt (long)ld->ld_unlocked);
766 1.35 ad }
767 1.35 ad
768 1.2 ad if (ld->ld_lockops->lo_dump != NULL)
769 1.2 ad (*ld->ld_lockops->lo_dump)(ld->ld_lock);
770 1.2 ad
771 1.2 ad if (sleeper) {
772 1.2 ad (*pr)("\n");
773 1.2 ad turnstile_print(ld->ld_lock, pr);
774 1.2 ad }
775 1.2 ad }
776 1.2 ad
777 1.2 ad /*
778 1.27 ad * lockdebug_abort1:
779 1.2 ad *
780 1.27 ad * An error has been trapped - dump lock info and panic.
781 1.2 ad */
782 1.5 ad static void
783 1.55 christos lockdebug_abort1(const char *func, size_t line, lockdebug_t *ld, int s,
784 1.10 ad const char *msg, bool dopanic)
785 1.2 ad {
786 1.2 ad
787 1.27 ad /*
788 1.46 christos * Don't make the situation worse if the system is already going
789 1.27 ad * down in flames. Once a panic is triggered, lockdebug state
790 1.27 ad * becomes stale and cannot be trusted.
791 1.27 ad */
792 1.27 ad if (atomic_inc_uint_nv(&ld_panic) != 1) {
793 1.34 ad __cpu_simple_unlock(&ld->ld_spinlock);
794 1.34 ad splx(s);
795 1.27 ad return;
796 1.27 ad }
797 1.27 ad
798 1.55 christos printf_nolog("%s error: %s,%zu: %s\n\n", ld->ld_lockops->lo_name,
799 1.55 christos func, line, msg);
800 1.2 ad lockdebug_dump(ld, printf_nolog);
801 1.34 ad __cpu_simple_unlock(&ld->ld_spinlock);
802 1.34 ad splx(s);
803 1.2 ad printf_nolog("\n");
804 1.10 ad if (dopanic)
805 1.55 christos panic("LOCKDEBUG: %s error: %s,%zu: %s",
806 1.55 christos ld->ld_lockops->lo_name, func, line, msg);
807 1.2 ad }
808 1.2 ad
809 1.2 ad #endif /* LOCKDEBUG */
810 1.2 ad
811 1.2 ad /*
812 1.2 ad * lockdebug_lock_print:
813 1.2 ad *
814 1.2 ad * Handle the DDB 'show lock' command.
815 1.2 ad */
816 1.2 ad #ifdef DDB
817 1.2 ad void
818 1.2 ad lockdebug_lock_print(void *addr, void (*pr)(const char *, ...))
819 1.2 ad {
820 1.2 ad #ifdef LOCKDEBUG
821 1.2 ad lockdebug_t *ld;
822 1.2 ad
823 1.2 ad TAILQ_FOREACH(ld, &ld_all, ld_achain) {
824 1.41 dyoung if (ld->ld_lock == NULL)
825 1.41 dyoung continue;
826 1.41 dyoung if (addr == NULL || ld->ld_lock == addr) {
827 1.2 ad lockdebug_dump(ld, pr);
828 1.41 dyoung if (addr != NULL)
829 1.41 dyoung return;
830 1.2 ad }
831 1.2 ad }
832 1.41 dyoung if (addr != NULL) {
833 1.41 dyoung (*pr)("Sorry, no record of a lock with address %p found.\n",
834 1.41 dyoung addr);
835 1.41 dyoung }
836 1.2 ad #else
837 1.2 ad (*pr)("Sorry, kernel not built with the LOCKDEBUG option.\n");
838 1.2 ad #endif /* LOCKDEBUG */
839 1.2 ad }
840 1.2 ad #endif /* DDB */
841 1.2 ad
842 1.2 ad /*
843 1.2 ad * lockdebug_abort:
844 1.2 ad *
845 1.2 ad * An error has been trapped - dump lock info and call panic().
846 1.2 ad */
847 1.2 ad void
848 1.55 christos lockdebug_abort(const char *func, size_t line, volatile void *lock,
849 1.55 christos lockops_t *ops, const char *msg)
850 1.2 ad {
851 1.2 ad #ifdef LOCKDEBUG
852 1.2 ad lockdebug_t *ld;
853 1.34 ad int s;
854 1.2 ad
855 1.34 ad s = splhigh();
856 1.55 christos if ((ld = lockdebug_lookup(func, line, lock,
857 1.38 rafal (uintptr_t) __builtin_return_address(0))) != NULL) {
858 1.55 christos lockdebug_abort1(func, line, ld, s, msg, true);
859 1.34 ad return;
860 1.2 ad }
861 1.34 ad splx(s);
862 1.2 ad #endif /* LOCKDEBUG */
863 1.2 ad
864 1.27 ad /*
865 1.27 ad * Complain first on the occurrance only. Otherwise proceeed to
866 1.27 ad * panic where we will `rendezvous' with other CPUs if the machine
867 1.27 ad * is going down in flames.
868 1.27 ad */
869 1.27 ad if (atomic_inc_uint_nv(&ld_panic) == 1) {
870 1.55 christos printf_nolog("%s error: %s,%zu: %s\n\n"
871 1.27 ad "lock address : %#018lx\n"
872 1.27 ad "current cpu : %18d\n"
873 1.27 ad "current lwp : %#018lx\n",
874 1.55 christos ops->lo_name, func, line, msg, (long)lock,
875 1.40 rmind (int)cpu_index(curcpu()), (long)curlwp);
876 1.27 ad (*ops->lo_dump)(lock);
877 1.27 ad printf_nolog("\n");
878 1.27 ad }
879 1.2 ad
880 1.55 christos panic("lock error: %s: %s,%zu: %s: lock %p cpu %d lwp %p",
881 1.55 christos ops->lo_name, func, line, msg, lock, cpu_index(curcpu()), curlwp);
882 1.2 ad }
883