Home | History | Annotate | Line # | Download | only in uvm
uvm_swap.c revision 1.46.2.10
      1  1.46.2.10  nathanw /*	$NetBSD: uvm_swap.c,v 1.46.2.10 2002/06/20 03:50:46 nathanw Exp $	*/
      2        1.1      mrg 
      3        1.1      mrg /*
      4        1.1      mrg  * Copyright (c) 1995, 1996, 1997 Matthew R. Green
      5        1.1      mrg  * All rights reserved.
      6        1.1      mrg  *
      7        1.1      mrg  * Redistribution and use in source and binary forms, with or without
      8        1.1      mrg  * modification, are permitted provided that the following conditions
      9        1.1      mrg  * are met:
     10        1.1      mrg  * 1. Redistributions of source code must retain the above copyright
     11        1.1      mrg  *    notice, this list of conditions and the following disclaimer.
     12        1.1      mrg  * 2. Redistributions in binary form must reproduce the above copyright
     13        1.1      mrg  *    notice, this list of conditions and the following disclaimer in the
     14        1.1      mrg  *    documentation and/or other materials provided with the distribution.
     15        1.1      mrg  * 3. The name of the author may not be used to endorse or promote products
     16        1.1      mrg  *    derived from this software without specific prior written permission.
     17        1.1      mrg  *
     18        1.1      mrg  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     19        1.1      mrg  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     20        1.1      mrg  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     21        1.1      mrg  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     22        1.1      mrg  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
     23        1.1      mrg  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     24        1.1      mrg  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
     25        1.1      mrg  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
     26        1.1      mrg  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     27        1.1      mrg  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     28        1.1      mrg  * SUCH DAMAGE.
     29        1.3      mrg  *
     30        1.3      mrg  * from: NetBSD: vm_swap.c,v 1.52 1997/12/02 13:47:37 pk Exp
     31        1.3      mrg  * from: Id: uvm_swap.c,v 1.1.2.42 1998/02/02 20:38:06 chuck Exp
     32        1.1      mrg  */
     33        1.5      mrg 
     34   1.46.2.5  nathanw #include <sys/cdefs.h>
     35  1.46.2.10  nathanw __KERNEL_RCSID(0, "$NetBSD: uvm_swap.c,v 1.46.2.10 2002/06/20 03:50:46 nathanw Exp $");
     36   1.46.2.5  nathanw 
     37        1.6  thorpej #include "fs_nfs.h"
     38        1.5      mrg #include "opt_uvmhist.h"
     39       1.16      mrg #include "opt_compat_netbsd.h"
     40       1.41      chs #include "opt_ddb.h"
     41        1.1      mrg 
     42        1.1      mrg #include <sys/param.h>
     43        1.1      mrg #include <sys/systm.h>
     44        1.1      mrg #include <sys/buf.h>
     45       1.36      mrg #include <sys/conf.h>
     46   1.46.2.1  nathanw #include <sys/lwp.h>
     47        1.1      mrg #include <sys/proc.h>
     48        1.1      mrg #include <sys/namei.h>
     49        1.1      mrg #include <sys/disklabel.h>
     50        1.1      mrg #include <sys/errno.h>
     51        1.1      mrg #include <sys/kernel.h>
     52        1.1      mrg #include <sys/malloc.h>
     53        1.1      mrg #include <sys/vnode.h>
     54        1.1      mrg #include <sys/file.h>
     55        1.1      mrg #include <sys/extent.h>
     56        1.1      mrg #include <sys/mount.h>
     57       1.12       pk #include <sys/pool.h>
     58   1.46.2.9  nathanw #include <sys/sa.h>
     59        1.1      mrg #include <sys/syscallargs.h>
     60       1.17      mrg #include <sys/swap.h>
     61        1.1      mrg 
     62        1.1      mrg #include <uvm/uvm.h>
     63        1.1      mrg 
     64        1.1      mrg #include <miscfs/specfs/specdev.h>
     65        1.1      mrg 
     66        1.1      mrg /*
     67        1.1      mrg  * uvm_swap.c: manage configuration and i/o to swap space.
     68        1.1      mrg  */
     69        1.1      mrg 
     70        1.1      mrg /*
     71        1.1      mrg  * swap space is managed in the following way:
     72   1.46.2.3  nathanw  *
     73        1.1      mrg  * each swap partition or file is described by a "swapdev" structure.
     74        1.1      mrg  * each "swapdev" structure contains a "swapent" structure which contains
     75        1.1      mrg  * information that is passed up to the user (via system calls).
     76        1.1      mrg  *
     77        1.1      mrg  * each swap partition is assigned a "priority" (int) which controls
     78        1.1      mrg  * swap parition usage.
     79        1.1      mrg  *
     80        1.1      mrg  * the system maintains a global data structure describing all swap
     81        1.1      mrg  * partitions/files.   there is a sorted LIST of "swappri" structures
     82        1.1      mrg  * which describe "swapdev"'s at that priority.   this LIST is headed
     83   1.46.2.3  nathanw  * by the "swap_priority" global var.    each "swappri" contains a
     84        1.1      mrg  * CIRCLEQ of "swapdev" structures at that priority.
     85        1.1      mrg  *
     86        1.1      mrg  * locking:
     87        1.1      mrg  *  - swap_syscall_lock (sleep lock): this lock serializes the swapctl
     88        1.1      mrg  *    system call and prevents the swap priority list from changing
     89        1.1      mrg  *    while we are in the middle of a system call (e.g. SWAP_STATS).
     90       1.26      chs  *  - uvm.swap_data_lock (simple_lock): this lock protects all swap data
     91        1.1      mrg  *    structures including the priority list, the swapdev structures,
     92        1.1      mrg  *    and the swapmap extent.
     93        1.1      mrg  *
     94        1.1      mrg  * each swap device has the following info:
     95        1.1      mrg  *  - swap device in use (could be disabled, preventing future use)
     96        1.1      mrg  *  - swap enabled (allows new allocations on swap)
     97        1.1      mrg  *  - map info in /dev/drum
     98        1.1      mrg  *  - vnode pointer
     99        1.1      mrg  * for swap files only:
    100        1.1      mrg  *  - block size
    101        1.1      mrg  *  - max byte count in buffer
    102        1.1      mrg  *  - buffer
    103        1.1      mrg  *
    104        1.1      mrg  * userland controls and configures swap with the swapctl(2) system call.
    105        1.1      mrg  * the sys_swapctl performs the following operations:
    106        1.1      mrg  *  [1] SWAP_NSWAP: returns the number of swap devices currently configured
    107   1.46.2.3  nathanw  *  [2] SWAP_STATS: given a pointer to an array of swapent structures
    108        1.1      mrg  *	(passed in via "arg") of a size passed in via "misc" ... we load
    109   1.46.2.8  nathanw  *	the current swap config into the array. The actual work is done
    110   1.46.2.8  nathanw  *	in the uvm_swap_stats(9) function.
    111        1.1      mrg  *  [3] SWAP_ON: given a pathname in arg (could be device or file) and a
    112        1.1      mrg  *	priority in "misc", start swapping on it.
    113        1.1      mrg  *  [4] SWAP_OFF: as SWAP_ON, but stops swapping to a device
    114        1.1      mrg  *  [5] SWAP_CTL: changes the priority of a swap device (new priority in
    115        1.1      mrg  *	"misc")
    116        1.1      mrg  */
    117        1.1      mrg 
    118        1.1      mrg /*
    119        1.1      mrg  * swapdev: describes a single swap partition/file
    120        1.1      mrg  *
    121        1.1      mrg  * note the following should be true:
    122        1.1      mrg  * swd_inuse <= swd_nblks  [number of blocks in use is <= total blocks]
    123        1.1      mrg  * swd_nblks <= swd_mapsize [because mapsize includes miniroot+disklabel]
    124        1.1      mrg  */
    125        1.1      mrg struct swapdev {
    126       1.16      mrg 	struct oswapent swd_ose;
    127       1.16      mrg #define	swd_dev		swd_ose.ose_dev		/* device id */
    128       1.16      mrg #define	swd_flags	swd_ose.ose_flags	/* flags:inuse/enable/fake */
    129       1.16      mrg #define	swd_priority	swd_ose.ose_priority	/* our priority */
    130       1.16      mrg 	/* also: swd_ose.ose_nblks, swd_ose.ose_inuse */
    131       1.16      mrg 	char			*swd_path;	/* saved pathname of device */
    132       1.16      mrg 	int			swd_pathlen;	/* length of pathname */
    133       1.16      mrg 	int			swd_npages;	/* #pages we can use */
    134       1.16      mrg 	int			swd_npginuse;	/* #pages in use */
    135       1.32      chs 	int			swd_npgbad;	/* #pages bad */
    136       1.16      mrg 	int			swd_drumoffset;	/* page0 offset in drum */
    137       1.16      mrg 	int			swd_drumsize;	/* #pages in drum */
    138       1.16      mrg 	struct extent		*swd_ex;	/* extent for this swapdev */
    139       1.42    enami 	char			swd_exname[12];	/* name of extent above */
    140       1.16      mrg 	struct vnode		*swd_vp;	/* backing vnode */
    141       1.16      mrg 	CIRCLEQ_ENTRY(swapdev)	swd_next;	/* priority circleq */
    142        1.1      mrg 
    143       1.16      mrg 	int			swd_bsize;	/* blocksize (bytes) */
    144       1.16      mrg 	int			swd_maxactive;	/* max active i/o reqs */
    145       1.33  thorpej 	struct buf_queue	swd_tab;	/* buffer list */
    146       1.33  thorpej 	int			swd_active;	/* number of active buffers */
    147        1.1      mrg };
    148        1.1      mrg 
    149        1.1      mrg /*
    150        1.1      mrg  * swap device priority entry; the list is kept sorted on `spi_priority'.
    151        1.1      mrg  */
    152        1.1      mrg struct swappri {
    153        1.1      mrg 	int			spi_priority;     /* priority */
    154        1.1      mrg 	CIRCLEQ_HEAD(spi_swapdev, swapdev)	spi_swapdev;
    155        1.1      mrg 	/* circleq of swapdevs at this priority */
    156        1.1      mrg 	LIST_ENTRY(swappri)	spi_swappri;      /* global list of pri's */
    157        1.1      mrg };
    158        1.1      mrg 
    159        1.1      mrg /*
    160        1.1      mrg  * The following two structures are used to keep track of data transfers
    161        1.1      mrg  * on swap devices associated with regular files.
    162        1.1      mrg  * NOTE: this code is more or less a copy of vnd.c; we use the same
    163        1.1      mrg  * structure names here to ease porting..
    164        1.1      mrg  */
    165        1.1      mrg struct vndxfer {
    166        1.1      mrg 	struct buf	*vx_bp;		/* Pointer to parent buffer */
    167        1.1      mrg 	struct swapdev	*vx_sdp;
    168        1.1      mrg 	int		vx_error;
    169        1.1      mrg 	int		vx_pending;	/* # of pending aux buffers */
    170        1.1      mrg 	int		vx_flags;
    171        1.1      mrg #define VX_BUSY		1
    172        1.1      mrg #define VX_DEAD		2
    173        1.1      mrg };
    174        1.1      mrg 
    175        1.1      mrg struct vndbuf {
    176        1.1      mrg 	struct buf	vb_buf;
    177        1.1      mrg 	struct vndxfer	*vb_xfer;
    178        1.1      mrg };
    179        1.1      mrg 
    180       1.12       pk 
    181        1.1      mrg /*
    182       1.12       pk  * We keep a of pool vndbuf's and vndxfer structures.
    183        1.1      mrg  */
    184   1.46.2.3  nathanw static struct pool vndxfer_pool;
    185   1.46.2.3  nathanw static struct pool vndbuf_pool;
    186        1.1      mrg 
    187       1.12       pk #define	getvndxfer(vnx)	do {						\
    188       1.12       pk 	int s = splbio();						\
    189   1.46.2.7  nathanw 	vnx = pool_get(&vndxfer_pool, PR_WAITOK);			\
    190       1.12       pk 	splx(s);							\
    191       1.12       pk } while (0)
    192       1.12       pk 
    193       1.12       pk #define putvndxfer(vnx) {						\
    194   1.46.2.3  nathanw 	pool_put(&vndxfer_pool, (void *)(vnx));				\
    195       1.12       pk }
    196       1.12       pk 
    197       1.12       pk #define	getvndbuf(vbp)	do {						\
    198       1.12       pk 	int s = splbio();						\
    199   1.46.2.7  nathanw 	vbp = pool_get(&vndbuf_pool, PR_WAITOK);			\
    200       1.12       pk 	splx(s);							\
    201       1.12       pk } while (0)
    202        1.1      mrg 
    203       1.12       pk #define putvndbuf(vbp) {						\
    204   1.46.2.3  nathanw 	pool_put(&vndbuf_pool, (void *)(vbp));				\
    205       1.12       pk }
    206        1.1      mrg 
    207       1.36      mrg /* /dev/drum */
    208       1.36      mrg bdev_decl(sw);
    209       1.36      mrg cdev_decl(sw);
    210        1.1      mrg 
    211        1.1      mrg /*
    212        1.1      mrg  * local variables
    213        1.1      mrg  */
    214        1.1      mrg static struct extent *swapmap;		/* controls the mapping of /dev/drum */
    215        1.1      mrg 
    216        1.1      mrg /* list of all active swap devices [by priority] */
    217        1.1      mrg LIST_HEAD(swap_priority, swappri);
    218        1.1      mrg static struct swap_priority swap_priority;
    219        1.1      mrg 
    220        1.1      mrg /* locks */
    221   1.46.2.3  nathanw struct lock swap_syscall_lock;
    222        1.1      mrg 
    223        1.1      mrg /*
    224        1.1      mrg  * prototypes
    225        1.1      mrg  */
    226        1.1      mrg static struct swapdev	*swapdrum_getsdp __P((int));
    227        1.1      mrg 
    228        1.1      mrg static struct swapdev	*swaplist_find __P((struct vnode *, int));
    229   1.46.2.3  nathanw static void		 swaplist_insert __P((struct swapdev *,
    230        1.1      mrg 					     struct swappri *, int));
    231        1.1      mrg static void		 swaplist_trim __P((void));
    232        1.1      mrg 
    233        1.1      mrg static int swap_on __P((struct proc *, struct swapdev *));
    234        1.1      mrg static int swap_off __P((struct proc *, struct swapdev *));
    235        1.1      mrg 
    236        1.1      mrg static void sw_reg_strategy __P((struct swapdev *, struct buf *, int));
    237        1.1      mrg static void sw_reg_iodone __P((struct buf *));
    238        1.1      mrg static void sw_reg_start __P((struct swapdev *));
    239        1.1      mrg 
    240        1.1      mrg static int uvm_swap_io __P((struct vm_page **, int, int, int));
    241        1.1      mrg 
    242        1.1      mrg /*
    243        1.1      mrg  * uvm_swap_init: init the swap system data structures and locks
    244        1.1      mrg  *
    245   1.46.2.3  nathanw  * => called at boot time from init_main.c after the filesystems
    246        1.1      mrg  *	are brought up (which happens after uvm_init())
    247        1.1      mrg  */
    248        1.1      mrg void
    249        1.1      mrg uvm_swap_init()
    250        1.1      mrg {
    251        1.1      mrg 	UVMHIST_FUNC("uvm_swap_init");
    252        1.1      mrg 
    253        1.1      mrg 	UVMHIST_CALLED(pdhist);
    254        1.1      mrg 	/*
    255        1.1      mrg 	 * first, init the swap list, its counter, and its lock.
    256        1.1      mrg 	 * then get a handle on the vnode for /dev/drum by using
    257        1.1      mrg 	 * the its dev_t number ("swapdev", from MD conf.c).
    258        1.1      mrg 	 */
    259        1.1      mrg 
    260        1.1      mrg 	LIST_INIT(&swap_priority);
    261        1.1      mrg 	uvmexp.nswapdev = 0;
    262        1.1      mrg 	lockinit(&swap_syscall_lock, PVM, "swapsys", 0, 0);
    263       1.26      chs 	simple_lock_init(&uvm.swap_data_lock);
    264       1.12       pk 
    265        1.1      mrg 	if (bdevvp(swapdev, &swapdev_vp))
    266        1.1      mrg 		panic("uvm_swap_init: can't get vnode for swap device");
    267        1.1      mrg 
    268        1.1      mrg 	/*
    269        1.1      mrg 	 * create swap block resource map to map /dev/drum.   the range
    270        1.1      mrg 	 * from 1 to INT_MAX allows 2 gigablocks of swap space.  note
    271   1.46.2.3  nathanw 	 * that block 0 is reserved (used to indicate an allocation
    272        1.1      mrg 	 * failure, or no allocation).
    273        1.1      mrg 	 */
    274        1.1      mrg 	swapmap = extent_create("swapmap", 1, INT_MAX,
    275        1.1      mrg 				M_VMSWAP, 0, 0, EX_NOWAIT);
    276        1.1      mrg 	if (swapmap == 0)
    277        1.1      mrg 		panic("uvm_swap_init: extent_create failed");
    278        1.1      mrg 
    279        1.1      mrg 	/*
    280       1.41      chs 	 * allocate pools for structures used for swapping to files.
    281        1.1      mrg 	 */
    282        1.1      mrg 
    283   1.46.2.3  nathanw 	pool_init(&vndxfer_pool, sizeof(struct vndxfer), 0, 0, 0,
    284   1.46.2.7  nathanw 	    "swp vnx", NULL);
    285   1.46.2.3  nathanw 
    286   1.46.2.3  nathanw 	pool_init(&vndbuf_pool, sizeof(struct vndbuf), 0, 0, 0,
    287   1.46.2.7  nathanw 	    "swp vnd", NULL);
    288   1.46.2.3  nathanw 
    289        1.1      mrg 	/*
    290        1.1      mrg 	 * done!
    291        1.1      mrg 	 */
    292        1.1      mrg 	UVMHIST_LOG(pdhist, "<- done", 0, 0, 0, 0);
    293        1.1      mrg }
    294        1.1      mrg 
    295        1.1      mrg /*
    296        1.1      mrg  * swaplist functions: functions that operate on the list of swap
    297        1.1      mrg  * devices on the system.
    298        1.1      mrg  */
    299        1.1      mrg 
    300        1.1      mrg /*
    301        1.1      mrg  * swaplist_insert: insert swap device "sdp" into the global list
    302        1.1      mrg  *
    303       1.26      chs  * => caller must hold both swap_syscall_lock and uvm.swap_data_lock
    304        1.1      mrg  * => caller must provide a newly malloc'd swappri structure (we will
    305        1.1      mrg  *	FREE it if we don't need it... this it to prevent malloc blocking
    306        1.1      mrg  *	here while adding swap)
    307        1.1      mrg  */
    308        1.1      mrg static void
    309        1.1      mrg swaplist_insert(sdp, newspp, priority)
    310        1.1      mrg 	struct swapdev *sdp;
    311        1.1      mrg 	struct swappri *newspp;
    312        1.1      mrg 	int priority;
    313        1.1      mrg {
    314        1.1      mrg 	struct swappri *spp, *pspp;
    315        1.1      mrg 	UVMHIST_FUNC("swaplist_insert"); UVMHIST_CALLED(pdhist);
    316        1.1      mrg 
    317        1.1      mrg 	/*
    318        1.1      mrg 	 * find entry at or after which to insert the new device.
    319        1.1      mrg 	 */
    320   1.46.2.5  nathanw 	pspp = NULL;
    321   1.46.2.5  nathanw 	LIST_FOREACH(spp, &swap_priority, spi_swappri) {
    322        1.1      mrg 		if (priority <= spp->spi_priority)
    323        1.1      mrg 			break;
    324        1.1      mrg 		pspp = spp;
    325        1.1      mrg 	}
    326        1.1      mrg 
    327        1.1      mrg 	/*
    328        1.1      mrg 	 * new priority?
    329        1.1      mrg 	 */
    330        1.1      mrg 	if (spp == NULL || spp->spi_priority != priority) {
    331        1.1      mrg 		spp = newspp;  /* use newspp! */
    332       1.32      chs 		UVMHIST_LOG(pdhist, "created new swappri = %d",
    333       1.32      chs 			    priority, 0, 0, 0);
    334        1.1      mrg 
    335        1.1      mrg 		spp->spi_priority = priority;
    336        1.1      mrg 		CIRCLEQ_INIT(&spp->spi_swapdev);
    337        1.1      mrg 
    338        1.1      mrg 		if (pspp)
    339        1.1      mrg 			LIST_INSERT_AFTER(pspp, spp, spi_swappri);
    340        1.1      mrg 		else
    341        1.1      mrg 			LIST_INSERT_HEAD(&swap_priority, spp, spi_swappri);
    342        1.1      mrg 	} else {
    343        1.1      mrg 	  	/* we don't need a new priority structure, free it */
    344        1.1      mrg 		FREE(newspp, M_VMSWAP);
    345        1.1      mrg 	}
    346        1.1      mrg 
    347        1.1      mrg 	/*
    348        1.1      mrg 	 * priority found (or created).   now insert on the priority's
    349        1.1      mrg 	 * circleq list and bump the total number of swapdevs.
    350        1.1      mrg 	 */
    351        1.1      mrg 	sdp->swd_priority = priority;
    352        1.1      mrg 	CIRCLEQ_INSERT_TAIL(&spp->spi_swapdev, sdp, swd_next);
    353        1.1      mrg 	uvmexp.nswapdev++;
    354        1.1      mrg }
    355        1.1      mrg 
    356        1.1      mrg /*
    357        1.1      mrg  * swaplist_find: find and optionally remove a swap device from the
    358        1.1      mrg  *	global list.
    359        1.1      mrg  *
    360       1.26      chs  * => caller must hold both swap_syscall_lock and uvm.swap_data_lock
    361        1.1      mrg  * => we return the swapdev we found (and removed)
    362        1.1      mrg  */
    363        1.1      mrg static struct swapdev *
    364        1.1      mrg swaplist_find(vp, remove)
    365        1.1      mrg 	struct vnode *vp;
    366        1.1      mrg 	boolean_t remove;
    367        1.1      mrg {
    368        1.1      mrg 	struct swapdev *sdp;
    369        1.1      mrg 	struct swappri *spp;
    370        1.1      mrg 
    371        1.1      mrg 	/*
    372        1.1      mrg 	 * search the lists for the requested vp
    373        1.1      mrg 	 */
    374   1.46.2.5  nathanw 
    375   1.46.2.5  nathanw 	LIST_FOREACH(spp, &swap_priority, spi_swappri) {
    376   1.46.2.5  nathanw 		CIRCLEQ_FOREACH(sdp, &spp->spi_swapdev, swd_next) {
    377        1.1      mrg 			if (sdp->swd_vp == vp) {
    378        1.1      mrg 				if (remove) {
    379        1.1      mrg 					CIRCLEQ_REMOVE(&spp->spi_swapdev,
    380        1.1      mrg 					    sdp, swd_next);
    381        1.1      mrg 					uvmexp.nswapdev--;
    382        1.1      mrg 				}
    383        1.1      mrg 				return(sdp);
    384        1.1      mrg 			}
    385   1.46.2.5  nathanw 		}
    386        1.1      mrg 	}
    387        1.1      mrg 	return (NULL);
    388        1.1      mrg }
    389        1.1      mrg 
    390        1.1      mrg 
    391        1.1      mrg /*
    392        1.1      mrg  * swaplist_trim: scan priority list for empty priority entries and kill
    393        1.1      mrg  *	them.
    394        1.1      mrg  *
    395       1.26      chs  * => caller must hold both swap_syscall_lock and uvm.swap_data_lock
    396        1.1      mrg  */
    397        1.1      mrg static void
    398        1.1      mrg swaplist_trim()
    399        1.1      mrg {
    400        1.1      mrg 	struct swappri *spp, *nextspp;
    401        1.1      mrg 
    402       1.32      chs 	for (spp = LIST_FIRST(&swap_priority); spp != NULL; spp = nextspp) {
    403       1.32      chs 		nextspp = LIST_NEXT(spp, spi_swappri);
    404       1.32      chs 		if (CIRCLEQ_FIRST(&spp->spi_swapdev) !=
    405       1.32      chs 		    (void *)&spp->spi_swapdev)
    406        1.1      mrg 			continue;
    407        1.1      mrg 		LIST_REMOVE(spp, spi_swappri);
    408       1.32      chs 		free(spp, M_VMSWAP);
    409        1.1      mrg 	}
    410        1.1      mrg }
    411        1.1      mrg 
    412        1.1      mrg /*
    413        1.1      mrg  * swapdrum_getsdp: given a page offset in /dev/drum, convert it back
    414        1.1      mrg  *	to the "swapdev" that maps that section of the drum.
    415        1.1      mrg  *
    416        1.1      mrg  * => each swapdev takes one big contig chunk of the drum
    417       1.26      chs  * => caller must hold uvm.swap_data_lock
    418        1.1      mrg  */
    419        1.1      mrg static struct swapdev *
    420        1.1      mrg swapdrum_getsdp(pgno)
    421        1.1      mrg 	int pgno;
    422        1.1      mrg {
    423        1.1      mrg 	struct swapdev *sdp;
    424        1.1      mrg 	struct swappri *spp;
    425   1.46.2.3  nathanw 
    426   1.46.2.5  nathanw 	LIST_FOREACH(spp, &swap_priority, spi_swappri) {
    427   1.46.2.5  nathanw 		CIRCLEQ_FOREACH(sdp, &spp->spi_swapdev, swd_next) {
    428   1.46.2.3  nathanw 			if (sdp->swd_flags & SWF_FAKE)
    429   1.46.2.3  nathanw 				continue;
    430        1.1      mrg 			if (pgno >= sdp->swd_drumoffset &&
    431        1.1      mrg 			    pgno < (sdp->swd_drumoffset + sdp->swd_drumsize)) {
    432        1.1      mrg 				return sdp;
    433        1.1      mrg 			}
    434   1.46.2.3  nathanw 		}
    435   1.46.2.5  nathanw 	}
    436        1.1      mrg 	return NULL;
    437        1.1      mrg }
    438        1.1      mrg 
    439        1.1      mrg 
    440        1.1      mrg /*
    441        1.1      mrg  * sys_swapctl: main entry point for swapctl(2) system call
    442        1.1      mrg  * 	[with two helper functions: swap_on and swap_off]
    443        1.1      mrg  */
    444        1.1      mrg int
    445   1.46.2.1  nathanw sys_swapctl(l, v, retval)
    446   1.46.2.1  nathanw 	struct lwp *l;
    447        1.1      mrg 	void *v;
    448        1.1      mrg 	register_t *retval;
    449        1.1      mrg {
    450        1.1      mrg 	struct sys_swapctl_args /* {
    451        1.1      mrg 		syscallarg(int) cmd;
    452        1.1      mrg 		syscallarg(void *) arg;
    453        1.1      mrg 		syscallarg(int) misc;
    454        1.1      mrg 	} */ *uap = (struct sys_swapctl_args *)v;
    455   1.46.2.1  nathanw 	struct proc *p = l->l_proc;
    456        1.1      mrg 	struct vnode *vp;
    457        1.1      mrg 	struct nameidata nd;
    458        1.1      mrg 	struct swappri *spp;
    459        1.1      mrg 	struct swapdev *sdp;
    460        1.1      mrg 	struct swapent *sep;
    461       1.16      mrg 	char	userpath[PATH_MAX + 1];
    462       1.18    enami 	size_t	len;
    463   1.46.2.7  nathanw 	int	error, misc;
    464        1.1      mrg 	int	priority;
    465        1.1      mrg 	UVMHIST_FUNC("sys_swapctl"); UVMHIST_CALLED(pdhist);
    466        1.1      mrg 
    467        1.1      mrg 	misc = SCARG(uap, misc);
    468        1.1      mrg 
    469        1.1      mrg 	/*
    470        1.1      mrg 	 * ensure serialized syscall access by grabbing the swap_syscall_lock
    471        1.1      mrg 	 */
    472       1.32      chs 	lockmgr(&swap_syscall_lock, LK_EXCLUSIVE, NULL);
    473       1.24      mrg 
    474        1.1      mrg 	/*
    475        1.1      mrg 	 * we handle the non-priv NSWAP and STATS request first.
    476        1.1      mrg 	 *
    477   1.46.2.3  nathanw 	 * SWAP_NSWAP: return number of config'd swap devices
    478        1.1      mrg 	 * [can also be obtained with uvmexp sysctl]
    479        1.1      mrg 	 */
    480        1.1      mrg 	if (SCARG(uap, cmd) == SWAP_NSWAP) {
    481        1.8      mrg 		UVMHIST_LOG(pdhist, "<- done SWAP_NSWAP=%d", uvmexp.nswapdev,
    482        1.8      mrg 		    0, 0, 0);
    483        1.1      mrg 		*retval = uvmexp.nswapdev;
    484       1.16      mrg 		error = 0;
    485       1.16      mrg 		goto out;
    486        1.1      mrg 	}
    487        1.1      mrg 
    488        1.1      mrg 	/*
    489        1.1      mrg 	 * SWAP_STATS: get stats on current # of configured swap devs
    490        1.1      mrg 	 *
    491   1.46.2.3  nathanw 	 * note that the swap_priority list can't change as long
    492        1.1      mrg 	 * as we are holding the swap_syscall_lock.  we don't want
    493   1.46.2.3  nathanw 	 * to grab the uvm.swap_data_lock because we may fault&sleep during
    494        1.1      mrg 	 * copyout() and we don't want to be holding that lock then!
    495        1.1      mrg 	 */
    496       1.16      mrg 	if (SCARG(uap, cmd) == SWAP_STATS
    497       1.16      mrg #if defined(COMPAT_13)
    498       1.16      mrg 	    || SCARG(uap, cmd) == SWAP_OSTATS
    499       1.16      mrg #endif
    500       1.16      mrg 	    ) {
    501   1.46.2.7  nathanw 		misc = MIN(uvmexp.nswapdev, misc);
    502       1.16      mrg #if defined(COMPAT_13)
    503   1.46.2.7  nathanw 		if (SCARG(uap, cmd) == SWAP_OSTATS)
    504   1.46.2.7  nathanw 			len = sizeof(struct oswapent) * misc;
    505   1.46.2.7  nathanw 		else
    506       1.16      mrg #endif
    507   1.46.2.7  nathanw 			len = sizeof(struct swapent) * misc;
    508   1.46.2.7  nathanw 		sep = (struct swapent *)malloc(len, M_TEMP, M_WAITOK);
    509       1.16      mrg 
    510   1.46.2.7  nathanw 		uvm_swap_stats(SCARG(uap, cmd), sep, misc, retval);
    511   1.46.2.7  nathanw 		error = copyout(sep, (void *)SCARG(uap, arg), len);
    512        1.1      mrg 
    513   1.46.2.7  nathanw 		free(sep, M_TEMP);
    514       1.16      mrg 		UVMHIST_LOG(pdhist, "<- done SWAP_STATS", 0, 0, 0, 0);
    515       1.16      mrg 		goto out;
    516   1.46.2.3  nathanw 	}
    517       1.40      mrg 	if (SCARG(uap, cmd) == SWAP_GETDUMPDEV) {
    518       1.40      mrg 		dev_t	*devp = (dev_t *)SCARG(uap, arg);
    519       1.40      mrg 
    520       1.40      mrg 		error = copyout(&dumpdev, devp, sizeof(dumpdev));
    521       1.40      mrg 		goto out;
    522       1.40      mrg 	}
    523       1.40      mrg 
    524        1.1      mrg 	/*
    525   1.46.2.5  nathanw 	 * all other requests require superuser privs.   verify.
    526   1.46.2.5  nathanw 	 */
    527   1.46.2.5  nathanw 	if ((error = suser(p->p_ucred, &p->p_acflag)))
    528   1.46.2.5  nathanw 		goto out;
    529   1.46.2.5  nathanw 
    530   1.46.2.5  nathanw 	/*
    531        1.1      mrg 	 * at this point we expect a path name in arg.   we will
    532        1.1      mrg 	 * use namei() to gain a vnode reference (vref), and lock
    533        1.1      mrg 	 * the vnode (VOP_LOCK).
    534        1.1      mrg 	 *
    535        1.1      mrg 	 * XXX: a NULL arg means use the root vnode pointer (e.g. for
    536       1.16      mrg 	 * miniroot)
    537        1.1      mrg 	 */
    538        1.1      mrg 	if (SCARG(uap, arg) == NULL) {
    539        1.1      mrg 		vp = rootvp;		/* miniroot */
    540        1.7     fvdl 		if (vget(vp, LK_EXCLUSIVE)) {
    541       1.16      mrg 			error = EBUSY;
    542       1.16      mrg 			goto out;
    543        1.1      mrg 		}
    544       1.16      mrg 		if (SCARG(uap, cmd) == SWAP_ON &&
    545       1.16      mrg 		    copystr("miniroot", userpath, sizeof userpath, &len))
    546       1.16      mrg 			panic("swapctl: miniroot copy failed");
    547        1.1      mrg 	} else {
    548       1.16      mrg 		int	space;
    549       1.16      mrg 		char	*where;
    550       1.16      mrg 
    551       1.16      mrg 		if (SCARG(uap, cmd) == SWAP_ON) {
    552       1.16      mrg 			if ((error = copyinstr(SCARG(uap, arg), userpath,
    553       1.16      mrg 			    sizeof userpath, &len)))
    554       1.16      mrg 				goto out;
    555       1.16      mrg 			space = UIO_SYSSPACE;
    556       1.16      mrg 			where = userpath;
    557       1.16      mrg 		} else {
    558       1.16      mrg 			space = UIO_USERSPACE;
    559       1.16      mrg 			where = (char *)SCARG(uap, arg);
    560        1.1      mrg 		}
    561       1.16      mrg 		NDINIT(&nd, LOOKUP, FOLLOW|LOCKLEAF, space, where, p);
    562       1.16      mrg 		if ((error = namei(&nd)))
    563       1.16      mrg 			goto out;
    564        1.1      mrg 		vp = nd.ni_vp;
    565        1.1      mrg 	}
    566        1.1      mrg 	/* note: "vp" is referenced and locked */
    567        1.1      mrg 
    568        1.1      mrg 	error = 0;		/* assume no error */
    569        1.1      mrg 	switch(SCARG(uap, cmd)) {
    570       1.40      mrg 
    571       1.24      mrg 	case SWAP_DUMPDEV:
    572       1.24      mrg 		if (vp->v_type != VBLK) {
    573       1.24      mrg 			error = ENOTBLK;
    574       1.45       pk 			break;
    575       1.24      mrg 		}
    576       1.24      mrg 		dumpdev = vp->v_rdev;
    577       1.24      mrg 		break;
    578       1.24      mrg 
    579        1.1      mrg 	case SWAP_CTL:
    580        1.1      mrg 		/*
    581        1.1      mrg 		 * get new priority, remove old entry (if any) and then
    582        1.1      mrg 		 * reinsert it in the correct place.  finally, prune out
    583        1.1      mrg 		 * any empty priority structures.
    584        1.1      mrg 		 */
    585        1.1      mrg 		priority = SCARG(uap, misc);
    586       1.32      chs 		spp = malloc(sizeof *spp, M_VMSWAP, M_WAITOK);
    587       1.26      chs 		simple_lock(&uvm.swap_data_lock);
    588        1.1      mrg 		if ((sdp = swaplist_find(vp, 1)) == NULL) {
    589        1.1      mrg 			error = ENOENT;
    590        1.1      mrg 		} else {
    591        1.1      mrg 			swaplist_insert(sdp, spp, priority);
    592        1.1      mrg 			swaplist_trim();
    593        1.1      mrg 		}
    594       1.26      chs 		simple_unlock(&uvm.swap_data_lock);
    595        1.1      mrg 		if (error)
    596        1.1      mrg 			free(spp, M_VMSWAP);
    597        1.1      mrg 		break;
    598        1.1      mrg 
    599        1.1      mrg 	case SWAP_ON:
    600       1.32      chs 
    601        1.1      mrg 		/*
    602        1.1      mrg 		 * check for duplicates.   if none found, then insert a
    603        1.1      mrg 		 * dummy entry on the list to prevent someone else from
    604        1.1      mrg 		 * trying to enable this device while we are working on
    605        1.1      mrg 		 * it.
    606        1.1      mrg 		 */
    607       1.32      chs 
    608        1.1      mrg 		priority = SCARG(uap, misc);
    609   1.46.2.3  nathanw 		sdp = malloc(sizeof *sdp, M_VMSWAP, M_WAITOK);
    610   1.46.2.3  nathanw 		spp = malloc(sizeof *spp, M_VMSWAP, M_WAITOK);
    611       1.26      chs 		simple_lock(&uvm.swap_data_lock);
    612   1.46.2.3  nathanw 		if (swaplist_find(vp, 0) != NULL) {
    613        1.1      mrg 			error = EBUSY;
    614       1.26      chs 			simple_unlock(&uvm.swap_data_lock);
    615   1.46.2.3  nathanw 			free(sdp, M_VMSWAP);
    616   1.46.2.3  nathanw 			free(spp, M_VMSWAP);
    617       1.16      mrg 			break;
    618        1.1      mrg 		}
    619       1.14    perry 		memset(sdp, 0, sizeof(*sdp));
    620        1.1      mrg 		sdp->swd_flags = SWF_FAKE;	/* placeholder only */
    621        1.1      mrg 		sdp->swd_vp = vp;
    622        1.1      mrg 		sdp->swd_dev = (vp->v_type == VBLK) ? vp->v_rdev : NODEV;
    623       1.33  thorpej 		BUFQ_INIT(&sdp->swd_tab);
    624       1.32      chs 
    625        1.1      mrg 		swaplist_insert(sdp, spp, priority);
    626       1.26      chs 		simple_unlock(&uvm.swap_data_lock);
    627        1.1      mrg 
    628       1.16      mrg 		sdp->swd_pathlen = len;
    629       1.16      mrg 		sdp->swd_path = malloc(sdp->swd_pathlen, M_VMSWAP, M_WAITOK);
    630       1.19       pk 		if (copystr(userpath, sdp->swd_path, sdp->swd_pathlen, 0) != 0)
    631       1.19       pk 			panic("swapctl: copystr");
    632       1.32      chs 
    633        1.1      mrg 		/*
    634        1.1      mrg 		 * we've now got a FAKE placeholder in the swap list.
    635        1.1      mrg 		 * now attempt to enable swap on it.  if we fail, undo
    636        1.1      mrg 		 * what we've done and kill the fake entry we just inserted.
    637        1.1      mrg 		 * if swap_on is a success, it will clear the SWF_FAKE flag
    638        1.1      mrg 		 */
    639       1.32      chs 
    640        1.1      mrg 		if ((error = swap_on(p, sdp)) != 0) {
    641       1.26      chs 			simple_lock(&uvm.swap_data_lock);
    642        1.8      mrg 			(void) swaplist_find(vp, 1);  /* kill fake entry */
    643        1.1      mrg 			swaplist_trim();
    644       1.26      chs 			simple_unlock(&uvm.swap_data_lock);
    645       1.19       pk 			free(sdp->swd_path, M_VMSWAP);
    646       1.32      chs 			free(sdp, M_VMSWAP);
    647        1.1      mrg 			break;
    648        1.1      mrg 		}
    649        1.1      mrg 		break;
    650        1.1      mrg 
    651        1.1      mrg 	case SWAP_OFF:
    652       1.26      chs 		simple_lock(&uvm.swap_data_lock);
    653        1.1      mrg 		if ((sdp = swaplist_find(vp, 0)) == NULL) {
    654       1.26      chs 			simple_unlock(&uvm.swap_data_lock);
    655        1.1      mrg 			error = ENXIO;
    656        1.1      mrg 			break;
    657        1.1      mrg 		}
    658       1.32      chs 
    659        1.1      mrg 		/*
    660        1.1      mrg 		 * If a device isn't in use or enabled, we
    661        1.1      mrg 		 * can't stop swapping from it (again).
    662        1.1      mrg 		 */
    663        1.1      mrg 		if ((sdp->swd_flags & (SWF_INUSE|SWF_ENABLE)) == 0) {
    664       1.26      chs 			simple_unlock(&uvm.swap_data_lock);
    665        1.1      mrg 			error = EBUSY;
    666       1.16      mrg 			break;
    667        1.1      mrg 		}
    668        1.1      mrg 
    669        1.1      mrg 		/*
    670       1.32      chs 		 * do the real work.
    671        1.1      mrg 		 */
    672       1.45       pk 		error = swap_off(p, sdp);
    673        1.1      mrg 		break;
    674        1.1      mrg 
    675        1.1      mrg 	default:
    676        1.1      mrg 		error = EINVAL;
    677        1.1      mrg 	}
    678        1.1      mrg 
    679        1.1      mrg 	/*
    680       1.39      chs 	 * done!  release the ref gained by namei() and unlock.
    681        1.1      mrg 	 */
    682        1.1      mrg 	vput(vp);
    683       1.39      chs 
    684       1.16      mrg out:
    685       1.32      chs 	lockmgr(&swap_syscall_lock, LK_RELEASE, NULL);
    686        1.1      mrg 
    687        1.1      mrg 	UVMHIST_LOG(pdhist, "<- done!  error=%d", error, 0, 0, 0);
    688        1.1      mrg 	return (error);
    689   1.46.2.7  nathanw }
    690   1.46.2.7  nathanw 
    691   1.46.2.7  nathanw /*
    692   1.46.2.7  nathanw  * swap_stats: implements swapctl(SWAP_STATS). The function is kept
    693   1.46.2.7  nathanw  * away from sys_swapctl() in order to allow COMPAT_* swapctl()
    694   1.46.2.7  nathanw  * emulation to use it directly without going through sys_swapctl().
    695   1.46.2.7  nathanw  * The problem with using sys_swapctl() there is that it involves
    696   1.46.2.7  nathanw  * copying the swapent array to the stackgap, and this array's size
    697   1.46.2.7  nathanw  * is not known at build time. Hence it would not be possible to
    698   1.46.2.7  nathanw  * ensure it would fit in the stackgap in any case.
    699   1.46.2.7  nathanw  */
    700   1.46.2.7  nathanw void
    701   1.46.2.7  nathanw uvm_swap_stats(cmd, sep, sec, retval)
    702   1.46.2.7  nathanw 	int cmd;
    703   1.46.2.7  nathanw 	struct swapent *sep;
    704   1.46.2.7  nathanw 	int sec;
    705   1.46.2.7  nathanw 	register_t *retval;
    706   1.46.2.7  nathanw {
    707   1.46.2.7  nathanw 	struct swappri *spp;
    708   1.46.2.7  nathanw 	struct swapdev *sdp;
    709   1.46.2.7  nathanw 	int count = 0;
    710   1.46.2.7  nathanw 
    711   1.46.2.7  nathanw 	LIST_FOREACH(spp, &swap_priority, spi_swappri) {
    712   1.46.2.7  nathanw 		for (sdp = CIRCLEQ_FIRST(&spp->spi_swapdev);
    713   1.46.2.7  nathanw 		     sdp != (void *)&spp->spi_swapdev && sec-- > 0;
    714   1.46.2.7  nathanw 		     sdp = CIRCLEQ_NEXT(sdp, swd_next)) {
    715   1.46.2.7  nathanw 		  	/*
    716   1.46.2.7  nathanw 			 * backwards compatibility for system call.
    717   1.46.2.7  nathanw 			 * note that we use 'struct oswapent' as an
    718   1.46.2.7  nathanw 			 * overlay into both 'struct swapdev' and
    719   1.46.2.7  nathanw 			 * the userland 'struct swapent', as we
    720   1.46.2.7  nathanw 			 * want to retain backwards compatibility
    721   1.46.2.7  nathanw 			 * with NetBSD 1.3.
    722   1.46.2.7  nathanw 			 */
    723   1.46.2.7  nathanw 			sdp->swd_ose.ose_inuse =
    724   1.46.2.7  nathanw 			    btodb((u_int64_t)sdp->swd_npginuse <<
    725   1.46.2.7  nathanw 			    PAGE_SHIFT);
    726   1.46.2.7  nathanw 			(void)memcpy(sep, &sdp->swd_ose,
    727   1.46.2.7  nathanw 			    sizeof(struct oswapent));
    728   1.46.2.7  nathanw 
    729   1.46.2.7  nathanw 			/* now copy out the path if necessary */
    730   1.46.2.7  nathanw #if defined(COMPAT_13)
    731   1.46.2.7  nathanw 			if (cmd == SWAP_STATS)
    732   1.46.2.7  nathanw #endif
    733   1.46.2.7  nathanw 				(void)memcpy(&sep->se_path, sdp->swd_path,
    734   1.46.2.7  nathanw 				    sdp->swd_pathlen);
    735   1.46.2.7  nathanw 
    736   1.46.2.7  nathanw 			count++;
    737   1.46.2.7  nathanw #if defined(COMPAT_13)
    738   1.46.2.7  nathanw 			if (cmd == SWAP_OSTATS)
    739   1.46.2.7  nathanw 				sep = (struct swapent *)
    740   1.46.2.7  nathanw 				    ((struct oswapent *)sep + 1);
    741   1.46.2.7  nathanw 			else
    742   1.46.2.7  nathanw #endif
    743   1.46.2.7  nathanw 				sep++;
    744   1.46.2.7  nathanw 		}
    745   1.46.2.7  nathanw 	}
    746   1.46.2.7  nathanw 
    747   1.46.2.7  nathanw 	*retval = count;
    748   1.46.2.7  nathanw 	return;
    749        1.1      mrg }
    750        1.1      mrg 
    751        1.1      mrg /*
    752        1.1      mrg  * swap_on: attempt to enable a swapdev for swapping.   note that the
    753        1.1      mrg  *	swapdev is already on the global list, but disabled (marked
    754        1.1      mrg  *	SWF_FAKE).
    755        1.1      mrg  *
    756        1.1      mrg  * => we avoid the start of the disk (to protect disk labels)
    757        1.1      mrg  * => we also avoid the miniroot, if we are swapping to root.
    758       1.26      chs  * => caller should leave uvm.swap_data_lock unlocked, we may lock it
    759        1.1      mrg  *	if needed.
    760        1.1      mrg  */
    761        1.1      mrg static int
    762        1.1      mrg swap_on(p, sdp)
    763        1.1      mrg 	struct proc *p;
    764        1.1      mrg 	struct swapdev *sdp;
    765        1.1      mrg {
    766        1.1      mrg 	static int count = 0;	/* static */
    767        1.1      mrg 	struct vnode *vp;
    768        1.1      mrg 	int error, npages, nblocks, size;
    769        1.1      mrg 	long addr;
    770   1.46.2.3  nathanw 	u_long result;
    771        1.1      mrg 	struct vattr va;
    772        1.1      mrg #ifdef NFS
    773        1.1      mrg 	extern int (**nfsv2_vnodeop_p) __P((void *));
    774        1.1      mrg #endif /* NFS */
    775        1.1      mrg 	dev_t dev;
    776        1.1      mrg 	UVMHIST_FUNC("swap_on"); UVMHIST_CALLED(pdhist);
    777        1.1      mrg 
    778        1.1      mrg 	/*
    779        1.1      mrg 	 * we want to enable swapping on sdp.   the swd_vp contains
    780        1.1      mrg 	 * the vnode we want (locked and ref'd), and the swd_dev
    781        1.1      mrg 	 * contains the dev_t of the file, if it a block device.
    782        1.1      mrg 	 */
    783        1.1      mrg 
    784        1.1      mrg 	vp = sdp->swd_vp;
    785        1.1      mrg 	dev = sdp->swd_dev;
    786        1.1      mrg 
    787        1.1      mrg 	/*
    788        1.1      mrg 	 * open the swap file (mostly useful for block device files to
    789        1.1      mrg 	 * let device driver know what is up).
    790        1.1      mrg 	 *
    791        1.1      mrg 	 * we skip the open/close for root on swap because the root
    792        1.1      mrg 	 * has already been opened when root was mounted (mountroot).
    793        1.1      mrg 	 */
    794        1.1      mrg 	if (vp != rootvp) {
    795        1.1      mrg 		if ((error = VOP_OPEN(vp, FREAD|FWRITE, p->p_ucred, p)))
    796        1.1      mrg 			return (error);
    797        1.1      mrg 	}
    798        1.1      mrg 
    799        1.1      mrg 	/* XXX this only works for block devices */
    800        1.1      mrg 	UVMHIST_LOG(pdhist, "  dev=%d, major(dev)=%d", dev, major(dev), 0,0);
    801        1.1      mrg 
    802        1.1      mrg 	/*
    803        1.1      mrg 	 * we now need to determine the size of the swap area.   for
    804        1.1      mrg 	 * block specials we can call the d_psize function.
    805        1.1      mrg 	 * for normal files, we must stat [get attrs].
    806        1.1      mrg 	 *
    807        1.1      mrg 	 * we put the result in nblks.
    808        1.1      mrg 	 * for normal files, we also want the filesystem block size
    809        1.1      mrg 	 * (which we get with statfs).
    810        1.1      mrg 	 */
    811        1.1      mrg 	switch (vp->v_type) {
    812        1.1      mrg 	case VBLK:
    813        1.1      mrg 		if (bdevsw[major(dev)].d_psize == 0 ||
    814        1.1      mrg 		    (nblocks = (*bdevsw[major(dev)].d_psize)(dev)) == -1) {
    815        1.1      mrg 			error = ENXIO;
    816        1.1      mrg 			goto bad;
    817        1.1      mrg 		}
    818        1.1      mrg 		break;
    819        1.1      mrg 
    820        1.1      mrg 	case VREG:
    821        1.1      mrg 		if ((error = VOP_GETATTR(vp, &va, p->p_ucred, p)))
    822        1.1      mrg 			goto bad;
    823        1.1      mrg 		nblocks = (int)btodb(va.va_size);
    824        1.1      mrg 		if ((error =
    825        1.1      mrg 		     VFS_STATFS(vp->v_mount, &vp->v_mount->mnt_stat, p)) != 0)
    826        1.1      mrg 			goto bad;
    827        1.1      mrg 
    828        1.1      mrg 		sdp->swd_bsize = vp->v_mount->mnt_stat.f_iosize;
    829        1.1      mrg 		/*
    830        1.1      mrg 		 * limit the max # of outstanding I/O requests we issue
    831        1.1      mrg 		 * at any one time.   take it easy on NFS servers.
    832        1.1      mrg 		 */
    833        1.1      mrg #ifdef NFS
    834        1.1      mrg 		if (vp->v_op == nfsv2_vnodeop_p)
    835        1.1      mrg 			sdp->swd_maxactive = 2; /* XXX */
    836        1.1      mrg 		else
    837        1.1      mrg #endif /* NFS */
    838        1.1      mrg 			sdp->swd_maxactive = 8; /* XXX */
    839        1.1      mrg 		break;
    840        1.1      mrg 
    841        1.1      mrg 	default:
    842        1.1      mrg 		error = ENXIO;
    843        1.1      mrg 		goto bad;
    844        1.1      mrg 	}
    845        1.1      mrg 
    846        1.1      mrg 	/*
    847        1.1      mrg 	 * save nblocks in a safe place and convert to pages.
    848        1.1      mrg 	 */
    849        1.1      mrg 
    850       1.16      mrg 	sdp->swd_ose.ose_nblks = nblocks;
    851       1.20      chs 	npages = dbtob((u_int64_t)nblocks) >> PAGE_SHIFT;
    852        1.1      mrg 
    853        1.1      mrg 	/*
    854        1.1      mrg 	 * for block special files, we want to make sure that leave
    855        1.1      mrg 	 * the disklabel and bootblocks alone, so we arrange to skip
    856       1.32      chs 	 * over them (arbitrarily choosing to skip PAGE_SIZE bytes).
    857        1.1      mrg 	 * note that because of this the "size" can be less than the
    858        1.1      mrg 	 * actual number of blocks on the device.
    859        1.1      mrg 	 */
    860        1.1      mrg 	if (vp->v_type == VBLK) {
    861        1.1      mrg 		/* we use pages 1 to (size - 1) [inclusive] */
    862        1.1      mrg 		size = npages - 1;
    863        1.1      mrg 		addr = 1;
    864        1.1      mrg 	} else {
    865        1.1      mrg 		/* we use pages 0 to (size - 1) [inclusive] */
    866        1.1      mrg 		size = npages;
    867        1.1      mrg 		addr = 0;
    868        1.1      mrg 	}
    869        1.1      mrg 
    870        1.1      mrg 	/*
    871        1.1      mrg 	 * make sure we have enough blocks for a reasonable sized swap
    872        1.1      mrg 	 * area.   we want at least one page.
    873        1.1      mrg 	 */
    874        1.1      mrg 
    875        1.1      mrg 	if (size < 1) {
    876        1.1      mrg 		UVMHIST_LOG(pdhist, "  size <= 1!!", 0, 0, 0, 0);
    877        1.1      mrg 		error = EINVAL;
    878        1.1      mrg 		goto bad;
    879        1.1      mrg 	}
    880        1.1      mrg 
    881        1.1      mrg 	UVMHIST_LOG(pdhist, "  dev=%x: size=%d addr=%ld\n", dev, size, addr, 0);
    882        1.1      mrg 
    883        1.1      mrg 	/*
    884        1.1      mrg 	 * now we need to allocate an extent to manage this swap device
    885        1.1      mrg 	 */
    886       1.42    enami 	snprintf(sdp->swd_exname, sizeof(sdp->swd_exname), "swap0x%04x",
    887       1.42    enami 	    count++);
    888        1.1      mrg 
    889        1.1      mrg 	/* note that extent_create's 3rd arg is inclusive, thus "- 1" */
    890       1.42    enami 	sdp->swd_ex = extent_create(sdp->swd_exname, 0, npages - 1, M_VMSWAP,
    891       1.12       pk 				    0, 0, EX_WAITOK);
    892        1.1      mrg 	/* allocate the `saved' region from the extent so it won't be used */
    893        1.1      mrg 	if (addr) {
    894        1.1      mrg 		if (extent_alloc_region(sdp->swd_ex, 0, addr, EX_WAITOK))
    895        1.1      mrg 			panic("disklabel region");
    896        1.1      mrg 	}
    897        1.1      mrg 
    898        1.1      mrg 	/*
    899   1.46.2.3  nathanw 	 * if the vnode we are swapping to is the root vnode
    900        1.1      mrg 	 * (i.e. we are swapping to the miniroot) then we want
    901   1.46.2.3  nathanw 	 * to make sure we don't overwrite it.   do a statfs to
    902        1.1      mrg 	 * find its size and skip over it.
    903        1.1      mrg 	 */
    904        1.1      mrg 	if (vp == rootvp) {
    905        1.1      mrg 		struct mount *mp;
    906        1.1      mrg 		struct statfs *sp;
    907        1.1      mrg 		int rootblocks, rootpages;
    908        1.1      mrg 
    909        1.1      mrg 		mp = rootvnode->v_mount;
    910        1.1      mrg 		sp = &mp->mnt_stat;
    911        1.1      mrg 		rootblocks = sp->f_blocks * btodb(sp->f_bsize);
    912  1.46.2.10  nathanw 		/*
    913  1.46.2.10  nathanw 		 * XXX: sp->f_blocks isn't the total number of
    914  1.46.2.10  nathanw 		 * blocks in the filesystem, it's the number of
    915  1.46.2.10  nathanw 		 * data blocks.  so, our rootblocks almost
    916  1.46.2.10  nathanw 		 * definitely underestimates the total size
    917  1.46.2.10  nathanw 		 * of the filesystem - how badly depends on the
    918  1.46.2.10  nathanw 		 * details of the filesystem type.  there isn't
    919  1.46.2.10  nathanw 		 * an obvious way to deal with this cleanly
    920  1.46.2.10  nathanw 		 * and perfectly, so for now we just pad our
    921  1.46.2.10  nathanw 		 * rootblocks estimate with an extra 5 percent.
    922  1.46.2.10  nathanw 		 */
    923  1.46.2.10  nathanw 		rootblocks += (rootblocks >> 5) +
    924  1.46.2.10  nathanw 			(rootblocks >> 6) +
    925  1.46.2.10  nathanw 			(rootblocks >> 7);
    926       1.20      chs 		rootpages = round_page(dbtob(rootblocks)) >> PAGE_SHIFT;
    927       1.32      chs 		if (rootpages > size)
    928        1.1      mrg 			panic("swap_on: miniroot larger than swap?");
    929        1.1      mrg 
    930   1.46.2.3  nathanw 		if (extent_alloc_region(sdp->swd_ex, addr,
    931        1.1      mrg 					rootpages, EX_WAITOK))
    932        1.1      mrg 			panic("swap_on: unable to preserve miniroot");
    933        1.1      mrg 
    934       1.32      chs 		size -= rootpages;
    935        1.1      mrg 		printf("Preserved %d pages of miniroot ", rootpages);
    936       1.32      chs 		printf("leaving %d pages of swap\n", size);
    937        1.1      mrg 	}
    938        1.1      mrg 
    939       1.43      chs   	/*
    940       1.43      chs 	 * try to add anons to reflect the new swap space.
    941       1.43      chs 	 */
    942       1.43      chs 
    943       1.43      chs 	error = uvm_anon_add(size);
    944       1.43      chs 	if (error) {
    945       1.43      chs 		goto bad;
    946       1.43      chs 	}
    947       1.43      chs 
    948       1.39      chs 	/*
    949       1.39      chs 	 * add a ref to vp to reflect usage as a swap device.
    950       1.39      chs 	 */
    951       1.39      chs 	vref(vp);
    952       1.39      chs 
    953        1.1      mrg 	/*
    954        1.1      mrg 	 * now add the new swapdev to the drum and enable.
    955        1.1      mrg 	 */
    956   1.46.2.3  nathanw 	if (extent_alloc(swapmap, npages, EX_NOALIGN, EX_NOBOUNDARY,
    957   1.46.2.3  nathanw 	    EX_WAITOK, &result))
    958   1.46.2.3  nathanw 		panic("swapdrum_add");
    959   1.46.2.3  nathanw 
    960   1.46.2.3  nathanw 	sdp->swd_drumoffset = (int)result;
    961   1.46.2.3  nathanw 	sdp->swd_drumsize = npages;
    962       1.32      chs 	sdp->swd_npages = size;
    963   1.46.2.3  nathanw 	simple_lock(&uvm.swap_data_lock);
    964        1.1      mrg 	sdp->swd_flags &= ~SWF_FAKE;	/* going live */
    965        1.1      mrg 	sdp->swd_flags |= (SWF_INUSE|SWF_ENABLE);
    966       1.32      chs 	uvmexp.swpages += size;
    967       1.26      chs 	simple_unlock(&uvm.swap_data_lock);
    968        1.1      mrg 	return (0);
    969        1.1      mrg 
    970        1.1      mrg 	/*
    971       1.43      chs 	 * failure: clean up and return error.
    972        1.1      mrg 	 */
    973       1.43      chs 
    974       1.43      chs bad:
    975       1.43      chs 	if (sdp->swd_ex) {
    976       1.43      chs 		extent_destroy(sdp->swd_ex);
    977       1.43      chs 	}
    978       1.43      chs 	if (vp != rootvp) {
    979        1.1      mrg 		(void)VOP_CLOSE(vp, FREAD|FWRITE, p->p_ucred, p);
    980       1.43      chs 	}
    981        1.1      mrg 	return (error);
    982        1.1      mrg }
    983        1.1      mrg 
    984        1.1      mrg /*
    985        1.1      mrg  * swap_off: stop swapping on swapdev
    986        1.1      mrg  *
    987       1.32      chs  * => swap data should be locked, we will unlock.
    988        1.1      mrg  */
    989        1.1      mrg static int
    990        1.1      mrg swap_off(p, sdp)
    991        1.1      mrg 	struct proc *p;
    992        1.1      mrg 	struct swapdev *sdp;
    993        1.1      mrg {
    994        1.1      mrg 	UVMHIST_FUNC("swap_off"); UVMHIST_CALLED(pdhist);
    995       1.32      chs 	UVMHIST_LOG(pdhist, "  dev=%x", sdp->swd_dev,0,0,0);
    996        1.1      mrg 
    997       1.32      chs 	/* disable the swap area being removed */
    998        1.1      mrg 	sdp->swd_flags &= ~SWF_ENABLE;
    999       1.32      chs 	simple_unlock(&uvm.swap_data_lock);
   1000       1.32      chs 
   1001       1.32      chs 	/*
   1002       1.32      chs 	 * the idea is to find all the pages that are paged out to this
   1003       1.32      chs 	 * device, and page them all in.  in uvm, swap-backed pageable
   1004       1.32      chs 	 * memory can take two forms: aobjs and anons.  call the
   1005       1.32      chs 	 * swapoff hook for each subsystem to bring in pages.
   1006       1.32      chs 	 */
   1007        1.1      mrg 
   1008       1.32      chs 	if (uao_swap_off(sdp->swd_drumoffset,
   1009       1.32      chs 			 sdp->swd_drumoffset + sdp->swd_drumsize) ||
   1010       1.32      chs 	    anon_swap_off(sdp->swd_drumoffset,
   1011       1.32      chs 			  sdp->swd_drumoffset + sdp->swd_drumsize)) {
   1012   1.46.2.3  nathanw 
   1013       1.32      chs 		simple_lock(&uvm.swap_data_lock);
   1014       1.32      chs 		sdp->swd_flags |= SWF_ENABLE;
   1015       1.32      chs 		simple_unlock(&uvm.swap_data_lock);
   1016       1.32      chs 		return ENOMEM;
   1017       1.32      chs 	}
   1018       1.46      chs 	KASSERT(sdp->swd_npginuse == sdp->swd_npgbad);
   1019        1.1      mrg 
   1020        1.1      mrg 	/*
   1021   1.46.2.6  nathanw 	 * done with the vnode.
   1022       1.39      chs 	 * drop our ref on the vnode before calling VOP_CLOSE()
   1023       1.39      chs 	 * so that spec_close() can tell if this is the last close.
   1024        1.1      mrg 	 */
   1025       1.39      chs 	vrele(sdp->swd_vp);
   1026       1.32      chs 	if (sdp->swd_vp != rootvp) {
   1027       1.32      chs 		(void) VOP_CLOSE(sdp->swd_vp, FREAD|FWRITE, p->p_ucred, p);
   1028       1.32      chs 	}
   1029       1.32      chs 
   1030       1.32      chs 	/* remove anons from the system */
   1031       1.32      chs 	uvm_anon_remove(sdp->swd_npages);
   1032       1.32      chs 
   1033       1.32      chs 	simple_lock(&uvm.swap_data_lock);
   1034       1.32      chs 	uvmexp.swpages -= sdp->swd_npages;
   1035        1.1      mrg 
   1036       1.32      chs 	if (swaplist_find(sdp->swd_vp, 1) == NULL)
   1037       1.32      chs 		panic("swap_off: swapdev not in list\n");
   1038       1.32      chs 	swaplist_trim();
   1039   1.46.2.3  nathanw 	simple_unlock(&uvm.swap_data_lock);
   1040        1.1      mrg 
   1041       1.32      chs 	/*
   1042       1.32      chs 	 * free all resources!
   1043       1.32      chs 	 */
   1044       1.32      chs 	extent_free(swapmap, sdp->swd_drumoffset, sdp->swd_drumsize,
   1045       1.32      chs 		    EX_WAITOK);
   1046        1.1      mrg 	extent_destroy(sdp->swd_ex);
   1047       1.32      chs 	free(sdp, M_VMSWAP);
   1048        1.1      mrg 	return (0);
   1049        1.1      mrg }
   1050        1.1      mrg 
   1051        1.1      mrg /*
   1052        1.1      mrg  * /dev/drum interface and i/o functions
   1053        1.1      mrg  */
   1054        1.1      mrg 
   1055        1.1      mrg /*
   1056        1.1      mrg  * swread: the read function for the drum (just a call to physio)
   1057        1.1      mrg  */
   1058        1.1      mrg /*ARGSUSED*/
   1059        1.1      mrg int
   1060        1.1      mrg swread(dev, uio, ioflag)
   1061        1.1      mrg 	dev_t dev;
   1062        1.1      mrg 	struct uio *uio;
   1063        1.1      mrg 	int ioflag;
   1064        1.1      mrg {
   1065        1.1      mrg 	UVMHIST_FUNC("swread"); UVMHIST_CALLED(pdhist);
   1066        1.1      mrg 
   1067        1.1      mrg 	UVMHIST_LOG(pdhist, "  dev=%x offset=%qx", dev, uio->uio_offset, 0, 0);
   1068        1.1      mrg 	return (physio(swstrategy, NULL, dev, B_READ, minphys, uio));
   1069        1.1      mrg }
   1070        1.1      mrg 
   1071        1.1      mrg /*
   1072        1.1      mrg  * swwrite: the write function for the drum (just a call to physio)
   1073        1.1      mrg  */
   1074        1.1      mrg /*ARGSUSED*/
   1075        1.1      mrg int
   1076        1.1      mrg swwrite(dev, uio, ioflag)
   1077        1.1      mrg 	dev_t dev;
   1078        1.1      mrg 	struct uio *uio;
   1079        1.1      mrg 	int ioflag;
   1080        1.1      mrg {
   1081        1.1      mrg 	UVMHIST_FUNC("swwrite"); UVMHIST_CALLED(pdhist);
   1082        1.1      mrg 
   1083        1.1      mrg 	UVMHIST_LOG(pdhist, "  dev=%x offset=%qx", dev, uio->uio_offset, 0, 0);
   1084        1.1      mrg 	return (physio(swstrategy, NULL, dev, B_WRITE, minphys, uio));
   1085        1.1      mrg }
   1086        1.1      mrg 
   1087        1.1      mrg /*
   1088        1.1      mrg  * swstrategy: perform I/O on the drum
   1089        1.1      mrg  *
   1090        1.1      mrg  * => we must map the i/o request from the drum to the correct swapdev.
   1091        1.1      mrg  */
   1092        1.1      mrg void
   1093        1.1      mrg swstrategy(bp)
   1094        1.1      mrg 	struct buf *bp;
   1095        1.1      mrg {
   1096        1.1      mrg 	struct swapdev *sdp;
   1097        1.1      mrg 	struct vnode *vp;
   1098       1.25      chs 	int s, pageno, bn;
   1099        1.1      mrg 	UVMHIST_FUNC("swstrategy"); UVMHIST_CALLED(pdhist);
   1100        1.1      mrg 
   1101        1.1      mrg 	/*
   1102        1.1      mrg 	 * convert block number to swapdev.   note that swapdev can't
   1103        1.1      mrg 	 * be yanked out from under us because we are holding resources
   1104        1.1      mrg 	 * in it (i.e. the blocks we are doing I/O on).
   1105        1.1      mrg 	 */
   1106       1.41      chs 	pageno = dbtob((int64_t)bp->b_blkno) >> PAGE_SHIFT;
   1107       1.26      chs 	simple_lock(&uvm.swap_data_lock);
   1108        1.1      mrg 	sdp = swapdrum_getsdp(pageno);
   1109       1.26      chs 	simple_unlock(&uvm.swap_data_lock);
   1110        1.1      mrg 	if (sdp == NULL) {
   1111        1.1      mrg 		bp->b_error = EINVAL;
   1112        1.1      mrg 		bp->b_flags |= B_ERROR;
   1113        1.1      mrg 		biodone(bp);
   1114        1.1      mrg 		UVMHIST_LOG(pdhist, "  failed to get swap device", 0, 0, 0, 0);
   1115        1.1      mrg 		return;
   1116        1.1      mrg 	}
   1117        1.1      mrg 
   1118        1.1      mrg 	/*
   1119        1.1      mrg 	 * convert drum page number to block number on this swapdev.
   1120        1.1      mrg 	 */
   1121        1.1      mrg 
   1122       1.32      chs 	pageno -= sdp->swd_drumoffset;	/* page # on swapdev */
   1123       1.44    enami 	bn = btodb((u_int64_t)pageno << PAGE_SHIFT); /* convert to diskblock */
   1124        1.1      mrg 
   1125       1.41      chs 	UVMHIST_LOG(pdhist, "  %s: mapoff=%x bn=%x bcount=%ld",
   1126        1.1      mrg 		((bp->b_flags & B_READ) == 0) ? "write" : "read",
   1127        1.1      mrg 		sdp->swd_drumoffset, bn, bp->b_bcount);
   1128        1.1      mrg 
   1129        1.1      mrg 	/*
   1130        1.1      mrg 	 * for block devices we finish up here.
   1131       1.32      chs 	 * for regular files we have to do more work which we delegate
   1132        1.1      mrg 	 * to sw_reg_strategy().
   1133        1.1      mrg 	 */
   1134        1.1      mrg 
   1135        1.1      mrg 	switch (sdp->swd_vp->v_type) {
   1136        1.1      mrg 	default:
   1137        1.1      mrg 		panic("swstrategy: vnode type 0x%x", sdp->swd_vp->v_type);
   1138       1.32      chs 
   1139        1.1      mrg 	case VBLK:
   1140        1.1      mrg 
   1141        1.1      mrg 		/*
   1142        1.1      mrg 		 * must convert "bp" from an I/O on /dev/drum to an I/O
   1143        1.1      mrg 		 * on the swapdev (sdp).
   1144        1.1      mrg 		 */
   1145       1.25      chs 		s = splbio();
   1146        1.1      mrg 		bp->b_blkno = bn;		/* swapdev block number */
   1147        1.1      mrg 		vp = sdp->swd_vp;		/* swapdev vnode pointer */
   1148        1.1      mrg 		bp->b_dev = sdp->swd_dev;	/* swapdev dev_t */
   1149        1.1      mrg 
   1150        1.1      mrg 		/*
   1151        1.1      mrg 		 * if we are doing a write, we have to redirect the i/o on
   1152        1.1      mrg 		 * drum's v_numoutput counter to the swapdevs.
   1153        1.1      mrg 		 */
   1154        1.1      mrg 		if ((bp->b_flags & B_READ) == 0) {
   1155        1.1      mrg 			vwakeup(bp);	/* kills one 'v_numoutput' on drum */
   1156        1.1      mrg 			vp->v_numoutput++;	/* put it on swapdev */
   1157        1.1      mrg 		}
   1158        1.1      mrg 
   1159       1.41      chs 		/*
   1160        1.1      mrg 		 * finally plug in swapdev vnode and start I/O
   1161        1.1      mrg 		 */
   1162        1.1      mrg 		bp->b_vp = vp;
   1163       1.25      chs 		splx(s);
   1164        1.1      mrg 		VOP_STRATEGY(bp);
   1165        1.1      mrg 		return;
   1166       1.32      chs 
   1167        1.1      mrg 	case VREG:
   1168        1.1      mrg 		/*
   1169       1.32      chs 		 * delegate to sw_reg_strategy function.
   1170        1.1      mrg 		 */
   1171        1.1      mrg 		sw_reg_strategy(sdp, bp, bn);
   1172        1.1      mrg 		return;
   1173        1.1      mrg 	}
   1174        1.1      mrg 	/* NOTREACHED */
   1175        1.1      mrg }
   1176        1.1      mrg 
   1177        1.1      mrg /*
   1178        1.1      mrg  * sw_reg_strategy: handle swap i/o to regular files
   1179        1.1      mrg  */
   1180        1.1      mrg static void
   1181        1.1      mrg sw_reg_strategy(sdp, bp, bn)
   1182        1.1      mrg 	struct swapdev	*sdp;
   1183        1.1      mrg 	struct buf	*bp;
   1184        1.1      mrg 	int		bn;
   1185        1.1      mrg {
   1186        1.1      mrg 	struct vnode	*vp;
   1187        1.1      mrg 	struct vndxfer	*vnx;
   1188       1.44    enami 	daddr_t		nbn;
   1189        1.1      mrg 	caddr_t		addr;
   1190       1.44    enami 	off_t		byteoff;
   1191        1.9      mrg 	int		s, off, nra, error, sz, resid;
   1192        1.1      mrg 	UVMHIST_FUNC("sw_reg_strategy"); UVMHIST_CALLED(pdhist);
   1193        1.1      mrg 
   1194        1.1      mrg 	/*
   1195        1.1      mrg 	 * allocate a vndxfer head for this transfer and point it to
   1196        1.1      mrg 	 * our buffer.
   1197        1.1      mrg 	 */
   1198       1.12       pk 	getvndxfer(vnx);
   1199        1.1      mrg 	vnx->vx_flags = VX_BUSY;
   1200        1.1      mrg 	vnx->vx_error = 0;
   1201        1.1      mrg 	vnx->vx_pending = 0;
   1202        1.1      mrg 	vnx->vx_bp = bp;
   1203        1.1      mrg 	vnx->vx_sdp = sdp;
   1204        1.1      mrg 
   1205        1.1      mrg 	/*
   1206        1.1      mrg 	 * setup for main loop where we read filesystem blocks into
   1207        1.1      mrg 	 * our buffer.
   1208        1.1      mrg 	 */
   1209        1.1      mrg 	error = 0;
   1210        1.1      mrg 	bp->b_resid = bp->b_bcount;	/* nothing transfered yet! */
   1211        1.1      mrg 	addr = bp->b_data;		/* current position in buffer */
   1212       1.44    enami 	byteoff = dbtob((u_int64_t)bn);
   1213        1.1      mrg 
   1214        1.1      mrg 	for (resid = bp->b_resid; resid; resid -= sz) {
   1215        1.1      mrg 		struct vndbuf	*nbp;
   1216        1.1      mrg 
   1217        1.1      mrg 		/*
   1218        1.1      mrg 		 * translate byteoffset into block number.  return values:
   1219        1.1      mrg 		 *   vp = vnode of underlying device
   1220        1.1      mrg 		 *  nbn = new block number (on underlying vnode dev)
   1221        1.1      mrg 		 *  nra = num blocks we can read-ahead (excludes requested
   1222        1.1      mrg 		 *	block)
   1223        1.1      mrg 		 */
   1224        1.1      mrg 		nra = 0;
   1225        1.1      mrg 		error = VOP_BMAP(sdp->swd_vp, byteoff / sdp->swd_bsize,
   1226        1.1      mrg 				 	&vp, &nbn, &nra);
   1227        1.1      mrg 
   1228       1.32      chs 		if (error == 0 && nbn == (daddr_t)-1) {
   1229   1.46.2.3  nathanw 			/*
   1230       1.23     marc 			 * this used to just set error, but that doesn't
   1231       1.23     marc 			 * do the right thing.  Instead, it causes random
   1232       1.23     marc 			 * memory errors.  The panic() should remain until
   1233       1.23     marc 			 * this condition doesn't destabilize the system.
   1234       1.23     marc 			 */
   1235       1.23     marc #if 1
   1236       1.23     marc 			panic("sw_reg_strategy: swap to sparse file");
   1237       1.23     marc #else
   1238        1.1      mrg 			error = EIO;	/* failure */
   1239       1.23     marc #endif
   1240       1.23     marc 		}
   1241        1.1      mrg 
   1242        1.1      mrg 		/*
   1243        1.1      mrg 		 * punt if there was an error or a hole in the file.
   1244        1.1      mrg 		 * we must wait for any i/o ops we have already started
   1245        1.1      mrg 		 * to finish before returning.
   1246        1.1      mrg 		 *
   1247        1.1      mrg 		 * XXX we could deal with holes here but it would be
   1248        1.1      mrg 		 * a hassle (in the write case).
   1249        1.1      mrg 		 */
   1250        1.1      mrg 		if (error) {
   1251        1.1      mrg 			s = splbio();
   1252        1.1      mrg 			vnx->vx_error = error;	/* pass error up */
   1253        1.1      mrg 			goto out;
   1254        1.1      mrg 		}
   1255        1.1      mrg 
   1256        1.1      mrg 		/*
   1257        1.1      mrg 		 * compute the size ("sz") of this transfer (in bytes).
   1258        1.1      mrg 		 */
   1259       1.41      chs 		off = byteoff % sdp->swd_bsize;
   1260       1.41      chs 		sz = (1 + nra) * sdp->swd_bsize - off;
   1261       1.41      chs 		if (sz > resid)
   1262        1.1      mrg 			sz = resid;
   1263        1.1      mrg 
   1264       1.41      chs 		UVMHIST_LOG(pdhist, "sw_reg_strategy: "
   1265       1.41      chs 			    "vp %p/%p offset 0x%x/0x%x",
   1266       1.41      chs 			    sdp->swd_vp, vp, byteoff, nbn);
   1267        1.1      mrg 
   1268        1.1      mrg 		/*
   1269        1.1      mrg 		 * now get a buf structure.   note that the vb_buf is
   1270        1.1      mrg 		 * at the front of the nbp structure so that you can
   1271        1.1      mrg 		 * cast pointers between the two structure easily.
   1272        1.1      mrg 		 */
   1273       1.12       pk 		getvndbuf(nbp);
   1274        1.1      mrg 		nbp->vb_buf.b_flags    = bp->b_flags | B_CALL;
   1275        1.1      mrg 		nbp->vb_buf.b_bcount   = sz;
   1276       1.12       pk 		nbp->vb_buf.b_bufsize  = sz;
   1277        1.1      mrg 		nbp->vb_buf.b_error    = 0;
   1278        1.1      mrg 		nbp->vb_buf.b_data     = addr;
   1279       1.41      chs 		nbp->vb_buf.b_lblkno   = 0;
   1280        1.1      mrg 		nbp->vb_buf.b_blkno    = nbn + btodb(off);
   1281       1.34  thorpej 		nbp->vb_buf.b_rawblkno = nbp->vb_buf.b_blkno;
   1282        1.1      mrg 		nbp->vb_buf.b_iodone   = sw_reg_iodone;
   1283   1.46.2.4  nathanw 		nbp->vb_buf.b_vp       = vp;
   1284   1.46.2.4  nathanw 		if (vp->v_type == VBLK) {
   1285   1.46.2.4  nathanw 			nbp->vb_buf.b_dev = vp->v_rdev;
   1286   1.46.2.4  nathanw 		}
   1287       1.30     fvdl 		LIST_INIT(&nbp->vb_buf.b_dep);
   1288        1.1      mrg 
   1289        1.1      mrg 		nbp->vb_xfer = vnx;	/* patch it back in to vnx */
   1290        1.1      mrg 
   1291        1.1      mrg 		/*
   1292        1.1      mrg 		 * Just sort by block number
   1293        1.1      mrg 		 */
   1294        1.1      mrg 		s = splbio();
   1295        1.1      mrg 		if (vnx->vx_error != 0) {
   1296        1.1      mrg 			putvndbuf(nbp);
   1297        1.1      mrg 			goto out;
   1298        1.1      mrg 		}
   1299        1.1      mrg 		vnx->vx_pending++;
   1300        1.1      mrg 
   1301        1.1      mrg 		/* sort it in and start I/O if we are not over our limit */
   1302       1.33  thorpej 		disksort_blkno(&sdp->swd_tab, &nbp->vb_buf);
   1303        1.1      mrg 		sw_reg_start(sdp);
   1304        1.1      mrg 		splx(s);
   1305        1.1      mrg 
   1306        1.1      mrg 		/*
   1307        1.1      mrg 		 * advance to the next I/O
   1308        1.1      mrg 		 */
   1309        1.9      mrg 		byteoff += sz;
   1310        1.1      mrg 		addr += sz;
   1311        1.1      mrg 	}
   1312        1.1      mrg 
   1313        1.1      mrg 	s = splbio();
   1314        1.1      mrg 
   1315        1.1      mrg out: /* Arrive here at splbio */
   1316        1.1      mrg 	vnx->vx_flags &= ~VX_BUSY;
   1317        1.1      mrg 	if (vnx->vx_pending == 0) {
   1318        1.1      mrg 		if (vnx->vx_error != 0) {
   1319        1.1      mrg 			bp->b_error = vnx->vx_error;
   1320        1.1      mrg 			bp->b_flags |= B_ERROR;
   1321        1.1      mrg 		}
   1322        1.1      mrg 		putvndxfer(vnx);
   1323        1.1      mrg 		biodone(bp);
   1324        1.1      mrg 	}
   1325        1.1      mrg 	splx(s);
   1326        1.1      mrg }
   1327        1.1      mrg 
   1328        1.1      mrg /*
   1329        1.1      mrg  * sw_reg_start: start an I/O request on the requested swapdev
   1330        1.1      mrg  *
   1331        1.1      mrg  * => reqs are sorted by disksort (above)
   1332        1.1      mrg  */
   1333        1.1      mrg static void
   1334        1.1      mrg sw_reg_start(sdp)
   1335        1.1      mrg 	struct swapdev	*sdp;
   1336        1.1      mrg {
   1337        1.1      mrg 	struct buf	*bp;
   1338        1.1      mrg 	UVMHIST_FUNC("sw_reg_start"); UVMHIST_CALLED(pdhist);
   1339        1.1      mrg 
   1340        1.8      mrg 	/* recursion control */
   1341        1.1      mrg 	if ((sdp->swd_flags & SWF_BUSY) != 0)
   1342        1.1      mrg 		return;
   1343        1.1      mrg 
   1344        1.1      mrg 	sdp->swd_flags |= SWF_BUSY;
   1345        1.1      mrg 
   1346       1.33  thorpej 	while (sdp->swd_active < sdp->swd_maxactive) {
   1347       1.33  thorpej 		bp = BUFQ_FIRST(&sdp->swd_tab);
   1348        1.1      mrg 		if (bp == NULL)
   1349        1.1      mrg 			break;
   1350       1.33  thorpej 		BUFQ_REMOVE(&sdp->swd_tab, bp);
   1351       1.33  thorpej 		sdp->swd_active++;
   1352        1.1      mrg 
   1353        1.1      mrg 		UVMHIST_LOG(pdhist,
   1354        1.1      mrg 		    "sw_reg_start:  bp %p vp %p blkno %p cnt %lx",
   1355        1.1      mrg 		    bp, bp->b_vp, bp->b_blkno, bp->b_bcount);
   1356        1.1      mrg 		if ((bp->b_flags & B_READ) == 0)
   1357        1.1      mrg 			bp->b_vp->v_numoutput++;
   1358       1.41      chs 
   1359        1.1      mrg 		VOP_STRATEGY(bp);
   1360        1.1      mrg 	}
   1361        1.1      mrg 	sdp->swd_flags &= ~SWF_BUSY;
   1362        1.1      mrg }
   1363        1.1      mrg 
   1364        1.1      mrg /*
   1365        1.1      mrg  * sw_reg_iodone: one of our i/o's has completed and needs post-i/o cleanup
   1366        1.1      mrg  *
   1367        1.1      mrg  * => note that we can recover the vndbuf struct by casting the buf ptr
   1368        1.1      mrg  */
   1369        1.1      mrg static void
   1370        1.1      mrg sw_reg_iodone(bp)
   1371        1.1      mrg 	struct buf *bp;
   1372        1.1      mrg {
   1373        1.1      mrg 	struct vndbuf *vbp = (struct vndbuf *) bp;
   1374        1.1      mrg 	struct vndxfer *vnx = vbp->vb_xfer;
   1375        1.1      mrg 	struct buf *pbp = vnx->vx_bp;		/* parent buffer */
   1376        1.1      mrg 	struct swapdev	*sdp = vnx->vx_sdp;
   1377        1.1      mrg 	int		s, resid;
   1378        1.1      mrg 	UVMHIST_FUNC("sw_reg_iodone"); UVMHIST_CALLED(pdhist);
   1379        1.1      mrg 
   1380        1.1      mrg 	UVMHIST_LOG(pdhist, "  vbp=%p vp=%p blkno=%x addr=%p",
   1381        1.1      mrg 	    vbp, vbp->vb_buf.b_vp, vbp->vb_buf.b_blkno, vbp->vb_buf.b_data);
   1382        1.1      mrg 	UVMHIST_LOG(pdhist, "  cnt=%lx resid=%lx",
   1383        1.1      mrg 	    vbp->vb_buf.b_bcount, vbp->vb_buf.b_resid, 0, 0);
   1384        1.1      mrg 
   1385        1.1      mrg 	/*
   1386        1.1      mrg 	 * protect vbp at splbio and update.
   1387        1.1      mrg 	 */
   1388        1.1      mrg 
   1389        1.1      mrg 	s = splbio();
   1390        1.1      mrg 	resid = vbp->vb_buf.b_bcount - vbp->vb_buf.b_resid;
   1391        1.1      mrg 	pbp->b_resid -= resid;
   1392        1.1      mrg 	vnx->vx_pending--;
   1393        1.1      mrg 
   1394        1.1      mrg 	if (vbp->vb_buf.b_error) {
   1395        1.1      mrg 		UVMHIST_LOG(pdhist, "  got error=%d !",
   1396        1.1      mrg 		    vbp->vb_buf.b_error, 0, 0, 0);
   1397        1.1      mrg 
   1398        1.1      mrg 		/* pass error upward */
   1399        1.1      mrg 		vnx->vx_error = vbp->vb_buf.b_error;
   1400       1.35      chs 	}
   1401       1.35      chs 
   1402       1.35      chs 	/*
   1403        1.1      mrg 	 * kill vbp structure
   1404        1.1      mrg 	 */
   1405        1.1      mrg 	putvndbuf(vbp);
   1406        1.1      mrg 
   1407        1.1      mrg 	/*
   1408        1.1      mrg 	 * wrap up this transaction if it has run to completion or, in
   1409        1.1      mrg 	 * case of an error, when all auxiliary buffers have returned.
   1410        1.1      mrg 	 */
   1411        1.1      mrg 	if (vnx->vx_error != 0) {
   1412        1.1      mrg 		/* pass error upward */
   1413        1.1      mrg 		pbp->b_flags |= B_ERROR;
   1414        1.1      mrg 		pbp->b_error = vnx->vx_error;
   1415        1.1      mrg 		if ((vnx->vx_flags & VX_BUSY) == 0 && vnx->vx_pending == 0) {
   1416        1.1      mrg 			putvndxfer(vnx);
   1417        1.1      mrg 			biodone(pbp);
   1418        1.1      mrg 		}
   1419       1.11       pk 	} else if (pbp->b_resid == 0) {
   1420       1.46      chs 		KASSERT(vnx->vx_pending == 0);
   1421        1.1      mrg 		if ((vnx->vx_flags & VX_BUSY) == 0) {
   1422        1.8      mrg 			UVMHIST_LOG(pdhist, "  iodone error=%d !",
   1423        1.8      mrg 			    pbp, vnx->vx_error, 0, 0);
   1424        1.8      mrg 			putvndxfer(vnx);
   1425        1.1      mrg 			biodone(pbp);
   1426        1.1      mrg 		}
   1427        1.1      mrg 	}
   1428        1.1      mrg 
   1429        1.1      mrg 	/*
   1430        1.1      mrg 	 * done!   start next swapdev I/O if one is pending
   1431        1.1      mrg 	 */
   1432       1.33  thorpej 	sdp->swd_active--;
   1433        1.1      mrg 	sw_reg_start(sdp);
   1434        1.1      mrg 	splx(s);
   1435        1.1      mrg }
   1436        1.1      mrg 
   1437        1.1      mrg 
   1438        1.1      mrg /*
   1439        1.1      mrg  * uvm_swap_alloc: allocate space on swap
   1440        1.1      mrg  *
   1441        1.1      mrg  * => allocation is done "round robin" down the priority list, as we
   1442        1.1      mrg  *	allocate in a priority we "rotate" the circle queue.
   1443        1.1      mrg  * => space can be freed with uvm_swap_free
   1444        1.1      mrg  * => we return the page slot number in /dev/drum (0 == invalid slot)
   1445       1.26      chs  * => we lock uvm.swap_data_lock
   1446        1.1      mrg  * => XXXMRG: "LESSOK" INTERFACE NEEDED TO EXTENT SYSTEM
   1447        1.1      mrg  */
   1448        1.1      mrg int
   1449        1.1      mrg uvm_swap_alloc(nslots, lessok)
   1450        1.1      mrg 	int *nslots;	/* IN/OUT */
   1451        1.1      mrg 	boolean_t lessok;
   1452        1.1      mrg {
   1453        1.1      mrg 	struct swapdev *sdp;
   1454        1.1      mrg 	struct swappri *spp;
   1455        1.1      mrg 	u_long	result;
   1456        1.1      mrg 	UVMHIST_FUNC("uvm_swap_alloc"); UVMHIST_CALLED(pdhist);
   1457        1.1      mrg 
   1458        1.1      mrg 	/*
   1459        1.1      mrg 	 * no swap devices configured yet?   definite failure.
   1460        1.1      mrg 	 */
   1461        1.1      mrg 	if (uvmexp.nswapdev < 1)
   1462        1.1      mrg 		return 0;
   1463   1.46.2.3  nathanw 
   1464        1.1      mrg 	/*
   1465        1.1      mrg 	 * lock data lock, convert slots into blocks, and enter loop
   1466        1.1      mrg 	 */
   1467       1.26      chs 	simple_lock(&uvm.swap_data_lock);
   1468        1.1      mrg 
   1469        1.1      mrg ReTry:	/* XXXMRG */
   1470   1.46.2.5  nathanw 	LIST_FOREACH(spp, &swap_priority, spi_swappri) {
   1471   1.46.2.5  nathanw 		CIRCLEQ_FOREACH(sdp, &spp->spi_swapdev, swd_next) {
   1472        1.1      mrg 			/* if it's not enabled, then we can't swap from it */
   1473        1.1      mrg 			if ((sdp->swd_flags & SWF_ENABLE) == 0)
   1474        1.1      mrg 				continue;
   1475        1.1      mrg 			if (sdp->swd_npginuse + *nslots > sdp->swd_npages)
   1476        1.1      mrg 				continue;
   1477        1.1      mrg 			if (extent_alloc(sdp->swd_ex, *nslots, EX_NOALIGN,
   1478        1.1      mrg 					 EX_NOBOUNDARY, EX_MALLOCOK|EX_NOWAIT,
   1479        1.1      mrg 					 &result) != 0) {
   1480        1.1      mrg 				continue;
   1481        1.1      mrg 			}
   1482        1.1      mrg 
   1483        1.1      mrg 			/*
   1484        1.1      mrg 			 * successful allocation!  now rotate the circleq.
   1485        1.1      mrg 			 */
   1486        1.1      mrg 			CIRCLEQ_REMOVE(&spp->spi_swapdev, sdp, swd_next);
   1487        1.1      mrg 			CIRCLEQ_INSERT_TAIL(&spp->spi_swapdev, sdp, swd_next);
   1488        1.1      mrg 			sdp->swd_npginuse += *nslots;
   1489        1.1      mrg 			uvmexp.swpginuse += *nslots;
   1490       1.26      chs 			simple_unlock(&uvm.swap_data_lock);
   1491        1.1      mrg 			/* done!  return drum slot number */
   1492        1.1      mrg 			UVMHIST_LOG(pdhist,
   1493        1.1      mrg 			    "success!  returning %d slots starting at %d",
   1494        1.1      mrg 			    *nslots, result + sdp->swd_drumoffset, 0, 0);
   1495   1.46.2.5  nathanw 			return (result + sdp->swd_drumoffset);
   1496        1.1      mrg 		}
   1497        1.1      mrg 	}
   1498        1.1      mrg 
   1499        1.1      mrg 	/* XXXMRG: BEGIN HACK */
   1500        1.1      mrg 	if (*nslots > 1 && lessok) {
   1501        1.1      mrg 		*nslots = 1;
   1502        1.1      mrg 		goto ReTry;	/* XXXMRG: ugh!  extent should support this for us */
   1503        1.1      mrg 	}
   1504        1.1      mrg 	/* XXXMRG: END HACK */
   1505        1.1      mrg 
   1506       1.26      chs 	simple_unlock(&uvm.swap_data_lock);
   1507   1.46.2.5  nathanw 	return 0;
   1508        1.1      mrg }
   1509        1.1      mrg 
   1510        1.1      mrg /*
   1511       1.32      chs  * uvm_swap_markbad: keep track of swap ranges where we've had i/o errors
   1512       1.32      chs  *
   1513       1.32      chs  * => we lock uvm.swap_data_lock
   1514       1.32      chs  */
   1515       1.32      chs void
   1516       1.32      chs uvm_swap_markbad(startslot, nslots)
   1517       1.32      chs 	int startslot;
   1518       1.32      chs 	int nslots;
   1519       1.32      chs {
   1520       1.32      chs 	struct swapdev *sdp;
   1521       1.32      chs 	UVMHIST_FUNC("uvm_swap_markbad"); UVMHIST_CALLED(pdhist);
   1522       1.32      chs 
   1523       1.32      chs 	simple_lock(&uvm.swap_data_lock);
   1524       1.32      chs 	sdp = swapdrum_getsdp(startslot);
   1525       1.32      chs 
   1526       1.32      chs 	/*
   1527       1.32      chs 	 * we just keep track of how many pages have been marked bad
   1528       1.32      chs 	 * in this device, to make everything add up in swap_off().
   1529       1.32      chs 	 * we assume here that the range of slots will all be within
   1530       1.32      chs 	 * one swap device.
   1531       1.32      chs 	 */
   1532       1.41      chs 
   1533       1.32      chs 	sdp->swd_npgbad += nslots;
   1534       1.41      chs 	UVMHIST_LOG(pdhist, "now %d bad", sdp->swd_npgbad, 0,0,0);
   1535       1.32      chs 	simple_unlock(&uvm.swap_data_lock);
   1536       1.32      chs }
   1537       1.32      chs 
   1538       1.32      chs /*
   1539        1.1      mrg  * uvm_swap_free: free swap slots
   1540        1.1      mrg  *
   1541        1.1      mrg  * => this can be all or part of an allocation made by uvm_swap_alloc
   1542       1.26      chs  * => we lock uvm.swap_data_lock
   1543        1.1      mrg  */
   1544        1.1      mrg void
   1545        1.1      mrg uvm_swap_free(startslot, nslots)
   1546        1.1      mrg 	int startslot;
   1547        1.1      mrg 	int nslots;
   1548        1.1      mrg {
   1549        1.1      mrg 	struct swapdev *sdp;
   1550        1.1      mrg 	UVMHIST_FUNC("uvm_swap_free"); UVMHIST_CALLED(pdhist);
   1551        1.1      mrg 
   1552        1.1      mrg 	UVMHIST_LOG(pdhist, "freeing %d slots starting at %d", nslots,
   1553        1.1      mrg 	    startslot, 0, 0);
   1554       1.32      chs 
   1555       1.32      chs 	/*
   1556       1.32      chs 	 * ignore attempts to free the "bad" slot.
   1557       1.32      chs 	 */
   1558       1.46      chs 
   1559       1.32      chs 	if (startslot == SWSLOT_BAD) {
   1560       1.32      chs 		return;
   1561       1.32      chs 	}
   1562       1.32      chs 
   1563        1.1      mrg 	/*
   1564   1.46.2.3  nathanw 	 * convert drum slot offset back to sdp, free the blocks
   1565   1.46.2.3  nathanw 	 * in the extent, and return.   must hold pri lock to do
   1566        1.1      mrg 	 * lookup and access the extent.
   1567        1.1      mrg 	 */
   1568       1.46      chs 
   1569       1.26      chs 	simple_lock(&uvm.swap_data_lock);
   1570        1.1      mrg 	sdp = swapdrum_getsdp(startslot);
   1571       1.46      chs 	KASSERT(uvmexp.nswapdev >= 1);
   1572       1.46      chs 	KASSERT(sdp != NULL);
   1573       1.46      chs 	KASSERT(sdp->swd_npginuse >= nslots);
   1574       1.12       pk 	if (extent_free(sdp->swd_ex, startslot - sdp->swd_drumoffset, nslots,
   1575       1.32      chs 			EX_MALLOCOK|EX_NOWAIT) != 0) {
   1576       1.32      chs 		printf("warning: resource shortage: %d pages of swap lost\n",
   1577       1.12       pk 			nslots);
   1578       1.32      chs 	}
   1579        1.1      mrg 	sdp->swd_npginuse -= nslots;
   1580        1.1      mrg 	uvmexp.swpginuse -= nslots;
   1581       1.26      chs 	simple_unlock(&uvm.swap_data_lock);
   1582        1.1      mrg }
   1583        1.1      mrg 
   1584        1.1      mrg /*
   1585        1.1      mrg  * uvm_swap_put: put any number of pages into a contig place on swap
   1586        1.1      mrg  *
   1587        1.1      mrg  * => can be sync or async
   1588        1.1      mrg  */
   1589   1.46.2.4  nathanw 
   1590        1.1      mrg int
   1591        1.1      mrg uvm_swap_put(swslot, ppsp, npages, flags)
   1592        1.1      mrg 	int swslot;
   1593        1.1      mrg 	struct vm_page **ppsp;
   1594   1.46.2.4  nathanw 	int npages;
   1595   1.46.2.4  nathanw 	int flags;
   1596        1.1      mrg {
   1597   1.46.2.5  nathanw 	int error;
   1598        1.1      mrg 
   1599   1.46.2.5  nathanw 	error = uvm_swap_io(ppsp, swslot, npages, B_WRITE |
   1600        1.1      mrg 	    ((flags & PGO_SYNCIO) ? 0 : B_ASYNC));
   1601   1.46.2.5  nathanw 	return error;
   1602        1.1      mrg }
   1603        1.1      mrg 
   1604        1.1      mrg /*
   1605        1.1      mrg  * uvm_swap_get: get a single page from swap
   1606        1.1      mrg  *
   1607        1.1      mrg  * => usually a sync op (from fault)
   1608        1.1      mrg  */
   1609   1.46.2.4  nathanw 
   1610        1.1      mrg int
   1611        1.1      mrg uvm_swap_get(page, swslot, flags)
   1612        1.1      mrg 	struct vm_page *page;
   1613        1.1      mrg 	int swslot, flags;
   1614        1.1      mrg {
   1615   1.46.2.5  nathanw 	int error;
   1616        1.1      mrg 
   1617        1.1      mrg 	uvmexp.nswget++;
   1618       1.46      chs 	KASSERT(flags & PGO_SYNCIO);
   1619       1.32      chs 	if (swslot == SWSLOT_BAD) {
   1620   1.46.2.2  nathanw 		return EIO;
   1621       1.32      chs 	}
   1622   1.46.2.5  nathanw 	error = uvm_swap_io(&page, swslot, 1, B_READ |
   1623        1.1      mrg 	    ((flags & PGO_SYNCIO) ? 0 : B_ASYNC));
   1624   1.46.2.5  nathanw 	if (error == 0) {
   1625   1.46.2.2  nathanw 
   1626       1.26      chs 		/*
   1627   1.46.2.4  nathanw 		 * this page is no longer only in swap.
   1628       1.26      chs 		 */
   1629   1.46.2.2  nathanw 
   1630       1.26      chs 		simple_lock(&uvm.swap_data_lock);
   1631   1.46.2.5  nathanw 		KASSERT(uvmexp.swpgonly > 0);
   1632   1.46.2.4  nathanw 		uvmexp.swpgonly--;
   1633       1.26      chs 		simple_unlock(&uvm.swap_data_lock);
   1634       1.26      chs 	}
   1635   1.46.2.5  nathanw 	return error;
   1636        1.1      mrg }
   1637        1.1      mrg 
   1638        1.1      mrg /*
   1639        1.1      mrg  * uvm_swap_io: do an i/o operation to swap
   1640        1.1      mrg  */
   1641        1.1      mrg 
   1642        1.1      mrg static int
   1643        1.1      mrg uvm_swap_io(pps, startslot, npages, flags)
   1644        1.1      mrg 	struct vm_page **pps;
   1645        1.1      mrg 	int startslot, npages, flags;
   1646        1.1      mrg {
   1647        1.1      mrg 	daddr_t startblk;
   1648        1.1      mrg 	struct	buf *bp;
   1649       1.15      eeh 	vaddr_t kva;
   1650   1.46.2.4  nathanw 	int	error, s, mapinflags;
   1651       1.41      chs 	boolean_t write, async;
   1652        1.1      mrg 	UVMHIST_FUNC("uvm_swap_io"); UVMHIST_CALLED(pdhist);
   1653        1.1      mrg 
   1654        1.1      mrg 	UVMHIST_LOG(pdhist, "<- called, startslot=%d, npages=%d, flags=%d",
   1655        1.1      mrg 	    startslot, npages, flags, 0);
   1656       1.32      chs 
   1657       1.41      chs 	write = (flags & B_READ) == 0;
   1658       1.41      chs 	async = (flags & B_ASYNC) != 0;
   1659       1.41      chs 
   1660        1.1      mrg 	/*
   1661        1.1      mrg 	 * convert starting drum slot to block number
   1662        1.1      mrg 	 */
   1663   1.46.2.4  nathanw 
   1664       1.44    enami 	startblk = btodb((u_int64_t)startslot << PAGE_SHIFT);
   1665        1.1      mrg 
   1666        1.1      mrg 	/*
   1667   1.46.2.4  nathanw 	 * first, map the pages into the kernel.
   1668       1.41      chs 	 */
   1669       1.41      chs 
   1670   1.46.2.4  nathanw 	mapinflags = !write ?
   1671   1.46.2.4  nathanw 		UVMPAGER_MAPIN_WAITOK|UVMPAGER_MAPIN_READ :
   1672   1.46.2.4  nathanw 		UVMPAGER_MAPIN_WAITOK|UVMPAGER_MAPIN_WRITE;
   1673       1.41      chs 	kva = uvm_pagermapin(pps, npages, mapinflags);
   1674        1.1      mrg 
   1675   1.46.2.3  nathanw 	/*
   1676       1.41      chs 	 * now allocate a buf for the i/o.
   1677        1.1      mrg 	 */
   1678   1.46.2.4  nathanw 
   1679        1.1      mrg 	s = splbio();
   1680   1.46.2.4  nathanw 	bp = pool_get(&bufpool, PR_WAITOK);
   1681       1.41      chs 	splx(s);
   1682        1.1      mrg 
   1683        1.1      mrg 	/*
   1684        1.1      mrg 	 * fill in the bp/sbp.   we currently route our i/o through
   1685        1.1      mrg 	 * /dev/drum's vnode [swapdev_vp].
   1686        1.1      mrg 	 */
   1687   1.46.2.4  nathanw 
   1688       1.21  mycroft 	bp->b_flags = B_BUSY | B_NOCACHE | (flags & (B_READ|B_ASYNC));
   1689        1.1      mrg 	bp->b_proc = &proc0;	/* XXX */
   1690       1.12       pk 	bp->b_vnbufs.le_next = NOLIST;
   1691        1.1      mrg 	bp->b_data = (caddr_t)kva;
   1692        1.1      mrg 	bp->b_blkno = startblk;
   1693        1.1      mrg 	bp->b_vp = swapdev_vp;
   1694   1.46.2.4  nathanw 	bp->b_dev = swapdev_vp->v_rdev;
   1695       1.41      chs 	bp->b_bufsize = bp->b_bcount = npages << PAGE_SHIFT;
   1696       1.30     fvdl 	LIST_INIT(&bp->b_dep);
   1697        1.1      mrg 
   1698   1.46.2.3  nathanw 	/*
   1699       1.41      chs 	 * bump v_numoutput (counter of number of active outputs).
   1700        1.1      mrg 	 */
   1701   1.46.2.4  nathanw 
   1702       1.41      chs 	if (write) {
   1703        1.1      mrg 		s = splbio();
   1704        1.1      mrg 		swapdev_vp->v_numoutput++;
   1705        1.1      mrg 		splx(s);
   1706        1.1      mrg 	}
   1707        1.1      mrg 
   1708        1.1      mrg 	/*
   1709       1.41      chs 	 * for async ops we must set up the iodone handler.
   1710        1.1      mrg 	 */
   1711   1.46.2.4  nathanw 
   1712       1.41      chs 	if (async) {
   1713   1.46.2.4  nathanw 		bp->b_flags |= B_CALL;
   1714       1.41      chs 		bp->b_iodone = uvm_aio_biodone;
   1715        1.1      mrg 		UVMHIST_LOG(pdhist, "doing async!", 0, 0, 0, 0);
   1716        1.1      mrg 	}
   1717        1.1      mrg 	UVMHIST_LOG(pdhist,
   1718       1.41      chs 	    "about to start io: data = %p blkno = 0x%x, bcount = %ld",
   1719        1.1      mrg 	    bp->b_data, bp->b_blkno, bp->b_bcount, 0);
   1720        1.1      mrg 
   1721        1.1      mrg 	/*
   1722        1.1      mrg 	 * now we start the I/O, and if async, return.
   1723        1.1      mrg 	 */
   1724   1.46.2.4  nathanw 
   1725        1.1      mrg 	VOP_STRATEGY(bp);
   1726       1.41      chs 	if (async)
   1727   1.46.2.2  nathanw 		return 0;
   1728        1.1      mrg 
   1729        1.1      mrg 	/*
   1730        1.1      mrg 	 * must be sync i/o.   wait for it to finish
   1731        1.1      mrg 	 */
   1732   1.46.2.4  nathanw 
   1733   1.46.2.2  nathanw 	error = biowait(bp);
   1734        1.1      mrg 
   1735        1.1      mrg 	/*
   1736        1.1      mrg 	 * kill the pager mapping
   1737        1.1      mrg 	 */
   1738   1.46.2.4  nathanw 
   1739        1.1      mrg 	uvm_pagermapout(kva, npages);
   1740        1.1      mrg 
   1741        1.1      mrg 	/*
   1742   1.46.2.4  nathanw 	 * now dispose of the buf and we're done.
   1743        1.1      mrg 	 */
   1744   1.46.2.4  nathanw 
   1745        1.1      mrg 	s = splbio();
   1746       1.41      chs 	if (write)
   1747       1.41      chs 		vwakeup(bp);
   1748       1.41      chs 	pool_put(&bufpool, bp);
   1749        1.1      mrg 	splx(s);
   1750   1.46.2.2  nathanw 	UVMHIST_LOG(pdhist, "<- done (sync)  error=%d", error, 0, 0, 0);
   1751   1.46.2.2  nathanw 	return (error);
   1752        1.1      mrg }
   1753