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