Home | History | Annotate | Line # | Download | only in uvm
uvm_pager.c revision 1.14
      1  1.14      chs /*	$NetBSD: uvm_pager.c,v 1.14 1999/01/22 08:00:35 chs Exp $	*/
      2   1.1      mrg 
      3   1.1      mrg /*
      4   1.1      mrg  * XXXCDC: "ROUGH DRAFT" QUALITY UVM PRE-RELEASE FILE!
      5   1.1      mrg  *	   >>>USE AT YOUR OWN RISK, WORK IS NOT FINISHED<<<
      6   1.1      mrg  */
      7   1.1      mrg /*
      8   1.1      mrg  *
      9   1.1      mrg  * Copyright (c) 1997 Charles D. Cranor and Washington University.
     10   1.1      mrg  * All rights reserved.
     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 and
     23   1.1      mrg  *      Washington University.
     24   1.1      mrg  * 4. The name of the author may not be used to endorse or promote products
     25   1.1      mrg  *    derived from this software without specific prior written permission.
     26   1.1      mrg  *
     27   1.1      mrg  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     28   1.1      mrg  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     29   1.1      mrg  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     30   1.1      mrg  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     31   1.1      mrg  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
     32   1.1      mrg  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
     33   1.1      mrg  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
     34   1.1      mrg  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     35   1.1      mrg  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     36   1.1      mrg  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     37   1.3      mrg  *
     38   1.3      mrg  * from: Id: uvm_pager.c,v 1.1.2.23 1998/02/02 20:38:06 chuck Exp
     39   1.1      mrg  */
     40   1.1      mrg 
     41   1.5      mrg #include "opt_uvmhist.h"
     42   1.5      mrg #include "opt_pmap_new.h"
     43   1.5      mrg 
     44   1.1      mrg /*
     45   1.1      mrg  * uvm_pager.c: generic functions used to assist the pagers.
     46   1.1      mrg  */
     47   1.1      mrg 
     48   1.1      mrg #include <sys/param.h>
     49   1.1      mrg #include <sys/systm.h>
     50   1.1      mrg #include <sys/proc.h>
     51   1.1      mrg #include <sys/malloc.h>
     52   1.1      mrg 
     53   1.1      mrg #include <vm/vm.h>
     54   1.1      mrg #include <vm/vm_page.h>
     55   1.1      mrg #include <vm/vm_kern.h>
     56   1.1      mrg 
     57   1.1      mrg #define UVM_PAGER
     58   1.1      mrg #include <uvm/uvm.h>
     59   1.1      mrg 
     60   1.1      mrg /*
     61   1.1      mrg  * list of uvm pagers in the system
     62   1.1      mrg  */
     63   1.1      mrg 
     64  1.10  thorpej extern struct uvm_pagerops aobj_pager;
     65   1.1      mrg extern struct uvm_pagerops uvm_deviceops;
     66   1.1      mrg extern struct uvm_pagerops uvm_vnodeops;
     67   1.1      mrg 
     68   1.1      mrg struct uvm_pagerops *uvmpagerops[] = {
     69  1.10  thorpej 	&aobj_pager,
     70   1.6      mrg 	&uvm_deviceops,
     71   1.6      mrg 	&uvm_vnodeops,
     72   1.1      mrg };
     73   1.1      mrg 
     74   1.1      mrg /*
     75   1.1      mrg  * the pager map: provides KVA for I/O
     76   1.1      mrg  */
     77   1.1      mrg 
     78   1.1      mrg #define PAGER_MAP_SIZE       (4 * 1024 * 1024)
     79   1.1      mrg vm_map_t pager_map;		/* XXX */
     80   1.1      mrg simple_lock_data_t pager_map_wanted_lock;
     81   1.1      mrg boolean_t pager_map_wanted;	/* locked by pager map */
     82   1.1      mrg 
     83   1.1      mrg 
     84   1.1      mrg /*
     85   1.1      mrg  * uvm_pager_init: init pagers (at boot time)
     86   1.1      mrg  */
     87   1.1      mrg 
     88   1.6      mrg void
     89   1.6      mrg uvm_pager_init()
     90   1.6      mrg {
     91   1.6      mrg 	int lcv;
     92   1.1      mrg 
     93   1.6      mrg 	/*
     94   1.6      mrg 	 * init pager map
     95   1.6      mrg 	 */
     96   1.6      mrg 
     97   1.6      mrg 	 pager_map = uvm_km_suballoc(kernel_map, &uvm.pager_sva, &uvm.pager_eva,
     98   1.6      mrg 	 			PAGER_MAP_SIZE, FALSE, FALSE, NULL);
     99   1.6      mrg 	 simple_lock_init(&pager_map_wanted_lock);
    100   1.6      mrg 	 pager_map_wanted = FALSE;
    101   1.6      mrg 
    102   1.6      mrg 	/*
    103   1.6      mrg 	 * init ASYNC I/O queue
    104   1.6      mrg 	 */
    105   1.6      mrg 
    106   1.6      mrg 	TAILQ_INIT(&uvm.aio_done);
    107   1.1      mrg 
    108   1.6      mrg 	/*
    109   1.6      mrg 	 * call pager init functions
    110   1.6      mrg 	 */
    111   1.6      mrg 	for (lcv = 0 ; lcv < sizeof(uvmpagerops)/sizeof(struct uvm_pagerops *);
    112   1.6      mrg 	    lcv++) {
    113   1.6      mrg 		if (uvmpagerops[lcv]->pgo_init)
    114   1.6      mrg 			uvmpagerops[lcv]->pgo_init();
    115   1.6      mrg 	}
    116   1.1      mrg }
    117   1.1      mrg 
    118   1.1      mrg /*
    119   1.1      mrg  * uvm_pagermapin: map pages into KVA (pager_map) for I/O that needs mappings
    120   1.1      mrg  *
    121   1.1      mrg  * we basically just map in a blank map entry to reserve the space in the
    122   1.1      mrg  * map and then use pmap_enter() to put the mappings in by hand.
    123   1.1      mrg  */
    124   1.1      mrg 
    125   1.9      eeh vaddr_t
    126   1.6      mrg uvm_pagermapin(pps, npages, aiop, waitf)
    127   1.6      mrg 	struct vm_page **pps;
    128   1.6      mrg 	int npages;
    129   1.6      mrg 	struct uvm_aiodesc **aiop;	/* OUT */
    130   1.6      mrg 	int waitf;
    131   1.1      mrg {
    132   1.9      eeh 	vsize_t size;
    133   1.9      eeh 	vaddr_t kva;
    134   1.6      mrg 	struct uvm_aiodesc *aio;
    135   1.1      mrg #if !defined(PMAP_NEW)
    136   1.9      eeh 	vaddr_t cva;
    137   1.6      mrg 	struct vm_page *pp;
    138   1.1      mrg #endif
    139   1.6      mrg 	UVMHIST_FUNC("uvm_pagermapin"); UVMHIST_CALLED(maphist);
    140   1.1      mrg 
    141   1.6      mrg 	UVMHIST_LOG(maphist,"(pps=0x%x, npages=%d, aiop=0x%x, waitf=%d)",
    142   1.1      mrg 	      pps, npages, aiop, waitf);
    143   1.1      mrg 
    144   1.1      mrg ReStart:
    145   1.6      mrg 	if (aiop) {
    146   1.6      mrg 		MALLOC(aio, struct uvm_aiodesc *, sizeof(*aio), M_TEMP, waitf);
    147   1.6      mrg 		if (aio == NULL)
    148   1.6      mrg 			return(0);
    149   1.6      mrg 		*aiop = aio;
    150   1.6      mrg 	} else {
    151   1.6      mrg 		aio = NULL;
    152   1.6      mrg 	}
    153   1.1      mrg 
    154  1.12      chs 	size = npages << PAGE_SHIFT;
    155   1.6      mrg 	kva = NULL;			/* let system choose VA */
    156   1.1      mrg 
    157   1.6      mrg 	if (uvm_map(pager_map, &kva, size, NULL,
    158   1.1      mrg 	      UVM_UNKNOWN_OFFSET, UVM_FLAG_NOMERGE) != KERN_SUCCESS) {
    159   1.6      mrg 		if (waitf == M_NOWAIT) {
    160   1.6      mrg 			if (aio)
    161   1.6      mrg 				FREE(aio, M_TEMP);
    162   1.6      mrg 			UVMHIST_LOG(maphist,"<- NOWAIT failed", 0,0,0,0);
    163   1.6      mrg 			return(NULL);
    164   1.6      mrg 		}
    165   1.6      mrg 		simple_lock(&pager_map_wanted_lock);
    166   1.6      mrg 		pager_map_wanted = TRUE;
    167   1.6      mrg 		UVMHIST_LOG(maphist, "  SLEEPING on pager_map",0,0,0,0);
    168   1.6      mrg 		UVM_UNLOCK_AND_WAIT(pager_map, &pager_map_wanted_lock, FALSE,
    169   1.6      mrg 		    "pager_map",0);
    170   1.6      mrg 		goto ReStart;
    171   1.6      mrg 	}
    172   1.1      mrg 
    173   1.1      mrg #if defined(PMAP_NEW)
    174   1.6      mrg 	/*
    175   1.6      mrg 	 * XXX: (ab)using the pmap module to store state info for us.
    176   1.6      mrg 	 * (pmap stores the PAs... we fetch them back later and convert back
    177   1.6      mrg 	 * to pages with PHYS_TO_VM_PAGE).
    178   1.6      mrg 	 */
    179   1.6      mrg 	pmap_kenter_pgs(kva, pps, npages);
    180   1.1      mrg 
    181   1.1      mrg #else /* PMAP_NEW */
    182   1.1      mrg 
    183   1.6      mrg 	/* got it */
    184   1.6      mrg 	for (cva = kva ; size != 0 ; size -= PAGE_SIZE, cva += PAGE_SIZE) {
    185   1.6      mrg 		pp = *pps++;
    186   1.1      mrg #ifdef DEBUG
    187   1.6      mrg 		if ((pp->flags & PG_BUSY) == 0)
    188   1.6      mrg 			panic("uvm_pagermapin: page not busy");
    189   1.1      mrg #endif
    190   1.1      mrg 
    191   1.6      mrg 		pmap_enter(vm_map_pmap(pager_map), cva, VM_PAGE_TO_PHYS(pp),
    192   1.6      mrg 		    VM_PROT_DEFAULT, TRUE);
    193   1.6      mrg 	}
    194   1.1      mrg 
    195   1.1      mrg #endif /* PMAP_NEW */
    196   1.1      mrg 
    197   1.6      mrg 	UVMHIST_LOG(maphist, "<- done (KVA=0x%x)", kva,0,0,0);
    198   1.6      mrg 	return(kva);
    199   1.1      mrg }
    200   1.1      mrg 
    201   1.1      mrg /*
    202   1.1      mrg  * uvm_pagermapout: remove pager_map mapping
    203   1.1      mrg  *
    204   1.1      mrg  * we remove our mappings by hand and then remove the mapping (waking
    205   1.1      mrg  * up anyone wanting space).
    206   1.1      mrg  */
    207   1.1      mrg 
    208   1.6      mrg void
    209   1.6      mrg uvm_pagermapout(kva, npages)
    210   1.9      eeh 	vaddr_t kva;
    211   1.6      mrg 	int npages;
    212   1.6      mrg {
    213  1.12      chs 	vsize_t size = npages << PAGE_SHIFT;
    214   1.6      mrg 	vm_map_entry_t entries;
    215   1.6      mrg 	UVMHIST_FUNC("uvm_pagermapout"); UVMHIST_CALLED(maphist);
    216   1.6      mrg 
    217   1.6      mrg 	UVMHIST_LOG(maphist, " (kva=0x%x, npages=%d)", kva, npages,0,0);
    218   1.1      mrg 
    219   1.6      mrg 	/*
    220   1.6      mrg 	 * duplicate uvm_unmap, but add in pager_map_wanted handling.
    221   1.6      mrg 	 */
    222   1.6      mrg 
    223   1.6      mrg 	vm_map_lock(pager_map);
    224  1.11    chuck 	(void) uvm_unmap_remove(pager_map, kva, kva + size, &entries);
    225   1.6      mrg 	simple_lock(&pager_map_wanted_lock);
    226   1.6      mrg 	if (pager_map_wanted) {
    227   1.6      mrg 		pager_map_wanted = FALSE;
    228   1.6      mrg 		wakeup(pager_map);
    229   1.6      mrg 	}
    230   1.6      mrg 	simple_unlock(&pager_map_wanted_lock);
    231   1.6      mrg 	vm_map_unlock(pager_map);
    232   1.6      mrg 	if (entries)
    233   1.6      mrg 		uvm_unmap_detach(entries, 0);
    234   1.1      mrg 
    235   1.6      mrg 	UVMHIST_LOG(maphist,"<- done",0,0,0,0);
    236   1.1      mrg }
    237   1.1      mrg 
    238   1.1      mrg /*
    239   1.1      mrg  * uvm_mk_pcluster
    240   1.1      mrg  *
    241   1.1      mrg  * generic "make 'pager put' cluster" function.  a pager can either
    242   1.1      mrg  * [1] set pgo_mk_pcluster to NULL (never cluster), [2] set it to this
    243   1.1      mrg  * generic function, or [3] set it to a pager specific function.
    244   1.1      mrg  *
    245   1.1      mrg  * => caller must lock object _and_ pagequeues (since we need to look
    246   1.1      mrg  *    at active vs. inactive bits, etc.)
    247   1.1      mrg  * => caller must make center page busy and write-protect it
    248   1.1      mrg  * => we mark all cluster pages busy for the caller
    249   1.1      mrg  * => the caller must unbusy all pages (and check wanted/released
    250   1.1      mrg  *    status if it drops the object lock)
    251   1.1      mrg  * => flags:
    252   1.1      mrg  *      PGO_ALLPAGES:  all pages in object are valid targets
    253   1.1      mrg  *      !PGO_ALLPAGES: use "lo" and "hi" to limit range of cluster
    254   1.1      mrg  *      PGO_DOACTCLUST: include active pages in cluster.
    255   1.1      mrg  *        NOTE: the caller should clear PG_CLEANCHK bits if PGO_DOACTCLUST.
    256   1.1      mrg  *              PG_CLEANCHK is only a hint, but clearing will help reduce
    257   1.1      mrg  *		the number of calls we make to the pmap layer.
    258   1.1      mrg  */
    259   1.1      mrg 
    260   1.6      mrg struct vm_page **
    261   1.6      mrg uvm_mk_pcluster(uobj, pps, npages, center, flags, mlo, mhi)
    262   1.6      mrg 	struct uvm_object *uobj;	/* IN */
    263   1.6      mrg 	struct vm_page **pps, *center;  /* IN/OUT, IN */
    264   1.6      mrg 	int *npages, flags;		/* IN/OUT, IN */
    265   1.9      eeh 	vaddr_t mlo, mhi;		/* IN (if !PGO_ALLPAGES) */
    266   1.1      mrg {
    267   1.6      mrg 	struct vm_page **ppsp, *pclust;
    268   1.9      eeh 	vaddr_t lo, hi, curoff;
    269   1.6      mrg 	int center_idx, forward;
    270   1.6      mrg 	UVMHIST_FUNC("uvm_mk_pcluster"); UVMHIST_CALLED(maphist);
    271   1.6      mrg 
    272   1.6      mrg 	/*
    273   1.6      mrg 	 * center page should already be busy and write protected.  XXX:
    274   1.6      mrg 	 * suppose page is wired?  if we lock, then a process could
    275   1.6      mrg 	 * fault/block on it.  if we don't lock, a process could write the
    276   1.6      mrg 	 * pages in the middle of an I/O.  (consider an msync()).  let's
    277   1.6      mrg 	 * lock it for now (better to delay than corrupt data?).
    278   1.6      mrg 	 */
    279   1.6      mrg 
    280   1.6      mrg 	/*
    281   1.6      mrg 	 * get cluster boundaries, check sanity, and apply our limits as well.
    282   1.6      mrg 	 */
    283   1.6      mrg 
    284   1.6      mrg 	uobj->pgops->pgo_cluster(uobj, center->offset, &lo, &hi);
    285   1.6      mrg 	if ((flags & PGO_ALLPAGES) == 0) {
    286   1.6      mrg 		if (lo < mlo)
    287   1.6      mrg 			lo = mlo;
    288   1.6      mrg 		if (hi > mhi)
    289   1.6      mrg 			hi = mhi;
    290   1.6      mrg 	}
    291  1.12      chs 	if ((hi - lo) >> PAGE_SHIFT > *npages) {  /* pps too small, bail out! */
    292   1.1      mrg #ifdef DIAGNOSTIC
    293   1.6      mrg 	    printf("uvm_mk_pcluster: provided page array too small (fixed)\n");
    294   1.1      mrg #endif
    295   1.6      mrg 		pps[0] = center;
    296   1.6      mrg 		*npages = 1;
    297   1.6      mrg 		return(pps);
    298   1.6      mrg 	}
    299   1.6      mrg 
    300   1.6      mrg 	/*
    301   1.6      mrg 	 * now determine the center and attempt to cluster around the
    302   1.6      mrg 	 * edges
    303   1.6      mrg 	 */
    304   1.6      mrg 
    305  1.12      chs 	center_idx = (center->offset - lo) >> PAGE_SHIFT;
    306   1.6      mrg 	pps[center_idx] = center;	/* plug in the center page */
    307   1.6      mrg 	ppsp = &pps[center_idx];
    308   1.6      mrg 	*npages = 1;
    309   1.6      mrg 
    310   1.6      mrg 	/*
    311   1.6      mrg 	 * attempt to cluster around the left [backward], and then
    312   1.6      mrg 	 * the right side [forward].
    313   1.6      mrg 	 *
    314   1.6      mrg 	 * note that for inactive pages (pages that have been deactivated)
    315   1.6      mrg 	 * there are no valid mappings and PG_CLEAN should be up to date.
    316   1.6      mrg 	 * [i.e. there is no need to query the pmap with pmap_is_modified
    317   1.6      mrg 	 * since there are no mappings].
    318   1.6      mrg 	 */
    319   1.6      mrg 
    320   1.6      mrg 	for (forward  = 0 ; forward <= 1 ; forward++) {
    321   1.6      mrg 
    322  1.14      chs 		curoff = center->offset + (forward ? PAGE_SIZE : -PAGE_SIZE);
    323   1.6      mrg 		for ( ;(forward == 0 && curoff >= lo) ||
    324  1.12      chs 		       (forward && curoff < hi);
    325  1.12      chs 		      curoff += (forward ? 1 : -1) << PAGE_SHIFT) {
    326   1.6      mrg 
    327   1.6      mrg 			pclust = uvm_pagelookup(uobj, curoff); /* lookup page */
    328   1.6      mrg 			if (pclust == NULL)
    329   1.6      mrg 				break;			/* no page */
    330   1.6      mrg 			/* handle active pages */
    331   1.6      mrg 			/* NOTE: inactive pages don't have pmap mappings */
    332   1.6      mrg 			if ((pclust->pqflags & PQ_INACTIVE) == 0) {
    333   1.6      mrg 				if ((flags & PGO_DOACTCLUST) == 0)
    334   1.6      mrg 					/* dont want mapped pages at all */
    335   1.6      mrg 					break;
    336   1.6      mrg 
    337   1.6      mrg 				/* make sure "clean" bit is sync'd */
    338   1.6      mrg 				if ((pclust->flags & PG_CLEANCHK) == 0) {
    339   1.6      mrg 					if ((pclust->flags & (PG_CLEAN|PG_BUSY))
    340   1.6      mrg 					   == PG_CLEAN &&
    341   1.6      mrg 					   pmap_is_modified(PMAP_PGARG(pclust)))
    342   1.6      mrg 					pclust->flags &= ~PG_CLEAN;
    343   1.6      mrg 					/* now checked */
    344   1.6      mrg 					pclust->flags |= PG_CLEANCHK;
    345   1.6      mrg 				}
    346   1.6      mrg 			}
    347   1.6      mrg 			/* is page available for cleaning and does it need it */
    348   1.6      mrg 			if ((pclust->flags & (PG_CLEAN|PG_BUSY)) != 0)
    349   1.6      mrg 				break;	/* page is already clean or is busy */
    350   1.6      mrg 
    351   1.6      mrg 			/* yes!   enroll the page in our array */
    352   1.6      mrg 			pclust->flags |= PG_BUSY;		/* busy! */
    353   1.6      mrg 			UVM_PAGE_OWN(pclust, "uvm_mk_pcluster");
    354   1.6      mrg 			/* XXX: protect wired page?   see above comment. */
    355   1.6      mrg 			pmap_page_protect(PMAP_PGARG(pclust), VM_PROT_READ);
    356   1.6      mrg 			if (!forward) {
    357   1.6      mrg 				ppsp--;			/* back up one page */
    358   1.6      mrg 				*ppsp = pclust;
    359   1.6      mrg 			} else {
    360   1.6      mrg 				/* move forward one page */
    361   1.6      mrg 				ppsp[*npages] = pclust;
    362   1.6      mrg 			}
    363   1.6      mrg 			*npages = *npages + 1;
    364   1.6      mrg 		}
    365   1.6      mrg 	}
    366   1.6      mrg 
    367   1.6      mrg 	/*
    368   1.6      mrg 	 * done!  return the cluster array to the caller!!!
    369   1.6      mrg 	 */
    370   1.1      mrg 
    371   1.6      mrg 	UVMHIST_LOG(maphist, "<- done",0,0,0,0);
    372   1.6      mrg 	return(ppsp);
    373   1.1      mrg }
    374   1.1      mrg 
    375   1.1      mrg 
    376   1.1      mrg /*
    377   1.1      mrg  * uvm_shareprot: generic share protect routine
    378   1.1      mrg  *
    379   1.1      mrg  * => caller must lock map entry's map
    380   1.1      mrg  * => caller must lock object pointed to by map entry
    381   1.1      mrg  */
    382   1.1      mrg 
    383   1.6      mrg void
    384   1.6      mrg uvm_shareprot(entry, prot)
    385   1.6      mrg 	vm_map_entry_t entry;
    386   1.6      mrg 	vm_prot_t prot;
    387   1.1      mrg {
    388   1.6      mrg 	struct uvm_object *uobj = entry->object.uvm_obj;
    389   1.6      mrg 	struct vm_page *pp;
    390   1.9      eeh 	vaddr_t start, stop;
    391   1.6      mrg 	UVMHIST_FUNC("uvm_shareprot"); UVMHIST_CALLED(maphist);
    392   1.6      mrg 
    393  1.11    chuck 	if (UVM_ET_ISSUBMAP(entry))
    394   1.6      mrg 		panic("uvm_shareprot: non-object attached");
    395   1.6      mrg 
    396   1.6      mrg 	start = entry->offset;
    397   1.6      mrg 	stop = start + (entry->end - entry->start);
    398   1.6      mrg 
    399   1.6      mrg 	/*
    400   1.6      mrg 	 * traverse list of pages in object.   if page in range, pmap_prot it
    401   1.6      mrg 	 */
    402   1.6      mrg 
    403   1.6      mrg 	for (pp = uobj->memq.tqh_first ; pp != NULL ; pp = pp->listq.tqe_next) {
    404   1.6      mrg 		if (pp->offset >= start && pp->offset < stop)
    405   1.6      mrg 			pmap_page_protect(PMAP_PGARG(pp), prot);
    406   1.6      mrg 	}
    407   1.6      mrg 	UVMHIST_LOG(maphist, "<- done",0,0,0,0);
    408   1.1      mrg }
    409   1.1      mrg 
    410   1.1      mrg /*
    411   1.1      mrg  * uvm_pager_put: high level pageout routine
    412   1.1      mrg  *
    413   1.1      mrg  * we want to pageout page "pg" to backing store, clustering if
    414   1.1      mrg  * possible.
    415   1.1      mrg  *
    416   1.1      mrg  * => page queues must be locked by caller
    417   1.1      mrg  * => if page is not swap-backed, then "uobj" points to the object
    418   1.1      mrg  *	backing it.   this object should be locked by the caller.
    419   1.1      mrg  * => if page is swap-backed, then "uobj" should be NULL.
    420   1.1      mrg  * => "pg" should be PG_BUSY (by caller), and !PG_CLEAN
    421   1.1      mrg  *    for swap-backed memory, "pg" can be NULL if there is no page
    422   1.1      mrg  *    of interest [sometimes the case for the pagedaemon]
    423   1.1      mrg  * => "ppsp_ptr" should point to an array of npages vm_page pointers
    424   1.1      mrg  *	for possible cluster building
    425   1.1      mrg  * => flags (first two for non-swap-backed pages)
    426   1.1      mrg  *	PGO_ALLPAGES: all pages in uobj are valid targets
    427   1.1      mrg  *	PGO_DOACTCLUST: include "PQ_ACTIVE" pages as valid targets
    428   1.1      mrg  *	PGO_SYNCIO: do SYNC I/O (no async)
    429   1.1      mrg  *	PGO_PDFREECLUST: pagedaemon: drop cluster on successful I/O
    430   1.1      mrg  * => start/stop: if (uobj && !PGO_ALLPAGES) limit targets to this range
    431   1.1      mrg  *		  if (!uobj) start is the (daddr_t) of the starting swapblk
    432   1.1      mrg  * => return state:
    433   1.1      mrg  *	1. we return the VM_PAGER status code of the pageout
    434   1.1      mrg  *	2. we return with the page queues unlocked
    435   1.1      mrg  *	3. if (uobj != NULL) [!swap_backed] we return with
    436   1.1      mrg  *		uobj locked _only_ if PGO_PDFREECLUST is set
    437   1.1      mrg  *		AND result != VM_PAGER_PEND.   in all other cases
    438   1.1      mrg  *		we return with uobj unlocked.   [this is a hack
    439   1.1      mrg  *		that allows the pagedaemon to save one lock/unlock
    440   1.1      mrg  *		pair in the !swap_backed case since we have to
    441   1.1      mrg  *		lock the uobj to drop the cluster anyway]
    442   1.1      mrg  *	4. on errors we always drop the cluster.   thus, if we return
    443   1.1      mrg  *		!PEND, !OK, then the caller only has to worry about
    444   1.1      mrg  *		un-busying the main page (not the cluster pages).
    445   1.1      mrg  *	5. on success, if !PGO_PDFREECLUST, we return the cluster
    446   1.1      mrg  *		with all pages busy (caller must un-busy and check
    447   1.1      mrg  *		wanted/released flags).
    448   1.1      mrg  */
    449   1.1      mrg 
    450   1.6      mrg int
    451   1.6      mrg uvm_pager_put(uobj, pg, ppsp_ptr, npages, flags, start, stop)
    452   1.6      mrg 	struct uvm_object *uobj;	/* IN */
    453   1.6      mrg 	struct vm_page *pg, ***ppsp_ptr;/* IN, IN/OUT */
    454   1.6      mrg 	int *npages;			/* IN/OUT */
    455   1.6      mrg 	int flags;			/* IN */
    456   1.9      eeh 	vaddr_t start, stop;	/* IN, IN */
    457   1.6      mrg {
    458   1.6      mrg 	int result;
    459   1.6      mrg 	daddr_t swblk;
    460   1.6      mrg 	struct vm_page **ppsp = *ppsp_ptr;
    461   1.6      mrg 
    462   1.6      mrg 	/*
    463   1.6      mrg 	 * note that uobj is null  if we are doing a swap-backed pageout.
    464   1.6      mrg 	 * note that uobj is !null if we are doing normal object pageout.
    465   1.6      mrg 	 * note that the page queues must be locked to cluster.
    466   1.6      mrg 	 */
    467   1.6      mrg 
    468   1.6      mrg 	if (uobj) {	/* if !swap-backed */
    469   1.6      mrg 
    470   1.6      mrg 		/*
    471   1.6      mrg 		 * attempt to build a cluster for pageout using its
    472   1.6      mrg 		 * make-put-cluster function (if it has one).
    473   1.6      mrg 		 */
    474   1.6      mrg 
    475   1.6      mrg 		if (uobj->pgops->pgo_mk_pcluster) {
    476   1.6      mrg 			ppsp = uobj->pgops->pgo_mk_pcluster(uobj, ppsp,
    477   1.6      mrg 			    npages, pg, flags, start, stop);
    478   1.6      mrg 			*ppsp_ptr = ppsp;  /* update caller's pointer */
    479   1.6      mrg 		} else {
    480   1.6      mrg 			ppsp[0] = pg;
    481   1.6      mrg 			*npages = 1;
    482   1.6      mrg 		 }
    483   1.6      mrg 
    484   1.6      mrg 		swblk = 0;		/* XXX: keep gcc happy */
    485   1.1      mrg 
    486   1.6      mrg 	} else {
    487   1.1      mrg 
    488   1.6      mrg 		/*
    489   1.6      mrg 		 * for swap-backed pageout, the caller (the pagedaemon) has
    490   1.6      mrg 		 * already built the cluster for us.   the starting swap
    491   1.6      mrg 		 * block we are writing to has been passed in as "start."
    492   1.6      mrg 		 * "pg" could be NULL if there is no page we are especially
    493   1.6      mrg 		 * interested in (in which case the whole cluster gets dropped
    494   1.6      mrg 		 * in the event of an error or a sync "done").
    495   1.6      mrg 		 */
    496   1.6      mrg 		swblk = (daddr_t) start;
    497   1.6      mrg 		/* ppsp and npages should be ok */
    498   1.6      mrg 	}
    499   1.1      mrg 
    500   1.6      mrg 	/* now that we've clustered we can unlock the page queues */
    501   1.6      mrg 	uvm_unlock_pageq();
    502   1.1      mrg 
    503   1.6      mrg 	/*
    504   1.6      mrg 	 * now attempt the I/O.   if we have a failure and we are
    505   1.6      mrg 	 * clustered, we will drop the cluster and try again.
    506   1.6      mrg 	 */
    507   1.1      mrg 
    508   1.1      mrg ReTry:
    509   1.6      mrg 	if (uobj) {
    510   1.6      mrg 		/* object is locked */
    511   1.6      mrg 		result = uobj->pgops->pgo_put(uobj, ppsp, *npages,
    512   1.6      mrg 		    flags & PGO_SYNCIO);
    513   1.6      mrg 		/* object is now unlocked */
    514   1.6      mrg 	} else {
    515   1.6      mrg 		/* nothing locked */
    516   1.6      mrg 		result = uvm_swap_put(swblk, ppsp, *npages, flags & PGO_SYNCIO);
    517   1.6      mrg 		/* nothing locked */
    518   1.6      mrg 	}
    519   1.6      mrg 
    520   1.6      mrg 	/*
    521   1.6      mrg 	 * we have attempted the I/O.
    522   1.6      mrg 	 *
    523   1.6      mrg 	 * if the I/O was a success then:
    524   1.6      mrg 	 * 	if !PGO_PDFREECLUST, we return the cluster to the
    525   1.6      mrg 	 *		caller (who must un-busy all pages)
    526   1.6      mrg 	 *	else we un-busy cluster pages for the pagedaemon
    527   1.6      mrg 	 *
    528   1.6      mrg 	 * if I/O is pending (async i/o) then we return the pending code.
    529   1.6      mrg 	 * [in this case the async i/o done function must clean up when
    530   1.6      mrg 	 *  i/o is done...]
    531   1.6      mrg 	 */
    532   1.6      mrg 
    533   1.6      mrg 	if (result == VM_PAGER_PEND || result == VM_PAGER_OK) {
    534   1.6      mrg 		if (result == VM_PAGER_OK && (flags & PGO_PDFREECLUST)) {
    535   1.6      mrg 			/*
    536   1.6      mrg 			 * drop cluster and relock object (only if I/O is
    537   1.6      mrg 			 * not pending)
    538   1.6      mrg 			 */
    539   1.6      mrg 			if (uobj)
    540   1.6      mrg 				/* required for dropcluster */
    541   1.6      mrg 				simple_lock(&uobj->vmobjlock);
    542   1.6      mrg 			if (*npages > 1 || pg == NULL)
    543   1.6      mrg 				uvm_pager_dropcluster(uobj, pg, ppsp, npages,
    544   1.6      mrg 				    PGO_PDFREECLUST, 0);
    545   1.6      mrg 			/* if (uobj): object still locked, as per
    546   1.6      mrg 			 * return-state item #3 */
    547   1.6      mrg 		}
    548   1.6      mrg 		return (result);
    549   1.6      mrg 	}
    550   1.6      mrg 
    551   1.6      mrg 	/*
    552   1.6      mrg 	 * a pager error occured.    if we have clustered, we drop the
    553   1.6      mrg 	 * cluster and try again.
    554   1.6      mrg 	 */
    555   1.6      mrg 
    556   1.6      mrg 	if (*npages > 1 || pg == NULL) {
    557   1.6      mrg 		if (uobj)
    558   1.6      mrg 			simple_lock(&uobj->vmobjlock);
    559   1.6      mrg 		uvm_pager_dropcluster(uobj, pg, ppsp, npages, PGO_REALLOCSWAP,
    560   1.6      mrg 		    swblk);
    561   1.6      mrg 		if (pg != NULL)
    562   1.6      mrg 			goto ReTry;
    563   1.6      mrg 	}
    564   1.6      mrg 
    565   1.6      mrg 	/*
    566   1.6      mrg 	 * a pager error occured (even after dropping the cluster, if there
    567   1.6      mrg 	 * was one).    give up!   the caller only has one page ("pg")
    568   1.6      mrg 	 * to worry about.
    569   1.6      mrg 	 */
    570   1.6      mrg 
    571   1.6      mrg 	if (uobj && (flags & PGO_PDFREECLUST) != 0)
    572   1.6      mrg 		simple_lock(&uobj->vmobjlock);
    573   1.6      mrg 	return(result);
    574   1.1      mrg }
    575   1.1      mrg 
    576   1.1      mrg /*
    577   1.1      mrg  * uvm_pager_dropcluster: drop a cluster we have built (because we
    578   1.1      mrg  * got an error, or, if PGO_PDFREECLUST we are un-busying the
    579   1.1      mrg  * cluster pages on behalf of the pagedaemon).
    580   1.1      mrg  *
    581   1.1      mrg  * => uobj, if non-null, is a non-swap-backed object that is
    582   1.1      mrg  *	locked by the caller.   we return with this object still
    583   1.1      mrg  *	locked.
    584   1.1      mrg  * => page queues are not locked
    585   1.1      mrg  * => pg is our page of interest (the one we clustered around, can be null)
    586   1.1      mrg  * => ppsp/npages is our current cluster
    587   1.1      mrg  * => flags: PGO_PDFREECLUST: pageout was a success: un-busy cluster
    588   1.1      mrg  *	pages on behalf of the pagedaemon.
    589   1.1      mrg  *           PGO_REALLOCSWAP: drop previously allocated swap slots for
    590   1.1      mrg  *		clustered swap-backed pages (except for "pg" if !NULL)
    591   1.1      mrg  *		"swblk" is the start of swap alloc (e.g. for ppsp[0])
    592   1.1      mrg  *		[only meaningful if swap-backed (uobj == NULL)]
    593   1.1      mrg  */
    594   1.1      mrg 
    595   1.1      mrg 
    596   1.1      mrg void uvm_pager_dropcluster(uobj, pg, ppsp, npages, flags, swblk)
    597   1.1      mrg 
    598   1.1      mrg struct uvm_object *uobj;	/* IN */
    599   1.1      mrg struct vm_page *pg, **ppsp;	/* IN, IN/OUT */
    600   1.1      mrg int *npages;			/* IN/OUT */
    601   1.1      mrg int flags;
    602   1.1      mrg int swblk;			/* valid if (uobj == NULL && PGO_REALLOCSWAP) */
    603   1.1      mrg 
    604   1.1      mrg {
    605   1.6      mrg 	int lcv;
    606   1.6      mrg 	boolean_t obj_is_alive;
    607   1.7    chuck 	struct uvm_object *saved_uobj;
    608   1.1      mrg 
    609   1.6      mrg 	/*
    610   1.6      mrg 	 * if we need to reallocate swap space for the cluster we are dropping
    611   1.6      mrg 	 * (true if swap-backed and PGO_REALLOCSWAP) then free the old
    612   1.6      mrg 	 * allocation now.   save a block for "pg" if it is non-NULL.
    613   1.6      mrg 	 *
    614   1.6      mrg 	 * note that we will zap the object's pointer to swap in the "for" loop
    615   1.6      mrg 	 * below...
    616   1.6      mrg 	 */
    617   1.6      mrg 
    618   1.6      mrg 	if (uobj == NULL && (flags & PGO_REALLOCSWAP)) {
    619   1.6      mrg 		if (pg)
    620   1.6      mrg 			uvm_swap_free(swblk + 1, *npages - 1);
    621   1.6      mrg 		else
    622   1.6      mrg 			uvm_swap_free(swblk, *npages);
    623   1.6      mrg 	}
    624   1.6      mrg 
    625   1.6      mrg 	/*
    626   1.6      mrg 	 * drop all pages but "pg"
    627   1.6      mrg 	 */
    628   1.1      mrg 
    629   1.6      mrg 	for (lcv = 0 ; lcv < *npages ; lcv++) {
    630   1.1      mrg 
    631   1.6      mrg 		if (ppsp[lcv] == pg)		/* skip "pg" */
    632   1.6      mrg 			continue;
    633   1.1      mrg 
    634   1.6      mrg 		/*
    635   1.6      mrg 		 * if swap-backed, gain lock on object that owns page.  note
    636   1.6      mrg 		 * that PQ_ANON bit can't change as long as we are holding
    637   1.6      mrg 		 * the PG_BUSY bit (so there is no need to lock the page
    638   1.6      mrg 		 * queues to test it).
    639   1.6      mrg 		 *
    640   1.6      mrg 		 * once we have the lock, dispose of the pointer to swap, if
    641   1.6      mrg 		 * requested
    642   1.6      mrg 		 */
    643   1.6      mrg 		if (!uobj) {
    644   1.6      mrg 			if (ppsp[lcv]->pqflags & PQ_ANON) {
    645   1.6      mrg 				simple_lock(&ppsp[lcv]->uanon->an_lock);
    646   1.6      mrg 				if (flags & PGO_REALLOCSWAP)
    647   1.6      mrg 					  /* zap swap block */
    648   1.6      mrg 					  ppsp[lcv]->uanon->an_swslot = 0;
    649   1.6      mrg 			} else {
    650   1.6      mrg 				simple_lock(&ppsp[lcv]->uobject->vmobjlock);
    651   1.6      mrg 				if (flags & PGO_REALLOCSWAP)
    652   1.6      mrg 					uao_set_swslot(ppsp[lcv]->uobject,
    653  1.12      chs 					    ppsp[lcv]->offset >> PAGE_SHIFT, 0);
    654   1.6      mrg 			}
    655   1.6      mrg 		}
    656   1.6      mrg 
    657   1.6      mrg 		/* did someone want the page while we had it busy-locked? */
    658   1.6      mrg 		if (ppsp[lcv]->flags & PG_WANTED)
    659   1.6      mrg 			/* still holding obj lock */
    660   1.6      mrg 			thread_wakeup(ppsp[lcv]);
    661   1.6      mrg 
    662   1.6      mrg 		/* if page was released, release it.  otherwise un-busy it */
    663   1.6      mrg 		if (ppsp[lcv]->flags & PG_RELEASED) {
    664   1.6      mrg 
    665   1.6      mrg 			if (ppsp[lcv]->pqflags & PQ_ANON) {
    666   1.6      mrg 				/* so that anfree will free */
    667   1.6      mrg 				ppsp[lcv]->flags &= ~(PG_BUSY);
    668   1.6      mrg 				UVM_PAGE_OWN(ppsp[lcv], NULL);
    669   1.6      mrg 
    670   1.6      mrg 				pmap_page_protect(PMAP_PGARG(ppsp[lcv]),
    671   1.6      mrg 				    VM_PROT_NONE); /* be safe */
    672  1.13      chs 				simple_unlock(&ppsp[lcv]->uanon->an_lock);
    673   1.6      mrg 				/* kills anon and frees pg */
    674  1.13      chs 				uvm_anfree(ppsp[lcv]->uanon);
    675   1.6      mrg 
    676   1.6      mrg 				continue;
    677   1.6      mrg 			}
    678   1.6      mrg 
    679   1.6      mrg 			/*
    680   1.6      mrg 			 * pgo_releasepg will dump the page for us
    681   1.6      mrg 			 */
    682   1.1      mrg 
    683   1.1      mrg #ifdef DIAGNOSTIC
    684   1.6      mrg 			if (ppsp[lcv]->uobject->pgops->pgo_releasepg == NULL)
    685   1.6      mrg 				panic("uvm_pager_dropcluster: no releasepg "
    686   1.6      mrg 				    "function");
    687   1.1      mrg #endif
    688   1.7    chuck 			saved_uobj = ppsp[lcv]->uobject;
    689   1.6      mrg 			obj_is_alive =
    690   1.7    chuck 			    saved_uobj->pgops->pgo_releasepg(ppsp[lcv], NULL);
    691   1.6      mrg 
    692   1.1      mrg #ifdef DIAGNOSTIC
    693   1.6      mrg 			/* for normal objects, "pg" is still PG_BUSY by us,
    694   1.6      mrg 			 * so obj can't die */
    695   1.6      mrg 			if (uobj && !obj_is_alive)
    696   1.6      mrg 				panic("uvm_pager_dropcluster: object died "
    697   1.6      mrg 				    "with active page");
    698   1.1      mrg #endif
    699   1.7    chuck 			/* only unlock the object if it is still alive...  */
    700   1.7    chuck 			if (obj_is_alive && saved_uobj != uobj)
    701   1.7    chuck 				simple_unlock(&saved_uobj->vmobjlock);
    702   1.7    chuck 
    703   1.7    chuck 			/*
    704   1.7    chuck 			 * XXXCDC: suppose uobj died in the pgo_releasepg?
    705   1.7    chuck 			 * how pass that
    706   1.7    chuck 			 * info up to caller.  we are currently ignoring it...
    707   1.7    chuck 			 */
    708   1.7    chuck 
    709   1.7    chuck 			continue;		/* next page */
    710   1.1      mrg 
    711   1.6      mrg 		} else {
    712   1.6      mrg 			ppsp[lcv]->flags &= ~(PG_BUSY|PG_WANTED);
    713   1.6      mrg 			UVM_PAGE_OWN(ppsp[lcv], NULL);
    714   1.6      mrg 		}
    715   1.6      mrg 
    716   1.6      mrg 		/*
    717   1.6      mrg 		 * if we are operating on behalf of the pagedaemon and we
    718   1.6      mrg 		 * had a successful pageout update the page!
    719   1.6      mrg 		 */
    720   1.6      mrg 		if (flags & PGO_PDFREECLUST) {
    721   1.6      mrg 			/* XXX: with PMAP_NEW ref should already be clear,
    722   1.6      mrg 			 * but don't trust! */
    723   1.6      mrg 			pmap_clear_reference(PMAP_PGARG(ppsp[lcv]));
    724   1.6      mrg 			pmap_clear_modify(PMAP_PGARG(ppsp[lcv]));
    725   1.6      mrg 			ppsp[lcv]->flags |= PG_CLEAN;
    726   1.6      mrg 		}
    727   1.6      mrg 
    728   1.6      mrg 		/* if anonymous cluster, unlock object and move on */
    729   1.6      mrg 		if (!uobj) {
    730   1.6      mrg 			if (ppsp[lcv]->pqflags & PQ_ANON)
    731   1.6      mrg 				simple_unlock(&ppsp[lcv]->uanon->an_lock);
    732   1.6      mrg 			else
    733   1.6      mrg 				simple_unlock(&ppsp[lcv]->uobject->vmobjlock);
    734   1.6      mrg 		}
    735   1.1      mrg 
    736   1.6      mrg 	}
    737   1.6      mrg 
    738   1.6      mrg 	/*
    739   1.6      mrg 	 * drop to a cluster of 1 page ("pg") if requested
    740   1.6      mrg 	 */
    741   1.6      mrg 
    742   1.6      mrg 	if (pg && (flags & PGO_PDFREECLUST) == 0) {
    743   1.6      mrg 		/*
    744   1.6      mrg 		 * if we are not a successful pageout, we make a 1 page cluster.
    745   1.6      mrg 		 */
    746   1.6      mrg 		ppsp[0] = pg;
    747   1.6      mrg 		*npages = 1;
    748   1.6      mrg 
    749   1.6      mrg 		/*
    750   1.6      mrg 		 * assign new swap block to new cluster, if anon backed
    751   1.6      mrg 		 */
    752   1.6      mrg 		if (uobj == NULL && (flags & PGO_REALLOCSWAP)) {
    753   1.6      mrg 			if (pg->pqflags & PQ_ANON) {
    754   1.6      mrg 				simple_lock(&pg->uanon->an_lock);
    755   1.6      mrg 				pg->uanon->an_swslot = swblk;	/* reassign */
    756   1.6      mrg 				simple_unlock(&pg->uanon->an_lock);
    757   1.6      mrg 			} else {
    758   1.6      mrg 				simple_lock(&pg->uobject->vmobjlock);
    759   1.6      mrg 				uao_set_swslot(pg->uobject,
    760  1.12      chs 				    pg->offset >> PAGE_SHIFT, swblk);
    761   1.6      mrg 				simple_unlock(&pg->uobject->vmobjlock);
    762   1.6      mrg 			}
    763   1.6      mrg 		}
    764   1.6      mrg 	}
    765   1.1      mrg }
    766