Home | History | Annotate | Line # | Download | only in rumpvfs
vm_vfs.c revision 1.5.2.2
      1  1.5.2.2  yamt /*	$NetBSD: vm_vfs.c,v 1.5.2.2 2009/05/04 08:14:31 yamt Exp $	*/
      2  1.5.2.2  yamt 
      3  1.5.2.2  yamt /*
      4  1.5.2.2  yamt  * Copyright (c) 2008 Antti Kantee.  All Rights Reserved.
      5  1.5.2.2  yamt  *
      6  1.5.2.2  yamt  * Development of this software was supported by the
      7  1.5.2.2  yamt  * Finnish Cultural Foundation.
      8  1.5.2.2  yamt  *
      9  1.5.2.2  yamt  * Redistribution and use in source and binary forms, with or without
     10  1.5.2.2  yamt  * modification, are permitted provided that the following conditions
     11  1.5.2.2  yamt  * are met:
     12  1.5.2.2  yamt  * 1. Redistributions of source code must retain the above copyright
     13  1.5.2.2  yamt  *    notice, this list of conditions and the following disclaimer.
     14  1.5.2.2  yamt  * 2. Redistributions in binary form must reproduce the above copyright
     15  1.5.2.2  yamt  *    notice, this list of conditions and the following disclaimer in the
     16  1.5.2.2  yamt  *    documentation and/or other materials provided with the distribution.
     17  1.5.2.2  yamt  *
     18  1.5.2.2  yamt  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS
     19  1.5.2.2  yamt  * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     20  1.5.2.2  yamt  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
     21  1.5.2.2  yamt  * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
     22  1.5.2.2  yamt  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     23  1.5.2.2  yamt  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
     24  1.5.2.2  yamt  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     25  1.5.2.2  yamt  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     26  1.5.2.2  yamt  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     27  1.5.2.2  yamt  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     28  1.5.2.2  yamt  * SUCH DAMAGE.
     29  1.5.2.2  yamt  */
     30  1.5.2.2  yamt 
     31  1.5.2.2  yamt #include <sys/cdefs.h>
     32  1.5.2.2  yamt __KERNEL_RCSID(0, "$NetBSD: vm_vfs.c,v 1.5.2.2 2009/05/04 08:14:31 yamt Exp $");
     33  1.5.2.2  yamt 
     34  1.5.2.2  yamt #include <sys/param.h>
     35  1.5.2.2  yamt 
     36  1.5.2.2  yamt #include <sys/buf.h>
     37  1.5.2.2  yamt #include <sys/vnode.h>
     38  1.5.2.2  yamt 
     39  1.5.2.2  yamt #include <uvm/uvm.h>
     40  1.5.2.2  yamt #include <uvm/uvm_readahead.h>
     41  1.5.2.2  yamt 
     42  1.5.2.2  yamt static int vn_get(struct uvm_object *, voff_t, struct vm_page **,
     43  1.5.2.2  yamt 	int *, int, vm_prot_t, int, int);
     44  1.5.2.2  yamt static int vn_put(struct uvm_object *, voff_t, voff_t, int);
     45  1.5.2.2  yamt 
     46  1.5.2.2  yamt const struct uvm_pagerops uvm_vnodeops = {
     47  1.5.2.2  yamt 	.pgo_get = vn_get,
     48  1.5.2.2  yamt 	.pgo_put = vn_put,
     49  1.5.2.2  yamt };
     50  1.5.2.2  yamt 
     51  1.5.2.2  yamt /*
     52  1.5.2.2  yamt  * vnode pager
     53  1.5.2.2  yamt  */
     54  1.5.2.2  yamt 
     55  1.5.2.2  yamt static int
     56  1.5.2.2  yamt vn_get(struct uvm_object *uobj, voff_t off, struct vm_page **pgs,
     57  1.5.2.2  yamt 	int *npages, int centeridx, vm_prot_t access_type,
     58  1.5.2.2  yamt 	int advice, int flags)
     59  1.5.2.2  yamt {
     60  1.5.2.2  yamt 	struct vnode *vp = (struct vnode *)uobj;
     61  1.5.2.2  yamt 
     62  1.5.2.2  yamt 	return VOP_GETPAGES(vp, off, pgs, npages, centeridx, access_type,
     63  1.5.2.2  yamt 	    advice, flags);
     64  1.5.2.2  yamt }
     65  1.5.2.2  yamt 
     66  1.5.2.2  yamt static int
     67  1.5.2.2  yamt vn_put(struct uvm_object *uobj, voff_t offlo, voff_t offhi, int flags)
     68  1.5.2.2  yamt {
     69  1.5.2.2  yamt 	struct vnode *vp = (struct vnode *)uobj;
     70  1.5.2.2  yamt 
     71  1.5.2.2  yamt 	return VOP_PUTPAGES(vp, offlo, offhi, flags);
     72  1.5.2.2  yamt }
     73  1.5.2.2  yamt 
     74  1.5.2.2  yamt void
     75  1.5.2.2  yamt uvm_aio_biodone1(struct buf *bp)
     76  1.5.2.2  yamt {
     77  1.5.2.2  yamt 
     78  1.5.2.2  yamt 	panic("%s: unimplemented", __func__);
     79  1.5.2.2  yamt }
     80  1.5.2.2  yamt 
     81  1.5.2.2  yamt void
     82  1.5.2.2  yamt uvm_aio_biodone(struct buf *bp)
     83  1.5.2.2  yamt {
     84  1.5.2.2  yamt 
     85  1.5.2.2  yamt 	uvm_aio_aiodone(bp);
     86  1.5.2.2  yamt }
     87  1.5.2.2  yamt 
     88  1.5.2.2  yamt void
     89  1.5.2.2  yamt uvm_aio_aiodone(struct buf *bp)
     90  1.5.2.2  yamt {
     91  1.5.2.2  yamt 
     92  1.5.2.2  yamt }
     93  1.5.2.2  yamt 
     94  1.5.2.2  yamt struct uvm_ractx *
     95  1.5.2.2  yamt uvm_ra_allocctx(void)
     96  1.5.2.2  yamt {
     97  1.5.2.2  yamt 
     98  1.5.2.2  yamt 	return NULL;
     99  1.5.2.2  yamt }
    100  1.5.2.2  yamt 
    101  1.5.2.2  yamt void
    102  1.5.2.2  yamt uvm_ra_freectx(struct uvm_ractx *ra)
    103  1.5.2.2  yamt {
    104  1.5.2.2  yamt 
    105  1.5.2.2  yamt 	return;
    106  1.5.2.2  yamt }
    107  1.5.2.2  yamt 
    108  1.5.2.2  yamt bool
    109  1.5.2.2  yamt uvn_clean_p(struct uvm_object *uobj)
    110  1.5.2.2  yamt {
    111  1.5.2.2  yamt 	struct vnode *vp = (void *)uobj;
    112  1.5.2.2  yamt 
    113  1.5.2.2  yamt 	return (vp->v_iflag & VI_ONWORKLST) == 0;
    114  1.5.2.2  yamt }
    115  1.5.2.2  yamt 
    116  1.5.2.2  yamt void
    117  1.5.2.2  yamt uvm_vnp_setsize(struct vnode *vp, voff_t newsize)
    118  1.5.2.2  yamt {
    119  1.5.2.2  yamt 
    120  1.5.2.2  yamt 	mutex_enter(&vp->v_interlock);
    121  1.5.2.2  yamt 	vp->v_size = vp->v_writesize = newsize;
    122  1.5.2.2  yamt 	mutex_exit(&vp->v_interlock);
    123  1.5.2.2  yamt }
    124  1.5.2.2  yamt 
    125  1.5.2.2  yamt void
    126  1.5.2.2  yamt uvm_vnp_setwritesize(struct vnode *vp, voff_t newsize)
    127  1.5.2.2  yamt {
    128  1.5.2.2  yamt 
    129  1.5.2.2  yamt 	mutex_enter(&vp->v_interlock);
    130  1.5.2.2  yamt 	vp->v_writesize = newsize;
    131  1.5.2.2  yamt 	mutex_exit(&vp->v_interlock);
    132  1.5.2.2  yamt }
    133  1.5.2.2  yamt 
    134  1.5.2.2  yamt void
    135  1.5.2.2  yamt uvm_vnp_zerorange(struct vnode *vp, off_t off, size_t len)
    136  1.5.2.2  yamt {
    137  1.5.2.2  yamt 	struct uvm_object *uobj = &vp->v_uobj;
    138  1.5.2.2  yamt 	struct vm_page **pgs;
    139  1.5.2.2  yamt 	int maxpages = MIN(32, round_page(len) >> PAGE_SHIFT);
    140  1.5.2.2  yamt 	int rv, npages, i;
    141  1.5.2.2  yamt 
    142  1.5.2.2  yamt 	pgs = kmem_zalloc(maxpages * sizeof(pgs), KM_SLEEP);
    143  1.5.2.2  yamt 	while (len) {
    144  1.5.2.2  yamt 		npages = MIN(maxpages, round_page(len) >> PAGE_SHIFT);
    145  1.5.2.2  yamt 		memset(pgs, 0, npages * sizeof(struct vm_page *));
    146  1.5.2.2  yamt 		mutex_enter(&uobj->vmobjlock);
    147  1.5.2.2  yamt 		rv = uobj->pgops->pgo_get(uobj, off, pgs, &npages, 0, 0, 0, 0);
    148  1.5.2.2  yamt 		KASSERT(npages > 0);
    149  1.5.2.2  yamt 
    150  1.5.2.2  yamt 		for (i = 0; i < npages; i++) {
    151  1.5.2.2  yamt 			uint8_t *start;
    152  1.5.2.2  yamt 			size_t chunkoff, chunklen;
    153  1.5.2.2  yamt 
    154  1.5.2.2  yamt 			chunkoff = off & PAGE_MASK;
    155  1.5.2.2  yamt 			chunklen = MIN(PAGE_SIZE - chunkoff, len);
    156  1.5.2.2  yamt 			start = (uint8_t *)pgs[i]->uanon + chunkoff;
    157  1.5.2.2  yamt 
    158  1.5.2.2  yamt 			memset(start, 0, chunklen);
    159  1.5.2.2  yamt 			pgs[i]->flags &= ~PG_CLEAN;
    160  1.5.2.2  yamt 
    161  1.5.2.2  yamt 			off += chunklen;
    162  1.5.2.2  yamt 			len -= chunklen;
    163  1.5.2.2  yamt 		}
    164  1.5.2.2  yamt 		uvm_page_unbusy(pgs, npages);
    165  1.5.2.2  yamt 	}
    166  1.5.2.2  yamt 	kmem_free(pgs, maxpages * sizeof(pgs));
    167  1.5.2.2  yamt 
    168  1.5.2.2  yamt 	return;
    169  1.5.2.2  yamt }
    170  1.5.2.2  yamt 
    171  1.5.2.2  yamt /*
    172  1.5.2.2  yamt  * UBC
    173  1.5.2.2  yamt  */
    174  1.5.2.2  yamt 
    175  1.5.2.2  yamt /* dumdidumdum */
    176  1.5.2.2  yamt #define len2npages(off, len)						\
    177  1.5.2.2  yamt   (((((len) + PAGE_MASK) & ~(PAGE_MASK)) >> PAGE_SHIFT)			\
    178  1.5.2.2  yamt     + (((off & PAGE_MASK) + (len & PAGE_MASK)) > PAGE_SIZE))
    179  1.5.2.2  yamt 
    180  1.5.2.2  yamt int
    181  1.5.2.2  yamt ubc_uiomove(struct uvm_object *uobj, struct uio *uio, vsize_t todo,
    182  1.5.2.2  yamt 	int advice, int flags)
    183  1.5.2.2  yamt {
    184  1.5.2.2  yamt 	struct vm_page **pgs;
    185  1.5.2.2  yamt 	int npages = len2npages(uio->uio_offset, todo);
    186  1.5.2.2  yamt 	size_t pgalloc;
    187  1.5.2.2  yamt 	int i, rv;
    188  1.5.2.2  yamt 
    189  1.5.2.2  yamt 	pgalloc = npages * sizeof(pgs);
    190  1.5.2.2  yamt 	pgs = kmem_zalloc(pgalloc, KM_SLEEP);
    191  1.5.2.2  yamt 
    192  1.5.2.2  yamt 	do {
    193  1.5.2.2  yamt 		mutex_enter(&uobj->vmobjlock);
    194  1.5.2.2  yamt 		rv = uobj->pgops->pgo_get(uobj, uio->uio_offset, pgs, &npages,
    195  1.5.2.2  yamt 		    0, 0, 0, 0);
    196  1.5.2.2  yamt 		if (rv)
    197  1.5.2.2  yamt 			goto out;
    198  1.5.2.2  yamt 
    199  1.5.2.2  yamt 		for (i = 0; i < npages; i++) {
    200  1.5.2.2  yamt 			size_t xfersize;
    201  1.5.2.2  yamt 			off_t pageoff;
    202  1.5.2.2  yamt 
    203  1.5.2.2  yamt 			pageoff = uio->uio_offset & PAGE_MASK;
    204  1.5.2.2  yamt 			xfersize = MIN(MIN(todo, PAGE_SIZE), PAGE_SIZE-pageoff);
    205  1.5.2.2  yamt 			uiomove((uint8_t *)pgs[i]->uanon + pageoff,
    206  1.5.2.2  yamt 			    xfersize, uio);
    207  1.5.2.2  yamt 			if (uio->uio_rw == UIO_WRITE)
    208  1.5.2.2  yamt 				pgs[i]->flags &= ~PG_CLEAN;
    209  1.5.2.2  yamt 			todo -= xfersize;
    210  1.5.2.2  yamt 		}
    211  1.5.2.2  yamt 		uvm_page_unbusy(pgs, npages);
    212  1.5.2.2  yamt 	} while (todo);
    213  1.5.2.2  yamt 
    214  1.5.2.2  yamt  out:
    215  1.5.2.2  yamt 	kmem_free(pgs, pgalloc);
    216  1.5.2.2  yamt 	return rv;
    217  1.5.2.2  yamt }
    218