uvm_pdaemon.c revision 1.1 1 1.1 mrg /* $Id: uvm_pdaemon.c,v 1.1 1998/02/05 06:25:09 mrg Exp $ */
2 1.1 mrg
3 1.1 mrg /*
4 1.1 mrg * XXXCDC: "ROUGH DRAFT" QUALITY UVM PRE-RELEASE FILE!
5 1.1 mrg * >>>USE AT YOUR OWN RISK, WORK IS NOT FINISHED<<<
6 1.1 mrg */
7 1.1 mrg /*
8 1.1 mrg * Copyright (c) 1997 Charles D. Cranor and Washington University.
9 1.1 mrg * Copyright (c) 1991, 1993, The Regents of the University of California.
10 1.1 mrg *
11 1.1 mrg * All rights reserved.
12 1.1 mrg *
13 1.1 mrg * This code is derived from software contributed to Berkeley by
14 1.1 mrg * The Mach Operating System project at Carnegie-Mellon University.
15 1.1 mrg *
16 1.1 mrg * Redistribution and use in source and binary forms, with or without
17 1.1 mrg * modification, are permitted provided that the following conditions
18 1.1 mrg * are met:
19 1.1 mrg * 1. Redistributions of source code must retain the above copyright
20 1.1 mrg * notice, this list of conditions and the following disclaimer.
21 1.1 mrg * 2. Redistributions in binary form must reproduce the above copyright
22 1.1 mrg * notice, this list of conditions and the following disclaimer in the
23 1.1 mrg * documentation and/or other materials provided with the distribution.
24 1.1 mrg * 3. All advertising materials mentioning features or use of this software
25 1.1 mrg * must display the following acknowledgement:
26 1.1 mrg * This product includes software developed by Charles D. Cranor,
27 1.1 mrg * Washington University, the University of California, Berkeley and
28 1.1 mrg * its contributors.
29 1.1 mrg * 4. Neither the name of the University nor the names of its contributors
30 1.1 mrg * may be used to endorse or promote products derived from this software
31 1.1 mrg * without specific prior written permission.
32 1.1 mrg *
33 1.1 mrg * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
34 1.1 mrg * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
35 1.1 mrg * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
36 1.1 mrg * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
37 1.1 mrg * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
38 1.1 mrg * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
39 1.1 mrg * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
40 1.1 mrg * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
41 1.1 mrg * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
42 1.1 mrg * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
43 1.1 mrg * SUCH DAMAGE.
44 1.1 mrg *
45 1.1 mrg * @(#)vm_pageout.c 8.5 (Berkeley) 2/14/94
46 1.1 mrg *
47 1.1 mrg *
48 1.1 mrg * Copyright (c) 1987, 1990 Carnegie-Mellon University.
49 1.1 mrg * All rights reserved.
50 1.1 mrg *
51 1.1 mrg * Permission to use, copy, modify and distribute this software and
52 1.1 mrg * its documentation is hereby granted, provided that both the copyright
53 1.1 mrg * notice and this permission notice appear in all copies of the
54 1.1 mrg * software, derivative works or modified versions, and any portions
55 1.1 mrg * thereof, and that both notices appear in supporting documentation.
56 1.1 mrg *
57 1.1 mrg * CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
58 1.1 mrg * CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
59 1.1 mrg * FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
60 1.1 mrg *
61 1.1 mrg * Carnegie Mellon requests users of this software to return to
62 1.1 mrg *
63 1.1 mrg * Software Distribution Coordinator or Software.Distribution (at) CS.CMU.EDU
64 1.1 mrg * School of Computer Science
65 1.1 mrg * Carnegie Mellon University
66 1.1 mrg * Pittsburgh PA 15213-3890
67 1.1 mrg *
68 1.1 mrg * any improvements or extensions that they make and grant Carnegie the
69 1.1 mrg * rights to redistribute these changes.
70 1.1 mrg */
71 1.1 mrg
72 1.1 mrg /*
73 1.1 mrg * uvm_pdaemon.c: the page daemon
74 1.1 mrg */
75 1.1 mrg
76 1.1 mrg #include <sys/param.h>
77 1.1 mrg #include <sys/proc.h>
78 1.1 mrg #include <sys/systm.h>
79 1.1 mrg #include <sys/kernel.h>
80 1.1 mrg
81 1.1 mrg #include <vm/vm.h>
82 1.1 mrg #include <vm/vm_page.h>
83 1.1 mrg #include <vm/vm_kern.h>
84 1.1 mrg
85 1.1 mrg #include <uvm/uvm.h>
86 1.1 mrg
87 1.1 mrg UVMHIST_DECL(pdhist);
88 1.1 mrg
89 1.1 mrg /*
90 1.1 mrg * local prototypes
91 1.1 mrg */
92 1.1 mrg
93 1.1 mrg static void uvmpd_scan __P((void));
94 1.1 mrg static boolean_t uvmpd_scan_inactive __P((struct pglist *));
95 1.1 mrg static void uvmpd_tune __P((void));
96 1.1 mrg
97 1.1 mrg
98 1.1 mrg /*
99 1.1 mrg * uvm_wait: wait (sleep) for the page daemon to free some pages
100 1.1 mrg *
101 1.1 mrg * => should be called with all locks released
102 1.1 mrg * => should _not_ be called by the page daemon (to avoid deadlock)
103 1.1 mrg */
104 1.1 mrg
105 1.1 mrg void uvm_wait(wmsg)
106 1.1 mrg
107 1.1 mrg char *wmsg;
108 1.1 mrg
109 1.1 mrg {
110 1.1 mrg int timo = 0;
111 1.1 mrg int s = splbio();
112 1.1 mrg
113 1.1 mrg /*
114 1.1 mrg * check for page daemon going to sleep (waiting for itself)
115 1.1 mrg */
116 1.1 mrg
117 1.1 mrg if (curproc == uvm.pagedaemon_proc) {
118 1.1 mrg /*
119 1.1 mrg * now we have a problem: the pagedaemon wants to go to sleep until
120 1.1 mrg * it frees more memory. but how can it free more memory if it is
121 1.1 mrg * asleep? that is a deadlock. we have two options:
122 1.1 mrg * [1] panic now
123 1.1 mrg * [2] put a timeout on the sleep, thus causing the pagedaemon to
124 1.1 mrg * only pause (rather than sleep forever)
125 1.1 mrg *
126 1.1 mrg * note that option [2] will only help us if we get lucky and some
127 1.1 mrg * other process on the system breaks the deadlock by exiting or
128 1.1 mrg * freeing memory (thus allowing the pagedaemon to continue).
129 1.1 mrg * for now we panic if DEBUG is defined, otherwise we hope for the
130 1.1 mrg * best with option [2] (better yet, this should never happen in
131 1.1 mrg * the first place!).
132 1.1 mrg */
133 1.1 mrg
134 1.1 mrg printf("pagedaemon: deadlock detected!\n");
135 1.1 mrg timo = hz >> 3; /* set timeout */
136 1.1 mrg #if defined(DEBUG)
137 1.1 mrg panic("pagedaemon deadlock"); /* DEBUG: panic so we can debug it */
138 1.1 mrg #endif
139 1.1 mrg }
140 1.1 mrg
141 1.1 mrg simple_lock(&uvm.pagedaemon_lock);
142 1.1 mrg thread_wakeup(&uvm.pagedaemon); /* wake the daemon! */
143 1.1 mrg UVM_UNLOCK_AND_WAIT(&uvmexp.free, &uvm.pagedaemon_lock, FALSE, wmsg, timo);
144 1.1 mrg
145 1.1 mrg splx(s);
146 1.1 mrg }
147 1.1 mrg
148 1.1 mrg
149 1.1 mrg /*
150 1.1 mrg * uvmpd_tune: tune paging parameters
151 1.1 mrg *
152 1.1 mrg * => called when ever memory is added (or removed?) to the system
153 1.1 mrg * => caller must call with page queues locked
154 1.1 mrg */
155 1.1 mrg
156 1.1 mrg static void uvmpd_tune()
157 1.1 mrg
158 1.1 mrg {
159 1.1 mrg UVMHIST_FUNC("uvmpd_tune"); UVMHIST_CALLED(pdhist);
160 1.1 mrg
161 1.1 mrg uvmexp.freemin = uvmexp.npages / 20;
162 1.1 mrg uvmexp.freemin = max(uvmexp.freemin, (16*1024)/PAGE_SIZE); /* at least 16K */
163 1.1 mrg uvmexp.freemin = min(uvmexp.freemin, (256*1024)/PAGE_SIZE); /* at most 256K */
164 1.1 mrg
165 1.1 mrg uvmexp.freetarg = (uvmexp.freemin * 4) / 3;
166 1.1 mrg if (uvmexp.freetarg <= uvmexp.freemin)
167 1.1 mrg uvmexp.freetarg = uvmexp.freemin + 1;
168 1.1 mrg
169 1.1 mrg /* uvmexp.inactarg: computed in main daemon loop */
170 1.1 mrg
171 1.1 mrg uvmexp.wiredmax = uvmexp.npages / 3;
172 1.1 mrg UVMHIST_LOG(pdhist, "<- done, freemin=%d, freetarg=%d, wiredmax=%d",
173 1.1 mrg uvmexp.freemin, uvmexp.freetarg, uvmexp.wiredmax, 0);
174 1.1 mrg }
175 1.1 mrg
176 1.1 mrg /*
177 1.1 mrg * uvm_pageout: the main loop for the pagedaemon
178 1.1 mrg */
179 1.1 mrg
180 1.1 mrg void uvm_pageout()
181 1.1 mrg
182 1.1 mrg {
183 1.1 mrg int npages = 0;
184 1.1 mrg int s;
185 1.1 mrg struct uvm_aiodesc *aio, *nextaio;
186 1.1 mrg UVMHIST_FUNC("uvm_pageout"); UVMHIST_CALLED(pdhist);
187 1.1 mrg
188 1.1 mrg UVMHIST_LOG(pdhist,"<starting uvm pagedaemon>", 0, 0, 0, 0);
189 1.1 mrg
190 1.1 mrg /*
191 1.1 mrg * ensure correct priority and set paging parameters...
192 1.1 mrg */
193 1.1 mrg
194 1.1 mrg uvm.pagedaemon_proc = curproc;
195 1.1 mrg (void) spl0();
196 1.1 mrg uvm_lock_pageq();
197 1.1 mrg npages = uvmexp.npages;
198 1.1 mrg uvmpd_tune();
199 1.1 mrg uvm_unlock_pageq();
200 1.1 mrg
201 1.1 mrg /*
202 1.1 mrg * main loop
203 1.1 mrg */
204 1.1 mrg while (TRUE) {
205 1.1 mrg
206 1.1 mrg /*
207 1.1 mrg * carefully attempt to go to sleep (without losing "wakeups"!).
208 1.1 mrg * we need splbio because we want to make sure the aio_done list
209 1.1 mrg * is totally empty before we go to sleep.
210 1.1 mrg */
211 1.1 mrg
212 1.1 mrg s = splbio();
213 1.1 mrg simple_lock(&uvm.pagedaemon_lock);
214 1.1 mrg
215 1.1 mrg /*
216 1.1 mrg * if we've got done aio's, then bypass the sleep
217 1.1 mrg */
218 1.1 mrg
219 1.1 mrg if (uvm.aio_done.tqh_first == NULL) {
220 1.1 mrg UVMHIST_LOG(maphist," <<SLEEPING>>",0,0,0,0);
221 1.1 mrg UVM_UNLOCK_AND_WAIT(&uvm.pagedaemon, &uvm.pagedaemon_lock, FALSE,
222 1.1 mrg "daemon_slp", 0);
223 1.1 mrg uvmexp.pdwoke++;
224 1.1 mrg UVMHIST_LOG(pdhist," <<WOKE UP>>",0,0,0,0);
225 1.1 mrg
226 1.1 mrg /* relock pagedaemon_lock, still at splbio */
227 1.1 mrg simple_lock(&uvm.pagedaemon_lock);
228 1.1 mrg }
229 1.1 mrg
230 1.1 mrg /*
231 1.1 mrg * check for done aio structures
232 1.1 mrg */
233 1.1 mrg
234 1.1 mrg aio = uvm.aio_done.tqh_first; /* save current list (if any)*/
235 1.1 mrg if (aio) {
236 1.1 mrg TAILQ_INIT(&uvm.aio_done); /* zero global list */
237 1.1 mrg }
238 1.1 mrg
239 1.1 mrg simple_unlock(&uvm.pagedaemon_lock); /* unlock */
240 1.1 mrg splx(s); /* drop splbio */
241 1.1 mrg
242 1.1 mrg /*
243 1.1 mrg * first clear out any pending aios (to free space in case we
244 1.1 mrg * want to pageout more stuff).
245 1.1 mrg */
246 1.1 mrg
247 1.1 mrg for (/*null*/; aio != NULL ; aio = nextaio) {
248 1.1 mrg
249 1.1 mrg nextaio = aio->aioq.tqe_next;
250 1.1 mrg aio->aiodone(aio);
251 1.1 mrg
252 1.1 mrg }
253 1.1 mrg
254 1.1 mrg /*
255 1.1 mrg * now lock page queues and recompute inactive count
256 1.1 mrg */
257 1.1 mrg uvm_lock_pageq();
258 1.1 mrg
259 1.1 mrg if (npages != uvmexp.npages) { /* check for new pages? */
260 1.1 mrg npages = uvmexp.npages;
261 1.1 mrg uvmpd_tune();
262 1.1 mrg }
263 1.1 mrg
264 1.1 mrg uvmexp.inactarg = (uvmexp.active + uvmexp.inactive) / 3;
265 1.1 mrg if (uvmexp.inactarg <= uvmexp.freetarg)
266 1.1 mrg uvmexp.inactarg = uvmexp.freetarg + 1;
267 1.1 mrg
268 1.1 mrg UVMHIST_LOG(pdhist," free/ftarg=%d/%d, inact/itarg=%d/%d",
269 1.1 mrg uvmexp.free, uvmexp.freetarg, uvmexp.inactive, uvmexp.inactarg);
270 1.1 mrg
271 1.1 mrg /*
272 1.1 mrg * scan if needed
273 1.1 mrg * [XXX: note we are reading uvm.free without locking]
274 1.1 mrg */
275 1.1 mrg if (uvmexp.free < uvmexp.freetarg || uvmexp.inactive < uvmexp.inactarg)
276 1.1 mrg uvmpd_scan();
277 1.1 mrg
278 1.1 mrg /*
279 1.1 mrg * done scan. unlock page queues (the only lock we are holding).
280 1.1 mrg */
281 1.1 mrg uvm_unlock_pageq();
282 1.1 mrg
283 1.1 mrg /*
284 1.1 mrg * done! restart loop.
285 1.1 mrg */
286 1.1 mrg thread_wakeup(&uvmexp.free);
287 1.1 mrg }
288 1.1 mrg /*NOTREACHED*/
289 1.1 mrg }
290 1.1 mrg
291 1.1 mrg /*
292 1.1 mrg * uvmpd_scan_inactive: the first loop of uvmpd_scan broken out into
293 1.1 mrg * its own function for ease of reading.
294 1.1 mrg *
295 1.1 mrg * => called with page queues locked
296 1.1 mrg * => we work on meeting our free target by converting inactive pages
297 1.1 mrg * into free pages.
298 1.1 mrg * => we handle the building of swap-backed clusters
299 1.1 mrg * => we return TRUE if we are exiting because we met our target
300 1.1 mrg */
301 1.1 mrg
302 1.1 mrg static boolean_t uvmpd_scan_inactive(pglst)
303 1.1 mrg
304 1.1 mrg struct pglist *pglst;
305 1.1 mrg
306 1.1 mrg {
307 1.1 mrg boolean_t retval = FALSE; /* assume we haven't hit target */
308 1.1 mrg int s, free, result;
309 1.1 mrg struct vm_page *p, *nextpg;
310 1.1 mrg struct uvm_object *uobj;
311 1.1 mrg struct vm_page *pps[MAXBSIZE/PAGE_SIZE], **ppsp;
312 1.1 mrg int npages;
313 1.1 mrg struct vm_page *swpps[MAXBSIZE/PAGE_SIZE]; /* XXX: see below */
314 1.1 mrg int swnpages, swcpages; /* XXX: see below */
315 1.1 mrg int swslot, oldslot;
316 1.1 mrg struct vm_anon *anon;
317 1.1 mrg boolean_t swap_backed;
318 1.1 mrg vm_offset_t start;
319 1.1 mrg UVMHIST_FUNC("uvmpd_scan_inactive"); UVMHIST_CALLED(pdhist);
320 1.1 mrg
321 1.1 mrg /*
322 1.1 mrg * note: we currently keep swap-backed pages on a seperate inactive
323 1.1 mrg * list from object-backed pages. however, merging the two lists
324 1.1 mrg * back together again hasn't been ruled out. thus, we keep our
325 1.1 mrg * swap cluster in "swpps" rather than in pps (allows us to mix clustering
326 1.1 mrg * types in the event of a mixed inactive queue).
327 1.1 mrg */
328 1.1 mrg
329 1.1 mrg /*
330 1.1 mrg * swslot is non-zero if we are building a swap cluster. we want
331 1.1 mrg * to stay in the loop while we have a page to scan or we have
332 1.1 mrg * a swap-cluster to build.
333 1.1 mrg */
334 1.1 mrg swslot = 0;
335 1.1 mrg swnpages = swcpages = 0;
336 1.1 mrg
337 1.1 mrg for (p = pglst->tqh_first ; p != NULL || swslot != 0 ; p = nextpg) {
338 1.1 mrg
339 1.1 mrg /*
340 1.1 mrg * note that p can be NULL iff we have traversed the whole
341 1.1 mrg * list and need to do one final swap-backed clustered pageout.
342 1.1 mrg */
343 1.1 mrg if (p) {
344 1.1 mrg /*
345 1.1 mrg * update our copy of "free" and see if we've met our target
346 1.1 mrg */
347 1.1 mrg s = splimp();
348 1.1 mrg uvm_lock_fpageq();
349 1.1 mrg free = uvmexp.free;
350 1.1 mrg uvm_unlock_fpageq();
351 1.1 mrg splx(s);
352 1.1 mrg
353 1.1 mrg if (free >= uvmexp.freetarg) {
354 1.1 mrg UVMHIST_LOG(pdhist," met free target: exit loop", 0, 0, 0, 0);
355 1.1 mrg retval = TRUE; /* hit the target! */
356 1.1 mrg if (swslot == 0)
357 1.1 mrg break; /* exit now if no swap-i/o pending */
358 1.1 mrg p = NULL; /* set p to null to signal final swap i/o */
359 1.1 mrg }
360 1.1 mrg }
361 1.1 mrg
362 1.1 mrg uobj = NULL; /* be safe and shut gcc up */
363 1.1 mrg anon = NULL; /* be safe and shut gcc up */
364 1.1 mrg
365 1.1 mrg if (p) { /* if (we have a new page to consider) */
366 1.1 mrg /*
367 1.1 mrg * we are below target and have a new page to consider.
368 1.1 mrg */
369 1.1 mrg uvmexp.pdscans++;
370 1.1 mrg nextpg = p->pageq.tqe_next;
371 1.1 mrg
372 1.1 mrg /*
373 1.1 mrg * move referenced pages back to active queue and skip to next page
374 1.1 mrg * (unlikely to happen since inactive pages shouldn't have any
375 1.1 mrg * valid mappings and we cleared reference before deactivating).
376 1.1 mrg */
377 1.1 mrg if (pmap_is_referenced(PMAP_PGARG(p))) {
378 1.1 mrg uvm_pageactivate(p);
379 1.1 mrg uvmexp.pdreact++;
380 1.1 mrg continue;
381 1.1 mrg }
382 1.1 mrg
383 1.1 mrg /*
384 1.1 mrg * first we attempt to lock the object that this page belongs to.
385 1.1 mrg * if our attempt fails we skip on to the next page (no harm done).
386 1.1 mrg * it is important to "try" locking the object as we are locking in the
387 1.1 mrg * wrong order (pageq -> object) and we don't want to get deadlocked.
388 1.1 mrg *
389 1.1 mrg * the only time we exepct to see an ownerless page (i.e. a page
390 1.1 mrg * with no uobject and !PQ_ANON) is if an anon has loaned a page
391 1.1 mrg * from a uvm_object and the uvm_object has dropped the ownership.
392 1.1 mrg * in that case, the anon can "take over" the loaned page and
393 1.1 mrg * make it its own.
394 1.1 mrg */
395 1.1 mrg
396 1.1 mrg /* is page part of an anon or ownerless ? */
397 1.1 mrg if ((p->pqflags & PQ_ANON) || p->uobject == NULL) {
398 1.1 mrg
399 1.1 mrg anon = p->uanon;
400 1.1 mrg
401 1.1 mrg #ifdef DIAGNOSTIC
402 1.1 mrg /* to be on inactive q, page must be part of _something_ */
403 1.1 mrg if (anon == NULL)
404 1.1 mrg panic("pagedaemon: page with no anon or object detected - loop 1");
405 1.1 mrg #endif
406 1.1 mrg
407 1.1 mrg if (!simple_lock_try(&anon->an_lock))
408 1.1 mrg continue; /* lock failed, skip this page */
409 1.1 mrg
410 1.1 mrg /* if the page is ownerless, claim it in the name of "anon"! */
411 1.1 mrg if ((p->pqflags & PQ_ANON) == 0) {
412 1.1 mrg #ifdef DIAGNOSTIC
413 1.1 mrg if (p->loan_count < 1)
414 1.1 mrg panic("pagedaemon: non-loaned ownerless page detected - loop 1");
415 1.1 mrg #endif
416 1.1 mrg p->loan_count--;
417 1.1 mrg p->pqflags |= PQ_ANON; /* anon now owns it */
418 1.1 mrg }
419 1.1 mrg
420 1.1 mrg if (p->flags & PG_BUSY) {
421 1.1 mrg simple_unlock(&anon->an_lock);
422 1.1 mrg uvmexp.pdbusy++;
423 1.1 mrg continue; /* someone else owns page, skip it */
424 1.1 mrg }
425 1.1 mrg
426 1.1 mrg uvmexp.pdanscan++;
427 1.1 mrg
428 1.1 mrg } else {
429 1.1 mrg
430 1.1 mrg uobj = p->uobject;
431 1.1 mrg
432 1.1 mrg if (!simple_lock_try(&uobj->vmobjlock))
433 1.1 mrg continue; /* lock failed, skip this page */
434 1.1 mrg
435 1.1 mrg if (p->flags & PG_BUSY) {
436 1.1 mrg simple_unlock(&uobj->vmobjlock);
437 1.1 mrg uvmexp.pdbusy++;
438 1.1 mrg continue; /* someone else owns page, skip it */
439 1.1 mrg }
440 1.1 mrg
441 1.1 mrg uvmexp.pdobscan++;
442 1.1 mrg
443 1.1 mrg }
444 1.1 mrg
445 1.1 mrg /*
446 1.1 mrg * we now have the object and the page queues locked. the page is
447 1.1 mrg * not busy. if the page is clean we can free it now and continue.
448 1.1 mrg */
449 1.1 mrg
450 1.1 mrg if (p->flags & PG_CLEAN) {
451 1.1 mrg /* zap all mappings with pmap_page_protect... */
452 1.1 mrg pmap_page_protect(PMAP_PGARG(p), VM_PROT_NONE);
453 1.1 mrg uvm_pagefree(p);
454 1.1 mrg uvmexp.pdfreed++;
455 1.1 mrg
456 1.1 mrg if (anon) {
457 1.1 mrg #ifdef DIAGNOSTIC
458 1.1 mrg /*
459 1.1 mrg * an anonymous page can only be clean if it has valid
460 1.1 mrg * backing store.
461 1.1 mrg */
462 1.1 mrg if (anon->an_swslot == 0)
463 1.1 mrg panic("pagedaemon: clean anon page without backing store?");
464 1.1 mrg #endif
465 1.1 mrg anon->u.an_page = NULL; /* remove from object */
466 1.1 mrg simple_unlock(&anon->an_lock);
467 1.1 mrg } else {
468 1.1 mrg /* pagefree has already removed the page from the object */
469 1.1 mrg simple_unlock(&uobj->vmobjlock);
470 1.1 mrg }
471 1.1 mrg continue;
472 1.1 mrg }
473 1.1 mrg
474 1.1 mrg /*
475 1.1 mrg * the page we are looking at is dirty. we must clean it before
476 1.1 mrg * it can be freed. to do this we first mark the page busy so that
477 1.1 mrg * no one else will touch the page. we write protect all the mappings
478 1.1 mrg * of the page so that no one touches it while it is in I/O.
479 1.1 mrg */
480 1.1 mrg
481 1.1 mrg swap_backed = ((p->pqflags & PQ_SWAPBACKED) != 0);
482 1.1 mrg uvmexp.pdpageouts++;
483 1.1 mrg p->flags |= PG_BUSY; /* now we own it */
484 1.1 mrg UVM_PAGE_OWN(p, "scan_inactive");
485 1.1 mrg pmap_page_protect(PMAP_PGARG(p), VM_PROT_READ);
486 1.1 mrg
487 1.1 mrg /*
488 1.1 mrg * for swap-backed pages we need to (re)allocate swap space.
489 1.1 mrg */
490 1.1 mrg if (swap_backed) {
491 1.1 mrg
492 1.1 mrg /*
493 1.1 mrg * free old swap slot (if any)
494 1.1 mrg */
495 1.1 mrg if (anon) {
496 1.1 mrg if (anon->an_swslot) {
497 1.1 mrg uvm_swap_free(anon->an_swslot, 1);
498 1.1 mrg anon->an_swslot = 0;
499 1.1 mrg }
500 1.1 mrg } else {
501 1.1 mrg oldslot = uao_set_swslot(uobj, p->offset/PAGE_SIZE, 0); /* remove */
502 1.1 mrg if (oldslot)
503 1.1 mrg uvm_swap_free(oldslot, 1); /* free */
504 1.1 mrg }
505 1.1 mrg
506 1.1 mrg /*
507 1.1 mrg * start new cluster (if necessary)
508 1.1 mrg */
509 1.1 mrg if (swslot == 0) {
510 1.1 mrg swnpages = MAXBSIZE/PAGE_SIZE; /* want this much */
511 1.1 mrg swslot = uvm_swap_alloc(&swnpages, TRUE);
512 1.1 mrg
513 1.1 mrg if (swslot == 0) {
514 1.1 mrg /* no swap? give up! */
515 1.1 mrg p->flags &= ~PG_BUSY;
516 1.1 mrg UVM_PAGE_OWN(p, NULL);
517 1.1 mrg if (anon)
518 1.1 mrg simple_unlock(&anon->an_lock);
519 1.1 mrg else
520 1.1 mrg simple_unlock(&uobj->vmobjlock);
521 1.1 mrg continue;
522 1.1 mrg }
523 1.1 mrg swcpages = 0; /* cluster is empty */
524 1.1 mrg }
525 1.1 mrg
526 1.1 mrg /*
527 1.1 mrg * add block to cluster
528 1.1 mrg */
529 1.1 mrg swpps[swcpages] = p;
530 1.1 mrg if (anon)
531 1.1 mrg anon->an_swslot = swslot + swcpages;
532 1.1 mrg else
533 1.1 mrg uao_set_swslot(uobj, p->offset/PAGE_SIZE, swslot + swcpages);
534 1.1 mrg swcpages++;
535 1.1 mrg
536 1.1 mrg /* done (swap-backed) */
537 1.1 mrg }
538 1.1 mrg
539 1.1 mrg /* end: if (p) [end of "if we have new page to consider"] */
540 1.1 mrg } else {
541 1.1 mrg
542 1.1 mrg swap_backed = TRUE; /* if p == NULL we must be doing a last swap i/o */
543 1.1 mrg
544 1.1 mrg }
545 1.1 mrg
546 1.1 mrg /*
547 1.1 mrg * now consider doing the pageout.
548 1.1 mrg *
549 1.1 mrg * for swap-backed pages, we do the pageout if we have either
550 1.1 mrg * filled the cluster (in which case (swnpages == swcpages) or
551 1.1 mrg * run out of pages (p == NULL).
552 1.1 mrg *
553 1.1 mrg * for object pages, we always do the pageout.
554 1.1 mrg */
555 1.1 mrg if (swap_backed) {
556 1.1 mrg
557 1.1 mrg if (p) { /* if we just added a page to cluster */
558 1.1 mrg if (anon)
559 1.1 mrg simple_unlock(&anon->an_lock);
560 1.1 mrg else
561 1.1 mrg simple_unlock(&uobj->vmobjlock);
562 1.1 mrg if (swcpages < swnpages) /* cluster not full yet? */
563 1.1 mrg continue;
564 1.1 mrg }
565 1.1 mrg
566 1.1 mrg /* starting I/O now... set up for it */
567 1.1 mrg npages = swcpages;
568 1.1 mrg ppsp = swpps;
569 1.1 mrg start = (vm_offset_t) swslot; /* for swap-backed pages only */
570 1.1 mrg
571 1.1 mrg /* if this is final pageout we could have a few extra swap blocks */
572 1.1 mrg if (swcpages < swnpages) {
573 1.1 mrg uvm_swap_free(swslot + swcpages, (swnpages - swcpages));
574 1.1 mrg }
575 1.1 mrg
576 1.1 mrg } else {
577 1.1 mrg
578 1.1 mrg /* normal object pageout */
579 1.1 mrg ppsp = pps;
580 1.1 mrg npages = sizeof(pps) / sizeof(struct vm_page *);
581 1.1 mrg start = 0; /* not looked at because PGO_ALLPAGES is set */
582 1.1 mrg
583 1.1 mrg }
584 1.1 mrg
585 1.1 mrg /*
586 1.1 mrg * now do the pageout.
587 1.1 mrg *
588 1.1 mrg * for swap_backed pages we have already built the cluster.
589 1.1 mrg * for !swap_backed pages, uvm_pager_put will call the object's
590 1.1 mrg * "make put cluster" function to build a cluster on our behalf.
591 1.1 mrg *
592 1.1 mrg * we pass the PGO_PDFREECLUST flag to uvm_pager_put to instruct
593 1.1 mrg * it to free the cluster pages for us on a successful I/O (it always
594 1.1 mrg * does this for un-successful I/O requests). this allows us to
595 1.1 mrg * do clustered pageout without having to deal with cluster pages
596 1.1 mrg * at this level.
597 1.1 mrg *
598 1.1 mrg * note locking semantics of uvm_pager_put with PGO_PDFREECLUST:
599 1.1 mrg * IN: locked: uobj (if !swap_backed), page queues
600 1.1 mrg * OUT: locked: uobj (if !swap_backed && result != VM_PAGER_PEND)
601 1.1 mrg * !locked: page queues, uobj (if swap_backed || VM_PAGER_PEND)
602 1.1 mrg *
603 1.1 mrg * [the bit about VM_PAGER_PEND saves us one lock-unlock pair]
604 1.1 mrg */
605 1.1 mrg
606 1.1 mrg /* locked: uobj (if !swap_backed), page queues */
607 1.1 mrg result = uvm_pager_put((swap_backed) ? NULL : uobj, p, &ppsp, &npages,
608 1.1 mrg PGO_ALLPAGES|PGO_PDFREECLUST, start, 0);
609 1.1 mrg /* locked: uobj (if !swap_backed && result != PEND) */
610 1.1 mrg /* unlocked: page queues, object (if swap_backed || result == PEND) */
611 1.1 mrg
612 1.1 mrg /*
613 1.1 mrg * if we did i/o to swap, zero swslot to indicate that we are
614 1.1 mrg * no longer building a swap-backed cluster.
615 1.1 mrg */
616 1.1 mrg
617 1.1 mrg if (swap_backed)
618 1.1 mrg swslot = 0; /* done with this cluster */
619 1.1 mrg
620 1.1 mrg /*
621 1.1 mrg * first, we check for VM_PAGER_PEND which means that the async I/O
622 1.1 mrg * is in progress and the async I/O done routine will clean up
623 1.1 mrg * after us. in this case we move on to the next page.
624 1.1 mrg *
625 1.1 mrg * there is a very remote chance that the pending async i/o can
626 1.1 mrg * finish _before_ we get here. if that happens, our page "p"
627 1.1 mrg * may no longer be on the inactive queue. so we verify this
628 1.1 mrg * when determining the next page (starting over at the head if
629 1.1 mrg * we've lost our inactive page).
630 1.1 mrg */
631 1.1 mrg
632 1.1 mrg if (result == VM_PAGER_PEND) {
633 1.1 mrg uvm_lock_pageq(); /* relock page queues */
634 1.1 mrg uvmexp.pdpending++;
635 1.1 mrg if (p) {
636 1.1 mrg if (p->pqflags & PQ_INACTIVE)
637 1.1 mrg nextpg = p->pageq.tqe_next; /* reload! */
638 1.1 mrg else
639 1.1 mrg nextpg = pglst->tqh_first; /* reload! */
640 1.1 mrg } else {
641 1.1 mrg nextpg = NULL; /* done list */
642 1.1 mrg }
643 1.1 mrg continue;
644 1.1 mrg }
645 1.1 mrg
646 1.1 mrg /*
647 1.1 mrg * clean up "p" if we have one
648 1.1 mrg */
649 1.1 mrg
650 1.1 mrg if (p) {
651 1.1 mrg /*
652 1.1 mrg * the I/O request to "p" is done and uvm_pager_put has freed
653 1.1 mrg * any cluster pages it may have allocated during I/O. all
654 1.1 mrg * that is left for us to do is clean up page "p" (which is
655 1.1 mrg * still PG_BUSY).
656 1.1 mrg *
657 1.1 mrg * our result could be one of the following:
658 1.1 mrg * VM_PAGER_OK: successful pageout
659 1.1 mrg *
660 1.1 mrg * VM_PAGER_AGAIN: tmp resource shortage, we skip to next page
661 1.1 mrg * VM_PAGER_{FAIL,ERROR,BAD}: an error. we "reactivate"
662 1.1 mrg * page to get it out of the way (it will eventually
663 1.1 mrg * drift back into the inactive queue for a retry).
664 1.1 mrg * VM_PAGER_UNLOCK: should never see this as it is only
665 1.1 mrg * valid for "get" operations
666 1.1 mrg */
667 1.1 mrg
668 1.1 mrg /* relock p's object: page queues not lock yet, so no need for "try" */
669 1.1 mrg if (swap_backed) { /* !swap_backed case: already locked... */
670 1.1 mrg if (anon)
671 1.1 mrg simple_lock(&anon->an_lock);
672 1.1 mrg else
673 1.1 mrg simple_lock(&uobj->vmobjlock);
674 1.1 mrg }
675 1.1 mrg
676 1.1 mrg #ifdef DIAGNOSTIC
677 1.1 mrg if (result == VM_PAGER_UNLOCK)
678 1.1 mrg panic("pagedaemon: pageout returned invalid 'unlock' code");
679 1.1 mrg #endif
680 1.1 mrg
681 1.1 mrg /* handle PG_WANTED now */
682 1.1 mrg if (p->flags & PG_WANTED)
683 1.1 mrg thread_wakeup(p); /* still holding object lock */
684 1.1 mrg p->flags &= ~(PG_BUSY|PG_WANTED);
685 1.1 mrg UVM_PAGE_OWN(p, NULL);
686 1.1 mrg
687 1.1 mrg /* released during I/O? */
688 1.1 mrg if (p->flags & PG_RELEASED) {
689 1.1 mrg if (anon) {
690 1.1 mrg anon->u.an_page = NULL; /* remove page so we can get nextpg */
691 1.1 mrg simple_unlock(&anon->an_lock);/* XXX needed? */
692 1.1 mrg uvm_anfree(anon); /* kills anon */
693 1.1 mrg pmap_page_protect(PMAP_PGARG(p), VM_PROT_NONE);
694 1.1 mrg anon = NULL;
695 1.1 mrg uvm_lock_pageq();
696 1.1 mrg nextpg = p->pageq.tqe_next;
697 1.1 mrg uvm_pagefree(p); /* free released page */
698 1.1 mrg
699 1.1 mrg } else {
700 1.1 mrg
701 1.1 mrg #ifdef DIAGNOSTIC
702 1.1 mrg if (uobj->pgops->pgo_releasepg == NULL)
703 1.1 mrg panic("pagedaemon: no pgo_releasepg function");
704 1.1 mrg #endif
705 1.1 mrg
706 1.1 mrg /*
707 1.1 mrg * pgo_releasepg nukes the page and gets "nextpg" for us.
708 1.1 mrg * it returns with the page queues locked (when given nextpg ptr).
709 1.1 mrg */
710 1.1 mrg if (!uobj->pgops->pgo_releasepg(p, &nextpg))
711 1.1 mrg uobj = NULL; /* uobj died after release */
712 1.1 mrg
713 1.1 mrg }
714 1.1 mrg
715 1.1 mrg } else { /* page was not released during I/O */
716 1.1 mrg
717 1.1 mrg uvm_lock_pageq();
718 1.1 mrg nextpg = p->pageq.tqe_next;
719 1.1 mrg
720 1.1 mrg if (result != VM_PAGER_OK) {
721 1.1 mrg
722 1.1 mrg /* pageout was a failure... */
723 1.1 mrg if (result != VM_PAGER_AGAIN)
724 1.1 mrg uvm_pageactivate(p);
725 1.1 mrg pmap_clear_reference(PMAP_PGARG(p));
726 1.1 mrg /* XXXCDC: if (swap_backed) FREE p's swap block? */
727 1.1 mrg
728 1.1 mrg } else {
729 1.1 mrg
730 1.1 mrg /* pageout was a success... */
731 1.1 mrg pmap_clear_reference(PMAP_PGARG(p));
732 1.1 mrg pmap_clear_modify(PMAP_PGARG(p));
733 1.1 mrg p->flags |= PG_CLEAN;
734 1.1 mrg /* XXX: could free page here, but old pagedaemon does not */
735 1.1 mrg
736 1.1 mrg }
737 1.1 mrg }
738 1.1 mrg
739 1.1 mrg /*
740 1.1 mrg * drop object lock (if there is an object left). do a safety
741 1.1 mrg * check of nextpg to make sure it is on the inactive queue
742 1.1 mrg * (it should be since PG_BUSY pages on the inactive queue can't
743 1.1 mrg * be re-queued [note: not true for active queue]).
744 1.1 mrg */
745 1.1 mrg
746 1.1 mrg if (anon)
747 1.1 mrg simple_unlock(&anon->an_lock);
748 1.1 mrg else if (uobj)
749 1.1 mrg simple_unlock(&uobj->vmobjlock);
750 1.1 mrg
751 1.1 mrg } /* if (p) */ else {
752 1.1 mrg
753 1.1 mrg /* if p is null in this loop, make sure it stays null in next loop */
754 1.1 mrg nextpg = NULL;
755 1.1 mrg
756 1.1 mrg }
757 1.1 mrg
758 1.1 mrg if (nextpg && (nextpg->pqflags & PQ_INACTIVE) == 0) {
759 1.1 mrg printf("pagedaemon: invalid nextpg! reverting to queue head\n");
760 1.1 mrg nextpg = pglst->tqh_first; /* reload! */
761 1.1 mrg }
762 1.1 mrg
763 1.1 mrg continue;
764 1.1 mrg } /* end of "inactive" 'for' loop */
765 1.1 mrg return(retval);
766 1.1 mrg }
767 1.1 mrg
768 1.1 mrg /*
769 1.1 mrg * uvmpd_scan: scan the page queues and attempt to meet our targets.
770 1.1 mrg *
771 1.1 mrg * => called with pageq's locked
772 1.1 mrg */
773 1.1 mrg
774 1.1 mrg void uvmpd_scan()
775 1.1 mrg
776 1.1 mrg {
777 1.1 mrg int s, free, pages_freed, page_shortage;
778 1.1 mrg struct vm_page *p, *nextpg;
779 1.1 mrg struct uvm_object *uobj;
780 1.1 mrg boolean_t got_it;
781 1.1 mrg UVMHIST_FUNC("uvmpd_scan"); UVMHIST_CALLED(pdhist);
782 1.1 mrg
783 1.1 mrg uvmexp.pdrevs++; /* counter */
784 1.1 mrg
785 1.1 mrg #ifdef __GNUC__
786 1.1 mrg uobj = NULL; /* XXX gcc */
787 1.1 mrg #endif
788 1.1 mrg /*
789 1.1 mrg * get current "free" page count
790 1.1 mrg */
791 1.1 mrg s = splimp();
792 1.1 mrg uvm_lock_fpageq();
793 1.1 mrg free = uvmexp.free;
794 1.1 mrg uvm_unlock_fpageq();
795 1.1 mrg splx(s);
796 1.1 mrg
797 1.1 mrg #ifndef __SWAP_BROKEN
798 1.1 mrg /*
799 1.1 mrg * swap out some processes if we are below our free target.
800 1.1 mrg * we need to unlock the page queues for this.
801 1.1 mrg */
802 1.1 mrg if (free < uvmexp.freetarg) {
803 1.1 mrg
804 1.1 mrg uvmexp.pdswout++;
805 1.1 mrg UVMHIST_LOG(pdhist," free %d < target %d: swapout", free, uvmexp.freetarg,
806 1.1 mrg 0,0);
807 1.1 mrg uvm_unlock_pageq();
808 1.1 mrg uvm_swapout_threads();
809 1.1 mrg pmap_update(); /* update so we can scan inactive q */
810 1.1 mrg uvm_lock_pageq();
811 1.1 mrg
812 1.1 mrg }
813 1.1 mrg #endif
814 1.1 mrg
815 1.1 mrg /*
816 1.1 mrg * now we want to work on meeting our targets. first we work on our
817 1.1 mrg * free target by converting inactive pages into free pages. then
818 1.1 mrg * we work on meeting our inactive target by converting active pages
819 1.1 mrg * to inactive ones.
820 1.1 mrg */
821 1.1 mrg
822 1.1 mrg UVMHIST_LOG(pdhist, " starting 'free' loop",0,0,0,0);
823 1.1 mrg pages_freed = uvmexp.pdfreed; /* so far... */
824 1.1 mrg
825 1.1 mrg /*
826 1.1 mrg * do loop #1! alternate starting queue between swap and object based
827 1.1 mrg * on the low bit of uvmexp.pdrevs (which we bump by one each call).
828 1.1 mrg */
829 1.1 mrg
830 1.1 mrg got_it = FALSE;
831 1.1 mrg if ((uvmexp.pdrevs & 1) != 0 && uvmexp.nswapdev != 0)
832 1.1 mrg got_it = uvmpd_scan_inactive(&uvm.page_inactive_swp);
833 1.1 mrg if (!got_it)
834 1.1 mrg got_it = uvmpd_scan_inactive(&uvm.page_inactive_obj);
835 1.1 mrg if (!got_it && (uvmexp.pdrevs & 1) == 0 && uvmexp.nswapdev != 0)
836 1.1 mrg (void) uvmpd_scan_inactive(&uvm.page_inactive_swp);
837 1.1 mrg
838 1.1 mrg /*
839 1.1 mrg * we have done the scan to get free pages. now we work on meeting
840 1.1 mrg * our inactive target.
841 1.1 mrg */
842 1.1 mrg
843 1.1 mrg page_shortage = uvmexp.inactarg - uvmexp.inactive;
844 1.1 mrg pages_freed = uvmexp.pdfreed - pages_freed; /* # pages freed in loop */
845 1.1 mrg if (page_shortage <= 0 && pages_freed == 0)
846 1.1 mrg page_shortage = 1;
847 1.1 mrg
848 1.1 mrg UVMHIST_LOG(pdhist, " second loop: page_shortage=%d", page_shortage,0,0,0);
849 1.1 mrg for (p = uvm.page_active.tqh_first ;
850 1.1 mrg p != NULL && page_shortage > 0 ; p = nextpg) {
851 1.1 mrg
852 1.1 mrg nextpg = p->pageq.tqe_next;
853 1.1 mrg if (p->flags & PG_BUSY)
854 1.1 mrg continue; /* quick check before trying to lock */
855 1.1 mrg
856 1.1 mrg /*
857 1.1 mrg * lock owner
858 1.1 mrg */
859 1.1 mrg /* is page anon owned or ownerless? */
860 1.1 mrg if ((p->pqflags & PQ_ANON) || p->uobject == NULL) {
861 1.1 mrg
862 1.1 mrg #ifdef DIAGNOSTIC
863 1.1 mrg if (p->uanon == NULL)
864 1.1 mrg panic("pagedaemon: page with no anon or object detected - loop 2");
865 1.1 mrg #endif
866 1.1 mrg
867 1.1 mrg if (!simple_lock_try(&p->uanon->an_lock))
868 1.1 mrg continue;
869 1.1 mrg
870 1.1 mrg /* take over the page? */
871 1.1 mrg if ((p->pqflags & PQ_ANON) == 0) {
872 1.1 mrg
873 1.1 mrg #ifdef DIAGNOSTIC
874 1.1 mrg if (p->loan_count < 1)
875 1.1 mrg panic("pagedaemon: non-loaned ownerless page detected - loop 2");
876 1.1 mrg #endif
877 1.1 mrg
878 1.1 mrg p->loan_count--;
879 1.1 mrg p->pqflags |= PQ_ANON;
880 1.1 mrg }
881 1.1 mrg
882 1.1 mrg } else {
883 1.1 mrg
884 1.1 mrg if (!simple_lock_try(&p->uobject->vmobjlock))
885 1.1 mrg continue;
886 1.1 mrg
887 1.1 mrg }
888 1.1 mrg
889 1.1 mrg if ((p->flags & PG_BUSY) == 0) {
890 1.1 mrg pmap_page_protect(PMAP_PGARG(p), VM_PROT_NONE);
891 1.1 mrg /* no need to check wire_count as pg is "active" */
892 1.1 mrg uvm_pagedeactivate(p);
893 1.1 mrg uvmexp.pddeact++;
894 1.1 mrg page_shortage--;
895 1.1 mrg }
896 1.1 mrg
897 1.1 mrg if (p->pqflags & PQ_ANON)
898 1.1 mrg simple_unlock(&p->uanon->an_lock);
899 1.1 mrg else
900 1.1 mrg simple_unlock(&p->uobject->vmobjlock);
901 1.1 mrg }
902 1.1 mrg
903 1.1 mrg /*
904 1.1 mrg * done scan
905 1.1 mrg */
906 1.1 mrg }
907