Home | History | Annotate | Line # | Download | only in uvm
uvm_pdaemon.c revision 1.65.2.3
      1  1.65.2.3      yamt /*	$NetBSD: uvm_pdaemon.c,v 1.65.2.3 2007/02/26 09:12:32 yamt Exp $	*/
      2       1.1       mrg 
      3      1.34       chs /*
      4       1.1       mrg  * Copyright (c) 1997 Charles D. Cranor and Washington University.
      5      1.34       chs  * Copyright (c) 1991, 1993, The Regents of the University of California.
      6       1.1       mrg  *
      7       1.1       mrg  * All rights reserved.
      8       1.1       mrg  *
      9       1.1       mrg  * This code is derived from software contributed to Berkeley by
     10       1.1       mrg  * The Mach Operating System project at Carnegie-Mellon University.
     11       1.1       mrg  *
     12       1.1       mrg  * Redistribution and use in source and binary forms, with or without
     13       1.1       mrg  * modification, are permitted provided that the following conditions
     14       1.1       mrg  * are met:
     15       1.1       mrg  * 1. Redistributions of source code must retain the above copyright
     16       1.1       mrg  *    notice, this list of conditions and the following disclaimer.
     17       1.1       mrg  * 2. Redistributions in binary form must reproduce the above copyright
     18       1.1       mrg  *    notice, this list of conditions and the following disclaimer in the
     19       1.1       mrg  *    documentation and/or other materials provided with the distribution.
     20       1.1       mrg  * 3. All advertising materials mentioning features or use of this software
     21       1.1       mrg  *    must display the following acknowledgement:
     22       1.1       mrg  *	This product includes software developed by Charles D. Cranor,
     23      1.34       chs  *      Washington University, the University of California, Berkeley and
     24       1.1       mrg  *      its contributors.
     25       1.1       mrg  * 4. Neither the name of the University nor the names of its contributors
     26       1.1       mrg  *    may be used to endorse or promote products derived from this software
     27       1.1       mrg  *    without specific prior written permission.
     28       1.1       mrg  *
     29       1.1       mrg  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     30       1.1       mrg  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     31       1.1       mrg  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     32       1.1       mrg  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     33       1.1       mrg  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     34       1.1       mrg  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     35       1.1       mrg  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     36       1.1       mrg  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     37       1.1       mrg  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     38       1.1       mrg  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     39       1.1       mrg  * SUCH DAMAGE.
     40       1.1       mrg  *
     41       1.1       mrg  *	@(#)vm_pageout.c        8.5 (Berkeley) 2/14/94
     42       1.4       mrg  * from: Id: uvm_pdaemon.c,v 1.1.2.32 1998/02/06 05:26:30 chs Exp
     43       1.1       mrg  *
     44       1.1       mrg  *
     45       1.1       mrg  * Copyright (c) 1987, 1990 Carnegie-Mellon University.
     46       1.1       mrg  * All rights reserved.
     47      1.34       chs  *
     48       1.1       mrg  * Permission to use, copy, modify and distribute this software and
     49       1.1       mrg  * its documentation is hereby granted, provided that both the copyright
     50       1.1       mrg  * notice and this permission notice appear in all copies of the
     51       1.1       mrg  * software, derivative works or modified versions, and any portions
     52       1.1       mrg  * thereof, and that both notices appear in supporting documentation.
     53      1.34       chs  *
     54      1.34       chs  * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
     55      1.34       chs  * CONDITION.  CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
     56       1.1       mrg  * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
     57      1.34       chs  *
     58       1.1       mrg  * Carnegie Mellon requests users of this software to return to
     59       1.1       mrg  *
     60       1.1       mrg  *  Software Distribution Coordinator  or  Software.Distribution (at) CS.CMU.EDU
     61       1.1       mrg  *  School of Computer Science
     62       1.1       mrg  *  Carnegie Mellon University
     63       1.1       mrg  *  Pittsburgh PA 15213-3890
     64       1.1       mrg  *
     65       1.1       mrg  * any improvements or extensions that they make and grant Carnegie the
     66       1.1       mrg  * rights to redistribute these changes.
     67       1.1       mrg  */
     68       1.1       mrg 
     69       1.1       mrg /*
     70       1.1       mrg  * uvm_pdaemon.c: the page daemon
     71       1.1       mrg  */
     72      1.42     lukem 
     73      1.42     lukem #include <sys/cdefs.h>
     74  1.65.2.3      yamt __KERNEL_RCSID(0, "$NetBSD: uvm_pdaemon.c,v 1.65.2.3 2007/02/26 09:12:32 yamt Exp $");
     75      1.42     lukem 
     76      1.42     lukem #include "opt_uvmhist.h"
     77  1.65.2.1      yamt #include "opt_readahead.h"
     78       1.1       mrg 
     79       1.1       mrg #include <sys/param.h>
     80       1.1       mrg #include <sys/proc.h>
     81       1.1       mrg #include <sys/systm.h>
     82       1.1       mrg #include <sys/kernel.h>
     83       1.9        pk #include <sys/pool.h>
     84      1.24       chs #include <sys/buf.h>
     85       1.1       mrg 
     86       1.1       mrg #include <uvm/uvm.h>
     87  1.65.2.2      yamt #include <uvm/uvm_pdpolicy.h>
     88       1.1       mrg 
     89       1.1       mrg /*
     90      1.45       wiz  * UVMPD_NUMDIRTYREACTS is how many dirty pages the pagedaemon will reactivate
     91      1.14       chs  * in a pass thru the inactive list when swap is full.  the value should be
     92      1.14       chs  * "small"... if it's too large we'll cycle the active pages thru the inactive
     93      1.14       chs  * queue too quickly to for them to be referenced and avoid being freed.
     94      1.14       chs  */
     95      1.14       chs 
     96      1.14       chs #define UVMPD_NUMDIRTYREACTS 16
     97      1.14       chs 
     98      1.14       chs 
     99      1.14       chs /*
    100       1.1       mrg  * local prototypes
    101       1.1       mrg  */
    102       1.1       mrg 
    103      1.65   thorpej static void	uvmpd_scan(void);
    104  1.65.2.2      yamt static void	uvmpd_scan_queue(void);
    105      1.65   thorpej static void	uvmpd_tune(void);
    106       1.1       mrg 
    107       1.1       mrg /*
    108      1.61       chs  * XXX hack to avoid hangs when large processes fork.
    109      1.61       chs  */
    110      1.61       chs int uvm_extrapages;
    111      1.61       chs 
    112      1.61       chs /*
    113       1.1       mrg  * uvm_wait: wait (sleep) for the page daemon to free some pages
    114       1.1       mrg  *
    115       1.1       mrg  * => should be called with all locks released
    116       1.1       mrg  * => should _not_ be called by the page daemon (to avoid deadlock)
    117       1.1       mrg  */
    118       1.1       mrg 
    119      1.19   thorpej void
    120      1.65   thorpej uvm_wait(const char *wmsg)
    121       1.8       mrg {
    122       1.8       mrg 	int timo = 0;
    123       1.8       mrg 	int s = splbio();
    124       1.1       mrg 
    125       1.8       mrg 	/*
    126       1.8       mrg 	 * check for page daemon going to sleep (waiting for itself)
    127       1.8       mrg 	 */
    128       1.1       mrg 
    129      1.37       chs 	if (curproc == uvm.pagedaemon_proc && uvmexp.paging == 0) {
    130       1.8       mrg 		/*
    131       1.8       mrg 		 * now we have a problem: the pagedaemon wants to go to
    132       1.8       mrg 		 * sleep until it frees more memory.   but how can it
    133       1.8       mrg 		 * free more memory if it is asleep?  that is a deadlock.
    134       1.8       mrg 		 * we have two options:
    135       1.8       mrg 		 *  [1] panic now
    136       1.8       mrg 		 *  [2] put a timeout on the sleep, thus causing the
    137       1.8       mrg 		 *      pagedaemon to only pause (rather than sleep forever)
    138       1.8       mrg 		 *
    139       1.8       mrg 		 * note that option [2] will only help us if we get lucky
    140       1.8       mrg 		 * and some other process on the system breaks the deadlock
    141       1.8       mrg 		 * by exiting or freeing memory (thus allowing the pagedaemon
    142       1.8       mrg 		 * to continue).  for now we panic if DEBUG is defined,
    143       1.8       mrg 		 * otherwise we hope for the best with option [2] (better
    144       1.8       mrg 		 * yet, this should never happen in the first place!).
    145       1.8       mrg 		 */
    146       1.1       mrg 
    147       1.8       mrg 		printf("pagedaemon: deadlock detected!\n");
    148       1.8       mrg 		timo = hz >> 3;		/* set timeout */
    149       1.1       mrg #if defined(DEBUG)
    150       1.8       mrg 		/* DEBUG: panic so we can debug it */
    151       1.8       mrg 		panic("pagedaemon deadlock");
    152       1.1       mrg #endif
    153       1.8       mrg 	}
    154       1.1       mrg 
    155       1.8       mrg 	simple_lock(&uvm.pagedaemon_lock);
    156      1.17   thorpej 	wakeup(&uvm.pagedaemon);		/* wake the daemon! */
    157  1.65.2.3      yamt 	UVM_UNLOCK_AND_WAIT(&uvmexp.free, &uvm.pagedaemon_lock, false, wmsg,
    158       1.8       mrg 	    timo);
    159       1.1       mrg 
    160       1.8       mrg 	splx(s);
    161       1.1       mrg }
    162       1.1       mrg 
    163  1.65.2.2      yamt /*
    164  1.65.2.2      yamt  * uvm_kick_pdaemon: perform checks to determine if we need to
    165  1.65.2.2      yamt  * give the pagedaemon a nudge, and do so if necessary.
    166  1.65.2.2      yamt  */
    167  1.65.2.2      yamt 
    168  1.65.2.2      yamt void
    169  1.65.2.2      yamt uvm_kick_pdaemon(void)
    170  1.65.2.2      yamt {
    171  1.65.2.2      yamt 
    172  1.65.2.2      yamt 	if (uvmexp.free + uvmexp.paging < uvmexp.freemin ||
    173  1.65.2.2      yamt 	    (uvmexp.free + uvmexp.paging < uvmexp.freetarg &&
    174  1.65.2.2      yamt 	     uvmpdpol_needsscan_p())) {
    175  1.65.2.2      yamt 		wakeup(&uvm.pagedaemon);
    176  1.65.2.2      yamt 	}
    177  1.65.2.2      yamt }
    178       1.1       mrg 
    179       1.1       mrg /*
    180       1.1       mrg  * uvmpd_tune: tune paging parameters
    181       1.1       mrg  *
    182       1.1       mrg  * => called when ever memory is added (or removed?) to the system
    183       1.1       mrg  * => caller must call with page queues locked
    184       1.1       mrg  */
    185       1.1       mrg 
    186      1.65   thorpej static void
    187      1.37       chs uvmpd_tune(void)
    188       1.8       mrg {
    189       1.8       mrg 	UVMHIST_FUNC("uvmpd_tune"); UVMHIST_CALLED(pdhist);
    190       1.1       mrg 
    191       1.8       mrg 	uvmexp.freemin = uvmexp.npages / 20;
    192       1.1       mrg 
    193       1.8       mrg 	/* between 16k and 256k */
    194       1.8       mrg 	/* XXX:  what are these values good for? */
    195      1.37       chs 	uvmexp.freemin = MAX(uvmexp.freemin, (16*1024) >> PAGE_SHIFT);
    196      1.37       chs 	uvmexp.freemin = MIN(uvmexp.freemin, (256*1024) >> PAGE_SHIFT);
    197      1.23     bjh21 
    198      1.23     bjh21 	/* Make sure there's always a user page free. */
    199      1.23     bjh21 	if (uvmexp.freemin < uvmexp.reserve_kernel + 1)
    200      1.23     bjh21 		uvmexp.freemin = uvmexp.reserve_kernel + 1;
    201       1.1       mrg 
    202       1.8       mrg 	uvmexp.freetarg = (uvmexp.freemin * 4) / 3;
    203       1.8       mrg 	if (uvmexp.freetarg <= uvmexp.freemin)
    204       1.8       mrg 		uvmexp.freetarg = uvmexp.freemin + 1;
    205       1.1       mrg 
    206      1.61       chs 	uvmexp.freetarg += uvm_extrapages;
    207      1.61       chs 	uvm_extrapages = 0;
    208      1.61       chs 
    209       1.8       mrg 	uvmexp.wiredmax = uvmexp.npages / 3;
    210       1.8       mrg 	UVMHIST_LOG(pdhist, "<- done, freemin=%d, freetarg=%d, wiredmax=%d",
    211       1.1       mrg 	      uvmexp.freemin, uvmexp.freetarg, uvmexp.wiredmax, 0);
    212       1.1       mrg }
    213       1.1       mrg 
    214       1.1       mrg /*
    215       1.1       mrg  * uvm_pageout: the main loop for the pagedaemon
    216       1.1       mrg  */
    217       1.1       mrg 
    218       1.8       mrg void
    219      1.22   thorpej uvm_pageout(void *arg)
    220       1.8       mrg {
    221      1.60     enami 	int bufcnt, npages = 0;
    222      1.61       chs 	int extrapages = 0;
    223       1.8       mrg 	UVMHIST_FUNC("uvm_pageout"); UVMHIST_CALLED(pdhist);
    224      1.24       chs 
    225       1.8       mrg 	UVMHIST_LOG(pdhist,"<starting uvm pagedaemon>", 0, 0, 0, 0);
    226       1.8       mrg 
    227       1.8       mrg 	/*
    228       1.8       mrg 	 * ensure correct priority and set paging parameters...
    229       1.8       mrg 	 */
    230       1.8       mrg 
    231       1.8       mrg 	uvm.pagedaemon_proc = curproc;
    232       1.8       mrg 	uvm_lock_pageq();
    233       1.8       mrg 	npages = uvmexp.npages;
    234       1.8       mrg 	uvmpd_tune();
    235       1.8       mrg 	uvm_unlock_pageq();
    236       1.8       mrg 
    237       1.8       mrg 	/*
    238       1.8       mrg 	 * main loop
    239       1.8       mrg 	 */
    240      1.24       chs 
    241      1.24       chs 	for (;;) {
    242      1.24       chs 		simple_lock(&uvm.pagedaemon_lock);
    243      1.24       chs 
    244      1.24       chs 		UVMHIST_LOG(pdhist,"  <<SLEEPING>>",0,0,0,0);
    245      1.24       chs 		UVM_UNLOCK_AND_WAIT(&uvm.pagedaemon,
    246  1.65.2.3      yamt 		    &uvm.pagedaemon_lock, false, "pgdaemon", 0);
    247      1.24       chs 		uvmexp.pdwoke++;
    248      1.24       chs 		UVMHIST_LOG(pdhist,"  <<WOKE UP>>",0,0,0,0);
    249      1.24       chs 
    250       1.8       mrg 		/*
    251      1.24       chs 		 * now lock page queues and recompute inactive count
    252       1.8       mrg 		 */
    253       1.8       mrg 
    254      1.24       chs 		uvm_lock_pageq();
    255      1.61       chs 		if (npages != uvmexp.npages || extrapages != uvm_extrapages) {
    256      1.24       chs 			npages = uvmexp.npages;
    257      1.61       chs 			extrapages = uvm_extrapages;
    258      1.24       chs 			uvmpd_tune();
    259      1.24       chs 		}
    260      1.24       chs 
    261  1.65.2.2      yamt 		uvmpdpol_tune();
    262      1.24       chs 
    263      1.60     enami 		/*
    264      1.60     enami 		 * Estimate a hint.  Note that bufmem are returned to
    265      1.60     enami 		 * system only when entire pool page is empty.
    266      1.60     enami 		 */
    267      1.60     enami 		bufcnt = uvmexp.freetarg - uvmexp.free;
    268      1.60     enami 		if (bufcnt < 0)
    269      1.60     enami 			bufcnt = 0;
    270      1.60     enami 
    271  1.65.2.2      yamt 		UVMHIST_LOG(pdhist,"  free/ftarg=%d/%d",
    272  1.65.2.2      yamt 		    uvmexp.free, uvmexp.freetarg, 0,0);
    273       1.8       mrg 
    274       1.8       mrg 		/*
    275      1.24       chs 		 * scan if needed
    276       1.8       mrg 		 */
    277       1.8       mrg 
    278      1.24       chs 		if (uvmexp.free + uvmexp.paging < uvmexp.freetarg ||
    279  1.65.2.2      yamt 		    uvmpdpol_needsscan_p()) {
    280      1.24       chs 			uvmpd_scan();
    281       1.8       mrg 		}
    282       1.8       mrg 
    283       1.8       mrg 		/*
    284      1.24       chs 		 * if there's any free memory to be had,
    285      1.24       chs 		 * wake up any waiters.
    286       1.8       mrg 		 */
    287       1.8       mrg 
    288      1.24       chs 		if (uvmexp.free > uvmexp.reserve_kernel ||
    289      1.24       chs 		    uvmexp.paging == 0) {
    290      1.24       chs 			wakeup(&uvmexp.free);
    291       1.8       mrg 		}
    292       1.1       mrg 
    293       1.8       mrg 		/*
    294      1.24       chs 		 * scan done.  unlock page queues (the only lock we are holding)
    295       1.8       mrg 		 */
    296       1.8       mrg 
    297      1.24       chs 		uvm_unlock_pageq();
    298      1.38       chs 
    299      1.60     enami 		buf_drain(bufcnt << PAGE_SHIFT);
    300      1.60     enami 
    301      1.38       chs 		/*
    302      1.38       chs 		 * drain pool resources now that we're not holding any locks
    303      1.38       chs 		 */
    304      1.38       chs 
    305      1.38       chs 		pool_drain(0);
    306      1.57  jdolecek 
    307      1.57  jdolecek 		/*
    308      1.57  jdolecek 		 * free any cached u-areas we don't need
    309      1.57  jdolecek 		 */
    310  1.65.2.3      yamt 		uvm_uarea_drain(true);
    311      1.57  jdolecek 
    312      1.24       chs 	}
    313      1.24       chs 	/*NOTREACHED*/
    314      1.24       chs }
    315      1.24       chs 
    316       1.8       mrg 
    317      1.24       chs /*
    318  1.65.2.2      yamt  * uvm_aiodone_worker: a workqueue callback for the aiodone daemon.
    319      1.24       chs  */
    320       1.8       mrg 
    321      1.24       chs void
    322  1.65.2.2      yamt uvm_aiodone_worker(struct work *wk, void *dummy)
    323      1.24       chs {
    324      1.24       chs 	int s, free;
    325  1.65.2.2      yamt 	struct buf *bp = (void *)wk;
    326       1.9        pk 
    327  1.65.2.2      yamt 	KASSERT(&bp->b_work == wk);
    328       1.8       mrg 
    329  1.65.2.2      yamt 	/*
    330  1.65.2.2      yamt 	 * process an i/o that's done.
    331  1.65.2.2      yamt 	 */
    332       1.8       mrg 
    333  1.65.2.2      yamt 	free = uvmexp.free;
    334  1.65.2.2      yamt 	(*bp->b_iodone)(bp);
    335  1.65.2.2      yamt 	if (free <= uvmexp.reserve_kernel) {
    336  1.65.2.2      yamt 		s = uvm_lock_fpageq();
    337  1.65.2.2      yamt 		wakeup(&uvm.pagedaemon);
    338  1.65.2.2      yamt 		uvm_unlock_fpageq(s);
    339  1.65.2.2      yamt 	} else {
    340  1.65.2.2      yamt 		simple_lock(&uvm.pagedaemon_lock);
    341  1.65.2.2      yamt 		wakeup(&uvmexp.free);
    342  1.65.2.2      yamt 		simple_unlock(&uvm.pagedaemon_lock);
    343       1.8       mrg 	}
    344       1.1       mrg }
    345       1.1       mrg 
    346       1.1       mrg /*
    347  1.65.2.1      yamt  * uvmpd_trylockowner: trylock the page's owner.
    348  1.65.2.1      yamt  *
    349  1.65.2.1      yamt  * => called with pageq locked.
    350  1.65.2.1      yamt  * => resolve orphaned O->A loaned page.
    351  1.65.2.1      yamt  * => return the locked simplelock on success.  otherwise, return NULL.
    352  1.65.2.1      yamt  */
    353  1.65.2.1      yamt 
    354  1.65.2.2      yamt struct simplelock *
    355  1.65.2.1      yamt uvmpd_trylockowner(struct vm_page *pg)
    356  1.65.2.1      yamt {
    357  1.65.2.1      yamt 	struct uvm_object *uobj = pg->uobject;
    358  1.65.2.1      yamt 	struct simplelock *slock;
    359  1.65.2.1      yamt 
    360  1.65.2.1      yamt 	UVM_LOCK_ASSERT_PAGEQ();
    361  1.65.2.1      yamt 	if (uobj != NULL) {
    362  1.65.2.1      yamt 		slock = &uobj->vmobjlock;
    363  1.65.2.1      yamt 	} else {
    364  1.65.2.1      yamt 		struct vm_anon *anon = pg->uanon;
    365  1.65.2.1      yamt 
    366  1.65.2.1      yamt 		KASSERT(anon != NULL);
    367  1.65.2.1      yamt 		slock = &anon->an_lock;
    368  1.65.2.1      yamt 	}
    369  1.65.2.1      yamt 
    370  1.65.2.1      yamt 	if (!simple_lock_try(slock)) {
    371  1.65.2.1      yamt 		return NULL;
    372  1.65.2.1      yamt 	}
    373  1.65.2.1      yamt 
    374  1.65.2.1      yamt 	if (uobj == NULL) {
    375  1.65.2.1      yamt 
    376  1.65.2.1      yamt 		/*
    377  1.65.2.1      yamt 		 * set PQ_ANON if it isn't set already.
    378  1.65.2.1      yamt 		 */
    379  1.65.2.1      yamt 
    380  1.65.2.1      yamt 		if ((pg->pqflags & PQ_ANON) == 0) {
    381  1.65.2.1      yamt 			KASSERT(pg->loan_count > 0);
    382  1.65.2.1      yamt 			pg->loan_count--;
    383  1.65.2.1      yamt 			pg->pqflags |= PQ_ANON;
    384  1.65.2.1      yamt 			/* anon now owns it */
    385  1.65.2.1      yamt 		}
    386  1.65.2.1      yamt 	}
    387  1.65.2.1      yamt 
    388  1.65.2.1      yamt 	return slock;
    389  1.65.2.1      yamt }
    390  1.65.2.1      yamt 
    391  1.65.2.1      yamt #if defined(VMSWAP)
    392  1.65.2.1      yamt struct swapcluster {
    393  1.65.2.1      yamt 	int swc_slot;
    394  1.65.2.1      yamt 	int swc_nallocated;
    395  1.65.2.1      yamt 	int swc_nused;
    396  1.65.2.1      yamt 	struct vm_page *swc_pages[howmany(MAXPHYS, MIN_PAGE_SIZE)];
    397  1.65.2.1      yamt };
    398  1.65.2.1      yamt 
    399  1.65.2.1      yamt static void
    400  1.65.2.1      yamt swapcluster_init(struct swapcluster *swc)
    401  1.65.2.1      yamt {
    402  1.65.2.1      yamt 
    403  1.65.2.1      yamt 	swc->swc_slot = 0;
    404  1.65.2.1      yamt }
    405  1.65.2.1      yamt 
    406  1.65.2.1      yamt static int
    407  1.65.2.1      yamt swapcluster_allocslots(struct swapcluster *swc)
    408  1.65.2.1      yamt {
    409  1.65.2.1      yamt 	int slot;
    410  1.65.2.1      yamt 	int npages;
    411  1.65.2.1      yamt 
    412  1.65.2.1      yamt 	if (swc->swc_slot != 0) {
    413  1.65.2.1      yamt 		return 0;
    414  1.65.2.1      yamt 	}
    415  1.65.2.1      yamt 
    416  1.65.2.1      yamt 	/* Even with strange MAXPHYS, the shift
    417  1.65.2.1      yamt 	   implicitly rounds down to a page. */
    418  1.65.2.1      yamt 	npages = MAXPHYS >> PAGE_SHIFT;
    419  1.65.2.3      yamt 	slot = uvm_swap_alloc(&npages, true);
    420  1.65.2.1      yamt 	if (slot == 0) {
    421  1.65.2.1      yamt 		return ENOMEM;
    422  1.65.2.1      yamt 	}
    423  1.65.2.1      yamt 	swc->swc_slot = slot;
    424  1.65.2.1      yamt 	swc->swc_nallocated = npages;
    425  1.65.2.1      yamt 	swc->swc_nused = 0;
    426  1.65.2.1      yamt 
    427  1.65.2.1      yamt 	return 0;
    428  1.65.2.1      yamt }
    429  1.65.2.1      yamt 
    430  1.65.2.1      yamt static int
    431  1.65.2.1      yamt swapcluster_add(struct swapcluster *swc, struct vm_page *pg)
    432  1.65.2.1      yamt {
    433  1.65.2.1      yamt 	int slot;
    434  1.65.2.1      yamt 	struct uvm_object *uobj;
    435  1.65.2.1      yamt 
    436  1.65.2.1      yamt 	KASSERT(swc->swc_slot != 0);
    437  1.65.2.1      yamt 	KASSERT(swc->swc_nused < swc->swc_nallocated);
    438  1.65.2.1      yamt 	KASSERT((pg->pqflags & PQ_SWAPBACKED) != 0);
    439  1.65.2.1      yamt 
    440  1.65.2.1      yamt 	slot = swc->swc_slot + swc->swc_nused;
    441  1.65.2.1      yamt 	uobj = pg->uobject;
    442  1.65.2.1      yamt 	if (uobj == NULL) {
    443  1.65.2.1      yamt 		LOCK_ASSERT(simple_lock_held(&pg->uanon->an_lock));
    444  1.65.2.1      yamt 		pg->uanon->an_swslot = slot;
    445  1.65.2.1      yamt 	} else {
    446  1.65.2.1      yamt 		int result;
    447  1.65.2.1      yamt 
    448  1.65.2.1      yamt 		LOCK_ASSERT(simple_lock_held(&uobj->vmobjlock));
    449  1.65.2.1      yamt 		result = uao_set_swslot(uobj, pg->offset >> PAGE_SHIFT, slot);
    450  1.65.2.1      yamt 		if (result == -1) {
    451  1.65.2.1      yamt 			return ENOMEM;
    452  1.65.2.1      yamt 		}
    453  1.65.2.1      yamt 	}
    454  1.65.2.1      yamt 	swc->swc_pages[swc->swc_nused] = pg;
    455  1.65.2.1      yamt 	swc->swc_nused++;
    456  1.65.2.1      yamt 
    457  1.65.2.1      yamt 	return 0;
    458  1.65.2.1      yamt }
    459  1.65.2.1      yamt 
    460  1.65.2.1      yamt static void
    461  1.65.2.3      yamt swapcluster_flush(struct swapcluster *swc, bool now)
    462  1.65.2.1      yamt {
    463  1.65.2.1      yamt 	int slot;
    464  1.65.2.1      yamt 	int nused;
    465  1.65.2.1      yamt 	int nallocated;
    466  1.65.2.1      yamt 	int error;
    467  1.65.2.1      yamt 
    468  1.65.2.1      yamt 	if (swc->swc_slot == 0) {
    469  1.65.2.1      yamt 		return;
    470  1.65.2.1      yamt 	}
    471  1.65.2.1      yamt 	KASSERT(swc->swc_nused <= swc->swc_nallocated);
    472  1.65.2.1      yamt 
    473  1.65.2.1      yamt 	slot = swc->swc_slot;
    474  1.65.2.1      yamt 	nused = swc->swc_nused;
    475  1.65.2.1      yamt 	nallocated = swc->swc_nallocated;
    476  1.65.2.1      yamt 
    477  1.65.2.1      yamt 	/*
    478  1.65.2.1      yamt 	 * if this is the final pageout we could have a few
    479  1.65.2.1      yamt 	 * unused swap blocks.  if so, free them now.
    480  1.65.2.1      yamt 	 */
    481  1.65.2.1      yamt 
    482  1.65.2.1      yamt 	if (nused < nallocated) {
    483  1.65.2.1      yamt 		if (!now) {
    484  1.65.2.1      yamt 			return;
    485  1.65.2.1      yamt 		}
    486  1.65.2.1      yamt 		uvm_swap_free(slot + nused, nallocated - nused);
    487  1.65.2.1      yamt 	}
    488  1.65.2.1      yamt 
    489  1.65.2.1      yamt 	/*
    490  1.65.2.1      yamt 	 * now start the pageout.
    491  1.65.2.1      yamt 	 */
    492  1.65.2.1      yamt 
    493  1.65.2.1      yamt 	uvmexp.pdpageouts++;
    494  1.65.2.1      yamt 	error = uvm_swap_put(slot, swc->swc_pages, nused, 0);
    495  1.65.2.1      yamt 	KASSERT(error == 0);
    496  1.65.2.1      yamt 
    497  1.65.2.1      yamt 	/*
    498  1.65.2.1      yamt 	 * zero swslot to indicate that we are
    499  1.65.2.1      yamt 	 * no longer building a swap-backed cluster.
    500  1.65.2.1      yamt 	 */
    501  1.65.2.1      yamt 
    502  1.65.2.1      yamt 	swc->swc_slot = 0;
    503  1.65.2.1      yamt }
    504  1.65.2.2      yamt 
    505  1.65.2.2      yamt /*
    506  1.65.2.2      yamt  * uvmpd_dropswap: free any swap allocated to this page.
    507  1.65.2.2      yamt  *
    508  1.65.2.2      yamt  * => called with owner locked.
    509  1.65.2.3      yamt  * => return true if a page had an associated slot.
    510  1.65.2.2      yamt  */
    511  1.65.2.2      yamt 
    512  1.65.2.3      yamt static bool
    513  1.65.2.2      yamt uvmpd_dropswap(struct vm_page *pg)
    514  1.65.2.2      yamt {
    515  1.65.2.3      yamt 	bool result = false;
    516  1.65.2.2      yamt 	struct vm_anon *anon = pg->uanon;
    517  1.65.2.2      yamt 
    518  1.65.2.2      yamt 	if ((pg->pqflags & PQ_ANON) && anon->an_swslot) {
    519  1.65.2.2      yamt 		uvm_swap_free(anon->an_swslot, 1);
    520  1.65.2.2      yamt 		anon->an_swslot = 0;
    521  1.65.2.2      yamt 		pg->flags &= ~PG_CLEAN;
    522  1.65.2.3      yamt 		result = true;
    523  1.65.2.2      yamt 	} else if (pg->pqflags & PQ_AOBJ) {
    524  1.65.2.2      yamt 		int slot = uao_set_swslot(pg->uobject,
    525  1.65.2.2      yamt 		    pg->offset >> PAGE_SHIFT, 0);
    526  1.65.2.2      yamt 		if (slot) {
    527  1.65.2.2      yamt 			uvm_swap_free(slot, 1);
    528  1.65.2.2      yamt 			pg->flags &= ~PG_CLEAN;
    529  1.65.2.3      yamt 			result = true;
    530  1.65.2.2      yamt 		}
    531  1.65.2.2      yamt 	}
    532  1.65.2.2      yamt 
    533  1.65.2.2      yamt 	return result;
    534  1.65.2.2      yamt }
    535  1.65.2.2      yamt 
    536  1.65.2.2      yamt /*
    537  1.65.2.2      yamt  * uvmpd_trydropswap: try to free any swap allocated to this page.
    538  1.65.2.2      yamt  *
    539  1.65.2.3      yamt  * => return true if a slot is successfully freed.
    540  1.65.2.2      yamt  */
    541  1.65.2.2      yamt 
    542  1.65.2.3      yamt bool
    543  1.65.2.2      yamt uvmpd_trydropswap(struct vm_page *pg)
    544  1.65.2.2      yamt {
    545  1.65.2.2      yamt 	struct simplelock *slock;
    546  1.65.2.3      yamt 	bool result;
    547  1.65.2.2      yamt 
    548  1.65.2.2      yamt 	if ((pg->flags & PG_BUSY) != 0) {
    549  1.65.2.3      yamt 		return false;
    550  1.65.2.2      yamt 	}
    551  1.65.2.2      yamt 
    552  1.65.2.2      yamt 	/*
    553  1.65.2.2      yamt 	 * lock the page's owner.
    554  1.65.2.2      yamt 	 */
    555  1.65.2.2      yamt 
    556  1.65.2.2      yamt 	slock = uvmpd_trylockowner(pg);
    557  1.65.2.2      yamt 	if (slock == NULL) {
    558  1.65.2.3      yamt 		return false;
    559  1.65.2.2      yamt 	}
    560  1.65.2.2      yamt 
    561  1.65.2.2      yamt 	/*
    562  1.65.2.2      yamt 	 * skip this page if it's busy.
    563  1.65.2.2      yamt 	 */
    564  1.65.2.2      yamt 
    565  1.65.2.2      yamt 	if ((pg->flags & PG_BUSY) != 0) {
    566  1.65.2.2      yamt 		simple_unlock(slock);
    567  1.65.2.3      yamt 		return false;
    568  1.65.2.2      yamt 	}
    569  1.65.2.2      yamt 
    570  1.65.2.2      yamt 	result = uvmpd_dropswap(pg);
    571  1.65.2.2      yamt 
    572  1.65.2.2      yamt 	simple_unlock(slock);
    573  1.65.2.2      yamt 
    574  1.65.2.2      yamt 	return result;
    575  1.65.2.2      yamt }
    576  1.65.2.2      yamt 
    577  1.65.2.1      yamt #endif /* defined(VMSWAP) */
    578  1.65.2.1      yamt 
    579  1.65.2.1      yamt /*
    580  1.65.2.2      yamt  * uvmpd_scan_queue: scan an replace candidate list for pages
    581  1.65.2.2      yamt  * to clean or free.
    582       1.1       mrg  *
    583       1.1       mrg  * => called with page queues locked
    584       1.1       mrg  * => we work on meeting our free target by converting inactive pages
    585       1.1       mrg  *    into free pages.
    586       1.1       mrg  * => we handle the building of swap-backed clusters
    587       1.1       mrg  */
    588       1.1       mrg 
    589      1.65   thorpej static void
    590  1.65.2.2      yamt uvmpd_scan_queue(void)
    591       1.8       mrg {
    592  1.65.2.2      yamt 	struct vm_page *p;
    593       1.8       mrg 	struct uvm_object *uobj;
    594      1.37       chs 	struct vm_anon *anon;
    595  1.65.2.1      yamt #if defined(VMSWAP)
    596  1.65.2.1      yamt 	struct swapcluster swc;
    597  1.65.2.1      yamt #endif /* defined(VMSWAP) */
    598  1.65.2.2      yamt 	int dirtyreacts;
    599      1.37       chs 	struct simplelock *slock;
    600  1.65.2.2      yamt 	UVMHIST_FUNC("uvmpd_scan_queue"); UVMHIST_CALLED(pdhist);
    601       1.1       mrg 
    602       1.8       mrg 	/*
    603       1.8       mrg 	 * swslot is non-zero if we are building a swap cluster.  we want
    604      1.24       chs 	 * to stay in the loop while we have a page to scan or we have
    605       1.8       mrg 	 * a swap-cluster to build.
    606       1.8       mrg 	 */
    607      1.24       chs 
    608  1.65.2.1      yamt #if defined(VMSWAP)
    609  1.65.2.1      yamt 	swapcluster_init(&swc);
    610  1.65.2.1      yamt #endif /* defined(VMSWAP) */
    611      1.43       chs 
    612  1.65.2.2      yamt 	dirtyreacts = 0;
    613  1.65.2.2      yamt 	uvmpdpol_scaninit();
    614  1.65.2.1      yamt 
    615  1.65.2.2      yamt 	while (/* CONSTCOND */ 1) {
    616      1.24       chs 
    617  1.65.2.1      yamt 		/*
    618  1.65.2.1      yamt 		 * see if we've met the free target.
    619  1.65.2.1      yamt 		 */
    620      1.30       chs 
    621  1.65.2.1      yamt 		if (uvmexp.free + uvmexp.paging >= uvmexp.freetarg << 2 ||
    622  1.65.2.1      yamt 		    dirtyreacts == UVMPD_NUMDIRTYREACTS) {
    623  1.65.2.1      yamt 			UVMHIST_LOG(pdhist,"  met free target: "
    624  1.65.2.1      yamt 				    "exit loop", 0, 0, 0, 0);
    625  1.65.2.1      yamt 			break;
    626       1.8       mrg 		}
    627       1.8       mrg 
    628  1.65.2.2      yamt 		p = uvmpdpol_selectvictim();
    629  1.65.2.2      yamt 		if (p == NULL) {
    630  1.65.2.2      yamt 			break;
    631  1.65.2.2      yamt 		}
    632  1.65.2.2      yamt 		KASSERT(uvmpdpol_pageisqueued_p(p));
    633  1.65.2.2      yamt 		KASSERT(p->wire_count == 0);
    634      1.30       chs 
    635  1.65.2.1      yamt 		/*
    636  1.65.2.2      yamt 		 * we are below target and have a new page to consider.
    637  1.65.2.1      yamt 		 */
    638      1.30       chs 
    639  1.65.2.1      yamt 		anon = p->uanon;
    640  1.65.2.1      yamt 		uobj = p->uobject;
    641       1.8       mrg 
    642  1.65.2.1      yamt 		/*
    643  1.65.2.1      yamt 		 * first we attempt to lock the object that this page
    644  1.65.2.1      yamt 		 * belongs to.  if our attempt fails we skip on to
    645  1.65.2.1      yamt 		 * the next page (no harm done).  it is important to
    646  1.65.2.1      yamt 		 * "try" locking the object as we are locking in the
    647  1.65.2.1      yamt 		 * wrong order (pageq -> object) and we don't want to
    648  1.65.2.1      yamt 		 * deadlock.
    649  1.65.2.1      yamt 		 *
    650  1.65.2.1      yamt 		 * the only time we expect to see an ownerless page
    651  1.65.2.1      yamt 		 * (i.e. a page with no uobject and !PQ_ANON) is if an
    652  1.65.2.1      yamt 		 * anon has loaned a page from a uvm_object and the
    653  1.65.2.1      yamt 		 * uvm_object has dropped the ownership.  in that
    654  1.65.2.1      yamt 		 * case, the anon can "take over" the loaned page
    655  1.65.2.1      yamt 		 * and make it its own.
    656  1.65.2.1      yamt 		 */
    657      1.37       chs 
    658  1.65.2.1      yamt 		slock = uvmpd_trylockowner(p);
    659  1.65.2.1      yamt 		if (slock == NULL) {
    660  1.65.2.1      yamt 			continue;
    661  1.65.2.1      yamt 		}
    662  1.65.2.1      yamt 		if (p->flags & PG_BUSY) {
    663  1.65.2.1      yamt 			simple_unlock(slock);
    664  1.65.2.1      yamt 			uvmexp.pdbusy++;
    665  1.65.2.1      yamt 			continue;
    666  1.65.2.1      yamt 		}
    667      1.37       chs 
    668  1.65.2.1      yamt 		/* does the page belong to an object? */
    669  1.65.2.1      yamt 		if (uobj != NULL) {
    670  1.65.2.1      yamt 			uvmexp.pdobscan++;
    671  1.65.2.1      yamt 		} else {
    672  1.65.2.1      yamt #if defined(VMSWAP)
    673  1.65.2.1      yamt 			KASSERT(anon != NULL);
    674  1.65.2.1      yamt 			uvmexp.pdanscan++;
    675  1.65.2.1      yamt #else /* defined(VMSWAP) */
    676  1.65.2.1      yamt 			panic("%s: anon", __func__);
    677  1.65.2.1      yamt #endif /* defined(VMSWAP) */
    678  1.65.2.1      yamt 		}
    679       1.8       mrg 
    680      1.41       chs 
    681  1.65.2.1      yamt 		/*
    682  1.65.2.1      yamt 		 * we now have the object and the page queues locked.
    683  1.65.2.1      yamt 		 * if the page is not swap-backed, call the object's
    684  1.65.2.1      yamt 		 * pager to flush and free the page.
    685  1.65.2.1      yamt 		 */
    686       1.8       mrg 
    687  1.65.2.1      yamt #if defined(READAHEAD_STATS)
    688  1.65.2.2      yamt 		if ((p->pqflags & PQ_READAHEAD) != 0) {
    689  1.65.2.2      yamt 			p->pqflags &= ~PQ_READAHEAD;
    690  1.65.2.1      yamt 			uvm_ra_miss.ev_count++;
    691  1.65.2.1      yamt 		}
    692  1.65.2.1      yamt #endif /* defined(READAHEAD_STATS) */
    693      1.24       chs 
    694  1.65.2.1      yamt 		if ((p->pqflags & PQ_SWAPBACKED) == 0) {
    695  1.65.2.2      yamt 			KASSERT(uobj != NULL);
    696  1.65.2.1      yamt 			uvm_unlock_pageq();
    697  1.65.2.1      yamt 			(void) (uobj->pgops->pgo_put)(uobj, p->offset,
    698  1.65.2.1      yamt 			    p->offset + PAGE_SIZE, PGO_CLEANIT|PGO_FREE);
    699  1.65.2.1      yamt 			uvm_lock_pageq();
    700  1.65.2.1      yamt 			continue;
    701  1.65.2.1      yamt 		}
    702       1.8       mrg 
    703  1.65.2.1      yamt 		/*
    704  1.65.2.1      yamt 		 * the page is swap-backed.  remove all the permissions
    705  1.65.2.1      yamt 		 * from the page so we can sync the modified info
    706  1.65.2.1      yamt 		 * without any race conditions.  if the page is clean
    707  1.65.2.1      yamt 		 * we can free it now and continue.
    708  1.65.2.1      yamt 		 */
    709      1.37       chs 
    710  1.65.2.1      yamt 		pmap_page_protect(p, VM_PROT_NONE);
    711  1.65.2.1      yamt 		if ((p->flags & PG_CLEAN) && pmap_clear_modify(p)) {
    712  1.65.2.1      yamt 			p->flags &= ~(PG_CLEAN);
    713  1.65.2.1      yamt 		}
    714  1.65.2.1      yamt 		if (p->flags & PG_CLEAN) {
    715  1.65.2.1      yamt 			int slot;
    716  1.65.2.1      yamt 			int pageidx;
    717  1.65.2.1      yamt 
    718  1.65.2.1      yamt 			pageidx = p->offset >> PAGE_SHIFT;
    719  1.65.2.1      yamt 			uvm_pagefree(p);
    720  1.65.2.1      yamt 			uvmexp.pdfreed++;
    721      1.37       chs 
    722      1.37       chs 			/*
    723  1.65.2.1      yamt 			 * for anons, we need to remove the page
    724  1.65.2.1      yamt 			 * from the anon ourselves.  for aobjs,
    725  1.65.2.1      yamt 			 * pagefree did that for us.
    726      1.14       chs 			 */
    727      1.24       chs 
    728  1.65.2.1      yamt 			if (anon) {
    729  1.65.2.1      yamt 				KASSERT(anon->an_swslot != 0);
    730  1.65.2.1      yamt 				anon->an_page = NULL;
    731  1.65.2.1      yamt 				slot = anon->an_swslot;
    732  1.65.2.1      yamt 			} else {
    733  1.65.2.1      yamt 				slot = uao_find_swslot(uobj, pageidx);
    734      1.14       chs 			}
    735  1.65.2.1      yamt 			simple_unlock(slock);
    736      1.14       chs 
    737  1.65.2.1      yamt 			if (slot > 0) {
    738  1.65.2.1      yamt 				/* this page is now only in swap. */
    739  1.65.2.1      yamt 				simple_lock(&uvm.swap_data_lock);
    740  1.65.2.1      yamt 				KASSERT(uvmexp.swpgonly < uvmexp.swpginuse);
    741  1.65.2.1      yamt 				uvmexp.swpgonly++;
    742  1.65.2.1      yamt 				simple_unlock(&uvm.swap_data_lock);
    743      1.14       chs 			}
    744  1.65.2.1      yamt 			continue;
    745  1.65.2.1      yamt 		}
    746      1.14       chs 
    747  1.65.2.2      yamt #if defined(VMSWAP)
    748  1.65.2.1      yamt 		/*
    749  1.65.2.1      yamt 		 * this page is dirty, skip it if we'll have met our
    750  1.65.2.1      yamt 		 * free target when all the current pageouts complete.
    751  1.65.2.1      yamt 		 */
    752      1.37       chs 
    753  1.65.2.1      yamt 		if (uvmexp.free + uvmexp.paging > uvmexp.freetarg << 2) {
    754  1.65.2.1      yamt 			simple_unlock(slock);
    755  1.65.2.1      yamt 			continue;
    756  1.65.2.1      yamt 		}
    757       1.8       mrg 
    758  1.65.2.1      yamt 		/*
    759  1.65.2.1      yamt 		 * free any swap space allocated to the page since
    760  1.65.2.1      yamt 		 * we'll have to write it again with its new data.
    761  1.65.2.1      yamt 		 */
    762      1.24       chs 
    763  1.65.2.2      yamt 		uvmpd_dropswap(p);
    764       1.8       mrg 
    765  1.65.2.1      yamt 		/*
    766  1.65.2.1      yamt 		 * if all pages in swap are only in swap,
    767  1.65.2.1      yamt 		 * the swap space is full and we can't page out
    768  1.65.2.1      yamt 		 * any more swap-backed pages.  reactivate this page
    769  1.65.2.1      yamt 		 * so that we eventually cycle all pages through
    770  1.65.2.1      yamt 		 * the inactive queue.
    771  1.65.2.1      yamt 		 */
    772      1.24       chs 
    773  1.65.2.1      yamt 		if (uvm_swapisfull()) {
    774  1.65.2.1      yamt 			dirtyreacts++;
    775  1.65.2.1      yamt 			uvm_pageactivate(p);
    776  1.65.2.1      yamt 			simple_unlock(slock);
    777  1.65.2.1      yamt 			continue;
    778       1.8       mrg 		}
    779       1.8       mrg 
    780       1.8       mrg 		/*
    781  1.65.2.1      yamt 		 * start new swap pageout cluster (if necessary).
    782       1.8       mrg 		 */
    783      1.24       chs 
    784  1.65.2.1      yamt 		if (swapcluster_allocslots(&swc)) {
    785  1.65.2.1      yamt 			simple_unlock(slock);
    786  1.65.2.2      yamt 			dirtyreacts++; /* XXX */
    787  1.65.2.1      yamt 			continue;
    788       1.8       mrg 		}
    789       1.8       mrg 
    790       1.8       mrg 		/*
    791  1.65.2.1      yamt 		 * at this point, we're definitely going reuse this
    792  1.65.2.1      yamt 		 * page.  mark the page busy and delayed-free.
    793  1.65.2.1      yamt 		 * we should remove the page from the page queues
    794  1.65.2.1      yamt 		 * so we don't ever look at it again.
    795  1.65.2.1      yamt 		 * adjust counters and such.
    796       1.8       mrg 		 */
    797       1.8       mrg 
    798  1.65.2.1      yamt 		p->flags |= PG_BUSY;
    799  1.65.2.2      yamt 		UVM_PAGE_OWN(p, "scan_queue");
    800  1.65.2.1      yamt 
    801  1.65.2.1      yamt 		p->flags |= PG_PAGEOUT;
    802  1.65.2.1      yamt 		uvmexp.paging++;
    803  1.65.2.1      yamt 		uvm_pagedequeue(p);
    804  1.65.2.1      yamt 
    805  1.65.2.1      yamt 		uvmexp.pgswapout++;
    806      1.37       chs 		uvm_unlock_pageq();
    807       1.8       mrg 
    808       1.8       mrg 		/*
    809  1.65.2.1      yamt 		 * add the new page to the cluster.
    810       1.8       mrg 		 */
    811       1.8       mrg 
    812  1.65.2.1      yamt 		if (swapcluster_add(&swc, p)) {
    813  1.65.2.1      yamt 			p->flags &= ~(PG_BUSY|PG_PAGEOUT);
    814  1.65.2.1      yamt 			UVM_PAGE_OWN(p, NULL);
    815  1.65.2.1      yamt 			uvm_lock_pageq();
    816  1.65.2.1      yamt 			uvmexp.paging--;
    817  1.65.2.2      yamt 			dirtyreacts++;
    818  1.65.2.1      yamt 			uvm_pageactivate(p);
    819  1.65.2.1      yamt 			simple_unlock(slock);
    820  1.65.2.1      yamt 			continue;
    821  1.65.2.1      yamt 		}
    822  1.65.2.1      yamt 		simple_unlock(slock);
    823  1.65.2.1      yamt 
    824  1.65.2.3      yamt 		swapcluster_flush(&swc, false);
    825  1.65.2.1      yamt 		uvm_lock_pageq();
    826  1.65.2.1      yamt 
    827       1.8       mrg 		/*
    828      1.31       chs 		 * the pageout is in progress.  bump counters and set up
    829      1.31       chs 		 * for the next loop.
    830       1.8       mrg 		 */
    831       1.8       mrg 
    832      1.31       chs 		uvmexp.pdpending++;
    833  1.65.2.2      yamt 
    834  1.65.2.2      yamt #else /* defined(VMSWAP) */
    835  1.65.2.2      yamt 		uvm_pageactivate(p);
    836  1.65.2.2      yamt 		simple_unlock(slock);
    837  1.65.2.2      yamt #endif /* defined(VMSWAP) */
    838      1.24       chs 	}
    839  1.65.2.1      yamt 
    840  1.65.2.1      yamt #if defined(VMSWAP)
    841  1.65.2.1      yamt 	uvm_unlock_pageq();
    842  1.65.2.3      yamt 	swapcluster_flush(&swc, true);
    843  1.65.2.1      yamt 	uvm_lock_pageq();
    844  1.65.2.1      yamt #endif /* defined(VMSWAP) */
    845       1.1       mrg }
    846       1.1       mrg 
    847       1.1       mrg /*
    848       1.1       mrg  * uvmpd_scan: scan the page queues and attempt to meet our targets.
    849       1.1       mrg  *
    850       1.1       mrg  * => called with pageq's locked
    851       1.1       mrg  */
    852       1.1       mrg 
    853      1.65   thorpej static void
    854      1.37       chs uvmpd_scan(void)
    855       1.1       mrg {
    856  1.65.2.2      yamt 	int swap_shortage, pages_freed;
    857       1.8       mrg 	UVMHIST_FUNC("uvmpd_scan"); UVMHIST_CALLED(pdhist);
    858       1.1       mrg 
    859      1.37       chs 	uvmexp.pdrevs++;
    860       1.1       mrg 
    861       1.1       mrg #ifndef __SWAP_BROKEN
    862      1.39       chs 
    863       1.8       mrg 	/*
    864       1.8       mrg 	 * swap out some processes if we are below our free target.
    865       1.8       mrg 	 * we need to unlock the page queues for this.
    866       1.8       mrg 	 */
    867      1.39       chs 
    868      1.39       chs 	if (uvmexp.free < uvmexp.freetarg && uvmexp.nswapdev != 0) {
    869       1.8       mrg 		uvmexp.pdswout++;
    870      1.37       chs 		UVMHIST_LOG(pdhist,"  free %d < target %d: swapout",
    871      1.37       chs 		    uvmexp.free, uvmexp.freetarg, 0, 0);
    872       1.8       mrg 		uvm_unlock_pageq();
    873       1.8       mrg 		uvm_swapout_threads();
    874       1.8       mrg 		uvm_lock_pageq();
    875       1.1       mrg 
    876       1.8       mrg 	}
    877       1.1       mrg #endif
    878       1.1       mrg 
    879       1.8       mrg 	/*
    880       1.8       mrg 	 * now we want to work on meeting our targets.   first we work on our
    881       1.8       mrg 	 * free target by converting inactive pages into free pages.  then
    882       1.8       mrg 	 * we work on meeting our inactive target by converting active pages
    883       1.8       mrg 	 * to inactive ones.
    884       1.8       mrg 	 */
    885       1.8       mrg 
    886       1.8       mrg 	UVMHIST_LOG(pdhist, "  starting 'free' loop",0,0,0,0);
    887       1.8       mrg 
    888      1.14       chs 	pages_freed = uvmexp.pdfreed;
    889  1.65.2.2      yamt 	uvmpd_scan_queue();
    890      1.14       chs 	pages_freed = uvmexp.pdfreed - pages_freed;
    891       1.8       mrg 
    892       1.8       mrg 	/*
    893      1.14       chs 	 * detect if we're not going to be able to page anything out
    894      1.14       chs 	 * until we free some swap resources from active pages.
    895      1.14       chs 	 */
    896      1.24       chs 
    897      1.14       chs 	swap_shortage = 0;
    898      1.14       chs 	if (uvmexp.free < uvmexp.freetarg &&
    899      1.52        pk 	    uvmexp.swpginuse >= uvmexp.swpgavail &&
    900      1.52        pk 	    !uvm_swapisfull() &&
    901      1.14       chs 	    pages_freed == 0) {
    902      1.14       chs 		swap_shortage = uvmexp.freetarg - uvmexp.free;
    903      1.14       chs 	}
    904      1.24       chs 
    905  1.65.2.2      yamt 	uvmpdpol_balancequeue(swap_shortage);
    906       1.1       mrg }
    907      1.62      yamt 
    908      1.62      yamt /*
    909      1.62      yamt  * uvm_reclaimable: decide whether to wait for pagedaemon.
    910      1.62      yamt  *
    911  1.65.2.3      yamt  * => return true if it seems to be worth to do uvm_wait.
    912      1.62      yamt  *
    913      1.62      yamt  * XXX should be tunable.
    914      1.62      yamt  * XXX should consider pools, etc?
    915      1.62      yamt  */
    916      1.62      yamt 
    917  1.65.2.3      yamt bool
    918      1.62      yamt uvm_reclaimable(void)
    919      1.62      yamt {
    920      1.62      yamt 	int filepages;
    921  1.65.2.2      yamt 	int active, inactive;
    922      1.62      yamt 
    923      1.62      yamt 	/*
    924      1.62      yamt 	 * if swap is not full, no problem.
    925      1.62      yamt 	 */
    926      1.62      yamt 
    927      1.62      yamt 	if (!uvm_swapisfull()) {
    928  1.65.2.3      yamt 		return true;
    929      1.62      yamt 	}
    930      1.62      yamt 
    931      1.62      yamt 	/*
    932      1.62      yamt 	 * file-backed pages can be reclaimed even when swap is full.
    933      1.62      yamt 	 * if we have more than 1/16 of pageable memory or 5MB, try to reclaim.
    934      1.62      yamt 	 *
    935      1.62      yamt 	 * XXX assume the worst case, ie. all wired pages are file-backed.
    936      1.63      yamt 	 *
    937      1.63      yamt 	 * XXX should consider about other reclaimable memory.
    938      1.63      yamt 	 * XXX ie. pools, traditional buffer cache.
    939      1.62      yamt 	 */
    940      1.62      yamt 
    941      1.62      yamt 	filepages = uvmexp.filepages + uvmexp.execpages - uvmexp.wired;
    942  1.65.2.2      yamt 	uvm_estimatepageable(&active, &inactive);
    943  1.65.2.2      yamt 	if (filepages >= MIN((active + inactive) >> 4,
    944      1.62      yamt 	    5 * 1024 * 1024 >> PAGE_SHIFT)) {
    945  1.65.2.3      yamt 		return true;
    946      1.62      yamt 	}
    947      1.62      yamt 
    948      1.62      yamt 	/*
    949      1.62      yamt 	 * kill the process, fail allocation, etc..
    950      1.62      yamt 	 */
    951      1.62      yamt 
    952  1.65.2.3      yamt 	return false;
    953      1.62      yamt }
    954  1.65.2.2      yamt 
    955  1.65.2.2      yamt void
    956  1.65.2.2      yamt uvm_estimatepageable(int *active, int *inactive)
    957  1.65.2.2      yamt {
    958  1.65.2.2      yamt 
    959  1.65.2.2      yamt 	uvmpdpol_estimatepageable(active, inactive);
    960  1.65.2.2      yamt }
    961