xref: /freebsd/sys/kern/kern_lockf.c (revision 69cc1d0d7f3445d3671e05dcb7baabe7e36c5ed9)
192dc7331SDavid Greenman /*
292dc7331SDavid Greenman  * Copyright (c) 1982, 1986, 1989, 1993
392dc7331SDavid Greenman  *	The Regents of the University of California.  All rights reserved.
492dc7331SDavid Greenman  *
592dc7331SDavid Greenman  * This code is derived from software contributed to Berkeley by
692dc7331SDavid Greenman  * Scooter Morris at Genentech Inc.
792dc7331SDavid Greenman  *
892dc7331SDavid Greenman  * Redistribution and use in source and binary forms, with or without
992dc7331SDavid Greenman  * modification, are permitted provided that the following conditions
1092dc7331SDavid Greenman  * are met:
1192dc7331SDavid Greenman  * 1. Redistributions of source code must retain the above copyright
1292dc7331SDavid Greenman  *    notice, this list of conditions and the following disclaimer.
1392dc7331SDavid Greenman  * 2. Redistributions in binary form must reproduce the above copyright
1492dc7331SDavid Greenman  *    notice, this list of conditions and the following disclaimer in the
1592dc7331SDavid Greenman  *    documentation and/or other materials provided with the distribution.
1692dc7331SDavid Greenman  * 3. All advertising materials mentioning features or use of this software
1792dc7331SDavid Greenman  *    must display the following acknowledgement:
1892dc7331SDavid Greenman  *	This product includes software developed by the University of
1992dc7331SDavid Greenman  *	California, Berkeley and its contributors.
2092dc7331SDavid Greenman  * 4. Neither the name of the University nor the names of its contributors
2192dc7331SDavid Greenman  *    may be used to endorse or promote products derived from this software
2292dc7331SDavid Greenman  *    without specific prior written permission.
2392dc7331SDavid Greenman  *
2492dc7331SDavid Greenman  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
2592dc7331SDavid Greenman  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
2692dc7331SDavid Greenman  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
2792dc7331SDavid Greenman  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
2892dc7331SDavid Greenman  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
2992dc7331SDavid Greenman  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
3092dc7331SDavid Greenman  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
3192dc7331SDavid Greenman  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
3292dc7331SDavid Greenman  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
3392dc7331SDavid Greenman  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
3492dc7331SDavid Greenman  * SUCH DAMAGE.
3592dc7331SDavid Greenman  *
3692dc7331SDavid Greenman  *	@(#)ufs_lockf.c	8.3 (Berkeley) 1/6/94
37c3aac50fSPeter Wemm  * $FreeBSD$
3892dc7331SDavid Greenman  */
3992dc7331SDavid Greenman 
403f2076daSEivind Eklund #include "opt_debug_lockf.h"
413f2076daSEivind Eklund 
4269cc1d0dSAndrey A. Chernov #include <machine/limits.h>
4392dc7331SDavid Greenman #include <sys/param.h>
4492dc7331SDavid Greenman #include <sys/systm.h>
451c5bb3eaSPeter Wemm #include <sys/kernel.h>
461cd52ec3SBruce Evans #include <sys/lock.h>
47fb919e4dSMark Murray #include <sys/mutex.h>
4892dc7331SDavid Greenman #include <sys/proc.h>
49b71fec07SBruce Evans #include <sys/unistd.h>
5092dc7331SDavid Greenman #include <sys/vnode.h>
5192dc7331SDavid Greenman #include <sys/malloc.h>
5292dc7331SDavid Greenman #include <sys/fcntl.h>
5392dc7331SDavid Greenman 
5492dc7331SDavid Greenman #include <sys/lockf.h>
5592dc7331SDavid Greenman 
5692dc7331SDavid Greenman /*
5792dc7331SDavid Greenman  * This variable controls the maximum number of processes that will
5892dc7331SDavid Greenman  * be checked in doing deadlock detection.
5992dc7331SDavid Greenman  */
60996c772fSJohn Dyson static int maxlockdepth = MAXDEPTH;
6192dc7331SDavid Greenman 
6292dc7331SDavid Greenman #ifdef LOCKF_DEBUG
63a8687b6dSBruce Evans #include <sys/kernel.h>
64996c772fSJohn Dyson #include <sys/sysctl.h>
65a8687b6dSBruce Evans 
66a8687b6dSBruce Evans #include <ufs/ufs/quota.h>
67a8687b6dSBruce Evans #include <ufs/ufs/inode.h>
68a8687b6dSBruce Evans 
6955166637SPoul-Henning Kamp 
707f725eacSBruce Evans static int	lockf_debug = 0;
717f725eacSBruce Evans SYSCTL_INT(_debug, OID_AUTO, lockf_debug, CTLFLAG_RW, &lockf_debug, 0, "");
7292dc7331SDavid Greenman #endif
7392dc7331SDavid Greenman 
74603c8667SAlfred Perlstein MALLOC_DEFINE(M_LOCKF, "lockf", "Byte-range locking structures");
7555166637SPoul-Henning Kamp 
7692dc7331SDavid Greenman #define NOLOCKF (struct lockf *)0
7792dc7331SDavid Greenman #define SELF	0x1
7892dc7331SDavid Greenman #define OTHERS	0x2
7987b6de2bSPoul-Henning Kamp static int	 lf_clearlock __P((struct lockf *));
8087b6de2bSPoul-Henning Kamp static int	 lf_findoverlap __P((struct lockf *,
8187b6de2bSPoul-Henning Kamp 	    struct lockf *, int, struct lockf ***, struct lockf **));
8287b6de2bSPoul-Henning Kamp static struct lockf *
8387b6de2bSPoul-Henning Kamp 	 lf_getblock __P((struct lockf *));
8487b6de2bSPoul-Henning Kamp static int	 lf_getlock __P((struct lockf *, struct flock *));
8587b6de2bSPoul-Henning Kamp static int	 lf_setlock __P((struct lockf *));
8687b6de2bSPoul-Henning Kamp static void	 lf_split __P((struct lockf *, struct lockf *));
8787b6de2bSPoul-Henning Kamp static void	 lf_wakelock __P((struct lockf *));
8892dc7331SDavid Greenman 
8992dc7331SDavid Greenman /*
9092dc7331SDavid Greenman  * Advisory record locking support
9192dc7331SDavid Greenman  */
9292dc7331SDavid Greenman int
9392dc7331SDavid Greenman lf_advlock(ap, head, size)
9492dc7331SDavid Greenman 	struct vop_advlock_args /* {
9592dc7331SDavid Greenman 		struct vnode *a_vp;
9692dc7331SDavid Greenman 		caddr_t  a_id;
9792dc7331SDavid Greenman 		int  a_op;
9892dc7331SDavid Greenman 		struct flock *a_fl;
9992dc7331SDavid Greenman 		int  a_flags;
10092dc7331SDavid Greenman 	} */ *ap;
10192dc7331SDavid Greenman 	struct lockf **head;
10292dc7331SDavid Greenman 	u_quad_t size;
10392dc7331SDavid Greenman {
10492dc7331SDavid Greenman 	register struct flock *fl = ap->a_fl;
10592dc7331SDavid Greenman 	register struct lockf *lock;
10692dc7331SDavid Greenman 	off_t start, end;
10792dc7331SDavid Greenman 	int error;
10892dc7331SDavid Greenman 
10969cc1d0dSAndrey A. Chernov 	if (fl->l_len < 0)
11069cc1d0dSAndrey A. Chernov 		return (EINVAL);
11192dc7331SDavid Greenman 	/*
11292dc7331SDavid Greenman 	 * Convert the flock structure into a start and end.
11392dc7331SDavid Greenman 	 */
11492dc7331SDavid Greenman 	switch (fl->l_whence) {
11592dc7331SDavid Greenman 
11692dc7331SDavid Greenman 	case SEEK_SET:
11792dc7331SDavid Greenman 	case SEEK_CUR:
11892dc7331SDavid Greenman 		/*
11992dc7331SDavid Greenman 		 * Caller is responsible for adding any necessary offset
12092dc7331SDavid Greenman 		 * when SEEK_CUR is used.
12192dc7331SDavid Greenman 		 */
12292dc7331SDavid Greenman 		start = fl->l_start;
12392dc7331SDavid Greenman 		break;
12492dc7331SDavid Greenman 
12592dc7331SDavid Greenman 	case SEEK_END:
12669cc1d0dSAndrey A. Chernov 		/* size always >= 0 */
12769cc1d0dSAndrey A. Chernov 		if (fl->l_start > 0 && size > OFF_MAX - fl->l_start)
12869cc1d0dSAndrey A. Chernov 			return (EOVERFLOW);
12992dc7331SDavid Greenman 		start = size + fl->l_start;
13092dc7331SDavid Greenman 		break;
13192dc7331SDavid Greenman 
13292dc7331SDavid Greenman 	default:
13392dc7331SDavid Greenman 		return (EINVAL);
13492dc7331SDavid Greenman 	}
13592dc7331SDavid Greenman 	if (start < 0)
13692dc7331SDavid Greenman 		return (EINVAL);
13792dc7331SDavid Greenman 	if (fl->l_len == 0)
13892dc7331SDavid Greenman 		end = -1;
139a88bd8aaSBruce Evans 	else {
14069cc1d0dSAndrey A. Chernov 		off_t oadd = fl->l_len - 1;
14169cc1d0dSAndrey A. Chernov 
14269cc1d0dSAndrey A. Chernov 		/* fl->l_len & start are non-negative */
14369cc1d0dSAndrey A. Chernov 		if (oadd > OFF_MAX - start)
14469cc1d0dSAndrey A. Chernov 			return (EOVERFLOW);
14569cc1d0dSAndrey A. Chernov 		end = start + oadd;
146a88bd8aaSBruce Evans 		if (end < start)
147a88bd8aaSBruce Evans 			return (EINVAL);
148a88bd8aaSBruce Evans 	}
149a88bd8aaSBruce Evans 	/*
150a88bd8aaSBruce Evans 	 * Avoid the common case of unlocking when inode has no locks.
151a88bd8aaSBruce Evans 	 */
152a88bd8aaSBruce Evans 	if (*head == (struct lockf *)0) {
153a88bd8aaSBruce Evans 		if (ap->a_op != F_SETLK) {
154a88bd8aaSBruce Evans 			fl->l_type = F_UNLCK;
155a88bd8aaSBruce Evans 			return (0);
156a88bd8aaSBruce Evans 		}
157a88bd8aaSBruce Evans 	}
15892dc7331SDavid Greenman 	/*
15992dc7331SDavid Greenman 	 * Create the lockf structure
16092dc7331SDavid Greenman 	 */
16192dc7331SDavid Greenman 	MALLOC(lock, struct lockf *, sizeof *lock, M_LOCKF, M_WAITOK);
16292dc7331SDavid Greenman 	lock->lf_start = start;
16392dc7331SDavid Greenman 	lock->lf_end = end;
16492dc7331SDavid Greenman 	lock->lf_id = ap->a_id;
165996c772fSJohn Dyson /*	lock->lf_inode = ip; */	/* XXX JH */
16692dc7331SDavid Greenman 	lock->lf_type = fl->l_type;
167996c772fSJohn Dyson 	lock->lf_head = head;
16892dc7331SDavid Greenman 	lock->lf_next = (struct lockf *)0;
169996c772fSJohn Dyson 	TAILQ_INIT(&lock->lf_blkhd);
17092dc7331SDavid Greenman 	lock->lf_flags = ap->a_flags;
17192dc7331SDavid Greenman 	/*
17292dc7331SDavid Greenman 	 * Do the requested operation.
17392dc7331SDavid Greenman 	 */
17492dc7331SDavid Greenman 	switch(ap->a_op) {
17592dc7331SDavid Greenman 	case F_SETLK:
17692dc7331SDavid Greenman 		return (lf_setlock(lock));
17792dc7331SDavid Greenman 
17892dc7331SDavid Greenman 	case F_UNLCK:
17992dc7331SDavid Greenman 		error = lf_clearlock(lock);
18092dc7331SDavid Greenman 		FREE(lock, M_LOCKF);
18192dc7331SDavid Greenman 		return (error);
18292dc7331SDavid Greenman 
18392dc7331SDavid Greenman 	case F_GETLK:
18492dc7331SDavid Greenman 		error = lf_getlock(lock, fl);
18592dc7331SDavid Greenman 		FREE(lock, M_LOCKF);
18692dc7331SDavid Greenman 		return (error);
18792dc7331SDavid Greenman 
18892dc7331SDavid Greenman 	default:
18992dc7331SDavid Greenman 		free(lock, M_LOCKF);
19092dc7331SDavid Greenman 		return (EINVAL);
19192dc7331SDavid Greenman 	}
19292dc7331SDavid Greenman 	/* NOTREACHED */
19392dc7331SDavid Greenman }
19492dc7331SDavid Greenman 
19592dc7331SDavid Greenman /*
19692dc7331SDavid Greenman  * Set a byte-range lock.
19792dc7331SDavid Greenman  */
19887b6de2bSPoul-Henning Kamp static int
19992dc7331SDavid Greenman lf_setlock(lock)
20092dc7331SDavid Greenman 	register struct lockf *lock;
20192dc7331SDavid Greenman {
20292dc7331SDavid Greenman 	register struct lockf *block;
20392dc7331SDavid Greenman 	struct lockf **head = lock->lf_head;
20492dc7331SDavid Greenman 	struct lockf **prev, *overlap, *ltmp;
20592dc7331SDavid Greenman 	static char lockstr[] = "lockf";
20692dc7331SDavid Greenman 	int ovcase, priority, needtolink, error;
20792dc7331SDavid Greenman 
20892dc7331SDavid Greenman #ifdef LOCKF_DEBUG
20992dc7331SDavid Greenman 	if (lockf_debug & 1)
21092dc7331SDavid Greenman 		lf_print("lf_setlock", lock);
21192dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
21292dc7331SDavid Greenman 
21392dc7331SDavid Greenman 	/*
21492dc7331SDavid Greenman 	 * Set the priority
21592dc7331SDavid Greenman 	 */
21692dc7331SDavid Greenman 	priority = PLOCK;
21792dc7331SDavid Greenman 	if (lock->lf_type == F_WRLCK)
21892dc7331SDavid Greenman 		priority += 4;
21992dc7331SDavid Greenman 	priority |= PCATCH;
22092dc7331SDavid Greenman 	/*
22192dc7331SDavid Greenman 	 * Scan lock list for this file looking for locks that would block us.
22292dc7331SDavid Greenman 	 */
223bb56ec4aSPoul-Henning Kamp 	while ((block = lf_getblock(lock))) {
22492dc7331SDavid Greenman 		/*
22592dc7331SDavid Greenman 		 * Free the structure and return if nonblocking.
22692dc7331SDavid Greenman 		 */
22792dc7331SDavid Greenman 		if ((lock->lf_flags & F_WAIT) == 0) {
22892dc7331SDavid Greenman 			FREE(lock, M_LOCKF);
22992dc7331SDavid Greenman 			return (EAGAIN);
23092dc7331SDavid Greenman 		}
23192dc7331SDavid Greenman 		/*
23292dc7331SDavid Greenman 		 * We are blocked. Since flock style locks cover
23392dc7331SDavid Greenman 		 * the whole file, there is no chance for deadlock.
23492dc7331SDavid Greenman 		 * For byte-range locks we must check for deadlock.
23592dc7331SDavid Greenman 		 *
23692dc7331SDavid Greenman 		 * Deadlock detection is done by looking through the
23792dc7331SDavid Greenman 		 * wait channels to see if there are any cycles that
23892dc7331SDavid Greenman 		 * involve us. MAXDEPTH is set just to make sure we
23992dc7331SDavid Greenman 		 * do not go off into neverland.
24092dc7331SDavid Greenman 		 */
24192dc7331SDavid Greenman 		if ((lock->lf_flags & F_POSIX) &&
24292dc7331SDavid Greenman 		    (block->lf_flags & F_POSIX)) {
24392dc7331SDavid Greenman 			register struct proc *wproc;
24492dc7331SDavid Greenman 			register struct lockf *waitblock;
24592dc7331SDavid Greenman 			int i = 0;
24692dc7331SDavid Greenman 
24792dc7331SDavid Greenman 			/* The block is waiting on something */
24892dc7331SDavid Greenman 			wproc = (struct proc *)block->lf_id;
2498d272518SJohn Baldwin 			mtx_lock_spin(&sched_lock);
25092dc7331SDavid Greenman 			while (wproc->p_wchan &&
25192dc7331SDavid Greenman 			       (wproc->p_wmesg == lockstr) &&
25292dc7331SDavid Greenman 			       (i++ < maxlockdepth)) {
25392dc7331SDavid Greenman 				waitblock = (struct lockf *)wproc->p_wchan;
25492dc7331SDavid Greenman 				/* Get the owner of the blocking lock */
25592dc7331SDavid Greenman 				waitblock = waitblock->lf_next;
25692dc7331SDavid Greenman 				if ((waitblock->lf_flags & F_POSIX) == 0)
25792dc7331SDavid Greenman 					break;
25892dc7331SDavid Greenman 				wproc = (struct proc *)waitblock->lf_id;
25992dc7331SDavid Greenman 				if (wproc == (struct proc *)lock->lf_id) {
2608d272518SJohn Baldwin 					mtx_unlock_spin(&sched_lock);
26192dc7331SDavid Greenman 					free(lock, M_LOCKF);
26292dc7331SDavid Greenman 					return (EDEADLK);
26392dc7331SDavid Greenman 				}
26492dc7331SDavid Greenman 			}
2658d272518SJohn Baldwin 			mtx_unlock_spin(&sched_lock);
26692dc7331SDavid Greenman 		}
26792dc7331SDavid Greenman 		/*
26892dc7331SDavid Greenman 		 * For flock type locks, we must first remove
26992dc7331SDavid Greenman 		 * any shared locks that we hold before we sleep
27092dc7331SDavid Greenman 		 * waiting for an exclusive lock.
27192dc7331SDavid Greenman 		 */
27292dc7331SDavid Greenman 		if ((lock->lf_flags & F_FLOCK) &&
27392dc7331SDavid Greenman 		    lock->lf_type == F_WRLCK) {
27492dc7331SDavid Greenman 			lock->lf_type = F_UNLCK;
27592dc7331SDavid Greenman 			(void) lf_clearlock(lock);
27692dc7331SDavid Greenman 			lock->lf_type = F_WRLCK;
27792dc7331SDavid Greenman 		}
27892dc7331SDavid Greenman 		/*
27992dc7331SDavid Greenman 		 * Add our lock to the blocked list and sleep until we're free.
28092dc7331SDavid Greenman 		 * Remember who blocked us (for deadlock detection).
28192dc7331SDavid Greenman 		 */
28292dc7331SDavid Greenman 		lock->lf_next = block;
283996c772fSJohn Dyson 		TAILQ_INSERT_TAIL(&block->lf_blkhd, lock, lf_block);
28492dc7331SDavid Greenman #ifdef LOCKF_DEBUG
28592dc7331SDavid Greenman 		if (lockf_debug & 1) {
28692dc7331SDavid Greenman 			lf_print("lf_setlock: blocking on", block);
28792dc7331SDavid Greenman 			lf_printlist("lf_setlock", block);
28892dc7331SDavid Greenman 		}
28992dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
2901168ab08SBruce Evans 		error = tsleep((caddr_t)lock, priority, lockstr, 0);
29192dc7331SDavid Greenman 		/*
2921168ab08SBruce Evans 		 * We may have been awakened by a signal and/or by a
2931168ab08SBruce Evans 		 * debugger continuing us (in which cases we must remove
2941168ab08SBruce Evans 		 * ourselves from the blocked list) and/or by another
2951168ab08SBruce Evans 		 * process releasing a lock (in which case we have
2961168ab08SBruce Evans 		 * already been removed from the blocked list and our
297996c772fSJohn Dyson 		 * lf_next field set to NOLOCKF).
29892dc7331SDavid Greenman 		 */
2991168ab08SBruce Evans 		if (lock->lf_next) {
3001168ab08SBruce Evans 			TAILQ_REMOVE(&lock->lf_next->lf_blkhd, lock, lf_block);
3011168ab08SBruce Evans 			lock->lf_next = NOLOCKF;
3021168ab08SBruce Evans 		}
3031168ab08SBruce Evans 		if (error) {
30492dc7331SDavid Greenman 			free(lock, M_LOCKF);
30592dc7331SDavid Greenman 			return (error);
30692dc7331SDavid Greenman 		}
30792dc7331SDavid Greenman 	}
30892dc7331SDavid Greenman 	/*
30992dc7331SDavid Greenman 	 * No blocks!!  Add the lock.  Note that we will
31092dc7331SDavid Greenman 	 * downgrade or upgrade any overlapping locks this
31192dc7331SDavid Greenman 	 * process already owns.
31292dc7331SDavid Greenman 	 *
31392dc7331SDavid Greenman 	 * Skip over locks owned by other processes.
31492dc7331SDavid Greenman 	 * Handle any locks that overlap and are owned by ourselves.
31592dc7331SDavid Greenman 	 */
31692dc7331SDavid Greenman 	prev = head;
31792dc7331SDavid Greenman 	block = *head;
31892dc7331SDavid Greenman 	needtolink = 1;
31992dc7331SDavid Greenman 	for (;;) {
320bb56ec4aSPoul-Henning Kamp 		ovcase = lf_findoverlap(block, lock, SELF, &prev, &overlap);
321bb56ec4aSPoul-Henning Kamp 		if (ovcase)
32292dc7331SDavid Greenman 			block = overlap->lf_next;
32392dc7331SDavid Greenman 		/*
32492dc7331SDavid Greenman 		 * Six cases:
32592dc7331SDavid Greenman 		 *	0) no overlap
32692dc7331SDavid Greenman 		 *	1) overlap == lock
32792dc7331SDavid Greenman 		 *	2) overlap contains lock
32892dc7331SDavid Greenman 		 *	3) lock contains overlap
32992dc7331SDavid Greenman 		 *	4) overlap starts before lock
33092dc7331SDavid Greenman 		 *	5) overlap ends after lock
33192dc7331SDavid Greenman 		 */
33292dc7331SDavid Greenman 		switch (ovcase) {
33392dc7331SDavid Greenman 		case 0: /* no overlap */
33492dc7331SDavid Greenman 			if (needtolink) {
33592dc7331SDavid Greenman 				*prev = lock;
33692dc7331SDavid Greenman 				lock->lf_next = overlap;
33792dc7331SDavid Greenman 			}
33892dc7331SDavid Greenman 			break;
33992dc7331SDavid Greenman 
34092dc7331SDavid Greenman 		case 1: /* overlap == lock */
34192dc7331SDavid Greenman 			/*
34292dc7331SDavid Greenman 			 * If downgrading lock, others may be
34392dc7331SDavid Greenman 			 * able to acquire it.
34492dc7331SDavid Greenman 			 */
34592dc7331SDavid Greenman 			if (lock->lf_type == F_RDLCK &&
34692dc7331SDavid Greenman 			    overlap->lf_type == F_WRLCK)
34792dc7331SDavid Greenman 				lf_wakelock(overlap);
34892dc7331SDavid Greenman 			overlap->lf_type = lock->lf_type;
34992dc7331SDavid Greenman 			FREE(lock, M_LOCKF);
35092dc7331SDavid Greenman 			lock = overlap; /* for debug output below */
35192dc7331SDavid Greenman 			break;
35292dc7331SDavid Greenman 
35392dc7331SDavid Greenman 		case 2: /* overlap contains lock */
35492dc7331SDavid Greenman 			/*
35592dc7331SDavid Greenman 			 * Check for common starting point and different types.
35692dc7331SDavid Greenman 			 */
35792dc7331SDavid Greenman 			if (overlap->lf_type == lock->lf_type) {
35892dc7331SDavid Greenman 				free(lock, M_LOCKF);
35992dc7331SDavid Greenman 				lock = overlap; /* for debug output below */
36092dc7331SDavid Greenman 				break;
36192dc7331SDavid Greenman 			}
36292dc7331SDavid Greenman 			if (overlap->lf_start == lock->lf_start) {
36392dc7331SDavid Greenman 				*prev = lock;
36492dc7331SDavid Greenman 				lock->lf_next = overlap;
36592dc7331SDavid Greenman 				overlap->lf_start = lock->lf_end + 1;
36692dc7331SDavid Greenman 			} else
36792dc7331SDavid Greenman 				lf_split(overlap, lock);
36892dc7331SDavid Greenman 			lf_wakelock(overlap);
36992dc7331SDavid Greenman 			break;
37092dc7331SDavid Greenman 
37192dc7331SDavid Greenman 		case 3: /* lock contains overlap */
37292dc7331SDavid Greenman 			/*
37392dc7331SDavid Greenman 			 * If downgrading lock, others may be able to
37492dc7331SDavid Greenman 			 * acquire it, otherwise take the list.
37592dc7331SDavid Greenman 			 */
37692dc7331SDavid Greenman 			if (lock->lf_type == F_RDLCK &&
37792dc7331SDavid Greenman 			    overlap->lf_type == F_WRLCK) {
37892dc7331SDavid Greenman 				lf_wakelock(overlap);
37992dc7331SDavid Greenman 			} else {
3801b727751SPoul-Henning Kamp 				while (!TAILQ_EMPTY(&overlap->lf_blkhd)) {
3811b727751SPoul-Henning Kamp 					ltmp = TAILQ_FIRST(&overlap->lf_blkhd);
382996c772fSJohn Dyson 					TAILQ_REMOVE(&overlap->lf_blkhd, ltmp,
383996c772fSJohn Dyson 					    lf_block);
384996c772fSJohn Dyson 					TAILQ_INSERT_TAIL(&lock->lf_blkhd,
385996c772fSJohn Dyson 					    ltmp, lf_block);
386db72e058SDmitrij Tejblum 					ltmp->lf_next = lock;
387996c772fSJohn Dyson 				}
38892dc7331SDavid Greenman 			}
38992dc7331SDavid Greenman 			/*
39092dc7331SDavid Greenman 			 * Add the new lock if necessary and delete the overlap.
39192dc7331SDavid Greenman 			 */
39292dc7331SDavid Greenman 			if (needtolink) {
39392dc7331SDavid Greenman 				*prev = lock;
39492dc7331SDavid Greenman 				lock->lf_next = overlap->lf_next;
39592dc7331SDavid Greenman 				prev = &lock->lf_next;
39692dc7331SDavid Greenman 				needtolink = 0;
39792dc7331SDavid Greenman 			} else
39892dc7331SDavid Greenman 				*prev = overlap->lf_next;
39992dc7331SDavid Greenman 			free(overlap, M_LOCKF);
40092dc7331SDavid Greenman 			continue;
40192dc7331SDavid Greenman 
40292dc7331SDavid Greenman 		case 4: /* overlap starts before lock */
40392dc7331SDavid Greenman 			/*
40492dc7331SDavid Greenman 			 * Add lock after overlap on the list.
40592dc7331SDavid Greenman 			 */
40692dc7331SDavid Greenman 			lock->lf_next = overlap->lf_next;
40792dc7331SDavid Greenman 			overlap->lf_next = lock;
40892dc7331SDavid Greenman 			overlap->lf_end = lock->lf_start - 1;
40992dc7331SDavid Greenman 			prev = &lock->lf_next;
41092dc7331SDavid Greenman 			lf_wakelock(overlap);
41192dc7331SDavid Greenman 			needtolink = 0;
41292dc7331SDavid Greenman 			continue;
41392dc7331SDavid Greenman 
41492dc7331SDavid Greenman 		case 5: /* overlap ends after lock */
41592dc7331SDavid Greenman 			/*
41692dc7331SDavid Greenman 			 * Add the new lock before overlap.
41792dc7331SDavid Greenman 			 */
41892dc7331SDavid Greenman 			if (needtolink) {
41992dc7331SDavid Greenman 				*prev = lock;
42092dc7331SDavid Greenman 				lock->lf_next = overlap;
42192dc7331SDavid Greenman 			}
42292dc7331SDavid Greenman 			overlap->lf_start = lock->lf_end + 1;
42392dc7331SDavid Greenman 			lf_wakelock(overlap);
42492dc7331SDavid Greenman 			break;
42592dc7331SDavid Greenman 		}
42692dc7331SDavid Greenman 		break;
42792dc7331SDavid Greenman 	}
42892dc7331SDavid Greenman #ifdef LOCKF_DEBUG
42992dc7331SDavid Greenman 	if (lockf_debug & 1) {
43092dc7331SDavid Greenman 		lf_print("lf_setlock: got the lock", lock);
43192dc7331SDavid Greenman 		lf_printlist("lf_setlock", lock);
43292dc7331SDavid Greenman 	}
43392dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
43492dc7331SDavid Greenman 	return (0);
43592dc7331SDavid Greenman }
43692dc7331SDavid Greenman 
43792dc7331SDavid Greenman /*
43892dc7331SDavid Greenman  * Remove a byte-range lock on an inode.
43992dc7331SDavid Greenman  *
44092dc7331SDavid Greenman  * Generally, find the lock (or an overlap to that lock)
44192dc7331SDavid Greenman  * and remove it (or shrink it), then wakeup anyone we can.
44292dc7331SDavid Greenman  */
44387b6de2bSPoul-Henning Kamp static int
44492dc7331SDavid Greenman lf_clearlock(unlock)
44592dc7331SDavid Greenman 	register struct lockf *unlock;
44692dc7331SDavid Greenman {
44792dc7331SDavid Greenman 	struct lockf **head = unlock->lf_head;
44892dc7331SDavid Greenman 	register struct lockf *lf = *head;
44992dc7331SDavid Greenman 	struct lockf *overlap, **prev;
45092dc7331SDavid Greenman 	int ovcase;
45192dc7331SDavid Greenman 
45292dc7331SDavid Greenman 	if (lf == NOLOCKF)
45392dc7331SDavid Greenman 		return (0);
45492dc7331SDavid Greenman #ifdef LOCKF_DEBUG
45592dc7331SDavid Greenman 	if (unlock->lf_type != F_UNLCK)
45692dc7331SDavid Greenman 		panic("lf_clearlock: bad type");
45792dc7331SDavid Greenman 	if (lockf_debug & 1)
45892dc7331SDavid Greenman 		lf_print("lf_clearlock", unlock);
45992dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
46092dc7331SDavid Greenman 	prev = head;
461bb56ec4aSPoul-Henning Kamp 	while ((ovcase = lf_findoverlap(lf, unlock, SELF, &prev, &overlap))) {
46292dc7331SDavid Greenman 		/*
46392dc7331SDavid Greenman 		 * Wakeup the list of locks to be retried.
46492dc7331SDavid Greenman 		 */
46592dc7331SDavid Greenman 		lf_wakelock(overlap);
46692dc7331SDavid Greenman 
46792dc7331SDavid Greenman 		switch (ovcase) {
46892dc7331SDavid Greenman 
46992dc7331SDavid Greenman 		case 1: /* overlap == lock */
47092dc7331SDavid Greenman 			*prev = overlap->lf_next;
47192dc7331SDavid Greenman 			FREE(overlap, M_LOCKF);
47292dc7331SDavid Greenman 			break;
47392dc7331SDavid Greenman 
47492dc7331SDavid Greenman 		case 2: /* overlap contains lock: split it */
47592dc7331SDavid Greenman 			if (overlap->lf_start == unlock->lf_start) {
47692dc7331SDavid Greenman 				overlap->lf_start = unlock->lf_end + 1;
47792dc7331SDavid Greenman 				break;
47892dc7331SDavid Greenman 			}
47992dc7331SDavid Greenman 			lf_split(overlap, unlock);
48092dc7331SDavid Greenman 			overlap->lf_next = unlock->lf_next;
48192dc7331SDavid Greenman 			break;
48292dc7331SDavid Greenman 
48392dc7331SDavid Greenman 		case 3: /* lock contains overlap */
48492dc7331SDavid Greenman 			*prev = overlap->lf_next;
48592dc7331SDavid Greenman 			lf = overlap->lf_next;
48692dc7331SDavid Greenman 			free(overlap, M_LOCKF);
48792dc7331SDavid Greenman 			continue;
48892dc7331SDavid Greenman 
48992dc7331SDavid Greenman 		case 4: /* overlap starts before lock */
49092dc7331SDavid Greenman 			overlap->lf_end = unlock->lf_start - 1;
49192dc7331SDavid Greenman 			prev = &overlap->lf_next;
49292dc7331SDavid Greenman 			lf = overlap->lf_next;
49392dc7331SDavid Greenman 			continue;
49492dc7331SDavid Greenman 
49592dc7331SDavid Greenman 		case 5: /* overlap ends after lock */
49692dc7331SDavid Greenman 			overlap->lf_start = unlock->lf_end + 1;
49792dc7331SDavid Greenman 			break;
49892dc7331SDavid Greenman 		}
49992dc7331SDavid Greenman 		break;
50092dc7331SDavid Greenman 	}
50192dc7331SDavid Greenman #ifdef LOCKF_DEBUG
50292dc7331SDavid Greenman 	if (lockf_debug & 1)
50392dc7331SDavid Greenman 		lf_printlist("lf_clearlock", unlock);
50492dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
50592dc7331SDavid Greenman 	return (0);
50692dc7331SDavid Greenman }
50792dc7331SDavid Greenman 
50892dc7331SDavid Greenman /*
50992dc7331SDavid Greenman  * Check whether there is a blocking lock,
51092dc7331SDavid Greenman  * and if so return its process identifier.
51192dc7331SDavid Greenman  */
51287b6de2bSPoul-Henning Kamp static int
51392dc7331SDavid Greenman lf_getlock(lock, fl)
51492dc7331SDavid Greenman 	register struct lockf *lock;
51592dc7331SDavid Greenman 	register struct flock *fl;
51692dc7331SDavid Greenman {
51792dc7331SDavid Greenman 	register struct lockf *block;
51892dc7331SDavid Greenman 
51992dc7331SDavid Greenman #ifdef LOCKF_DEBUG
52092dc7331SDavid Greenman 	if (lockf_debug & 1)
52192dc7331SDavid Greenman 		lf_print("lf_getlock", lock);
52292dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
52392dc7331SDavid Greenman 
524bb56ec4aSPoul-Henning Kamp 	if ((block = lf_getblock(lock))) {
52592dc7331SDavid Greenman 		fl->l_type = block->lf_type;
52692dc7331SDavid Greenman 		fl->l_whence = SEEK_SET;
52792dc7331SDavid Greenman 		fl->l_start = block->lf_start;
52892dc7331SDavid Greenman 		if (block->lf_end == -1)
52992dc7331SDavid Greenman 			fl->l_len = 0;
53092dc7331SDavid Greenman 		else
53192dc7331SDavid Greenman 			fl->l_len = block->lf_end - block->lf_start + 1;
53292dc7331SDavid Greenman 		if (block->lf_flags & F_POSIX)
53392dc7331SDavid Greenman 			fl->l_pid = ((struct proc *)(block->lf_id))->p_pid;
53492dc7331SDavid Greenman 		else
53592dc7331SDavid Greenman 			fl->l_pid = -1;
53692dc7331SDavid Greenman 	} else {
53792dc7331SDavid Greenman 		fl->l_type = F_UNLCK;
53892dc7331SDavid Greenman 	}
53992dc7331SDavid Greenman 	return (0);
54092dc7331SDavid Greenman }
54192dc7331SDavid Greenman 
54292dc7331SDavid Greenman /*
54392dc7331SDavid Greenman  * Walk the list of locks for an inode and
54492dc7331SDavid Greenman  * return the first blocking lock.
54592dc7331SDavid Greenman  */
54687b6de2bSPoul-Henning Kamp static struct lockf *
54792dc7331SDavid Greenman lf_getblock(lock)
54892dc7331SDavid Greenman 	register struct lockf *lock;
54992dc7331SDavid Greenman {
55092dc7331SDavid Greenman 	struct lockf **prev, *overlap, *lf = *(lock->lf_head);
55192dc7331SDavid Greenman 	int ovcase;
55292dc7331SDavid Greenman 
55392dc7331SDavid Greenman 	prev = lock->lf_head;
554bb56ec4aSPoul-Henning Kamp 	while ((ovcase = lf_findoverlap(lf, lock, OTHERS, &prev, &overlap))) {
55592dc7331SDavid Greenman 		/*
55692dc7331SDavid Greenman 		 * We've found an overlap, see if it blocks us
55792dc7331SDavid Greenman 		 */
55892dc7331SDavid Greenman 		if ((lock->lf_type == F_WRLCK || overlap->lf_type == F_WRLCK))
55992dc7331SDavid Greenman 			return (overlap);
56092dc7331SDavid Greenman 		/*
56192dc7331SDavid Greenman 		 * Nope, point to the next one on the list and
56292dc7331SDavid Greenman 		 * see if it blocks us
56392dc7331SDavid Greenman 		 */
56492dc7331SDavid Greenman 		lf = overlap->lf_next;
56592dc7331SDavid Greenman 	}
56692dc7331SDavid Greenman 	return (NOLOCKF);
56792dc7331SDavid Greenman }
56892dc7331SDavid Greenman 
56992dc7331SDavid Greenman /*
57092dc7331SDavid Greenman  * Walk the list of locks for an inode to
57192dc7331SDavid Greenman  * find an overlapping lock (if any).
57292dc7331SDavid Greenman  *
57392dc7331SDavid Greenman  * NOTE: this returns only the FIRST overlapping lock.  There
57492dc7331SDavid Greenman  *	 may be more than one.
57592dc7331SDavid Greenman  */
57687b6de2bSPoul-Henning Kamp static int
57792dc7331SDavid Greenman lf_findoverlap(lf, lock, type, prev, overlap)
57892dc7331SDavid Greenman 	register struct lockf *lf;
57992dc7331SDavid Greenman 	struct lockf *lock;
58092dc7331SDavid Greenman 	int type;
58192dc7331SDavid Greenman 	struct lockf ***prev;
58292dc7331SDavid Greenman 	struct lockf **overlap;
58392dc7331SDavid Greenman {
58492dc7331SDavid Greenman 	off_t start, end;
58592dc7331SDavid Greenman 
58692dc7331SDavid Greenman 	*overlap = lf;
58792dc7331SDavid Greenman 	if (lf == NOLOCKF)
58892dc7331SDavid Greenman 		return (0);
58992dc7331SDavid Greenman #ifdef LOCKF_DEBUG
59092dc7331SDavid Greenman 	if (lockf_debug & 2)
59192dc7331SDavid Greenman 		lf_print("lf_findoverlap: looking for overlap in", lock);
59292dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
59392dc7331SDavid Greenman 	start = lock->lf_start;
59492dc7331SDavid Greenman 	end = lock->lf_end;
59592dc7331SDavid Greenman 	while (lf != NOLOCKF) {
59692dc7331SDavid Greenman 		if (((type & SELF) && lf->lf_id != lock->lf_id) ||
59792dc7331SDavid Greenman 		    ((type & OTHERS) && lf->lf_id == lock->lf_id)) {
59892dc7331SDavid Greenman 			*prev = &lf->lf_next;
59992dc7331SDavid Greenman 			*overlap = lf = lf->lf_next;
60092dc7331SDavid Greenman 			continue;
60192dc7331SDavid Greenman 		}
60292dc7331SDavid Greenman #ifdef LOCKF_DEBUG
60392dc7331SDavid Greenman 		if (lockf_debug & 2)
60492dc7331SDavid Greenman 			lf_print("\tchecking", lf);
60592dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
60692dc7331SDavid Greenman 		/*
60792dc7331SDavid Greenman 		 * OK, check for overlap
60892dc7331SDavid Greenman 		 *
60992dc7331SDavid Greenman 		 * Six cases:
61092dc7331SDavid Greenman 		 *	0) no overlap
61192dc7331SDavid Greenman 		 *	1) overlap == lock
61292dc7331SDavid Greenman 		 *	2) overlap contains lock
61392dc7331SDavid Greenman 		 *	3) lock contains overlap
61492dc7331SDavid Greenman 		 *	4) overlap starts before lock
61592dc7331SDavid Greenman 		 *	5) overlap ends after lock
61692dc7331SDavid Greenman 		 */
61792dc7331SDavid Greenman 		if ((lf->lf_end != -1 && start > lf->lf_end) ||
61892dc7331SDavid Greenman 		    (end != -1 && lf->lf_start > end)) {
61992dc7331SDavid Greenman 			/* Case 0 */
62092dc7331SDavid Greenman #ifdef LOCKF_DEBUG
62192dc7331SDavid Greenman 			if (lockf_debug & 2)
62292dc7331SDavid Greenman 				printf("no overlap\n");
62392dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
62492dc7331SDavid Greenman 			if ((type & SELF) && end != -1 && lf->lf_start > end)
62592dc7331SDavid Greenman 				return (0);
62692dc7331SDavid Greenman 			*prev = &lf->lf_next;
62792dc7331SDavid Greenman 			*overlap = lf = lf->lf_next;
62892dc7331SDavid Greenman 			continue;
62992dc7331SDavid Greenman 		}
63092dc7331SDavid Greenman 		if ((lf->lf_start == start) && (lf->lf_end == end)) {
63192dc7331SDavid Greenman 			/* Case 1 */
63292dc7331SDavid Greenman #ifdef LOCKF_DEBUG
63392dc7331SDavid Greenman 			if (lockf_debug & 2)
63492dc7331SDavid Greenman 				printf("overlap == lock\n");
63592dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
63692dc7331SDavid Greenman 			return (1);
63792dc7331SDavid Greenman 		}
63892dc7331SDavid Greenman 		if ((lf->lf_start <= start) &&
63992dc7331SDavid Greenman 		    (end != -1) &&
64092dc7331SDavid Greenman 		    ((lf->lf_end >= end) || (lf->lf_end == -1))) {
64192dc7331SDavid Greenman 			/* Case 2 */
64292dc7331SDavid Greenman #ifdef LOCKF_DEBUG
64392dc7331SDavid Greenman 			if (lockf_debug & 2)
64492dc7331SDavid Greenman 				printf("overlap contains lock\n");
64592dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
64692dc7331SDavid Greenman 			return (2);
64792dc7331SDavid Greenman 		}
64892dc7331SDavid Greenman 		if (start <= lf->lf_start &&
64992dc7331SDavid Greenman 		           (end == -1 ||
65092dc7331SDavid Greenman 			   (lf->lf_end != -1 && end >= lf->lf_end))) {
65192dc7331SDavid Greenman 			/* Case 3 */
65292dc7331SDavid Greenman #ifdef LOCKF_DEBUG
65392dc7331SDavid Greenman 			if (lockf_debug & 2)
65492dc7331SDavid Greenman 				printf("lock contains overlap\n");
65592dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
65692dc7331SDavid Greenman 			return (3);
65792dc7331SDavid Greenman 		}
65892dc7331SDavid Greenman 		if ((lf->lf_start < start) &&
65992dc7331SDavid Greenman 			((lf->lf_end >= start) || (lf->lf_end == -1))) {
66092dc7331SDavid Greenman 			/* Case 4 */
66192dc7331SDavid Greenman #ifdef LOCKF_DEBUG
66292dc7331SDavid Greenman 			if (lockf_debug & 2)
66392dc7331SDavid Greenman 				printf("overlap starts before lock\n");
66492dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
66592dc7331SDavid Greenman 			return (4);
66692dc7331SDavid Greenman 		}
66792dc7331SDavid Greenman 		if ((lf->lf_start > start) &&
66892dc7331SDavid Greenman 			(end != -1) &&
66992dc7331SDavid Greenman 			((lf->lf_end > end) || (lf->lf_end == -1))) {
67092dc7331SDavid Greenman 			/* Case 5 */
67192dc7331SDavid Greenman #ifdef LOCKF_DEBUG
67292dc7331SDavid Greenman 			if (lockf_debug & 2)
67392dc7331SDavid Greenman 				printf("overlap ends after lock\n");
67492dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
67592dc7331SDavid Greenman 			return (5);
67692dc7331SDavid Greenman 		}
67792dc7331SDavid Greenman 		panic("lf_findoverlap: default");
67892dc7331SDavid Greenman 	}
67992dc7331SDavid Greenman 	return (0);
68092dc7331SDavid Greenman }
68192dc7331SDavid Greenman 
68292dc7331SDavid Greenman /*
68392dc7331SDavid Greenman  * Split a lock and a contained region into
68492dc7331SDavid Greenman  * two or three locks as necessary.
68592dc7331SDavid Greenman  */
68687b6de2bSPoul-Henning Kamp static void
68792dc7331SDavid Greenman lf_split(lock1, lock2)
68892dc7331SDavid Greenman 	register struct lockf *lock1;
68992dc7331SDavid Greenman 	register struct lockf *lock2;
69092dc7331SDavid Greenman {
69192dc7331SDavid Greenman 	register struct lockf *splitlock;
69292dc7331SDavid Greenman 
69392dc7331SDavid Greenman #ifdef LOCKF_DEBUG
69492dc7331SDavid Greenman 	if (lockf_debug & 2) {
69592dc7331SDavid Greenman 		lf_print("lf_split", lock1);
69692dc7331SDavid Greenman 		lf_print("splitting from", lock2);
69792dc7331SDavid Greenman 	}
69892dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
69992dc7331SDavid Greenman 	/*
70092dc7331SDavid Greenman 	 * Check to see if spliting into only two pieces.
70192dc7331SDavid Greenman 	 */
70292dc7331SDavid Greenman 	if (lock1->lf_start == lock2->lf_start) {
70392dc7331SDavid Greenman 		lock1->lf_start = lock2->lf_end + 1;
70492dc7331SDavid Greenman 		lock2->lf_next = lock1;
70592dc7331SDavid Greenman 		return;
70692dc7331SDavid Greenman 	}
70792dc7331SDavid Greenman 	if (lock1->lf_end == lock2->lf_end) {
70892dc7331SDavid Greenman 		lock1->lf_end = lock2->lf_start - 1;
70992dc7331SDavid Greenman 		lock2->lf_next = lock1->lf_next;
71092dc7331SDavid Greenman 		lock1->lf_next = lock2;
71192dc7331SDavid Greenman 		return;
71292dc7331SDavid Greenman 	}
71392dc7331SDavid Greenman 	/*
71492dc7331SDavid Greenman 	 * Make a new lock consisting of the last part of
71592dc7331SDavid Greenman 	 * the encompassing lock
71692dc7331SDavid Greenman 	 */
71792dc7331SDavid Greenman 	MALLOC(splitlock, struct lockf *, sizeof *splitlock, M_LOCKF, M_WAITOK);
71892dc7331SDavid Greenman 	bcopy((caddr_t)lock1, (caddr_t)splitlock, sizeof *splitlock);
71992dc7331SDavid Greenman 	splitlock->lf_start = lock2->lf_end + 1;
720996c772fSJohn Dyson 	TAILQ_INIT(&splitlock->lf_blkhd);
72192dc7331SDavid Greenman 	lock1->lf_end = lock2->lf_start - 1;
72292dc7331SDavid Greenman 	/*
72392dc7331SDavid Greenman 	 * OK, now link it in
72492dc7331SDavid Greenman 	 */
72592dc7331SDavid Greenman 	splitlock->lf_next = lock1->lf_next;
72692dc7331SDavid Greenman 	lock2->lf_next = splitlock;
72792dc7331SDavid Greenman 	lock1->lf_next = lock2;
72892dc7331SDavid Greenman }
72992dc7331SDavid Greenman 
73092dc7331SDavid Greenman /*
73192dc7331SDavid Greenman  * Wakeup a blocklist
73292dc7331SDavid Greenman  */
73387b6de2bSPoul-Henning Kamp static void
73492dc7331SDavid Greenman lf_wakelock(listhead)
73592dc7331SDavid Greenman 	struct lockf *listhead;
73692dc7331SDavid Greenman {
737996c772fSJohn Dyson 	register struct lockf *wakelock;
73892dc7331SDavid Greenman 
7391b727751SPoul-Henning Kamp 	while (!TAILQ_EMPTY(&listhead->lf_blkhd)) {
7401b727751SPoul-Henning Kamp 		wakelock = TAILQ_FIRST(&listhead->lf_blkhd);
741996c772fSJohn Dyson 		TAILQ_REMOVE(&listhead->lf_blkhd, wakelock, lf_block);
74292dc7331SDavid Greenman 		wakelock->lf_next = NOLOCKF;
74392dc7331SDavid Greenman #ifdef LOCKF_DEBUG
74492dc7331SDavid Greenman 		if (lockf_debug & 2)
74592dc7331SDavid Greenman 			lf_print("lf_wakelock: awakening", wakelock);
74692dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
74792dc7331SDavid Greenman 		wakeup((caddr_t)wakelock);
74892dc7331SDavid Greenman 	}
74992dc7331SDavid Greenman }
75092dc7331SDavid Greenman 
75192dc7331SDavid Greenman #ifdef LOCKF_DEBUG
75292dc7331SDavid Greenman /*
75392dc7331SDavid Greenman  * Print out a lock.
75492dc7331SDavid Greenman  */
755b52748beSBruce Evans void
75692dc7331SDavid Greenman lf_print(tag, lock)
75792dc7331SDavid Greenman 	char *tag;
75892dc7331SDavid Greenman 	register struct lockf *lock;
75992dc7331SDavid Greenman {
76092dc7331SDavid Greenman 
761d974cf4dSBruce Evans 	printf("%s: lock %p for ", tag, (void *)lock);
76292dc7331SDavid Greenman 	if (lock->lf_flags & F_POSIX)
763d974cf4dSBruce Evans 		printf("proc %ld", (long)((struct proc *)lock->lf_id)->p_pid);
76492dc7331SDavid Greenman 	else
765d974cf4dSBruce Evans 		printf("id %p", (void *)lock->lf_id);
766d974cf4dSBruce Evans 	/* XXX no %qd in kernel.  Truncate. */
767d974cf4dSBruce Evans 	printf(" in ino %lu on dev <%d, %d>, %s, start %ld, end %ld",
768d974cf4dSBruce Evans 	    (u_long)lock->lf_inode->i_number,
76992dc7331SDavid Greenman 	    major(lock->lf_inode->i_dev),
77092dc7331SDavid Greenman 	    minor(lock->lf_inode->i_dev),
77192dc7331SDavid Greenman 	    lock->lf_type == F_RDLCK ? "shared" :
77292dc7331SDavid Greenman 	    lock->lf_type == F_WRLCK ? "exclusive" :
77392dc7331SDavid Greenman 	    lock->lf_type == F_UNLCK ? "unlock" :
774d974cf4dSBruce Evans 	    "unknown", (long)lock->lf_start, (long)lock->lf_end);
7751b727751SPoul-Henning Kamp 	if (!TAILQ_EMPTY(&lock->lf_blkhd))
7761b727751SPoul-Henning Kamp 		printf(" block %p\n", (void *)TAILQ_FIRST(&lock->lf_blkhd));
77792dc7331SDavid Greenman 	else
77892dc7331SDavid Greenman 		printf("\n");
77992dc7331SDavid Greenman }
78092dc7331SDavid Greenman 
781b52748beSBruce Evans void
78292dc7331SDavid Greenman lf_printlist(tag, lock)
78392dc7331SDavid Greenman 	char *tag;
78492dc7331SDavid Greenman 	struct lockf *lock;
78592dc7331SDavid Greenman {
786996c772fSJohn Dyson 	register struct lockf *lf, *blk;
78792dc7331SDavid Greenman 
788d974cf4dSBruce Evans 	printf("%s: Lock list for ino %lu on dev <%d, %d>:\n",
789d974cf4dSBruce Evans 	    tag, (u_long)lock->lf_inode->i_number,
79092dc7331SDavid Greenman 	    major(lock->lf_inode->i_dev),
79192dc7331SDavid Greenman 	    minor(lock->lf_inode->i_dev));
79292dc7331SDavid Greenman 	for (lf = lock->lf_inode->i_lockf; lf; lf = lf->lf_next) {
793d974cf4dSBruce Evans 		printf("\tlock %p for ",(void *)lf);
79492dc7331SDavid Greenman 		if (lf->lf_flags & F_POSIX)
795d974cf4dSBruce Evans 			printf("proc %ld",
796d974cf4dSBruce Evans 			    (long)((struct proc *)lf->lf_id)->p_pid);
79792dc7331SDavid Greenman 		else
798d974cf4dSBruce Evans 			printf("id %p", (void *)lf->lf_id);
799d974cf4dSBruce Evans 		/* XXX no %qd in kernel.  Truncate. */
800d974cf4dSBruce Evans 		printf(", %s, start %ld, end %ld",
80192dc7331SDavid Greenman 		    lf->lf_type == F_RDLCK ? "shared" :
80292dc7331SDavid Greenman 		    lf->lf_type == F_WRLCK ? "exclusive" :
80392dc7331SDavid Greenman 		    lf->lf_type == F_UNLCK ? "unlock" :
804d974cf4dSBruce Evans 		    "unknown", (long)lf->lf_start, (long)lf->lf_end);
8051b727751SPoul-Henning Kamp 		TAILQ_FOREACH(blk, &lf->lf_blkhd, lf_block) {
806d974cf4dSBruce Evans 			printf("\n\t\tlock request %p for ", (void *)blk);
807996c772fSJohn Dyson 			if (blk->lf_flags & F_POSIX)
808d974cf4dSBruce Evans 				printf("proc %ld",
809d974cf4dSBruce Evans 				    (long)((struct proc *)blk->lf_id)->p_pid);
81092dc7331SDavid Greenman 			else
811d974cf4dSBruce Evans 				printf("id %p", (void *)blk->lf_id);
812d974cf4dSBruce Evans 			/* XXX no %qd in kernel.  Truncate. */
813d974cf4dSBruce Evans 			printf(", %s, start %ld, end %ld",
814996c772fSJohn Dyson 			    blk->lf_type == F_RDLCK ? "shared" :
815996c772fSJohn Dyson 			    blk->lf_type == F_WRLCK ? "exclusive" :
816996c772fSJohn Dyson 			    blk->lf_type == F_UNLCK ? "unlock" :
817d974cf4dSBruce Evans 			    "unknown", (long)blk->lf_start,
818d974cf4dSBruce Evans 			    (long)blk->lf_end);
8191b727751SPoul-Henning Kamp 			if (!TAILQ_EMPTY(&blk->lf_blkhd))
820996c772fSJohn Dyson 				panic("lf_printlist: bad list");
821996c772fSJohn Dyson 		}
82292dc7331SDavid Greenman 		printf("\n");
82392dc7331SDavid Greenman 	}
82492dc7331SDavid Greenman }
82592dc7331SDavid Greenman #endif /* LOCKF_DEBUG */
826