1df8bae1dSRodney W. Grimes /* 21c7c3c6aSMatthew Dillon * Copyright (c) 1998 Matthew Dillon, 326f9a767SRodney W. Grimes * Copyright (c) 1994 John S. Dyson 4df8bae1dSRodney W. Grimes * Copyright (c) 1990 University of Utah. 5df8bae1dSRodney W. Grimes * Copyright (c) 1991, 1993 6df8bae1dSRodney W. Grimes * The Regents of the University of California. All rights reserved. 7df8bae1dSRodney W. Grimes * 8df8bae1dSRodney W. Grimes * This code is derived from software contributed to Berkeley by 9df8bae1dSRodney W. Grimes * the Systems Programming Group of the University of Utah Computer 10df8bae1dSRodney W. Grimes * Science Department. 11df8bae1dSRodney W. Grimes * 12df8bae1dSRodney W. Grimes * Redistribution and use in source and binary forms, with or without 13df8bae1dSRodney W. Grimes * modification, are permitted provided that the following conditions 14df8bae1dSRodney W. Grimes * are met: 15df8bae1dSRodney W. Grimes * 1. Redistributions of source code must retain the above copyright 16df8bae1dSRodney W. Grimes * notice, this list of conditions and the following disclaimer. 17df8bae1dSRodney W. Grimes * 2. Redistributions in binary form must reproduce the above copyright 18df8bae1dSRodney W. Grimes * notice, this list of conditions and the following disclaimer in the 19df8bae1dSRodney W. Grimes * documentation and/or other materials provided with the distribution. 20df8bae1dSRodney W. Grimes * 3. All advertising materials mentioning features or use of this software 215929bcfaSPhilippe Charnier * must display the following acknowledgement: 22df8bae1dSRodney W. Grimes * This product includes software developed by the University of 23df8bae1dSRodney W. Grimes * California, Berkeley and its contributors. 24df8bae1dSRodney W. Grimes * 4. Neither the name of the University nor the names of its contributors 25df8bae1dSRodney W. Grimes * may be used to endorse or promote products derived from this software 26df8bae1dSRodney W. Grimes * without specific prior written permission. 27df8bae1dSRodney W. Grimes * 28df8bae1dSRodney W. Grimes * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 29df8bae1dSRodney W. Grimes * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 30df8bae1dSRodney W. Grimes * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 31df8bae1dSRodney W. Grimes * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 32df8bae1dSRodney W. Grimes * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 33df8bae1dSRodney W. Grimes * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 34df8bae1dSRodney W. Grimes * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 35df8bae1dSRodney W. Grimes * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 36df8bae1dSRodney W. Grimes * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 37df8bae1dSRodney W. Grimes * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 38df8bae1dSRodney W. Grimes * SUCH DAMAGE. 39df8bae1dSRodney W. Grimes * 401c7c3c6aSMatthew Dillon * New Swap System 411c7c3c6aSMatthew Dillon * Matthew Dillon 421c7c3c6aSMatthew Dillon * 431c7c3c6aSMatthew Dillon * Radix Bitmap 'blists'. 441c7c3c6aSMatthew Dillon * 451c7c3c6aSMatthew Dillon * - The new swapper uses the new radix bitmap code. This should scale 461c7c3c6aSMatthew Dillon * to arbitrarily small or arbitrarily large swap spaces and an almost 471c7c3c6aSMatthew Dillon * arbitrary degree of fragmentation. 481c7c3c6aSMatthew Dillon * 491c7c3c6aSMatthew Dillon * Features: 501c7c3c6aSMatthew Dillon * 511c7c3c6aSMatthew Dillon * - on the fly reallocation of swap during putpages. The new system 521c7c3c6aSMatthew Dillon * does not try to keep previously allocated swap blocks for dirty 531c7c3c6aSMatthew Dillon * pages. 541c7c3c6aSMatthew Dillon * 551c7c3c6aSMatthew Dillon * - on the fly deallocation of swap 561c7c3c6aSMatthew Dillon * 571c7c3c6aSMatthew Dillon * - No more garbage collection required. Unnecessarily allocated swap 581c7c3c6aSMatthew Dillon * blocks only exist for dirty vm_page_t's now and these are already 591c7c3c6aSMatthew Dillon * cycled (in a high-load system) by the pager. We also do on-the-fly 601c7c3c6aSMatthew Dillon * removal of invalidated swap blocks when a page is destroyed 611c7c3c6aSMatthew Dillon * or renamed. 621c7c3c6aSMatthew Dillon * 63df8bae1dSRodney W. Grimes * from: Utah $Hdr: swap_pager.c 1.4 91/04/30$ 64df8bae1dSRodney W. Grimes * 65df8bae1dSRodney W. Grimes * @(#)swap_pager.c 8.9 (Berkeley) 3/21/94 661c7c3c6aSMatthew Dillon * 67c3aac50fSPeter Wemm * $FreeBSD$ 68df8bae1dSRodney W. Grimes */ 69df8bae1dSRodney W. Grimes 70df8bae1dSRodney W. Grimes #include <sys/param.h> 71df8bae1dSRodney W. Grimes #include <sys/systm.h> 72af647ddeSBruce Evans #include <sys/conf.h> 7364abb5a5SDavid Greenman #include <sys/kernel.h> 74df8bae1dSRodney W. Grimes #include <sys/proc.h> 759626b608SPoul-Henning Kamp #include <sys/bio.h> 76df8bae1dSRodney W. Grimes #include <sys/buf.h> 77df8bae1dSRodney W. Grimes #include <sys/vnode.h> 78df8bae1dSRodney W. Grimes #include <sys/malloc.h> 79efeaf95aSDavid Greenman #include <sys/vmmeter.h> 80327f4e83SMatthew Dillon #include <sys/sysctl.h> 811c7c3c6aSMatthew Dillon #include <sys/blist.h> 821c7c3c6aSMatthew Dillon #include <sys/lock.h> 830cddd8f0SMatthew Dillon #include <sys/sx.h> 84936524aaSMatthew Dillon #include <sys/vmmeter.h> 85df8bae1dSRodney W. Grimes 86e47ed70bSJohn Dyson #ifndef MAX_PAGEOUT_CLUSTER 87ffc82b0aSJohn Dyson #define MAX_PAGEOUT_CLUSTER 16 88e47ed70bSJohn Dyson #endif 89e47ed70bSJohn Dyson 90e47ed70bSJohn Dyson #define SWB_NPAGES MAX_PAGEOUT_CLUSTER 91e47ed70bSJohn Dyson 921c7c3c6aSMatthew Dillon #include "opt_swap.h" 93df8bae1dSRodney W. Grimes #include <vm/vm.h> 9421cd6e62SSeigo Tanimura #include <vm/pmap.h> 9521cd6e62SSeigo Tanimura #include <vm/vm_map.h> 9621cd6e62SSeigo Tanimura #include <vm/vm_kern.h> 97efeaf95aSDavid Greenman #include <vm/vm_object.h> 98df8bae1dSRodney W. Grimes #include <vm/vm_page.h> 99efeaf95aSDavid Greenman #include <vm/vm_pager.h> 100df8bae1dSRodney W. Grimes #include <vm/vm_pageout.h> 10121cd6e62SSeigo Tanimura #include <vm/vm_zone.h> 102df8bae1dSRodney W. Grimes #include <vm/swap_pager.h> 103efeaf95aSDavid Greenman #include <vm/vm_extern.h> 104df8bae1dSRodney W. Grimes 1051c7c3c6aSMatthew Dillon #define SWM_FREE 0x02 /* free, period */ 1061c7c3c6aSMatthew Dillon #define SWM_POP 0x04 /* pop out */ 10726f9a767SRodney W. Grimes 10824a1cce3SDavid Greenman /* 1091c7c3c6aSMatthew Dillon * vm_swap_size is in page-sized chunks now. It was DEV_BSIZE'd chunks 1101c7c3c6aSMatthew Dillon * in the old system. 11124a1cce3SDavid Greenman */ 1121c7c3c6aSMatthew Dillon 1131c7c3c6aSMatthew Dillon extern int vm_swap_size; /* number of free swap blocks, in pages */ 1141c7c3c6aSMatthew Dillon 11520d3034fSMatthew Dillon int swap_pager_full; /* swap space exhaustion (task killing) */ 11620d3034fSMatthew Dillon static int swap_pager_almost_full; /* swap space exhaustion (w/ hysteresis)*/ 1171c7c3c6aSMatthew Dillon static int nsw_rcount; /* free read buffers */ 118327f4e83SMatthew Dillon static int nsw_wcount_sync; /* limit write buffers / synchronous */ 119327f4e83SMatthew Dillon static int nsw_wcount_async; /* limit write buffers / asynchronous */ 120327f4e83SMatthew Dillon static int nsw_wcount_async_max;/* assigned maximum */ 121327f4e83SMatthew Dillon static int nsw_cluster_max; /* maximum VOP I/O allowed */ 1221c7c3c6aSMatthew Dillon 1231c7c3c6aSMatthew Dillon struct blist *swapblist; 1241c7c3c6aSMatthew Dillon static struct swblock **swhash; 1251c7c3c6aSMatthew Dillon static int swhash_mask; 126327f4e83SMatthew Dillon static int swap_async_max = 4; /* maximum in-progress async I/O's */ 1270cddd8f0SMatthew Dillon static struct sx sw_alloc_sx; 128327f4e83SMatthew Dillon 129edfa785aSRobert Watson /* from vm_swap.c */ 130edfa785aSRobert Watson extern struct vnode *swapdev_vp; 131edfa785aSRobert Watson extern struct swdevt *swdevt; 132edfa785aSRobert Watson extern int nswdev; 13324e7ab7cSPoul-Henning Kamp 134327f4e83SMatthew Dillon SYSCTL_INT(_vm, OID_AUTO, swap_async_max, 135327f4e83SMatthew Dillon CTLFLAG_RW, &swap_async_max, 0, "Maximum running async swap ops"); 1361c7c3c6aSMatthew Dillon 137edfa785aSRobert Watson #define BLK2DEVIDX(blk) (nswdev > 1 ? blk / dmmax % nswdev : 0) 138edfa785aSRobert Watson 1391c7c3c6aSMatthew Dillon /* 1401c7c3c6aSMatthew Dillon * "named" and "unnamed" anon region objects. Try to reduce the overhead 1411c7c3c6aSMatthew Dillon * of searching a named list by hashing it just a little. 1421c7c3c6aSMatthew Dillon */ 1431c7c3c6aSMatthew Dillon 1441c7c3c6aSMatthew Dillon #define NOBJLISTS 8 1451c7c3c6aSMatthew Dillon 1461c7c3c6aSMatthew Dillon #define NOBJLIST(handle) \ 147af647ddeSBruce Evans (&swap_pager_object_list[((int)(intptr_t)handle >> 4) & (NOBJLISTS-1)]) 1481c7c3c6aSMatthew Dillon 149a9fa2c05SAlfred Perlstein static struct mtx sw_alloc_mtx; /* protect list manipulation */ 1501c7c3c6aSMatthew Dillon static struct pagerlst swap_pager_object_list[NOBJLISTS]; 1511c7c3c6aSMatthew Dillon struct pagerlst swap_pager_un_object_list; 1521c7c3c6aSMatthew Dillon vm_zone_t swap_zone; 1531c7c3c6aSMatthew Dillon 1541c7c3c6aSMatthew Dillon /* 1551c7c3c6aSMatthew Dillon * pagerops for OBJT_SWAP - "swap pager". Some ops are also global procedure 1561c7c3c6aSMatthew Dillon * calls hooked from other parts of the VM system and do not appear here. 1571c7c3c6aSMatthew Dillon * (see vm/swap_pager.h). 1581c7c3c6aSMatthew Dillon */ 1591c7c3c6aSMatthew Dillon 160ff98689dSBruce Evans static vm_object_t 1616cde7a16SDavid Greenman swap_pager_alloc __P((void *handle, vm_ooffset_t size, 162a316d390SJohn Dyson vm_prot_t prot, vm_ooffset_t offset)); 163ff98689dSBruce Evans static void swap_pager_dealloc __P((vm_object_t object)); 164f708ef1bSPoul-Henning Kamp static int swap_pager_getpages __P((vm_object_t, vm_page_t *, int, int)); 165ff98689dSBruce Evans static void swap_pager_init __P((void)); 1661c7c3c6aSMatthew Dillon static void swap_pager_unswapped __P((vm_page_t)); 1670b441832SPoul-Henning Kamp static void swap_pager_strategy __P((vm_object_t, struct bio *)); 168f708ef1bSPoul-Henning Kamp 169df8bae1dSRodney W. Grimes struct pagerops swappagerops = { 1701c7c3c6aSMatthew Dillon swap_pager_init, /* early system initialization of pager */ 1711c7c3c6aSMatthew Dillon swap_pager_alloc, /* allocate an OBJT_SWAP object */ 1721c7c3c6aSMatthew Dillon swap_pager_dealloc, /* deallocate an OBJT_SWAP object */ 1731c7c3c6aSMatthew Dillon swap_pager_getpages, /* pagein */ 1741c7c3c6aSMatthew Dillon swap_pager_putpages, /* pageout */ 1751c7c3c6aSMatthew Dillon swap_pager_haspage, /* get backing store status for page */ 176a5296b05SJulian Elischer swap_pager_unswapped, /* remove swap related to page */ 177a5296b05SJulian Elischer swap_pager_strategy /* pager strategy call */ 178df8bae1dSRodney W. Grimes }; 179df8bae1dSRodney W. Grimes 1800b441832SPoul-Henning Kamp static struct buf *getchainbuf(struct bio *bp, struct vnode *vp, int flags); 181e4057dbdSPoul-Henning Kamp static void flushchainbuf(struct buf *nbp); 1820b441832SPoul-Henning Kamp static void waitchainbuf(struct bio *bp, int count, int done); 183e4057dbdSPoul-Henning Kamp 1841c7c3c6aSMatthew Dillon /* 1851c7c3c6aSMatthew Dillon * dmmax is in page-sized chunks with the new swap system. It was 18664bcb9c8SMatthew Dillon * dev-bsized chunks in the old. dmmax is always a power of 2. 1871c7c3c6aSMatthew Dillon * 1881c7c3c6aSMatthew Dillon * swap_*() routines are externally accessible. swp_*() routines are 1891c7c3c6aSMatthew Dillon * internal. 1901c7c3c6aSMatthew Dillon */ 1911c7c3c6aSMatthew Dillon 192f708ef1bSPoul-Henning Kamp int dmmax; 1931c7c3c6aSMatthew Dillon static int dmmax_mask; 19420d3034fSMatthew Dillon int nswap_lowat = 128; /* in pages, swap_pager_almost_full warn */ 19520d3034fSMatthew Dillon int nswap_hiwat = 512; /* in pages, swap_pager_almost_full warn */ 19626f9a767SRodney W. Grimes 197cee313c4SRobert Watson SYSCTL_INT(_vm, OID_AUTO, dmmax, 198cee313c4SRobert Watson CTLFLAG_RD, &dmmax, 0, "Maximum size of a swap block"); 199cee313c4SRobert Watson 2001c7c3c6aSMatthew Dillon static __inline void swp_sizecheck __P((void)); 2011c7c3c6aSMatthew Dillon static void swp_pager_sync_iodone __P((struct buf *bp)); 2021c7c3c6aSMatthew Dillon static void swp_pager_async_iodone __P((struct buf *bp)); 20324a1cce3SDavid Greenman 2041c7c3c6aSMatthew Dillon /* 2051c7c3c6aSMatthew Dillon * Swap bitmap functions 2061c7c3c6aSMatthew Dillon */ 2071c7c3c6aSMatthew Dillon 2081c7c3c6aSMatthew Dillon static __inline void swp_pager_freeswapspace __P((daddr_t blk, int npages)); 2091c7c3c6aSMatthew Dillon static __inline daddr_t swp_pager_getswapspace __P((int npages)); 2101c7c3c6aSMatthew Dillon 2111c7c3c6aSMatthew Dillon /* 2121c7c3c6aSMatthew Dillon * Metadata functions 2131c7c3c6aSMatthew Dillon */ 2141c7c3c6aSMatthew Dillon 2154dcc5c2dSMatthew Dillon static void swp_pager_meta_build __P((vm_object_t, vm_pindex_t, daddr_t)); 2164dcc5c2dSMatthew Dillon static void swp_pager_meta_free __P((vm_object_t, vm_pindex_t, daddr_t)); 2171c7c3c6aSMatthew Dillon static void swp_pager_meta_free_all __P((vm_object_t)); 2181c7c3c6aSMatthew Dillon static daddr_t swp_pager_meta_ctl __P((vm_object_t, vm_pindex_t, int)); 2191c7c3c6aSMatthew Dillon 2201c7c3c6aSMatthew Dillon /* 2211c7c3c6aSMatthew Dillon * SWP_SIZECHECK() - update swap_pager_full indication 2221c7c3c6aSMatthew Dillon * 22320d3034fSMatthew Dillon * update the swap_pager_almost_full indication and warn when we are 22420d3034fSMatthew Dillon * about to run out of swap space, using lowat/hiwat hysteresis. 22520d3034fSMatthew Dillon * 22620d3034fSMatthew Dillon * Clear swap_pager_full ( task killing ) indication when lowat is met. 2271c7c3c6aSMatthew Dillon * 2281c7c3c6aSMatthew Dillon * No restrictions on call 2291c7c3c6aSMatthew Dillon * This routine may not block. 2301c7c3c6aSMatthew Dillon * This routine must be called at splvm() 2311c7c3c6aSMatthew Dillon */ 232de5f6a77SJohn Dyson 233c1087c13SBruce Evans static __inline void 2341c7c3c6aSMatthew Dillon swp_sizecheck() 2350d94caffSDavid Greenman { 2360cddd8f0SMatthew Dillon GIANT_REQUIRED; 23723955314SAlfred Perlstein 2381c7c3c6aSMatthew Dillon if (vm_swap_size < nswap_lowat) { 23920d3034fSMatthew Dillon if (swap_pager_almost_full == 0) { 2401af87c92SDavid Greenman printf("swap_pager: out of swap space\n"); 24120d3034fSMatthew Dillon swap_pager_almost_full = 1; 2422b0d37a4SMatthew Dillon } 24320d3034fSMatthew Dillon } else { 24426f9a767SRodney W. Grimes swap_pager_full = 0; 24520d3034fSMatthew Dillon if (vm_swap_size > nswap_hiwat) 24620d3034fSMatthew Dillon swap_pager_almost_full = 0; 24726f9a767SRodney W. Grimes } 2481c7c3c6aSMatthew Dillon } 2491c7c3c6aSMatthew Dillon 2501c7c3c6aSMatthew Dillon /* 2511c7c3c6aSMatthew Dillon * SWAP_PAGER_INIT() - initialize the swap pager! 2521c7c3c6aSMatthew Dillon * 2531c7c3c6aSMatthew Dillon * Expected to be started from system init. NOTE: This code is run 2541c7c3c6aSMatthew Dillon * before much else so be careful what you depend on. Most of the VM 2551c7c3c6aSMatthew Dillon * system has yet to be initialized at this point. 2561c7c3c6aSMatthew Dillon */ 25726f9a767SRodney W. Grimes 258f5a12711SPoul-Henning Kamp static void 259df8bae1dSRodney W. Grimes swap_pager_init() 260df8bae1dSRodney W. Grimes { 2611c7c3c6aSMatthew Dillon /* 2621c7c3c6aSMatthew Dillon * Initialize object lists 2631c7c3c6aSMatthew Dillon */ 2641c7c3c6aSMatthew Dillon int i; 2651c7c3c6aSMatthew Dillon 2661c7c3c6aSMatthew Dillon for (i = 0; i < NOBJLISTS; ++i) 2671c7c3c6aSMatthew Dillon TAILQ_INIT(&swap_pager_object_list[i]); 26824a1cce3SDavid Greenman TAILQ_INIT(&swap_pager_un_object_list); 269a9fa2c05SAlfred Perlstein mtx_init(&sw_alloc_mtx, "swap_pager list", MTX_DEF); 270df8bae1dSRodney W. Grimes 271df8bae1dSRodney W. Grimes /* 2721c7c3c6aSMatthew Dillon * Device Stripe, in PAGE_SIZE'd blocks 273df8bae1dSRodney W. Grimes */ 2741c7c3c6aSMatthew Dillon 2751c7c3c6aSMatthew Dillon dmmax = SWB_NPAGES * 2; 2761c7c3c6aSMatthew Dillon dmmax_mask = ~(dmmax - 1); 2771c7c3c6aSMatthew Dillon } 27826f9a767SRodney W. Grimes 279df8bae1dSRodney W. Grimes /* 2801c7c3c6aSMatthew Dillon * SWAP_PAGER_SWAP_INIT() - swap pager initialization from pageout process 2811c7c3c6aSMatthew Dillon * 2821c7c3c6aSMatthew Dillon * Expected to be started from pageout process once, prior to entering 2831c7c3c6aSMatthew Dillon * its main loop. 284df8bae1dSRodney W. Grimes */ 285df8bae1dSRodney W. Grimes 28624a1cce3SDavid Greenman void 28724a1cce3SDavid Greenman swap_pager_swap_init() 288df8bae1dSRodney W. Grimes { 28921cd6e62SSeigo Tanimura int n, n2; 2900d94caffSDavid Greenman 29126f9a767SRodney W. Grimes /* 2921c7c3c6aSMatthew Dillon * Number of in-transit swap bp operations. Don't 2931c7c3c6aSMatthew Dillon * exhaust the pbufs completely. Make sure we 2941c7c3c6aSMatthew Dillon * initialize workable values (0 will work for hysteresis 2951c7c3c6aSMatthew Dillon * but it isn't very efficient). 2961c7c3c6aSMatthew Dillon * 297327f4e83SMatthew Dillon * The nsw_cluster_max is constrained by the bp->b_pages[] 2981c7c3c6aSMatthew Dillon * array (MAXPHYS/PAGE_SIZE) and our locally defined 2991c7c3c6aSMatthew Dillon * MAX_PAGEOUT_CLUSTER. Also be aware that swap ops are 3001c7c3c6aSMatthew Dillon * constrained by the swap device interleave stripe size. 301327f4e83SMatthew Dillon * 302327f4e83SMatthew Dillon * Currently we hardwire nsw_wcount_async to 4. This limit is 303327f4e83SMatthew Dillon * designed to prevent other I/O from having high latencies due to 304327f4e83SMatthew Dillon * our pageout I/O. The value 4 works well for one or two active swap 305327f4e83SMatthew Dillon * devices but is probably a little low if you have more. Even so, 306327f4e83SMatthew Dillon * a higher value would probably generate only a limited improvement 307327f4e83SMatthew Dillon * with three or four active swap devices since the system does not 308327f4e83SMatthew Dillon * typically have to pageout at extreme bandwidths. We will want 309327f4e83SMatthew Dillon * at least 2 per swap devices, and 4 is a pretty good value if you 310327f4e83SMatthew Dillon * have one NFS swap device due to the command/ack latency over NFS. 311327f4e83SMatthew Dillon * So it all works out pretty well. 31226f9a767SRodney W. Grimes */ 31324a1cce3SDavid Greenman 314ad3cce20SMatthew Dillon nsw_cluster_max = min((MAXPHYS/PAGE_SIZE), MAX_PAGEOUT_CLUSTER); 315327f4e83SMatthew Dillon 3166d541bf1SJohn Baldwin mtx_lock(&pbuf_mtx); 3171c7c3c6aSMatthew Dillon nsw_rcount = (nswbuf + 1) / 2; 318327f4e83SMatthew Dillon nsw_wcount_sync = (nswbuf + 3) / 4; 319327f4e83SMatthew Dillon nsw_wcount_async = 4; 320327f4e83SMatthew Dillon nsw_wcount_async_max = nsw_wcount_async; 3216d541bf1SJohn Baldwin mtx_unlock(&pbuf_mtx); 32224a1cce3SDavid Greenman 3231c7c3c6aSMatthew Dillon /* 3241c7c3c6aSMatthew Dillon * Initialize our zone. Right now I'm just guessing on the number 3251c7c3c6aSMatthew Dillon * we need based on the number of pages in the system. Each swblock 3261c7c3c6aSMatthew Dillon * can hold 16 pages, so this is probably overkill. 3271c7c3c6aSMatthew Dillon */ 32824a1cce3SDavid Greenman 32921cd6e62SSeigo Tanimura n = min(cnt.v_page_count, (kernel_map->max_offset - kernel_map->min_offset) / PAGE_SIZE) * 2; 33021cd6e62SSeigo Tanimura n2 = n; 33126f9a767SRodney W. Grimes 33221cd6e62SSeigo Tanimura while (n > 0 33321cd6e62SSeigo Tanimura && (swap_zone = zinit( 3341c7c3c6aSMatthew Dillon "SWAPMETA", 3351c7c3c6aSMatthew Dillon sizeof(struct swblock), 3361c7c3c6aSMatthew Dillon n, 3371c7c3c6aSMatthew Dillon ZONE_INTERRUPT, 3381c7c3c6aSMatthew Dillon 1 33921cd6e62SSeigo Tanimura )) == NULL) 34021cd6e62SSeigo Tanimura n >>= 1; 34121cd6e62SSeigo Tanimura if (swap_zone == NULL) 34221cd6e62SSeigo Tanimura printf("WARNING: failed to init swap_zone!\n"); 34321cd6e62SSeigo Tanimura if (n2 != n) 34421cd6e62SSeigo Tanimura printf("Swap zone entries reduced to %d.\n", n); 34521cd6e62SSeigo Tanimura n2 = n; 34624a1cce3SDavid Greenman 3471c7c3c6aSMatthew Dillon /* 3481c7c3c6aSMatthew Dillon * Initialize our meta-data hash table. The swapper does not need to 3491c7c3c6aSMatthew Dillon * be quite as efficient as the VM system, so we do not use an 3501c7c3c6aSMatthew Dillon * oversized hash table. 3511c7c3c6aSMatthew Dillon * 3521c7c3c6aSMatthew Dillon * n: size of hash table, must be power of 2 3531c7c3c6aSMatthew Dillon * swhash_mask: hash table index mask 3541c7c3c6aSMatthew Dillon */ 355df8bae1dSRodney W. Grimes 35621cd6e62SSeigo Tanimura for (n = 1; n < n2 ; n <<= 1) 3571c7c3c6aSMatthew Dillon ; 3581c7c3c6aSMatthew Dillon 3597cc0979fSDavid Malone swhash = malloc(sizeof(struct swblock *) * n, M_VMPGDATA, M_WAITOK | M_ZERO); 3601c7c3c6aSMatthew Dillon 3611c7c3c6aSMatthew Dillon swhash_mask = n - 1; 36224a1cce3SDavid Greenman } 36324a1cce3SDavid Greenman 36424a1cce3SDavid Greenman /* 3651c7c3c6aSMatthew Dillon * SWAP_PAGER_ALLOC() - allocate a new OBJT_SWAP VM object and instantiate 3661c7c3c6aSMatthew Dillon * its metadata structures. 3671c7c3c6aSMatthew Dillon * 3681c7c3c6aSMatthew Dillon * This routine is called from the mmap and fork code to create a new 3691c7c3c6aSMatthew Dillon * OBJT_SWAP object. We do this by creating an OBJT_DEFAULT object 3701c7c3c6aSMatthew Dillon * and then converting it with swp_pager_meta_build(). 3711c7c3c6aSMatthew Dillon * 3721c7c3c6aSMatthew Dillon * This routine may block in vm_object_allocate() and create a named 3731c7c3c6aSMatthew Dillon * object lookup race, so we must interlock. We must also run at 3741c7c3c6aSMatthew Dillon * splvm() for the object lookup to handle races with interrupts, but 3751c7c3c6aSMatthew Dillon * we do not have to maintain splvm() in between the lookup and the 3761c7c3c6aSMatthew Dillon * add because (I believe) it is not possible to attempt to create 3771c7c3c6aSMatthew Dillon * a new swap object w/handle when a default object with that handle 3781c7c3c6aSMatthew Dillon * already exists. 37924a1cce3SDavid Greenman */ 3801c7c3c6aSMatthew Dillon 381f5a12711SPoul-Henning Kamp static vm_object_t 3826cde7a16SDavid Greenman swap_pager_alloc(void *handle, vm_ooffset_t size, vm_prot_t prot, 383b9dcd593SBruce Evans vm_ooffset_t offset) 38424a1cce3SDavid Greenman { 38524a1cce3SDavid Greenman vm_object_t object; 38624a1cce3SDavid Greenman 3870cddd8f0SMatthew Dillon GIANT_REQUIRED; 3880cddd8f0SMatthew Dillon 38924a1cce3SDavid Greenman if (handle) { 3901c7c3c6aSMatthew Dillon /* 3911c7c3c6aSMatthew Dillon * Reference existing named region or allocate new one. There 3921c7c3c6aSMatthew Dillon * should not be a race here against swp_pager_meta_build() 3931c7c3c6aSMatthew Dillon * as called from vm_page_remove() in regards to the lookup 3941c7c3c6aSMatthew Dillon * of the handle. 3951c7c3c6aSMatthew Dillon */ 3960cddd8f0SMatthew Dillon sx_xlock(&sw_alloc_sx); 3971c7c3c6aSMatthew Dillon object = vm_pager_object_lookup(NOBJLIST(handle), handle); 3981c7c3c6aSMatthew Dillon 39924a1cce3SDavid Greenman if (object != NULL) { 40024a1cce3SDavid Greenman vm_object_reference(object); 40124a1cce3SDavid Greenman } else { 4021c7c3c6aSMatthew Dillon object = vm_object_allocate(OBJT_DEFAULT, 4036cde7a16SDavid Greenman OFF_TO_IDX(offset + PAGE_MASK + size)); 40424a1cce3SDavid Greenman object->handle = handle; 4051c7c3c6aSMatthew Dillon 4064dcc5c2dSMatthew Dillon swp_pager_meta_build(object, 0, SWAPBLK_NONE); 40724a1cce3SDavid Greenman } 4080cddd8f0SMatthew Dillon sx_xunlock(&sw_alloc_sx); 40924a1cce3SDavid Greenman } else { 4101c7c3c6aSMatthew Dillon object = vm_object_allocate(OBJT_DEFAULT, 4116cde7a16SDavid Greenman OFF_TO_IDX(offset + PAGE_MASK + size)); 4121c7c3c6aSMatthew Dillon 4134dcc5c2dSMatthew Dillon swp_pager_meta_build(object, 0, SWAPBLK_NONE); 41424a1cce3SDavid Greenman } 41524a1cce3SDavid Greenman 41624a1cce3SDavid Greenman return (object); 417df8bae1dSRodney W. Grimes } 418df8bae1dSRodney W. Grimes 41926f9a767SRodney W. Grimes /* 4201c7c3c6aSMatthew Dillon * SWAP_PAGER_DEALLOC() - remove swap metadata from object 4211c7c3c6aSMatthew Dillon * 4221c7c3c6aSMatthew Dillon * The swap backing for the object is destroyed. The code is 4231c7c3c6aSMatthew Dillon * designed such that we can reinstantiate it later, but this 4241c7c3c6aSMatthew Dillon * routine is typically called only when the entire object is 4251c7c3c6aSMatthew Dillon * about to be destroyed. 4261c7c3c6aSMatthew Dillon * 4271c7c3c6aSMatthew Dillon * This routine may block, but no longer does. 4281c7c3c6aSMatthew Dillon * 4291c7c3c6aSMatthew Dillon * The object must be locked or unreferenceable. 43026f9a767SRodney W. Grimes */ 43126f9a767SRodney W. Grimes 432df8bae1dSRodney W. Grimes static void 4331c7c3c6aSMatthew Dillon swap_pager_dealloc(object) 4342a4895f4SDavid Greenman vm_object_t object; 43526f9a767SRodney W. Grimes { 4364dcc5c2dSMatthew Dillon int s; 4374dcc5c2dSMatthew Dillon 4380cddd8f0SMatthew Dillon GIANT_REQUIRED; 4390cddd8f0SMatthew Dillon 44026f9a767SRodney W. Grimes /* 4411c7c3c6aSMatthew Dillon * Remove from list right away so lookups will fail if we block for 4421c7c3c6aSMatthew Dillon * pageout completion. 44326f9a767SRodney W. Grimes */ 444a9fa2c05SAlfred Perlstein mtx_lock(&sw_alloc_mtx); 4451c7c3c6aSMatthew Dillon if (object->handle == NULL) { 4461c7c3c6aSMatthew Dillon TAILQ_REMOVE(&swap_pager_un_object_list, object, pager_object_list); 44724ea4a96SDavid Greenman } else { 4481c7c3c6aSMatthew Dillon TAILQ_REMOVE(NOBJLIST(object->handle), object, pager_object_list); 44926f9a767SRodney W. Grimes } 450a9fa2c05SAlfred Perlstein mtx_unlock(&sw_alloc_mtx); 4511c7c3c6aSMatthew Dillon 4521c7c3c6aSMatthew Dillon vm_object_pip_wait(object, "swpdea"); 4531c7c3c6aSMatthew Dillon 4541c7c3c6aSMatthew Dillon /* 4551c7c3c6aSMatthew Dillon * Free all remaining metadata. We only bother to free it from 4561c7c3c6aSMatthew Dillon * the swap meta data. We do not attempt to free swapblk's still 4571c7c3c6aSMatthew Dillon * associated with vm_page_t's for this object. We do not care 4581c7c3c6aSMatthew Dillon * if paging is still in progress on some objects. 4591c7c3c6aSMatthew Dillon */ 4604dcc5c2dSMatthew Dillon s = splvm(); 4611c7c3c6aSMatthew Dillon swp_pager_meta_free_all(object); 4624dcc5c2dSMatthew Dillon splx(s); 4631c7c3c6aSMatthew Dillon } 4641c7c3c6aSMatthew Dillon 4651c7c3c6aSMatthew Dillon /************************************************************************ 4661c7c3c6aSMatthew Dillon * SWAP PAGER BITMAP ROUTINES * 4671c7c3c6aSMatthew Dillon ************************************************************************/ 4681c7c3c6aSMatthew Dillon 4691c7c3c6aSMatthew Dillon /* 4701c7c3c6aSMatthew Dillon * SWP_PAGER_GETSWAPSPACE() - allocate raw swap space 4711c7c3c6aSMatthew Dillon * 4721c7c3c6aSMatthew Dillon * Allocate swap for the requested number of pages. The starting 4731c7c3c6aSMatthew Dillon * swap block number (a page index) is returned or SWAPBLK_NONE 4741c7c3c6aSMatthew Dillon * if the allocation failed. 4751c7c3c6aSMatthew Dillon * 4761c7c3c6aSMatthew Dillon * Also has the side effect of advising that somebody made a mistake 4771c7c3c6aSMatthew Dillon * when they configured swap and didn't configure enough. 4781c7c3c6aSMatthew Dillon * 4791c7c3c6aSMatthew Dillon * Must be called at splvm() to avoid races with bitmap frees from 4801c7c3c6aSMatthew Dillon * vm_page_remove() aka swap_pager_page_removed(). 4811c7c3c6aSMatthew Dillon * 4821c7c3c6aSMatthew Dillon * This routine may not block 4831c7c3c6aSMatthew Dillon * This routine must be called at splvm(). 4841c7c3c6aSMatthew Dillon */ 4851c7c3c6aSMatthew Dillon 4861c7c3c6aSMatthew Dillon static __inline daddr_t 4871c7c3c6aSMatthew Dillon swp_pager_getswapspace(npages) 4881c7c3c6aSMatthew Dillon int npages; 4891c7c3c6aSMatthew Dillon { 4901c7c3c6aSMatthew Dillon daddr_t blk; 4911c7c3c6aSMatthew Dillon 4920cddd8f0SMatthew Dillon GIANT_REQUIRED; 4930cddd8f0SMatthew Dillon 4941c7c3c6aSMatthew Dillon if ((blk = blist_alloc(swapblist, npages)) == SWAPBLK_NONE) { 4952b0d37a4SMatthew Dillon if (swap_pager_full != 2) { 4961c7c3c6aSMatthew Dillon printf("swap_pager_getswapspace: failed\n"); 4972b0d37a4SMatthew Dillon swap_pager_full = 2; 49820d3034fSMatthew Dillon swap_pager_almost_full = 1; 4992b0d37a4SMatthew Dillon } 5001c7c3c6aSMatthew Dillon } else { 5011c7c3c6aSMatthew Dillon vm_swap_size -= npages; 502edfa785aSRobert Watson /* per-swap area stats */ 503edfa785aSRobert Watson swdevt[BLK2DEVIDX(blk)].sw_used += npages; 5041c7c3c6aSMatthew Dillon swp_sizecheck(); 5051c7c3c6aSMatthew Dillon } 5061c7c3c6aSMatthew Dillon return(blk); 50726f9a767SRodney W. Grimes } 50826f9a767SRodney W. Grimes 50926f9a767SRodney W. Grimes /* 5101c7c3c6aSMatthew Dillon * SWP_PAGER_FREESWAPSPACE() - free raw swap space 5111c7c3c6aSMatthew Dillon * 5121c7c3c6aSMatthew Dillon * This routine returns the specified swap blocks back to the bitmap. 5131c7c3c6aSMatthew Dillon * 5141c7c3c6aSMatthew Dillon * Note: This routine may not block (it could in the old swap code), 5151c7c3c6aSMatthew Dillon * and through the use of the new blist routines it does not block. 5161c7c3c6aSMatthew Dillon * 5171c7c3c6aSMatthew Dillon * We must be called at splvm() to avoid races with bitmap frees from 5181c7c3c6aSMatthew Dillon * vm_page_remove() aka swap_pager_page_removed(). 5191c7c3c6aSMatthew Dillon * 5201c7c3c6aSMatthew Dillon * This routine may not block 5211c7c3c6aSMatthew Dillon * This routine must be called at splvm(). 52226f9a767SRodney W. Grimes */ 5231c7c3c6aSMatthew Dillon 5241c7c3c6aSMatthew Dillon static __inline void 5251c7c3c6aSMatthew Dillon swp_pager_freeswapspace(blk, npages) 5261c7c3c6aSMatthew Dillon daddr_t blk; 5271c7c3c6aSMatthew Dillon int npages; 5280d94caffSDavid Greenman { 5290cddd8f0SMatthew Dillon GIANT_REQUIRED; 53023955314SAlfred Perlstein 5311c7c3c6aSMatthew Dillon blist_free(swapblist, blk, npages); 5321c7c3c6aSMatthew Dillon vm_swap_size += npages; 533edfa785aSRobert Watson /* per-swap area stats */ 534edfa785aSRobert Watson swdevt[BLK2DEVIDX(blk)].sw_used -= npages; 5351c7c3c6aSMatthew Dillon swp_sizecheck(); 53626f9a767SRodney W. Grimes } 5371c7c3c6aSMatthew Dillon 53826f9a767SRodney W. Grimes /* 5391c7c3c6aSMatthew Dillon * SWAP_PAGER_FREESPACE() - frees swap blocks associated with a page 5401c7c3c6aSMatthew Dillon * range within an object. 5411c7c3c6aSMatthew Dillon * 5421c7c3c6aSMatthew Dillon * This is a globally accessible routine. 5431c7c3c6aSMatthew Dillon * 5441c7c3c6aSMatthew Dillon * This routine removes swapblk assignments from swap metadata. 5451c7c3c6aSMatthew Dillon * 5461c7c3c6aSMatthew Dillon * The external callers of this routine typically have already destroyed 5471c7c3c6aSMatthew Dillon * or renamed vm_page_t's associated with this range in the object so 5481c7c3c6aSMatthew Dillon * we should be ok. 5494dcc5c2dSMatthew Dillon * 5504dcc5c2dSMatthew Dillon * This routine may be called at any spl. We up our spl to splvm temporarily 5514dcc5c2dSMatthew Dillon * in order to perform the metadata removal. 55226f9a767SRodney W. Grimes */ 5531c7c3c6aSMatthew Dillon 55426f9a767SRodney W. Grimes void 55524a1cce3SDavid Greenman swap_pager_freespace(object, start, size) 55624a1cce3SDavid Greenman vm_object_t object; 557a316d390SJohn Dyson vm_pindex_t start; 558a316d390SJohn Dyson vm_size_t size; 55926f9a767SRodney W. Grimes { 5604dcc5c2dSMatthew Dillon int s = splvm(); 56123955314SAlfred Perlstein 5620cddd8f0SMatthew Dillon GIANT_REQUIRED; 5631c7c3c6aSMatthew Dillon swp_pager_meta_free(object, start, size); 5644dcc5c2dSMatthew Dillon splx(s); 5654dcc5c2dSMatthew Dillon } 5664dcc5c2dSMatthew Dillon 5674dcc5c2dSMatthew Dillon /* 5684dcc5c2dSMatthew Dillon * SWAP_PAGER_RESERVE() - reserve swap blocks in object 5694dcc5c2dSMatthew Dillon * 5704dcc5c2dSMatthew Dillon * Assigns swap blocks to the specified range within the object. The 5714dcc5c2dSMatthew Dillon * swap blocks are not zerod. Any previous swap assignment is destroyed. 5724dcc5c2dSMatthew Dillon * 5734dcc5c2dSMatthew Dillon * Returns 0 on success, -1 on failure. 5744dcc5c2dSMatthew Dillon */ 5754dcc5c2dSMatthew Dillon 5764dcc5c2dSMatthew Dillon int 5774dcc5c2dSMatthew Dillon swap_pager_reserve(vm_object_t object, vm_pindex_t start, vm_size_t size) 5784dcc5c2dSMatthew Dillon { 5794dcc5c2dSMatthew Dillon int s; 5804dcc5c2dSMatthew Dillon int n = 0; 5814dcc5c2dSMatthew Dillon daddr_t blk = SWAPBLK_NONE; 5824dcc5c2dSMatthew Dillon vm_pindex_t beg = start; /* save start index */ 5834dcc5c2dSMatthew Dillon 5844dcc5c2dSMatthew Dillon s = splvm(); 5854dcc5c2dSMatthew Dillon while (size) { 5864dcc5c2dSMatthew Dillon if (n == 0) { 5874dcc5c2dSMatthew Dillon n = BLIST_MAX_ALLOC; 5884dcc5c2dSMatthew Dillon while ((blk = swp_pager_getswapspace(n)) == SWAPBLK_NONE) { 5894dcc5c2dSMatthew Dillon n >>= 1; 5904dcc5c2dSMatthew Dillon if (n == 0) { 5914dcc5c2dSMatthew Dillon swp_pager_meta_free(object, beg, start - beg); 5924dcc5c2dSMatthew Dillon splx(s); 5934dcc5c2dSMatthew Dillon return(-1); 5944dcc5c2dSMatthew Dillon } 5954dcc5c2dSMatthew Dillon } 5964dcc5c2dSMatthew Dillon } 5974dcc5c2dSMatthew Dillon swp_pager_meta_build(object, start, blk); 5984dcc5c2dSMatthew Dillon --size; 5994dcc5c2dSMatthew Dillon ++start; 6004dcc5c2dSMatthew Dillon ++blk; 6014dcc5c2dSMatthew Dillon --n; 6024dcc5c2dSMatthew Dillon } 6034dcc5c2dSMatthew Dillon swp_pager_meta_free(object, start, n); 6044dcc5c2dSMatthew Dillon splx(s); 6054dcc5c2dSMatthew Dillon return(0); 60626f9a767SRodney W. Grimes } 60726f9a767SRodney W. Grimes 6080a47b48bSJohn Dyson /* 6091c7c3c6aSMatthew Dillon * SWAP_PAGER_COPY() - copy blocks from source pager to destination pager 6101c7c3c6aSMatthew Dillon * and destroy the source. 6111c7c3c6aSMatthew Dillon * 6121c7c3c6aSMatthew Dillon * Copy any valid swapblks from the source to the destination. In 6131c7c3c6aSMatthew Dillon * cases where both the source and destination have a valid swapblk, 6141c7c3c6aSMatthew Dillon * we keep the destination's. 6151c7c3c6aSMatthew Dillon * 6161c7c3c6aSMatthew Dillon * This routine is allowed to block. It may block allocating metadata 6171c7c3c6aSMatthew Dillon * indirectly through swp_pager_meta_build() or if paging is still in 6181c7c3c6aSMatthew Dillon * progress on the source. 6191c7c3c6aSMatthew Dillon * 6204dcc5c2dSMatthew Dillon * This routine can be called at any spl 6214dcc5c2dSMatthew Dillon * 6221c7c3c6aSMatthew Dillon * XXX vm_page_collapse() kinda expects us not to block because we 6231c7c3c6aSMatthew Dillon * supposedly do not need to allocate memory, but for the moment we 6241c7c3c6aSMatthew Dillon * *may* have to get a little memory from the zone allocator, but 6251c7c3c6aSMatthew Dillon * it is taken from the interrupt memory. We should be ok. 6261c7c3c6aSMatthew Dillon * 6271c7c3c6aSMatthew Dillon * The source object contains no vm_page_t's (which is just as well) 6281c7c3c6aSMatthew Dillon * 6291c7c3c6aSMatthew Dillon * The source object is of type OBJT_SWAP. 6301c7c3c6aSMatthew Dillon * 6314dcc5c2dSMatthew Dillon * The source and destination objects must be locked or 6324dcc5c2dSMatthew Dillon * inaccessible (XXX are they ?) 63326f9a767SRodney W. Grimes */ 63426f9a767SRodney W. Grimes 63526f9a767SRodney W. Grimes void 6361c7c3c6aSMatthew Dillon swap_pager_copy(srcobject, dstobject, offset, destroysource) 63724a1cce3SDavid Greenman vm_object_t srcobject; 63824a1cce3SDavid Greenman vm_object_t dstobject; 639a316d390SJohn Dyson vm_pindex_t offset; 640c0877f10SJohn Dyson int destroysource; 64126f9a767SRodney W. Grimes { 642a316d390SJohn Dyson vm_pindex_t i; 6434dcc5c2dSMatthew Dillon int s; 6444dcc5c2dSMatthew Dillon 6450cddd8f0SMatthew Dillon GIANT_REQUIRED; 6460cddd8f0SMatthew Dillon 6474dcc5c2dSMatthew Dillon s = splvm(); 64826f9a767SRodney W. Grimes /* 6491c7c3c6aSMatthew Dillon * If destroysource is set, we remove the source object from the 6501c7c3c6aSMatthew Dillon * swap_pager internal queue now. 65126f9a767SRodney W. Grimes */ 6521c7c3c6aSMatthew Dillon 653cbd8ec09SJohn Dyson if (destroysource) { 654a9fa2c05SAlfred Perlstein mtx_lock(&sw_alloc_mtx); 65524a1cce3SDavid Greenman if (srcobject->handle == NULL) { 6561c7c3c6aSMatthew Dillon TAILQ_REMOVE( 6571c7c3c6aSMatthew Dillon &swap_pager_un_object_list, 6581c7c3c6aSMatthew Dillon srcobject, 6591c7c3c6aSMatthew Dillon pager_object_list 6601c7c3c6aSMatthew Dillon ); 66126f9a767SRodney W. Grimes } else { 6621c7c3c6aSMatthew Dillon TAILQ_REMOVE( 6631c7c3c6aSMatthew Dillon NOBJLIST(srcobject->handle), 6641c7c3c6aSMatthew Dillon srcobject, 6651c7c3c6aSMatthew Dillon pager_object_list 6661c7c3c6aSMatthew Dillon ); 66726f9a767SRodney W. Grimes } 668a9fa2c05SAlfred Perlstein mtx_unlock(&sw_alloc_mtx); 669cbd8ec09SJohn Dyson } 67026f9a767SRodney W. Grimes 6711c7c3c6aSMatthew Dillon /* 6721c7c3c6aSMatthew Dillon * transfer source to destination. 6731c7c3c6aSMatthew Dillon */ 6741c7c3c6aSMatthew Dillon 6751c7c3c6aSMatthew Dillon for (i = 0; i < dstobject->size; ++i) { 6761c7c3c6aSMatthew Dillon daddr_t dstaddr; 6771c7c3c6aSMatthew Dillon 6781c7c3c6aSMatthew Dillon /* 6791c7c3c6aSMatthew Dillon * Locate (without changing) the swapblk on the destination, 6801c7c3c6aSMatthew Dillon * unless it is invalid in which case free it silently, or 6811c7c3c6aSMatthew Dillon * if the destination is a resident page, in which case the 6821c7c3c6aSMatthew Dillon * source is thrown away. 6831c7c3c6aSMatthew Dillon */ 6841c7c3c6aSMatthew Dillon 6851c7c3c6aSMatthew Dillon dstaddr = swp_pager_meta_ctl(dstobject, i, 0); 6861c7c3c6aSMatthew Dillon 6871c7c3c6aSMatthew Dillon if (dstaddr == SWAPBLK_NONE) { 6881c7c3c6aSMatthew Dillon /* 6891c7c3c6aSMatthew Dillon * Destination has no swapblk and is not resident, 6901c7c3c6aSMatthew Dillon * copy source. 6911c7c3c6aSMatthew Dillon */ 6921c7c3c6aSMatthew Dillon daddr_t srcaddr; 6931c7c3c6aSMatthew Dillon 6941c7c3c6aSMatthew Dillon srcaddr = swp_pager_meta_ctl( 6951c7c3c6aSMatthew Dillon srcobject, 6961c7c3c6aSMatthew Dillon i + offset, 6971c7c3c6aSMatthew Dillon SWM_POP 6981c7c3c6aSMatthew Dillon ); 6991c7c3c6aSMatthew Dillon 7001c7c3c6aSMatthew Dillon if (srcaddr != SWAPBLK_NONE) 7014dcc5c2dSMatthew Dillon swp_pager_meta_build(dstobject, i, srcaddr); 7021c7c3c6aSMatthew Dillon } else { 7031c7c3c6aSMatthew Dillon /* 7041c7c3c6aSMatthew Dillon * Destination has valid swapblk or it is represented 7051c7c3c6aSMatthew Dillon * by a resident page. We destroy the sourceblock. 7061c7c3c6aSMatthew Dillon */ 7071c7c3c6aSMatthew Dillon 7081c7c3c6aSMatthew Dillon swp_pager_meta_ctl(srcobject, i + offset, SWM_FREE); 7091c7c3c6aSMatthew Dillon } 71026f9a767SRodney W. Grimes } 71126f9a767SRodney W. Grimes 71226f9a767SRodney W. Grimes /* 7131c7c3c6aSMatthew Dillon * Free left over swap blocks in source. 7141c7c3c6aSMatthew Dillon * 7151c7c3c6aSMatthew Dillon * We have to revert the type to OBJT_DEFAULT so we do not accidently 7161c7c3c6aSMatthew Dillon * double-remove the object from the swap queues. 71726f9a767SRodney W. Grimes */ 71826f9a767SRodney W. Grimes 719c0877f10SJohn Dyson if (destroysource) { 7201c7c3c6aSMatthew Dillon swp_pager_meta_free_all(srcobject); 7211c7c3c6aSMatthew Dillon /* 7221c7c3c6aSMatthew Dillon * Reverting the type is not necessary, the caller is going 7231c7c3c6aSMatthew Dillon * to destroy srcobject directly, but I'm doing it here 724956f3135SPhilippe Charnier * for consistency since we've removed the object from its 7251c7c3c6aSMatthew Dillon * queues. 7261c7c3c6aSMatthew Dillon */ 7271c7c3c6aSMatthew Dillon srcobject->type = OBJT_DEFAULT; 728c0877f10SJohn Dyson } 7294dcc5c2dSMatthew Dillon splx(s); 73026f9a767SRodney W. Grimes } 73126f9a767SRodney W. Grimes 732df8bae1dSRodney W. Grimes /* 7331c7c3c6aSMatthew Dillon * SWAP_PAGER_HASPAGE() - determine if we have good backing store for 7341c7c3c6aSMatthew Dillon * the requested page. 7351c7c3c6aSMatthew Dillon * 7361c7c3c6aSMatthew Dillon * We determine whether good backing store exists for the requested 7371c7c3c6aSMatthew Dillon * page and return TRUE if it does, FALSE if it doesn't. 7381c7c3c6aSMatthew Dillon * 7391c7c3c6aSMatthew Dillon * If TRUE, we also try to determine how much valid, contiguous backing 7401c7c3c6aSMatthew Dillon * store exists before and after the requested page within a reasonable 7411c7c3c6aSMatthew Dillon * distance. We do not try to restrict it to the swap device stripe 7421c7c3c6aSMatthew Dillon * (that is handled in getpages/putpages). It probably isn't worth 7431c7c3c6aSMatthew Dillon * doing here. 744df8bae1dSRodney W. Grimes */ 74526f9a767SRodney W. Grimes 7461c7c3c6aSMatthew Dillon boolean_t 747a316d390SJohn Dyson swap_pager_haspage(object, pindex, before, after) 74824a1cce3SDavid Greenman vm_object_t object; 749a316d390SJohn Dyson vm_pindex_t pindex; 75024a1cce3SDavid Greenman int *before; 75124a1cce3SDavid Greenman int *after; 75226f9a767SRodney W. Grimes { 7531c7c3c6aSMatthew Dillon daddr_t blk0; 75425db2c54SMatthew Dillon int s; 75526f9a767SRodney W. Grimes 7561c7c3c6aSMatthew Dillon /* 7571c7c3c6aSMatthew Dillon * do we have good backing store at the requested index ? 7581c7c3c6aSMatthew Dillon */ 7591c7c3c6aSMatthew Dillon 76025db2c54SMatthew Dillon s = splvm(); 7611c7c3c6aSMatthew Dillon blk0 = swp_pager_meta_ctl(object, pindex, 0); 7621c7c3c6aSMatthew Dillon 7634dcc5c2dSMatthew Dillon if (blk0 == SWAPBLK_NONE) { 76425db2c54SMatthew Dillon splx(s); 7651c7c3c6aSMatthew Dillon if (before) 76624a1cce3SDavid Greenman *before = 0; 7671c7c3c6aSMatthew Dillon if (after) 76824a1cce3SDavid Greenman *after = 0; 76926f9a767SRodney W. Grimes return (FALSE); 77026f9a767SRodney W. Grimes } 77126f9a767SRodney W. Grimes 77226f9a767SRodney W. Grimes /* 7731c7c3c6aSMatthew Dillon * find backwards-looking contiguous good backing store 774e47ed70bSJohn Dyson */ 775e47ed70bSJohn Dyson 7761c7c3c6aSMatthew Dillon if (before != NULL) { 77726f9a767SRodney W. Grimes int i; 7780d94caffSDavid Greenman 7791c7c3c6aSMatthew Dillon for (i = 1; i < (SWB_NPAGES/2); ++i) { 7801c7c3c6aSMatthew Dillon daddr_t blk; 7811c7c3c6aSMatthew Dillon 7821c7c3c6aSMatthew Dillon if (i > pindex) 7831c7c3c6aSMatthew Dillon break; 7841c7c3c6aSMatthew Dillon blk = swp_pager_meta_ctl(object, pindex - i, 0); 7851c7c3c6aSMatthew Dillon if (blk != blk0 - i) 7861c7c3c6aSMatthew Dillon break; 787ffc82b0aSJohn Dyson } 7881c7c3c6aSMatthew Dillon *before = (i - 1); 78926f9a767SRodney W. Grimes } 79026f9a767SRodney W. Grimes 79126f9a767SRodney W. Grimes /* 7921c7c3c6aSMatthew Dillon * find forward-looking contiguous good backing store 79326f9a767SRodney W. Grimes */ 7941c7c3c6aSMatthew Dillon 7951c7c3c6aSMatthew Dillon if (after != NULL) { 7961c7c3c6aSMatthew Dillon int i; 7971c7c3c6aSMatthew Dillon 7981c7c3c6aSMatthew Dillon for (i = 1; i < (SWB_NPAGES/2); ++i) { 7991c7c3c6aSMatthew Dillon daddr_t blk; 8001c7c3c6aSMatthew Dillon 8011c7c3c6aSMatthew Dillon blk = swp_pager_meta_ctl(object, pindex + i, 0); 8021c7c3c6aSMatthew Dillon if (blk != blk0 + i) 8031c7c3c6aSMatthew Dillon break; 80426f9a767SRodney W. Grimes } 8051c7c3c6aSMatthew Dillon *after = (i - 1); 8061c7c3c6aSMatthew Dillon } 80725db2c54SMatthew Dillon splx(s); 8081c7c3c6aSMatthew Dillon return (TRUE); 8091c7c3c6aSMatthew Dillon } 8101c7c3c6aSMatthew Dillon 8111c7c3c6aSMatthew Dillon /* 8121c7c3c6aSMatthew Dillon * SWAP_PAGER_PAGE_UNSWAPPED() - remove swap backing store related to page 8131c7c3c6aSMatthew Dillon * 8141c7c3c6aSMatthew Dillon * This removes any associated swap backing store, whether valid or 8151c7c3c6aSMatthew Dillon * not, from the page. 8161c7c3c6aSMatthew Dillon * 8171c7c3c6aSMatthew Dillon * This routine is typically called when a page is made dirty, at 8181c7c3c6aSMatthew Dillon * which point any associated swap can be freed. MADV_FREE also 8191c7c3c6aSMatthew Dillon * calls us in a special-case situation 8201c7c3c6aSMatthew Dillon * 8211c7c3c6aSMatthew Dillon * NOTE!!! If the page is clean and the swap was valid, the caller 8221c7c3c6aSMatthew Dillon * should make the page dirty before calling this routine. This routine 8231c7c3c6aSMatthew Dillon * does NOT change the m->dirty status of the page. Also: MADV_FREE 8241c7c3c6aSMatthew Dillon * depends on it. 8251c7c3c6aSMatthew Dillon * 8261c7c3c6aSMatthew Dillon * This routine may not block 8274dcc5c2dSMatthew Dillon * This routine must be called at splvm() 8281c7c3c6aSMatthew Dillon */ 8291c7c3c6aSMatthew Dillon 8301c7c3c6aSMatthew Dillon static void 8311c7c3c6aSMatthew Dillon swap_pager_unswapped(m) 8321c7c3c6aSMatthew Dillon vm_page_t m; 8331c7c3c6aSMatthew Dillon { 8341c7c3c6aSMatthew Dillon swp_pager_meta_ctl(m->object, m->pindex, SWM_FREE); 8351c7c3c6aSMatthew Dillon } 8361c7c3c6aSMatthew Dillon 8371c7c3c6aSMatthew Dillon /* 838a5296b05SJulian Elischer * SWAP_PAGER_STRATEGY() - read, write, free blocks 839a5296b05SJulian Elischer * 840a5296b05SJulian Elischer * This implements the vm_pager_strategy() interface to swap and allows 841a5296b05SJulian Elischer * other parts of the system to directly access swap as backing store 842a5296b05SJulian Elischer * through vm_objects of type OBJT_SWAP. This is intended to be a 843a5296b05SJulian Elischer * cacheless interface ( i.e. caching occurs at higher levels ). 844a5296b05SJulian Elischer * Therefore we do not maintain any resident pages. All I/O goes 8454dcc5c2dSMatthew Dillon * directly to and from the swap device. 846a5296b05SJulian Elischer * 847a5296b05SJulian Elischer * Note that b_blkno is scaled for PAGE_SIZE 848a5296b05SJulian Elischer * 849a5296b05SJulian Elischer * We currently attempt to run I/O synchronously or asynchronously as 850a5296b05SJulian Elischer * the caller requests. This isn't perfect because we loose error 851a5296b05SJulian Elischer * sequencing when we run multiple ops in parallel to satisfy a request. 852a5296b05SJulian Elischer * But this is swap, so we let it all hang out. 853a5296b05SJulian Elischer */ 854a5296b05SJulian Elischer 855a5296b05SJulian Elischer static void 8560b441832SPoul-Henning Kamp swap_pager_strategy(vm_object_t object, struct bio *bp) 857a5296b05SJulian Elischer { 858a5296b05SJulian Elischer vm_pindex_t start; 859a5296b05SJulian Elischer int count; 8604dcc5c2dSMatthew Dillon int s; 861a5296b05SJulian Elischer char *data; 862a5296b05SJulian Elischer struct buf *nbp = NULL; 863a5296b05SJulian Elischer 8640cddd8f0SMatthew Dillon GIANT_REQUIRED; 8650cddd8f0SMatthew Dillon 8660b441832SPoul-Henning Kamp /* XXX: KASSERT instead ? */ 8670b441832SPoul-Henning Kamp if (bp->bio_bcount & PAGE_MASK) { 868a468031cSPoul-Henning Kamp biofinish(bp, NULL, EINVAL); 8690b441832SPoul-Henning Kamp printf("swap_pager_strategy: bp %p blk %d size %d, not page bounded\n", bp, (int)bp->bio_pblkno, (int)bp->bio_bcount); 870a5296b05SJulian Elischer return; 871a5296b05SJulian Elischer } 872a5296b05SJulian Elischer 873a5296b05SJulian Elischer /* 874a5296b05SJulian Elischer * Clear error indication, initialize page index, count, data pointer. 875a5296b05SJulian Elischer */ 876a5296b05SJulian Elischer 8770b441832SPoul-Henning Kamp bp->bio_error = 0; 8780b441832SPoul-Henning Kamp bp->bio_flags &= ~BIO_ERROR; 8790b441832SPoul-Henning Kamp bp->bio_resid = bp->bio_bcount; 880a5296b05SJulian Elischer 8810b441832SPoul-Henning Kamp start = bp->bio_pblkno; 8820b441832SPoul-Henning Kamp count = howmany(bp->bio_bcount, PAGE_SIZE); 8830b441832SPoul-Henning Kamp data = bp->bio_data; 884a5296b05SJulian Elischer 8854dcc5c2dSMatthew Dillon s = splvm(); 8864dcc5c2dSMatthew Dillon 887a5296b05SJulian Elischer /* 88821144e3bSPoul-Henning Kamp * Deal with BIO_DELETE 889a5296b05SJulian Elischer */ 890a5296b05SJulian Elischer 8910b441832SPoul-Henning Kamp if (bp->bio_cmd == BIO_DELETE) { 892a5296b05SJulian Elischer /* 893a5296b05SJulian Elischer * FREE PAGE(s) - destroy underlying swap that is no longer 894a5296b05SJulian Elischer * needed. 895a5296b05SJulian Elischer */ 896a5296b05SJulian Elischer swp_pager_meta_free(object, start, count); 897a5296b05SJulian Elischer splx(s); 8980b441832SPoul-Henning Kamp bp->bio_resid = 0; 8990b441832SPoul-Henning Kamp biodone(bp); 9004dcc5c2dSMatthew Dillon return; 9014dcc5c2dSMatthew Dillon } 9024dcc5c2dSMatthew Dillon 903a5296b05SJulian Elischer /* 9044dcc5c2dSMatthew Dillon * Execute read or write 905a5296b05SJulian Elischer */ 906a5296b05SJulian Elischer while (count > 0) { 907a5296b05SJulian Elischer daddr_t blk; 908a5296b05SJulian Elischer 909a5296b05SJulian Elischer /* 9104dcc5c2dSMatthew Dillon * Obtain block. If block not found and writing, allocate a 9114dcc5c2dSMatthew Dillon * new block and build it into the object. 9124dcc5c2dSMatthew Dillon */ 9134dcc5c2dSMatthew Dillon 9144dcc5c2dSMatthew Dillon blk = swp_pager_meta_ctl(object, start, 0); 9150b441832SPoul-Henning Kamp if ((blk == SWAPBLK_NONE) && (bp->bio_cmd == BIO_WRITE)) { 9164dcc5c2dSMatthew Dillon blk = swp_pager_getswapspace(1); 9174dcc5c2dSMatthew Dillon if (blk == SWAPBLK_NONE) { 9180b441832SPoul-Henning Kamp bp->bio_error = ENOMEM; 9190b441832SPoul-Henning Kamp bp->bio_flags |= BIO_ERROR; 9204dcc5c2dSMatthew Dillon break; 9214dcc5c2dSMatthew Dillon } 9224dcc5c2dSMatthew Dillon swp_pager_meta_build(object, start, blk); 9234dcc5c2dSMatthew Dillon } 9244dcc5c2dSMatthew Dillon 9254dcc5c2dSMatthew Dillon /* 9264dcc5c2dSMatthew Dillon * Do we have to flush our current collection? Yes if: 9274dcc5c2dSMatthew Dillon * 9284dcc5c2dSMatthew Dillon * - no swap block at this index 9294dcc5c2dSMatthew Dillon * - swap block is not contiguous 9304dcc5c2dSMatthew Dillon * - we cross a physical disk boundry in the 9314dcc5c2dSMatthew Dillon * stripe. 932a5296b05SJulian Elischer */ 933a5296b05SJulian Elischer 934a5296b05SJulian Elischer if ( 9354dcc5c2dSMatthew Dillon nbp && (nbp->b_blkno + btoc(nbp->b_bcount) != blk || 9364dcc5c2dSMatthew Dillon ((nbp->b_blkno ^ blk) & dmmax_mask) 937a5296b05SJulian Elischer ) 938a5296b05SJulian Elischer ) { 9394dcc5c2dSMatthew Dillon splx(s); 9400b441832SPoul-Henning Kamp if (bp->bio_cmd == BIO_READ) { 941a5296b05SJulian Elischer ++cnt.v_swapin; 942a5296b05SJulian Elischer cnt.v_swappgsin += btoc(nbp->b_bcount); 9434dcc5c2dSMatthew Dillon } else { 9444dcc5c2dSMatthew Dillon ++cnt.v_swapout; 9454dcc5c2dSMatthew Dillon cnt.v_swappgsout += btoc(nbp->b_bcount); 9464dcc5c2dSMatthew Dillon nbp->b_dirtyend = nbp->b_bcount; 9474dcc5c2dSMatthew Dillon } 948a5296b05SJulian Elischer flushchainbuf(nbp); 9494dcc5c2dSMatthew Dillon s = splvm(); 950a5296b05SJulian Elischer nbp = NULL; 951a5296b05SJulian Elischer } 952a5296b05SJulian Elischer 953a5296b05SJulian Elischer /* 9544dcc5c2dSMatthew Dillon * Add new swapblk to nbp, instantiating nbp if necessary. 9554dcc5c2dSMatthew Dillon * Zero-fill reads are able to take a shortcut. 956a5296b05SJulian Elischer */ 9574dcc5c2dSMatthew Dillon 9584dcc5c2dSMatthew Dillon if (blk == SWAPBLK_NONE) { 9594dcc5c2dSMatthew Dillon /* 9604dcc5c2dSMatthew Dillon * We can only get here if we are reading. Since 9614dcc5c2dSMatthew Dillon * we are at splvm() we can safely modify b_resid, 9624dcc5c2dSMatthew Dillon * even if chain ops are in progress. 9634dcc5c2dSMatthew Dillon */ 964a5296b05SJulian Elischer bzero(data, PAGE_SIZE); 9650b441832SPoul-Henning Kamp bp->bio_resid -= PAGE_SIZE; 966a5296b05SJulian Elischer } else { 967a5296b05SJulian Elischer if (nbp == NULL) { 9680b441832SPoul-Henning Kamp nbp = getchainbuf(bp, swapdev_vp, B_ASYNC); 969a5296b05SJulian Elischer nbp->b_blkno = blk; 9704dcc5c2dSMatthew Dillon nbp->b_bcount = 0; 971a5296b05SJulian Elischer nbp->b_data = data; 972a5296b05SJulian Elischer } 973a5296b05SJulian Elischer nbp->b_bcount += PAGE_SIZE; 974a5296b05SJulian Elischer } 975a5296b05SJulian Elischer --count; 976a5296b05SJulian Elischer ++start; 977a5296b05SJulian Elischer data += PAGE_SIZE; 978a5296b05SJulian Elischer } 979a5296b05SJulian Elischer 980a5296b05SJulian Elischer /* 9814dcc5c2dSMatthew Dillon * Flush out last buffer 982a5296b05SJulian Elischer */ 983a5296b05SJulian Elischer 984a5296b05SJulian Elischer splx(s); 985a5296b05SJulian Elischer 986a5296b05SJulian Elischer if (nbp) { 98721144e3bSPoul-Henning Kamp if (nbp->b_iocmd == BIO_READ) { 988a5296b05SJulian Elischer ++cnt.v_swapin; 989a5296b05SJulian Elischer cnt.v_swappgsin += btoc(nbp->b_bcount); 990a5296b05SJulian Elischer } else { 991a5296b05SJulian Elischer ++cnt.v_swapout; 992a5296b05SJulian Elischer cnt.v_swappgsout += btoc(nbp->b_bcount); 9934dcc5c2dSMatthew Dillon nbp->b_dirtyend = nbp->b_bcount; 994a5296b05SJulian Elischer } 995a5296b05SJulian Elischer flushchainbuf(nbp); 9964dcc5c2dSMatthew Dillon /* nbp = NULL; */ 9970cddd8f0SMatthew Dillon } 9984dcc5c2dSMatthew Dillon /* 9994dcc5c2dSMatthew Dillon * Wait for completion. 10004dcc5c2dSMatthew Dillon */ 10014dcc5c2dSMatthew Dillon 1002a5296b05SJulian Elischer waitchainbuf(bp, 0, 1); 1003a5296b05SJulian Elischer } 1004a5296b05SJulian Elischer 1005a5296b05SJulian Elischer /* 10061c7c3c6aSMatthew Dillon * SWAP_PAGER_GETPAGES() - bring pages in from swap 10071c7c3c6aSMatthew Dillon * 10081c7c3c6aSMatthew Dillon * Attempt to retrieve (m, count) pages from backing store, but make 10091c7c3c6aSMatthew Dillon * sure we retrieve at least m[reqpage]. We try to load in as large 10101c7c3c6aSMatthew Dillon * a chunk surrounding m[reqpage] as is contiguous in swap and which 10111c7c3c6aSMatthew Dillon * belongs to the same object. 10121c7c3c6aSMatthew Dillon * 10131c7c3c6aSMatthew Dillon * The code is designed for asynchronous operation and 10141c7c3c6aSMatthew Dillon * immediate-notification of 'reqpage' but tends not to be 10151c7c3c6aSMatthew Dillon * used that way. Please do not optimize-out this algorithmic 10161c7c3c6aSMatthew Dillon * feature, I intend to improve on it in the future. 10171c7c3c6aSMatthew Dillon * 10181c7c3c6aSMatthew Dillon * The parent has a single vm_object_pip_add() reference prior to 10191c7c3c6aSMatthew Dillon * calling us and we should return with the same. 10201c7c3c6aSMatthew Dillon * 10211c7c3c6aSMatthew Dillon * The parent has BUSY'd the pages. We should return with 'm' 10221c7c3c6aSMatthew Dillon * left busy, but the others adjusted. 10231c7c3c6aSMatthew Dillon */ 102426f9a767SRodney W. Grimes 1025f708ef1bSPoul-Henning Kamp static int 102624a1cce3SDavid Greenman swap_pager_getpages(object, m, count, reqpage) 102724a1cce3SDavid Greenman vm_object_t object; 102826f9a767SRodney W. Grimes vm_page_t *m; 102926f9a767SRodney W. Grimes int count, reqpage; 1030df8bae1dSRodney W. Grimes { 10311c7c3c6aSMatthew Dillon struct buf *bp; 10321c7c3c6aSMatthew Dillon vm_page_t mreq; 10331c7c3c6aSMatthew Dillon int s; 103426f9a767SRodney W. Grimes int i; 103526f9a767SRodney W. Grimes int j; 10361c7c3c6aSMatthew Dillon daddr_t blk; 10371c7c3c6aSMatthew Dillon vm_offset_t kva; 10381c7c3c6aSMatthew Dillon vm_pindex_t lastpindex; 10390d94caffSDavid Greenman 10400cddd8f0SMatthew Dillon GIANT_REQUIRED; 10410cddd8f0SMatthew Dillon 10421c7c3c6aSMatthew Dillon mreq = m[reqpage]; 10431c7c3c6aSMatthew Dillon 10441c7c3c6aSMatthew Dillon if (mreq->object != object) { 10451c7c3c6aSMatthew Dillon panic("swap_pager_getpages: object mismatch %p/%p", 10461c7c3c6aSMatthew Dillon object, 10471c7c3c6aSMatthew Dillon mreq->object 10481c7c3c6aSMatthew Dillon ); 104926f9a767SRodney W. Grimes } 10501c7c3c6aSMatthew Dillon /* 10511c7c3c6aSMatthew Dillon * Calculate range to retrieve. The pages have already been assigned 10521c7c3c6aSMatthew Dillon * their swapblks. We require a *contiguous* range that falls entirely 10531c7c3c6aSMatthew Dillon * within a single device stripe. If we do not supply it, bad things 10544dcc5c2dSMatthew Dillon * happen. Note that blk, iblk & jblk can be SWAPBLK_NONE, but the 10554dcc5c2dSMatthew Dillon * loops are set up such that the case(s) are handled implicitly. 10564dcc5c2dSMatthew Dillon * 10574dcc5c2dSMatthew Dillon * The swp_*() calls must be made at splvm(). vm_page_free() does 10584dcc5c2dSMatthew Dillon * not need to be, but it will go a little faster if it is. 10591c7c3c6aSMatthew Dillon */ 10601c7c3c6aSMatthew Dillon 10614dcc5c2dSMatthew Dillon s = splvm(); 10621c7c3c6aSMatthew Dillon blk = swp_pager_meta_ctl(mreq->object, mreq->pindex, 0); 10631c7c3c6aSMatthew Dillon 10641c7c3c6aSMatthew Dillon for (i = reqpage - 1; i >= 0; --i) { 10651c7c3c6aSMatthew Dillon daddr_t iblk; 10661c7c3c6aSMatthew Dillon 10671c7c3c6aSMatthew Dillon iblk = swp_pager_meta_ctl(m[i]->object, m[i]->pindex, 0); 10681c7c3c6aSMatthew Dillon if (blk != iblk + (reqpage - i)) 106926f9a767SRodney W. Grimes break; 10704dcc5c2dSMatthew Dillon if ((blk ^ iblk) & dmmax_mask) 10714dcc5c2dSMatthew Dillon break; 107226f9a767SRodney W. Grimes } 10731c7c3c6aSMatthew Dillon ++i; 10741c7c3c6aSMatthew Dillon 10751c7c3c6aSMatthew Dillon for (j = reqpage + 1; j < count; ++j) { 10761c7c3c6aSMatthew Dillon daddr_t jblk; 10771c7c3c6aSMatthew Dillon 10781c7c3c6aSMatthew Dillon jblk = swp_pager_meta_ctl(m[j]->object, m[j]->pindex, 0); 10791c7c3c6aSMatthew Dillon if (blk != jblk - (j - reqpage)) 10801c7c3c6aSMatthew Dillon break; 10814dcc5c2dSMatthew Dillon if ((blk ^ jblk) & dmmax_mask) 10824dcc5c2dSMatthew Dillon break; 10831c7c3c6aSMatthew Dillon } 10841c7c3c6aSMatthew Dillon 10851c7c3c6aSMatthew Dillon /* 10861c7c3c6aSMatthew Dillon * free pages outside our collection range. Note: we never free 10871c7c3c6aSMatthew Dillon * mreq, it must remain busy throughout. 10881c7c3c6aSMatthew Dillon */ 10891c7c3c6aSMatthew Dillon 10901c7c3c6aSMatthew Dillon { 10911c7c3c6aSMatthew Dillon int k; 10921c7c3c6aSMatthew Dillon 10934dcc5c2dSMatthew Dillon for (k = 0; k < i; ++k) 10944dcc5c2dSMatthew Dillon vm_page_free(m[k]); 10954dcc5c2dSMatthew Dillon for (k = j; k < count; ++k) 10961c7c3c6aSMatthew Dillon vm_page_free(m[k]); 10971c7c3c6aSMatthew Dillon } 10984dcc5c2dSMatthew Dillon splx(s); 10994dcc5c2dSMatthew Dillon 11001c7c3c6aSMatthew Dillon 11011c7c3c6aSMatthew Dillon /* 11024dcc5c2dSMatthew Dillon * Return VM_PAGER_FAIL if we have nothing to do. Return mreq 11034dcc5c2dSMatthew Dillon * still busy, but the others unbusied. 11041c7c3c6aSMatthew Dillon */ 11051c7c3c6aSMatthew Dillon 11064dcc5c2dSMatthew Dillon if (blk == SWAPBLK_NONE) 110726f9a767SRodney W. Grimes return(VM_PAGER_FAIL); 1108df8bae1dSRodney W. Grimes 110916f62314SDavid Greenman /* 111016f62314SDavid Greenman * Get a swap buffer header to perform the IO 111116f62314SDavid Greenman */ 11121c7c3c6aSMatthew Dillon 11131c7c3c6aSMatthew Dillon bp = getpbuf(&nsw_rcount); 111416f62314SDavid Greenman kva = (vm_offset_t) bp->b_data; 111526f9a767SRodney W. Grimes 111616f62314SDavid Greenman /* 111716f62314SDavid Greenman * map our page(s) into kva for input 11181c7c3c6aSMatthew Dillon * 11191c7c3c6aSMatthew Dillon * NOTE: B_PAGING is set by pbgetvp() 112016f62314SDavid Greenman */ 112116f62314SDavid Greenman 11221c7c3c6aSMatthew Dillon pmap_qenter(kva, m + i, j - i); 11231c7c3c6aSMatthew Dillon 112421144e3bSPoul-Henning Kamp bp->b_iocmd = BIO_READ; 11251c7c3c6aSMatthew Dillon bp->b_iodone = swp_pager_async_iodone; 1126b0eeea20SPoul-Henning Kamp bp->b_rcred = bp->b_wcred = proc0.p_ucred; 1127a5296b05SJulian Elischer bp->b_data = (caddr_t) kva; 112826f9a767SRodney W. Grimes crhold(bp->b_rcred); 112926f9a767SRodney W. Grimes crhold(bp->b_wcred); 11301c7c3c6aSMatthew Dillon bp->b_blkno = blk - (reqpage - i); 11311c7c3c6aSMatthew Dillon bp->b_bcount = PAGE_SIZE * (j - i); 11321c7c3c6aSMatthew Dillon bp->b_bufsize = PAGE_SIZE * (j - i); 11331c7c3c6aSMatthew Dillon bp->b_pager.pg_reqpage = reqpage - i; 11341c7c3c6aSMatthew Dillon 11351c7c3c6aSMatthew Dillon { 11361c7c3c6aSMatthew Dillon int k; 11371c7c3c6aSMatthew Dillon 11381c7c3c6aSMatthew Dillon for (k = i; k < j; ++k) { 11391c7c3c6aSMatthew Dillon bp->b_pages[k - i] = m[k]; 11401c7c3c6aSMatthew Dillon vm_page_flag_set(m[k], PG_SWAPINPROG); 11411c7c3c6aSMatthew Dillon } 11421c7c3c6aSMatthew Dillon } 11431c7c3c6aSMatthew Dillon bp->b_npages = j - i; 114426f9a767SRodney W. Grimes 11450d94caffSDavid Greenman pbgetvp(swapdev_vp, bp); 1146df8bae1dSRodney W. Grimes 1147976e77fcSDavid Greenman cnt.v_swapin++; 11481c7c3c6aSMatthew Dillon cnt.v_swappgsin += bp->b_npages; 11491c7c3c6aSMatthew Dillon 1150df8bae1dSRodney W. Grimes /* 11511c7c3c6aSMatthew Dillon * We still hold the lock on mreq, and our automatic completion routine 11521c7c3c6aSMatthew Dillon * does not remove it. 1153df8bae1dSRodney W. Grimes */ 11541c7c3c6aSMatthew Dillon 11551c7c3c6aSMatthew Dillon vm_object_pip_add(mreq->object, bp->b_npages); 11561c7c3c6aSMatthew Dillon lastpindex = m[j-1]->pindex; 11571c7c3c6aSMatthew Dillon 11581c7c3c6aSMatthew Dillon /* 11591c7c3c6aSMatthew Dillon * perform the I/O. NOTE!!! bp cannot be considered valid after 11601c7c3c6aSMatthew Dillon * this point because we automatically release it on completion. 11611c7c3c6aSMatthew Dillon * Instead, we look at the one page we are interested in which we 11621c7c3c6aSMatthew Dillon * still hold a lock on even through the I/O completion. 11631c7c3c6aSMatthew Dillon * 11641c7c3c6aSMatthew Dillon * The other pages in our m[] array are also released on completion, 11651c7c3c6aSMatthew Dillon * so we cannot assume they are valid anymore either. 11661c7c3c6aSMatthew Dillon * 1167ea3aecf5SPeter Wemm * NOTE: b_blkno is destroyed by the call to VOP_STRATEGY 11681c7c3c6aSMatthew Dillon */ 1169b890cb2cSPeter Wemm BUF_KERNPROC(bp); 1170b99c307aSPoul-Henning Kamp BUF_STRATEGY(bp); 117126f9a767SRodney W. Grimes 117226f9a767SRodney W. Grimes /* 11731c7c3c6aSMatthew Dillon * wait for the page we want to complete. PG_SWAPINPROG is always 11741c7c3c6aSMatthew Dillon * cleared on completion. If an I/O error occurs, SWAPBLK_NONE 11751c7c3c6aSMatthew Dillon * is set in the meta-data. 117626f9a767SRodney W. Grimes */ 11771b119d9dSDavid Greenman 11781c7c3c6aSMatthew Dillon s = splvm(); 11791c7c3c6aSMatthew Dillon 11801c7c3c6aSMatthew Dillon while ((mreq->flags & PG_SWAPINPROG) != 0) { 11811c7c3c6aSMatthew Dillon vm_page_flag_set(mreq, PG_WANTED | PG_REFERENCED); 11821c7c3c6aSMatthew Dillon cnt.v_intrans++; 11830cddd8f0SMatthew Dillon if (tsleep(mreq, PSWP, "swread", hz*20)) { 1184ac1e407bSBruce Evans printf( 11851c7c3c6aSMatthew Dillon "swap_pager: indefinite wait buffer: device:" 1186af647ddeSBruce Evans " %s, blkno: %ld, size: %ld\n", 1187af647ddeSBruce Evans devtoname(bp->b_dev), (long)bp->b_blkno, 1188af647ddeSBruce Evans bp->b_bcount 11891c7c3c6aSMatthew Dillon ); 11901c7c3c6aSMatthew Dillon } 11911b119d9dSDavid Greenman } 119226f9a767SRodney W. Grimes 1193df8bae1dSRodney W. Grimes splx(s); 119426f9a767SRodney W. Grimes 119526f9a767SRodney W. Grimes /* 11961c7c3c6aSMatthew Dillon * mreq is left bussied after completion, but all the other pages 11971c7c3c6aSMatthew Dillon * are freed. If we had an unrecoverable read error the page will 11981c7c3c6aSMatthew Dillon * not be valid. 119926f9a767SRodney W. Grimes */ 120026f9a767SRodney W. Grimes 12011c7c3c6aSMatthew Dillon if (mreq->valid != VM_PAGE_BITS_ALL) { 12021c7c3c6aSMatthew Dillon return(VM_PAGER_ERROR); 120326f9a767SRodney W. Grimes } else { 12041c7c3c6aSMatthew Dillon return(VM_PAGER_OK); 120526f9a767SRodney W. Grimes } 12061c7c3c6aSMatthew Dillon 12071c7c3c6aSMatthew Dillon /* 12081c7c3c6aSMatthew Dillon * A final note: in a low swap situation, we cannot deallocate swap 12091c7c3c6aSMatthew Dillon * and mark a page dirty here because the caller is likely to mark 12101c7c3c6aSMatthew Dillon * the page clean when we return, causing the page to possibly revert 12111c7c3c6aSMatthew Dillon * to all-zero's later. 12121c7c3c6aSMatthew Dillon */ 1213df8bae1dSRodney W. Grimes } 1214df8bae1dSRodney W. Grimes 12151c7c3c6aSMatthew Dillon /* 12161c7c3c6aSMatthew Dillon * swap_pager_putpages: 12171c7c3c6aSMatthew Dillon * 12181c7c3c6aSMatthew Dillon * Assign swap (if necessary) and initiate I/O on the specified pages. 12191c7c3c6aSMatthew Dillon * 12201c7c3c6aSMatthew Dillon * We support both OBJT_DEFAULT and OBJT_SWAP objects. DEFAULT objects 12211c7c3c6aSMatthew Dillon * are automatically converted to SWAP objects. 12221c7c3c6aSMatthew Dillon * 1223ea3aecf5SPeter Wemm * In a low memory situation we may block in VOP_STRATEGY(), but the new 12241c7c3c6aSMatthew Dillon * vm_page reservation system coupled with properly written VFS devices 12251c7c3c6aSMatthew Dillon * should ensure that no low-memory deadlock occurs. This is an area 12261c7c3c6aSMatthew Dillon * which needs work. 12271c7c3c6aSMatthew Dillon * 12281c7c3c6aSMatthew Dillon * The parent has N vm_object_pip_add() references prior to 12291c7c3c6aSMatthew Dillon * calling us and will remove references for rtvals[] that are 12301c7c3c6aSMatthew Dillon * not set to VM_PAGER_PEND. We need to remove the rest on I/O 12311c7c3c6aSMatthew Dillon * completion. 12321c7c3c6aSMatthew Dillon * 12331c7c3c6aSMatthew Dillon * The parent has soft-busy'd the pages it passes us and will unbusy 12341c7c3c6aSMatthew Dillon * those whos rtvals[] entry is not set to VM_PAGER_PEND on return. 12351c7c3c6aSMatthew Dillon * We need to unbusy the rest on I/O completion. 12361c7c3c6aSMatthew Dillon */ 12371c7c3c6aSMatthew Dillon 1238e4542174SMatthew Dillon void 123924a1cce3SDavid Greenman swap_pager_putpages(object, m, count, sync, rtvals) 124024a1cce3SDavid Greenman vm_object_t object; 124126f9a767SRodney W. Grimes vm_page_t *m; 124226f9a767SRodney W. Grimes int count; 124324a1cce3SDavid Greenman boolean_t sync; 124426f9a767SRodney W. Grimes int *rtvals; 1245df8bae1dSRodney W. Grimes { 12461c7c3c6aSMatthew Dillon int i; 12471c7c3c6aSMatthew Dillon int n = 0; 1248df8bae1dSRodney W. Grimes 12490cddd8f0SMatthew Dillon GIANT_REQUIRED; 12501c7c3c6aSMatthew Dillon if (count && m[0]->object != object) { 12511c7c3c6aSMatthew Dillon panic("swap_pager_getpages: object mismatch %p/%p", 12521c7c3c6aSMatthew Dillon object, 12531c7c3c6aSMatthew Dillon m[0]->object 12541c7c3c6aSMatthew Dillon ); 12551c7c3c6aSMatthew Dillon } 12561c7c3c6aSMatthew Dillon /* 12571c7c3c6aSMatthew Dillon * Step 1 12581c7c3c6aSMatthew Dillon * 12591c7c3c6aSMatthew Dillon * Turn object into OBJT_SWAP 12601c7c3c6aSMatthew Dillon * check for bogus sysops 12611c7c3c6aSMatthew Dillon * force sync if not pageout process 12621c7c3c6aSMatthew Dillon */ 1263e736cd05SJohn Dyson 12644dcc5c2dSMatthew Dillon if (object->type != OBJT_SWAP) 12654dcc5c2dSMatthew Dillon swp_pager_meta_build(object, 0, SWAPBLK_NONE); 1266e47ed70bSJohn Dyson 1267e47ed70bSJohn Dyson if (curproc != pageproc) 1268e47ed70bSJohn Dyson sync = TRUE; 126926f9a767SRodney W. Grimes 12701c7c3c6aSMatthew Dillon /* 12711c7c3c6aSMatthew Dillon * Step 2 12721c7c3c6aSMatthew Dillon * 1273ad3cce20SMatthew Dillon * Update nsw parameters from swap_async_max sysctl values. 1274ad3cce20SMatthew Dillon * Do not let the sysop crash the machine with bogus numbers. 1275327f4e83SMatthew Dillon */ 1276327f4e83SMatthew Dillon 12776d541bf1SJohn Baldwin mtx_lock(&pbuf_mtx); 1278327f4e83SMatthew Dillon if (swap_async_max != nsw_wcount_async_max) { 1279327f4e83SMatthew Dillon int n; 1280327f4e83SMatthew Dillon int s; 1281327f4e83SMatthew Dillon 1282327f4e83SMatthew Dillon /* 1283327f4e83SMatthew Dillon * limit range 1284327f4e83SMatthew Dillon */ 1285327f4e83SMatthew Dillon if ((n = swap_async_max) > nswbuf / 2) 1286327f4e83SMatthew Dillon n = nswbuf / 2; 1287327f4e83SMatthew Dillon if (n < 1) 1288327f4e83SMatthew Dillon n = 1; 1289327f4e83SMatthew Dillon swap_async_max = n; 1290327f4e83SMatthew Dillon 1291327f4e83SMatthew Dillon /* 1292327f4e83SMatthew Dillon * Adjust difference ( if possible ). If the current async 1293327f4e83SMatthew Dillon * count is too low, we may not be able to make the adjustment 1294327f4e83SMatthew Dillon * at this time. 1295327f4e83SMatthew Dillon */ 1296327f4e83SMatthew Dillon s = splvm(); 1297327f4e83SMatthew Dillon n -= nsw_wcount_async_max; 1298327f4e83SMatthew Dillon if (nsw_wcount_async + n >= 0) { 1299327f4e83SMatthew Dillon nsw_wcount_async += n; 1300327f4e83SMatthew Dillon nsw_wcount_async_max += n; 1301327f4e83SMatthew Dillon wakeup(&nsw_wcount_async); 1302327f4e83SMatthew Dillon } 1303327f4e83SMatthew Dillon splx(s); 1304327f4e83SMatthew Dillon } 13056d541bf1SJohn Baldwin mtx_unlock(&pbuf_mtx); 1306327f4e83SMatthew Dillon 1307327f4e83SMatthew Dillon /* 1308327f4e83SMatthew Dillon * Step 3 1309327f4e83SMatthew Dillon * 13101c7c3c6aSMatthew Dillon * Assign swap blocks and issue I/O. We reallocate swap on the fly. 13111c7c3c6aSMatthew Dillon * The page is left dirty until the pageout operation completes 13121c7c3c6aSMatthew Dillon * successfully. 13131c7c3c6aSMatthew Dillon */ 131426f9a767SRodney W. Grimes 13151c7c3c6aSMatthew Dillon for (i = 0; i < count; i += n) { 13161c7c3c6aSMatthew Dillon int s; 13171c7c3c6aSMatthew Dillon int j; 13181c7c3c6aSMatthew Dillon struct buf *bp; 1319a316d390SJohn Dyson daddr_t blk; 132026f9a767SRodney W. Grimes 1321df8bae1dSRodney W. Grimes /* 13221c7c3c6aSMatthew Dillon * Maximum I/O size is limited by a number of factors. 1323df8bae1dSRodney W. Grimes */ 132426f9a767SRodney W. Grimes 13251c7c3c6aSMatthew Dillon n = min(BLIST_MAX_ALLOC, count - i); 1326327f4e83SMatthew Dillon n = min(n, nsw_cluster_max); 13271c7c3c6aSMatthew Dillon 13284dcc5c2dSMatthew Dillon s = splvm(); 13294dcc5c2dSMatthew Dillon 133026f9a767SRodney W. Grimes /* 13311c7c3c6aSMatthew Dillon * Get biggest block of swap we can. If we fail, fall 13321c7c3c6aSMatthew Dillon * back and try to allocate a smaller block. Don't go 13331c7c3c6aSMatthew Dillon * overboard trying to allocate space if it would overly 13341c7c3c6aSMatthew Dillon * fragment swap. 133526f9a767SRodney W. Grimes */ 13361c7c3c6aSMatthew Dillon while ( 13371c7c3c6aSMatthew Dillon (blk = swp_pager_getswapspace(n)) == SWAPBLK_NONE && 13381c7c3c6aSMatthew Dillon n > 4 13391c7c3c6aSMatthew Dillon ) { 13401c7c3c6aSMatthew Dillon n >>= 1; 134126f9a767SRodney W. Grimes } 13421c7c3c6aSMatthew Dillon if (blk == SWAPBLK_NONE) { 13434dcc5c2dSMatthew Dillon for (j = 0; j < n; ++j) 13441c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_FAIL; 13454dcc5c2dSMatthew Dillon splx(s); 13461c7c3c6aSMatthew Dillon continue; 134726f9a767SRodney W. Grimes } 134826f9a767SRodney W. Grimes 134926f9a767SRodney W. Grimes /* 13504dcc5c2dSMatthew Dillon * The I/O we are constructing cannot cross a physical 13514dcc5c2dSMatthew Dillon * disk boundry in the swap stripe. Note: we are still 13524dcc5c2dSMatthew Dillon * at splvm(). 135326f9a767SRodney W. Grimes */ 13541c7c3c6aSMatthew Dillon if ((blk ^ (blk + n)) & dmmax_mask) { 13551c7c3c6aSMatthew Dillon j = ((blk + dmmax) & dmmax_mask) - blk; 13561c7c3c6aSMatthew Dillon swp_pager_freeswapspace(blk + j, n - j); 13571c7c3c6aSMatthew Dillon n = j; 1358e47ed70bSJohn Dyson } 135926f9a767SRodney W. Grimes 136026f9a767SRodney W. Grimes /* 13611c7c3c6aSMatthew Dillon * All I/O parameters have been satisfied, build the I/O 13621c7c3c6aSMatthew Dillon * request and assign the swap space. 13631c7c3c6aSMatthew Dillon * 13641c7c3c6aSMatthew Dillon * NOTE: B_PAGING is set by pbgetvp() 136526f9a767SRodney W. Grimes */ 136626f9a767SRodney W. Grimes 1367327f4e83SMatthew Dillon if (sync == TRUE) { 1368327f4e83SMatthew Dillon bp = getpbuf(&nsw_wcount_sync); 1369327f4e83SMatthew Dillon } else { 1370327f4e83SMatthew Dillon bp = getpbuf(&nsw_wcount_async); 137121144e3bSPoul-Henning Kamp bp->b_flags = B_ASYNC; 1372327f4e83SMatthew Dillon } 1373912e4ae9SPoul-Henning Kamp bp->b_iocmd = BIO_WRITE; 13741c7c3c6aSMatthew Dillon bp->b_spc = NULL; /* not used, but NULL-out anyway */ 137526f9a767SRodney W. Grimes 13761c7c3c6aSMatthew Dillon pmap_qenter((vm_offset_t)bp->b_data, &m[i], n); 13771c7c3c6aSMatthew Dillon 1378b0eeea20SPoul-Henning Kamp bp->b_rcred = bp->b_wcred = proc0.p_ucred; 13791c7c3c6aSMatthew Dillon bp->b_bcount = PAGE_SIZE * n; 13801c7c3c6aSMatthew Dillon bp->b_bufsize = PAGE_SIZE * n; 13811c7c3c6aSMatthew Dillon bp->b_blkno = blk; 1382e47ed70bSJohn Dyson 1383a5296b05SJulian Elischer crhold(bp->b_rcred); 1384a5296b05SJulian Elischer crhold(bp->b_wcred); 1385a5296b05SJulian Elischer 1386a5296b05SJulian Elischer pbgetvp(swapdev_vp, bp); 1387a5296b05SJulian Elischer 13881c7c3c6aSMatthew Dillon for (j = 0; j < n; ++j) { 13891c7c3c6aSMatthew Dillon vm_page_t mreq = m[i+j]; 13901c7c3c6aSMatthew Dillon 13911c7c3c6aSMatthew Dillon swp_pager_meta_build( 13921c7c3c6aSMatthew Dillon mreq->object, 13931c7c3c6aSMatthew Dillon mreq->pindex, 13944dcc5c2dSMatthew Dillon blk + j 13951c7c3c6aSMatthew Dillon ); 13967dbf82dcSMatthew Dillon vm_page_dirty(mreq); 13971c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_OK; 13981c7c3c6aSMatthew Dillon 13991c7c3c6aSMatthew Dillon vm_page_flag_set(mreq, PG_SWAPINPROG); 14001c7c3c6aSMatthew Dillon bp->b_pages[j] = mreq; 14011c7c3c6aSMatthew Dillon } 14021c7c3c6aSMatthew Dillon bp->b_npages = n; 1403a5296b05SJulian Elischer /* 1404a5296b05SJulian Elischer * Must set dirty range for NFS to work. 1405a5296b05SJulian Elischer */ 1406a5296b05SJulian Elischer bp->b_dirtyoff = 0; 1407a5296b05SJulian Elischer bp->b_dirtyend = bp->b_bcount; 14081c7c3c6aSMatthew Dillon 14091c7c3c6aSMatthew Dillon cnt.v_swapout++; 14101c7c3c6aSMatthew Dillon cnt.v_swappgsout += bp->b_npages; 141126f9a767SRodney W. Grimes swapdev_vp->v_numoutput++; 141226f9a767SRodney W. Grimes 14134dcc5c2dSMatthew Dillon splx(s); 14144dcc5c2dSMatthew Dillon 141526f9a767SRodney W. Grimes /* 14161c7c3c6aSMatthew Dillon * asynchronous 14171c7c3c6aSMatthew Dillon * 1418ea3aecf5SPeter Wemm * NOTE: b_blkno is destroyed by the call to VOP_STRATEGY 141926f9a767SRodney W. Grimes */ 1420e47ed70bSJohn Dyson 14211c7c3c6aSMatthew Dillon if (sync == FALSE) { 14221c7c3c6aSMatthew Dillon bp->b_iodone = swp_pager_async_iodone; 142367812eacSKirk McKusick BUF_KERNPROC(bp); 1424b99c307aSPoul-Henning Kamp BUF_STRATEGY(bp); 14251c7c3c6aSMatthew Dillon 14261c7c3c6aSMatthew Dillon for (j = 0; j < n; ++j) 14271c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_PEND; 142823955314SAlfred Perlstein /* restart outter loop */ 14291c7c3c6aSMatthew Dillon continue; 143026f9a767SRodney W. Grimes } 1431e47ed70bSJohn Dyson 143226f9a767SRodney W. Grimes /* 14331c7c3c6aSMatthew Dillon * synchronous 14341c7c3c6aSMatthew Dillon * 1435ea3aecf5SPeter Wemm * NOTE: b_blkno is destroyed by the call to VOP_STRATEGY 14361c7c3c6aSMatthew Dillon */ 14371c7c3c6aSMatthew Dillon 14381c7c3c6aSMatthew Dillon bp->b_iodone = swp_pager_sync_iodone; 1439b99c307aSPoul-Henning Kamp BUF_STRATEGY(bp); 14401c7c3c6aSMatthew Dillon 14411c7c3c6aSMatthew Dillon /* 14421c7c3c6aSMatthew Dillon * Wait for the sync I/O to complete, then update rtvals. 14431c7c3c6aSMatthew Dillon * We just set the rtvals[] to VM_PAGER_PEND so we can call 14441c7c3c6aSMatthew Dillon * our async completion routine at the end, thus avoiding a 14451c7c3c6aSMatthew Dillon * double-free. 144626f9a767SRodney W. Grimes */ 14474dcc5c2dSMatthew Dillon s = splbio(); 14484dcc5c2dSMatthew Dillon 144926f9a767SRodney W. Grimes while ((bp->b_flags & B_DONE) == 0) { 145024a1cce3SDavid Greenman tsleep(bp, PVM, "swwrt", 0); 145126f9a767SRodney W. Grimes } 1452e47ed70bSJohn Dyson 14531c7c3c6aSMatthew Dillon for (j = 0; j < n; ++j) 14541c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_PEND; 145526f9a767SRodney W. Grimes 14561c7c3c6aSMatthew Dillon /* 14571c7c3c6aSMatthew Dillon * Now that we are through with the bp, we can call the 14581c7c3c6aSMatthew Dillon * normal async completion, which frees everything up. 14591c7c3c6aSMatthew Dillon */ 14601c7c3c6aSMatthew Dillon 14611c7c3c6aSMatthew Dillon swp_pager_async_iodone(bp); 146226f9a767SRodney W. Grimes splx(s); 14631c7c3c6aSMatthew Dillon } 14641c7c3c6aSMatthew Dillon } 14651c7c3c6aSMatthew Dillon 14661c7c3c6aSMatthew Dillon /* 14671c7c3c6aSMatthew Dillon * swap_pager_sync_iodone: 14681c7c3c6aSMatthew Dillon * 14691c7c3c6aSMatthew Dillon * Completion routine for synchronous reads and writes from/to swap. 14701c7c3c6aSMatthew Dillon * We just mark the bp is complete and wake up anyone waiting on it. 14711c7c3c6aSMatthew Dillon * 14724dcc5c2dSMatthew Dillon * This routine may not block. This routine is called at splbio() or better. 14731c7c3c6aSMatthew Dillon */ 14741c7c3c6aSMatthew Dillon 14751c7c3c6aSMatthew Dillon static void 14761c7c3c6aSMatthew Dillon swp_pager_sync_iodone(bp) 14771c7c3c6aSMatthew Dillon struct buf *bp; 14781c7c3c6aSMatthew Dillon { 14791c7c3c6aSMatthew Dillon bp->b_flags |= B_DONE; 14801c7c3c6aSMatthew Dillon bp->b_flags &= ~B_ASYNC; 14811c7c3c6aSMatthew Dillon wakeup(bp); 14821c7c3c6aSMatthew Dillon } 14831c7c3c6aSMatthew Dillon 14841c7c3c6aSMatthew Dillon /* 14851c7c3c6aSMatthew Dillon * swp_pager_async_iodone: 14861c7c3c6aSMatthew Dillon * 14871c7c3c6aSMatthew Dillon * Completion routine for asynchronous reads and writes from/to swap. 14881c7c3c6aSMatthew Dillon * Also called manually by synchronous code to finish up a bp. 14891c7c3c6aSMatthew Dillon * 14901c7c3c6aSMatthew Dillon * For READ operations, the pages are PG_BUSY'd. For WRITE operations, 14911c7c3c6aSMatthew Dillon * the pages are vm_page_t->busy'd. For READ operations, we PG_BUSY 14921c7c3c6aSMatthew Dillon * unbusy all pages except the 'main' request page. For WRITE 14931c7c3c6aSMatthew Dillon * operations, we vm_page_t->busy'd unbusy all pages ( we can do this 14941c7c3c6aSMatthew Dillon * because we marked them all VM_PAGER_PEND on return from putpages ). 14951c7c3c6aSMatthew Dillon * 14961c7c3c6aSMatthew Dillon * This routine may not block. 14974dcc5c2dSMatthew Dillon * This routine is called at splbio() or better 14984dcc5c2dSMatthew Dillon * 14994dcc5c2dSMatthew Dillon * We up ourselves to splvm() as required for various vm_page related 15004dcc5c2dSMatthew Dillon * calls. 15011c7c3c6aSMatthew Dillon */ 15021c7c3c6aSMatthew Dillon 15031c7c3c6aSMatthew Dillon static void 15041c7c3c6aSMatthew Dillon swp_pager_async_iodone(bp) 15051c7c3c6aSMatthew Dillon register struct buf *bp; 15061c7c3c6aSMatthew Dillon { 15071c7c3c6aSMatthew Dillon int s; 15081c7c3c6aSMatthew Dillon int i; 15091c7c3c6aSMatthew Dillon vm_object_t object = NULL; 15101c7c3c6aSMatthew Dillon 15110cddd8f0SMatthew Dillon GIANT_REQUIRED; 15120cddd8f0SMatthew Dillon 15131c7c3c6aSMatthew Dillon bp->b_flags |= B_DONE; 15141c7c3c6aSMatthew Dillon 15151c7c3c6aSMatthew Dillon /* 15161c7c3c6aSMatthew Dillon * report error 15171c7c3c6aSMatthew Dillon */ 15181c7c3c6aSMatthew Dillon 1519c244d2deSPoul-Henning Kamp if (bp->b_ioflags & BIO_ERROR) { 15201c7c3c6aSMatthew Dillon printf( 15211c7c3c6aSMatthew Dillon "swap_pager: I/O error - %s failed; blkno %ld," 15221c7c3c6aSMatthew Dillon "size %ld, error %d\n", 152321144e3bSPoul-Henning Kamp ((bp->b_iocmd == BIO_READ) ? "pagein" : "pageout"), 15241c7c3c6aSMatthew Dillon (long)bp->b_blkno, 15251c7c3c6aSMatthew Dillon (long)bp->b_bcount, 15261c7c3c6aSMatthew Dillon bp->b_error 15271c7c3c6aSMatthew Dillon ); 15281c7c3c6aSMatthew Dillon } 15291c7c3c6aSMatthew Dillon 15301c7c3c6aSMatthew Dillon /* 15314dcc5c2dSMatthew Dillon * set object, raise to splvm(). 15321c7c3c6aSMatthew Dillon */ 15331c7c3c6aSMatthew Dillon 15341c7c3c6aSMatthew Dillon if (bp->b_npages) 15351c7c3c6aSMatthew Dillon object = bp->b_pages[0]->object; 15364dcc5c2dSMatthew Dillon s = splvm(); 153726f9a767SRodney W. Grimes 153826f9a767SRodney W. Grimes /* 153926f9a767SRodney W. Grimes * remove the mapping for kernel virtual 154026f9a767SRodney W. Grimes */ 15411c7c3c6aSMatthew Dillon pmap_qremove((vm_offset_t)bp->b_data, bp->b_npages); 154226f9a767SRodney W. Grimes 154326f9a767SRodney W. Grimes /* 15441c7c3c6aSMatthew Dillon * cleanup pages. If an error occurs writing to swap, we are in 15451c7c3c6aSMatthew Dillon * very serious trouble. If it happens to be a disk error, though, 15461c7c3c6aSMatthew Dillon * we may be able to recover by reassigning the swap later on. So 15471c7c3c6aSMatthew Dillon * in this case we remove the m->swapblk assignment for the page 15481c7c3c6aSMatthew Dillon * but do not free it in the rlist. The errornous block(s) are thus 15491c7c3c6aSMatthew Dillon * never reallocated as swap. Redirty the page and continue. 155026f9a767SRodney W. Grimes */ 155126f9a767SRodney W. Grimes 15521c7c3c6aSMatthew Dillon for (i = 0; i < bp->b_npages; ++i) { 15531c7c3c6aSMatthew Dillon vm_page_t m = bp->b_pages[i]; 1554e47ed70bSJohn Dyson 15551c7c3c6aSMatthew Dillon vm_page_flag_clear(m, PG_SWAPINPROG); 1556e47ed70bSJohn Dyson 1557c244d2deSPoul-Henning Kamp if (bp->b_ioflags & BIO_ERROR) { 1558ffc82b0aSJohn Dyson /* 15591c7c3c6aSMatthew Dillon * If an error occurs I'd love to throw the swapblk 15601c7c3c6aSMatthew Dillon * away without freeing it back to swapspace, so it 15611c7c3c6aSMatthew Dillon * can never be used again. But I can't from an 15621c7c3c6aSMatthew Dillon * interrupt. 1563ffc82b0aSJohn Dyson */ 15641c7c3c6aSMatthew Dillon 156521144e3bSPoul-Henning Kamp if (bp->b_iocmd == BIO_READ) { 15661c7c3c6aSMatthew Dillon /* 15671c7c3c6aSMatthew Dillon * When reading, reqpage needs to stay 15681c7c3c6aSMatthew Dillon * locked for the parent, but all other 15691c7c3c6aSMatthew Dillon * pages can be freed. We still want to 15701c7c3c6aSMatthew Dillon * wakeup the parent waiting on the page, 15711c7c3c6aSMatthew Dillon * though. ( also: pg_reqpage can be -1 and 15721c7c3c6aSMatthew Dillon * not match anything ). 15731c7c3c6aSMatthew Dillon * 15741c7c3c6aSMatthew Dillon * We have to wake specifically requested pages 15751c7c3c6aSMatthew Dillon * up too because we cleared PG_SWAPINPROG and 15761c7c3c6aSMatthew Dillon * someone may be waiting for that. 15771c7c3c6aSMatthew Dillon * 15781c7c3c6aSMatthew Dillon * NOTE: for reads, m->dirty will probably 1579956f3135SPhilippe Charnier * be overridden by the original caller of 15801c7c3c6aSMatthew Dillon * getpages so don't play cute tricks here. 15811c7c3c6aSMatthew Dillon * 1582279d7226SMatthew Dillon * XXX IT IS NOT LEGAL TO FREE THE PAGE HERE 1583279d7226SMatthew Dillon * AS THIS MESSES WITH object->memq, and it is 1584279d7226SMatthew Dillon * not legal to mess with object->memq from an 1585279d7226SMatthew Dillon * interrupt. 15861c7c3c6aSMatthew Dillon */ 15871c7c3c6aSMatthew Dillon 15881c7c3c6aSMatthew Dillon m->valid = 0; 15891c7c3c6aSMatthew Dillon vm_page_flag_clear(m, PG_ZERO); 15901c7c3c6aSMatthew Dillon 15911c7c3c6aSMatthew Dillon if (i != bp->b_pager.pg_reqpage) 15921c7c3c6aSMatthew Dillon vm_page_free(m); 15931c7c3c6aSMatthew Dillon else 15941c7c3c6aSMatthew Dillon vm_page_flash(m); 15951c7c3c6aSMatthew Dillon /* 15961c7c3c6aSMatthew Dillon * If i == bp->b_pager.pg_reqpage, do not wake 15971c7c3c6aSMatthew Dillon * the page up. The caller needs to. 15981c7c3c6aSMatthew Dillon */ 15991c7c3c6aSMatthew Dillon } else { 16001c7c3c6aSMatthew Dillon /* 16011c7c3c6aSMatthew Dillon * If a write error occurs, reactivate page 16021c7c3c6aSMatthew Dillon * so it doesn't clog the inactive list, 16031c7c3c6aSMatthew Dillon * then finish the I/O. 16041c7c3c6aSMatthew Dillon */ 16057dbf82dcSMatthew Dillon vm_page_dirty(m); 16061c7c3c6aSMatthew Dillon vm_page_activate(m); 16071c7c3c6aSMatthew Dillon vm_page_io_finish(m); 16081c7c3c6aSMatthew Dillon } 160921144e3bSPoul-Henning Kamp } else if (bp->b_iocmd == BIO_READ) { 16101c7c3c6aSMatthew Dillon /* 16111c7c3c6aSMatthew Dillon * For read success, clear dirty bits. Nobody should 16121c7c3c6aSMatthew Dillon * have this page mapped but don't take any chances, 16131c7c3c6aSMatthew Dillon * make sure the pmap modify bits are also cleared. 16141c7c3c6aSMatthew Dillon * 16151c7c3c6aSMatthew Dillon * NOTE: for reads, m->dirty will probably be 1616956f3135SPhilippe Charnier * overridden by the original caller of getpages so 16171c7c3c6aSMatthew Dillon * we cannot set them in order to free the underlying 16181c7c3c6aSMatthew Dillon * swap in a low-swap situation. I don't think we'd 16191c7c3c6aSMatthew Dillon * want to do that anyway, but it was an optimization 16201c7c3c6aSMatthew Dillon * that existed in the old swapper for a time before 16211c7c3c6aSMatthew Dillon * it got ripped out due to precisely this problem. 16221c7c3c6aSMatthew Dillon * 16231c7c3c6aSMatthew Dillon * clear PG_ZERO in page. 16241c7c3c6aSMatthew Dillon * 16251c7c3c6aSMatthew Dillon * If not the requested page then deactivate it. 16261c7c3c6aSMatthew Dillon * 16271c7c3c6aSMatthew Dillon * Note that the requested page, reqpage, is left 16281c7c3c6aSMatthew Dillon * busied, but we still have to wake it up. The 16291c7c3c6aSMatthew Dillon * other pages are released (unbusied) by 16301c7c3c6aSMatthew Dillon * vm_page_wakeup(). We do not set reqpage's 16311c7c3c6aSMatthew Dillon * valid bits here, it is up to the caller. 16321c7c3c6aSMatthew Dillon */ 16331c7c3c6aSMatthew Dillon 16340385347cSPeter Wemm pmap_clear_modify(m); 16351c7c3c6aSMatthew Dillon m->valid = VM_PAGE_BITS_ALL; 16362c28a105SAlan Cox vm_page_undirty(m); 16371c7c3c6aSMatthew Dillon vm_page_flag_clear(m, PG_ZERO); 16381c7c3c6aSMatthew Dillon 16391c7c3c6aSMatthew Dillon /* 16401c7c3c6aSMatthew Dillon * We have to wake specifically requested pages 16411c7c3c6aSMatthew Dillon * up too because we cleared PG_SWAPINPROG and 16421c7c3c6aSMatthew Dillon * could be waiting for it in getpages. However, 16431c7c3c6aSMatthew Dillon * be sure to not unbusy getpages specifically 16441c7c3c6aSMatthew Dillon * requested page - getpages expects it to be 16451c7c3c6aSMatthew Dillon * left busy. 16461c7c3c6aSMatthew Dillon */ 16471c7c3c6aSMatthew Dillon if (i != bp->b_pager.pg_reqpage) { 16481c7c3c6aSMatthew Dillon vm_page_deactivate(m); 16491c7c3c6aSMatthew Dillon vm_page_wakeup(m); 16501c7c3c6aSMatthew Dillon } else { 16511c7c3c6aSMatthew Dillon vm_page_flash(m); 16521c7c3c6aSMatthew Dillon } 16531c7c3c6aSMatthew Dillon } else { 16541c7c3c6aSMatthew Dillon /* 16551c7c3c6aSMatthew Dillon * For write success, clear the modify and dirty 16561c7c3c6aSMatthew Dillon * status, then finish the I/O ( which decrements the 16571c7c3c6aSMatthew Dillon * busy count and possibly wakes waiter's up ). 16581c7c3c6aSMatthew Dillon */ 16590385347cSPeter Wemm pmap_clear_modify(m); 1660c52e7044SAlan Cox vm_page_undirty(m); 16611c7c3c6aSMatthew Dillon vm_page_io_finish(m); 1662936524aaSMatthew Dillon if (!vm_page_count_severe() || !vm_page_try_to_cache(m)) 1663936524aaSMatthew Dillon vm_page_protect(m, VM_PROT_READ); 1664ffc82b0aSJohn Dyson } 1665df8bae1dSRodney W. Grimes } 166626f9a767SRodney W. Grimes 16671c7c3c6aSMatthew Dillon /* 16681c7c3c6aSMatthew Dillon * adjust pip. NOTE: the original parent may still have its own 16691c7c3c6aSMatthew Dillon * pip refs on the object. 16701c7c3c6aSMatthew Dillon */ 16710d94caffSDavid Greenman 16721c7c3c6aSMatthew Dillon if (object) 16731c7c3c6aSMatthew Dillon vm_object_pip_wakeupn(object, bp->b_npages); 167426f9a767SRodney W. Grimes 16751c7c3c6aSMatthew Dillon /* 16761c7c3c6aSMatthew Dillon * release the physical I/O buffer 16771c7c3c6aSMatthew Dillon */ 1678e47ed70bSJohn Dyson 1679327f4e83SMatthew Dillon relpbuf( 1680327f4e83SMatthew Dillon bp, 168121144e3bSPoul-Henning Kamp ((bp->b_iocmd == BIO_READ) ? &nsw_rcount : 1682327f4e83SMatthew Dillon ((bp->b_flags & B_ASYNC) ? 1683327f4e83SMatthew Dillon &nsw_wcount_async : 1684327f4e83SMatthew Dillon &nsw_wcount_sync 1685327f4e83SMatthew Dillon ) 1686327f4e83SMatthew Dillon ) 1687327f4e83SMatthew Dillon ); 168826f9a767SRodney W. Grimes splx(s); 168926f9a767SRodney W. Grimes } 16901c7c3c6aSMatthew Dillon 16911c7c3c6aSMatthew Dillon /************************************************************************ 16921c7c3c6aSMatthew Dillon * SWAP META DATA * 16931c7c3c6aSMatthew Dillon ************************************************************************ 16941c7c3c6aSMatthew Dillon * 16951c7c3c6aSMatthew Dillon * These routines manipulate the swap metadata stored in the 16964dcc5c2dSMatthew Dillon * OBJT_SWAP object. All swp_*() routines must be called at 16974dcc5c2dSMatthew Dillon * splvm() because swap can be freed up by the low level vm_page 16984dcc5c2dSMatthew Dillon * code which might be called from interrupts beyond what splbio() covers. 16991c7c3c6aSMatthew Dillon * 17004dcc5c2dSMatthew Dillon * Swap metadata is implemented with a global hash and not directly 17014dcc5c2dSMatthew Dillon * linked into the object. Instead the object simply contains 17024dcc5c2dSMatthew Dillon * appropriate tracking counters. 17031c7c3c6aSMatthew Dillon */ 17041c7c3c6aSMatthew Dillon 17051c7c3c6aSMatthew Dillon /* 17061c7c3c6aSMatthew Dillon * SWP_PAGER_HASH() - hash swap meta data 17071c7c3c6aSMatthew Dillon * 17084dcc5c2dSMatthew Dillon * This is an inline helper function which hashes the swapblk given 17091c7c3c6aSMatthew Dillon * the object and page index. It returns a pointer to a pointer 17101c7c3c6aSMatthew Dillon * to the object, or a pointer to a NULL pointer if it could not 17111c7c3c6aSMatthew Dillon * find a swapblk. 17124dcc5c2dSMatthew Dillon * 17134dcc5c2dSMatthew Dillon * This routine must be called at splvm(). 17141c7c3c6aSMatthew Dillon */ 17151c7c3c6aSMatthew Dillon 17161c7c3c6aSMatthew Dillon static __inline struct swblock ** 17174dcc5c2dSMatthew Dillon swp_pager_hash(vm_object_t object, vm_pindex_t index) 17181c7c3c6aSMatthew Dillon { 17191c7c3c6aSMatthew Dillon struct swblock **pswap; 17201c7c3c6aSMatthew Dillon struct swblock *swap; 17211c7c3c6aSMatthew Dillon 17221c7c3c6aSMatthew Dillon index &= ~SWAP_META_MASK; 1723af647ddeSBruce Evans pswap = &swhash[(index ^ (int)(intptr_t)object) & swhash_mask]; 17241c7c3c6aSMatthew Dillon 17251c7c3c6aSMatthew Dillon while ((swap = *pswap) != NULL) { 17261c7c3c6aSMatthew Dillon if (swap->swb_object == object && 17271c7c3c6aSMatthew Dillon swap->swb_index == index 17281c7c3c6aSMatthew Dillon ) { 17291c7c3c6aSMatthew Dillon break; 17301c7c3c6aSMatthew Dillon } 17311c7c3c6aSMatthew Dillon pswap = &swap->swb_hnext; 17321c7c3c6aSMatthew Dillon } 17331c7c3c6aSMatthew Dillon return(pswap); 17341c7c3c6aSMatthew Dillon } 17351c7c3c6aSMatthew Dillon 17361c7c3c6aSMatthew Dillon /* 17371c7c3c6aSMatthew Dillon * SWP_PAGER_META_BUILD() - add swap block to swap meta data for object 17381c7c3c6aSMatthew Dillon * 17391c7c3c6aSMatthew Dillon * We first convert the object to a swap object if it is a default 17401c7c3c6aSMatthew Dillon * object. 17411c7c3c6aSMatthew Dillon * 17421c7c3c6aSMatthew Dillon * The specified swapblk is added to the object's swap metadata. If 17431c7c3c6aSMatthew Dillon * the swapblk is not valid, it is freed instead. Any previously 17441c7c3c6aSMatthew Dillon * assigned swapblk is freed. 17454dcc5c2dSMatthew Dillon * 17464dcc5c2dSMatthew Dillon * This routine must be called at splvm(), except when used to convert 17474dcc5c2dSMatthew Dillon * an OBJT_DEFAULT object into an OBJT_SWAP object. 17481c7c3c6aSMatthew Dillon */ 17491c7c3c6aSMatthew Dillon 17501c7c3c6aSMatthew Dillon static void 17511c7c3c6aSMatthew Dillon swp_pager_meta_build( 17521c7c3c6aSMatthew Dillon vm_object_t object, 17534dcc5c2dSMatthew Dillon vm_pindex_t index, 17544dcc5c2dSMatthew Dillon daddr_t swapblk 17551c7c3c6aSMatthew Dillon ) { 17561c7c3c6aSMatthew Dillon struct swblock *swap; 17571c7c3c6aSMatthew Dillon struct swblock **pswap; 17581c7c3c6aSMatthew Dillon 17590cddd8f0SMatthew Dillon GIANT_REQUIRED; 17601c7c3c6aSMatthew Dillon /* 17611c7c3c6aSMatthew Dillon * Convert default object to swap object if necessary 17621c7c3c6aSMatthew Dillon */ 17631c7c3c6aSMatthew Dillon 17641c7c3c6aSMatthew Dillon if (object->type != OBJT_SWAP) { 17651c7c3c6aSMatthew Dillon object->type = OBJT_SWAP; 17661c7c3c6aSMatthew Dillon object->un_pager.swp.swp_bcount = 0; 17671c7c3c6aSMatthew Dillon 1768a9fa2c05SAlfred Perlstein mtx_lock(&sw_alloc_mtx); 17691c7c3c6aSMatthew Dillon if (object->handle != NULL) { 17701c7c3c6aSMatthew Dillon TAILQ_INSERT_TAIL( 17711c7c3c6aSMatthew Dillon NOBJLIST(object->handle), 17721c7c3c6aSMatthew Dillon object, 17731c7c3c6aSMatthew Dillon pager_object_list 17741c7c3c6aSMatthew Dillon ); 17751c7c3c6aSMatthew Dillon } else { 17761c7c3c6aSMatthew Dillon TAILQ_INSERT_TAIL( 17771c7c3c6aSMatthew Dillon &swap_pager_un_object_list, 17781c7c3c6aSMatthew Dillon object, 17791c7c3c6aSMatthew Dillon pager_object_list 17801c7c3c6aSMatthew Dillon ); 17811c7c3c6aSMatthew Dillon } 1782a9fa2c05SAlfred Perlstein mtx_unlock(&sw_alloc_mtx); 17831c7c3c6aSMatthew Dillon } 17841c7c3c6aSMatthew Dillon 17851c7c3c6aSMatthew Dillon /* 17861c7c3c6aSMatthew Dillon * Locate hash entry. If not found create, but if we aren't adding 17874dcc5c2dSMatthew Dillon * anything just return. If we run out of space in the map we wait 17884dcc5c2dSMatthew Dillon * and, since the hash table may have changed, retry. 17891c7c3c6aSMatthew Dillon */ 17901c7c3c6aSMatthew Dillon 17914dcc5c2dSMatthew Dillon retry: 17921c7c3c6aSMatthew Dillon pswap = swp_pager_hash(object, index); 17931c7c3c6aSMatthew Dillon 17941c7c3c6aSMatthew Dillon if ((swap = *pswap) == NULL) { 17951c7c3c6aSMatthew Dillon int i; 17961c7c3c6aSMatthew Dillon 17971c7c3c6aSMatthew Dillon if (swapblk == SWAPBLK_NONE) 17981c7c3c6aSMatthew Dillon return; 17991c7c3c6aSMatthew Dillon 18001c7c3c6aSMatthew Dillon swap = *pswap = zalloc(swap_zone); 18014dcc5c2dSMatthew Dillon if (swap == NULL) { 18024dcc5c2dSMatthew Dillon VM_WAIT; 18034dcc5c2dSMatthew Dillon goto retry; 18044dcc5c2dSMatthew Dillon } 18051c7c3c6aSMatthew Dillon swap->swb_hnext = NULL; 18061c7c3c6aSMatthew Dillon swap->swb_object = object; 18071c7c3c6aSMatthew Dillon swap->swb_index = index & ~SWAP_META_MASK; 18081c7c3c6aSMatthew Dillon swap->swb_count = 0; 18091c7c3c6aSMatthew Dillon 18101c7c3c6aSMatthew Dillon ++object->un_pager.swp.swp_bcount; 18111c7c3c6aSMatthew Dillon 18121c7c3c6aSMatthew Dillon for (i = 0; i < SWAP_META_PAGES; ++i) 18131c7c3c6aSMatthew Dillon swap->swb_pages[i] = SWAPBLK_NONE; 18141c7c3c6aSMatthew Dillon } 18151c7c3c6aSMatthew Dillon 18161c7c3c6aSMatthew Dillon /* 18171c7c3c6aSMatthew Dillon * Delete prior contents of metadata 18181c7c3c6aSMatthew Dillon */ 18191c7c3c6aSMatthew Dillon 18201c7c3c6aSMatthew Dillon index &= SWAP_META_MASK; 18211c7c3c6aSMatthew Dillon 18221c7c3c6aSMatthew Dillon if (swap->swb_pages[index] != SWAPBLK_NONE) { 18234dcc5c2dSMatthew Dillon swp_pager_freeswapspace(swap->swb_pages[index], 1); 18241c7c3c6aSMatthew Dillon --swap->swb_count; 18251c7c3c6aSMatthew Dillon } 18261c7c3c6aSMatthew Dillon 18271c7c3c6aSMatthew Dillon /* 18281c7c3c6aSMatthew Dillon * Enter block into metadata 18291c7c3c6aSMatthew Dillon */ 18301c7c3c6aSMatthew Dillon 18311c7c3c6aSMatthew Dillon swap->swb_pages[index] = swapblk; 18324dcc5c2dSMatthew Dillon if (swapblk != SWAPBLK_NONE) 18331c7c3c6aSMatthew Dillon ++swap->swb_count; 18341c7c3c6aSMatthew Dillon } 18351c7c3c6aSMatthew Dillon 18361c7c3c6aSMatthew Dillon /* 18371c7c3c6aSMatthew Dillon * SWP_PAGER_META_FREE() - free a range of blocks in the object's swap metadata 18381c7c3c6aSMatthew Dillon * 18391c7c3c6aSMatthew Dillon * The requested range of blocks is freed, with any associated swap 18401c7c3c6aSMatthew Dillon * returned to the swap bitmap. 18411c7c3c6aSMatthew Dillon * 18421c7c3c6aSMatthew Dillon * This routine will free swap metadata structures as they are cleaned 18431c7c3c6aSMatthew Dillon * out. This routine does *NOT* operate on swap metadata associated 18441c7c3c6aSMatthew Dillon * with resident pages. 18451c7c3c6aSMatthew Dillon * 18461c7c3c6aSMatthew Dillon * This routine must be called at splvm() 18471c7c3c6aSMatthew Dillon */ 18481c7c3c6aSMatthew Dillon 18491c7c3c6aSMatthew Dillon static void 18504dcc5c2dSMatthew Dillon swp_pager_meta_free(vm_object_t object, vm_pindex_t index, daddr_t count) 18511c7c3c6aSMatthew Dillon { 18520cddd8f0SMatthew Dillon GIANT_REQUIRED; 185323955314SAlfred Perlstein 18541c7c3c6aSMatthew Dillon if (object->type != OBJT_SWAP) 18551c7c3c6aSMatthew Dillon return; 18561c7c3c6aSMatthew Dillon 18571c7c3c6aSMatthew Dillon while (count > 0) { 18581c7c3c6aSMatthew Dillon struct swblock **pswap; 18591c7c3c6aSMatthew Dillon struct swblock *swap; 18601c7c3c6aSMatthew Dillon 18611c7c3c6aSMatthew Dillon pswap = swp_pager_hash(object, index); 18621c7c3c6aSMatthew Dillon 18631c7c3c6aSMatthew Dillon if ((swap = *pswap) != NULL) { 18641c7c3c6aSMatthew Dillon daddr_t v = swap->swb_pages[index & SWAP_META_MASK]; 18651c7c3c6aSMatthew Dillon 18661c7c3c6aSMatthew Dillon if (v != SWAPBLK_NONE) { 18671c7c3c6aSMatthew Dillon swp_pager_freeswapspace(v, 1); 18681c7c3c6aSMatthew Dillon swap->swb_pages[index & SWAP_META_MASK] = 18691c7c3c6aSMatthew Dillon SWAPBLK_NONE; 18701c7c3c6aSMatthew Dillon if (--swap->swb_count == 0) { 18711c7c3c6aSMatthew Dillon *pswap = swap->swb_hnext; 18721c7c3c6aSMatthew Dillon zfree(swap_zone, swap); 18731c7c3c6aSMatthew Dillon --object->un_pager.swp.swp_bcount; 18741c7c3c6aSMatthew Dillon } 18751c7c3c6aSMatthew Dillon } 18761c7c3c6aSMatthew Dillon --count; 18771c7c3c6aSMatthew Dillon ++index; 18781c7c3c6aSMatthew Dillon } else { 18794dcc5c2dSMatthew Dillon int n = SWAP_META_PAGES - (index & SWAP_META_MASK); 18801c7c3c6aSMatthew Dillon count -= n; 18811c7c3c6aSMatthew Dillon index += n; 18821c7c3c6aSMatthew Dillon } 18831c7c3c6aSMatthew Dillon } 18841c7c3c6aSMatthew Dillon } 18851c7c3c6aSMatthew Dillon 18861c7c3c6aSMatthew Dillon /* 18871c7c3c6aSMatthew Dillon * SWP_PAGER_META_FREE_ALL() - destroy all swap metadata associated with object 18881c7c3c6aSMatthew Dillon * 18891c7c3c6aSMatthew Dillon * This routine locates and destroys all swap metadata associated with 18901c7c3c6aSMatthew Dillon * an object. 18914dcc5c2dSMatthew Dillon * 18924dcc5c2dSMatthew Dillon * This routine must be called at splvm() 18931c7c3c6aSMatthew Dillon */ 18941c7c3c6aSMatthew Dillon 18951c7c3c6aSMatthew Dillon static void 18961c7c3c6aSMatthew Dillon swp_pager_meta_free_all(vm_object_t object) 18971c7c3c6aSMatthew Dillon { 18981c7c3c6aSMatthew Dillon daddr_t index = 0; 18991c7c3c6aSMatthew Dillon 19000cddd8f0SMatthew Dillon GIANT_REQUIRED; 190123955314SAlfred Perlstein 19021c7c3c6aSMatthew Dillon if (object->type != OBJT_SWAP) 19031c7c3c6aSMatthew Dillon return; 19041c7c3c6aSMatthew Dillon 19051c7c3c6aSMatthew Dillon while (object->un_pager.swp.swp_bcount) { 19061c7c3c6aSMatthew Dillon struct swblock **pswap; 19071c7c3c6aSMatthew Dillon struct swblock *swap; 19081c7c3c6aSMatthew Dillon 19091c7c3c6aSMatthew Dillon pswap = swp_pager_hash(object, index); 19101c7c3c6aSMatthew Dillon if ((swap = *pswap) != NULL) { 19111c7c3c6aSMatthew Dillon int i; 19121c7c3c6aSMatthew Dillon 19131c7c3c6aSMatthew Dillon for (i = 0; i < SWAP_META_PAGES; ++i) { 19141c7c3c6aSMatthew Dillon daddr_t v = swap->swb_pages[i]; 19151c7c3c6aSMatthew Dillon if (v != SWAPBLK_NONE) { 19161c7c3c6aSMatthew Dillon --swap->swb_count; 19174dcc5c2dSMatthew Dillon swp_pager_freeswapspace(v, 1); 19181c7c3c6aSMatthew Dillon } 19191c7c3c6aSMatthew Dillon } 19201c7c3c6aSMatthew Dillon if (swap->swb_count != 0) 19211c7c3c6aSMatthew Dillon panic("swap_pager_meta_free_all: swb_count != 0"); 19221c7c3c6aSMatthew Dillon *pswap = swap->swb_hnext; 19231c7c3c6aSMatthew Dillon zfree(swap_zone, swap); 19241c7c3c6aSMatthew Dillon --object->un_pager.swp.swp_bcount; 19251c7c3c6aSMatthew Dillon } 19261c7c3c6aSMatthew Dillon index += SWAP_META_PAGES; 19271c7c3c6aSMatthew Dillon if (index > 0x20000000) 19281c7c3c6aSMatthew Dillon panic("swp_pager_meta_free_all: failed to locate all swap meta blocks"); 19291c7c3c6aSMatthew Dillon } 19301c7c3c6aSMatthew Dillon } 19311c7c3c6aSMatthew Dillon 19321c7c3c6aSMatthew Dillon /* 19331c7c3c6aSMatthew Dillon * SWP_PAGER_METACTL() - misc control of swap and vm_page_t meta data. 19341c7c3c6aSMatthew Dillon * 19351c7c3c6aSMatthew Dillon * This routine is capable of looking up, popping, or freeing 19361c7c3c6aSMatthew Dillon * swapblk assignments in the swap meta data or in the vm_page_t. 19371c7c3c6aSMatthew Dillon * The routine typically returns the swapblk being looked-up, or popped, 19381c7c3c6aSMatthew Dillon * or SWAPBLK_NONE if the block was freed, or SWAPBLK_NONE if the block 19391c7c3c6aSMatthew Dillon * was invalid. This routine will automatically free any invalid 19401c7c3c6aSMatthew Dillon * meta-data swapblks. 19411c7c3c6aSMatthew Dillon * 19421c7c3c6aSMatthew Dillon * It is not possible to store invalid swapblks in the swap meta data 19431c7c3c6aSMatthew Dillon * (other then a literal 'SWAPBLK_NONE'), so we don't bother checking. 19441c7c3c6aSMatthew Dillon * 19451c7c3c6aSMatthew Dillon * When acting on a busy resident page and paging is in progress, we 19461c7c3c6aSMatthew Dillon * have to wait until paging is complete but otherwise can act on the 19471c7c3c6aSMatthew Dillon * busy page. 19481c7c3c6aSMatthew Dillon * 19494dcc5c2dSMatthew Dillon * This routine must be called at splvm(). 19501c7c3c6aSMatthew Dillon * 19514dcc5c2dSMatthew Dillon * SWM_FREE remove and free swap block from metadata 19521c7c3c6aSMatthew Dillon * SWM_POP remove from meta data but do not free.. pop it out 19531c7c3c6aSMatthew Dillon */ 19541c7c3c6aSMatthew Dillon 19551c7c3c6aSMatthew Dillon static daddr_t 19561c7c3c6aSMatthew Dillon swp_pager_meta_ctl( 19571c7c3c6aSMatthew Dillon vm_object_t object, 19581c7c3c6aSMatthew Dillon vm_pindex_t index, 19591c7c3c6aSMatthew Dillon int flags 19601c7c3c6aSMatthew Dillon ) { 19614dcc5c2dSMatthew Dillon struct swblock **pswap; 19624dcc5c2dSMatthew Dillon struct swblock *swap; 19634dcc5c2dSMatthew Dillon daddr_t r1; 19644dcc5c2dSMatthew Dillon 19650cddd8f0SMatthew Dillon GIANT_REQUIRED; 19661c7c3c6aSMatthew Dillon /* 19671c7c3c6aSMatthew Dillon * The meta data only exists of the object is OBJT_SWAP 19681c7c3c6aSMatthew Dillon * and even then might not be allocated yet. 19691c7c3c6aSMatthew Dillon */ 19701c7c3c6aSMatthew Dillon 19714dcc5c2dSMatthew Dillon if (object->type != OBJT_SWAP) 19721c7c3c6aSMatthew Dillon return(SWAPBLK_NONE); 19731c7c3c6aSMatthew Dillon 19744dcc5c2dSMatthew Dillon r1 = SWAPBLK_NONE; 19751c7c3c6aSMatthew Dillon pswap = swp_pager_hash(object, index); 19761c7c3c6aSMatthew Dillon 19771c7c3c6aSMatthew Dillon if ((swap = *pswap) != NULL) { 19784dcc5c2dSMatthew Dillon index &= SWAP_META_MASK; 19791c7c3c6aSMatthew Dillon r1 = swap->swb_pages[index]; 19801c7c3c6aSMatthew Dillon 19811c7c3c6aSMatthew Dillon if (r1 != SWAPBLK_NONE) { 19821c7c3c6aSMatthew Dillon if (flags & SWM_FREE) { 19834dcc5c2dSMatthew Dillon swp_pager_freeswapspace(r1, 1); 19841c7c3c6aSMatthew Dillon r1 = SWAPBLK_NONE; 19851c7c3c6aSMatthew Dillon } 19861c7c3c6aSMatthew Dillon if (flags & (SWM_FREE|SWM_POP)) { 19871c7c3c6aSMatthew Dillon swap->swb_pages[index] = SWAPBLK_NONE; 19881c7c3c6aSMatthew Dillon if (--swap->swb_count == 0) { 19891c7c3c6aSMatthew Dillon *pswap = swap->swb_hnext; 19901c7c3c6aSMatthew Dillon zfree(swap_zone, swap); 19911c7c3c6aSMatthew Dillon --object->un_pager.swp.swp_bcount; 19921c7c3c6aSMatthew Dillon } 19931c7c3c6aSMatthew Dillon } 19941c7c3c6aSMatthew Dillon } 19951c7c3c6aSMatthew Dillon } 19961c7c3c6aSMatthew Dillon return(r1); 19971c7c3c6aSMatthew Dillon } 19981c7c3c6aSMatthew Dillon 1999e4057dbdSPoul-Henning Kamp /******************************************************** 2000e4057dbdSPoul-Henning Kamp * CHAINING FUNCTIONS * 2001e4057dbdSPoul-Henning Kamp ******************************************************** 2002e4057dbdSPoul-Henning Kamp * 2003e4057dbdSPoul-Henning Kamp * These functions support recursion of I/O operations 2004e4057dbdSPoul-Henning Kamp * on bp's, typically by chaining one or more 'child' bp's 2005e4057dbdSPoul-Henning Kamp * to the parent. Synchronous, asynchronous, and semi-synchronous 2006e4057dbdSPoul-Henning Kamp * chaining is possible. 2007e4057dbdSPoul-Henning Kamp */ 2008e4057dbdSPoul-Henning Kamp 2009e4057dbdSPoul-Henning Kamp /* 2010e4057dbdSPoul-Henning Kamp * vm_pager_chain_iodone: 2011e4057dbdSPoul-Henning Kamp * 2012e4057dbdSPoul-Henning Kamp * io completion routine for child bp. Currently we fudge a bit 2013e4057dbdSPoul-Henning Kamp * on dealing with b_resid. Since users of these routines may issue 2014e4057dbdSPoul-Henning Kamp * multiple children simultaneously, sequencing of the error can be lost. 2015e4057dbdSPoul-Henning Kamp */ 2016e4057dbdSPoul-Henning Kamp 2017e4057dbdSPoul-Henning Kamp static void 2018e4057dbdSPoul-Henning Kamp vm_pager_chain_iodone(struct buf *nbp) 2019e4057dbdSPoul-Henning Kamp { 20200b441832SPoul-Henning Kamp struct bio *bp; 20210b441832SPoul-Henning Kamp u_int *count; 2022e4057dbdSPoul-Henning Kamp 20230b441832SPoul-Henning Kamp bp = nbp->b_caller1; 20240b441832SPoul-Henning Kamp count = (u_int *)&(bp->bio_caller1); 20250b441832SPoul-Henning Kamp if (bp != NULL) { 2026e4057dbdSPoul-Henning Kamp if (nbp->b_ioflags & BIO_ERROR) { 20270b441832SPoul-Henning Kamp bp->bio_flags |= BIO_ERROR; 20280b441832SPoul-Henning Kamp bp->bio_error = nbp->b_error; 2029e4057dbdSPoul-Henning Kamp } else if (nbp->b_resid != 0) { 20300b441832SPoul-Henning Kamp bp->bio_flags |= BIO_ERROR; 20310b441832SPoul-Henning Kamp bp->bio_error = EINVAL; 2032e4057dbdSPoul-Henning Kamp } else { 20330b441832SPoul-Henning Kamp bp->bio_resid -= nbp->b_bcount; 2034e4057dbdSPoul-Henning Kamp } 20350b441832SPoul-Henning Kamp nbp->b_caller1 = NULL; 20360b441832SPoul-Henning Kamp --(*count); 20370b441832SPoul-Henning Kamp if (bp->bio_flags & BIO_FLAG1) { 20380b441832SPoul-Henning Kamp bp->bio_flags &= ~BIO_FLAG1; 2039e4057dbdSPoul-Henning Kamp wakeup(bp); 2040e4057dbdSPoul-Henning Kamp } 2041e4057dbdSPoul-Henning Kamp } 2042e4057dbdSPoul-Henning Kamp nbp->b_flags |= B_DONE; 2043e4057dbdSPoul-Henning Kamp nbp->b_flags &= ~B_ASYNC; 2044e4057dbdSPoul-Henning Kamp relpbuf(nbp, NULL); 2045e4057dbdSPoul-Henning Kamp } 2046e4057dbdSPoul-Henning Kamp 2047e4057dbdSPoul-Henning Kamp /* 2048e4057dbdSPoul-Henning Kamp * getchainbuf: 2049e4057dbdSPoul-Henning Kamp * 2050e4057dbdSPoul-Henning Kamp * Obtain a physical buffer and chain it to its parent buffer. When 2051e4057dbdSPoul-Henning Kamp * I/O completes, the parent buffer will be B_SIGNAL'd. Errors are 2052e4057dbdSPoul-Henning Kamp * automatically propagated to the parent 2053e4057dbdSPoul-Henning Kamp */ 2054e4057dbdSPoul-Henning Kamp 2055e4057dbdSPoul-Henning Kamp struct buf * 20560b441832SPoul-Henning Kamp getchainbuf(struct bio *bp, struct vnode *vp, int flags) 2057e4057dbdSPoul-Henning Kamp { 205823955314SAlfred Perlstein struct buf *nbp; 205923955314SAlfred Perlstein u_int *count; 206023955314SAlfred Perlstein 20610cddd8f0SMatthew Dillon GIANT_REQUIRED; 206223955314SAlfred Perlstein nbp = getpbuf(NULL); 206323955314SAlfred Perlstein count = (u_int *)&(bp->bio_caller1); 2064e4057dbdSPoul-Henning Kamp 20650b441832SPoul-Henning Kamp nbp->b_caller1 = bp; 20660b441832SPoul-Henning Kamp ++(*count); 2067e4057dbdSPoul-Henning Kamp 20680b441832SPoul-Henning Kamp if (*count > 4) 2069e4057dbdSPoul-Henning Kamp waitchainbuf(bp, 4, 0); 2070e4057dbdSPoul-Henning Kamp 20710b441832SPoul-Henning Kamp nbp->b_iocmd = bp->bio_cmd; 20720b441832SPoul-Henning Kamp nbp->b_ioflags = bp->bio_flags & BIO_ORDERED; 2073e4057dbdSPoul-Henning Kamp nbp->b_flags = flags; 2074e4057dbdSPoul-Henning Kamp nbp->b_rcred = nbp->b_wcred = proc0.p_ucred; 2075e4057dbdSPoul-Henning Kamp nbp->b_iodone = vm_pager_chain_iodone; 2076e4057dbdSPoul-Henning Kamp 2077e4057dbdSPoul-Henning Kamp crhold(nbp->b_rcred); 2078e4057dbdSPoul-Henning Kamp crhold(nbp->b_wcred); 2079e4057dbdSPoul-Henning Kamp 2080e4057dbdSPoul-Henning Kamp if (vp) 2081e4057dbdSPoul-Henning Kamp pbgetvp(vp, nbp); 2082e4057dbdSPoul-Henning Kamp return(nbp); 2083e4057dbdSPoul-Henning Kamp } 2084e4057dbdSPoul-Henning Kamp 2085e4057dbdSPoul-Henning Kamp void 2086e4057dbdSPoul-Henning Kamp flushchainbuf(struct buf *nbp) 2087e4057dbdSPoul-Henning Kamp { 20880cddd8f0SMatthew Dillon GIANT_REQUIRED; 2089e4057dbdSPoul-Henning Kamp if (nbp->b_bcount) { 2090e4057dbdSPoul-Henning Kamp nbp->b_bufsize = nbp->b_bcount; 2091e4057dbdSPoul-Henning Kamp if (nbp->b_iocmd == BIO_WRITE) 2092e4057dbdSPoul-Henning Kamp nbp->b_dirtyend = nbp->b_bcount; 2093e4057dbdSPoul-Henning Kamp BUF_KERNPROC(nbp); 2094e4057dbdSPoul-Henning Kamp BUF_STRATEGY(nbp); 2095e4057dbdSPoul-Henning Kamp } else { 2096e4057dbdSPoul-Henning Kamp bufdone(nbp); 2097e4057dbdSPoul-Henning Kamp } 2098e4057dbdSPoul-Henning Kamp } 2099e4057dbdSPoul-Henning Kamp 210023955314SAlfred Perlstein static void 21010b441832SPoul-Henning Kamp waitchainbuf(struct bio *bp, int limit, int done) 2102e4057dbdSPoul-Henning Kamp { 2103e4057dbdSPoul-Henning Kamp int s; 210423955314SAlfred Perlstein u_int *count; 2105e4057dbdSPoul-Henning Kamp 21060cddd8f0SMatthew Dillon GIANT_REQUIRED; 210723955314SAlfred Perlstein count = (u_int *)&(bp->bio_caller1); 2108e4057dbdSPoul-Henning Kamp s = splbio(); 21090b441832SPoul-Henning Kamp while (*count > limit) { 21100b441832SPoul-Henning Kamp bp->bio_flags |= BIO_FLAG1; 2111e4057dbdSPoul-Henning Kamp tsleep(bp, PRIBIO + 4, "bpchain", 0); 2112e4057dbdSPoul-Henning Kamp } 2113e4057dbdSPoul-Henning Kamp if (done) { 21140b441832SPoul-Henning Kamp if (bp->bio_resid != 0 && !(bp->bio_flags & BIO_ERROR)) { 21150b441832SPoul-Henning Kamp bp->bio_flags |= BIO_ERROR; 21160b441832SPoul-Henning Kamp bp->bio_error = EINVAL; 2117e4057dbdSPoul-Henning Kamp } 21180b441832SPoul-Henning Kamp biodone(bp); 2119e4057dbdSPoul-Henning Kamp } 2120e4057dbdSPoul-Henning Kamp splx(s); 2121e4057dbdSPoul-Henning Kamp } 2122e4057dbdSPoul-Henning Kamp 2123