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