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. 5e9c0cc15SPoul-Henning Kamp * Copyright (c) 1982, 1986, 1989, 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 66e9c0cc15SPoul-Henning Kamp * @(#)vm_swap.c 8.5 (Berkeley) 2/17/94 67df8bae1dSRodney W. Grimes */ 68df8bae1dSRodney W. Grimes 69874651b1SDavid E. O'Brien #include <sys/cdefs.h> 70874651b1SDavid E. O'Brien __FBSDID("$FreeBSD$"); 71874651b1SDavid E. O'Brien 72e9c0cc15SPoul-Henning Kamp #include "opt_mac.h" 73e9c0cc15SPoul-Henning Kamp #include "opt_swap.h" 74e9c0cc15SPoul-Henning Kamp #include "opt_vm.h" 75e9c0cc15SPoul-Henning Kamp 76df8bae1dSRodney W. Grimes #include <sys/param.h> 77df8bae1dSRodney W. Grimes #include <sys/systm.h> 78af647ddeSBruce Evans #include <sys/conf.h> 7964abb5a5SDavid Greenman #include <sys/kernel.h> 80df8bae1dSRodney W. Grimes #include <sys/proc.h> 819626b608SPoul-Henning Kamp #include <sys/bio.h> 82df8bae1dSRodney W. Grimes #include <sys/buf.h> 83e9c0cc15SPoul-Henning Kamp #include <sys/disk.h> 84e9c0cc15SPoul-Henning Kamp #include <sys/fcntl.h> 85e9c0cc15SPoul-Henning Kamp #include <sys/mount.h> 86e9c0cc15SPoul-Henning Kamp #include <sys/namei.h> 87df8bae1dSRodney W. Grimes #include <sys/vnode.h> 88e9c0cc15SPoul-Henning Kamp #include <sys/mac.h> 89df8bae1dSRodney W. Grimes #include <sys/malloc.h> 90327f4e83SMatthew Dillon #include <sys/sysctl.h> 91e9c0cc15SPoul-Henning Kamp #include <sys/sysproto.h> 921c7c3c6aSMatthew Dillon #include <sys/blist.h> 931c7c3c6aSMatthew Dillon #include <sys/lock.h> 940cddd8f0SMatthew Dillon #include <sys/sx.h> 95936524aaSMatthew Dillon #include <sys/vmmeter.h> 96df8bae1dSRodney W. Grimes 97df8bae1dSRodney W. Grimes #include <vm/vm.h> 9821cd6e62SSeigo Tanimura #include <vm/pmap.h> 9921cd6e62SSeigo Tanimura #include <vm/vm_map.h> 10021cd6e62SSeigo Tanimura #include <vm/vm_kern.h> 101efeaf95aSDavid Greenman #include <vm/vm_object.h> 102df8bae1dSRodney W. Grimes #include <vm/vm_page.h> 103efeaf95aSDavid Greenman #include <vm/vm_pager.h> 104df8bae1dSRodney W. Grimes #include <vm/vm_pageout.h> 105e9c0cc15SPoul-Henning Kamp #include <vm/vm_param.h> 106df8bae1dSRodney W. Grimes #include <vm/swap_pager.h> 107efeaf95aSDavid Greenman #include <vm/vm_extern.h> 108670d17b5SJeff Roberson #include <vm/uma.h> 109df8bae1dSRodney W. Grimes 110dee34ca4SPoul-Henning Kamp #include <geom/geom.h> 111dee34ca4SPoul-Henning Kamp 112ec38b344SPoul-Henning Kamp /* 113ec38b344SPoul-Henning Kamp * SWB_NPAGES must be a power of 2. It may be set to 1, 2, 4, 8, or 16 114ec38b344SPoul-Henning Kamp * pages per allocation. We recommend you stick with the default of 8. 115ec38b344SPoul-Henning Kamp * The 16-page limit is due to the radix code (kern/subr_blist.c). 116ec38b344SPoul-Henning Kamp */ 117ec38b344SPoul-Henning Kamp #ifndef MAX_PAGEOUT_CLUSTER 118ec38b344SPoul-Henning Kamp #define MAX_PAGEOUT_CLUSTER 16 119ec38b344SPoul-Henning Kamp #endif 120ec38b344SPoul-Henning Kamp 121ec38b344SPoul-Henning Kamp #if !defined(SWB_NPAGES) 122ec38b344SPoul-Henning Kamp #define SWB_NPAGES MAX_PAGEOUT_CLUSTER 123ec38b344SPoul-Henning Kamp #endif 124ec38b344SPoul-Henning Kamp 125ec38b344SPoul-Henning Kamp /* 126ec38b344SPoul-Henning Kamp * Piecemeal swap metadata structure. Swap is stored in a radix tree. 127ec38b344SPoul-Henning Kamp * 128ec38b344SPoul-Henning Kamp * If SWB_NPAGES is 8 and sizeof(char *) == sizeof(daddr_t), our radix 129ec38b344SPoul-Henning Kamp * is basically 8. Assuming PAGE_SIZE == 4096, one tree level represents 130ec38b344SPoul-Henning Kamp * 32K worth of data, two levels represent 256K, three levels represent 131ec38b344SPoul-Henning Kamp * 2 MBytes. This is acceptable. 132ec38b344SPoul-Henning Kamp * 133ec38b344SPoul-Henning Kamp * Overall memory utilization is about the same as the old swap structure. 134ec38b344SPoul-Henning Kamp */ 135ec38b344SPoul-Henning Kamp #define SWCORRECT(n) (sizeof(void *) * (n) / sizeof(daddr_t)) 136ec38b344SPoul-Henning Kamp #define SWAP_META_PAGES (SWB_NPAGES * 2) 137ec38b344SPoul-Henning Kamp #define SWAP_META_MASK (SWAP_META_PAGES - 1) 138ec38b344SPoul-Henning Kamp 1398f60c087SPoul-Henning Kamp typedef int32_t swblk_t; /* 1408f60c087SPoul-Henning Kamp * swap offset. This is the type used to 1418f60c087SPoul-Henning Kamp * address the "virtual swap device" and 1428f60c087SPoul-Henning Kamp * therefore the maximum swap space is 1438f60c087SPoul-Henning Kamp * 2^32 pages. 1448f60c087SPoul-Henning Kamp */ 145e9c0cc15SPoul-Henning Kamp 1464b03903aSPoul-Henning Kamp struct swdevt; 1474b03903aSPoul-Henning Kamp typedef void sw_strategy_t(struct buf *bp, struct swdevt *sw); 148dee34ca4SPoul-Henning Kamp typedef void sw_close_t(struct thread *td, struct swdevt *sw); 1494b03903aSPoul-Henning Kamp 1508d677ef9SPoul-Henning Kamp /* 1518d677ef9SPoul-Henning Kamp * Swap device table 1528d677ef9SPoul-Henning Kamp */ 1538d677ef9SPoul-Henning Kamp struct swdevt { 1548d677ef9SPoul-Henning Kamp int sw_flags; 1558d677ef9SPoul-Henning Kamp int sw_nblks; 1568d677ef9SPoul-Henning Kamp int sw_used; 15720da9c2eSPoul-Henning Kamp udev_t sw_udev; 158dee34ca4SPoul-Henning Kamp struct vnode *sw_vp; 15959efee01SPoul-Henning Kamp void *sw_id; 1608f60c087SPoul-Henning Kamp swblk_t sw_first; 1618f60c087SPoul-Henning Kamp swblk_t sw_end; 1628f60c087SPoul-Henning Kamp struct blist *sw_blist; 1638f60c087SPoul-Henning Kamp TAILQ_ENTRY(swdevt) sw_list; 1644b03903aSPoul-Henning Kamp sw_strategy_t *sw_strategy; 165dee34ca4SPoul-Henning Kamp sw_close_t *sw_close; 1668d677ef9SPoul-Henning Kamp }; 1678d677ef9SPoul-Henning Kamp 1688d677ef9SPoul-Henning Kamp #define SW_CLOSING 0x04 1698d677ef9SPoul-Henning Kamp 170e9c0cc15SPoul-Henning Kamp struct swblock { 171e9c0cc15SPoul-Henning Kamp struct swblock *swb_hnext; 172e9c0cc15SPoul-Henning Kamp vm_object_t swb_object; 173e9c0cc15SPoul-Henning Kamp vm_pindex_t swb_index; 174e9c0cc15SPoul-Henning Kamp int swb_count; 175e9c0cc15SPoul-Henning Kamp daddr_t swb_pages[SWAP_META_PAGES]; 176e9c0cc15SPoul-Henning Kamp }; 177e9c0cc15SPoul-Henning Kamp 17820da9c2eSPoul-Henning Kamp static struct mtx sw_dev_mtx; 1798f60c087SPoul-Henning Kamp static TAILQ_HEAD(, swdevt) swtailq = TAILQ_HEAD_INITIALIZER(swtailq); 1808f60c087SPoul-Henning Kamp static struct swdevt *swdevhd; /* Allocate from here next */ 1818f60c087SPoul-Henning Kamp static int nswapdev; /* Number of swap devices */ 1828f60c087SPoul-Henning Kamp int swap_pager_avail; 183e9c0cc15SPoul-Henning Kamp static int swdev_syscall_active = 0; /* serialize swap(on|off) */ 184e9c0cc15SPoul-Henning Kamp 1854b03903aSPoul-Henning Kamp static void swapdev_strategy(struct buf *, struct swdevt *sw); 186e9c0cc15SPoul-Henning Kamp 1871c7c3c6aSMatthew Dillon #define SWM_FREE 0x02 /* free, period */ 1881c7c3c6aSMatthew Dillon #define SWM_POP 0x04 /* pop out */ 18926f9a767SRodney W. Grimes 19020d3034fSMatthew Dillon int swap_pager_full; /* swap space exhaustion (task killing) */ 19120d3034fSMatthew Dillon static int swap_pager_almost_full; /* swap space exhaustion (w/ hysteresis)*/ 1921c7c3c6aSMatthew Dillon static int nsw_rcount; /* free read buffers */ 193327f4e83SMatthew Dillon static int nsw_wcount_sync; /* limit write buffers / synchronous */ 194327f4e83SMatthew Dillon static int nsw_wcount_async; /* limit write buffers / asynchronous */ 195327f4e83SMatthew Dillon static int nsw_wcount_async_max;/* assigned maximum */ 196327f4e83SMatthew Dillon static int nsw_cluster_max; /* maximum VOP I/O allowed */ 1971c7c3c6aSMatthew Dillon 1981c7c3c6aSMatthew Dillon static struct swblock **swhash; 1991c7c3c6aSMatthew Dillon static int swhash_mask; 200327f4e83SMatthew Dillon static int swap_async_max = 4; /* maximum in-progress async I/O's */ 2010cddd8f0SMatthew Dillon static struct sx sw_alloc_sx; 202327f4e83SMatthew Dillon 20324e7ab7cSPoul-Henning Kamp 204327f4e83SMatthew Dillon SYSCTL_INT(_vm, OID_AUTO, swap_async_max, 205327f4e83SMatthew Dillon CTLFLAG_RW, &swap_async_max, 0, "Maximum running async swap ops"); 2061c7c3c6aSMatthew Dillon 2071c7c3c6aSMatthew Dillon /* 2081c7c3c6aSMatthew Dillon * "named" and "unnamed" anon region objects. Try to reduce the overhead 2091c7c3c6aSMatthew Dillon * of searching a named list by hashing it just a little. 2101c7c3c6aSMatthew Dillon */ 2111c7c3c6aSMatthew Dillon 2121c7c3c6aSMatthew Dillon #define NOBJLISTS 8 2131c7c3c6aSMatthew Dillon 2141c7c3c6aSMatthew Dillon #define NOBJLIST(handle) \ 215af647ddeSBruce Evans (&swap_pager_object_list[((int)(intptr_t)handle >> 4) & (NOBJLISTS-1)]) 2161c7c3c6aSMatthew Dillon 217a9fa2c05SAlfred Perlstein static struct mtx sw_alloc_mtx; /* protect list manipulation */ 2181c7c3c6aSMatthew Dillon static struct pagerlst swap_pager_object_list[NOBJLISTS]; 219e9c0cc15SPoul-Henning Kamp static struct pagerlst swap_pager_un_object_list; 220e9c0cc15SPoul-Henning Kamp static uma_zone_t swap_zone; 2211c7c3c6aSMatthew Dillon 2221c7c3c6aSMatthew Dillon /* 2231c7c3c6aSMatthew Dillon * pagerops for OBJT_SWAP - "swap pager". Some ops are also global procedure 2241c7c3c6aSMatthew Dillon * calls hooked from other parts of the VM system and do not appear here. 2251c7c3c6aSMatthew Dillon * (see vm/swap_pager.h). 2261c7c3c6aSMatthew Dillon */ 227ff98689dSBruce Evans static vm_object_t 22811caded3SAlfred Perlstein swap_pager_alloc(void *handle, vm_ooffset_t size, 22911caded3SAlfred Perlstein vm_prot_t prot, vm_ooffset_t offset); 23011caded3SAlfred Perlstein static void swap_pager_dealloc(vm_object_t object); 23111caded3SAlfred Perlstein static int swap_pager_getpages(vm_object_t, vm_page_t *, int, int); 232751221fdSPoul-Henning Kamp static void swap_pager_putpages(vm_object_t, vm_page_t *, int, boolean_t, int *); 2335ea4972cSAlan Cox static boolean_t 2345ea4972cSAlan Cox swap_pager_haspage(vm_object_t object, vm_pindex_t pindex, int *before, int *after); 23511caded3SAlfred Perlstein static void swap_pager_init(void); 23611caded3SAlfred Perlstein static void swap_pager_unswapped(vm_page_t); 2378f60c087SPoul-Henning Kamp static void swap_pager_swapoff(struct swdevt *sp, int *sw_used); 238f708ef1bSPoul-Henning Kamp 239df8bae1dSRodney W. Grimes struct pagerops swappagerops = { 240e04e4bacSPoul-Henning Kamp .pgo_init = swap_pager_init, /* early system initialization of pager */ 241e04e4bacSPoul-Henning Kamp .pgo_alloc = swap_pager_alloc, /* allocate an OBJT_SWAP object */ 242e04e4bacSPoul-Henning Kamp .pgo_dealloc = swap_pager_dealloc, /* deallocate an OBJT_SWAP object */ 243e04e4bacSPoul-Henning Kamp .pgo_getpages = swap_pager_getpages, /* pagein */ 244e04e4bacSPoul-Henning Kamp .pgo_putpages = swap_pager_putpages, /* pageout */ 245e04e4bacSPoul-Henning Kamp .pgo_haspage = swap_pager_haspage, /* get backing store status for page */ 246e04e4bacSPoul-Henning Kamp .pgo_pageunswapped = swap_pager_unswapped, /* remove swap related to page */ 247df8bae1dSRodney W. Grimes }; 248df8bae1dSRodney W. Grimes 2491c7c3c6aSMatthew Dillon /* 2501c7c3c6aSMatthew Dillon * dmmax is in page-sized chunks with the new swap system. It was 25164bcb9c8SMatthew Dillon * dev-bsized chunks in the old. dmmax is always a power of 2. 2521c7c3c6aSMatthew Dillon * 2531c7c3c6aSMatthew Dillon * swap_*() routines are externally accessible. swp_*() routines are 2541c7c3c6aSMatthew Dillon * internal. 2551c7c3c6aSMatthew Dillon */ 256751221fdSPoul-Henning Kamp static int dmmax; 257e9c0cc15SPoul-Henning Kamp static int nswap_lowat = 128; /* in pages, swap_pager_almost_full warn */ 258e9c0cc15SPoul-Henning Kamp static int nswap_hiwat = 512; /* in pages, swap_pager_almost_full warn */ 25926f9a767SRodney W. Grimes 260cee313c4SRobert Watson SYSCTL_INT(_vm, OID_AUTO, dmmax, 261cee313c4SRobert Watson CTLFLAG_RD, &dmmax, 0, "Maximum size of a swap block"); 262cee313c4SRobert Watson 263a5edd34aSPoul-Henning Kamp static void swp_sizecheck(void); 26411caded3SAlfred Perlstein static void swp_pager_sync_iodone(struct buf *bp); 26511caded3SAlfred Perlstein static void swp_pager_async_iodone(struct buf *bp); 266dee34ca4SPoul-Henning Kamp static int swapongeom(struct thread *, struct vnode *); 26759efee01SPoul-Henning Kamp static int swaponvp(struct thread *, struct vnode *, u_long); 26824a1cce3SDavid Greenman 2691c7c3c6aSMatthew Dillon /* 2701c7c3c6aSMatthew Dillon * Swap bitmap functions 2711c7c3c6aSMatthew Dillon */ 272a5edd34aSPoul-Henning Kamp static void swp_pager_freeswapspace(daddr_t blk, int npages); 273a5edd34aSPoul-Henning Kamp static daddr_t swp_pager_getswapspace(int npages); 2741c7c3c6aSMatthew Dillon 2751c7c3c6aSMatthew Dillon /* 2761c7c3c6aSMatthew Dillon * Metadata functions 2771c7c3c6aSMatthew Dillon */ 278a5edd34aSPoul-Henning Kamp static struct swblock **swp_pager_hash(vm_object_t object, vm_pindex_t index); 27911caded3SAlfred Perlstein static void swp_pager_meta_build(vm_object_t, vm_pindex_t, daddr_t); 28011caded3SAlfred Perlstein static void swp_pager_meta_free(vm_object_t, vm_pindex_t, daddr_t); 28111caded3SAlfred Perlstein static void swp_pager_meta_free_all(vm_object_t); 28211caded3SAlfred Perlstein static daddr_t swp_pager_meta_ctl(vm_object_t, vm_pindex_t, int); 2831c7c3c6aSMatthew Dillon 2841c7c3c6aSMatthew Dillon /* 2851c7c3c6aSMatthew Dillon * SWP_SIZECHECK() - update swap_pager_full indication 2861c7c3c6aSMatthew Dillon * 28720d3034fSMatthew Dillon * update the swap_pager_almost_full indication and warn when we are 28820d3034fSMatthew Dillon * about to run out of swap space, using lowat/hiwat hysteresis. 28920d3034fSMatthew Dillon * 29020d3034fSMatthew Dillon * Clear swap_pager_full ( task killing ) indication when lowat is met. 2911c7c3c6aSMatthew Dillon * 2921c7c3c6aSMatthew Dillon * No restrictions on call 2931c7c3c6aSMatthew Dillon * This routine may not block. 2941c7c3c6aSMatthew Dillon * This routine must be called at splvm() 2951c7c3c6aSMatthew Dillon */ 296a5edd34aSPoul-Henning Kamp static void 2972f249180SPoul-Henning Kamp swp_sizecheck(void) 2980d94caffSDavid Greenman { 2990cddd8f0SMatthew Dillon GIANT_REQUIRED; 30023955314SAlfred Perlstein 3018f60c087SPoul-Henning Kamp if (swap_pager_avail < nswap_lowat) { 30220d3034fSMatthew Dillon if (swap_pager_almost_full == 0) { 3031af87c92SDavid Greenman printf("swap_pager: out of swap space\n"); 30420d3034fSMatthew Dillon swap_pager_almost_full = 1; 3052b0d37a4SMatthew Dillon } 30620d3034fSMatthew Dillon } else { 30726f9a767SRodney W. Grimes swap_pager_full = 0; 3088f60c087SPoul-Henning Kamp if (swap_pager_avail > nswap_hiwat) 30920d3034fSMatthew Dillon swap_pager_almost_full = 0; 31026f9a767SRodney W. Grimes } 3111c7c3c6aSMatthew Dillon } 3121c7c3c6aSMatthew Dillon 3131c7c3c6aSMatthew Dillon /* 314da5fd145SPeter Wemm * SWP_PAGER_HASH() - hash swap meta data 315da5fd145SPeter Wemm * 316a5edd34aSPoul-Henning Kamp * This is an helper function which hashes the swapblk given 317da5fd145SPeter Wemm * the object and page index. It returns a pointer to a pointer 318da5fd145SPeter Wemm * to the object, or a pointer to a NULL pointer if it could not 319da5fd145SPeter Wemm * find a swapblk. 320da5fd145SPeter Wemm * 321da5fd145SPeter Wemm * This routine must be called at splvm(). 322da5fd145SPeter Wemm */ 323a5edd34aSPoul-Henning Kamp static struct swblock ** 324da5fd145SPeter Wemm swp_pager_hash(vm_object_t object, vm_pindex_t index) 325da5fd145SPeter Wemm { 326da5fd145SPeter Wemm struct swblock **pswap; 327da5fd145SPeter Wemm struct swblock *swap; 328da5fd145SPeter Wemm 329da5fd145SPeter Wemm index &= ~(vm_pindex_t)SWAP_META_MASK; 330da5fd145SPeter Wemm pswap = &swhash[(index ^ (int)(intptr_t)object) & swhash_mask]; 331da5fd145SPeter Wemm while ((swap = *pswap) != NULL) { 332da5fd145SPeter Wemm if (swap->swb_object == object && 333da5fd145SPeter Wemm swap->swb_index == index 334da5fd145SPeter Wemm ) { 335da5fd145SPeter Wemm break; 336da5fd145SPeter Wemm } 337da5fd145SPeter Wemm pswap = &swap->swb_hnext; 338da5fd145SPeter Wemm } 339da5fd145SPeter Wemm return (pswap); 340da5fd145SPeter Wemm } 341da5fd145SPeter Wemm 342da5fd145SPeter Wemm /* 3431c7c3c6aSMatthew Dillon * SWAP_PAGER_INIT() - initialize the swap pager! 3441c7c3c6aSMatthew Dillon * 3451c7c3c6aSMatthew Dillon * Expected to be started from system init. NOTE: This code is run 3461c7c3c6aSMatthew Dillon * before much else so be careful what you depend on. Most of the VM 3471c7c3c6aSMatthew Dillon * system has yet to be initialized at this point. 3481c7c3c6aSMatthew Dillon */ 349f5a12711SPoul-Henning Kamp static void 3502f249180SPoul-Henning Kamp swap_pager_init(void) 351df8bae1dSRodney W. Grimes { 3521c7c3c6aSMatthew Dillon /* 3531c7c3c6aSMatthew Dillon * Initialize object lists 3541c7c3c6aSMatthew Dillon */ 3551c7c3c6aSMatthew Dillon int i; 3561c7c3c6aSMatthew Dillon 3571c7c3c6aSMatthew Dillon for (i = 0; i < NOBJLISTS; ++i) 3581c7c3c6aSMatthew Dillon TAILQ_INIT(&swap_pager_object_list[i]); 35924a1cce3SDavid Greenman TAILQ_INIT(&swap_pager_un_object_list); 3606008862bSJohn Baldwin mtx_init(&sw_alloc_mtx, "swap_pager list", NULL, MTX_DEF); 36120da9c2eSPoul-Henning Kamp mtx_init(&sw_dev_mtx, "swapdev", NULL, MTX_DEF); 362df8bae1dSRodney W. Grimes 363df8bae1dSRodney W. Grimes /* 3641c7c3c6aSMatthew Dillon * Device Stripe, in PAGE_SIZE'd blocks 365df8bae1dSRodney W. Grimes */ 3661c7c3c6aSMatthew Dillon dmmax = SWB_NPAGES * 2; 3671c7c3c6aSMatthew Dillon } 36826f9a767SRodney W. Grimes 369df8bae1dSRodney W. Grimes /* 3701c7c3c6aSMatthew Dillon * SWAP_PAGER_SWAP_INIT() - swap pager initialization from pageout process 3711c7c3c6aSMatthew Dillon * 3721c7c3c6aSMatthew Dillon * Expected to be started from pageout process once, prior to entering 3731c7c3c6aSMatthew Dillon * its main loop. 374df8bae1dSRodney W. Grimes */ 37524a1cce3SDavid Greenman void 3762f249180SPoul-Henning Kamp swap_pager_swap_init(void) 377df8bae1dSRodney W. Grimes { 37821cd6e62SSeigo Tanimura int n, n2; 3790d94caffSDavid Greenman 38026f9a767SRodney W. Grimes /* 3811c7c3c6aSMatthew Dillon * Number of in-transit swap bp operations. Don't 3821c7c3c6aSMatthew Dillon * exhaust the pbufs completely. Make sure we 3831c7c3c6aSMatthew Dillon * initialize workable values (0 will work for hysteresis 3841c7c3c6aSMatthew Dillon * but it isn't very efficient). 3851c7c3c6aSMatthew Dillon * 386327f4e83SMatthew Dillon * The nsw_cluster_max is constrained by the bp->b_pages[] 3871c7c3c6aSMatthew Dillon * array (MAXPHYS/PAGE_SIZE) and our locally defined 3881c7c3c6aSMatthew Dillon * MAX_PAGEOUT_CLUSTER. Also be aware that swap ops are 3891c7c3c6aSMatthew Dillon * constrained by the swap device interleave stripe size. 390327f4e83SMatthew Dillon * 391327f4e83SMatthew Dillon * Currently we hardwire nsw_wcount_async to 4. This limit is 392327f4e83SMatthew Dillon * designed to prevent other I/O from having high latencies due to 393327f4e83SMatthew Dillon * our pageout I/O. The value 4 works well for one or two active swap 394327f4e83SMatthew Dillon * devices but is probably a little low if you have more. Even so, 395327f4e83SMatthew Dillon * a higher value would probably generate only a limited improvement 396327f4e83SMatthew Dillon * with three or four active swap devices since the system does not 397327f4e83SMatthew Dillon * typically have to pageout at extreme bandwidths. We will want 398327f4e83SMatthew Dillon * at least 2 per swap devices, and 4 is a pretty good value if you 399327f4e83SMatthew Dillon * have one NFS swap device due to the command/ack latency over NFS. 400327f4e83SMatthew Dillon * So it all works out pretty well. 40126f9a767SRodney W. Grimes */ 402ad3cce20SMatthew Dillon nsw_cluster_max = min((MAXPHYS/PAGE_SIZE), MAX_PAGEOUT_CLUSTER); 403327f4e83SMatthew Dillon 4046d541bf1SJohn Baldwin mtx_lock(&pbuf_mtx); 4051c7c3c6aSMatthew Dillon nsw_rcount = (nswbuf + 1) / 2; 406327f4e83SMatthew Dillon nsw_wcount_sync = (nswbuf + 3) / 4; 407327f4e83SMatthew Dillon nsw_wcount_async = 4; 408327f4e83SMatthew Dillon nsw_wcount_async_max = nsw_wcount_async; 4096d541bf1SJohn Baldwin mtx_unlock(&pbuf_mtx); 41024a1cce3SDavid Greenman 4111c7c3c6aSMatthew Dillon /* 4121c7c3c6aSMatthew Dillon * Initialize our zone. Right now I'm just guessing on the number 4131c7c3c6aSMatthew Dillon * we need based on the number of pages in the system. Each swblock 4142f9e4e80SMatthew Dillon * can hold 16 pages, so this is probably overkill. This reservation 415ec61f55dSMatthew Dillon * is typically limited to around 32MB by default. 4161c7c3c6aSMatthew Dillon */ 417ec61f55dSMatthew Dillon n = cnt.v_page_count / 2; 4182f9e4e80SMatthew Dillon if (maxswzone && n > maxswzone / sizeof(struct swblock)) 4192f9e4e80SMatthew Dillon n = maxswzone / sizeof(struct swblock); 42021cd6e62SSeigo Tanimura n2 = n; 421670d17b5SJeff Roberson swap_zone = uma_zcreate("SWAPMETA", sizeof(struct swblock), NULL, NULL, 422670d17b5SJeff Roberson NULL, NULL, UMA_ALIGN_PTR, UMA_ZONE_NOFREE); 4238355f576SJeff Roberson do { 4248355f576SJeff Roberson if (uma_zone_set_obj(swap_zone, NULL, n)) 42561ce6eeeSAlfred Perlstein break; 42661ce6eeeSAlfred Perlstein /* 42761ce6eeeSAlfred Perlstein * if the allocation failed, try a zone two thirds the 42861ce6eeeSAlfred Perlstein * size of the previous attempt. 42961ce6eeeSAlfred Perlstein */ 43061ce6eeeSAlfred Perlstein n -= ((n + 2) / 3); 43161ce6eeeSAlfred Perlstein } while (n > 0); 43221cd6e62SSeigo Tanimura if (swap_zone == NULL) 433670d17b5SJeff Roberson panic("failed to create swap_zone."); 43421cd6e62SSeigo Tanimura if (n2 != n) 43561ce6eeeSAlfred Perlstein printf("Swap zone entries reduced from %d to %d.\n", n2, n); 43621cd6e62SSeigo Tanimura n2 = n; 43724a1cce3SDavid Greenman 4381c7c3c6aSMatthew Dillon /* 4391c7c3c6aSMatthew Dillon * Initialize our meta-data hash table. The swapper does not need to 4401c7c3c6aSMatthew Dillon * be quite as efficient as the VM system, so we do not use an 4411c7c3c6aSMatthew Dillon * oversized hash table. 4421c7c3c6aSMatthew Dillon * 4431c7c3c6aSMatthew Dillon * n: size of hash table, must be power of 2 4441c7c3c6aSMatthew Dillon * swhash_mask: hash table index mask 4451c7c3c6aSMatthew Dillon */ 44661ce6eeeSAlfred Perlstein for (n = 1; n < n2 / 8; n *= 2) 4471c7c3c6aSMatthew Dillon ; 448a163d034SWarner Losh swhash = malloc(sizeof(struct swblock *) * n, M_VMPGDATA, M_WAITOK | M_ZERO); 4491c7c3c6aSMatthew Dillon swhash_mask = n - 1; 45024a1cce3SDavid Greenman } 45124a1cce3SDavid Greenman 45224a1cce3SDavid Greenman /* 4531c7c3c6aSMatthew Dillon * SWAP_PAGER_ALLOC() - allocate a new OBJT_SWAP VM object and instantiate 4541c7c3c6aSMatthew Dillon * its metadata structures. 4551c7c3c6aSMatthew Dillon * 4561c7c3c6aSMatthew Dillon * This routine is called from the mmap and fork code to create a new 4571c7c3c6aSMatthew Dillon * OBJT_SWAP object. We do this by creating an OBJT_DEFAULT object 4581c7c3c6aSMatthew Dillon * and then converting it with swp_pager_meta_build(). 4591c7c3c6aSMatthew Dillon * 4601c7c3c6aSMatthew Dillon * This routine may block in vm_object_allocate() and create a named 4611c7c3c6aSMatthew Dillon * object lookup race, so we must interlock. We must also run at 4621c7c3c6aSMatthew Dillon * splvm() for the object lookup to handle races with interrupts, but 4631c7c3c6aSMatthew Dillon * we do not have to maintain splvm() in between the lookup and the 4641c7c3c6aSMatthew Dillon * add because (I believe) it is not possible to attempt to create 4651c7c3c6aSMatthew Dillon * a new swap object w/handle when a default object with that handle 4661c7c3c6aSMatthew Dillon * already exists. 46724c46d03SAlan Cox * 46824c46d03SAlan Cox * MPSAFE 46924a1cce3SDavid Greenman */ 470f5a12711SPoul-Henning Kamp static vm_object_t 4716cde7a16SDavid Greenman swap_pager_alloc(void *handle, vm_ooffset_t size, vm_prot_t prot, 472b9dcd593SBruce Evans vm_ooffset_t offset) 47324a1cce3SDavid Greenman { 47424a1cce3SDavid Greenman vm_object_t object; 47524a1cce3SDavid Greenman 47624c46d03SAlan Cox mtx_lock(&Giant); 47724a1cce3SDavid Greenman if (handle) { 4781c7c3c6aSMatthew Dillon /* 4791c7c3c6aSMatthew Dillon * Reference existing named region or allocate new one. There 4801c7c3c6aSMatthew Dillon * should not be a race here against swp_pager_meta_build() 4811c7c3c6aSMatthew Dillon * as called from vm_page_remove() in regards to the lookup 4821c7c3c6aSMatthew Dillon * of the handle. 4831c7c3c6aSMatthew Dillon */ 4840cddd8f0SMatthew Dillon sx_xlock(&sw_alloc_sx); 4851c7c3c6aSMatthew Dillon object = vm_pager_object_lookup(NOBJLIST(handle), handle); 4861c7c3c6aSMatthew Dillon 48724a1cce3SDavid Greenman if (object != NULL) { 48824a1cce3SDavid Greenman vm_object_reference(object); 48924a1cce3SDavid Greenman } else { 4901c7c3c6aSMatthew Dillon object = vm_object_allocate(OBJT_DEFAULT, 4916cde7a16SDavid Greenman OFF_TO_IDX(offset + PAGE_MASK + size)); 49224a1cce3SDavid Greenman object->handle = handle; 4931c7c3c6aSMatthew Dillon 494ee3dc7d7SAlan Cox VM_OBJECT_LOCK(object); 4954dcc5c2dSMatthew Dillon swp_pager_meta_build(object, 0, SWAPBLK_NONE); 496ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 49724a1cce3SDavid Greenman } 4980cddd8f0SMatthew Dillon sx_xunlock(&sw_alloc_sx); 49924a1cce3SDavid Greenman } else { 5001c7c3c6aSMatthew Dillon object = vm_object_allocate(OBJT_DEFAULT, 5016cde7a16SDavid Greenman OFF_TO_IDX(offset + PAGE_MASK + size)); 5021c7c3c6aSMatthew Dillon 503ee3dc7d7SAlan Cox VM_OBJECT_LOCK(object); 5044dcc5c2dSMatthew Dillon swp_pager_meta_build(object, 0, SWAPBLK_NONE); 505ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 50624a1cce3SDavid Greenman } 50724c46d03SAlan Cox mtx_unlock(&Giant); 50824a1cce3SDavid Greenman return (object); 509df8bae1dSRodney W. Grimes } 510df8bae1dSRodney W. Grimes 51126f9a767SRodney W. Grimes /* 5121c7c3c6aSMatthew Dillon * SWAP_PAGER_DEALLOC() - remove swap metadata from object 5131c7c3c6aSMatthew Dillon * 5141c7c3c6aSMatthew Dillon * The swap backing for the object is destroyed. The code is 5151c7c3c6aSMatthew Dillon * designed such that we can reinstantiate it later, but this 5161c7c3c6aSMatthew Dillon * routine is typically called only when the entire object is 5171c7c3c6aSMatthew Dillon * about to be destroyed. 5181c7c3c6aSMatthew Dillon * 5191c7c3c6aSMatthew Dillon * This routine may block, but no longer does. 5201c7c3c6aSMatthew Dillon * 5211c7c3c6aSMatthew Dillon * The object must be locked or unreferenceable. 52226f9a767SRodney W. Grimes */ 523df8bae1dSRodney W. Grimes static void 5242f249180SPoul-Henning Kamp swap_pager_dealloc(vm_object_t object) 52526f9a767SRodney W. Grimes { 5264dcc5c2dSMatthew Dillon int s; 5274dcc5c2dSMatthew Dillon 5280cddd8f0SMatthew Dillon GIANT_REQUIRED; 5290cddd8f0SMatthew Dillon 53026f9a767SRodney W. Grimes /* 5311c7c3c6aSMatthew Dillon * Remove from list right away so lookups will fail if we block for 5321c7c3c6aSMatthew Dillon * pageout completion. 53326f9a767SRodney W. Grimes */ 534a9fa2c05SAlfred Perlstein mtx_lock(&sw_alloc_mtx); 5351c7c3c6aSMatthew Dillon if (object->handle == NULL) { 5361c7c3c6aSMatthew Dillon TAILQ_REMOVE(&swap_pager_un_object_list, object, pager_object_list); 53724ea4a96SDavid Greenman } else { 5381c7c3c6aSMatthew Dillon TAILQ_REMOVE(NOBJLIST(object->handle), object, pager_object_list); 53926f9a767SRodney W. Grimes } 540a9fa2c05SAlfred Perlstein mtx_unlock(&sw_alloc_mtx); 5411c7c3c6aSMatthew Dillon 542658ad5ffSAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 5431c7c3c6aSMatthew Dillon vm_object_pip_wait(object, "swpdea"); 5441c7c3c6aSMatthew Dillon 5451c7c3c6aSMatthew Dillon /* 5461c7c3c6aSMatthew Dillon * Free all remaining metadata. We only bother to free it from 5471c7c3c6aSMatthew Dillon * the swap meta data. We do not attempt to free swapblk's still 5481c7c3c6aSMatthew Dillon * associated with vm_page_t's for this object. We do not care 5491c7c3c6aSMatthew Dillon * if paging is still in progress on some objects. 5501c7c3c6aSMatthew Dillon */ 5514dcc5c2dSMatthew Dillon s = splvm(); 5521c7c3c6aSMatthew Dillon swp_pager_meta_free_all(object); 5534dcc5c2dSMatthew Dillon splx(s); 5541c7c3c6aSMatthew Dillon } 5551c7c3c6aSMatthew Dillon 5561c7c3c6aSMatthew Dillon /************************************************************************ 5571c7c3c6aSMatthew Dillon * SWAP PAGER BITMAP ROUTINES * 5581c7c3c6aSMatthew Dillon ************************************************************************/ 5591c7c3c6aSMatthew Dillon 5601c7c3c6aSMatthew Dillon /* 5611c7c3c6aSMatthew Dillon * SWP_PAGER_GETSWAPSPACE() - allocate raw swap space 5621c7c3c6aSMatthew Dillon * 5631c7c3c6aSMatthew Dillon * Allocate swap for the requested number of pages. The starting 5641c7c3c6aSMatthew Dillon * swap block number (a page index) is returned or SWAPBLK_NONE 5651c7c3c6aSMatthew Dillon * if the allocation failed. 5661c7c3c6aSMatthew Dillon * 5671c7c3c6aSMatthew Dillon * Also has the side effect of advising that somebody made a mistake 5681c7c3c6aSMatthew Dillon * when they configured swap and didn't configure enough. 5691c7c3c6aSMatthew Dillon * 5701c7c3c6aSMatthew Dillon * Must be called at splvm() to avoid races with bitmap frees from 5711c7c3c6aSMatthew Dillon * vm_page_remove() aka swap_pager_page_removed(). 5721c7c3c6aSMatthew Dillon * 5731c7c3c6aSMatthew Dillon * This routine may not block 5741c7c3c6aSMatthew Dillon * This routine must be called at splvm(). 5758f60c087SPoul-Henning Kamp * 5768f60c087SPoul-Henning Kamp * We allocate in round-robin fashion from the configured devices. 5771c7c3c6aSMatthew Dillon */ 578a5edd34aSPoul-Henning Kamp static daddr_t 5792f249180SPoul-Henning Kamp swp_pager_getswapspace(int npages) 5801c7c3c6aSMatthew Dillon { 5811c7c3c6aSMatthew Dillon daddr_t blk; 5828f60c087SPoul-Henning Kamp struct swdevt *sp; 5838f60c087SPoul-Henning Kamp int i; 5841c7c3c6aSMatthew Dillon 5850cddd8f0SMatthew Dillon GIANT_REQUIRED; 5860cddd8f0SMatthew Dillon 5878f60c087SPoul-Henning Kamp blk = SWAPBLK_NONE; 58820da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 5898f60c087SPoul-Henning Kamp sp = swdevhd; 5908f60c087SPoul-Henning Kamp for (i = 0; i < nswapdev; i++) { 5918f60c087SPoul-Henning Kamp if (sp == NULL) 5928f60c087SPoul-Henning Kamp sp = TAILQ_FIRST(&swtailq); 5938f60c087SPoul-Henning Kamp if (!(sp->sw_flags & SW_CLOSING)) { 5948f60c087SPoul-Henning Kamp blk = blist_alloc(sp->sw_blist, npages); 5958f60c087SPoul-Henning Kamp if (blk != SWAPBLK_NONE) { 5968f60c087SPoul-Henning Kamp blk += sp->sw_first; 5978f60c087SPoul-Henning Kamp swap_pager_avail -= npages; 5988f60c087SPoul-Henning Kamp sp->sw_used += npages; 5998f60c087SPoul-Henning Kamp swp_sizecheck(); 6008f60c087SPoul-Henning Kamp swdevhd = TAILQ_NEXT(sp, sw_list); 60120da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 6028f60c087SPoul-Henning Kamp return(blk); 6038f60c087SPoul-Henning Kamp } 6048f60c087SPoul-Henning Kamp } 6058f60c087SPoul-Henning Kamp sp = TAILQ_NEXT(sp, sw_list); 6068f60c087SPoul-Henning Kamp } 60720da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 6082b0d37a4SMatthew Dillon if (swap_pager_full != 2) { 60920da9c2eSPoul-Henning Kamp printf("swap_pager_getswapspace(%d): failed\n", npages); 6102b0d37a4SMatthew Dillon swap_pager_full = 2; 61120d3034fSMatthew Dillon swap_pager_almost_full = 1; 6122b0d37a4SMatthew Dillon } 6138f60c087SPoul-Henning Kamp swdevhd = NULL; 6141c7c3c6aSMatthew Dillon return (blk); 61526f9a767SRodney W. Grimes } 61626f9a767SRodney W. Grimes 6178f60c087SPoul-Henning Kamp static struct swdevt * 6184b03903aSPoul-Henning Kamp swp_pager_find_dev(daddr_t blk) 6198f60c087SPoul-Henning Kamp { 6208f60c087SPoul-Henning Kamp struct swdevt *sp; 6218f60c087SPoul-Henning Kamp 62220da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 6238f60c087SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 62420da9c2eSPoul-Henning Kamp if (blk >= sp->sw_first && blk < sp->sw_end) { 62520da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 6268f60c087SPoul-Henning Kamp return (sp); 6278f60c087SPoul-Henning Kamp } 62820da9c2eSPoul-Henning Kamp } 62920da9c2eSPoul-Henning Kamp panic("Swapdev not found"); 6308f60c087SPoul-Henning Kamp } 6318f60c087SPoul-Henning Kamp 6324b03903aSPoul-Henning Kamp static void 6334b03903aSPoul-Henning Kamp swp_pager_strategy(struct buf *bp) 6344b03903aSPoul-Henning Kamp { 6354b03903aSPoul-Henning Kamp struct swdevt *sp; 6364b03903aSPoul-Henning Kamp 63720da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 6384b03903aSPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 6394b03903aSPoul-Henning Kamp if (bp->b_blkno >= sp->sw_first && bp->b_blkno < sp->sw_end) { 64020da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 6414b03903aSPoul-Henning Kamp sp->sw_strategy(bp, sp); 6424b03903aSPoul-Henning Kamp return; 6434b03903aSPoul-Henning Kamp } 6444b03903aSPoul-Henning Kamp } 64520da9c2eSPoul-Henning Kamp panic("Swapdev not found"); 6464b03903aSPoul-Henning Kamp } 6474b03903aSPoul-Henning Kamp 6488f60c087SPoul-Henning Kamp 64926f9a767SRodney W. Grimes /* 6501c7c3c6aSMatthew Dillon * SWP_PAGER_FREESWAPSPACE() - free raw swap space 6511c7c3c6aSMatthew Dillon * 6521c7c3c6aSMatthew Dillon * This routine returns the specified swap blocks back to the bitmap. 6531c7c3c6aSMatthew Dillon * 6541c7c3c6aSMatthew Dillon * Note: This routine may not block (it could in the old swap code), 6551c7c3c6aSMatthew Dillon * and through the use of the new blist routines it does not block. 6561c7c3c6aSMatthew Dillon * 6571c7c3c6aSMatthew Dillon * We must be called at splvm() to avoid races with bitmap frees from 6581c7c3c6aSMatthew Dillon * vm_page_remove() aka swap_pager_page_removed(). 6591c7c3c6aSMatthew Dillon * 6601c7c3c6aSMatthew Dillon * This routine may not block 6611c7c3c6aSMatthew Dillon * This routine must be called at splvm(). 66226f9a767SRodney W. Grimes */ 663a5edd34aSPoul-Henning Kamp static void 6648f60c087SPoul-Henning Kamp swp_pager_freeswapspace(daddr_t blk, int npages) 6650d94caffSDavid Greenman { 6668f60c087SPoul-Henning Kamp struct swdevt *sp; 66792da00bbSMatthew Dillon 6680cddd8f0SMatthew Dillon GIANT_REQUIRED; 66923955314SAlfred Perlstein 6704b03903aSPoul-Henning Kamp sp = swp_pager_find_dev(blk); 6718f60c087SPoul-Henning Kamp 67292da00bbSMatthew Dillon /* per-swap area stats */ 67392da00bbSMatthew Dillon sp->sw_used -= npages; 67492da00bbSMatthew Dillon 67592da00bbSMatthew Dillon /* 67692da00bbSMatthew Dillon * If we are attempting to stop swapping on this device, we 67792da00bbSMatthew Dillon * don't want to mark any blocks free lest they be reused. 67892da00bbSMatthew Dillon */ 67992da00bbSMatthew Dillon if (sp->sw_flags & SW_CLOSING) 68092da00bbSMatthew Dillon return; 68192da00bbSMatthew Dillon 6828f60c087SPoul-Henning Kamp blist_free(sp->sw_blist, blk - sp->sw_first, npages); 6838f60c087SPoul-Henning Kamp swap_pager_avail += npages; 6841c7c3c6aSMatthew Dillon swp_sizecheck(); 68526f9a767SRodney W. Grimes } 6861c7c3c6aSMatthew Dillon 68726f9a767SRodney W. Grimes /* 6881c7c3c6aSMatthew Dillon * SWAP_PAGER_FREESPACE() - frees swap blocks associated with a page 6891c7c3c6aSMatthew Dillon * range within an object. 6901c7c3c6aSMatthew Dillon * 6911c7c3c6aSMatthew Dillon * This is a globally accessible routine. 6921c7c3c6aSMatthew Dillon * 6931c7c3c6aSMatthew Dillon * This routine removes swapblk assignments from swap metadata. 6941c7c3c6aSMatthew Dillon * 6951c7c3c6aSMatthew Dillon * The external callers of this routine typically have already destroyed 6961c7c3c6aSMatthew Dillon * or renamed vm_page_t's associated with this range in the object so 6971c7c3c6aSMatthew Dillon * we should be ok. 6984dcc5c2dSMatthew Dillon * 6994dcc5c2dSMatthew Dillon * This routine may be called at any spl. We up our spl to splvm temporarily 7004dcc5c2dSMatthew Dillon * in order to perform the metadata removal. 70126f9a767SRodney W. Grimes */ 70226f9a767SRodney W. Grimes void 7032f249180SPoul-Henning Kamp swap_pager_freespace(vm_object_t object, vm_pindex_t start, vm_size_t size) 70426f9a767SRodney W. Grimes { 7054dcc5c2dSMatthew Dillon int s = splvm(); 70623955314SAlfred Perlstein 70719ba4c8eSAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 7081c7c3c6aSMatthew Dillon swp_pager_meta_free(object, start, size); 7094dcc5c2dSMatthew Dillon splx(s); 7104dcc5c2dSMatthew Dillon } 7114dcc5c2dSMatthew Dillon 7124dcc5c2dSMatthew Dillon /* 7134dcc5c2dSMatthew Dillon * SWAP_PAGER_RESERVE() - reserve swap blocks in object 7144dcc5c2dSMatthew Dillon * 7154dcc5c2dSMatthew Dillon * Assigns swap blocks to the specified range within the object. The 7164dcc5c2dSMatthew Dillon * swap blocks are not zerod. Any previous swap assignment is destroyed. 7174dcc5c2dSMatthew Dillon * 7184dcc5c2dSMatthew Dillon * Returns 0 on success, -1 on failure. 7194dcc5c2dSMatthew Dillon */ 7204dcc5c2dSMatthew Dillon int 7214dcc5c2dSMatthew Dillon swap_pager_reserve(vm_object_t object, vm_pindex_t start, vm_size_t size) 7224dcc5c2dSMatthew Dillon { 7234dcc5c2dSMatthew Dillon int s; 7244dcc5c2dSMatthew Dillon int n = 0; 7254dcc5c2dSMatthew Dillon daddr_t blk = SWAPBLK_NONE; 7264dcc5c2dSMatthew Dillon vm_pindex_t beg = start; /* save start index */ 7274dcc5c2dSMatthew Dillon 7284dcc5c2dSMatthew Dillon s = splvm(); 729ee3dc7d7SAlan Cox VM_OBJECT_LOCK(object); 7304dcc5c2dSMatthew Dillon while (size) { 7314dcc5c2dSMatthew Dillon if (n == 0) { 7324dcc5c2dSMatthew Dillon n = BLIST_MAX_ALLOC; 7334dcc5c2dSMatthew Dillon while ((blk = swp_pager_getswapspace(n)) == SWAPBLK_NONE) { 7344dcc5c2dSMatthew Dillon n >>= 1; 7354dcc5c2dSMatthew Dillon if (n == 0) { 7364dcc5c2dSMatthew Dillon swp_pager_meta_free(object, beg, start - beg); 737ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 7384dcc5c2dSMatthew Dillon splx(s); 7394dcc5c2dSMatthew Dillon return (-1); 7404dcc5c2dSMatthew Dillon } 7414dcc5c2dSMatthew Dillon } 7424dcc5c2dSMatthew Dillon } 7434dcc5c2dSMatthew Dillon swp_pager_meta_build(object, start, blk); 7444dcc5c2dSMatthew Dillon --size; 7454dcc5c2dSMatthew Dillon ++start; 7464dcc5c2dSMatthew Dillon ++blk; 7474dcc5c2dSMatthew Dillon --n; 7484dcc5c2dSMatthew Dillon } 7494dcc5c2dSMatthew Dillon swp_pager_meta_free(object, start, n); 750ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 7514dcc5c2dSMatthew Dillon splx(s); 7524dcc5c2dSMatthew Dillon return (0); 75326f9a767SRodney W. Grimes } 75426f9a767SRodney W. Grimes 7550a47b48bSJohn Dyson /* 7561c7c3c6aSMatthew Dillon * SWAP_PAGER_COPY() - copy blocks from source pager to destination pager 7571c7c3c6aSMatthew Dillon * and destroy the source. 7581c7c3c6aSMatthew Dillon * 7591c7c3c6aSMatthew Dillon * Copy any valid swapblks from the source to the destination. In 7601c7c3c6aSMatthew Dillon * cases where both the source and destination have a valid swapblk, 7611c7c3c6aSMatthew Dillon * we keep the destination's. 7621c7c3c6aSMatthew Dillon * 7631c7c3c6aSMatthew Dillon * This routine is allowed to block. It may block allocating metadata 7641c7c3c6aSMatthew Dillon * indirectly through swp_pager_meta_build() or if paging is still in 7651c7c3c6aSMatthew Dillon * progress on the source. 7661c7c3c6aSMatthew Dillon * 7674dcc5c2dSMatthew Dillon * This routine can be called at any spl 7684dcc5c2dSMatthew Dillon * 7691c7c3c6aSMatthew Dillon * XXX vm_page_collapse() kinda expects us not to block because we 7701c7c3c6aSMatthew Dillon * supposedly do not need to allocate memory, but for the moment we 7711c7c3c6aSMatthew Dillon * *may* have to get a little memory from the zone allocator, but 7721c7c3c6aSMatthew Dillon * it is taken from the interrupt memory. We should be ok. 7731c7c3c6aSMatthew Dillon * 7741c7c3c6aSMatthew Dillon * The source object contains no vm_page_t's (which is just as well) 7751c7c3c6aSMatthew Dillon * 7761c7c3c6aSMatthew Dillon * The source object is of type OBJT_SWAP. 7771c7c3c6aSMatthew Dillon * 7784dcc5c2dSMatthew Dillon * The source and destination objects must be locked or 7794dcc5c2dSMatthew Dillon * inaccessible (XXX are they ?) 78026f9a767SRodney W. Grimes */ 78126f9a767SRodney W. Grimes void 7822f249180SPoul-Henning Kamp swap_pager_copy(vm_object_t srcobject, vm_object_t dstobject, 7832f249180SPoul-Henning Kamp vm_pindex_t offset, int destroysource) 78426f9a767SRodney W. Grimes { 785a316d390SJohn Dyson vm_pindex_t i; 7864dcc5c2dSMatthew Dillon int s; 7874dcc5c2dSMatthew Dillon 7880cddd8f0SMatthew Dillon GIANT_REQUIRED; 7890cddd8f0SMatthew Dillon 7904dcc5c2dSMatthew Dillon s = splvm(); 79126f9a767SRodney W. Grimes /* 7921c7c3c6aSMatthew Dillon * If destroysource is set, we remove the source object from the 7931c7c3c6aSMatthew Dillon * swap_pager internal queue now. 79426f9a767SRodney W. Grimes */ 795cbd8ec09SJohn Dyson if (destroysource) { 796a9fa2c05SAlfred Perlstein mtx_lock(&sw_alloc_mtx); 79724a1cce3SDavid Greenman if (srcobject->handle == NULL) { 7981c7c3c6aSMatthew Dillon TAILQ_REMOVE( 7991c7c3c6aSMatthew Dillon &swap_pager_un_object_list, 8001c7c3c6aSMatthew Dillon srcobject, 8011c7c3c6aSMatthew Dillon pager_object_list 8021c7c3c6aSMatthew Dillon ); 80326f9a767SRodney W. Grimes } else { 8041c7c3c6aSMatthew Dillon TAILQ_REMOVE( 8051c7c3c6aSMatthew Dillon NOBJLIST(srcobject->handle), 8061c7c3c6aSMatthew Dillon srcobject, 8071c7c3c6aSMatthew Dillon pager_object_list 8081c7c3c6aSMatthew Dillon ); 80926f9a767SRodney W. Grimes } 810a9fa2c05SAlfred Perlstein mtx_unlock(&sw_alloc_mtx); 811cbd8ec09SJohn Dyson } 81226f9a767SRodney W. Grimes 8131c7c3c6aSMatthew Dillon /* 8141c7c3c6aSMatthew Dillon * transfer source to destination. 8151c7c3c6aSMatthew Dillon */ 8161c7c3c6aSMatthew Dillon for (i = 0; i < dstobject->size; ++i) { 8171c7c3c6aSMatthew Dillon daddr_t dstaddr; 8181c7c3c6aSMatthew Dillon 8191c7c3c6aSMatthew Dillon /* 8201c7c3c6aSMatthew Dillon * Locate (without changing) the swapblk on the destination, 8211c7c3c6aSMatthew Dillon * unless it is invalid in which case free it silently, or 8221c7c3c6aSMatthew Dillon * if the destination is a resident page, in which case the 8231c7c3c6aSMatthew Dillon * source is thrown away. 8241c7c3c6aSMatthew Dillon */ 8251c7c3c6aSMatthew Dillon dstaddr = swp_pager_meta_ctl(dstobject, i, 0); 8261c7c3c6aSMatthew Dillon 8271c7c3c6aSMatthew Dillon if (dstaddr == SWAPBLK_NONE) { 8281c7c3c6aSMatthew Dillon /* 8291c7c3c6aSMatthew Dillon * Destination has no swapblk and is not resident, 8301c7c3c6aSMatthew Dillon * copy source. 8311c7c3c6aSMatthew Dillon */ 8321c7c3c6aSMatthew Dillon daddr_t srcaddr; 8331c7c3c6aSMatthew Dillon 8341c7c3c6aSMatthew Dillon srcaddr = swp_pager_meta_ctl( 8351c7c3c6aSMatthew Dillon srcobject, 8361c7c3c6aSMatthew Dillon i + offset, 8371c7c3c6aSMatthew Dillon SWM_POP 8381c7c3c6aSMatthew Dillon ); 8391c7c3c6aSMatthew Dillon 840ee3dc7d7SAlan Cox if (srcaddr != SWAPBLK_NONE) { 841ee3dc7d7SAlan Cox VM_OBJECT_LOCK(dstobject); 8424dcc5c2dSMatthew Dillon swp_pager_meta_build(dstobject, i, srcaddr); 843ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(dstobject); 844ee3dc7d7SAlan Cox } 8451c7c3c6aSMatthew Dillon } else { 8461c7c3c6aSMatthew Dillon /* 8471c7c3c6aSMatthew Dillon * Destination has valid swapblk or it is represented 8481c7c3c6aSMatthew Dillon * by a resident page. We destroy the sourceblock. 8491c7c3c6aSMatthew Dillon */ 8501c7c3c6aSMatthew Dillon 8511c7c3c6aSMatthew Dillon swp_pager_meta_ctl(srcobject, i + offset, SWM_FREE); 8521c7c3c6aSMatthew Dillon } 85326f9a767SRodney W. Grimes } 85426f9a767SRodney W. Grimes 85526f9a767SRodney W. Grimes /* 8561c7c3c6aSMatthew Dillon * Free left over swap blocks in source. 8571c7c3c6aSMatthew Dillon * 8581c7c3c6aSMatthew Dillon * We have to revert the type to OBJT_DEFAULT so we do not accidently 8591c7c3c6aSMatthew Dillon * double-remove the object from the swap queues. 86026f9a767SRodney W. Grimes */ 861c0877f10SJohn Dyson if (destroysource) { 862ee3dc7d7SAlan Cox VM_OBJECT_LOCK(srcobject); 8631c7c3c6aSMatthew Dillon swp_pager_meta_free_all(srcobject); 864ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(srcobject); 8651c7c3c6aSMatthew Dillon /* 8661c7c3c6aSMatthew Dillon * Reverting the type is not necessary, the caller is going 8671c7c3c6aSMatthew Dillon * to destroy srcobject directly, but I'm doing it here 868956f3135SPhilippe Charnier * for consistency since we've removed the object from its 8691c7c3c6aSMatthew Dillon * queues. 8701c7c3c6aSMatthew Dillon */ 8711c7c3c6aSMatthew Dillon srcobject->type = OBJT_DEFAULT; 872c0877f10SJohn Dyson } 8734dcc5c2dSMatthew Dillon splx(s); 87426f9a767SRodney W. Grimes } 87526f9a767SRodney W. Grimes 876df8bae1dSRodney W. Grimes /* 8771c7c3c6aSMatthew Dillon * SWAP_PAGER_HASPAGE() - determine if we have good backing store for 8781c7c3c6aSMatthew Dillon * the requested page. 8791c7c3c6aSMatthew Dillon * 8801c7c3c6aSMatthew Dillon * We determine whether good backing store exists for the requested 8811c7c3c6aSMatthew Dillon * page and return TRUE if it does, FALSE if it doesn't. 8821c7c3c6aSMatthew Dillon * 8831c7c3c6aSMatthew Dillon * If TRUE, we also try to determine how much valid, contiguous backing 8841c7c3c6aSMatthew Dillon * store exists before and after the requested page within a reasonable 8851c7c3c6aSMatthew Dillon * distance. We do not try to restrict it to the swap device stripe 8861c7c3c6aSMatthew Dillon * (that is handled in getpages/putpages). It probably isn't worth 8871c7c3c6aSMatthew Dillon * doing here. 888df8bae1dSRodney W. Grimes */ 8895ea4972cSAlan Cox static boolean_t 8902f249180SPoul-Henning Kamp swap_pager_haspage(vm_object_t object, vm_pindex_t pindex, int *before, int *after) 89126f9a767SRodney W. Grimes { 8921c7c3c6aSMatthew Dillon daddr_t blk0; 89325db2c54SMatthew Dillon int s; 89426f9a767SRodney W. Grimes 895ee3dc7d7SAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 8961c7c3c6aSMatthew Dillon /* 8971c7c3c6aSMatthew Dillon * do we have good backing store at the requested index ? 8981c7c3c6aSMatthew Dillon */ 89925db2c54SMatthew Dillon s = splvm(); 9001c7c3c6aSMatthew Dillon blk0 = swp_pager_meta_ctl(object, pindex, 0); 9011c7c3c6aSMatthew Dillon 9024dcc5c2dSMatthew Dillon if (blk0 == SWAPBLK_NONE) { 90325db2c54SMatthew Dillon splx(s); 9041c7c3c6aSMatthew Dillon if (before) 90524a1cce3SDavid Greenman *before = 0; 9061c7c3c6aSMatthew Dillon if (after) 90724a1cce3SDavid Greenman *after = 0; 90826f9a767SRodney W. Grimes return (FALSE); 90926f9a767SRodney W. Grimes } 91026f9a767SRodney W. Grimes 91126f9a767SRodney W. Grimes /* 9121c7c3c6aSMatthew Dillon * find backwards-looking contiguous good backing store 913e47ed70bSJohn Dyson */ 9141c7c3c6aSMatthew Dillon if (before != NULL) { 91526f9a767SRodney W. Grimes int i; 9160d94caffSDavid Greenman 9171c7c3c6aSMatthew Dillon for (i = 1; i < (SWB_NPAGES/2); ++i) { 9181c7c3c6aSMatthew Dillon daddr_t blk; 9191c7c3c6aSMatthew Dillon 9201c7c3c6aSMatthew Dillon if (i > pindex) 9211c7c3c6aSMatthew Dillon break; 9221c7c3c6aSMatthew Dillon blk = swp_pager_meta_ctl(object, pindex - i, 0); 9231c7c3c6aSMatthew Dillon if (blk != blk0 - i) 9241c7c3c6aSMatthew Dillon break; 925ffc82b0aSJohn Dyson } 9261c7c3c6aSMatthew Dillon *before = (i - 1); 92726f9a767SRodney W. Grimes } 92826f9a767SRodney W. Grimes 92926f9a767SRodney W. Grimes /* 9301c7c3c6aSMatthew Dillon * find forward-looking contiguous good backing store 93126f9a767SRodney W. Grimes */ 9321c7c3c6aSMatthew Dillon if (after != NULL) { 9331c7c3c6aSMatthew Dillon int i; 9341c7c3c6aSMatthew Dillon 9351c7c3c6aSMatthew Dillon for (i = 1; i < (SWB_NPAGES/2); ++i) { 9361c7c3c6aSMatthew Dillon daddr_t blk; 9371c7c3c6aSMatthew Dillon 9381c7c3c6aSMatthew Dillon blk = swp_pager_meta_ctl(object, pindex + i, 0); 9391c7c3c6aSMatthew Dillon if (blk != blk0 + i) 9401c7c3c6aSMatthew Dillon break; 94126f9a767SRodney W. Grimes } 9421c7c3c6aSMatthew Dillon *after = (i - 1); 9431c7c3c6aSMatthew Dillon } 94425db2c54SMatthew Dillon splx(s); 9451c7c3c6aSMatthew Dillon return (TRUE); 9461c7c3c6aSMatthew Dillon } 9471c7c3c6aSMatthew Dillon 9481c7c3c6aSMatthew Dillon /* 9491c7c3c6aSMatthew Dillon * SWAP_PAGER_PAGE_UNSWAPPED() - remove swap backing store related to page 9501c7c3c6aSMatthew Dillon * 9511c7c3c6aSMatthew Dillon * This removes any associated swap backing store, whether valid or 9521c7c3c6aSMatthew Dillon * not, from the page. 9531c7c3c6aSMatthew Dillon * 9541c7c3c6aSMatthew Dillon * This routine is typically called when a page is made dirty, at 9551c7c3c6aSMatthew Dillon * which point any associated swap can be freed. MADV_FREE also 9561c7c3c6aSMatthew Dillon * calls us in a special-case situation 9571c7c3c6aSMatthew Dillon * 9581c7c3c6aSMatthew Dillon * NOTE!!! If the page is clean and the swap was valid, the caller 9591c7c3c6aSMatthew Dillon * should make the page dirty before calling this routine. This routine 9601c7c3c6aSMatthew Dillon * does NOT change the m->dirty status of the page. Also: MADV_FREE 9611c7c3c6aSMatthew Dillon * depends on it. 9621c7c3c6aSMatthew Dillon * 9631c7c3c6aSMatthew Dillon * This routine may not block 9644dcc5c2dSMatthew Dillon * This routine must be called at splvm() 9651c7c3c6aSMatthew Dillon */ 9661c7c3c6aSMatthew Dillon static void 9672f249180SPoul-Henning Kamp swap_pager_unswapped(vm_page_t m) 9681c7c3c6aSMatthew Dillon { 9692f249180SPoul-Henning Kamp 970ee3dc7d7SAlan Cox VM_OBJECT_LOCK_ASSERT(m->object, MA_OWNED); 9711c7c3c6aSMatthew Dillon swp_pager_meta_ctl(m->object, m->pindex, SWM_FREE); 9721c7c3c6aSMatthew Dillon } 9731c7c3c6aSMatthew Dillon 9741c7c3c6aSMatthew Dillon /* 9751c7c3c6aSMatthew Dillon * SWAP_PAGER_GETPAGES() - bring pages in from swap 9761c7c3c6aSMatthew Dillon * 9771c7c3c6aSMatthew Dillon * Attempt to retrieve (m, count) pages from backing store, but make 9781c7c3c6aSMatthew Dillon * sure we retrieve at least m[reqpage]. We try to load in as large 9791c7c3c6aSMatthew Dillon * a chunk surrounding m[reqpage] as is contiguous in swap and which 9801c7c3c6aSMatthew Dillon * belongs to the same object. 9811c7c3c6aSMatthew Dillon * 9821c7c3c6aSMatthew Dillon * The code is designed for asynchronous operation and 9831c7c3c6aSMatthew Dillon * immediate-notification of 'reqpage' but tends not to be 9841c7c3c6aSMatthew Dillon * used that way. Please do not optimize-out this algorithmic 9851c7c3c6aSMatthew Dillon * feature, I intend to improve on it in the future. 9861c7c3c6aSMatthew Dillon * 9871c7c3c6aSMatthew Dillon * The parent has a single vm_object_pip_add() reference prior to 9881c7c3c6aSMatthew Dillon * calling us and we should return with the same. 9891c7c3c6aSMatthew Dillon * 9901c7c3c6aSMatthew Dillon * The parent has BUSY'd the pages. We should return with 'm' 9911c7c3c6aSMatthew Dillon * left busy, but the others adjusted. 9921c7c3c6aSMatthew Dillon */ 993f708ef1bSPoul-Henning Kamp static int 9942f249180SPoul-Henning Kamp swap_pager_getpages(vm_object_t object, vm_page_t *m, int count, int reqpage) 995df8bae1dSRodney W. Grimes { 9961c7c3c6aSMatthew Dillon struct buf *bp; 9971c7c3c6aSMatthew Dillon vm_page_t mreq; 9981c7c3c6aSMatthew Dillon int s; 99926f9a767SRodney W. Grimes int i; 100026f9a767SRodney W. Grimes int j; 10011c7c3c6aSMatthew Dillon daddr_t blk; 10020d94caffSDavid Greenman 10031c7c3c6aSMatthew Dillon mreq = m[reqpage]; 10041c7c3c6aSMatthew Dillon 1005e04e4bacSPoul-Henning Kamp KASSERT(mreq->object == object, 1006e04e4bacSPoul-Henning Kamp ("swap_pager_getpages: object mismatch %p/%p", 1007e04e4bacSPoul-Henning Kamp object, mreq->object)); 1008e04e4bacSPoul-Henning Kamp 10091c7c3c6aSMatthew Dillon /* 10101c7c3c6aSMatthew Dillon * Calculate range to retrieve. The pages have already been assigned 1011751221fdSPoul-Henning Kamp * their swapblks. We require a *contiguous* range but we know it to 1012751221fdSPoul-Henning Kamp * not span devices. If we do not supply it, bad things 10134dcc5c2dSMatthew Dillon * happen. Note that blk, iblk & jblk can be SWAPBLK_NONE, but the 10144dcc5c2dSMatthew Dillon * loops are set up such that the case(s) are handled implicitly. 10154dcc5c2dSMatthew Dillon * 10164dcc5c2dSMatthew Dillon * The swp_*() calls must be made at splvm(). vm_page_free() does 10174dcc5c2dSMatthew Dillon * not need to be, but it will go a little faster if it is. 10181c7c3c6aSMatthew Dillon */ 10194dcc5c2dSMatthew Dillon s = splvm(); 10201c7c3c6aSMatthew Dillon blk = swp_pager_meta_ctl(mreq->object, mreq->pindex, 0); 10211c7c3c6aSMatthew Dillon 10221c7c3c6aSMatthew Dillon for (i = reqpage - 1; i >= 0; --i) { 10231c7c3c6aSMatthew Dillon daddr_t iblk; 10241c7c3c6aSMatthew Dillon 10251c7c3c6aSMatthew Dillon iblk = swp_pager_meta_ctl(m[i]->object, m[i]->pindex, 0); 10261c7c3c6aSMatthew Dillon if (blk != iblk + (reqpage - i)) 102726f9a767SRodney W. Grimes break; 102826f9a767SRodney W. Grimes } 10291c7c3c6aSMatthew Dillon ++i; 10301c7c3c6aSMatthew Dillon 10311c7c3c6aSMatthew Dillon for (j = reqpage + 1; j < count; ++j) { 10321c7c3c6aSMatthew Dillon daddr_t jblk; 10331c7c3c6aSMatthew Dillon 10341c7c3c6aSMatthew Dillon jblk = swp_pager_meta_ctl(m[j]->object, m[j]->pindex, 0); 10351c7c3c6aSMatthew Dillon if (blk != jblk - (j - reqpage)) 10361c7c3c6aSMatthew Dillon break; 10371c7c3c6aSMatthew Dillon } 10381c7c3c6aSMatthew Dillon 10391c7c3c6aSMatthew Dillon /* 10401c7c3c6aSMatthew Dillon * free pages outside our collection range. Note: we never free 10411c7c3c6aSMatthew Dillon * mreq, it must remain busy throughout. 10421c7c3c6aSMatthew Dillon */ 1043ab9abe5dSAlan Cox vm_page_lock_queues(); 10441c7c3c6aSMatthew Dillon { 10451c7c3c6aSMatthew Dillon int k; 10461c7c3c6aSMatthew Dillon 10474dcc5c2dSMatthew Dillon for (k = 0; k < i; ++k) 10484dcc5c2dSMatthew Dillon vm_page_free(m[k]); 10494dcc5c2dSMatthew Dillon for (k = j; k < count; ++k) 10501c7c3c6aSMatthew Dillon vm_page_free(m[k]); 10511c7c3c6aSMatthew Dillon } 1052ab9abe5dSAlan Cox vm_page_unlock_queues(); 10534dcc5c2dSMatthew Dillon splx(s); 10544dcc5c2dSMatthew Dillon 10551c7c3c6aSMatthew Dillon 10561c7c3c6aSMatthew Dillon /* 10574dcc5c2dSMatthew Dillon * Return VM_PAGER_FAIL if we have nothing to do. Return mreq 10584dcc5c2dSMatthew Dillon * still busy, but the others unbusied. 10591c7c3c6aSMatthew Dillon */ 10604dcc5c2dSMatthew Dillon if (blk == SWAPBLK_NONE) 106126f9a767SRodney W. Grimes return (VM_PAGER_FAIL); 1062df8bae1dSRodney W. Grimes 106316f62314SDavid Greenman /* 10648630c117SAlan Cox * Getpbuf() can sleep. 10658630c117SAlan Cox */ 10668630c117SAlan Cox VM_OBJECT_UNLOCK(object); 10678630c117SAlan Cox /* 106816f62314SDavid Greenman * Get a swap buffer header to perform the IO 106916f62314SDavid Greenman */ 10701c7c3c6aSMatthew Dillon bp = getpbuf(&nsw_rcount); 10715e04322aSPoul-Henning Kamp bp->b_flags |= B_PAGING; 107226f9a767SRodney W. Grimes 107316f62314SDavid Greenman /* 107416f62314SDavid Greenman * map our page(s) into kva for input 107516f62314SDavid Greenman */ 1076d68d828bSAlan Cox pmap_qenter((vm_offset_t)bp->b_data, m + i, j - i); 10771c7c3c6aSMatthew Dillon 107821144e3bSPoul-Henning Kamp bp->b_iocmd = BIO_READ; 10791c7c3c6aSMatthew Dillon bp->b_iodone = swp_pager_async_iodone; 1080fdcc1cc0SJohn Baldwin bp->b_rcred = crhold(thread0.td_ucred); 1081fdcc1cc0SJohn Baldwin bp->b_wcred = crhold(thread0.td_ucred); 10821c7c3c6aSMatthew Dillon bp->b_blkno = blk - (reqpage - i); 10831c7c3c6aSMatthew Dillon bp->b_bcount = PAGE_SIZE * (j - i); 10841c7c3c6aSMatthew Dillon bp->b_bufsize = PAGE_SIZE * (j - i); 10851c7c3c6aSMatthew Dillon bp->b_pager.pg_reqpage = reqpage - i; 10861c7c3c6aSMatthew Dillon 10878630c117SAlan Cox VM_OBJECT_LOCK(object); 1088b365ea9eSAlan Cox vm_page_lock_queues(); 10891c7c3c6aSMatthew Dillon { 10901c7c3c6aSMatthew Dillon int k; 10911c7c3c6aSMatthew Dillon 10921c7c3c6aSMatthew Dillon for (k = i; k < j; ++k) { 10931c7c3c6aSMatthew Dillon bp->b_pages[k - i] = m[k]; 10941c7c3c6aSMatthew Dillon vm_page_flag_set(m[k], PG_SWAPINPROG); 10951c7c3c6aSMatthew Dillon } 10961c7c3c6aSMatthew Dillon } 1097b365ea9eSAlan Cox vm_page_unlock_queues(); 10988630c117SAlan Cox VM_OBJECT_UNLOCK(object); 10991c7c3c6aSMatthew Dillon bp->b_npages = j - i; 110026f9a767SRodney W. Grimes 1101976e77fcSDavid Greenman cnt.v_swapin++; 11021c7c3c6aSMatthew Dillon cnt.v_swappgsin += bp->b_npages; 11031c7c3c6aSMatthew Dillon 1104df8bae1dSRodney W. Grimes /* 11051c7c3c6aSMatthew Dillon * We still hold the lock on mreq, and our automatic completion routine 11061c7c3c6aSMatthew Dillon * does not remove it. 1107df8bae1dSRodney W. Grimes */ 1108d68d828bSAlan Cox VM_OBJECT_LOCK(mreq->object); 11091c7c3c6aSMatthew Dillon vm_object_pip_add(mreq->object, bp->b_npages); 1110d68d828bSAlan Cox VM_OBJECT_UNLOCK(mreq->object); 11111c7c3c6aSMatthew Dillon 11121c7c3c6aSMatthew Dillon /* 11131c7c3c6aSMatthew Dillon * perform the I/O. NOTE!!! bp cannot be considered valid after 11141c7c3c6aSMatthew Dillon * this point because we automatically release it on completion. 11151c7c3c6aSMatthew Dillon * Instead, we look at the one page we are interested in which we 11161c7c3c6aSMatthew Dillon * still hold a lock on even through the I/O completion. 11171c7c3c6aSMatthew Dillon * 11181c7c3c6aSMatthew Dillon * The other pages in our m[] array are also released on completion, 11191c7c3c6aSMatthew Dillon * so we cannot assume they are valid anymore either. 11201c7c3c6aSMatthew Dillon * 1121c37a77eeSPoul-Henning Kamp * NOTE: b_blkno is destroyed by the call to swapdev_strategy 11221c7c3c6aSMatthew Dillon */ 1123b890cb2cSPeter Wemm BUF_KERNPROC(bp); 11244b03903aSPoul-Henning Kamp swp_pager_strategy(bp); 112526f9a767SRodney W. Grimes 112626f9a767SRodney W. Grimes /* 11271c7c3c6aSMatthew Dillon * wait for the page we want to complete. PG_SWAPINPROG is always 11281c7c3c6aSMatthew Dillon * cleared on completion. If an I/O error occurs, SWAPBLK_NONE 11291c7c3c6aSMatthew Dillon * is set in the meta-data. 113026f9a767SRodney W. Grimes */ 11311c7c3c6aSMatthew Dillon s = splvm(); 1132b365ea9eSAlan Cox vm_page_lock_queues(); 11331c7c3c6aSMatthew Dillon while ((mreq->flags & PG_SWAPINPROG) != 0) { 11341c7c3c6aSMatthew Dillon vm_page_flag_set(mreq, PG_WANTED | PG_REFERENCED); 11351c7c3c6aSMatthew Dillon cnt.v_intrans++; 1136b365ea9eSAlan Cox if (msleep(mreq, &vm_page_queue_mtx, PSWP, "swread", hz*20)) { 1137ac1e407bSBruce Evans printf( 11381c7c3c6aSMatthew Dillon "swap_pager: indefinite wait buffer: device:" 1139af647ddeSBruce Evans " %s, blkno: %ld, size: %ld\n", 1140af647ddeSBruce Evans devtoname(bp->b_dev), (long)bp->b_blkno, 1141af647ddeSBruce Evans bp->b_bcount 11421c7c3c6aSMatthew Dillon ); 11431c7c3c6aSMatthew Dillon } 11441b119d9dSDavid Greenman } 1145b365ea9eSAlan Cox vm_page_unlock_queues(); 1146df8bae1dSRodney W. Grimes splx(s); 114726f9a767SRodney W. Grimes 11488630c117SAlan Cox VM_OBJECT_LOCK(mreq->object); 114926f9a767SRodney W. Grimes /* 1150a1287949SEivind Eklund * mreq is left busied after completion, but all the other pages 11511c7c3c6aSMatthew Dillon * are freed. If we had an unrecoverable read error the page will 11521c7c3c6aSMatthew Dillon * not be valid. 115326f9a767SRodney W. Grimes */ 11541c7c3c6aSMatthew Dillon if (mreq->valid != VM_PAGE_BITS_ALL) { 11551c7c3c6aSMatthew Dillon return (VM_PAGER_ERROR); 115626f9a767SRodney W. Grimes } else { 11571c7c3c6aSMatthew Dillon return (VM_PAGER_OK); 115826f9a767SRodney W. Grimes } 11591c7c3c6aSMatthew Dillon 11601c7c3c6aSMatthew Dillon /* 11611c7c3c6aSMatthew Dillon * A final note: in a low swap situation, we cannot deallocate swap 11621c7c3c6aSMatthew Dillon * and mark a page dirty here because the caller is likely to mark 11631c7c3c6aSMatthew Dillon * the page clean when we return, causing the page to possibly revert 11641c7c3c6aSMatthew Dillon * to all-zero's later. 11651c7c3c6aSMatthew Dillon */ 1166df8bae1dSRodney W. Grimes } 1167df8bae1dSRodney W. Grimes 11681c7c3c6aSMatthew Dillon /* 11691c7c3c6aSMatthew Dillon * swap_pager_putpages: 11701c7c3c6aSMatthew Dillon * 11711c7c3c6aSMatthew Dillon * Assign swap (if necessary) and initiate I/O on the specified pages. 11721c7c3c6aSMatthew Dillon * 11731c7c3c6aSMatthew Dillon * We support both OBJT_DEFAULT and OBJT_SWAP objects. DEFAULT objects 11741c7c3c6aSMatthew Dillon * are automatically converted to SWAP objects. 11751c7c3c6aSMatthew Dillon * 1176ea3aecf5SPeter Wemm * In a low memory situation we may block in VOP_STRATEGY(), but the new 11771c7c3c6aSMatthew Dillon * vm_page reservation system coupled with properly written VFS devices 11781c7c3c6aSMatthew Dillon * should ensure that no low-memory deadlock occurs. This is an area 11791c7c3c6aSMatthew Dillon * which needs work. 11801c7c3c6aSMatthew Dillon * 11811c7c3c6aSMatthew Dillon * The parent has N vm_object_pip_add() references prior to 11821c7c3c6aSMatthew Dillon * calling us and will remove references for rtvals[] that are 11831c7c3c6aSMatthew Dillon * not set to VM_PAGER_PEND. We need to remove the rest on I/O 11841c7c3c6aSMatthew Dillon * completion. 11851c7c3c6aSMatthew Dillon * 11861c7c3c6aSMatthew Dillon * The parent has soft-busy'd the pages it passes us and will unbusy 11871c7c3c6aSMatthew Dillon * those whos rtvals[] entry is not set to VM_PAGER_PEND on return. 11881c7c3c6aSMatthew Dillon * We need to unbusy the rest on I/O completion. 11891c7c3c6aSMatthew Dillon */ 1190e4542174SMatthew Dillon void 11912f249180SPoul-Henning Kamp swap_pager_putpages(vm_object_t object, vm_page_t *m, int count, 11922f249180SPoul-Henning Kamp boolean_t sync, int *rtvals) 1193df8bae1dSRodney W. Grimes { 11941c7c3c6aSMatthew Dillon int i; 11951c7c3c6aSMatthew Dillon int n = 0; 1196df8bae1dSRodney W. Grimes 11970cddd8f0SMatthew Dillon GIANT_REQUIRED; 11981c7c3c6aSMatthew Dillon if (count && m[0]->object != object) { 11991c7c3c6aSMatthew Dillon panic("swap_pager_getpages: object mismatch %p/%p", 12001c7c3c6aSMatthew Dillon object, 12011c7c3c6aSMatthew Dillon m[0]->object 12021c7c3c6aSMatthew Dillon ); 12031c7c3c6aSMatthew Dillon } 1204ee3dc7d7SAlan Cox 12051c7c3c6aSMatthew Dillon /* 12061c7c3c6aSMatthew Dillon * Step 1 12071c7c3c6aSMatthew Dillon * 12081c7c3c6aSMatthew Dillon * Turn object into OBJT_SWAP 12091c7c3c6aSMatthew Dillon * check for bogus sysops 12101c7c3c6aSMatthew Dillon * force sync if not pageout process 12111c7c3c6aSMatthew Dillon */ 12124dcc5c2dSMatthew Dillon if (object->type != OBJT_SWAP) 12134dcc5c2dSMatthew Dillon swp_pager_meta_build(object, 0, SWAPBLK_NONE); 1214ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 1215e47ed70bSJohn Dyson 1216e47ed70bSJohn Dyson if (curproc != pageproc) 1217e47ed70bSJohn Dyson sync = TRUE; 121826f9a767SRodney W. Grimes 12191c7c3c6aSMatthew Dillon /* 12201c7c3c6aSMatthew Dillon * Step 2 12211c7c3c6aSMatthew Dillon * 1222ad3cce20SMatthew Dillon * Update nsw parameters from swap_async_max sysctl values. 1223ad3cce20SMatthew Dillon * Do not let the sysop crash the machine with bogus numbers. 1224327f4e83SMatthew Dillon */ 12256d541bf1SJohn Baldwin mtx_lock(&pbuf_mtx); 1226327f4e83SMatthew Dillon if (swap_async_max != nsw_wcount_async_max) { 1227327f4e83SMatthew Dillon int n; 1228327f4e83SMatthew Dillon int s; 1229327f4e83SMatthew Dillon 1230327f4e83SMatthew Dillon /* 1231327f4e83SMatthew Dillon * limit range 1232327f4e83SMatthew Dillon */ 1233327f4e83SMatthew Dillon if ((n = swap_async_max) > nswbuf / 2) 1234327f4e83SMatthew Dillon n = nswbuf / 2; 1235327f4e83SMatthew Dillon if (n < 1) 1236327f4e83SMatthew Dillon n = 1; 1237327f4e83SMatthew Dillon swap_async_max = n; 1238327f4e83SMatthew Dillon 1239327f4e83SMatthew Dillon /* 1240327f4e83SMatthew Dillon * Adjust difference ( if possible ). If the current async 1241327f4e83SMatthew Dillon * count is too low, we may not be able to make the adjustment 1242327f4e83SMatthew Dillon * at this time. 1243327f4e83SMatthew Dillon */ 1244327f4e83SMatthew Dillon s = splvm(); 1245327f4e83SMatthew Dillon n -= nsw_wcount_async_max; 1246327f4e83SMatthew Dillon if (nsw_wcount_async + n >= 0) { 1247327f4e83SMatthew Dillon nsw_wcount_async += n; 1248327f4e83SMatthew Dillon nsw_wcount_async_max += n; 1249327f4e83SMatthew Dillon wakeup(&nsw_wcount_async); 1250327f4e83SMatthew Dillon } 1251327f4e83SMatthew Dillon splx(s); 1252327f4e83SMatthew Dillon } 12536d541bf1SJohn Baldwin mtx_unlock(&pbuf_mtx); 1254327f4e83SMatthew Dillon 1255327f4e83SMatthew Dillon /* 1256327f4e83SMatthew Dillon * Step 3 1257327f4e83SMatthew Dillon * 12581c7c3c6aSMatthew Dillon * Assign swap blocks and issue I/O. We reallocate swap on the fly. 12591c7c3c6aSMatthew Dillon * The page is left dirty until the pageout operation completes 12601c7c3c6aSMatthew Dillon * successfully. 12611c7c3c6aSMatthew Dillon */ 12621c7c3c6aSMatthew Dillon for (i = 0; i < count; i += n) { 12631c7c3c6aSMatthew Dillon int s; 12641c7c3c6aSMatthew Dillon int j; 12651c7c3c6aSMatthew Dillon struct buf *bp; 1266a316d390SJohn Dyson daddr_t blk; 126726f9a767SRodney W. Grimes 1268df8bae1dSRodney W. Grimes /* 12691c7c3c6aSMatthew Dillon * Maximum I/O size is limited by a number of factors. 1270df8bae1dSRodney W. Grimes */ 12711c7c3c6aSMatthew Dillon n = min(BLIST_MAX_ALLOC, count - i); 1272327f4e83SMatthew Dillon n = min(n, nsw_cluster_max); 12731c7c3c6aSMatthew Dillon 12744dcc5c2dSMatthew Dillon s = splvm(); 12754dcc5c2dSMatthew Dillon 127626f9a767SRodney W. Grimes /* 12771c7c3c6aSMatthew Dillon * Get biggest block of swap we can. If we fail, fall 12781c7c3c6aSMatthew Dillon * back and try to allocate a smaller block. Don't go 12791c7c3c6aSMatthew Dillon * overboard trying to allocate space if it would overly 12801c7c3c6aSMatthew Dillon * fragment swap. 128126f9a767SRodney W. Grimes */ 12821c7c3c6aSMatthew Dillon while ( 12831c7c3c6aSMatthew Dillon (blk = swp_pager_getswapspace(n)) == SWAPBLK_NONE && 12841c7c3c6aSMatthew Dillon n > 4 12851c7c3c6aSMatthew Dillon ) { 12861c7c3c6aSMatthew Dillon n >>= 1; 128726f9a767SRodney W. Grimes } 12881c7c3c6aSMatthew Dillon if (blk == SWAPBLK_NONE) { 12894dcc5c2dSMatthew Dillon for (j = 0; j < n; ++j) 12901c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_FAIL; 12914dcc5c2dSMatthew Dillon splx(s); 12921c7c3c6aSMatthew Dillon continue; 129326f9a767SRodney W. Grimes } 129426f9a767SRodney W. Grimes 129526f9a767SRodney W. Grimes /* 12961c7c3c6aSMatthew Dillon * All I/O parameters have been satisfied, build the I/O 12971c7c3c6aSMatthew Dillon * request and assign the swap space. 129826f9a767SRodney W. Grimes */ 1299327f4e83SMatthew Dillon if (sync == TRUE) { 1300327f4e83SMatthew Dillon bp = getpbuf(&nsw_wcount_sync); 1301327f4e83SMatthew Dillon } else { 1302327f4e83SMatthew Dillon bp = getpbuf(&nsw_wcount_async); 130321144e3bSPoul-Henning Kamp bp->b_flags = B_ASYNC; 1304327f4e83SMatthew Dillon } 13055e04322aSPoul-Henning Kamp bp->b_flags |= B_PAGING; 1306912e4ae9SPoul-Henning Kamp bp->b_iocmd = BIO_WRITE; 130726f9a767SRodney W. Grimes 13081c7c3c6aSMatthew Dillon pmap_qenter((vm_offset_t)bp->b_data, &m[i], n); 13091c7c3c6aSMatthew Dillon 1310fdcc1cc0SJohn Baldwin bp->b_rcred = crhold(thread0.td_ucred); 1311fdcc1cc0SJohn Baldwin bp->b_wcred = crhold(thread0.td_ucred); 13121c7c3c6aSMatthew Dillon bp->b_bcount = PAGE_SIZE * n; 13131c7c3c6aSMatthew Dillon bp->b_bufsize = PAGE_SIZE * n; 13141c7c3c6aSMatthew Dillon bp->b_blkno = blk; 1315e47ed70bSJohn Dyson 1316ee3dc7d7SAlan Cox VM_OBJECT_LOCK(object); 13171c7c3c6aSMatthew Dillon for (j = 0; j < n; ++j) { 13181c7c3c6aSMatthew Dillon vm_page_t mreq = m[i+j]; 13191c7c3c6aSMatthew Dillon 13201c7c3c6aSMatthew Dillon swp_pager_meta_build( 13211c7c3c6aSMatthew Dillon mreq->object, 13221c7c3c6aSMatthew Dillon mreq->pindex, 13234dcc5c2dSMatthew Dillon blk + j 13241c7c3c6aSMatthew Dillon ); 13257dbf82dcSMatthew Dillon vm_page_dirty(mreq); 13261c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_OK; 13271c7c3c6aSMatthew Dillon 1328b365ea9eSAlan Cox vm_page_lock_queues(); 13291c7c3c6aSMatthew Dillon vm_page_flag_set(mreq, PG_SWAPINPROG); 1330b365ea9eSAlan Cox vm_page_unlock_queues(); 13311c7c3c6aSMatthew Dillon bp->b_pages[j] = mreq; 13321c7c3c6aSMatthew Dillon } 1333ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 13341c7c3c6aSMatthew Dillon bp->b_npages = n; 1335a5296b05SJulian Elischer /* 1336a5296b05SJulian Elischer * Must set dirty range for NFS to work. 1337a5296b05SJulian Elischer */ 1338a5296b05SJulian Elischer bp->b_dirtyoff = 0; 1339a5296b05SJulian Elischer bp->b_dirtyend = bp->b_bcount; 13401c7c3c6aSMatthew Dillon 13411c7c3c6aSMatthew Dillon cnt.v_swapout++; 13421c7c3c6aSMatthew Dillon cnt.v_swappgsout += bp->b_npages; 134326f9a767SRodney W. Grimes 13444dcc5c2dSMatthew Dillon splx(s); 13454dcc5c2dSMatthew Dillon 134626f9a767SRodney W. Grimes /* 13471c7c3c6aSMatthew Dillon * asynchronous 13481c7c3c6aSMatthew Dillon * 1349c37a77eeSPoul-Henning Kamp * NOTE: b_blkno is destroyed by the call to swapdev_strategy 135026f9a767SRodney W. Grimes */ 13511c7c3c6aSMatthew Dillon if (sync == FALSE) { 13521c7c3c6aSMatthew Dillon bp->b_iodone = swp_pager_async_iodone; 135367812eacSKirk McKusick BUF_KERNPROC(bp); 13544b03903aSPoul-Henning Kamp swp_pager_strategy(bp); 13551c7c3c6aSMatthew Dillon 13561c7c3c6aSMatthew Dillon for (j = 0; j < n; ++j) 13571c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_PEND; 135823955314SAlfred Perlstein /* restart outter loop */ 13591c7c3c6aSMatthew Dillon continue; 136026f9a767SRodney W. Grimes } 1361e47ed70bSJohn Dyson 136226f9a767SRodney W. Grimes /* 13631c7c3c6aSMatthew Dillon * synchronous 13641c7c3c6aSMatthew Dillon * 1365c37a77eeSPoul-Henning Kamp * NOTE: b_blkno is destroyed by the call to swapdev_strategy 13661c7c3c6aSMatthew Dillon */ 13671c7c3c6aSMatthew Dillon bp->b_iodone = swp_pager_sync_iodone; 13684b03903aSPoul-Henning Kamp swp_pager_strategy(bp); 13691c7c3c6aSMatthew Dillon 13701c7c3c6aSMatthew Dillon /* 13711c7c3c6aSMatthew Dillon * Wait for the sync I/O to complete, then update rtvals. 13721c7c3c6aSMatthew Dillon * We just set the rtvals[] to VM_PAGER_PEND so we can call 13731c7c3c6aSMatthew Dillon * our async completion routine at the end, thus avoiding a 13741c7c3c6aSMatthew Dillon * double-free. 137526f9a767SRodney W. Grimes */ 13764dcc5c2dSMatthew Dillon s = splbio(); 137726f9a767SRodney W. Grimes while ((bp->b_flags & B_DONE) == 0) { 137824a1cce3SDavid Greenman tsleep(bp, PVM, "swwrt", 0); 137926f9a767SRodney W. Grimes } 13801c7c3c6aSMatthew Dillon for (j = 0; j < n; ++j) 13811c7c3c6aSMatthew Dillon rtvals[i+j] = VM_PAGER_PEND; 13821c7c3c6aSMatthew Dillon /* 13831c7c3c6aSMatthew Dillon * Now that we are through with the bp, we can call the 13841c7c3c6aSMatthew Dillon * normal async completion, which frees everything up. 13851c7c3c6aSMatthew Dillon */ 13861c7c3c6aSMatthew Dillon swp_pager_async_iodone(bp); 138726f9a767SRodney W. Grimes splx(s); 13881c7c3c6aSMatthew Dillon } 13892e3b314dSAlan Cox VM_OBJECT_LOCK(object); 13901c7c3c6aSMatthew Dillon } 13911c7c3c6aSMatthew Dillon 13921c7c3c6aSMatthew Dillon /* 13931c7c3c6aSMatthew Dillon * swap_pager_sync_iodone: 13941c7c3c6aSMatthew Dillon * 13951c7c3c6aSMatthew Dillon * Completion routine for synchronous reads and writes from/to swap. 13961c7c3c6aSMatthew Dillon * We just mark the bp is complete and wake up anyone waiting on it. 13971c7c3c6aSMatthew Dillon * 13984dcc5c2dSMatthew Dillon * This routine may not block. This routine is called at splbio() or better. 13991c7c3c6aSMatthew Dillon */ 14001c7c3c6aSMatthew Dillon static void 14012f249180SPoul-Henning Kamp swp_pager_sync_iodone(struct buf *bp) 14021c7c3c6aSMatthew Dillon { 14031c7c3c6aSMatthew Dillon bp->b_flags |= B_DONE; 14041c7c3c6aSMatthew Dillon bp->b_flags &= ~B_ASYNC; 14051c7c3c6aSMatthew Dillon wakeup(bp); 14061c7c3c6aSMatthew Dillon } 14071c7c3c6aSMatthew Dillon 14081c7c3c6aSMatthew Dillon /* 14091c7c3c6aSMatthew Dillon * swp_pager_async_iodone: 14101c7c3c6aSMatthew Dillon * 14111c7c3c6aSMatthew Dillon * Completion routine for asynchronous reads and writes from/to swap. 14121c7c3c6aSMatthew Dillon * Also called manually by synchronous code to finish up a bp. 14131c7c3c6aSMatthew Dillon * 14141c7c3c6aSMatthew Dillon * For READ operations, the pages are PG_BUSY'd. For WRITE operations, 14151c7c3c6aSMatthew Dillon * the pages are vm_page_t->busy'd. For READ operations, we PG_BUSY 14161c7c3c6aSMatthew Dillon * unbusy all pages except the 'main' request page. For WRITE 14171c7c3c6aSMatthew Dillon * operations, we vm_page_t->busy'd unbusy all pages ( we can do this 14181c7c3c6aSMatthew Dillon * because we marked them all VM_PAGER_PEND on return from putpages ). 14191c7c3c6aSMatthew Dillon * 14201c7c3c6aSMatthew Dillon * This routine may not block. 14214dcc5c2dSMatthew Dillon * This routine is called at splbio() or better 14224dcc5c2dSMatthew Dillon * 14234dcc5c2dSMatthew Dillon * We up ourselves to splvm() as required for various vm_page related 14244dcc5c2dSMatthew Dillon * calls. 14251c7c3c6aSMatthew Dillon */ 14261c7c3c6aSMatthew Dillon static void 14272f249180SPoul-Henning Kamp swp_pager_async_iodone(struct buf *bp) 14281c7c3c6aSMatthew Dillon { 14291c7c3c6aSMatthew Dillon int s; 14301c7c3c6aSMatthew Dillon int i; 14311c7c3c6aSMatthew Dillon vm_object_t object = NULL; 14321c7c3c6aSMatthew Dillon 14330cddd8f0SMatthew Dillon GIANT_REQUIRED; 14341c7c3c6aSMatthew Dillon bp->b_flags |= B_DONE; 14351c7c3c6aSMatthew Dillon 14361c7c3c6aSMatthew Dillon /* 14371c7c3c6aSMatthew Dillon * report error 14381c7c3c6aSMatthew Dillon */ 1439c244d2deSPoul-Henning Kamp if (bp->b_ioflags & BIO_ERROR) { 14401c7c3c6aSMatthew Dillon printf( 14411c7c3c6aSMatthew Dillon "swap_pager: I/O error - %s failed; blkno %ld," 14421c7c3c6aSMatthew Dillon "size %ld, error %d\n", 144321144e3bSPoul-Henning Kamp ((bp->b_iocmd == BIO_READ) ? "pagein" : "pageout"), 14441c7c3c6aSMatthew Dillon (long)bp->b_blkno, 14451c7c3c6aSMatthew Dillon (long)bp->b_bcount, 14461c7c3c6aSMatthew Dillon bp->b_error 14471c7c3c6aSMatthew Dillon ); 14481c7c3c6aSMatthew Dillon } 14491c7c3c6aSMatthew Dillon 14501c7c3c6aSMatthew Dillon /* 14514dcc5c2dSMatthew Dillon * set object, raise to splvm(). 14521c7c3c6aSMatthew Dillon */ 14534dcc5c2dSMatthew Dillon s = splvm(); 145426f9a767SRodney W. Grimes 145526f9a767SRodney W. Grimes /* 145626f9a767SRodney W. Grimes * remove the mapping for kernel virtual 145726f9a767SRodney W. Grimes */ 14581c7c3c6aSMatthew Dillon pmap_qremove((vm_offset_t)bp->b_data, bp->b_npages); 145926f9a767SRodney W. Grimes 146033a609ecSAlan Cox if (bp->b_npages) { 146133a609ecSAlan Cox object = bp->b_pages[0]->object; 146233a609ecSAlan Cox VM_OBJECT_LOCK(object); 146333a609ecSAlan Cox } 146440eab1e9SAlan Cox vm_page_lock_queues(); 146526f9a767SRodney W. Grimes /* 14661c7c3c6aSMatthew Dillon * cleanup pages. If an error occurs writing to swap, we are in 14671c7c3c6aSMatthew Dillon * very serious trouble. If it happens to be a disk error, though, 14681c7c3c6aSMatthew Dillon * we may be able to recover by reassigning the swap later on. So 14691c7c3c6aSMatthew Dillon * in this case we remove the m->swapblk assignment for the page 14701c7c3c6aSMatthew Dillon * but do not free it in the rlist. The errornous block(s) are thus 14711c7c3c6aSMatthew Dillon * never reallocated as swap. Redirty the page and continue. 147226f9a767SRodney W. Grimes */ 14731c7c3c6aSMatthew Dillon for (i = 0; i < bp->b_npages; ++i) { 14741c7c3c6aSMatthew Dillon vm_page_t m = bp->b_pages[i]; 1475e47ed70bSJohn Dyson 14761c7c3c6aSMatthew Dillon vm_page_flag_clear(m, PG_SWAPINPROG); 1477e47ed70bSJohn Dyson 1478c244d2deSPoul-Henning Kamp if (bp->b_ioflags & BIO_ERROR) { 1479ffc82b0aSJohn Dyson /* 14801c7c3c6aSMatthew Dillon * If an error occurs I'd love to throw the swapblk 14811c7c3c6aSMatthew Dillon * away without freeing it back to swapspace, so it 14821c7c3c6aSMatthew Dillon * can never be used again. But I can't from an 14831c7c3c6aSMatthew Dillon * interrupt. 1484ffc82b0aSJohn Dyson */ 148521144e3bSPoul-Henning Kamp if (bp->b_iocmd == BIO_READ) { 14861c7c3c6aSMatthew Dillon /* 14871c7c3c6aSMatthew Dillon * When reading, reqpage needs to stay 14881c7c3c6aSMatthew Dillon * locked for the parent, but all other 14891c7c3c6aSMatthew Dillon * pages can be freed. We still want to 14901c7c3c6aSMatthew Dillon * wakeup the parent waiting on the page, 14911c7c3c6aSMatthew Dillon * though. ( also: pg_reqpage can be -1 and 14921c7c3c6aSMatthew Dillon * not match anything ). 14931c7c3c6aSMatthew Dillon * 14941c7c3c6aSMatthew Dillon * We have to wake specifically requested pages 14951c7c3c6aSMatthew Dillon * up too because we cleared PG_SWAPINPROG and 14961c7c3c6aSMatthew Dillon * someone may be waiting for that. 14971c7c3c6aSMatthew Dillon * 14981c7c3c6aSMatthew Dillon * NOTE: for reads, m->dirty will probably 1499956f3135SPhilippe Charnier * be overridden by the original caller of 15001c7c3c6aSMatthew Dillon * getpages so don't play cute tricks here. 15011c7c3c6aSMatthew Dillon * 1502279d7226SMatthew Dillon * XXX IT IS NOT LEGAL TO FREE THE PAGE HERE 1503279d7226SMatthew Dillon * AS THIS MESSES WITH object->memq, and it is 1504279d7226SMatthew Dillon * not legal to mess with object->memq from an 1505279d7226SMatthew Dillon * interrupt. 15061c7c3c6aSMatthew Dillon */ 15071c7c3c6aSMatthew Dillon m->valid = 0; 15081c7c3c6aSMatthew Dillon vm_page_flag_clear(m, PG_ZERO); 15091c7c3c6aSMatthew Dillon if (i != bp->b_pager.pg_reqpage) 15101c7c3c6aSMatthew Dillon vm_page_free(m); 15111c7c3c6aSMatthew Dillon else 15121c7c3c6aSMatthew Dillon vm_page_flash(m); 15131c7c3c6aSMatthew Dillon /* 15141c7c3c6aSMatthew Dillon * If i == bp->b_pager.pg_reqpage, do not wake 15151c7c3c6aSMatthew Dillon * the page up. The caller needs to. 15161c7c3c6aSMatthew Dillon */ 15171c7c3c6aSMatthew Dillon } else { 15181c7c3c6aSMatthew Dillon /* 15191c7c3c6aSMatthew Dillon * If a write error occurs, reactivate page 15201c7c3c6aSMatthew Dillon * so it doesn't clog the inactive list, 15211c7c3c6aSMatthew Dillon * then finish the I/O. 15221c7c3c6aSMatthew Dillon */ 15237dbf82dcSMatthew Dillon vm_page_dirty(m); 15241c7c3c6aSMatthew Dillon vm_page_activate(m); 15251c7c3c6aSMatthew Dillon vm_page_io_finish(m); 15261c7c3c6aSMatthew Dillon } 152721144e3bSPoul-Henning Kamp } else if (bp->b_iocmd == BIO_READ) { 15281c7c3c6aSMatthew Dillon /* 15291c7c3c6aSMatthew Dillon * For read success, clear dirty bits. Nobody should 15301c7c3c6aSMatthew Dillon * have this page mapped but don't take any chances, 15311c7c3c6aSMatthew Dillon * make sure the pmap modify bits are also cleared. 15321c7c3c6aSMatthew Dillon * 15331c7c3c6aSMatthew Dillon * NOTE: for reads, m->dirty will probably be 1534956f3135SPhilippe Charnier * overridden by the original caller of getpages so 15351c7c3c6aSMatthew Dillon * we cannot set them in order to free the underlying 15361c7c3c6aSMatthew Dillon * swap in a low-swap situation. I don't think we'd 15371c7c3c6aSMatthew Dillon * want to do that anyway, but it was an optimization 15381c7c3c6aSMatthew Dillon * that existed in the old swapper for a time before 15391c7c3c6aSMatthew Dillon * it got ripped out due to precisely this problem. 15401c7c3c6aSMatthew Dillon * 15411c7c3c6aSMatthew Dillon * clear PG_ZERO in page. 15421c7c3c6aSMatthew Dillon * 15431c7c3c6aSMatthew Dillon * If not the requested page then deactivate it. 15441c7c3c6aSMatthew Dillon * 15451c7c3c6aSMatthew Dillon * Note that the requested page, reqpage, is left 15461c7c3c6aSMatthew Dillon * busied, but we still have to wake it up. The 15471c7c3c6aSMatthew Dillon * other pages are released (unbusied) by 15481c7c3c6aSMatthew Dillon * vm_page_wakeup(). We do not set reqpage's 15491c7c3c6aSMatthew Dillon * valid bits here, it is up to the caller. 15501c7c3c6aSMatthew Dillon */ 15510385347cSPeter Wemm pmap_clear_modify(m); 15521c7c3c6aSMatthew Dillon m->valid = VM_PAGE_BITS_ALL; 15532c28a105SAlan Cox vm_page_undirty(m); 15541c7c3c6aSMatthew Dillon vm_page_flag_clear(m, PG_ZERO); 15551c7c3c6aSMatthew Dillon 15561c7c3c6aSMatthew Dillon /* 15571c7c3c6aSMatthew Dillon * We have to wake specifically requested pages 15581c7c3c6aSMatthew Dillon * up too because we cleared PG_SWAPINPROG and 15591c7c3c6aSMatthew Dillon * could be waiting for it in getpages. However, 15601c7c3c6aSMatthew Dillon * be sure to not unbusy getpages specifically 15611c7c3c6aSMatthew Dillon * requested page - getpages expects it to be 15621c7c3c6aSMatthew Dillon * left busy. 15631c7c3c6aSMatthew Dillon */ 15641c7c3c6aSMatthew Dillon if (i != bp->b_pager.pg_reqpage) { 15651c7c3c6aSMatthew Dillon vm_page_deactivate(m); 15661c7c3c6aSMatthew Dillon vm_page_wakeup(m); 15671c7c3c6aSMatthew Dillon } else { 15681c7c3c6aSMatthew Dillon vm_page_flash(m); 15691c7c3c6aSMatthew Dillon } 15701c7c3c6aSMatthew Dillon } else { 15711c7c3c6aSMatthew Dillon /* 15721c7c3c6aSMatthew Dillon * For write success, clear the modify and dirty 15731c7c3c6aSMatthew Dillon * status, then finish the I/O ( which decrements the 15741c7c3c6aSMatthew Dillon * busy count and possibly wakes waiter's up ). 15751c7c3c6aSMatthew Dillon */ 15760385347cSPeter Wemm pmap_clear_modify(m); 1577c52e7044SAlan Cox vm_page_undirty(m); 15781c7c3c6aSMatthew Dillon vm_page_io_finish(m); 1579936524aaSMatthew Dillon if (!vm_page_count_severe() || !vm_page_try_to_cache(m)) 1580a12cc0e4SAlan Cox pmap_page_protect(m, VM_PROT_READ); 1581ffc82b0aSJohn Dyson } 1582df8bae1dSRodney W. Grimes } 158340eab1e9SAlan Cox vm_page_unlock_queues(); 158426f9a767SRodney W. Grimes 15851c7c3c6aSMatthew Dillon /* 15861c7c3c6aSMatthew Dillon * adjust pip. NOTE: the original parent may still have its own 15871c7c3c6aSMatthew Dillon * pip refs on the object. 15881c7c3c6aSMatthew Dillon */ 15890d420ad3SAlan Cox if (object != NULL) { 15901c7c3c6aSMatthew Dillon vm_object_pip_wakeupn(object, bp->b_npages); 15910d420ad3SAlan Cox VM_OBJECT_UNLOCK(object); 15920d420ad3SAlan Cox } 159326f9a767SRodney W. Grimes 15941c7c3c6aSMatthew Dillon /* 15951c7c3c6aSMatthew Dillon * release the physical I/O buffer 15961c7c3c6aSMatthew Dillon */ 1597327f4e83SMatthew Dillon relpbuf( 1598327f4e83SMatthew Dillon bp, 159921144e3bSPoul-Henning Kamp ((bp->b_iocmd == BIO_READ) ? &nsw_rcount : 1600327f4e83SMatthew Dillon ((bp->b_flags & B_ASYNC) ? 1601327f4e83SMatthew Dillon &nsw_wcount_async : 1602327f4e83SMatthew Dillon &nsw_wcount_sync 1603327f4e83SMatthew Dillon ) 1604327f4e83SMatthew Dillon ) 1605327f4e83SMatthew Dillon ); 160626f9a767SRodney W. Grimes splx(s); 160726f9a767SRodney W. Grimes } 16081c7c3c6aSMatthew Dillon 160992da00bbSMatthew Dillon /* 161092da00bbSMatthew Dillon * swap_pager_isswapped: 161192da00bbSMatthew Dillon * 161292da00bbSMatthew Dillon * Return 1 if at least one page in the given object is paged 161392da00bbSMatthew Dillon * out to the given swap device. 161492da00bbSMatthew Dillon * 161592da00bbSMatthew Dillon * This routine may not block. 161692da00bbSMatthew Dillon */ 16178f60c087SPoul-Henning Kamp int 16188f60c087SPoul-Henning Kamp swap_pager_isswapped(vm_object_t object, struct swdevt *sp) 16198f60c087SPoul-Henning Kamp { 162092da00bbSMatthew Dillon daddr_t index = 0; 162192da00bbSMatthew Dillon int bcount; 162292da00bbSMatthew Dillon int i; 162392da00bbSMatthew Dillon 162417cd3642SAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 162592da00bbSMatthew Dillon for (bcount = 0; bcount < object->un_pager.swp.swp_bcount; bcount++) { 162692da00bbSMatthew Dillon struct swblock *swap; 162792da00bbSMatthew Dillon 162892da00bbSMatthew Dillon if ((swap = *swp_pager_hash(object, index)) != NULL) { 162992da00bbSMatthew Dillon for (i = 0; i < SWAP_META_PAGES; ++i) { 163092da00bbSMatthew Dillon daddr_t v = swap->swb_pages[i]; 16318f60c087SPoul-Henning Kamp if (v == SWAPBLK_NONE) 16328f60c087SPoul-Henning Kamp continue; 16334b03903aSPoul-Henning Kamp if (swp_pager_find_dev(v) == sp) 163492da00bbSMatthew Dillon return 1; 163592da00bbSMatthew Dillon } 163692da00bbSMatthew Dillon } 163792da00bbSMatthew Dillon 163892da00bbSMatthew Dillon index += SWAP_META_PAGES; 163992da00bbSMatthew Dillon if (index > 0x20000000) 164092da00bbSMatthew Dillon panic("swap_pager_isswapped: failed to locate all swap meta blocks"); 164192da00bbSMatthew Dillon } 164292da00bbSMatthew Dillon return 0; 164392da00bbSMatthew Dillon } 164492da00bbSMatthew Dillon 164592da00bbSMatthew Dillon /* 164692da00bbSMatthew Dillon * SWP_PAGER_FORCE_PAGEIN() - force a swap block to be paged in 164792da00bbSMatthew Dillon * 164892da00bbSMatthew Dillon * This routine dissociates the page at the given index within a 164992da00bbSMatthew Dillon * swap block from its backing store, paging it in if necessary. 165092da00bbSMatthew Dillon * If the page is paged in, it is placed in the inactive queue, 165192da00bbSMatthew Dillon * since it had its backing store ripped out from under it. 165292da00bbSMatthew Dillon * We also attempt to swap in all other pages in the swap block, 165392da00bbSMatthew Dillon * we only guarantee that the one at the specified index is 165492da00bbSMatthew Dillon * paged in. 165592da00bbSMatthew Dillon * 165692da00bbSMatthew Dillon * XXX - The code to page the whole block in doesn't work, so we 165792da00bbSMatthew Dillon * revert to the one-by-one behavior for now. Sigh. 165892da00bbSMatthew Dillon */ 165992da00bbSMatthew Dillon static __inline void 166092da00bbSMatthew Dillon swp_pager_force_pagein(struct swblock *swap, int idx) 166192da00bbSMatthew Dillon { 166292da00bbSMatthew Dillon vm_object_t object; 166392da00bbSMatthew Dillon vm_page_t m; 166492da00bbSMatthew Dillon vm_pindex_t pindex; 166592da00bbSMatthew Dillon 166692da00bbSMatthew Dillon object = swap->swb_object; 166792da00bbSMatthew Dillon pindex = swap->swb_index; 166892da00bbSMatthew Dillon 1669d22bc710SAlan Cox VM_OBJECT_LOCK(object); 167092da00bbSMatthew Dillon vm_object_pip_add(object, 1); 167192da00bbSMatthew Dillon m = vm_page_grab(object, pindex + idx, VM_ALLOC_NORMAL|VM_ALLOC_RETRY); 167292da00bbSMatthew Dillon if (m->valid == VM_PAGE_BITS_ALL) { 167392da00bbSMatthew Dillon vm_object_pip_subtract(object, 1); 167492da00bbSMatthew Dillon vm_page_lock_queues(); 167592da00bbSMatthew Dillon vm_page_activate(m); 167692da00bbSMatthew Dillon vm_page_dirty(m); 167792da00bbSMatthew Dillon vm_page_wakeup(m); 167892da00bbSMatthew Dillon vm_page_unlock_queues(); 167992da00bbSMatthew Dillon vm_pager_page_unswapped(m); 16802e3b314dSAlan Cox VM_OBJECT_UNLOCK(object); 168192da00bbSMatthew Dillon return; 168292da00bbSMatthew Dillon } 168392da00bbSMatthew Dillon 168492da00bbSMatthew Dillon if (swap_pager_getpages(object, &m, 1, 0) != 168592da00bbSMatthew Dillon VM_PAGER_OK) 168692da00bbSMatthew Dillon panic("swap_pager_force_pagein: read from swap failed");/*XXX*/ 168792da00bbSMatthew Dillon vm_object_pip_subtract(object, 1); 168892da00bbSMatthew Dillon vm_page_lock_queues(); 168992da00bbSMatthew Dillon vm_page_dirty(m); 169092da00bbSMatthew Dillon vm_page_dontneed(m); 169192da00bbSMatthew Dillon vm_page_wakeup(m); 169292da00bbSMatthew Dillon vm_page_unlock_queues(); 169392da00bbSMatthew Dillon vm_pager_page_unswapped(m); 16942e3b314dSAlan Cox VM_OBJECT_UNLOCK(object); 169592da00bbSMatthew Dillon } 169692da00bbSMatthew Dillon 169792da00bbSMatthew Dillon 169892da00bbSMatthew Dillon /* 169992da00bbSMatthew Dillon * swap_pager_swapoff: 170092da00bbSMatthew Dillon * 170192da00bbSMatthew Dillon * Page in all of the pages that have been paged out to the 170292da00bbSMatthew Dillon * given device. The corresponding blocks in the bitmap must be 170392da00bbSMatthew Dillon * marked as allocated and the device must be flagged SW_CLOSING. 170492da00bbSMatthew Dillon * There may be no processes swapped out to the device. 170592da00bbSMatthew Dillon * 170692da00bbSMatthew Dillon * The sw_used parameter points to the field in the swdev structure 170792da00bbSMatthew Dillon * that contains a count of the number of blocks still allocated 170892da00bbSMatthew Dillon * on the device. If we encounter objects with a nonzero pip count 170992da00bbSMatthew Dillon * in our scan, we use this number to determine if we're really done. 171092da00bbSMatthew Dillon * 171192da00bbSMatthew Dillon * This routine may block. 171292da00bbSMatthew Dillon */ 1713e9c0cc15SPoul-Henning Kamp static void 17148f60c087SPoul-Henning Kamp swap_pager_swapoff(struct swdevt *sp, int *sw_used) 171592da00bbSMatthew Dillon { 171692da00bbSMatthew Dillon struct swblock **pswap; 171792da00bbSMatthew Dillon struct swblock *swap; 171892da00bbSMatthew Dillon vm_object_t waitobj; 171992da00bbSMatthew Dillon daddr_t v; 172092da00bbSMatthew Dillon int i, j; 172192da00bbSMatthew Dillon 172292da00bbSMatthew Dillon GIANT_REQUIRED; 172392da00bbSMatthew Dillon 172492da00bbSMatthew Dillon full_rescan: 172592da00bbSMatthew Dillon waitobj = NULL; 172692da00bbSMatthew Dillon for (i = 0; i <= swhash_mask; i++) { /* '<=' is correct here */ 172792da00bbSMatthew Dillon restart: 172892da00bbSMatthew Dillon pswap = &swhash[i]; 172992da00bbSMatthew Dillon while ((swap = *pswap) != NULL) { 173092da00bbSMatthew Dillon for (j = 0; j < SWAP_META_PAGES; ++j) { 173192da00bbSMatthew Dillon v = swap->swb_pages[j]; 173292da00bbSMatthew Dillon if (v != SWAPBLK_NONE && 17334b03903aSPoul-Henning Kamp swp_pager_find_dev(v) == sp) 173492da00bbSMatthew Dillon break; 173592da00bbSMatthew Dillon } 173692da00bbSMatthew Dillon if (j < SWAP_META_PAGES) { 173792da00bbSMatthew Dillon swp_pager_force_pagein(swap, j); 173892da00bbSMatthew Dillon goto restart; 173992da00bbSMatthew Dillon } else if (swap->swb_object->paging_in_progress) { 174092da00bbSMatthew Dillon if (!waitobj) 174192da00bbSMatthew Dillon waitobj = swap->swb_object; 174292da00bbSMatthew Dillon } 174392da00bbSMatthew Dillon pswap = &swap->swb_hnext; 174492da00bbSMatthew Dillon } 174592da00bbSMatthew Dillon } 174692da00bbSMatthew Dillon if (waitobj && *sw_used) { 174792da00bbSMatthew Dillon /* 174892da00bbSMatthew Dillon * We wait on an arbitrary object to clock our rescans 174992da00bbSMatthew Dillon * to the rate of paging completion. 175092da00bbSMatthew Dillon */ 17511ca58953SAlan Cox VM_OBJECT_LOCK(waitobj); 175292da00bbSMatthew Dillon vm_object_pip_wait(waitobj, "swpoff"); 17531ca58953SAlan Cox VM_OBJECT_UNLOCK(waitobj); 175492da00bbSMatthew Dillon goto full_rescan; 175592da00bbSMatthew Dillon } 175692da00bbSMatthew Dillon if (*sw_used) 175792da00bbSMatthew Dillon panic("swapoff: failed to locate %d swap blocks", *sw_used); 175892da00bbSMatthew Dillon } 175992da00bbSMatthew Dillon 17601c7c3c6aSMatthew Dillon /************************************************************************ 17611c7c3c6aSMatthew Dillon * SWAP META DATA * 17621c7c3c6aSMatthew Dillon ************************************************************************ 17631c7c3c6aSMatthew Dillon * 17641c7c3c6aSMatthew Dillon * These routines manipulate the swap metadata stored in the 17654dcc5c2dSMatthew Dillon * OBJT_SWAP object. All swp_*() routines must be called at 17664dcc5c2dSMatthew Dillon * splvm() because swap can be freed up by the low level vm_page 17674dcc5c2dSMatthew Dillon * code which might be called from interrupts beyond what splbio() covers. 17681c7c3c6aSMatthew Dillon * 17694dcc5c2dSMatthew Dillon * Swap metadata is implemented with a global hash and not directly 17704dcc5c2dSMatthew Dillon * linked into the object. Instead the object simply contains 17714dcc5c2dSMatthew Dillon * appropriate tracking counters. 17721c7c3c6aSMatthew Dillon */ 17731c7c3c6aSMatthew Dillon 17741c7c3c6aSMatthew Dillon /* 17751c7c3c6aSMatthew Dillon * SWP_PAGER_META_BUILD() - add swap block to swap meta data for object 17761c7c3c6aSMatthew Dillon * 17771c7c3c6aSMatthew Dillon * We first convert the object to a swap object if it is a default 17781c7c3c6aSMatthew Dillon * object. 17791c7c3c6aSMatthew Dillon * 17801c7c3c6aSMatthew Dillon * The specified swapblk is added to the object's swap metadata. If 17811c7c3c6aSMatthew Dillon * the swapblk is not valid, it is freed instead. Any previously 17821c7c3c6aSMatthew Dillon * assigned swapblk is freed. 17834dcc5c2dSMatthew Dillon * 17844dcc5c2dSMatthew Dillon * This routine must be called at splvm(), except when used to convert 17854dcc5c2dSMatthew Dillon * an OBJT_DEFAULT object into an OBJT_SWAP object. 17861c7c3c6aSMatthew Dillon */ 17871c7c3c6aSMatthew Dillon static void 17882f249180SPoul-Henning Kamp swp_pager_meta_build(vm_object_t object, vm_pindex_t pindex, daddr_t swapblk) 17892f249180SPoul-Henning Kamp { 17901c7c3c6aSMatthew Dillon struct swblock *swap; 17911c7c3c6aSMatthew Dillon struct swblock **pswap; 179223f09d50SIan Dowse int idx; 17931c7c3c6aSMatthew Dillon 17940cddd8f0SMatthew Dillon GIANT_REQUIRED; 1795ee3dc7d7SAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 17961c7c3c6aSMatthew Dillon /* 17971c7c3c6aSMatthew Dillon * Convert default object to swap object if necessary 17981c7c3c6aSMatthew Dillon */ 17991c7c3c6aSMatthew Dillon if (object->type != OBJT_SWAP) { 18001c7c3c6aSMatthew Dillon object->type = OBJT_SWAP; 18011c7c3c6aSMatthew Dillon object->un_pager.swp.swp_bcount = 0; 18021c7c3c6aSMatthew Dillon 1803a9fa2c05SAlfred Perlstein mtx_lock(&sw_alloc_mtx); 18041c7c3c6aSMatthew Dillon if (object->handle != NULL) { 18051c7c3c6aSMatthew Dillon TAILQ_INSERT_TAIL( 18061c7c3c6aSMatthew Dillon NOBJLIST(object->handle), 18071c7c3c6aSMatthew Dillon object, 18081c7c3c6aSMatthew Dillon pager_object_list 18091c7c3c6aSMatthew Dillon ); 18101c7c3c6aSMatthew Dillon } else { 18111c7c3c6aSMatthew Dillon TAILQ_INSERT_TAIL( 18121c7c3c6aSMatthew Dillon &swap_pager_un_object_list, 18131c7c3c6aSMatthew Dillon object, 18141c7c3c6aSMatthew Dillon pager_object_list 18151c7c3c6aSMatthew Dillon ); 18161c7c3c6aSMatthew Dillon } 1817a9fa2c05SAlfred Perlstein mtx_unlock(&sw_alloc_mtx); 18181c7c3c6aSMatthew Dillon } 18191c7c3c6aSMatthew Dillon 18201c7c3c6aSMatthew Dillon /* 18211c7c3c6aSMatthew Dillon * Locate hash entry. If not found create, but if we aren't adding 18224dcc5c2dSMatthew Dillon * anything just return. If we run out of space in the map we wait 18234dcc5c2dSMatthew Dillon * and, since the hash table may have changed, retry. 18241c7c3c6aSMatthew Dillon */ 18254dcc5c2dSMatthew Dillon retry: 182623f09d50SIan Dowse pswap = swp_pager_hash(object, pindex); 18271c7c3c6aSMatthew Dillon 18281c7c3c6aSMatthew Dillon if ((swap = *pswap) == NULL) { 18291c7c3c6aSMatthew Dillon int i; 18301c7c3c6aSMatthew Dillon 18311c7c3c6aSMatthew Dillon if (swapblk == SWAPBLK_NONE) 18321c7c3c6aSMatthew Dillon return; 18331c7c3c6aSMatthew Dillon 1834670d17b5SJeff Roberson swap = *pswap = uma_zalloc(swap_zone, M_NOWAIT); 18354dcc5c2dSMatthew Dillon if (swap == NULL) { 1836ee3dc7d7SAlan Cox VM_OBJECT_UNLOCK(object); 18374dcc5c2dSMatthew Dillon VM_WAIT; 1838ee3dc7d7SAlan Cox VM_OBJECT_LOCK(object); 18394dcc5c2dSMatthew Dillon goto retry; 18404dcc5c2dSMatthew Dillon } 1841670d17b5SJeff Roberson 18421c7c3c6aSMatthew Dillon swap->swb_hnext = NULL; 18431c7c3c6aSMatthew Dillon swap->swb_object = object; 184423f09d50SIan Dowse swap->swb_index = pindex & ~(vm_pindex_t)SWAP_META_MASK; 18451c7c3c6aSMatthew Dillon swap->swb_count = 0; 18461c7c3c6aSMatthew Dillon 18471c7c3c6aSMatthew Dillon ++object->un_pager.swp.swp_bcount; 18481c7c3c6aSMatthew Dillon 18491c7c3c6aSMatthew Dillon for (i = 0; i < SWAP_META_PAGES; ++i) 18501c7c3c6aSMatthew Dillon swap->swb_pages[i] = SWAPBLK_NONE; 18511c7c3c6aSMatthew Dillon } 18521c7c3c6aSMatthew Dillon 18531c7c3c6aSMatthew Dillon /* 18541c7c3c6aSMatthew Dillon * Delete prior contents of metadata 18551c7c3c6aSMatthew Dillon */ 185623f09d50SIan Dowse idx = pindex & SWAP_META_MASK; 18571c7c3c6aSMatthew Dillon 185823f09d50SIan Dowse if (swap->swb_pages[idx] != SWAPBLK_NONE) { 185923f09d50SIan Dowse swp_pager_freeswapspace(swap->swb_pages[idx], 1); 18601c7c3c6aSMatthew Dillon --swap->swb_count; 18611c7c3c6aSMatthew Dillon } 18621c7c3c6aSMatthew Dillon 18631c7c3c6aSMatthew Dillon /* 18641c7c3c6aSMatthew Dillon * Enter block into metadata 18651c7c3c6aSMatthew Dillon */ 186623f09d50SIan Dowse swap->swb_pages[idx] = swapblk; 18674dcc5c2dSMatthew Dillon if (swapblk != SWAPBLK_NONE) 18681c7c3c6aSMatthew Dillon ++swap->swb_count; 18691c7c3c6aSMatthew Dillon } 18701c7c3c6aSMatthew Dillon 18711c7c3c6aSMatthew Dillon /* 18721c7c3c6aSMatthew Dillon * SWP_PAGER_META_FREE() - free a range of blocks in the object's swap metadata 18731c7c3c6aSMatthew Dillon * 18741c7c3c6aSMatthew Dillon * The requested range of blocks is freed, with any associated swap 18751c7c3c6aSMatthew Dillon * returned to the swap bitmap. 18761c7c3c6aSMatthew Dillon * 18771c7c3c6aSMatthew Dillon * This routine will free swap metadata structures as they are cleaned 18781c7c3c6aSMatthew Dillon * out. This routine does *NOT* operate on swap metadata associated 18791c7c3c6aSMatthew Dillon * with resident pages. 18801c7c3c6aSMatthew Dillon * 18811c7c3c6aSMatthew Dillon * This routine must be called at splvm() 18821c7c3c6aSMatthew Dillon */ 18831c7c3c6aSMatthew Dillon static void 18844dcc5c2dSMatthew Dillon swp_pager_meta_free(vm_object_t object, vm_pindex_t index, daddr_t count) 18851c7c3c6aSMatthew Dillon { 18860cddd8f0SMatthew Dillon GIANT_REQUIRED; 1887ee3dc7d7SAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 18881c7c3c6aSMatthew Dillon if (object->type != OBJT_SWAP) 18891c7c3c6aSMatthew Dillon return; 18901c7c3c6aSMatthew Dillon 18911c7c3c6aSMatthew Dillon while (count > 0) { 18921c7c3c6aSMatthew Dillon struct swblock **pswap; 18931c7c3c6aSMatthew Dillon struct swblock *swap; 18941c7c3c6aSMatthew Dillon 18951c7c3c6aSMatthew Dillon pswap = swp_pager_hash(object, index); 18961c7c3c6aSMatthew Dillon 18971c7c3c6aSMatthew Dillon if ((swap = *pswap) != NULL) { 18981c7c3c6aSMatthew Dillon daddr_t v = swap->swb_pages[index & SWAP_META_MASK]; 18991c7c3c6aSMatthew Dillon 19001c7c3c6aSMatthew Dillon if (v != SWAPBLK_NONE) { 19011c7c3c6aSMatthew Dillon swp_pager_freeswapspace(v, 1); 19021c7c3c6aSMatthew Dillon swap->swb_pages[index & SWAP_META_MASK] = 19031c7c3c6aSMatthew Dillon SWAPBLK_NONE; 19041c7c3c6aSMatthew Dillon if (--swap->swb_count == 0) { 19051c7c3c6aSMatthew Dillon *pswap = swap->swb_hnext; 1906670d17b5SJeff Roberson uma_zfree(swap_zone, swap); 19071c7c3c6aSMatthew Dillon --object->un_pager.swp.swp_bcount; 19081c7c3c6aSMatthew Dillon } 19091c7c3c6aSMatthew Dillon } 19101c7c3c6aSMatthew Dillon --count; 19111c7c3c6aSMatthew Dillon ++index; 19121c7c3c6aSMatthew Dillon } else { 19134dcc5c2dSMatthew Dillon int n = SWAP_META_PAGES - (index & SWAP_META_MASK); 19141c7c3c6aSMatthew Dillon count -= n; 19151c7c3c6aSMatthew Dillon index += n; 19161c7c3c6aSMatthew Dillon } 19171c7c3c6aSMatthew Dillon } 19181c7c3c6aSMatthew Dillon } 19191c7c3c6aSMatthew Dillon 19201c7c3c6aSMatthew Dillon /* 19211c7c3c6aSMatthew Dillon * SWP_PAGER_META_FREE_ALL() - destroy all swap metadata associated with object 19221c7c3c6aSMatthew Dillon * 19231c7c3c6aSMatthew Dillon * This routine locates and destroys all swap metadata associated with 19241c7c3c6aSMatthew Dillon * an object. 19254dcc5c2dSMatthew Dillon * 19264dcc5c2dSMatthew Dillon * This routine must be called at splvm() 19271c7c3c6aSMatthew Dillon */ 19281c7c3c6aSMatthew Dillon static void 19291c7c3c6aSMatthew Dillon swp_pager_meta_free_all(vm_object_t object) 19301c7c3c6aSMatthew Dillon { 19311c7c3c6aSMatthew Dillon daddr_t index = 0; 19321c7c3c6aSMatthew Dillon 19330cddd8f0SMatthew Dillon GIANT_REQUIRED; 1934ee3dc7d7SAlan Cox VM_OBJECT_LOCK_ASSERT(object, MA_OWNED); 19351c7c3c6aSMatthew Dillon if (object->type != OBJT_SWAP) 19361c7c3c6aSMatthew Dillon return; 19371c7c3c6aSMatthew Dillon 19381c7c3c6aSMatthew Dillon while (object->un_pager.swp.swp_bcount) { 19391c7c3c6aSMatthew Dillon struct swblock **pswap; 19401c7c3c6aSMatthew Dillon struct swblock *swap; 19411c7c3c6aSMatthew Dillon 19421c7c3c6aSMatthew Dillon pswap = swp_pager_hash(object, index); 19431c7c3c6aSMatthew Dillon if ((swap = *pswap) != NULL) { 19441c7c3c6aSMatthew Dillon int i; 19451c7c3c6aSMatthew Dillon 19461c7c3c6aSMatthew Dillon for (i = 0; i < SWAP_META_PAGES; ++i) { 19471c7c3c6aSMatthew Dillon daddr_t v = swap->swb_pages[i]; 19481c7c3c6aSMatthew Dillon if (v != SWAPBLK_NONE) { 19491c7c3c6aSMatthew Dillon --swap->swb_count; 19504dcc5c2dSMatthew Dillon swp_pager_freeswapspace(v, 1); 19511c7c3c6aSMatthew Dillon } 19521c7c3c6aSMatthew Dillon } 19531c7c3c6aSMatthew Dillon if (swap->swb_count != 0) 19541c7c3c6aSMatthew Dillon panic("swap_pager_meta_free_all: swb_count != 0"); 19551c7c3c6aSMatthew Dillon *pswap = swap->swb_hnext; 1956670d17b5SJeff Roberson uma_zfree(swap_zone, swap); 19571c7c3c6aSMatthew Dillon --object->un_pager.swp.swp_bcount; 19581c7c3c6aSMatthew Dillon } 19591c7c3c6aSMatthew Dillon index += SWAP_META_PAGES; 19601c7c3c6aSMatthew Dillon if (index > 0x20000000) 19611c7c3c6aSMatthew Dillon panic("swp_pager_meta_free_all: failed to locate all swap meta blocks"); 19621c7c3c6aSMatthew Dillon } 19631c7c3c6aSMatthew Dillon } 19641c7c3c6aSMatthew Dillon 19651c7c3c6aSMatthew Dillon /* 19661c7c3c6aSMatthew Dillon * SWP_PAGER_METACTL() - misc control of swap and vm_page_t meta data. 19671c7c3c6aSMatthew Dillon * 19681c7c3c6aSMatthew Dillon * This routine is capable of looking up, popping, or freeing 19691c7c3c6aSMatthew Dillon * swapblk assignments in the swap meta data or in the vm_page_t. 19701c7c3c6aSMatthew Dillon * The routine typically returns the swapblk being looked-up, or popped, 19711c7c3c6aSMatthew Dillon * or SWAPBLK_NONE if the block was freed, or SWAPBLK_NONE if the block 19721c7c3c6aSMatthew Dillon * was invalid. This routine will automatically free any invalid 19731c7c3c6aSMatthew Dillon * meta-data swapblks. 19741c7c3c6aSMatthew Dillon * 19751c7c3c6aSMatthew Dillon * It is not possible to store invalid swapblks in the swap meta data 19761c7c3c6aSMatthew Dillon * (other then a literal 'SWAPBLK_NONE'), so we don't bother checking. 19771c7c3c6aSMatthew Dillon * 19781c7c3c6aSMatthew Dillon * When acting on a busy resident page and paging is in progress, we 19791c7c3c6aSMatthew Dillon * have to wait until paging is complete but otherwise can act on the 19801c7c3c6aSMatthew Dillon * busy page. 19811c7c3c6aSMatthew Dillon * 19824dcc5c2dSMatthew Dillon * This routine must be called at splvm(). 19831c7c3c6aSMatthew Dillon * 19844dcc5c2dSMatthew Dillon * SWM_FREE remove and free swap block from metadata 19851c7c3c6aSMatthew Dillon * SWM_POP remove from meta data but do not free.. pop it out 19861c7c3c6aSMatthew Dillon */ 19871c7c3c6aSMatthew Dillon static daddr_t 19882f249180SPoul-Henning Kamp swp_pager_meta_ctl(vm_object_t object, vm_pindex_t pindex, int flags) 19892f249180SPoul-Henning Kamp { 19904dcc5c2dSMatthew Dillon struct swblock **pswap; 19914dcc5c2dSMatthew Dillon struct swblock *swap; 19924dcc5c2dSMatthew Dillon daddr_t r1; 199323f09d50SIan Dowse int idx; 19944dcc5c2dSMatthew Dillon 19950cddd8f0SMatthew Dillon GIANT_REQUIRED; 19961c7c3c6aSMatthew Dillon /* 19971c7c3c6aSMatthew Dillon * The meta data only exists of the object is OBJT_SWAP 19981c7c3c6aSMatthew Dillon * and even then might not be allocated yet. 19991c7c3c6aSMatthew Dillon */ 20004dcc5c2dSMatthew Dillon if (object->type != OBJT_SWAP) 20011c7c3c6aSMatthew Dillon return (SWAPBLK_NONE); 20021c7c3c6aSMatthew Dillon 20034dcc5c2dSMatthew Dillon r1 = SWAPBLK_NONE; 200423f09d50SIan Dowse pswap = swp_pager_hash(object, pindex); 20051c7c3c6aSMatthew Dillon 20061c7c3c6aSMatthew Dillon if ((swap = *pswap) != NULL) { 200723f09d50SIan Dowse idx = pindex & SWAP_META_MASK; 200823f09d50SIan Dowse r1 = swap->swb_pages[idx]; 20091c7c3c6aSMatthew Dillon 20101c7c3c6aSMatthew Dillon if (r1 != SWAPBLK_NONE) { 20111c7c3c6aSMatthew Dillon if (flags & SWM_FREE) { 20124dcc5c2dSMatthew Dillon swp_pager_freeswapspace(r1, 1); 20131c7c3c6aSMatthew Dillon r1 = SWAPBLK_NONE; 20141c7c3c6aSMatthew Dillon } 20151c7c3c6aSMatthew Dillon if (flags & (SWM_FREE|SWM_POP)) { 201623f09d50SIan Dowse swap->swb_pages[idx] = SWAPBLK_NONE; 20171c7c3c6aSMatthew Dillon if (--swap->swb_count == 0) { 20181c7c3c6aSMatthew Dillon *pswap = swap->swb_hnext; 2019670d17b5SJeff Roberson uma_zfree(swap_zone, swap); 20201c7c3c6aSMatthew Dillon --object->un_pager.swp.swp_bcount; 20211c7c3c6aSMatthew Dillon } 20221c7c3c6aSMatthew Dillon } 20231c7c3c6aSMatthew Dillon } 20241c7c3c6aSMatthew Dillon } 20251c7c3c6aSMatthew Dillon return (r1); 20261c7c3c6aSMatthew Dillon } 20271c7c3c6aSMatthew Dillon 2028e9c0cc15SPoul-Henning Kamp /* 2029e9c0cc15SPoul-Henning Kamp * System call swapon(name) enables swapping on device name, 2030e9c0cc15SPoul-Henning Kamp * which must be in the swdevsw. Return EBUSY 2031e9c0cc15SPoul-Henning Kamp * if already swapping on this device. 2032e9c0cc15SPoul-Henning Kamp */ 2033e9c0cc15SPoul-Henning Kamp #ifndef _SYS_SYSPROTO_H_ 2034e9c0cc15SPoul-Henning Kamp struct swapon_args { 2035e9c0cc15SPoul-Henning Kamp char *name; 2036e9c0cc15SPoul-Henning Kamp }; 2037e9c0cc15SPoul-Henning Kamp #endif 2038e9c0cc15SPoul-Henning Kamp 2039e9c0cc15SPoul-Henning Kamp /* 2040e9c0cc15SPoul-Henning Kamp * MPSAFE 2041e9c0cc15SPoul-Henning Kamp */ 2042e9c0cc15SPoul-Henning Kamp /* ARGSUSED */ 2043e9c0cc15SPoul-Henning Kamp int 20442f249180SPoul-Henning Kamp swapon(struct thread *td, struct swapon_args *uap) 2045e9c0cc15SPoul-Henning Kamp { 2046e9c0cc15SPoul-Henning Kamp struct vattr attr; 2047e9c0cc15SPoul-Henning Kamp struct vnode *vp; 2048e9c0cc15SPoul-Henning Kamp struct nameidata nd; 2049e9c0cc15SPoul-Henning Kamp int error; 2050e9c0cc15SPoul-Henning Kamp 2051e9c0cc15SPoul-Henning Kamp mtx_lock(&Giant); 2052e9c0cc15SPoul-Henning Kamp error = suser(td); 2053e9c0cc15SPoul-Henning Kamp if (error) 2054e9c0cc15SPoul-Henning Kamp goto done2; 2055e9c0cc15SPoul-Henning Kamp 2056e9c0cc15SPoul-Henning Kamp while (swdev_syscall_active) 2057e9c0cc15SPoul-Henning Kamp tsleep(&swdev_syscall_active, PUSER - 1, "swpon", 0); 2058e9c0cc15SPoul-Henning Kamp swdev_syscall_active = 1; 2059e9c0cc15SPoul-Henning Kamp 2060e9c0cc15SPoul-Henning Kamp /* 2061e9c0cc15SPoul-Henning Kamp * Swap metadata may not fit in the KVM if we have physical 2062e9c0cc15SPoul-Henning Kamp * memory of >1GB. 2063e9c0cc15SPoul-Henning Kamp */ 2064e9c0cc15SPoul-Henning Kamp if (swap_zone == NULL) { 2065e9c0cc15SPoul-Henning Kamp error = ENOMEM; 2066e9c0cc15SPoul-Henning Kamp goto done; 2067e9c0cc15SPoul-Henning Kamp } 2068e9c0cc15SPoul-Henning Kamp 2069e9c0cc15SPoul-Henning Kamp NDINIT(&nd, LOOKUP, FOLLOW, UIO_USERSPACE, uap->name, td); 2070e9c0cc15SPoul-Henning Kamp error = namei(&nd); 2071e9c0cc15SPoul-Henning Kamp if (error) 2072e9c0cc15SPoul-Henning Kamp goto done; 2073e9c0cc15SPoul-Henning Kamp 2074e9c0cc15SPoul-Henning Kamp NDFREE(&nd, NDF_ONLY_PNBUF); 2075e9c0cc15SPoul-Henning Kamp vp = nd.ni_vp; 2076e9c0cc15SPoul-Henning Kamp 207720da9c2eSPoul-Henning Kamp if (vn_isdisk(vp, &error)) { 2078dee34ca4SPoul-Henning Kamp error = swapongeom(td, vp); 207920da9c2eSPoul-Henning Kamp } else if (vp->v_type == VREG && 2080e9c0cc15SPoul-Henning Kamp (vp->v_mount->mnt_vfc->vfc_flags & VFCF_NETWORK) != 0 && 2081e9c0cc15SPoul-Henning Kamp (error = VOP_GETATTR(vp, &attr, td->td_ucred, td)) == 0) { 2082e9c0cc15SPoul-Henning Kamp /* 2083e9c0cc15SPoul-Henning Kamp * Allow direct swapping to NFS regular files in the same 2084e9c0cc15SPoul-Henning Kamp * way that nfs_mountroot() sets up diskless swapping. 2085e9c0cc15SPoul-Henning Kamp */ 208659efee01SPoul-Henning Kamp error = swaponvp(td, vp, attr.va_size / DEV_BSIZE); 2087e9c0cc15SPoul-Henning Kamp } 2088e9c0cc15SPoul-Henning Kamp 2089e9c0cc15SPoul-Henning Kamp if (error) 2090e9c0cc15SPoul-Henning Kamp vrele(vp); 2091e9c0cc15SPoul-Henning Kamp done: 2092e9c0cc15SPoul-Henning Kamp swdev_syscall_active = 0; 2093e9c0cc15SPoul-Henning Kamp wakeup_one(&swdev_syscall_active); 2094e9c0cc15SPoul-Henning Kamp done2: 2095e9c0cc15SPoul-Henning Kamp mtx_unlock(&Giant); 2096e9c0cc15SPoul-Henning Kamp return (error); 2097e9c0cc15SPoul-Henning Kamp } 2098e9c0cc15SPoul-Henning Kamp 209959efee01SPoul-Henning Kamp static void 2100dee34ca4SPoul-Henning Kamp swaponsomething(struct vnode *vp, void *id, u_long nblks, sw_strategy_t *strategy, sw_close_t *close, udev_t udev) 2101e9c0cc15SPoul-Henning Kamp { 2102e9c0cc15SPoul-Henning Kamp struct swdevt *sp; 2103e9c0cc15SPoul-Henning Kamp swblk_t dvbase; 21048f60c087SPoul-Henning Kamp u_long mblocks; 2105e9c0cc15SPoul-Henning Kamp 21068f60c087SPoul-Henning Kamp dvbase = 0; 210720da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 21088f60c087SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 2109665c0cafSPoul-Henning Kamp if (sp->sw_end >= dvbase) { 2110665c0cafSPoul-Henning Kamp /* 2111665c0cafSPoul-Henning Kamp * We put one uncovered page between the devices 2112665c0cafSPoul-Henning Kamp * in order to definitively prevent any cross-device 2113665c0cafSPoul-Henning Kamp * I/O requests 2114665c0cafSPoul-Henning Kamp */ 2115665c0cafSPoul-Henning Kamp dvbase = sp->sw_end + 1; 2116665c0cafSPoul-Henning Kamp } 2117e9c0cc15SPoul-Henning Kamp } 211820da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 21198f60c087SPoul-Henning Kamp 2120e9c0cc15SPoul-Henning Kamp /* 2121e9c0cc15SPoul-Henning Kamp * If we go beyond this, we get overflows in the radix 2122e9c0cc15SPoul-Henning Kamp * tree bitmap code. 2123e9c0cc15SPoul-Henning Kamp */ 21248f60c087SPoul-Henning Kamp mblocks = 0x40000000 / BLIST_META_RADIX; 2125d3dd89abSPoul-Henning Kamp if (nblks > mblocks) { 212685fdafb9SPoul-Henning Kamp printf("WARNING: reducing size to maximum of %lu blocks per swap unit\n", 2127d3dd89abSPoul-Henning Kamp mblocks); 2128d3dd89abSPoul-Henning Kamp nblks = mblocks; 2129e9c0cc15SPoul-Henning Kamp } 2130e9c0cc15SPoul-Henning Kamp /* 2131e9c0cc15SPoul-Henning Kamp * nblks is in DEV_BSIZE'd chunks, convert to PAGE_SIZE'd chunks. 2132e9c0cc15SPoul-Henning Kamp * First chop nblks off to page-align it, then convert. 2133e9c0cc15SPoul-Henning Kamp * 2134e9c0cc15SPoul-Henning Kamp * sw->sw_nblks is in page-sized chunks now too. 2135e9c0cc15SPoul-Henning Kamp */ 2136e9c0cc15SPoul-Henning Kamp nblks &= ~(ctodb(1) - 1); 2137e9c0cc15SPoul-Henning Kamp nblks = dbtoc(nblks); 2138e9c0cc15SPoul-Henning Kamp 21398f60c087SPoul-Henning Kamp sp = malloc(sizeof *sp, M_VMPGDATA, M_WAITOK | M_ZERO); 2140dee34ca4SPoul-Henning Kamp sp->sw_vp = vp; 2141dee34ca4SPoul-Henning Kamp sp->sw_id = id; 214220da9c2eSPoul-Henning Kamp sp->sw_udev = udev; 21438d677ef9SPoul-Henning Kamp sp->sw_flags = 0; 2144e9c0cc15SPoul-Henning Kamp sp->sw_nblks = nblks; 2145e9c0cc15SPoul-Henning Kamp sp->sw_used = 0; 21468f60c087SPoul-Henning Kamp sp->sw_first = dvbase; 21478f60c087SPoul-Henning Kamp sp->sw_end = dvbase + nblks; 214859efee01SPoul-Henning Kamp sp->sw_strategy = strategy; 2149dee34ca4SPoul-Henning Kamp sp->sw_close = close; 2150e9c0cc15SPoul-Henning Kamp 21518f60c087SPoul-Henning Kamp sp->sw_blist = blist_create(nblks); 2152e9c0cc15SPoul-Henning Kamp /* 2153ef3c5abdSPoul-Henning Kamp * Do not free the first two block in order to avoid overwriting 21548f60c087SPoul-Henning Kamp * any bsd label at the front of the partition 2155e9c0cc15SPoul-Henning Kamp */ 2156ef3c5abdSPoul-Henning Kamp blist_free(sp->sw_blist, 2, nblks - 2); 2157e9c0cc15SPoul-Henning Kamp 215820da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 21598f60c087SPoul-Henning Kamp TAILQ_INSERT_TAIL(&swtailq, sp, sw_list); 216020da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 21618f60c087SPoul-Henning Kamp nswapdev++; 21628f60c087SPoul-Henning Kamp swap_pager_avail += nblks; 2163e9c0cc15SPoul-Henning Kamp swap_pager_full = 0; 216459efee01SPoul-Henning Kamp } 2165e9c0cc15SPoul-Henning Kamp 2166e9c0cc15SPoul-Henning Kamp /* 2167e9c0cc15SPoul-Henning Kamp * SYSCALL: swapoff(devname) 2168e9c0cc15SPoul-Henning Kamp * 2169e9c0cc15SPoul-Henning Kamp * Disable swapping on the given device. 2170dee34ca4SPoul-Henning Kamp * 2171dee34ca4SPoul-Henning Kamp * XXX: Badly designed system call: it should use a device index 2172dee34ca4SPoul-Henning Kamp * rather than filename as specification. We keep sw_vp around 2173dee34ca4SPoul-Henning Kamp * only to make this work. 2174e9c0cc15SPoul-Henning Kamp */ 2175e9c0cc15SPoul-Henning Kamp #ifndef _SYS_SYSPROTO_H_ 2176e9c0cc15SPoul-Henning Kamp struct swapoff_args { 2177e9c0cc15SPoul-Henning Kamp char *name; 2178e9c0cc15SPoul-Henning Kamp }; 2179e9c0cc15SPoul-Henning Kamp #endif 2180e9c0cc15SPoul-Henning Kamp 2181e9c0cc15SPoul-Henning Kamp /* 2182e9c0cc15SPoul-Henning Kamp * MPSAFE 2183e9c0cc15SPoul-Henning Kamp */ 2184e9c0cc15SPoul-Henning Kamp /* ARGSUSED */ 2185e9c0cc15SPoul-Henning Kamp int 21862f249180SPoul-Henning Kamp swapoff(struct thread *td, struct swapoff_args *uap) 2187e9c0cc15SPoul-Henning Kamp { 2188e9c0cc15SPoul-Henning Kamp struct vnode *vp; 2189e9c0cc15SPoul-Henning Kamp struct nameidata nd; 2190e9c0cc15SPoul-Henning Kamp struct swdevt *sp; 21918f60c087SPoul-Henning Kamp u_long nblks, dvbase; 21928f60c087SPoul-Henning Kamp int error; 2193e9c0cc15SPoul-Henning Kamp 2194e9c0cc15SPoul-Henning Kamp mtx_lock(&Giant); 2195e9c0cc15SPoul-Henning Kamp 2196e9c0cc15SPoul-Henning Kamp error = suser(td); 2197e9c0cc15SPoul-Henning Kamp if (error) 2198e9c0cc15SPoul-Henning Kamp goto done2; 2199e9c0cc15SPoul-Henning Kamp 2200e9c0cc15SPoul-Henning Kamp while (swdev_syscall_active) 2201e9c0cc15SPoul-Henning Kamp tsleep(&swdev_syscall_active, PUSER - 1, "swpoff", 0); 2202e9c0cc15SPoul-Henning Kamp swdev_syscall_active = 1; 2203e9c0cc15SPoul-Henning Kamp 2204e9c0cc15SPoul-Henning Kamp NDINIT(&nd, LOOKUP, FOLLOW, UIO_USERSPACE, uap->name, td); 2205e9c0cc15SPoul-Henning Kamp error = namei(&nd); 2206e9c0cc15SPoul-Henning Kamp if (error) 2207e9c0cc15SPoul-Henning Kamp goto done; 2208e9c0cc15SPoul-Henning Kamp NDFREE(&nd, NDF_ONLY_PNBUF); 2209e9c0cc15SPoul-Henning Kamp vp = nd.ni_vp; 2210e9c0cc15SPoul-Henning Kamp 221120da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 22128f60c087SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 2213dee34ca4SPoul-Henning Kamp if (sp->sw_vp == vp) 2214e9c0cc15SPoul-Henning Kamp goto found; 2215e9c0cc15SPoul-Henning Kamp } 221620da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2217e9c0cc15SPoul-Henning Kamp error = EINVAL; 2218e9c0cc15SPoul-Henning Kamp goto done; 2219e9c0cc15SPoul-Henning Kamp found: 222020da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2221e9c0cc15SPoul-Henning Kamp #ifdef MAC 2222e9c0cc15SPoul-Henning Kamp (void) vn_lock(vp, LK_EXCLUSIVE | LK_RETRY, td); 2223e9c0cc15SPoul-Henning Kamp error = mac_check_system_swapoff(td->td_ucred, vp); 2224e9c0cc15SPoul-Henning Kamp (void) VOP_UNLOCK(vp, 0, td); 2225e9c0cc15SPoul-Henning Kamp if (error != 0) 2226e9c0cc15SPoul-Henning Kamp goto done; 2227e9c0cc15SPoul-Henning Kamp #endif 2228e9c0cc15SPoul-Henning Kamp 2229e9c0cc15SPoul-Henning Kamp nblks = sp->sw_nblks; 2230e9c0cc15SPoul-Henning Kamp 2231e9c0cc15SPoul-Henning Kamp /* 2232e9c0cc15SPoul-Henning Kamp * We can turn off this swap device safely only if the 2233e9c0cc15SPoul-Henning Kamp * available virtual memory in the system will fit the amount 2234e9c0cc15SPoul-Henning Kamp * of data we will have to page back in, plus an epsilon so 2235e9c0cc15SPoul-Henning Kamp * the system doesn't become critically low on swap space. 2236e9c0cc15SPoul-Henning Kamp */ 22378f60c087SPoul-Henning Kamp if (cnt.v_free_count + cnt.v_cache_count + swap_pager_avail < 2238e9c0cc15SPoul-Henning Kamp nblks + nswap_lowat) { 2239e9c0cc15SPoul-Henning Kamp error = ENOMEM; 2240e9c0cc15SPoul-Henning Kamp goto done; 2241e9c0cc15SPoul-Henning Kamp } 2242e9c0cc15SPoul-Henning Kamp 2243e9c0cc15SPoul-Henning Kamp /* 2244e9c0cc15SPoul-Henning Kamp * Prevent further allocations on this device. 2245e9c0cc15SPoul-Henning Kamp */ 2246e9c0cc15SPoul-Henning Kamp sp->sw_flags |= SW_CLOSING; 22478f60c087SPoul-Henning Kamp for (dvbase = 0; dvbase < sp->sw_end; dvbase += dmmax) { 22488f60c087SPoul-Henning Kamp swap_pager_avail -= blist_fill(sp->sw_blist, 22498f60c087SPoul-Henning Kamp dvbase, dmmax); 2250e9c0cc15SPoul-Henning Kamp } 2251e9c0cc15SPoul-Henning Kamp 2252e9c0cc15SPoul-Henning Kamp /* 2253e9c0cc15SPoul-Henning Kamp * Page in the contents of the device and close it. 2254e9c0cc15SPoul-Henning Kamp */ 2255e9c0cc15SPoul-Henning Kamp #ifndef NO_SWAPPING 22568f60c087SPoul-Henning Kamp vm_proc_swapin_all(sp); 2257e9c0cc15SPoul-Henning Kamp #endif /* !NO_SWAPPING */ 22588f60c087SPoul-Henning Kamp swap_pager_swapoff(sp, &sp->sw_used); 2259e9c0cc15SPoul-Henning Kamp 2260dee34ca4SPoul-Henning Kamp sp->sw_close(td, sp); 226159efee01SPoul-Henning Kamp sp->sw_id = NULL; 226220da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 22638f60c087SPoul-Henning Kamp TAILQ_REMOVE(&swtailq, sp, sw_list); 226420da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 22658f60c087SPoul-Henning Kamp if (swdevhd == sp) 22668f60c087SPoul-Henning Kamp swdevhd = NULL; 22678f60c087SPoul-Henning Kamp nswapdev--; 22688f60c087SPoul-Henning Kamp blist_destroy(sp->sw_blist); 22698f60c087SPoul-Henning Kamp free(sp, M_VMPGDATA); 2270e9c0cc15SPoul-Henning Kamp 2271e9c0cc15SPoul-Henning Kamp done: 2272e9c0cc15SPoul-Henning Kamp swdev_syscall_active = 0; 2273e9c0cc15SPoul-Henning Kamp wakeup_one(&swdev_syscall_active); 2274e9c0cc15SPoul-Henning Kamp done2: 2275e9c0cc15SPoul-Henning Kamp mtx_unlock(&Giant); 2276e9c0cc15SPoul-Henning Kamp return (error); 2277e9c0cc15SPoul-Henning Kamp } 2278e9c0cc15SPoul-Henning Kamp 2279567104a1SPoul-Henning Kamp void 2280567104a1SPoul-Henning Kamp swap_pager_status(int *total, int *used) 2281567104a1SPoul-Henning Kamp { 2282567104a1SPoul-Henning Kamp struct swdevt *sp; 2283567104a1SPoul-Henning Kamp 2284567104a1SPoul-Henning Kamp *total = 0; 2285567104a1SPoul-Henning Kamp *used = 0; 228620da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 22878f60c087SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 2288567104a1SPoul-Henning Kamp *total += sp->sw_nblks; 2289567104a1SPoul-Henning Kamp *used += sp->sw_used; 2290567104a1SPoul-Henning Kamp } 229120da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2292567104a1SPoul-Henning Kamp } 2293567104a1SPoul-Henning Kamp 2294e9c0cc15SPoul-Henning Kamp static int 2295e9c0cc15SPoul-Henning Kamp sysctl_vm_swap_info(SYSCTL_HANDLER_ARGS) 2296e9c0cc15SPoul-Henning Kamp { 2297e9c0cc15SPoul-Henning Kamp int *name = (int *)arg1; 22988f60c087SPoul-Henning Kamp int error, n; 2299e9c0cc15SPoul-Henning Kamp struct xswdev xs; 2300e9c0cc15SPoul-Henning Kamp struct swdevt *sp; 2301e9c0cc15SPoul-Henning Kamp 2302e9c0cc15SPoul-Henning Kamp if (arg2 != 1) /* name length */ 2303e9c0cc15SPoul-Henning Kamp return (EINVAL); 2304e9c0cc15SPoul-Henning Kamp 23058f60c087SPoul-Henning Kamp n = 0; 230620da9c2eSPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 23078f60c087SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 2308e9c0cc15SPoul-Henning Kamp if (n == *name) { 230920da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2310e9c0cc15SPoul-Henning Kamp xs.xsw_version = XSWDEV_VERSION; 231120da9c2eSPoul-Henning Kamp xs.xsw_dev = sp->sw_udev; 2312e9c0cc15SPoul-Henning Kamp xs.xsw_flags = sp->sw_flags; 2313e9c0cc15SPoul-Henning Kamp xs.xsw_nblks = sp->sw_nblks; 2314e9c0cc15SPoul-Henning Kamp xs.xsw_used = sp->sw_used; 2315e9c0cc15SPoul-Henning Kamp 2316e9c0cc15SPoul-Henning Kamp error = SYSCTL_OUT(req, &xs, sizeof(xs)); 2317e9c0cc15SPoul-Henning Kamp return (error); 2318e9c0cc15SPoul-Henning Kamp } 2319e9c0cc15SPoul-Henning Kamp n++; 2320e9c0cc15SPoul-Henning Kamp } 232120da9c2eSPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2322e9c0cc15SPoul-Henning Kamp return (ENOENT); 2323e9c0cc15SPoul-Henning Kamp } 2324e9c0cc15SPoul-Henning Kamp 23258f60c087SPoul-Henning Kamp SYSCTL_INT(_vm, OID_AUTO, nswapdev, CTLFLAG_RD, &nswapdev, 0, 2326e9c0cc15SPoul-Henning Kamp "Number of swap devices"); 2327e9c0cc15SPoul-Henning Kamp SYSCTL_NODE(_vm, OID_AUTO, swap_info, CTLFLAG_RD, sysctl_vm_swap_info, 2328e9c0cc15SPoul-Henning Kamp "Swap statistics by device"); 2329ec38b344SPoul-Henning Kamp 2330ec38b344SPoul-Henning Kamp /* 2331ec38b344SPoul-Henning Kamp * vmspace_swap_count() - count the approximate swap useage in pages for a 2332ec38b344SPoul-Henning Kamp * vmspace. 2333ec38b344SPoul-Henning Kamp * 2334ec38b344SPoul-Henning Kamp * The map must be locked. 2335ec38b344SPoul-Henning Kamp * 2336ec38b344SPoul-Henning Kamp * Swap useage is determined by taking the proportional swap used by 2337ec38b344SPoul-Henning Kamp * VM objects backing the VM map. To make up for fractional losses, 2338ec38b344SPoul-Henning Kamp * if the VM object has any swap use at all the associated map entries 2339ec38b344SPoul-Henning Kamp * count for at least 1 swap page. 2340ec38b344SPoul-Henning Kamp */ 2341ec38b344SPoul-Henning Kamp int 2342ec38b344SPoul-Henning Kamp vmspace_swap_count(struct vmspace *vmspace) 2343ec38b344SPoul-Henning Kamp { 2344ec38b344SPoul-Henning Kamp vm_map_t map = &vmspace->vm_map; 2345ec38b344SPoul-Henning Kamp vm_map_entry_t cur; 2346ec38b344SPoul-Henning Kamp int count = 0; 2347ec38b344SPoul-Henning Kamp 2348ec38b344SPoul-Henning Kamp for (cur = map->header.next; cur != &map->header; cur = cur->next) { 2349ec38b344SPoul-Henning Kamp vm_object_t object; 2350ec38b344SPoul-Henning Kamp 2351ec38b344SPoul-Henning Kamp if ((cur->eflags & MAP_ENTRY_IS_SUB_MAP) == 0 && 2352ec38b344SPoul-Henning Kamp (object = cur->object.vm_object) != NULL) { 2353ec38b344SPoul-Henning Kamp VM_OBJECT_LOCK(object); 2354ec38b344SPoul-Henning Kamp if (object->type == OBJT_SWAP && 2355ec38b344SPoul-Henning Kamp object->un_pager.swp.swp_bcount != 0) { 2356ec38b344SPoul-Henning Kamp int n = (cur->end - cur->start) / PAGE_SIZE; 2357ec38b344SPoul-Henning Kamp 2358ec38b344SPoul-Henning Kamp count += object->un_pager.swp.swp_bcount * 2359ec38b344SPoul-Henning Kamp SWAP_META_PAGES * n / object->size + 1; 2360ec38b344SPoul-Henning Kamp } 2361ec38b344SPoul-Henning Kamp VM_OBJECT_UNLOCK(object); 2362ec38b344SPoul-Henning Kamp } 2363ec38b344SPoul-Henning Kamp } 2364ec38b344SPoul-Henning Kamp return (count); 2365ec38b344SPoul-Henning Kamp } 2366dee34ca4SPoul-Henning Kamp 2367dee34ca4SPoul-Henning Kamp /* 2368dee34ca4SPoul-Henning Kamp * GEOM backend 2369dee34ca4SPoul-Henning Kamp * 2370dee34ca4SPoul-Henning Kamp * Swapping onto disk devices. 2371dee34ca4SPoul-Henning Kamp * 2372dee34ca4SPoul-Henning Kamp */ 2373dee34ca4SPoul-Henning Kamp 2374dee34ca4SPoul-Henning Kamp static struct g_class g_swap_class = { 2375dee34ca4SPoul-Henning Kamp .name = "SWAP", 2376dee34ca4SPoul-Henning Kamp }; 2377dee34ca4SPoul-Henning Kamp 2378dee34ca4SPoul-Henning Kamp DECLARE_GEOM_CLASS(g_swap_class, g_class); 2379dee34ca4SPoul-Henning Kamp 2380dee34ca4SPoul-Henning Kamp 2381dee34ca4SPoul-Henning Kamp static void 2382dee34ca4SPoul-Henning Kamp swapgeom_done(struct bio *bp2) 2383dee34ca4SPoul-Henning Kamp { 2384dee34ca4SPoul-Henning Kamp struct buf *bp; 2385dee34ca4SPoul-Henning Kamp 2386dee34ca4SPoul-Henning Kamp bp = bp2->bio_caller2; 2387dee34ca4SPoul-Henning Kamp if (bp2->bio_error) 2388dee34ca4SPoul-Henning Kamp bp->b_ioflags |= BIO_ERROR; 2389dee34ca4SPoul-Henning Kamp mtx_lock(&Giant); 2390dee34ca4SPoul-Henning Kamp bufdone(bp); 2391dee34ca4SPoul-Henning Kamp mtx_unlock(&Giant); 2392dee34ca4SPoul-Henning Kamp g_destroy_bio(bp2); 2393dee34ca4SPoul-Henning Kamp } 2394dee34ca4SPoul-Henning Kamp 2395dee34ca4SPoul-Henning Kamp static void 2396dee34ca4SPoul-Henning Kamp swapgeom_strategy(struct buf *bp, struct swdevt *sp) 2397dee34ca4SPoul-Henning Kamp { 2398dee34ca4SPoul-Henning Kamp struct bio *bio; 2399dee34ca4SPoul-Henning Kamp struct g_consumer *cp; 2400dee34ca4SPoul-Henning Kamp 2401dee34ca4SPoul-Henning Kamp cp = sp->sw_id; 2402dee34ca4SPoul-Henning Kamp if (cp == NULL) { 2403dee34ca4SPoul-Henning Kamp bp->b_error = ENXIO; 2404dee34ca4SPoul-Henning Kamp bp->b_ioflags |= BIO_ERROR; 2405dee34ca4SPoul-Henning Kamp bufdone(bp); 2406dee34ca4SPoul-Henning Kamp return; 2407dee34ca4SPoul-Henning Kamp } 2408dee34ca4SPoul-Henning Kamp bio = g_clone_bio(&bp->b_io); 2409dee34ca4SPoul-Henning Kamp bio->bio_caller2 = bp; 2410dee34ca4SPoul-Henning Kamp bio->bio_offset = (bp->b_blkno - sp->sw_first) * PAGE_SIZE; 2411dee34ca4SPoul-Henning Kamp bio->bio_length = bp->b_bcount; 2412dee34ca4SPoul-Henning Kamp bio->bio_done = swapgeom_done; 2413dee34ca4SPoul-Henning Kamp g_io_request(bio, cp); 2414dee34ca4SPoul-Henning Kamp return; 2415dee34ca4SPoul-Henning Kamp } 2416dee34ca4SPoul-Henning Kamp 2417dee34ca4SPoul-Henning Kamp static void 2418dee34ca4SPoul-Henning Kamp swapgeom_orphan(struct g_consumer *cp) 2419dee34ca4SPoul-Henning Kamp { 2420dee34ca4SPoul-Henning Kamp struct swdevt *sp; 2421dee34ca4SPoul-Henning Kamp 2422dee34ca4SPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 2423dee34ca4SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) 2424dee34ca4SPoul-Henning Kamp if (sp->sw_id == cp) 2425dee34ca4SPoul-Henning Kamp sp->sw_id = NULL; 2426dee34ca4SPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2427dee34ca4SPoul-Henning Kamp } 2428dee34ca4SPoul-Henning Kamp 2429dee34ca4SPoul-Henning Kamp static void 2430dee34ca4SPoul-Henning Kamp swapgeom_close_ev(void *arg, int flags) 2431dee34ca4SPoul-Henning Kamp { 2432dee34ca4SPoul-Henning Kamp struct g_consumer *cp; 2433dee34ca4SPoul-Henning Kamp 2434dee34ca4SPoul-Henning Kamp cp = arg; 2435afeb65e6SPoul-Henning Kamp g_access_rel(cp, -1, -1, 0); 2436dee34ca4SPoul-Henning Kamp g_detach(cp); 2437dee34ca4SPoul-Henning Kamp g_destroy_consumer(cp); 2438dee34ca4SPoul-Henning Kamp } 2439dee34ca4SPoul-Henning Kamp 2440dee34ca4SPoul-Henning Kamp static void 2441dee34ca4SPoul-Henning Kamp swapgeom_close(struct thread *td, struct swdevt *sw) 2442dee34ca4SPoul-Henning Kamp { 2443dee34ca4SPoul-Henning Kamp 2444dee34ca4SPoul-Henning Kamp /* XXX: direct call when Giant untangled */ 2445dee34ca4SPoul-Henning Kamp g_waitfor_event(swapgeom_close_ev, sw->sw_id, M_WAITOK, NULL); 2446dee34ca4SPoul-Henning Kamp } 2447dee34ca4SPoul-Henning Kamp 2448dee34ca4SPoul-Henning Kamp 2449dee34ca4SPoul-Henning Kamp struct swh0h0 { 2450dee34ca4SPoul-Henning Kamp dev_t dev; 2451dee34ca4SPoul-Henning Kamp struct vnode *vp; 2452dee34ca4SPoul-Henning Kamp int error; 2453dee34ca4SPoul-Henning Kamp }; 2454dee34ca4SPoul-Henning Kamp 2455dee34ca4SPoul-Henning Kamp static void 2456dee34ca4SPoul-Henning Kamp swapongeom_ev(void *arg, int flags) 2457dee34ca4SPoul-Henning Kamp { 2458dee34ca4SPoul-Henning Kamp struct swh0h0 *swh; 2459dee34ca4SPoul-Henning Kamp struct g_provider *pp; 2460dee34ca4SPoul-Henning Kamp struct g_consumer *cp; 2461dee34ca4SPoul-Henning Kamp static struct g_geom *gp; 2462dee34ca4SPoul-Henning Kamp struct swdevt *sp; 2463dee34ca4SPoul-Henning Kamp u_long nblks; 2464dee34ca4SPoul-Henning Kamp int error; 2465dee34ca4SPoul-Henning Kamp 2466dee34ca4SPoul-Henning Kamp swh = arg; 2467dee34ca4SPoul-Henning Kamp swh->error = 0; 2468dee34ca4SPoul-Henning Kamp pp = g_dev_getprovider(swh->dev); 2469dee34ca4SPoul-Henning Kamp if (pp == NULL) { 2470dee34ca4SPoul-Henning Kamp swh->error = ENODEV; 2471dee34ca4SPoul-Henning Kamp return; 2472dee34ca4SPoul-Henning Kamp } 2473dee34ca4SPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 2474dee34ca4SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 2475dee34ca4SPoul-Henning Kamp cp = sp->sw_id; 2476dee34ca4SPoul-Henning Kamp if (cp != NULL && cp->provider == pp) { 2477dee34ca4SPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2478dee34ca4SPoul-Henning Kamp swh->error = EBUSY; 2479dee34ca4SPoul-Henning Kamp return; 2480dee34ca4SPoul-Henning Kamp } 2481dee34ca4SPoul-Henning Kamp } 2482dee34ca4SPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2483dee34ca4SPoul-Henning Kamp if (gp == NULL) { 2484dee34ca4SPoul-Henning Kamp gp = g_new_geomf(&g_swap_class, "swap", NULL); 2485dee34ca4SPoul-Henning Kamp gp->orphan = swapgeom_orphan; 2486dee34ca4SPoul-Henning Kamp } 2487dee34ca4SPoul-Henning Kamp cp = g_new_consumer(gp); 2488dee34ca4SPoul-Henning Kamp g_attach(cp, pp); 2489afeb65e6SPoul-Henning Kamp /* 2490afeb65e6SPoul-Henning Kamp * XXX: Everytime you think you can improve the margin for 2491afeb65e6SPoul-Henning Kamp * footshooting, somebody depends on the ability to do so: 2492afeb65e6SPoul-Henning Kamp * savecore(8) wants to write to our swapdev so we cannot 2493afeb65e6SPoul-Henning Kamp * set an exclusive count :-( 2494afeb65e6SPoul-Henning Kamp */ 2495afeb65e6SPoul-Henning Kamp error = g_access_rel(cp, 1, 1, 0); 2496dee34ca4SPoul-Henning Kamp if (error) { 2497dee34ca4SPoul-Henning Kamp g_detach(cp); 2498dee34ca4SPoul-Henning Kamp g_destroy_consumer(cp); 2499dee34ca4SPoul-Henning Kamp swh->error = error; 2500dee34ca4SPoul-Henning Kamp return; 2501dee34ca4SPoul-Henning Kamp } 2502dee34ca4SPoul-Henning Kamp nblks = pp->mediasize / DEV_BSIZE; 2503dee34ca4SPoul-Henning Kamp swaponsomething(swh->vp, cp, nblks, swapgeom_strategy, 2504dee34ca4SPoul-Henning Kamp swapgeom_close, dev2udev(swh->dev)); 2505dee34ca4SPoul-Henning Kamp swh->error = 0; 2506dee34ca4SPoul-Henning Kamp return; 2507dee34ca4SPoul-Henning Kamp } 2508dee34ca4SPoul-Henning Kamp 2509dee34ca4SPoul-Henning Kamp static int 2510dee34ca4SPoul-Henning Kamp swapongeom(struct thread *td, struct vnode *vp) 2511dee34ca4SPoul-Henning Kamp { 2512dee34ca4SPoul-Henning Kamp int error; 2513dee34ca4SPoul-Henning Kamp struct swh0h0 swh; 2514dee34ca4SPoul-Henning Kamp 2515dee34ca4SPoul-Henning Kamp vn_lock(vp, LK_EXCLUSIVE | LK_RETRY, td); 2516dee34ca4SPoul-Henning Kamp 2517dee34ca4SPoul-Henning Kamp swh.dev = vp->v_rdev; 2518dee34ca4SPoul-Henning Kamp swh.vp = vp; 2519dee34ca4SPoul-Henning Kamp swh.error = 0; 2520dee34ca4SPoul-Henning Kamp /* XXX: direct call when Giant untangled */ 2521dee34ca4SPoul-Henning Kamp error = g_waitfor_event(swapongeom_ev, &swh, M_WAITOK, NULL); 2522dee34ca4SPoul-Henning Kamp if (!error) 2523dee34ca4SPoul-Henning Kamp error = swh.error; 2524dee34ca4SPoul-Henning Kamp VOP_UNLOCK(vp, 0, td); 2525dee34ca4SPoul-Henning Kamp return (error); 2526dee34ca4SPoul-Henning Kamp } 2527dee34ca4SPoul-Henning Kamp 2528dee34ca4SPoul-Henning Kamp /* 2529dee34ca4SPoul-Henning Kamp * VNODE backend 2530dee34ca4SPoul-Henning Kamp * 2531dee34ca4SPoul-Henning Kamp * This is used mainly for network filesystem (read: probably only tested 2532dee34ca4SPoul-Henning Kamp * with NFS) swapfiles. 2533dee34ca4SPoul-Henning Kamp * 2534dee34ca4SPoul-Henning Kamp */ 2535dee34ca4SPoul-Henning Kamp 2536dee34ca4SPoul-Henning Kamp static void 2537dee34ca4SPoul-Henning Kamp swapdev_strategy(struct buf *bp, struct swdevt *sp) 2538dee34ca4SPoul-Henning Kamp { 2539dee34ca4SPoul-Henning Kamp int s; 2540dee34ca4SPoul-Henning Kamp struct vnode *vp, *vp2; 2541dee34ca4SPoul-Henning Kamp 2542dee34ca4SPoul-Henning Kamp bp->b_dev = NODEV; 2543dee34ca4SPoul-Henning Kamp bp->b_blkno = ctodb(bp->b_blkno - sp->sw_first); 2544dee34ca4SPoul-Henning Kamp 2545dee34ca4SPoul-Henning Kamp vp2 = sp->sw_id; 2546dee34ca4SPoul-Henning Kamp vhold(vp2); 2547dee34ca4SPoul-Henning Kamp s = splvm(); 2548dee34ca4SPoul-Henning Kamp if (bp->b_iocmd == BIO_WRITE) { 2549dee34ca4SPoul-Henning Kamp vp = bp->b_vp; 2550dee34ca4SPoul-Henning Kamp if (vp) { 2551dee34ca4SPoul-Henning Kamp VI_LOCK(vp); 2552dee34ca4SPoul-Henning Kamp vp->v_numoutput--; 2553dee34ca4SPoul-Henning Kamp if ((vp->v_iflag & VI_BWAIT) && vp->v_numoutput <= 0) { 2554dee34ca4SPoul-Henning Kamp vp->v_iflag &= ~VI_BWAIT; 2555dee34ca4SPoul-Henning Kamp wakeup(&vp->v_numoutput); 2556dee34ca4SPoul-Henning Kamp } 2557dee34ca4SPoul-Henning Kamp VI_UNLOCK(vp); 2558dee34ca4SPoul-Henning Kamp } 2559dee34ca4SPoul-Henning Kamp VI_LOCK(vp2); 2560dee34ca4SPoul-Henning Kamp vp2->v_numoutput++; 2561dee34ca4SPoul-Henning Kamp VI_UNLOCK(vp2); 2562dee34ca4SPoul-Henning Kamp } 2563dee34ca4SPoul-Henning Kamp bp->b_vp = vp2; 2564dee34ca4SPoul-Henning Kamp splx(s); 25652c18019fSPoul-Henning Kamp bp->b_iooffset = dbtob(bp->b_blkno); 2566dee34ca4SPoul-Henning Kamp VOP_STRATEGY(vp2, bp); 2567dee34ca4SPoul-Henning Kamp return; 2568dee34ca4SPoul-Henning Kamp } 2569dee34ca4SPoul-Henning Kamp 2570dee34ca4SPoul-Henning Kamp static void 2571dee34ca4SPoul-Henning Kamp swapdev_close(struct thread *td, struct swdevt *sp) 2572dee34ca4SPoul-Henning Kamp { 2573dee34ca4SPoul-Henning Kamp 2574dee34ca4SPoul-Henning Kamp VOP_CLOSE(sp->sw_vp, FREAD | FWRITE, td->td_ucred, td); 2575dee34ca4SPoul-Henning Kamp vrele(sp->sw_vp); 2576dee34ca4SPoul-Henning Kamp } 2577dee34ca4SPoul-Henning Kamp 2578dee34ca4SPoul-Henning Kamp 2579dee34ca4SPoul-Henning Kamp static int 2580dee34ca4SPoul-Henning Kamp swaponvp(struct thread *td, struct vnode *vp, u_long nblks) 2581dee34ca4SPoul-Henning Kamp { 2582dee34ca4SPoul-Henning Kamp struct swdevt *sp; 2583dee34ca4SPoul-Henning Kamp int error; 2584dee34ca4SPoul-Henning Kamp 2585dee34ca4SPoul-Henning Kamp if (nblks == 0) 2586dee34ca4SPoul-Henning Kamp return (ENXIO); 2587dee34ca4SPoul-Henning Kamp mtx_lock(&sw_dev_mtx); 2588dee34ca4SPoul-Henning Kamp TAILQ_FOREACH(sp, &swtailq, sw_list) { 2589dee34ca4SPoul-Henning Kamp if (sp->sw_id == vp) { 2590dee34ca4SPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2591dee34ca4SPoul-Henning Kamp return (EBUSY); 2592dee34ca4SPoul-Henning Kamp } 2593dee34ca4SPoul-Henning Kamp } 2594dee34ca4SPoul-Henning Kamp mtx_unlock(&sw_dev_mtx); 2595dee34ca4SPoul-Henning Kamp 2596dee34ca4SPoul-Henning Kamp (void) vn_lock(vp, LK_EXCLUSIVE | LK_RETRY, td); 2597dee34ca4SPoul-Henning Kamp #ifdef MAC 2598dee34ca4SPoul-Henning Kamp error = mac_check_system_swapon(td->td_ucred, vp); 2599dee34ca4SPoul-Henning Kamp if (error == 0) 2600dee34ca4SPoul-Henning Kamp #endif 2601dee34ca4SPoul-Henning Kamp error = VOP_OPEN(vp, FREAD | FWRITE, td->td_ucred, td, -1); 2602dee34ca4SPoul-Henning Kamp (void) VOP_UNLOCK(vp, 0, td); 2603dee34ca4SPoul-Henning Kamp if (error) 2604dee34ca4SPoul-Henning Kamp return (error); 2605dee34ca4SPoul-Henning Kamp 2606dee34ca4SPoul-Henning Kamp swaponsomething(vp, vp, nblks, swapdev_strategy, swapdev_close, 2607dee34ca4SPoul-Henning Kamp NOUDEV); 2608dee34ca4SPoul-Henning Kamp return (0); 2609dee34ca4SPoul-Henning Kamp } 2610