Home | History | Annotate | Line # | Download | only in uvm
uvm_bio.c revision 1.70
      1  1.70     rmind /*	$NetBSD: uvm_bio.c,v 1.70 2010/06/22 18:34:50 rmind Exp $	*/
      2   1.2       chs 
      3  1.13       chs /*
      4   1.2       chs  * Copyright (c) 1998 Chuck Silvers.
      5   1.2       chs  * All rights reserved.
      6   1.2       chs  *
      7   1.2       chs  * Redistribution and use in source and binary forms, with or without
      8   1.2       chs  * modification, are permitted provided that the following conditions
      9   1.2       chs  * are met:
     10   1.2       chs  * 1. Redistributions of source code must retain the above copyright
     11   1.2       chs  *    notice, this list of conditions and the following disclaimer.
     12   1.2       chs  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.2       chs  *    notice, this list of conditions and the following disclaimer in the
     14   1.2       chs  *    documentation and/or other materials provided with the distribution.
     15   1.2       chs  * 3. The name of the author may not be used to endorse or promote products
     16   1.2       chs  *    derived from this software without specific prior written permission.
     17   1.2       chs  *
     18   1.2       chs  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     19   1.2       chs  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     20   1.2       chs  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     21   1.2       chs  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     22   1.2       chs  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
     23   1.2       chs  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     24   1.2       chs  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
     25   1.2       chs  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
     26   1.2       chs  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     27   1.2       chs  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     28   1.2       chs  * SUCH DAMAGE.
     29   1.2       chs  *
     30   1.2       chs  */
     31   1.2       chs 
     32   1.2       chs /*
     33  1.33       chs  * uvm_bio.c: buffered i/o object mapping cache
     34   1.2       chs  */
     35   1.2       chs 
     36  1.21     lukem #include <sys/cdefs.h>
     37  1.70     rmind __KERNEL_RCSID(0, "$NetBSD: uvm_bio.c,v 1.70 2010/06/22 18:34:50 rmind Exp $");
     38  1.21     lukem 
     39  1.21     lukem #include "opt_uvmhist.h"
     40  1.50      yamt #include "opt_ubc.h"
     41   1.2       chs 
     42   1.2       chs #include <sys/param.h>
     43   1.2       chs #include <sys/systm.h>
     44  1.65        ad #include <sys/kmem.h>
     45   1.2       chs #include <sys/kernel.h>
     46  1.60        ad #include <sys/proc.h>
     47  1.67     pooka #include <sys/vnode.h>
     48   1.2       chs 
     49   1.2       chs #include <uvm/uvm.h>
     50   1.2       chs 
     51   1.2       chs /*
     52   1.2       chs  * global data structures
     53   1.2       chs  */
     54   1.2       chs 
     55   1.2       chs /*
     56   1.2       chs  * local functions
     57   1.2       chs  */
     58   1.2       chs 
     59  1.39   thorpej static int	ubc_fault(struct uvm_faultinfo *, vaddr_t, struct vm_page **,
     60  1.44  drochner 			  int, int, vm_prot_t, int);
     61  1.39   thorpej static struct ubc_map *ubc_find_mapping(struct uvm_object *, voff_t);
     62   1.2       chs 
     63   1.2       chs /*
     64   1.2       chs  * local data structues
     65   1.2       chs  */
     66   1.2       chs 
     67  1.18       chs #define UBC_HASH(uobj, offset) 						\
     68  1.18       chs 	(((((u_long)(uobj)) >> 8) + (((u_long)(offset)) >> PAGE_SHIFT)) & \
     69   1.2       chs 				ubc_object.hashmask)
     70   1.2       chs 
     71  1.18       chs #define UBC_QUEUE(offset)						\
     72  1.18       chs 	(&ubc_object.inactive[(((u_long)(offset)) >> ubc_winshift) &	\
     73  1.18       chs 			     (UBC_NQUEUES - 1)])
     74  1.18       chs 
     75  1.18       chs #define UBC_UMAP_ADDR(u)						\
     76  1.18       chs 	(vaddr_t)(ubc_object.kva + (((u) - ubc_object.umap) << ubc_winshift))
     77  1.18       chs 
     78  1.18       chs 
     79  1.18       chs #define UMAP_PAGES_LOCKED	0x0001
     80  1.18       chs #define UMAP_MAPPING_CACHED	0x0002
     81   1.2       chs 
     82   1.2       chs struct ubc_map
     83   1.2       chs {
     84   1.2       chs 	struct uvm_object *	uobj;		/* mapped object */
     85   1.2       chs 	voff_t			offset;		/* offset into uobj */
     86  1.33       chs 	voff_t			writeoff;	/* write offset */
     87  1.33       chs 	vsize_t			writelen;	/* write len */
     88  1.18       chs 	int			refcount;	/* refcount on mapping */
     89  1.18       chs 	int			flags;		/* extra state */
     90  1.42      yamt 	int			advice;
     91   1.2       chs 
     92   1.2       chs 	LIST_ENTRY(ubc_map)	hash;		/* hash table */
     93   1.2       chs 	TAILQ_ENTRY(ubc_map)	inactive;	/* inactive queue */
     94   1.2       chs };
     95   1.2       chs 
     96   1.2       chs static struct ubc_object
     97   1.2       chs {
     98   1.2       chs 	struct uvm_object uobj;		/* glue for uvm_map() */
     99   1.2       chs 	char *kva;			/* where ubc_object is mapped */
    100   1.2       chs 	struct ubc_map *umap;		/* array of ubc_map's */
    101   1.2       chs 
    102   1.2       chs 	LIST_HEAD(, ubc_map) *hash;	/* hashtable for cached ubc_map's */
    103   1.2       chs 	u_long hashmask;		/* mask for hashtable */
    104   1.2       chs 
    105   1.2       chs 	TAILQ_HEAD(ubc_inactive_head, ubc_map) *inactive;
    106   1.2       chs 					/* inactive queues for ubc_map's */
    107   1.2       chs 
    108   1.2       chs } ubc_object;
    109   1.2       chs 
    110  1.63      yamt const struct uvm_pagerops ubc_pager = {
    111  1.48  christos 	.pgo_fault = ubc_fault,
    112   1.2       chs 	/* ... rest are NULL */
    113   1.2       chs };
    114   1.2       chs 
    115   1.2       chs int ubc_nwins = UBC_NWINS;
    116  1.11       chs int ubc_winshift = UBC_WINSHIFT;
    117  1.11       chs int ubc_winsize;
    118  1.27   thorpej #if defined(PMAP_PREFER)
    119   1.2       chs int ubc_nqueues;
    120   1.2       chs #define UBC_NQUEUES ubc_nqueues
    121   1.2       chs #else
    122   1.2       chs #define UBC_NQUEUES 1
    123   1.2       chs #endif
    124   1.2       chs 
    125  1.50      yamt #if defined(UBC_STATS)
    126  1.50      yamt 
    127  1.50      yamt #define	UBC_EVCNT_DEFINE(name) \
    128  1.50      yamt struct evcnt ubc_evcnt_##name = \
    129  1.50      yamt EVCNT_INITIALIZER(EVCNT_TYPE_MISC, NULL, "ubc", #name); \
    130  1.50      yamt EVCNT_ATTACH_STATIC(ubc_evcnt_##name);
    131  1.50      yamt #define	UBC_EVCNT_INCR(name) ubc_evcnt_##name.ev_count++
    132  1.50      yamt 
    133  1.50      yamt #else /* defined(UBC_STATS) */
    134  1.50      yamt 
    135  1.50      yamt #define	UBC_EVCNT_DEFINE(name)	/* nothing */
    136  1.50      yamt #define	UBC_EVCNT_INCR(name)	/* nothing */
    137  1.50      yamt 
    138  1.50      yamt #endif /* defined(UBC_STATS) */
    139  1.50      yamt 
    140  1.50      yamt UBC_EVCNT_DEFINE(wincachehit)
    141  1.50      yamt UBC_EVCNT_DEFINE(wincachemiss)
    142  1.57      yamt UBC_EVCNT_DEFINE(faultbusy)
    143  1.50      yamt 
    144   1.2       chs /*
    145   1.2       chs  * ubc_init
    146   1.2       chs  *
    147   1.2       chs  * init pager private data structures.
    148   1.2       chs  */
    149   1.2       chs 
    150   1.2       chs void
    151   1.2       chs ubc_init(void)
    152   1.2       chs {
    153   1.2       chs 	struct ubc_map *umap;
    154   1.2       chs 	vaddr_t va;
    155   1.2       chs 	int i;
    156  1.15    simonb 
    157  1.15    simonb 	/*
    158  1.15    simonb 	 * Make sure ubc_winshift is sane.
    159  1.15    simonb 	 */
    160  1.15    simonb 	if (ubc_winshift < PAGE_SHIFT)
    161  1.15    simonb 		ubc_winshift = PAGE_SHIFT;
    162   1.2       chs 
    163   1.2       chs 	/*
    164   1.2       chs 	 * init ubc_object.
    165   1.2       chs 	 * alloc and init ubc_map's.
    166   1.2       chs 	 * init inactive queues.
    167   1.2       chs 	 * alloc and init hashtable.
    168   1.2       chs 	 * map in ubc_object.
    169   1.2       chs 	 */
    170   1.2       chs 
    171  1.38      yamt 	UVM_OBJ_INIT(&ubc_object.uobj, &ubc_pager, UVM_OBJ_KERN);
    172   1.2       chs 
    173  1.65        ad 	ubc_object.umap = kmem_zalloc(ubc_nwins * sizeof(struct ubc_map),
    174  1.65        ad 	    KM_SLEEP);
    175   1.7     enami 	if (ubc_object.umap == NULL)
    176   1.7     enami 		panic("ubc_init: failed to allocate ubc_map");
    177   1.2       chs 
    178  1.18       chs 	if (ubc_winshift < PAGE_SHIFT) {
    179  1.18       chs 		ubc_winshift = PAGE_SHIFT;
    180  1.18       chs 	}
    181   1.2       chs 	va = (vaddr_t)1L;
    182   1.2       chs #ifdef PMAP_PREFER
    183  1.36    atatat 	PMAP_PREFER(0, &va, 0, 0);	/* kernel is never topdown */
    184  1.11       chs 	ubc_nqueues = va >> ubc_winshift;
    185  1.11       chs 	if (ubc_nqueues == 0) {
    186  1.11       chs 		ubc_nqueues = 1;
    187   1.2       chs 	}
    188   1.2       chs #endif
    189  1.11       chs 	ubc_winsize = 1 << ubc_winshift;
    190  1.65        ad 	ubc_object.inactive = kmem_alloc(UBC_NQUEUES *
    191  1.65        ad 	    sizeof(struct ubc_inactive_head), KM_SLEEP);
    192   1.7     enami 	if (ubc_object.inactive == NULL)
    193   1.7     enami 		panic("ubc_init: failed to allocate inactive queue heads");
    194   1.2       chs 	for (i = 0; i < UBC_NQUEUES; i++) {
    195   1.2       chs 		TAILQ_INIT(&ubc_object.inactive[i]);
    196   1.2       chs 	}
    197   1.2       chs 	for (i = 0; i < ubc_nwins; i++) {
    198   1.2       chs 		umap = &ubc_object.umap[i];
    199   1.2       chs 		TAILQ_INSERT_TAIL(&ubc_object.inactive[i & (UBC_NQUEUES - 1)],
    200   1.2       chs 				  umap, inactive);
    201   1.2       chs 	}
    202   1.2       chs 
    203  1.65        ad 	ubc_object.hash = hashinit(ubc_nwins, HASH_LIST, true,
    204  1.65        ad 	    &ubc_object.hashmask);
    205   1.2       chs 	for (i = 0; i <= ubc_object.hashmask; i++) {
    206   1.2       chs 		LIST_INIT(&ubc_object.hash[i]);
    207   1.2       chs 	}
    208   1.2       chs 
    209   1.2       chs 	if (uvm_map(kernel_map, (vaddr_t *)&ubc_object.kva,
    210  1.11       chs 		    ubc_nwins << ubc_winshift, &ubc_object.uobj, 0, (vsize_t)va,
    211   1.2       chs 		    UVM_MAPFLAG(UVM_PROT_ALL, UVM_PROT_ALL, UVM_INH_NONE,
    212   1.9       chs 				UVM_ADV_RANDOM, UVM_FLAG_NOMERGE)) != 0) {
    213  1.26    provos 		panic("ubc_init: failed to map ubc_object");
    214   1.2       chs 	}
    215   1.2       chs 	UVMHIST_INIT(ubchist, 300);
    216   1.2       chs }
    217   1.2       chs 
    218   1.2       chs /*
    219  1.69     rmind  * ubc_fault_page: helper of ubc_fault to handle a single page.
    220  1.70     rmind  *
    221  1.70     rmind  * => Caller has UVM object locked.
    222  1.69     rmind  */
    223  1.69     rmind 
    224  1.70     rmind static inline int
    225  1.69     rmind ubc_fault_page(const struct uvm_faultinfo *ufi, const struct ubc_map *umap,
    226  1.69     rmind     struct vm_page *pg, vm_prot_t prot, vm_prot_t access_type, vaddr_t va)
    227  1.69     rmind {
    228  1.69     rmind 	struct uvm_object *uobj;
    229  1.69     rmind 	vm_prot_t mask;
    230  1.69     rmind 	int error;
    231  1.69     rmind 	bool rdonly;
    232  1.69     rmind 
    233  1.69     rmind 	uobj = pg->uobject;
    234  1.70     rmind 	KASSERT(mutex_owned(&uobj->vmobjlock));
    235  1.70     rmind 
    236  1.69     rmind 	if (pg->flags & PG_WANTED) {
    237  1.69     rmind 		wakeup(pg);
    238  1.69     rmind 	}
    239  1.69     rmind 	KASSERT((pg->flags & PG_FAKE) == 0);
    240  1.69     rmind 	if (pg->flags & PG_RELEASED) {
    241  1.69     rmind 		mutex_enter(&uvm_pageqlock);
    242  1.69     rmind 		uvm_pagefree(pg);
    243  1.69     rmind 		mutex_exit(&uvm_pageqlock);
    244  1.70     rmind 		return 0;
    245  1.69     rmind 	}
    246  1.69     rmind 	if (pg->loan_count != 0) {
    247  1.69     rmind 
    248  1.69     rmind 		/*
    249  1.69     rmind 		 * Avoid unneeded loan break, if possible.
    250  1.69     rmind 		 */
    251  1.69     rmind 
    252  1.69     rmind 		if ((access_type & VM_PROT_WRITE) == 0) {
    253  1.69     rmind 			prot &= ~VM_PROT_WRITE;
    254  1.69     rmind 		}
    255  1.69     rmind 		if (prot & VM_PROT_WRITE) {
    256  1.69     rmind 			struct vm_page *newpg;
    257  1.69     rmind 
    258  1.69     rmind 			newpg = uvm_loanbreak(pg);
    259  1.69     rmind 			if (newpg == NULL) {
    260  1.69     rmind 				uvm_page_unbusy(&pg, 1);
    261  1.70     rmind 				return ENOMEM;
    262  1.69     rmind 			}
    263  1.69     rmind 			pg = newpg;
    264  1.69     rmind 		}
    265  1.69     rmind 	}
    266  1.69     rmind 
    267  1.69     rmind 	/*
    268  1.69     rmind 	 * Note that a page whose backing store is partially allocated
    269  1.69     rmind 	 * is marked as PG_RDONLY.
    270  1.69     rmind 	 */
    271  1.69     rmind 
    272  1.69     rmind 	KASSERT((pg->flags & PG_RDONLY) == 0 ||
    273  1.69     rmind 	    (access_type & VM_PROT_WRITE) == 0 ||
    274  1.69     rmind 	    pg->offset < umap->writeoff ||
    275  1.69     rmind 	    pg->offset + PAGE_SIZE > umap->writeoff + umap->writelen);
    276  1.69     rmind 
    277  1.69     rmind 	rdonly = ((access_type & VM_PROT_WRITE) == 0 &&
    278  1.69     rmind 	    (pg->flags & PG_RDONLY) != 0) ||
    279  1.69     rmind 	    UVM_OBJ_NEEDS_WRITEFAULT(uobj);
    280  1.69     rmind 	mask = rdonly ? ~VM_PROT_WRITE : VM_PROT_ALL;
    281  1.69     rmind 
    282  1.69     rmind 	error = pmap_enter(ufi->orig_map->pmap, va, VM_PAGE_TO_PHYS(pg),
    283  1.69     rmind 	    prot & mask, PMAP_CANFAIL | (access_type & mask));
    284  1.69     rmind 
    285  1.69     rmind 	mutex_enter(&uvm_pageqlock);
    286  1.69     rmind 	uvm_pageactivate(pg);
    287  1.69     rmind 	mutex_exit(&uvm_pageqlock);
    288  1.69     rmind 	pg->flags &= ~(PG_BUSY|PG_WANTED);
    289  1.69     rmind 	UVM_PAGE_OWN(pg, NULL);
    290  1.69     rmind 
    291  1.70     rmind 	return error;
    292  1.69     rmind }
    293  1.69     rmind 
    294  1.69     rmind /*
    295   1.2       chs  * ubc_fault: fault routine for ubc mapping
    296   1.2       chs  */
    297  1.18       chs 
    298  1.39   thorpej static int
    299  1.54      yamt ubc_fault(struct uvm_faultinfo *ufi, vaddr_t ign1, struct vm_page **ign2,
    300  1.54      yamt     int ign3, int ign4, vm_prot_t access_type, int flags)
    301   1.2       chs {
    302   1.2       chs 	struct uvm_object *uobj;
    303   1.2       chs 	struct ubc_map *umap;
    304   1.2       chs 	vaddr_t va, eva, ubc_offset, slot_offset;
    305  1.69     rmind 	struct vm_page *pgs[ubc_winsize >> PAGE_SHIFT];
    306  1.18       chs 	int i, error, npages;
    307  1.23       chs 	vm_prot_t prot;
    308  1.69     rmind 
    309  1.69     rmind 	UVMHIST_FUNC("ubc_fault"); UVMHIST_CALLED(ubchist);
    310   1.2       chs 
    311   1.2       chs 	/*
    312   1.2       chs 	 * no need to try with PGO_LOCKED...
    313   1.2       chs 	 * we don't need to have the map locked since we know that
    314   1.2       chs 	 * no one will mess with it until our reference is released.
    315   1.2       chs 	 */
    316  1.18       chs 
    317   1.2       chs 	if (flags & PGO_LOCKED) {
    318   1.2       chs 		uvmfault_unlockall(ufi, NULL, &ubc_object.uobj, NULL);
    319   1.2       chs 		flags &= ~PGO_LOCKED;
    320   1.2       chs 	}
    321   1.2       chs 
    322   1.2       chs 	va = ufi->orig_rvaddr;
    323   1.2       chs 	ubc_offset = va - (vaddr_t)ubc_object.kva;
    324  1.11       chs 	umap = &ubc_object.umap[ubc_offset >> ubc_winshift];
    325   1.2       chs 	KASSERT(umap->refcount != 0);
    326  1.53      yamt 	KASSERT((umap->flags & UMAP_PAGES_LOCKED) == 0);
    327  1.18       chs 	slot_offset = ubc_offset & (ubc_winsize - 1);
    328   1.2       chs 
    329  1.34       chs 	/*
    330  1.34       chs 	 * some platforms cannot write to individual bytes atomically, so
    331  1.34       chs 	 * software has to do read/modify/write of larger quantities instead.
    332  1.34       chs 	 * this means that the access_type for "write" operations
    333  1.34       chs 	 * can be VM_PROT_READ, which confuses us mightily.
    334  1.37     perry 	 *
    335  1.34       chs 	 * deal with this by resetting access_type based on the info
    336  1.34       chs 	 * that ubc_alloc() stores for us.
    337  1.34       chs 	 */
    338  1.34       chs 
    339  1.34       chs 	access_type = umap->writelen ? VM_PROT_WRITE : VM_PROT_READ;
    340  1.34       chs 	UVMHIST_LOG(ubchist, "va 0x%lx ubc_offset 0x%lx access_type %d",
    341  1.34       chs 	    va, ubc_offset, access_type, 0);
    342  1.34       chs 
    343  1.33       chs #ifdef DIAGNOSTIC
    344  1.33       chs 	if ((access_type & VM_PROT_WRITE) != 0) {
    345  1.33       chs 		if (slot_offset < trunc_page(umap->writeoff) ||
    346  1.33       chs 		    umap->writeoff + umap->writelen <= slot_offset) {
    347  1.33       chs 			panic("ubc_fault: out of range write");
    348  1.33       chs 		}
    349  1.33       chs 	}
    350  1.33       chs #endif
    351  1.33       chs 
    352   1.2       chs 	/* no umap locking needed since we have a ref on the umap */
    353   1.2       chs 	uobj = umap->uobj;
    354   1.2       chs 
    355  1.33       chs 	if ((access_type & VM_PROT_WRITE) == 0) {
    356  1.33       chs 		npages = (ubc_winsize - slot_offset) >> PAGE_SHIFT;
    357  1.33       chs 	} else {
    358  1.33       chs 		npages = (round_page(umap->offset + umap->writeoff +
    359  1.33       chs 		    umap->writelen) - (umap->offset + slot_offset))
    360  1.33       chs 		    >> PAGE_SHIFT;
    361  1.33       chs 		flags |= PGO_PASTEOF;
    362  1.33       chs 	}
    363   1.2       chs 
    364   1.2       chs again:
    365   1.2       chs 	memset(pgs, 0, sizeof (pgs));
    366  1.64        ad 	mutex_enter(&uobj->vmobjlock);
    367   1.2       chs 
    368  1.33       chs 	UVMHIST_LOG(ubchist, "slot_offset 0x%x writeoff 0x%x writelen 0x%x ",
    369  1.33       chs 	    slot_offset, umap->writeoff, umap->writelen, 0);
    370  1.33       chs 	UVMHIST_LOG(ubchist, "getpages uobj %p offset 0x%x npages %d",
    371  1.18       chs 	    uobj, umap->offset + slot_offset, npages, 0);
    372   1.2       chs 
    373  1.33       chs 	error = (*uobj->pgops->pgo_get)(uobj, umap->offset + slot_offset, pgs,
    374  1.42      yamt 	    &npages, 0, access_type, umap->advice, flags | PGO_NOBLOCKALLOC |
    375  1.41      yamt 	    PGO_NOTIMESTAMP);
    376  1.24    simonb 	UVMHIST_LOG(ubchist, "getpages error %d npages %d", error, npages, 0,
    377  1.24    simonb 	    0);
    378   1.2       chs 
    379   1.5       chs 	if (error == EAGAIN) {
    380  1.70     rmind 		kpause("ubc_fault", false, hz >> 2, NULL);
    381   1.2       chs 		goto again;
    382   1.2       chs 	}
    383   1.5       chs 	if (error) {
    384  1.10       chs 		return error;
    385   1.5       chs 	}
    386   1.2       chs 
    387  1.69     rmind 	/*
    388  1.69     rmind 	 * For virtually-indexed, virtually-tagged caches we should avoid
    389  1.69     rmind 	 * creating writable mappings when we do not absolutely need them,
    390  1.69     rmind 	 * since the "compatible alias" trick does not work on such caches.
    391  1.69     rmind 	 * Otherwise, we can always map the pages writable.
    392  1.69     rmind 	 */
    393  1.69     rmind 
    394  1.69     rmind #ifdef PMAP_CACHE_VIVT
    395  1.69     rmind 	prot = VM_PROT_READ | access_type;
    396  1.69     rmind #else
    397  1.69     rmind 	prot = VM_PROT_READ | VM_PROT_WRITE;
    398  1.69     rmind #endif
    399  1.70     rmind 
    400  1.70     rmind 	/*
    401  1.70     rmind 	 * Note: in the common case, all returned pages would have the same
    402  1.70     rmind 	 * UVM object.  However, due to layered file-systems and e.g. tmpfs,
    403  1.70     rmind 	 * returned pages may have different objects.  We "remember" the
    404  1.70     rmind 	 * last object in the loop to reduce locking overhead and to perform
    405  1.70     rmind 	 * pmap_update() before object unlock.
    406  1.70     rmind 	 */
    407  1.70     rmind 	uobj = NULL;
    408  1.70     rmind 
    409   1.2       chs 	va = ufi->orig_rvaddr;
    410   1.2       chs 	eva = ufi->orig_rvaddr + (npages << PAGE_SHIFT);
    411   1.2       chs 
    412  1.28      yamt 	UVMHIST_LOG(ubchist, "va 0x%lx eva 0x%lx", va, eva, 0, 0);
    413  1.28      yamt 	for (i = 0; va < eva; i++, va += PAGE_SIZE) {
    414  1.69     rmind 		struct vm_page *pg;
    415  1.34       chs 
    416  1.24    simonb 		UVMHIST_LOG(ubchist, "pgs[%d] = %p", i, pgs[i], 0, 0);
    417   1.2       chs 		pg = pgs[i];
    418   1.2       chs 
    419   1.2       chs 		if (pg == NULL || pg == PGO_DONTCARE) {
    420   1.2       chs 			continue;
    421   1.2       chs 		}
    422  1.70     rmind 		if (__predict_false(pg->uobject != uobj)) {
    423  1.70     rmind 			/* Check for the first iteration and error cases. */
    424  1.70     rmind 			if (uobj != NULL) {
    425  1.70     rmind 				/* Must make VA visible before the unlock. */
    426  1.70     rmind 				pmap_update(ufi->orig_map->pmap);
    427  1.70     rmind 				mutex_exit(&uobj->vmobjlock);
    428  1.70     rmind 			}
    429  1.70     rmind 			uobj = pg->uobject;
    430  1.70     rmind 			mutex_enter(&uobj->vmobjlock);
    431  1.70     rmind 		}
    432  1.70     rmind 		error = ubc_fault_page(ufi, umap, pg, prot, access_type, va);
    433  1.70     rmind 		if (error) {
    434  1.70     rmind 			/*
    435  1.70     rmind 			 * Flush (there might be pages entered), drop the lock,
    436  1.70     rmind 			 * "forget" the object and perform uvm_wait().
    437  1.70     rmind 			 * Note: page will re-fault.
    438  1.70     rmind 			 */
    439  1.70     rmind 			pmap_update(ufi->orig_map->pmap);
    440  1.70     rmind 			mutex_exit(&uobj->vmobjlock);
    441  1.70     rmind 			uobj = NULL;
    442  1.70     rmind 			uvm_wait("ubc_fault");
    443  1.70     rmind 		}
    444  1.70     rmind 	}
    445  1.70     rmind 	if (__predict_true(uobj != NULL)) {
    446  1.70     rmind 		pmap_update(ufi->orig_map->pmap);
    447  1.70     rmind 		mutex_exit(&uobj->vmobjlock);
    448   1.2       chs 	}
    449   1.8       chs 	return 0;
    450   1.2       chs }
    451   1.2       chs 
    452   1.2       chs /*
    453   1.2       chs  * local functions
    454   1.2       chs  */
    455   1.2       chs 
    456  1.39   thorpej static struct ubc_map *
    457  1.39   thorpej ubc_find_mapping(struct uvm_object *uobj, voff_t offset)
    458   1.2       chs {
    459   1.2       chs 	struct ubc_map *umap;
    460   1.2       chs 
    461   1.2       chs 	LIST_FOREACH(umap, &ubc_object.hash[UBC_HASH(uobj, offset)], hash) {
    462   1.2       chs 		if (umap->uobj == uobj && umap->offset == offset) {
    463   1.2       chs 			return umap;
    464   1.2       chs 		}
    465   1.2       chs 	}
    466   1.2       chs 	return NULL;
    467   1.2       chs }
    468   1.2       chs 
    469   1.2       chs 
    470   1.2       chs /*
    471   1.2       chs  * ubc interface functions
    472   1.2       chs  */
    473   1.2       chs 
    474   1.2       chs /*
    475  1.18       chs  * ubc_alloc:  allocate a file mapping window
    476   1.2       chs  */
    477  1.18       chs 
    478   1.2       chs void *
    479  1.42      yamt ubc_alloc(struct uvm_object *uobj, voff_t offset, vsize_t *lenp, int advice,
    480  1.42      yamt     int flags)
    481   1.2       chs {
    482   1.6       chs 	vaddr_t slot_offset, va;
    483   1.2       chs 	struct ubc_map *umap;
    484   1.6       chs 	voff_t umap_offset;
    485  1.18       chs 	int error;
    486   1.2       chs 	UVMHIST_FUNC("ubc_alloc"); UVMHIST_CALLED(ubchist);
    487   1.2       chs 
    488  1.33       chs 	UVMHIST_LOG(ubchist, "uobj %p offset 0x%lx len 0x%lx",
    489  1.33       chs 	    uobj, offset, *lenp, 0);
    490   1.2       chs 
    491  1.34       chs 	KASSERT(*lenp > 0);
    492   1.6       chs 	umap_offset = (offset & ~((voff_t)ubc_winsize - 1));
    493   1.4     enami 	slot_offset = (vaddr_t)(offset & ((voff_t)ubc_winsize - 1));
    494  1.18       chs 	*lenp = MIN(*lenp, ubc_winsize - slot_offset);
    495   1.2       chs 
    496   1.2       chs 	/*
    497  1.33       chs 	 * the object is always locked here, so we don't need to add a ref.
    498   1.2       chs 	 */
    499   1.2       chs 
    500   1.2       chs again:
    501  1.64        ad 	mutex_enter(&ubc_object.uobj.vmobjlock);
    502   1.2       chs 	umap = ubc_find_mapping(uobj, umap_offset);
    503   1.2       chs 	if (umap == NULL) {
    504  1.50      yamt 		UBC_EVCNT_INCR(wincachemiss);
    505   1.2       chs 		umap = TAILQ_FIRST(UBC_QUEUE(offset));
    506   1.2       chs 		if (umap == NULL) {
    507  1.64        ad 			mutex_exit(&ubc_object.uobj.vmobjlock);
    508  1.60        ad 			kpause("ubc_alloc", false, hz, NULL);
    509   1.2       chs 			goto again;
    510   1.2       chs 		}
    511   1.2       chs 
    512   1.2       chs 		/*
    513  1.18       chs 		 * remove from old hash (if any), add to new hash.
    514   1.2       chs 		 */
    515   1.2       chs 
    516   1.2       chs 		if (umap->uobj != NULL) {
    517   1.2       chs 			LIST_REMOVE(umap, hash);
    518   1.2       chs 		}
    519   1.2       chs 		umap->uobj = uobj;
    520   1.2       chs 		umap->offset = umap_offset;
    521   1.2       chs 		LIST_INSERT_HEAD(&ubc_object.hash[UBC_HASH(uobj, umap_offset)],
    522  1.18       chs 		    umap, hash);
    523  1.18       chs 		va = UBC_UMAP_ADDR(umap);
    524  1.18       chs 		if (umap->flags & UMAP_MAPPING_CACHED) {
    525  1.18       chs 			umap->flags &= ~UMAP_MAPPING_CACHED;
    526  1.18       chs 			pmap_remove(pmap_kernel(), va, va + ubc_winsize);
    527  1.18       chs 			pmap_update(pmap_kernel());
    528  1.18       chs 		}
    529  1.18       chs 	} else {
    530  1.50      yamt 		UBC_EVCNT_INCR(wincachehit);
    531  1.18       chs 		va = UBC_UMAP_ADDR(umap);
    532   1.2       chs 	}
    533   1.2       chs 
    534   1.2       chs 	if (umap->refcount == 0) {
    535   1.2       chs 		TAILQ_REMOVE(UBC_QUEUE(offset), umap, inactive);
    536   1.2       chs 	}
    537   1.2       chs 
    538   1.2       chs #ifdef DIAGNOSTIC
    539  1.18       chs 	if ((flags & UBC_WRITE) && (umap->writeoff || umap->writelen)) {
    540  1.33       chs 		panic("ubc_alloc: concurrent writes uobj %p", uobj);
    541   1.2       chs 	}
    542   1.2       chs #endif
    543   1.2       chs 	if (flags & UBC_WRITE) {
    544   1.2       chs 		umap->writeoff = slot_offset;
    545   1.2       chs 		umap->writelen = *lenp;
    546   1.2       chs 	}
    547   1.2       chs 
    548   1.2       chs 	umap->refcount++;
    549  1.42      yamt 	umap->advice = advice;
    550  1.64        ad 	mutex_exit(&ubc_object.uobj.vmobjlock);
    551  1.18       chs 	UVMHIST_LOG(ubchist, "umap %p refs %d va %p flags 0x%x",
    552  1.18       chs 	    umap, umap->refcount, va, flags);
    553  1.18       chs 
    554  1.18       chs 	if (flags & UBC_FAULTBUSY) {
    555  1.18       chs 		int npages = (*lenp + PAGE_SIZE - 1) >> PAGE_SHIFT;
    556  1.18       chs 		struct vm_page *pgs[npages];
    557  1.40      yamt 		int gpflags =
    558  1.41      yamt 		    PGO_SYNCIO|PGO_OVERWRITE|PGO_PASTEOF|PGO_NOBLOCKALLOC|
    559  1.41      yamt 		    PGO_NOTIMESTAMP;
    560  1.18       chs 		int i;
    561  1.30       dbj 		KDASSERT(flags & UBC_WRITE);
    562  1.57      yamt 		KASSERT(umap->refcount == 1);
    563   1.2       chs 
    564  1.57      yamt 		UBC_EVCNT_INCR(faultbusy);
    565  1.18       chs 		if (umap->flags & UMAP_MAPPING_CACHED) {
    566  1.18       chs 			umap->flags &= ~UMAP_MAPPING_CACHED;
    567  1.18       chs 			pmap_remove(pmap_kernel(), va, va + ubc_winsize);
    568  1.18       chs 		}
    569  1.59      yamt again_faultbusy:
    570  1.22     enami 		memset(pgs, 0, sizeof(pgs));
    571  1.64        ad 		mutex_enter(&uobj->vmobjlock);
    572  1.33       chs 		error = (*uobj->pgops->pgo_get)(uobj, trunc_page(offset), pgs,
    573  1.42      yamt 		    &npages, 0, VM_PROT_READ | VM_PROT_WRITE, advice, gpflags);
    574  1.24    simonb 		UVMHIST_LOG(ubchist, "faultbusy getpages %d", error, 0, 0, 0);
    575  1.18       chs 		if (error) {
    576  1.18       chs 			goto out;
    577  1.18       chs 		}
    578  1.18       chs 		for (i = 0; i < npages; i++) {
    579  1.59      yamt 			struct vm_page *pg = pgs[i];
    580  1.59      yamt 
    581  1.59      yamt 			KASSERT(pg->uobject == uobj);
    582  1.59      yamt 			if (pg->loan_count != 0) {
    583  1.64        ad 				mutex_enter(&uobj->vmobjlock);
    584  1.59      yamt 				if (pg->loan_count != 0) {
    585  1.59      yamt 					pg = uvm_loanbreak(pg);
    586  1.59      yamt 				}
    587  1.64        ad 				mutex_exit(&uobj->vmobjlock);
    588  1.59      yamt 				if (pg == NULL) {
    589  1.59      yamt 					pmap_kremove(va, ubc_winsize);
    590  1.59      yamt 					pmap_update(pmap_kernel());
    591  1.64        ad 					mutex_enter(&uobj->vmobjlock);
    592  1.59      yamt 					uvm_page_unbusy(pgs, npages);
    593  1.64        ad 					mutex_exit(&uobj->vmobjlock);
    594  1.59      yamt 					uvm_wait("ubc_alloc");
    595  1.59      yamt 					goto again_faultbusy;
    596  1.59      yamt 				}
    597  1.59      yamt 				pgs[i] = pg;
    598  1.59      yamt 			}
    599  1.18       chs 			pmap_kenter_pa(va + slot_offset + (i << PAGE_SHIFT),
    600  1.68    cegger 			    VM_PAGE_TO_PHYS(pg),
    601  1.68    cegger 			    VM_PROT_READ | VM_PROT_WRITE, 0);
    602  1.18       chs 		}
    603  1.18       chs 		pmap_update(pmap_kernel());
    604  1.18       chs 		umap->flags |= UMAP_PAGES_LOCKED;
    605  1.57      yamt 	} else {
    606  1.57      yamt 		KASSERT((umap->flags & UMAP_PAGES_LOCKED) == 0);
    607  1.18       chs 	}
    608  1.18       chs 
    609  1.18       chs out:
    610  1.18       chs 	return (void *)(va + slot_offset);
    611   1.2       chs }
    612   1.2       chs 
    613  1.18       chs /*
    614  1.18       chs  * ubc_release:  free a file mapping window.
    615  1.18       chs  */
    616   1.2       chs 
    617   1.2       chs void
    618  1.39   thorpej ubc_release(void *va, int flags)
    619   1.2       chs {
    620   1.2       chs 	struct ubc_map *umap;
    621   1.2       chs 	struct uvm_object *uobj;
    622  1.18       chs 	vaddr_t umapva;
    623  1.55   thorpej 	bool unmapped;
    624   1.2       chs 	UVMHIST_FUNC("ubc_release"); UVMHIST_CALLED(ubchist);
    625   1.2       chs 
    626  1.24    simonb 	UVMHIST_LOG(ubchist, "va %p", va, 0, 0, 0);
    627  1.11       chs 	umap = &ubc_object.umap[((char *)va - ubc_object.kva) >> ubc_winshift];
    628  1.18       chs 	umapva = UBC_UMAP_ADDR(umap);
    629   1.2       chs 	uobj = umap->uobj;
    630   1.2       chs 	KASSERT(uobj != NULL);
    631   1.2       chs 
    632  1.18       chs 	if (umap->flags & UMAP_PAGES_LOCKED) {
    633  1.18       chs 		int slot_offset = umap->writeoff;
    634  1.18       chs 		int endoff = umap->writeoff + umap->writelen;
    635  1.18       chs 		int zerolen = round_page(endoff) - endoff;
    636  1.18       chs 		int npages = (int)(round_page(umap->writeoff + umap->writelen)
    637  1.18       chs 				   - trunc_page(umap->writeoff)) >> PAGE_SHIFT;
    638  1.18       chs 		struct vm_page *pgs[npages];
    639  1.18       chs 		paddr_t pa;
    640  1.18       chs 		int i;
    641  1.55   thorpej 		bool rv;
    642  1.18       chs 
    643  1.57      yamt 		KASSERT((umap->flags & UMAP_MAPPING_CACHED) == 0);
    644  1.18       chs 		if (zerolen) {
    645  1.18       chs 			memset((char *)umapva + endoff, 0, zerolen);
    646  1.18       chs 		}
    647  1.18       chs 		umap->flags &= ~UMAP_PAGES_LOCKED;
    648  1.64        ad 		mutex_enter(&uvm_pageqlock);
    649  1.18       chs 		for (i = 0; i < npages; i++) {
    650  1.18       chs 			rv = pmap_extract(pmap_kernel(),
    651  1.18       chs 			    umapva + slot_offset + (i << PAGE_SHIFT), &pa);
    652  1.18       chs 			KASSERT(rv);
    653  1.18       chs 			pgs[i] = PHYS_TO_VM_PAGE(pa);
    654  1.18       chs 			pgs[i]->flags &= ~(PG_FAKE|PG_CLEAN);
    655  1.28      yamt 			KASSERT(pgs[i]->loan_count == 0);
    656  1.18       chs 			uvm_pageactivate(pgs[i]);
    657  1.18       chs 		}
    658  1.64        ad 		mutex_exit(&uvm_pageqlock);
    659  1.18       chs 		pmap_kremove(umapva, ubc_winsize);
    660  1.18       chs 		pmap_update(pmap_kernel());
    661  1.64        ad 		mutex_enter(&uobj->vmobjlock);
    662  1.18       chs 		uvm_page_unbusy(pgs, npages);
    663  1.64        ad 		mutex_exit(&uobj->vmobjlock);
    664  1.56   thorpej 		unmapped = true;
    665  1.18       chs 	} else {
    666  1.56   thorpej 		unmapped = false;
    667  1.18       chs 	}
    668  1.18       chs 
    669  1.64        ad 	mutex_enter(&ubc_object.uobj.vmobjlock);
    670   1.2       chs 	umap->writeoff = 0;
    671   1.2       chs 	umap->writelen = 0;
    672   1.2       chs 	umap->refcount--;
    673   1.2       chs 	if (umap->refcount == 0) {
    674  1.33       chs 		if (flags & UBC_UNMAP) {
    675   1.2       chs 
    676   1.2       chs 			/*
    677  1.33       chs 			 * Invalidate any cached mappings if requested.
    678  1.33       chs 			 * This is typically used to avoid leaving
    679  1.33       chs 			 * incompatible cache aliases around indefinitely.
    680   1.2       chs 			 */
    681   1.2       chs 
    682  1.18       chs 			pmap_remove(pmap_kernel(), umapva,
    683  1.18       chs 				    umapva + ubc_winsize);
    684  1.18       chs 			umap->flags &= ~UMAP_MAPPING_CACHED;
    685  1.17     chris 			pmap_update(pmap_kernel());
    686   1.2       chs 			LIST_REMOVE(umap, hash);
    687   1.2       chs 			umap->uobj = NULL;
    688   1.2       chs 			TAILQ_INSERT_HEAD(UBC_QUEUE(umap->offset), umap,
    689   1.2       chs 			    inactive);
    690   1.2       chs 		} else {
    691  1.18       chs 			if (!unmapped) {
    692  1.18       chs 				umap->flags |= UMAP_MAPPING_CACHED;
    693  1.18       chs 			}
    694   1.2       chs 			TAILQ_INSERT_TAIL(UBC_QUEUE(umap->offset), umap,
    695   1.2       chs 			    inactive);
    696   1.2       chs 		}
    697   1.2       chs 	}
    698  1.24    simonb 	UVMHIST_LOG(ubchist, "umap %p refs %d", umap, umap->refcount, 0, 0);
    699  1.64        ad 	mutex_exit(&ubc_object.uobj.vmobjlock);
    700   1.2       chs }
    701   1.2       chs 
    702  1.58      yamt /*
    703  1.58      yamt  * ubc_uiomove: move data to/from an object.
    704  1.58      yamt  */
    705  1.58      yamt 
    706  1.58      yamt int
    707  1.62      yamt ubc_uiomove(struct uvm_object *uobj, struct uio *uio, vsize_t todo, int advice,
    708  1.62      yamt     int flags)
    709  1.58      yamt {
    710  1.58      yamt 	voff_t off;
    711  1.58      yamt 	const bool overwrite = (flags & UBC_FAULTBUSY) != 0;
    712  1.58      yamt 	int error;
    713  1.58      yamt 
    714  1.58      yamt 	KASSERT(todo <= uio->uio_resid);
    715  1.58      yamt 	KASSERT(((flags & UBC_WRITE) != 0 && uio->uio_rw == UIO_WRITE) ||
    716  1.58      yamt 	    ((flags & UBC_READ) != 0 && uio->uio_rw == UIO_READ));
    717  1.58      yamt 
    718  1.58      yamt 	off = uio->uio_offset;
    719  1.58      yamt 	error = 0;
    720  1.58      yamt 	while (todo > 0) {
    721  1.58      yamt 		vsize_t bytelen = todo;
    722  1.58      yamt 		void *win;
    723  1.58      yamt 
    724  1.62      yamt 		win = ubc_alloc(uobj, off, &bytelen, advice, flags);
    725  1.58      yamt 		if (error == 0) {
    726  1.58      yamt 			error = uiomove(win, bytelen, uio);
    727  1.58      yamt 		}
    728  1.58      yamt 		if (error != 0 && overwrite) {
    729  1.58      yamt 			/*
    730  1.58      yamt 			 * if we haven't initialized the pages yet,
    731  1.58      yamt 			 * do it now.  it's safe to use memset here
    732  1.58      yamt 			 * because we just mapped the pages above.
    733  1.58      yamt 			 */
    734  1.64        ad 			printf("%s: error=%d\n", __func__, error);
    735  1.58      yamt 			memset(win, 0, bytelen);
    736  1.58      yamt 		}
    737  1.58      yamt 		ubc_release(win, flags);
    738  1.58      yamt 		off += bytelen;
    739  1.58      yamt 		todo -= bytelen;
    740  1.58      yamt 		if (error != 0 && (flags & UBC_PARTIALOK) != 0) {
    741  1.58      yamt 			break;
    742  1.58      yamt 		}
    743  1.58      yamt 	}
    744  1.58      yamt 
    745  1.58      yamt 	return error;
    746  1.58      yamt }
    747  1.67     pooka 
    748  1.67     pooka 
    749  1.67     pooka /*
    750  1.67     pooka  * uvm_vnp_zerorange:  set a range of bytes in a file to zero.
    751  1.67     pooka  */
    752  1.67     pooka 
    753  1.67     pooka void
    754  1.67     pooka uvm_vnp_zerorange(struct vnode *vp, off_t off, size_t len)
    755  1.67     pooka {
    756  1.67     pooka 	void *win;
    757  1.67     pooka 	int flags;
    758  1.67     pooka 
    759  1.67     pooka 	/*
    760  1.67     pooka 	 * XXXUBC invent kzero() and use it
    761  1.67     pooka 	 */
    762  1.67     pooka 
    763  1.67     pooka 	while (len) {
    764  1.67     pooka 		vsize_t bytelen = len;
    765  1.67     pooka 
    766  1.67     pooka 		win = ubc_alloc(&vp->v_uobj, off, &bytelen, UVM_ADV_NORMAL,
    767  1.67     pooka 		    UBC_WRITE);
    768  1.67     pooka 		memset(win, 0, bytelen);
    769  1.67     pooka 		flags = UBC_WANT_UNMAP(vp) ? UBC_UNMAP : 0;
    770  1.67     pooka 		ubc_release(win, flags);
    771  1.67     pooka 
    772  1.67     pooka 		off += bytelen;
    773  1.67     pooka 		len -= bytelen;
    774  1.67     pooka 	}
    775  1.67     pooka }
    776