1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://www.opensolaris.org/os/licensing. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 /* 22 * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 23 * Use is subject to license terms. 24 */ 25 26 /* Copyright (c) 1983, 1984, 1985, 1986, 1987, 1988, 1989 AT&T */ 27 /* All Rights Reserved */ 28 29 /* 30 * University Copyright- Copyright (c) 1982, 1986, 1988 31 * The Regents of the University of California 32 * All Rights Reserved 33 * 34 * University Acknowledgment- Portions of this document are derived from 35 * software developed by the University of California, Berkeley, and its 36 * contributors. 37 */ 38 39 /* 40 * VM - physical page management. 41 */ 42 43 #include <sys/types.h> 44 #include <sys/t_lock.h> 45 #include <sys/param.h> 46 #include <sys/systm.h> 47 #include <sys/errno.h> 48 #include <sys/time.h> 49 #include <sys/vnode.h> 50 #include <sys/vm.h> 51 #include <sys/vtrace.h> 52 #include <sys/swap.h> 53 #include <sys/cmn_err.h> 54 #include <sys/tuneable.h> 55 #include <sys/sysmacros.h> 56 #include <sys/cpuvar.h> 57 #include <sys/callb.h> 58 #include <sys/debug.h> 59 #include <sys/tnf_probe.h> 60 #include <sys/condvar_impl.h> 61 #include <sys/mem_config.h> 62 #include <sys/mem_cage.h> 63 #include <sys/kmem.h> 64 #include <sys/atomic.h> 65 #include <sys/strlog.h> 66 #include <sys/mman.h> 67 #include <sys/ontrap.h> 68 #include <sys/lgrp.h> 69 #include <sys/vfs.h> 70 71 #include <vm/hat.h> 72 #include <vm/anon.h> 73 #include <vm/page.h> 74 #include <vm/seg.h> 75 #include <vm/pvn.h> 76 #include <vm/seg_kmem.h> 77 #include <vm/vm_dep.h> 78 #include <sys/vm_usage.h> 79 #include <fs/fs_subr.h> 80 #include <sys/ddi.h> 81 #include <sys/modctl.h> 82 83 static int nopageage = 0; 84 85 static pgcnt_t max_page_get; /* max page_get request size in pages */ 86 pgcnt_t total_pages = 0; /* total number of pages (used by /proc) */ 87 88 /* 89 * freemem_lock protects all freemem variables: 90 * availrmem. Also this lock protects the globals which track the 91 * availrmem changes for accurate kernel footprint calculation. 92 * See below for an explanation of these 93 * globals. 94 */ 95 kmutex_t freemem_lock; 96 pgcnt_t availrmem; 97 pgcnt_t availrmem_initial; 98 99 /* 100 * These globals track availrmem changes to get a more accurate 101 * estimate of tke kernel size. Historically pp_kernel is used for 102 * kernel size and is based on availrmem. But availrmem is adjusted for 103 * locked pages in the system not just for kernel locked pages. 104 * These new counters will track the pages locked through segvn and 105 * by explicit user locking. 106 * 107 * pages_locked : How many pages are locked because of user specified 108 * locking through mlock or plock. 109 * 110 * pages_useclaim,pages_claimed : These two variables track the 111 * claim adjustments because of the protection changes on a segvn segment. 112 * 113 * All these globals are protected by the same lock which protects availrmem. 114 */ 115 pgcnt_t pages_locked = 0; 116 pgcnt_t pages_useclaim = 0; 117 pgcnt_t pages_claimed = 0; 118 119 120 /* 121 * new_freemem_lock protects freemem, freemem_wait & freemem_cv. 122 */ 123 static kmutex_t new_freemem_lock; 124 static uint_t freemem_wait; /* someone waiting for freemem */ 125 static kcondvar_t freemem_cv; 126 127 /* 128 * The logical page free list is maintained as two lists, the 'free' 129 * and the 'cache' lists. 130 * The free list contains those pages that should be reused first. 131 * 132 * The implementation of the lists is machine dependent. 133 * page_get_freelist(), page_get_cachelist(), 134 * page_list_sub(), and page_list_add() 135 * form the interface to the machine dependent implementation. 136 * 137 * Pages with p_free set are on the cache list. 138 * Pages with p_free and p_age set are on the free list, 139 * 140 * A page may be locked while on either list. 141 */ 142 143 /* 144 * free list accounting stuff. 145 * 146 * 147 * Spread out the value for the number of pages on the 148 * page free and page cache lists. If there is just one 149 * value, then it must be under just one lock. 150 * The lock contention and cache traffic are a real bother. 151 * 152 * When we acquire and then drop a single pcf lock 153 * we can start in the middle of the array of pcf structures. 154 * If we acquire more than one pcf lock at a time, we need to 155 * start at the front to avoid deadlocking. 156 * 157 * pcf_count holds the number of pages in each pool. 158 * 159 * pcf_block is set when page_create_get_something() has asked the 160 * PSM page freelist and page cachelist routines without specifying 161 * a color and nothing came back. This is used to block anything 162 * else from moving pages from one list to the other while the 163 * lists are searched again. If a page is freeed while pcf_block is 164 * set, then pcf_reserve is incremented. pcgs_unblock() takes care 165 * of clearning pcf_block, doing the wakeups, etc. 166 */ 167 168 #define MAX_PCF_FANOUT NCPU 169 static uint_t pcf_fanout = 1; /* Will get changed at boot time */ 170 static uint_t pcf_fanout_mask = 0; 171 172 struct pcf { 173 kmutex_t pcf_lock; /* protects the structure */ 174 uint_t pcf_count; /* page count */ 175 uint_t pcf_wait; /* number of waiters */ 176 uint_t pcf_block; /* pcgs flag to page_free() */ 177 uint_t pcf_reserve; /* pages freed after pcf_block set */ 178 uint_t pcf_fill[10]; /* to line up on the caches */ 179 }; 180 181 /* 182 * PCF_INDEX hash needs to be dynamic (every so often the hash changes where 183 * it will hash the cpu to). This is done to prevent a drain condition 184 * from happening. This drain condition will occur when pcf_count decrement 185 * occurs on cpu A and the increment of pcf_count always occurs on cpu B. An 186 * example of this shows up with device interrupts. The dma buffer is allocated 187 * by the cpu requesting the IO thus the pcf_count is decremented based on that. 188 * When the memory is returned by the interrupt thread, the pcf_count will be 189 * incremented based on the cpu servicing the interrupt. 190 */ 191 static struct pcf pcf[MAX_PCF_FANOUT]; 192 #define PCF_INDEX() ((int)(((long)CPU->cpu_seqid) + \ 193 (randtick() >> 24)) & (pcf_fanout_mask)) 194 195 static int pcf_decrement_bucket(pgcnt_t); 196 static int pcf_decrement_multiple(pgcnt_t *, pgcnt_t, int); 197 198 kmutex_t pcgs_lock; /* serializes page_create_get_ */ 199 kmutex_t pcgs_cagelock; /* serializes NOSLEEP cage allocs */ 200 kmutex_t pcgs_wait_lock; /* used for delay in pcgs */ 201 static kcondvar_t pcgs_cv; /* cv for delay in pcgs */ 202 203 #ifdef VM_STATS 204 205 /* 206 * No locks, but so what, they are only statistics. 207 */ 208 209 static struct page_tcnt { 210 int pc_free_cache; /* free's into cache list */ 211 int pc_free_dontneed; /* free's with dontneed */ 212 int pc_free_pageout; /* free's from pageout */ 213 int pc_free_free; /* free's into free list */ 214 int pc_free_pages; /* free's into large page free list */ 215 int pc_destroy_pages; /* large page destroy's */ 216 int pc_get_cache; /* get's from cache list */ 217 int pc_get_free; /* get's from free list */ 218 int pc_reclaim; /* reclaim's */ 219 int pc_abortfree; /* abort's of free pages */ 220 int pc_find_hit; /* find's that find page */ 221 int pc_find_miss; /* find's that don't find page */ 222 int pc_destroy_free; /* # of free pages destroyed */ 223 #define PC_HASH_CNT (4*PAGE_HASHAVELEN) 224 int pc_find_hashlen[PC_HASH_CNT+1]; 225 int pc_addclaim_pages; 226 int pc_subclaim_pages; 227 int pc_free_replacement_page[2]; 228 int pc_try_demote_pages[6]; 229 int pc_demote_pages[2]; 230 } pagecnt; 231 232 uint_t hashin_count; 233 uint_t hashin_not_held; 234 uint_t hashin_already; 235 236 uint_t hashout_count; 237 uint_t hashout_not_held; 238 239 uint_t page_create_count; 240 uint_t page_create_not_enough; 241 uint_t page_create_not_enough_again; 242 uint_t page_create_zero; 243 uint_t page_create_hashout; 244 uint_t page_create_page_lock_failed; 245 uint_t page_create_trylock_failed; 246 uint_t page_create_found_one; 247 uint_t page_create_hashin_failed; 248 uint_t page_create_dropped_phm; 249 250 uint_t page_create_new; 251 uint_t page_create_exists; 252 uint_t page_create_putbacks; 253 uint_t page_create_overshoot; 254 255 uint_t page_reclaim_zero; 256 uint_t page_reclaim_zero_locked; 257 258 uint_t page_rename_exists; 259 uint_t page_rename_count; 260 261 uint_t page_lookup_cnt[20]; 262 uint_t page_lookup_nowait_cnt[10]; 263 uint_t page_find_cnt; 264 uint_t page_exists_cnt; 265 uint_t page_exists_forreal_cnt; 266 uint_t page_lookup_dev_cnt; 267 uint_t get_cachelist_cnt; 268 uint_t page_create_cnt[10]; 269 uint_t alloc_pages[9]; 270 uint_t page_exphcontg[19]; 271 uint_t page_create_large_cnt[10]; 272 273 /* 274 * Collects statistics. 275 */ 276 #define PAGE_HASH_SEARCH(index, pp, vp, off) { \ 277 uint_t mylen = 0; \ 278 \ 279 for ((pp) = page_hash[(index)]; (pp); (pp) = (pp)->p_hash, mylen++) { \ 280 if ((pp)->p_vnode == (vp) && (pp)->p_offset == (off)) \ 281 break; \ 282 } \ 283 if ((pp) != NULL) \ 284 pagecnt.pc_find_hit++; \ 285 else \ 286 pagecnt.pc_find_miss++; \ 287 if (mylen > PC_HASH_CNT) \ 288 mylen = PC_HASH_CNT; \ 289 pagecnt.pc_find_hashlen[mylen]++; \ 290 } 291 292 #else /* VM_STATS */ 293 294 /* 295 * Don't collect statistics 296 */ 297 #define PAGE_HASH_SEARCH(index, pp, vp, off) { \ 298 for ((pp) = page_hash[(index)]; (pp); (pp) = (pp)->p_hash) { \ 299 if ((pp)->p_vnode == (vp) && (pp)->p_offset == (off)) \ 300 break; \ 301 } \ 302 } 303 304 #endif /* VM_STATS */ 305 306 307 308 #ifdef DEBUG 309 #define MEMSEG_SEARCH_STATS 310 #endif 311 312 #ifdef MEMSEG_SEARCH_STATS 313 struct memseg_stats { 314 uint_t nsearch; 315 uint_t nlastwon; 316 uint_t nhashwon; 317 uint_t nnotfound; 318 } memseg_stats; 319 320 #define MEMSEG_STAT_INCR(v) \ 321 atomic_add_32(&memseg_stats.v, 1) 322 #else 323 #define MEMSEG_STAT_INCR(x) 324 #endif 325 326 struct memseg *memsegs; /* list of memory segments */ 327 328 /* 329 * /etc/system tunable to control large page allocation hueristic. 330 * 331 * Setting to LPAP_LOCAL will heavily prefer the local lgroup over remote lgroup 332 * for large page allocation requests. If a large page is not readily 333 * avaliable on the local freelists we will go through additional effort 334 * to create a large page, potentially moving smaller pages around to coalesce 335 * larger pages in the local lgroup. 336 * Default value of LPAP_DEFAULT will go to remote freelists if large pages 337 * are not readily available in the local lgroup. 338 */ 339 enum lpap { 340 LPAP_DEFAULT, /* default large page allocation policy */ 341 LPAP_LOCAL /* local large page allocation policy */ 342 }; 343 344 enum lpap lpg_alloc_prefer = LPAP_DEFAULT; 345 346 static void page_init_mem_config(void); 347 static int page_do_hashin(page_t *, vnode_t *, u_offset_t); 348 static void page_do_hashout(page_t *); 349 static void page_capture_init(); 350 int page_capture_take_action(page_t *, uint_t, void *); 351 352 static void page_demote_vp_pages(page_t *); 353 354 355 void 356 pcf_init(void) 357 358 { 359 if (boot_ncpus != -1) { 360 pcf_fanout = boot_ncpus; 361 } else { 362 pcf_fanout = max_ncpus; 363 } 364 #ifdef sun4v 365 /* 366 * Force at least 4 buckets if possible for sun4v. 367 */ 368 pcf_fanout = MAX(pcf_fanout, 4); 369 #endif /* sun4v */ 370 371 /* 372 * Round up to the nearest power of 2. 373 */ 374 pcf_fanout = MIN(pcf_fanout, MAX_PCF_FANOUT); 375 if (!ISP2(pcf_fanout)) { 376 pcf_fanout = 1 << highbit(pcf_fanout); 377 378 if (pcf_fanout > MAX_PCF_FANOUT) { 379 pcf_fanout = 1 << (highbit(MAX_PCF_FANOUT) - 1); 380 } 381 } 382 pcf_fanout_mask = pcf_fanout - 1; 383 } 384 385 /* 386 * vm subsystem related initialization 387 */ 388 void 389 vm_init(void) 390 { 391 boolean_t callb_vm_cpr(void *, int); 392 393 (void) callb_add(callb_vm_cpr, 0, CB_CL_CPR_VM, "vm"); 394 page_init_mem_config(); 395 page_retire_init(); 396 vm_usage_init(); 397 page_capture_init(); 398 } 399 400 /* 401 * This function is called at startup and when memory is added or deleted. 402 */ 403 void 404 init_pages_pp_maximum() 405 { 406 static pgcnt_t p_min; 407 static pgcnt_t pages_pp_maximum_startup; 408 static pgcnt_t avrmem_delta; 409 static int init_done; 410 static int user_set; /* true if set in /etc/system */ 411 412 if (init_done == 0) { 413 414 /* If the user specified a value, save it */ 415 if (pages_pp_maximum != 0) { 416 user_set = 1; 417 pages_pp_maximum_startup = pages_pp_maximum; 418 } 419 420 /* 421 * Setting of pages_pp_maximum is based first time 422 * on the value of availrmem just after the start-up 423 * allocations. To preserve this relationship at run 424 * time, use a delta from availrmem_initial. 425 */ 426 ASSERT(availrmem_initial >= availrmem); 427 avrmem_delta = availrmem_initial - availrmem; 428 429 /* The allowable floor of pages_pp_maximum */ 430 p_min = tune.t_minarmem + 100; 431 432 /* Make sure we don't come through here again. */ 433 init_done = 1; 434 } 435 /* 436 * Determine pages_pp_maximum, the number of currently available 437 * pages (availrmem) that can't be `locked'. If not set by 438 * the user, we set it to 4% of the currently available memory 439 * plus 4MB. 440 * But we also insist that it be greater than tune.t_minarmem; 441 * otherwise a process could lock down a lot of memory, get swapped 442 * out, and never have enough to get swapped back in. 443 */ 444 if (user_set) 445 pages_pp_maximum = pages_pp_maximum_startup; 446 else 447 pages_pp_maximum = ((availrmem_initial - avrmem_delta) / 25) 448 + btop(4 * 1024 * 1024); 449 450 if (pages_pp_maximum <= p_min) { 451 pages_pp_maximum = p_min; 452 } 453 } 454 455 void 456 set_max_page_get(pgcnt_t target_total_pages) 457 { 458 max_page_get = target_total_pages / 2; 459 } 460 461 static pgcnt_t pending_delete; 462 463 /*ARGSUSED*/ 464 static void 465 page_mem_config_post_add( 466 void *arg, 467 pgcnt_t delta_pages) 468 { 469 set_max_page_get(total_pages - pending_delete); 470 init_pages_pp_maximum(); 471 } 472 473 /*ARGSUSED*/ 474 static int 475 page_mem_config_pre_del( 476 void *arg, 477 pgcnt_t delta_pages) 478 { 479 pgcnt_t nv; 480 481 nv = atomic_add_long_nv(&pending_delete, (spgcnt_t)delta_pages); 482 set_max_page_get(total_pages - nv); 483 return (0); 484 } 485 486 /*ARGSUSED*/ 487 static void 488 page_mem_config_post_del( 489 void *arg, 490 pgcnt_t delta_pages, 491 int cancelled) 492 { 493 pgcnt_t nv; 494 495 nv = atomic_add_long_nv(&pending_delete, -(spgcnt_t)delta_pages); 496 set_max_page_get(total_pages - nv); 497 if (!cancelled) 498 init_pages_pp_maximum(); 499 } 500 501 static kphysm_setup_vector_t page_mem_config_vec = { 502 KPHYSM_SETUP_VECTOR_VERSION, 503 page_mem_config_post_add, 504 page_mem_config_pre_del, 505 page_mem_config_post_del, 506 }; 507 508 static void 509 page_init_mem_config(void) 510 { 511 int ret; 512 513 ret = kphysm_setup_func_register(&page_mem_config_vec, (void *)NULL); 514 ASSERT(ret == 0); 515 } 516 517 /* 518 * Evenly spread out the PCF counters for large free pages 519 */ 520 static void 521 page_free_large_ctr(pgcnt_t npages) 522 { 523 static struct pcf *p = pcf; 524 pgcnt_t lump; 525 526 freemem += npages; 527 528 lump = roundup(npages, pcf_fanout) / pcf_fanout; 529 530 while (npages > 0) { 531 532 ASSERT(!p->pcf_block); 533 534 if (lump < npages) { 535 p->pcf_count += (uint_t)lump; 536 npages -= lump; 537 } else { 538 p->pcf_count += (uint_t)npages; 539 npages = 0; 540 } 541 542 ASSERT(!p->pcf_wait); 543 544 if (++p > &pcf[pcf_fanout - 1]) 545 p = pcf; 546 } 547 548 ASSERT(npages == 0); 549 } 550 551 /* 552 * Add a physical chunk of memory to the system free lists during startup. 553 * Platform specific startup() allocates the memory for the page structs. 554 * 555 * num - number of page structures 556 * base - page number (pfn) to be associated with the first page. 557 * 558 * Since we are doing this during startup (ie. single threaded), we will 559 * use shortcut routines to avoid any locking overhead while putting all 560 * these pages on the freelists. 561 * 562 * NOTE: Any changes performed to page_free(), must also be performed to 563 * add_physmem() since this is how we initialize all page_t's at 564 * boot time. 565 */ 566 void 567 add_physmem( 568 page_t *pp, 569 pgcnt_t num, 570 pfn_t pnum) 571 { 572 page_t *root = NULL; 573 uint_t szc = page_num_pagesizes() - 1; 574 pgcnt_t large = page_get_pagecnt(szc); 575 pgcnt_t cnt = 0; 576 577 TRACE_2(TR_FAC_VM, TR_PAGE_INIT, 578 "add_physmem:pp %p num %lu", pp, num); 579 580 /* 581 * Arbitrarily limit the max page_get request 582 * to 1/2 of the page structs we have. 583 */ 584 total_pages += num; 585 set_max_page_get(total_pages); 586 587 PLCNT_MODIFY_MAX(pnum, (long)num); 588 589 /* 590 * The physical space for the pages array 591 * representing ram pages has already been 592 * allocated. Here we initialize each lock 593 * in the page structure, and put each on 594 * the free list 595 */ 596 for (; num; pp++, pnum++, num--) { 597 598 /* 599 * this needs to fill in the page number 600 * and do any other arch specific initialization 601 */ 602 add_physmem_cb(pp, pnum); 603 604 pp->p_lckcnt = 0; 605 pp->p_cowcnt = 0; 606 pp->p_slckcnt = 0; 607 608 /* 609 * Initialize the page lock as unlocked, since nobody 610 * can see or access this page yet. 611 */ 612 pp->p_selock = 0; 613 614 /* 615 * Initialize IO lock 616 */ 617 page_iolock_init(pp); 618 619 /* 620 * initialize other fields in the page_t 621 */ 622 PP_SETFREE(pp); 623 page_clr_all_props(pp, 0); 624 PP_SETAGED(pp); 625 pp->p_offset = (u_offset_t)-1; 626 pp->p_next = pp; 627 pp->p_prev = pp; 628 629 /* 630 * Simple case: System doesn't support large pages. 631 */ 632 if (szc == 0) { 633 pp->p_szc = 0; 634 page_free_at_startup(pp); 635 continue; 636 } 637 638 /* 639 * Handle unaligned pages, we collect them up onto 640 * the root page until we have a full large page. 641 */ 642 if (!IS_P2ALIGNED(pnum, large)) { 643 644 /* 645 * If not in a large page, 646 * just free as small page. 647 */ 648 if (root == NULL) { 649 pp->p_szc = 0; 650 page_free_at_startup(pp); 651 continue; 652 } 653 654 /* 655 * Link a constituent page into the large page. 656 */ 657 pp->p_szc = szc; 658 page_list_concat(&root, &pp); 659 660 /* 661 * When large page is fully formed, free it. 662 */ 663 if (++cnt == large) { 664 page_free_large_ctr(cnt); 665 page_list_add_pages(root, PG_LIST_ISINIT); 666 root = NULL; 667 cnt = 0; 668 } 669 continue; 670 } 671 672 /* 673 * At this point we have a page number which 674 * is aligned. We assert that we aren't already 675 * in a different large page. 676 */ 677 ASSERT(IS_P2ALIGNED(pnum, large)); 678 ASSERT(root == NULL && cnt == 0); 679 680 /* 681 * If insufficient number of pages left to form 682 * a large page, just free the small page. 683 */ 684 if (num < large) { 685 pp->p_szc = 0; 686 page_free_at_startup(pp); 687 continue; 688 } 689 690 /* 691 * Otherwise start a new large page. 692 */ 693 pp->p_szc = szc; 694 cnt++; 695 root = pp; 696 } 697 ASSERT(root == NULL && cnt == 0); 698 } 699 700 /* 701 * Find a page representing the specified [vp, offset]. 702 * If we find the page but it is intransit coming in, 703 * it will have an "exclusive" lock and we wait for 704 * the i/o to complete. A page found on the free list 705 * is always reclaimed and then locked. On success, the page 706 * is locked, its data is valid and it isn't on the free 707 * list, while a NULL is returned if the page doesn't exist. 708 */ 709 page_t * 710 page_lookup(vnode_t *vp, u_offset_t off, se_t se) 711 { 712 return (page_lookup_create(vp, off, se, NULL, NULL, 0)); 713 } 714 715 /* 716 * Find a page representing the specified [vp, offset]. 717 * We either return the one we found or, if passed in, 718 * create one with identity of [vp, offset] of the 719 * pre-allocated page. If we find existing page but it is 720 * intransit coming in, it will have an "exclusive" lock 721 * and we wait for the i/o to complete. A page found on 722 * the free list is always reclaimed and then locked. 723 * On success, the page is locked, its data is valid and 724 * it isn't on the free list, while a NULL is returned 725 * if the page doesn't exist and newpp is NULL; 726 */ 727 page_t * 728 page_lookup_create( 729 vnode_t *vp, 730 u_offset_t off, 731 se_t se, 732 page_t *newpp, 733 spgcnt_t *nrelocp, 734 int flags) 735 { 736 page_t *pp; 737 kmutex_t *phm; 738 ulong_t index; 739 uint_t hash_locked; 740 uint_t es; 741 742 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 743 VM_STAT_ADD(page_lookup_cnt[0]); 744 ASSERT(newpp ? PAGE_EXCL(newpp) : 1); 745 746 /* 747 * Acquire the appropriate page hash lock since 748 * we have to search the hash list. Pages that 749 * hash to this list can't change identity while 750 * this lock is held. 751 */ 752 hash_locked = 0; 753 index = PAGE_HASH_FUNC(vp, off); 754 phm = NULL; 755 top: 756 PAGE_HASH_SEARCH(index, pp, vp, off); 757 if (pp != NULL) { 758 VM_STAT_ADD(page_lookup_cnt[1]); 759 es = (newpp != NULL) ? 1 : 0; 760 es |= flags; 761 if (!hash_locked) { 762 VM_STAT_ADD(page_lookup_cnt[2]); 763 if (!page_try_reclaim_lock(pp, se, es)) { 764 /* 765 * On a miss, acquire the phm. Then 766 * next time, page_lock() will be called, 767 * causing a wait if the page is busy. 768 * just looping with page_trylock() would 769 * get pretty boring. 770 */ 771 VM_STAT_ADD(page_lookup_cnt[3]); 772 phm = PAGE_HASH_MUTEX(index); 773 mutex_enter(phm); 774 hash_locked = 1; 775 goto top; 776 } 777 } else { 778 VM_STAT_ADD(page_lookup_cnt[4]); 779 if (!page_lock_es(pp, se, phm, P_RECLAIM, es)) { 780 VM_STAT_ADD(page_lookup_cnt[5]); 781 goto top; 782 } 783 } 784 785 /* 786 * Since `pp' is locked it can not change identity now. 787 * Reconfirm we locked the correct page. 788 * 789 * Both the p_vnode and p_offset *must* be cast volatile 790 * to force a reload of their values: The PAGE_HASH_SEARCH 791 * macro will have stuffed p_vnode and p_offset into 792 * registers before calling page_trylock(); another thread, 793 * actually holding the hash lock, could have changed the 794 * page's identity in memory, but our registers would not 795 * be changed, fooling the reconfirmation. If the hash 796 * lock was held during the search, the casting would 797 * not be needed. 798 */ 799 VM_STAT_ADD(page_lookup_cnt[6]); 800 if (((volatile struct vnode *)(pp->p_vnode) != vp) || 801 ((volatile u_offset_t)(pp->p_offset) != off)) { 802 VM_STAT_ADD(page_lookup_cnt[7]); 803 if (hash_locked) { 804 panic("page_lookup_create: lost page %p", 805 (void *)pp); 806 /*NOTREACHED*/ 807 } 808 page_unlock(pp); 809 phm = PAGE_HASH_MUTEX(index); 810 mutex_enter(phm); 811 hash_locked = 1; 812 goto top; 813 } 814 815 /* 816 * If page_trylock() was called, then pp may still be on 817 * the cachelist (can't be on the free list, it would not 818 * have been found in the search). If it is on the 819 * cachelist it must be pulled now. To pull the page from 820 * the cachelist, it must be exclusively locked. 821 * 822 * The other big difference between page_trylock() and 823 * page_lock(), is that page_lock() will pull the 824 * page from whatever free list (the cache list in this 825 * case) the page is on. If page_trylock() was used 826 * above, then we have to do the reclaim ourselves. 827 */ 828 if ((!hash_locked) && (PP_ISFREE(pp))) { 829 ASSERT(PP_ISAGED(pp) == 0); 830 VM_STAT_ADD(page_lookup_cnt[8]); 831 832 /* 833 * page_relcaim will insure that we 834 * have this page exclusively 835 */ 836 837 if (!page_reclaim(pp, NULL)) { 838 /* 839 * Page_reclaim dropped whatever lock 840 * we held. 841 */ 842 VM_STAT_ADD(page_lookup_cnt[9]); 843 phm = PAGE_HASH_MUTEX(index); 844 mutex_enter(phm); 845 hash_locked = 1; 846 goto top; 847 } else if (se == SE_SHARED && newpp == NULL) { 848 VM_STAT_ADD(page_lookup_cnt[10]); 849 page_downgrade(pp); 850 } 851 } 852 853 if (hash_locked) { 854 mutex_exit(phm); 855 } 856 857 if (newpp != NULL && pp->p_szc < newpp->p_szc && 858 PAGE_EXCL(pp) && nrelocp != NULL) { 859 ASSERT(nrelocp != NULL); 860 (void) page_relocate(&pp, &newpp, 1, 1, nrelocp, 861 NULL); 862 if (*nrelocp > 0) { 863 VM_STAT_COND_ADD(*nrelocp == 1, 864 page_lookup_cnt[11]); 865 VM_STAT_COND_ADD(*nrelocp > 1, 866 page_lookup_cnt[12]); 867 pp = newpp; 868 se = SE_EXCL; 869 } else { 870 if (se == SE_SHARED) { 871 page_downgrade(pp); 872 } 873 VM_STAT_ADD(page_lookup_cnt[13]); 874 } 875 } else if (newpp != NULL && nrelocp != NULL) { 876 if (PAGE_EXCL(pp) && se == SE_SHARED) { 877 page_downgrade(pp); 878 } 879 VM_STAT_COND_ADD(pp->p_szc < newpp->p_szc, 880 page_lookup_cnt[14]); 881 VM_STAT_COND_ADD(pp->p_szc == newpp->p_szc, 882 page_lookup_cnt[15]); 883 VM_STAT_COND_ADD(pp->p_szc > newpp->p_szc, 884 page_lookup_cnt[16]); 885 } else if (newpp != NULL && PAGE_EXCL(pp)) { 886 se = SE_EXCL; 887 } 888 } else if (!hash_locked) { 889 VM_STAT_ADD(page_lookup_cnt[17]); 890 phm = PAGE_HASH_MUTEX(index); 891 mutex_enter(phm); 892 hash_locked = 1; 893 goto top; 894 } else if (newpp != NULL) { 895 /* 896 * If we have a preallocated page then 897 * insert it now and basically behave like 898 * page_create. 899 */ 900 VM_STAT_ADD(page_lookup_cnt[18]); 901 /* 902 * Since we hold the page hash mutex and 903 * just searched for this page, page_hashin 904 * had better not fail. If it does, that 905 * means some thread did not follow the 906 * page hash mutex rules. Panic now and 907 * get it over with. As usual, go down 908 * holding all the locks. 909 */ 910 ASSERT(MUTEX_HELD(phm)); 911 if (!page_hashin(newpp, vp, off, phm)) { 912 ASSERT(MUTEX_HELD(phm)); 913 panic("page_lookup_create: hashin failed %p %p %llx %p", 914 (void *)newpp, (void *)vp, off, (void *)phm); 915 /*NOTREACHED*/ 916 } 917 ASSERT(MUTEX_HELD(phm)); 918 mutex_exit(phm); 919 phm = NULL; 920 page_set_props(newpp, P_REF); 921 page_io_lock(newpp); 922 pp = newpp; 923 se = SE_EXCL; 924 } else { 925 VM_STAT_ADD(page_lookup_cnt[19]); 926 mutex_exit(phm); 927 } 928 929 ASSERT(pp ? PAGE_LOCKED_SE(pp, se) : 1); 930 931 ASSERT(pp ? ((PP_ISFREE(pp) == 0) && (PP_ISAGED(pp) == 0)) : 1); 932 933 return (pp); 934 } 935 936 /* 937 * Search the hash list for the page representing the 938 * specified [vp, offset] and return it locked. Skip 939 * free pages and pages that cannot be locked as requested. 940 * Used while attempting to kluster pages. 941 */ 942 page_t * 943 page_lookup_nowait(vnode_t *vp, u_offset_t off, se_t se) 944 { 945 page_t *pp; 946 kmutex_t *phm; 947 ulong_t index; 948 uint_t locked; 949 950 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 951 VM_STAT_ADD(page_lookup_nowait_cnt[0]); 952 953 index = PAGE_HASH_FUNC(vp, off); 954 PAGE_HASH_SEARCH(index, pp, vp, off); 955 locked = 0; 956 if (pp == NULL) { 957 top: 958 VM_STAT_ADD(page_lookup_nowait_cnt[1]); 959 locked = 1; 960 phm = PAGE_HASH_MUTEX(index); 961 mutex_enter(phm); 962 PAGE_HASH_SEARCH(index, pp, vp, off); 963 } 964 965 if (pp == NULL || PP_ISFREE(pp)) { 966 VM_STAT_ADD(page_lookup_nowait_cnt[2]); 967 pp = NULL; 968 } else { 969 if (!page_trylock(pp, se)) { 970 VM_STAT_ADD(page_lookup_nowait_cnt[3]); 971 pp = NULL; 972 } else { 973 VM_STAT_ADD(page_lookup_nowait_cnt[4]); 974 /* 975 * See the comment in page_lookup() 976 */ 977 if (((volatile struct vnode *)(pp->p_vnode) != vp) || 978 ((u_offset_t)(pp->p_offset) != off)) { 979 VM_STAT_ADD(page_lookup_nowait_cnt[5]); 980 if (locked) { 981 panic("page_lookup_nowait %p", 982 (void *)pp); 983 /*NOTREACHED*/ 984 } 985 page_unlock(pp); 986 goto top; 987 } 988 if (PP_ISFREE(pp)) { 989 VM_STAT_ADD(page_lookup_nowait_cnt[6]); 990 page_unlock(pp); 991 pp = NULL; 992 } 993 } 994 } 995 if (locked) { 996 VM_STAT_ADD(page_lookup_nowait_cnt[7]); 997 mutex_exit(phm); 998 } 999 1000 ASSERT(pp ? PAGE_LOCKED_SE(pp, se) : 1); 1001 1002 return (pp); 1003 } 1004 1005 /* 1006 * Search the hash list for a page with the specified [vp, off] 1007 * that is known to exist and is already locked. This routine 1008 * is typically used by segment SOFTUNLOCK routines. 1009 */ 1010 page_t * 1011 page_find(vnode_t *vp, u_offset_t off) 1012 { 1013 page_t *pp; 1014 kmutex_t *phm; 1015 ulong_t index; 1016 1017 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 1018 VM_STAT_ADD(page_find_cnt); 1019 1020 index = PAGE_HASH_FUNC(vp, off); 1021 phm = PAGE_HASH_MUTEX(index); 1022 1023 mutex_enter(phm); 1024 PAGE_HASH_SEARCH(index, pp, vp, off); 1025 mutex_exit(phm); 1026 1027 ASSERT(pp == NULL || PAGE_LOCKED(pp) || panicstr); 1028 return (pp); 1029 } 1030 1031 /* 1032 * Determine whether a page with the specified [vp, off] 1033 * currently exists in the system. Obviously this should 1034 * only be considered as a hint since nothing prevents the 1035 * page from disappearing or appearing immediately after 1036 * the return from this routine. Subsequently, we don't 1037 * even bother to lock the list. 1038 */ 1039 page_t * 1040 page_exists(vnode_t *vp, u_offset_t off) 1041 { 1042 page_t *pp; 1043 ulong_t index; 1044 1045 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 1046 VM_STAT_ADD(page_exists_cnt); 1047 1048 index = PAGE_HASH_FUNC(vp, off); 1049 PAGE_HASH_SEARCH(index, pp, vp, off); 1050 1051 return (pp); 1052 } 1053 1054 /* 1055 * Determine if physically contiguous pages exist for [vp, off] - [vp, off + 1056 * page_size(szc)) range. if they exist and ppa is not NULL fill ppa array 1057 * with these pages locked SHARED. If necessary reclaim pages from 1058 * freelist. Return 1 if contiguous pages exist and 0 otherwise. 1059 * 1060 * If we fail to lock pages still return 1 if pages exist and contiguous. 1061 * But in this case return value is just a hint. ppa array won't be filled. 1062 * Caller should initialize ppa[0] as NULL to distinguish return value. 1063 * 1064 * Returns 0 if pages don't exist or not physically contiguous. 1065 * 1066 * This routine doesn't work for anonymous(swapfs) pages. 1067 */ 1068 int 1069 page_exists_physcontig(vnode_t *vp, u_offset_t off, uint_t szc, page_t *ppa[]) 1070 { 1071 pgcnt_t pages; 1072 pfn_t pfn; 1073 page_t *rootpp; 1074 pgcnt_t i; 1075 pgcnt_t j; 1076 u_offset_t save_off = off; 1077 ulong_t index; 1078 kmutex_t *phm; 1079 page_t *pp; 1080 uint_t pszc; 1081 int loopcnt = 0; 1082 1083 ASSERT(szc != 0); 1084 ASSERT(vp != NULL); 1085 ASSERT(!IS_SWAPFSVP(vp)); 1086 ASSERT(!VN_ISKAS(vp)); 1087 1088 again: 1089 if (++loopcnt > 3) { 1090 VM_STAT_ADD(page_exphcontg[0]); 1091 return (0); 1092 } 1093 1094 index = PAGE_HASH_FUNC(vp, off); 1095 phm = PAGE_HASH_MUTEX(index); 1096 1097 mutex_enter(phm); 1098 PAGE_HASH_SEARCH(index, pp, vp, off); 1099 mutex_exit(phm); 1100 1101 VM_STAT_ADD(page_exphcontg[1]); 1102 1103 if (pp == NULL) { 1104 VM_STAT_ADD(page_exphcontg[2]); 1105 return (0); 1106 } 1107 1108 pages = page_get_pagecnt(szc); 1109 rootpp = pp; 1110 pfn = rootpp->p_pagenum; 1111 1112 if ((pszc = pp->p_szc) >= szc && ppa != NULL) { 1113 VM_STAT_ADD(page_exphcontg[3]); 1114 if (!page_trylock(pp, SE_SHARED)) { 1115 VM_STAT_ADD(page_exphcontg[4]); 1116 return (1); 1117 } 1118 if (pp->p_szc != pszc || pp->p_vnode != vp || 1119 pp->p_offset != off) { 1120 VM_STAT_ADD(page_exphcontg[5]); 1121 page_unlock(pp); 1122 off = save_off; 1123 goto again; 1124 } 1125 /* 1126 * szc was non zero and vnode and offset matched after we 1127 * locked the page it means it can't become free on us. 1128 */ 1129 ASSERT(!PP_ISFREE(pp)); 1130 if (!IS_P2ALIGNED(pfn, pages)) { 1131 page_unlock(pp); 1132 return (0); 1133 } 1134 ppa[0] = pp; 1135 pp++; 1136 off += PAGESIZE; 1137 pfn++; 1138 for (i = 1; i < pages; i++, pp++, off += PAGESIZE, pfn++) { 1139 if (!page_trylock(pp, SE_SHARED)) { 1140 VM_STAT_ADD(page_exphcontg[6]); 1141 pp--; 1142 while (i-- > 0) { 1143 page_unlock(pp); 1144 pp--; 1145 } 1146 ppa[0] = NULL; 1147 return (1); 1148 } 1149 if (pp->p_szc != pszc) { 1150 VM_STAT_ADD(page_exphcontg[7]); 1151 page_unlock(pp); 1152 pp--; 1153 while (i-- > 0) { 1154 page_unlock(pp); 1155 pp--; 1156 } 1157 ppa[0] = NULL; 1158 off = save_off; 1159 goto again; 1160 } 1161 /* 1162 * szc the same as for previous already locked pages 1163 * with right identity. Since this page had correct 1164 * szc after we locked it can't get freed or destroyed 1165 * and therefore must have the expected identity. 1166 */ 1167 ASSERT(!PP_ISFREE(pp)); 1168 if (pp->p_vnode != vp || 1169 pp->p_offset != off) { 1170 panic("page_exists_physcontig: " 1171 "large page identity doesn't match"); 1172 } 1173 ppa[i] = pp; 1174 ASSERT(pp->p_pagenum == pfn); 1175 } 1176 VM_STAT_ADD(page_exphcontg[8]); 1177 ppa[pages] = NULL; 1178 return (1); 1179 } else if (pszc >= szc) { 1180 VM_STAT_ADD(page_exphcontg[9]); 1181 if (!IS_P2ALIGNED(pfn, pages)) { 1182 return (0); 1183 } 1184 return (1); 1185 } 1186 1187 if (!IS_P2ALIGNED(pfn, pages)) { 1188 VM_STAT_ADD(page_exphcontg[10]); 1189 return (0); 1190 } 1191 1192 if (page_numtomemseg_nolock(pfn) != 1193 page_numtomemseg_nolock(pfn + pages - 1)) { 1194 VM_STAT_ADD(page_exphcontg[11]); 1195 return (0); 1196 } 1197 1198 /* 1199 * We loop up 4 times across pages to promote page size. 1200 * We're extra cautious to promote page size atomically with respect 1201 * to everybody else. But we can probably optimize into 1 loop if 1202 * this becomes an issue. 1203 */ 1204 1205 for (i = 0; i < pages; i++, pp++, off += PAGESIZE, pfn++) { 1206 ASSERT(pp->p_pagenum == pfn); 1207 if (!page_trylock(pp, SE_EXCL)) { 1208 VM_STAT_ADD(page_exphcontg[12]); 1209 break; 1210 } 1211 if (pp->p_vnode != vp || 1212 pp->p_offset != off) { 1213 VM_STAT_ADD(page_exphcontg[13]); 1214 page_unlock(pp); 1215 break; 1216 } 1217 if (pp->p_szc >= szc) { 1218 ASSERT(i == 0); 1219 page_unlock(pp); 1220 off = save_off; 1221 goto again; 1222 } 1223 } 1224 1225 if (i != pages) { 1226 VM_STAT_ADD(page_exphcontg[14]); 1227 --pp; 1228 while (i-- > 0) { 1229 page_unlock(pp); 1230 --pp; 1231 } 1232 return (0); 1233 } 1234 1235 pp = rootpp; 1236 for (i = 0; i < pages; i++, pp++) { 1237 if (PP_ISFREE(pp)) { 1238 VM_STAT_ADD(page_exphcontg[15]); 1239 ASSERT(!PP_ISAGED(pp)); 1240 ASSERT(pp->p_szc == 0); 1241 if (!page_reclaim(pp, NULL)) { 1242 break; 1243 } 1244 } else { 1245 ASSERT(pp->p_szc < szc); 1246 VM_STAT_ADD(page_exphcontg[16]); 1247 (void) hat_pageunload(pp, HAT_FORCE_PGUNLOAD); 1248 } 1249 } 1250 if (i < pages) { 1251 VM_STAT_ADD(page_exphcontg[17]); 1252 /* 1253 * page_reclaim failed because we were out of memory. 1254 * drop the rest of the locks and return because this page 1255 * must be already reallocated anyway. 1256 */ 1257 pp = rootpp; 1258 for (j = 0; j < pages; j++, pp++) { 1259 if (j != i) { 1260 page_unlock(pp); 1261 } 1262 } 1263 return (0); 1264 } 1265 1266 off = save_off; 1267 pp = rootpp; 1268 for (i = 0; i < pages; i++, pp++, off += PAGESIZE) { 1269 ASSERT(PAGE_EXCL(pp)); 1270 ASSERT(!PP_ISFREE(pp)); 1271 ASSERT(!hat_page_is_mapped(pp)); 1272 ASSERT(pp->p_vnode == vp); 1273 ASSERT(pp->p_offset == off); 1274 pp->p_szc = szc; 1275 } 1276 pp = rootpp; 1277 for (i = 0; i < pages; i++, pp++) { 1278 if (ppa == NULL) { 1279 page_unlock(pp); 1280 } else { 1281 ppa[i] = pp; 1282 page_downgrade(ppa[i]); 1283 } 1284 } 1285 if (ppa != NULL) { 1286 ppa[pages] = NULL; 1287 } 1288 VM_STAT_ADD(page_exphcontg[18]); 1289 ASSERT(vp->v_pages != NULL); 1290 return (1); 1291 } 1292 1293 /* 1294 * Determine whether a page with the specified [vp, off] 1295 * currently exists in the system and if so return its 1296 * size code. Obviously this should only be considered as 1297 * a hint since nothing prevents the page from disappearing 1298 * or appearing immediately after the return from this routine. 1299 */ 1300 int 1301 page_exists_forreal(vnode_t *vp, u_offset_t off, uint_t *szc) 1302 { 1303 page_t *pp; 1304 kmutex_t *phm; 1305 ulong_t index; 1306 int rc = 0; 1307 1308 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 1309 ASSERT(szc != NULL); 1310 VM_STAT_ADD(page_exists_forreal_cnt); 1311 1312 index = PAGE_HASH_FUNC(vp, off); 1313 phm = PAGE_HASH_MUTEX(index); 1314 1315 mutex_enter(phm); 1316 PAGE_HASH_SEARCH(index, pp, vp, off); 1317 if (pp != NULL) { 1318 *szc = pp->p_szc; 1319 rc = 1; 1320 } 1321 mutex_exit(phm); 1322 return (rc); 1323 } 1324 1325 /* wakeup threads waiting for pages in page_create_get_something() */ 1326 void 1327 wakeup_pcgs(void) 1328 { 1329 if (!CV_HAS_WAITERS(&pcgs_cv)) 1330 return; 1331 cv_broadcast(&pcgs_cv); 1332 } 1333 1334 /* 1335 * 'freemem' is used all over the kernel as an indication of how many 1336 * pages are free (either on the cache list or on the free page list) 1337 * in the system. In very few places is a really accurate 'freemem' 1338 * needed. To avoid contention of the lock protecting a the 1339 * single freemem, it was spread out into NCPU buckets. Set_freemem 1340 * sets freemem to the total of all NCPU buckets. It is called from 1341 * clock() on each TICK. 1342 */ 1343 void 1344 set_freemem() 1345 { 1346 struct pcf *p; 1347 ulong_t t; 1348 uint_t i; 1349 1350 t = 0; 1351 p = pcf; 1352 for (i = 0; i < pcf_fanout; i++) { 1353 t += p->pcf_count; 1354 p++; 1355 } 1356 freemem = t; 1357 1358 /* 1359 * Don't worry about grabbing mutex. It's not that 1360 * critical if we miss a tick or two. This is 1361 * where we wakeup possible delayers in 1362 * page_create_get_something(). 1363 */ 1364 wakeup_pcgs(); 1365 } 1366 1367 ulong_t 1368 get_freemem() 1369 { 1370 struct pcf *p; 1371 ulong_t t; 1372 uint_t i; 1373 1374 t = 0; 1375 p = pcf; 1376 for (i = 0; i < pcf_fanout; i++) { 1377 t += p->pcf_count; 1378 p++; 1379 } 1380 /* 1381 * We just calculated it, might as well set it. 1382 */ 1383 freemem = t; 1384 return (t); 1385 } 1386 1387 /* 1388 * Acquire all of the page cache & free (pcf) locks. 1389 */ 1390 void 1391 pcf_acquire_all() 1392 { 1393 struct pcf *p; 1394 uint_t i; 1395 1396 p = pcf; 1397 for (i = 0; i < pcf_fanout; i++) { 1398 mutex_enter(&p->pcf_lock); 1399 p++; 1400 } 1401 } 1402 1403 /* 1404 * Release all the pcf_locks. 1405 */ 1406 void 1407 pcf_release_all() 1408 { 1409 struct pcf *p; 1410 uint_t i; 1411 1412 p = pcf; 1413 for (i = 0; i < pcf_fanout; i++) { 1414 mutex_exit(&p->pcf_lock); 1415 p++; 1416 } 1417 } 1418 1419 /* 1420 * Inform the VM system that we need some pages freed up. 1421 * Calls must be symmetric, e.g.: 1422 * 1423 * page_needfree(100); 1424 * wait a bit; 1425 * page_needfree(-100); 1426 */ 1427 void 1428 page_needfree(spgcnt_t npages) 1429 { 1430 mutex_enter(&new_freemem_lock); 1431 needfree += npages; 1432 mutex_exit(&new_freemem_lock); 1433 } 1434 1435 /* 1436 * Throttle for page_create(): try to prevent freemem from dropping 1437 * below throttlefree. We can't provide a 100% guarantee because 1438 * KM_NOSLEEP allocations, page_reclaim(), and various other things 1439 * nibble away at the freelist. However, we can block all PG_WAIT 1440 * allocations until memory becomes available. The motivation is 1441 * that several things can fall apart when there's no free memory: 1442 * 1443 * (1) If pageout() needs memory to push a page, the system deadlocks. 1444 * 1445 * (2) By (broken) specification, timeout(9F) can neither fail nor 1446 * block, so it has no choice but to panic the system if it 1447 * cannot allocate a callout structure. 1448 * 1449 * (3) Like timeout(), ddi_set_callback() cannot fail and cannot block; 1450 * it panics if it cannot allocate a callback structure. 1451 * 1452 * (4) Untold numbers of third-party drivers have not yet been hardened 1453 * against KM_NOSLEEP and/or allocb() failures; they simply assume 1454 * success and panic the system with a data fault on failure. 1455 * (The long-term solution to this particular problem is to ship 1456 * hostile fault-injecting DEBUG kernels with the DDK.) 1457 * 1458 * It is theoretically impossible to guarantee success of non-blocking 1459 * allocations, but in practice, this throttle is very hard to break. 1460 */ 1461 static int 1462 page_create_throttle(pgcnt_t npages, int flags) 1463 { 1464 ulong_t fm; 1465 uint_t i; 1466 pgcnt_t tf; /* effective value of throttlefree */ 1467 1468 /* 1469 * Never deny pages when: 1470 * - it's a thread that cannot block [NOMEMWAIT()] 1471 * - the allocation cannot block and must not fail 1472 * - the allocation cannot block and is pageout dispensated 1473 */ 1474 if (NOMEMWAIT() || 1475 ((flags & (PG_WAIT | PG_PANIC)) == PG_PANIC) || 1476 ((flags & (PG_WAIT | PG_PUSHPAGE)) == PG_PUSHPAGE)) 1477 return (1); 1478 1479 /* 1480 * If the allocation can't block, we look favorably upon it 1481 * unless we're below pageout_reserve. In that case we fail 1482 * the allocation because we want to make sure there are a few 1483 * pages available for pageout. 1484 */ 1485 if ((flags & PG_WAIT) == 0) 1486 return (freemem >= npages + pageout_reserve); 1487 1488 /* Calculate the effective throttlefree value */ 1489 tf = throttlefree - 1490 ((flags & PG_PUSHPAGE) ? pageout_reserve : 0); 1491 1492 cv_signal(&proc_pageout->p_cv); 1493 1494 for (;;) { 1495 fm = 0; 1496 pcf_acquire_all(); 1497 mutex_enter(&new_freemem_lock); 1498 for (i = 0; i < pcf_fanout; i++) { 1499 fm += pcf[i].pcf_count; 1500 pcf[i].pcf_wait++; 1501 mutex_exit(&pcf[i].pcf_lock); 1502 } 1503 freemem = fm; 1504 if (freemem >= npages + tf) { 1505 mutex_exit(&new_freemem_lock); 1506 break; 1507 } 1508 needfree += npages; 1509 freemem_wait++; 1510 cv_wait(&freemem_cv, &new_freemem_lock); 1511 freemem_wait--; 1512 needfree -= npages; 1513 mutex_exit(&new_freemem_lock); 1514 } 1515 return (1); 1516 } 1517 1518 /* 1519 * page_create_wait() is called to either coalesce pages from the 1520 * different pcf buckets or to wait because there simply are not 1521 * enough pages to satisfy the caller's request. 1522 * 1523 * Sadly, this is called from platform/vm/vm_machdep.c 1524 */ 1525 int 1526 page_create_wait(pgcnt_t npages, uint_t flags) 1527 { 1528 pgcnt_t total; 1529 uint_t i; 1530 struct pcf *p; 1531 1532 /* 1533 * Wait until there are enough free pages to satisfy our 1534 * entire request. 1535 * We set needfree += npages before prodding pageout, to make sure 1536 * it does real work when npages > lotsfree > freemem. 1537 */ 1538 VM_STAT_ADD(page_create_not_enough); 1539 1540 ASSERT(!kcage_on ? !(flags & PG_NORELOC) : 1); 1541 checkagain: 1542 if ((flags & PG_NORELOC) && 1543 kcage_freemem < kcage_throttlefree + npages) 1544 (void) kcage_create_throttle(npages, flags); 1545 1546 if (freemem < npages + throttlefree) 1547 if (!page_create_throttle(npages, flags)) 1548 return (0); 1549 1550 if (pcf_decrement_bucket(npages) || 1551 pcf_decrement_multiple(&total, npages, 0)) 1552 return (1); 1553 1554 /* 1555 * All of the pcf locks are held, there are not enough pages 1556 * to satisfy the request (npages < total). 1557 * Be sure to acquire the new_freemem_lock before dropping 1558 * the pcf locks. This prevents dropping wakeups in page_free(). 1559 * The order is always pcf_lock then new_freemem_lock. 1560 * 1561 * Since we hold all the pcf locks, it is a good time to set freemem. 1562 * 1563 * If the caller does not want to wait, return now. 1564 * Else turn the pageout daemon loose to find something 1565 * and wait till it does. 1566 * 1567 */ 1568 freemem = total; 1569 1570 if ((flags & PG_WAIT) == 0) { 1571 pcf_release_all(); 1572 1573 TRACE_2(TR_FAC_VM, TR_PAGE_CREATE_NOMEM, 1574 "page_create_nomem:npages %ld freemem %ld", npages, freemem); 1575 return (0); 1576 } 1577 1578 ASSERT(proc_pageout != NULL); 1579 cv_signal(&proc_pageout->p_cv); 1580 1581 TRACE_2(TR_FAC_VM, TR_PAGE_CREATE_SLEEP_START, 1582 "page_create_sleep_start: freemem %ld needfree %ld", 1583 freemem, needfree); 1584 1585 /* 1586 * We are going to wait. 1587 * We currently hold all of the pcf_locks, 1588 * get the new_freemem_lock (it protects freemem_wait), 1589 * before dropping the pcf_locks. 1590 */ 1591 mutex_enter(&new_freemem_lock); 1592 1593 p = pcf; 1594 for (i = 0; i < pcf_fanout; i++) { 1595 p->pcf_wait++; 1596 mutex_exit(&p->pcf_lock); 1597 p++; 1598 } 1599 1600 needfree += npages; 1601 freemem_wait++; 1602 1603 cv_wait(&freemem_cv, &new_freemem_lock); 1604 1605 freemem_wait--; 1606 needfree -= npages; 1607 1608 mutex_exit(&new_freemem_lock); 1609 1610 TRACE_2(TR_FAC_VM, TR_PAGE_CREATE_SLEEP_END, 1611 "page_create_sleep_end: freemem %ld needfree %ld", 1612 freemem, needfree); 1613 1614 VM_STAT_ADD(page_create_not_enough_again); 1615 goto checkagain; 1616 } 1617 /* 1618 * A routine to do the opposite of page_create_wait(). 1619 */ 1620 void 1621 page_create_putback(spgcnt_t npages) 1622 { 1623 struct pcf *p; 1624 pgcnt_t lump; 1625 uint_t *which; 1626 1627 /* 1628 * When a contiguous lump is broken up, we have to 1629 * deal with lots of pages (min 64) so lets spread 1630 * the wealth around. 1631 */ 1632 lump = roundup(npages, pcf_fanout) / pcf_fanout; 1633 freemem += npages; 1634 1635 for (p = pcf; (npages > 0) && (p < &pcf[pcf_fanout]); p++) { 1636 which = &p->pcf_count; 1637 1638 mutex_enter(&p->pcf_lock); 1639 1640 if (p->pcf_block) { 1641 which = &p->pcf_reserve; 1642 } 1643 1644 if (lump < npages) { 1645 *which += (uint_t)lump; 1646 npages -= lump; 1647 } else { 1648 *which += (uint_t)npages; 1649 npages = 0; 1650 } 1651 1652 if (p->pcf_wait) { 1653 mutex_enter(&new_freemem_lock); 1654 /* 1655 * Check to see if some other thread 1656 * is actually waiting. Another bucket 1657 * may have woken it up by now. If there 1658 * are no waiters, then set our pcf_wait 1659 * count to zero to avoid coming in here 1660 * next time. 1661 */ 1662 if (freemem_wait) { 1663 if (npages > 1) { 1664 cv_broadcast(&freemem_cv); 1665 } else { 1666 cv_signal(&freemem_cv); 1667 } 1668 p->pcf_wait--; 1669 } else { 1670 p->pcf_wait = 0; 1671 } 1672 mutex_exit(&new_freemem_lock); 1673 } 1674 mutex_exit(&p->pcf_lock); 1675 } 1676 ASSERT(npages == 0); 1677 } 1678 1679 /* 1680 * A helper routine for page_create_get_something. 1681 * The indenting got to deep down there. 1682 * Unblock the pcf counters. Any pages freed after 1683 * pcf_block got set are moved to pcf_count and 1684 * wakeups (cv_broadcast() or cv_signal()) are done as needed. 1685 */ 1686 static void 1687 pcgs_unblock(void) 1688 { 1689 int i; 1690 struct pcf *p; 1691 1692 /* Update freemem while we're here. */ 1693 freemem = 0; 1694 p = pcf; 1695 for (i = 0; i < pcf_fanout; i++) { 1696 mutex_enter(&p->pcf_lock); 1697 ASSERT(p->pcf_count == 0); 1698 p->pcf_count = p->pcf_reserve; 1699 p->pcf_block = 0; 1700 freemem += p->pcf_count; 1701 if (p->pcf_wait) { 1702 mutex_enter(&new_freemem_lock); 1703 if (freemem_wait) { 1704 if (p->pcf_reserve > 1) { 1705 cv_broadcast(&freemem_cv); 1706 p->pcf_wait = 0; 1707 } else { 1708 cv_signal(&freemem_cv); 1709 p->pcf_wait--; 1710 } 1711 } else { 1712 p->pcf_wait = 0; 1713 } 1714 mutex_exit(&new_freemem_lock); 1715 } 1716 p->pcf_reserve = 0; 1717 mutex_exit(&p->pcf_lock); 1718 p++; 1719 } 1720 } 1721 1722 /* 1723 * Called from page_create_va() when both the cache and free lists 1724 * have been checked once. 1725 * 1726 * Either returns a page or panics since the accounting was done 1727 * way before we got here. 1728 * 1729 * We don't come here often, so leave the accounting on permanently. 1730 */ 1731 1732 #define MAX_PCGS 100 1733 1734 #ifdef DEBUG 1735 #define PCGS_TRIES 100 1736 #else /* DEBUG */ 1737 #define PCGS_TRIES 10 1738 #endif /* DEBUG */ 1739 1740 #ifdef VM_STATS 1741 uint_t pcgs_counts[PCGS_TRIES]; 1742 uint_t pcgs_too_many; 1743 uint_t pcgs_entered; 1744 uint_t pcgs_entered_noreloc; 1745 uint_t pcgs_locked; 1746 uint_t pcgs_cagelocked; 1747 #endif /* VM_STATS */ 1748 1749 static page_t * 1750 page_create_get_something(vnode_t *vp, u_offset_t off, struct seg *seg, 1751 caddr_t vaddr, uint_t flags) 1752 { 1753 uint_t count; 1754 page_t *pp; 1755 uint_t locked, i; 1756 struct pcf *p; 1757 lgrp_t *lgrp; 1758 int cagelocked = 0; 1759 1760 VM_STAT_ADD(pcgs_entered); 1761 1762 /* 1763 * Tap any reserve freelists: if we fail now, we'll die 1764 * since the page(s) we're looking for have already been 1765 * accounted for. 1766 */ 1767 flags |= PG_PANIC; 1768 1769 if ((flags & PG_NORELOC) != 0) { 1770 VM_STAT_ADD(pcgs_entered_noreloc); 1771 /* 1772 * Requests for free pages from critical threads 1773 * such as pageout still won't throttle here, but 1774 * we must try again, to give the cageout thread 1775 * another chance to catch up. Since we already 1776 * accounted for the pages, we had better get them 1777 * this time. 1778 * 1779 * N.B. All non-critical threads acquire the pcgs_cagelock 1780 * to serialize access to the freelists. This implements a 1781 * turnstile-type synchornization to avoid starvation of 1782 * critical requests for PG_NORELOC memory by non-critical 1783 * threads: all non-critical threads must acquire a 'ticket' 1784 * before passing through, which entails making sure 1785 * kcage_freemem won't fall below minfree prior to grabbing 1786 * pages from the freelists. 1787 */ 1788 if (kcage_create_throttle(1, flags) == KCT_NONCRIT) { 1789 mutex_enter(&pcgs_cagelock); 1790 cagelocked = 1; 1791 VM_STAT_ADD(pcgs_cagelocked); 1792 } 1793 } 1794 1795 /* 1796 * Time to get serious. 1797 * We failed to get a `correctly colored' page from both the 1798 * free and cache lists. 1799 * We escalate in stage. 1800 * 1801 * First try both lists without worring about color. 1802 * 1803 * Then, grab all page accounting locks (ie. pcf[]) and 1804 * steal any pages that they have and set the pcf_block flag to 1805 * stop deletions from the lists. This will help because 1806 * a page can get added to the free list while we are looking 1807 * at the cache list, then another page could be added to the cache 1808 * list allowing the page on the free list to be removed as we 1809 * move from looking at the cache list to the free list. This 1810 * could happen over and over. We would never find the page 1811 * we have accounted for. 1812 * 1813 * Noreloc pages are a subset of the global (relocatable) page pool. 1814 * They are not tracked separately in the pcf bins, so it is 1815 * impossible to know when doing pcf accounting if the available 1816 * page(s) are noreloc pages or not. When looking for a noreloc page 1817 * it is quite easy to end up here even if the global (relocatable) 1818 * page pool has plenty of free pages but the noreloc pool is empty. 1819 * 1820 * When the noreloc pool is empty (or low), additional noreloc pages 1821 * are created by converting pages from the global page pool. This 1822 * process will stall during pcf accounting if the pcf bins are 1823 * already locked. Such is the case when a noreloc allocation is 1824 * looping here in page_create_get_something waiting for more noreloc 1825 * pages to appear. 1826 * 1827 * Short of adding a new field to the pcf bins to accurately track 1828 * the number of free noreloc pages, we instead do not grab the 1829 * pcgs_lock, do not set the pcf blocks and do not timeout when 1830 * allocating a noreloc page. This allows noreloc allocations to 1831 * loop without blocking global page pool allocations. 1832 * 1833 * NOTE: the behaviour of page_create_get_something has not changed 1834 * for the case of global page pool allocations. 1835 */ 1836 1837 flags &= ~PG_MATCH_COLOR; 1838 locked = 0; 1839 #if defined(__i386) || defined(__amd64) 1840 flags = page_create_update_flags_x86(flags); 1841 #endif 1842 1843 lgrp = lgrp_mem_choose(seg, vaddr, PAGESIZE); 1844 1845 for (count = 0; kcage_on || count < MAX_PCGS; count++) { 1846 pp = page_get_freelist(vp, off, seg, vaddr, PAGESIZE, 1847 flags, lgrp); 1848 if (pp == NULL) { 1849 pp = page_get_cachelist(vp, off, seg, vaddr, 1850 flags, lgrp); 1851 } 1852 if (pp == NULL) { 1853 /* 1854 * Serialize. Don't fight with other pcgs(). 1855 */ 1856 if (!locked && (!kcage_on || !(flags & PG_NORELOC))) { 1857 mutex_enter(&pcgs_lock); 1858 VM_STAT_ADD(pcgs_locked); 1859 locked = 1; 1860 p = pcf; 1861 for (i = 0; i < pcf_fanout; i++) { 1862 mutex_enter(&p->pcf_lock); 1863 ASSERT(p->pcf_block == 0); 1864 p->pcf_block = 1; 1865 p->pcf_reserve = p->pcf_count; 1866 p->pcf_count = 0; 1867 mutex_exit(&p->pcf_lock); 1868 p++; 1869 } 1870 freemem = 0; 1871 } 1872 1873 if (count) { 1874 /* 1875 * Since page_free() puts pages on 1876 * a list then accounts for it, we 1877 * just have to wait for page_free() 1878 * to unlock any page it was working 1879 * with. The page_lock()-page_reclaim() 1880 * path falls in the same boat. 1881 * 1882 * We don't need to check on the 1883 * PG_WAIT flag, we have already 1884 * accounted for the page we are 1885 * looking for in page_create_va(). 1886 * 1887 * We just wait a moment to let any 1888 * locked pages on the lists free up, 1889 * then continue around and try again. 1890 * 1891 * Will be awakened by set_freemem(). 1892 */ 1893 mutex_enter(&pcgs_wait_lock); 1894 cv_wait(&pcgs_cv, &pcgs_wait_lock); 1895 mutex_exit(&pcgs_wait_lock); 1896 } 1897 } else { 1898 #ifdef VM_STATS 1899 if (count >= PCGS_TRIES) { 1900 VM_STAT_ADD(pcgs_too_many); 1901 } else { 1902 VM_STAT_ADD(pcgs_counts[count]); 1903 } 1904 #endif 1905 if (locked) { 1906 pcgs_unblock(); 1907 mutex_exit(&pcgs_lock); 1908 } 1909 if (cagelocked) 1910 mutex_exit(&pcgs_cagelock); 1911 return (pp); 1912 } 1913 } 1914 /* 1915 * we go down holding the pcf locks. 1916 */ 1917 panic("no %spage found %d", 1918 ((flags & PG_NORELOC) ? "non-reloc " : ""), count); 1919 /*NOTREACHED*/ 1920 } 1921 1922 /* 1923 * Create enough pages for "bytes" worth of data starting at 1924 * "off" in "vp". 1925 * 1926 * Where flag must be one of: 1927 * 1928 * PG_EXCL: Exclusive create (fail if any page already 1929 * exists in the page cache) which does not 1930 * wait for memory to become available. 1931 * 1932 * PG_WAIT: Non-exclusive create which can wait for 1933 * memory to become available. 1934 * 1935 * PG_PHYSCONTIG: Allocate physically contiguous pages. 1936 * (Not Supported) 1937 * 1938 * A doubly linked list of pages is returned to the caller. Each page 1939 * on the list has the "exclusive" (p_selock) lock and "iolock" (p_iolock) 1940 * lock. 1941 * 1942 * Unable to change the parameters to page_create() in a minor release, 1943 * we renamed page_create() to page_create_va(), changed all known calls 1944 * from page_create() to page_create_va(), and created this wrapper. 1945 * 1946 * Upon a major release, we should break compatibility by deleting this 1947 * wrapper, and replacing all the strings "page_create_va", with "page_create". 1948 * 1949 * NOTE: There is a copy of this interface as page_create_io() in 1950 * i86/vm/vm_machdep.c. Any bugs fixed here should be applied 1951 * there. 1952 */ 1953 page_t * 1954 page_create(vnode_t *vp, u_offset_t off, size_t bytes, uint_t flags) 1955 { 1956 caddr_t random_vaddr; 1957 struct seg kseg; 1958 1959 #ifdef DEBUG 1960 cmn_err(CE_WARN, "Using deprecated interface page_create: caller %p", 1961 (void *)caller()); 1962 #endif 1963 1964 random_vaddr = (caddr_t)(((uintptr_t)vp >> 7) ^ 1965 (uintptr_t)(off >> PAGESHIFT)); 1966 kseg.s_as = &kas; 1967 1968 return (page_create_va(vp, off, bytes, flags, &kseg, random_vaddr)); 1969 } 1970 1971 #ifdef DEBUG 1972 uint32_t pg_alloc_pgs_mtbf = 0; 1973 #endif 1974 1975 /* 1976 * Used for large page support. It will attempt to allocate 1977 * a large page(s) off the freelist. 1978 * 1979 * Returns non zero on failure. 1980 */ 1981 int 1982 page_alloc_pages(struct vnode *vp, struct seg *seg, caddr_t addr, 1983 page_t **basepp, page_t *ppa[], uint_t szc, int anypgsz, int pgflags) 1984 { 1985 pgcnt_t npgs, curnpgs, totpgs; 1986 size_t pgsz; 1987 page_t *pplist = NULL, *pp; 1988 int err = 0; 1989 lgrp_t *lgrp; 1990 1991 ASSERT(szc != 0 && szc <= (page_num_pagesizes() - 1)); 1992 ASSERT(pgflags == 0 || pgflags == PG_LOCAL); 1993 1994 /* 1995 * Check if system heavily prefers local large pages over remote 1996 * on systems with multiple lgroups. 1997 */ 1998 if (lpg_alloc_prefer == LPAP_LOCAL && nlgrps > 1) { 1999 pgflags = PG_LOCAL; 2000 } 2001 2002 VM_STAT_ADD(alloc_pages[0]); 2003 2004 #ifdef DEBUG 2005 if (pg_alloc_pgs_mtbf && !(gethrtime() % pg_alloc_pgs_mtbf)) { 2006 return (ENOMEM); 2007 } 2008 #endif 2009 2010 /* 2011 * One must be NULL but not both. 2012 * And one must be non NULL but not both. 2013 */ 2014 ASSERT(basepp != NULL || ppa != NULL); 2015 ASSERT(basepp == NULL || ppa == NULL); 2016 2017 #if defined(__i386) || defined(__amd64) 2018 while (page_chk_freelist(szc) == 0) { 2019 VM_STAT_ADD(alloc_pages[8]); 2020 if (anypgsz == 0 || --szc == 0) 2021 return (ENOMEM); 2022 } 2023 #endif 2024 2025 pgsz = page_get_pagesize(szc); 2026 totpgs = curnpgs = npgs = pgsz >> PAGESHIFT; 2027 2028 ASSERT(((uintptr_t)addr & (pgsz - 1)) == 0); 2029 2030 (void) page_create_wait(npgs, PG_WAIT); 2031 2032 while (npgs && szc) { 2033 lgrp = lgrp_mem_choose(seg, addr, pgsz); 2034 if (pgflags == PG_LOCAL) { 2035 pp = page_get_freelist(vp, 0, seg, addr, pgsz, 2036 pgflags, lgrp); 2037 if (pp == NULL) { 2038 pp = page_get_freelist(vp, 0, seg, addr, pgsz, 2039 0, lgrp); 2040 } 2041 } else { 2042 pp = page_get_freelist(vp, 0, seg, addr, pgsz, 2043 0, lgrp); 2044 } 2045 if (pp != NULL) { 2046 VM_STAT_ADD(alloc_pages[1]); 2047 page_list_concat(&pplist, &pp); 2048 ASSERT(npgs >= curnpgs); 2049 npgs -= curnpgs; 2050 } else if (anypgsz) { 2051 VM_STAT_ADD(alloc_pages[2]); 2052 szc--; 2053 pgsz = page_get_pagesize(szc); 2054 curnpgs = pgsz >> PAGESHIFT; 2055 } else { 2056 VM_STAT_ADD(alloc_pages[3]); 2057 ASSERT(npgs == totpgs); 2058 page_create_putback(npgs); 2059 return (ENOMEM); 2060 } 2061 } 2062 if (szc == 0) { 2063 VM_STAT_ADD(alloc_pages[4]); 2064 ASSERT(npgs != 0); 2065 page_create_putback(npgs); 2066 err = ENOMEM; 2067 } else if (basepp != NULL) { 2068 ASSERT(npgs == 0); 2069 ASSERT(ppa == NULL); 2070 *basepp = pplist; 2071 } 2072 2073 npgs = totpgs - npgs; 2074 pp = pplist; 2075 2076 /* 2077 * Clear the free and age bits. Also if we were passed in a ppa then 2078 * fill it in with all the constituent pages from the large page. But 2079 * if we failed to allocate all the pages just free what we got. 2080 */ 2081 while (npgs != 0) { 2082 ASSERT(PP_ISFREE(pp)); 2083 ASSERT(PP_ISAGED(pp)); 2084 if (ppa != NULL || err != 0) { 2085 if (err == 0) { 2086 VM_STAT_ADD(alloc_pages[5]); 2087 PP_CLRFREE(pp); 2088 PP_CLRAGED(pp); 2089 page_sub(&pplist, pp); 2090 *ppa++ = pp; 2091 npgs--; 2092 } else { 2093 VM_STAT_ADD(alloc_pages[6]); 2094 ASSERT(pp->p_szc != 0); 2095 curnpgs = page_get_pagecnt(pp->p_szc); 2096 page_list_break(&pp, &pplist, curnpgs); 2097 page_list_add_pages(pp, 0); 2098 page_create_putback(curnpgs); 2099 ASSERT(npgs >= curnpgs); 2100 npgs -= curnpgs; 2101 } 2102 pp = pplist; 2103 } else { 2104 VM_STAT_ADD(alloc_pages[7]); 2105 PP_CLRFREE(pp); 2106 PP_CLRAGED(pp); 2107 pp = pp->p_next; 2108 npgs--; 2109 } 2110 } 2111 return (err); 2112 } 2113 2114 /* 2115 * Get a single large page off of the freelists, and set it up for use. 2116 * Number of bytes requested must be a supported page size. 2117 * 2118 * Note that this call may fail even if there is sufficient 2119 * memory available or PG_WAIT is set, so the caller must 2120 * be willing to fallback on page_create_va(), block and retry, 2121 * or fail the requester. 2122 */ 2123 page_t * 2124 page_create_va_large(vnode_t *vp, u_offset_t off, size_t bytes, uint_t flags, 2125 struct seg *seg, caddr_t vaddr, void *arg) 2126 { 2127 pgcnt_t npages; 2128 page_t *pp; 2129 page_t *rootpp; 2130 lgrp_t *lgrp; 2131 lgrp_id_t *lgrpid = (lgrp_id_t *)arg; 2132 2133 ASSERT(vp != NULL); 2134 2135 ASSERT((flags & ~(PG_EXCL | PG_WAIT | 2136 PG_NORELOC | PG_PANIC | PG_PUSHPAGE)) == 0); 2137 /* but no others */ 2138 2139 ASSERT((flags & PG_EXCL) == PG_EXCL); 2140 2141 npages = btop(bytes); 2142 2143 if (!kcage_on || panicstr) { 2144 /* 2145 * Cage is OFF, or we are single threaded in 2146 * panic, so make everything a RELOC request. 2147 */ 2148 flags &= ~PG_NORELOC; 2149 } 2150 2151 /* 2152 * Make sure there's adequate physical memory available. 2153 * Note: PG_WAIT is ignored here. 2154 */ 2155 if (freemem <= throttlefree + npages) { 2156 VM_STAT_ADD(page_create_large_cnt[1]); 2157 return (NULL); 2158 } 2159 2160 /* 2161 * If cage is on, dampen draw from cage when available 2162 * cage space is low. 2163 */ 2164 if ((flags & (PG_NORELOC | PG_WAIT)) == (PG_NORELOC | PG_WAIT) && 2165 kcage_freemem < kcage_throttlefree + npages) { 2166 2167 /* 2168 * The cage is on, the caller wants PG_NORELOC 2169 * pages and available cage memory is very low. 2170 * Call kcage_create_throttle() to attempt to 2171 * control demand on the cage. 2172 */ 2173 if (kcage_create_throttle(npages, flags) == KCT_FAILURE) { 2174 VM_STAT_ADD(page_create_large_cnt[2]); 2175 return (NULL); 2176 } 2177 } 2178 2179 if (!pcf_decrement_bucket(npages) && 2180 !pcf_decrement_multiple(NULL, npages, 1)) { 2181 VM_STAT_ADD(page_create_large_cnt[4]); 2182 return (NULL); 2183 } 2184 2185 /* 2186 * This is where this function behaves fundamentally differently 2187 * than page_create_va(); since we're intending to map the page 2188 * with a single TTE, we have to get it as a physically contiguous 2189 * hardware pagesize chunk. If we can't, we fail. 2190 */ 2191 if (lgrpid != NULL && *lgrpid >= 0 && *lgrpid <= lgrp_alloc_max && 2192 LGRP_EXISTS(lgrp_table[*lgrpid])) 2193 lgrp = lgrp_table[*lgrpid]; 2194 else 2195 lgrp = lgrp_mem_choose(seg, vaddr, bytes); 2196 2197 if ((rootpp = page_get_freelist(&kvp, off, seg, vaddr, 2198 bytes, flags & ~PG_MATCH_COLOR, lgrp)) == NULL) { 2199 page_create_putback(npages); 2200 VM_STAT_ADD(page_create_large_cnt[5]); 2201 return (NULL); 2202 } 2203 2204 /* 2205 * if we got the page with the wrong mtype give it back this is a 2206 * workaround for CR 6249718. When CR 6249718 is fixed we never get 2207 * inside "if" and the workaround becomes just a nop 2208 */ 2209 if (kcage_on && (flags & PG_NORELOC) && !PP_ISNORELOC(rootpp)) { 2210 page_list_add_pages(rootpp, 0); 2211 page_create_putback(npages); 2212 VM_STAT_ADD(page_create_large_cnt[6]); 2213 return (NULL); 2214 } 2215 2216 /* 2217 * If satisfying this request has left us with too little 2218 * memory, start the wheels turning to get some back. The 2219 * first clause of the test prevents waking up the pageout 2220 * daemon in situations where it would decide that there's 2221 * nothing to do. 2222 */ 2223 if (nscan < desscan && freemem < minfree) { 2224 TRACE_1(TR_FAC_VM, TR_PAGEOUT_CV_SIGNAL, 2225 "pageout_cv_signal:freemem %ld", freemem); 2226 cv_signal(&proc_pageout->p_cv); 2227 } 2228 2229 pp = rootpp; 2230 while (npages--) { 2231 ASSERT(PAGE_EXCL(pp)); 2232 ASSERT(pp->p_vnode == NULL); 2233 ASSERT(!hat_page_is_mapped(pp)); 2234 PP_CLRFREE(pp); 2235 PP_CLRAGED(pp); 2236 if (!page_hashin(pp, vp, off, NULL)) 2237 panic("page_create_large: hashin failed: page %p", 2238 (void *)pp); 2239 page_io_lock(pp); 2240 off += PAGESIZE; 2241 pp = pp->p_next; 2242 } 2243 2244 VM_STAT_ADD(page_create_large_cnt[0]); 2245 return (rootpp); 2246 } 2247 2248 page_t * 2249 page_create_va(vnode_t *vp, u_offset_t off, size_t bytes, uint_t flags, 2250 struct seg *seg, caddr_t vaddr) 2251 { 2252 page_t *plist = NULL; 2253 pgcnt_t npages; 2254 pgcnt_t found_on_free = 0; 2255 pgcnt_t pages_req; 2256 page_t *npp = NULL; 2257 struct pcf *p; 2258 lgrp_t *lgrp; 2259 2260 TRACE_4(TR_FAC_VM, TR_PAGE_CREATE_START, 2261 "page_create_start:vp %p off %llx bytes %lu flags %x", 2262 vp, off, bytes, flags); 2263 2264 ASSERT(bytes != 0 && vp != NULL); 2265 2266 if ((flags & PG_EXCL) == 0 && (flags & PG_WAIT) == 0) { 2267 panic("page_create: invalid flags"); 2268 /*NOTREACHED*/ 2269 } 2270 ASSERT((flags & ~(PG_EXCL | PG_WAIT | 2271 PG_NORELOC | PG_PANIC | PG_PUSHPAGE)) == 0); 2272 /* but no others */ 2273 2274 pages_req = npages = btopr(bytes); 2275 /* 2276 * Try to see whether request is too large to *ever* be 2277 * satisfied, in order to prevent deadlock. We arbitrarily 2278 * decide to limit maximum size requests to max_page_get. 2279 */ 2280 if (npages >= max_page_get) { 2281 if ((flags & PG_WAIT) == 0) { 2282 TRACE_4(TR_FAC_VM, TR_PAGE_CREATE_TOOBIG, 2283 "page_create_toobig:vp %p off %llx npages " 2284 "%lu max_page_get %lu", 2285 vp, off, npages, max_page_get); 2286 return (NULL); 2287 } else { 2288 cmn_err(CE_WARN, 2289 "Request for too much kernel memory " 2290 "(%lu bytes), will hang forever", bytes); 2291 for (;;) 2292 delay(1000000000); 2293 } 2294 } 2295 2296 if (!kcage_on || panicstr) { 2297 /* 2298 * Cage is OFF, or we are single threaded in 2299 * panic, so make everything a RELOC request. 2300 */ 2301 flags &= ~PG_NORELOC; 2302 } 2303 2304 if (freemem <= throttlefree + npages) 2305 if (!page_create_throttle(npages, flags)) 2306 return (NULL); 2307 2308 /* 2309 * If cage is on, dampen draw from cage when available 2310 * cage space is low. 2311 */ 2312 if ((flags & PG_NORELOC) && 2313 kcage_freemem < kcage_throttlefree + npages) { 2314 2315 /* 2316 * The cage is on, the caller wants PG_NORELOC 2317 * pages and available cage memory is very low. 2318 * Call kcage_create_throttle() to attempt to 2319 * control demand on the cage. 2320 */ 2321 if (kcage_create_throttle(npages, flags) == KCT_FAILURE) 2322 return (NULL); 2323 } 2324 2325 VM_STAT_ADD(page_create_cnt[0]); 2326 2327 if (!pcf_decrement_bucket(npages)) { 2328 /* 2329 * Have to look harder. If npages is greater than 2330 * one, then we might have to coalesce the counters. 2331 * 2332 * Go wait. We come back having accounted 2333 * for the memory. 2334 */ 2335 VM_STAT_ADD(page_create_cnt[1]); 2336 if (!page_create_wait(npages, flags)) { 2337 VM_STAT_ADD(page_create_cnt[2]); 2338 return (NULL); 2339 } 2340 } 2341 2342 TRACE_2(TR_FAC_VM, TR_PAGE_CREATE_SUCCESS, 2343 "page_create_success:vp %p off %llx", vp, off); 2344 2345 /* 2346 * If satisfying this request has left us with too little 2347 * memory, start the wheels turning to get some back. The 2348 * first clause of the test prevents waking up the pageout 2349 * daemon in situations where it would decide that there's 2350 * nothing to do. 2351 */ 2352 if (nscan < desscan && freemem < minfree) { 2353 TRACE_1(TR_FAC_VM, TR_PAGEOUT_CV_SIGNAL, 2354 "pageout_cv_signal:freemem %ld", freemem); 2355 cv_signal(&proc_pageout->p_cv); 2356 } 2357 2358 /* 2359 * Loop around collecting the requested number of pages. 2360 * Most of the time, we have to `create' a new page. With 2361 * this in mind, pull the page off the free list before 2362 * getting the hash lock. This will minimize the hash 2363 * lock hold time, nesting, and the like. If it turns 2364 * out we don't need the page, we put it back at the end. 2365 */ 2366 while (npages--) { 2367 page_t *pp; 2368 kmutex_t *phm = NULL; 2369 ulong_t index; 2370 2371 index = PAGE_HASH_FUNC(vp, off); 2372 top: 2373 ASSERT(phm == NULL); 2374 ASSERT(index == PAGE_HASH_FUNC(vp, off)); 2375 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 2376 2377 if (npp == NULL) { 2378 /* 2379 * Try to get a page from the freelist (ie, 2380 * a page with no [vp, off] tag). If that 2381 * fails, use the cachelist. 2382 * 2383 * During the first attempt at both the free 2384 * and cache lists we try for the correct color. 2385 */ 2386 /* 2387 * XXXX-how do we deal with virtual indexed 2388 * caches and and colors? 2389 */ 2390 VM_STAT_ADD(page_create_cnt[4]); 2391 /* 2392 * Get lgroup to allocate next page of shared memory 2393 * from and use it to specify where to allocate 2394 * the physical memory 2395 */ 2396 lgrp = lgrp_mem_choose(seg, vaddr, PAGESIZE); 2397 npp = page_get_freelist(vp, off, seg, vaddr, PAGESIZE, 2398 flags | PG_MATCH_COLOR, lgrp); 2399 if (npp == NULL) { 2400 npp = page_get_cachelist(vp, off, seg, 2401 vaddr, flags | PG_MATCH_COLOR, lgrp); 2402 if (npp == NULL) { 2403 npp = page_create_get_something(vp, 2404 off, seg, vaddr, 2405 flags & ~PG_MATCH_COLOR); 2406 } 2407 2408 if (PP_ISAGED(npp) == 0) { 2409 /* 2410 * Since this page came from the 2411 * cachelist, we must destroy the 2412 * old vnode association. 2413 */ 2414 page_hashout(npp, NULL); 2415 } 2416 } 2417 } 2418 2419 /* 2420 * We own this page! 2421 */ 2422 ASSERT(PAGE_EXCL(npp)); 2423 ASSERT(npp->p_vnode == NULL); 2424 ASSERT(!hat_page_is_mapped(npp)); 2425 PP_CLRFREE(npp); 2426 PP_CLRAGED(npp); 2427 2428 /* 2429 * Here we have a page in our hot little mits and are 2430 * just waiting to stuff it on the appropriate lists. 2431 * Get the mutex and check to see if it really does 2432 * not exist. 2433 */ 2434 phm = PAGE_HASH_MUTEX(index); 2435 mutex_enter(phm); 2436 PAGE_HASH_SEARCH(index, pp, vp, off); 2437 if (pp == NULL) { 2438 VM_STAT_ADD(page_create_new); 2439 pp = npp; 2440 npp = NULL; 2441 if (!page_hashin(pp, vp, off, phm)) { 2442 /* 2443 * Since we hold the page hash mutex and 2444 * just searched for this page, page_hashin 2445 * had better not fail. If it does, that 2446 * means somethread did not follow the 2447 * page hash mutex rules. Panic now and 2448 * get it over with. As usual, go down 2449 * holding all the locks. 2450 */ 2451 ASSERT(MUTEX_HELD(phm)); 2452 panic("page_create: " 2453 "hashin failed %p %p %llx %p", 2454 (void *)pp, (void *)vp, off, (void *)phm); 2455 /*NOTREACHED*/ 2456 } 2457 ASSERT(MUTEX_HELD(phm)); 2458 mutex_exit(phm); 2459 phm = NULL; 2460 2461 /* 2462 * Hat layer locking need not be done to set 2463 * the following bits since the page is not hashed 2464 * and was on the free list (i.e., had no mappings). 2465 * 2466 * Set the reference bit to protect 2467 * against immediate pageout 2468 * 2469 * XXXmh modify freelist code to set reference 2470 * bit so we don't have to do it here. 2471 */ 2472 page_set_props(pp, P_REF); 2473 found_on_free++; 2474 } else { 2475 VM_STAT_ADD(page_create_exists); 2476 if (flags & PG_EXCL) { 2477 /* 2478 * Found an existing page, and the caller 2479 * wanted all new pages. Undo all of the work 2480 * we have done. 2481 */ 2482 mutex_exit(phm); 2483 phm = NULL; 2484 while (plist != NULL) { 2485 pp = plist; 2486 page_sub(&plist, pp); 2487 page_io_unlock(pp); 2488 /* large pages should not end up here */ 2489 ASSERT(pp->p_szc == 0); 2490 /*LINTED: constant in conditional ctx*/ 2491 VN_DISPOSE(pp, B_INVAL, 0, kcred); 2492 } 2493 VM_STAT_ADD(page_create_found_one); 2494 goto fail; 2495 } 2496 ASSERT(flags & PG_WAIT); 2497 if (!page_lock(pp, SE_EXCL, phm, P_NO_RECLAIM)) { 2498 /* 2499 * Start all over again if we blocked trying 2500 * to lock the page. 2501 */ 2502 mutex_exit(phm); 2503 VM_STAT_ADD(page_create_page_lock_failed); 2504 phm = NULL; 2505 goto top; 2506 } 2507 mutex_exit(phm); 2508 phm = NULL; 2509 2510 if (PP_ISFREE(pp)) { 2511 ASSERT(PP_ISAGED(pp) == 0); 2512 VM_STAT_ADD(pagecnt.pc_get_cache); 2513 page_list_sub(pp, PG_CACHE_LIST); 2514 PP_CLRFREE(pp); 2515 found_on_free++; 2516 } 2517 } 2518 2519 /* 2520 * Got a page! It is locked. Acquire the i/o 2521 * lock since we are going to use the p_next and 2522 * p_prev fields to link the requested pages together. 2523 */ 2524 page_io_lock(pp); 2525 page_add(&plist, pp); 2526 plist = plist->p_next; 2527 off += PAGESIZE; 2528 vaddr += PAGESIZE; 2529 } 2530 2531 ASSERT((flags & PG_EXCL) ? (found_on_free == pages_req) : 1); 2532 fail: 2533 if (npp != NULL) { 2534 /* 2535 * Did not need this page after all. 2536 * Put it back on the free list. 2537 */ 2538 VM_STAT_ADD(page_create_putbacks); 2539 PP_SETFREE(npp); 2540 PP_SETAGED(npp); 2541 npp->p_offset = (u_offset_t)-1; 2542 page_list_add(npp, PG_FREE_LIST | PG_LIST_TAIL); 2543 page_unlock(npp); 2544 2545 } 2546 2547 ASSERT(pages_req >= found_on_free); 2548 2549 { 2550 uint_t overshoot = (uint_t)(pages_req - found_on_free); 2551 2552 if (overshoot) { 2553 VM_STAT_ADD(page_create_overshoot); 2554 p = &pcf[PCF_INDEX()]; 2555 mutex_enter(&p->pcf_lock); 2556 if (p->pcf_block) { 2557 p->pcf_reserve += overshoot; 2558 } else { 2559 p->pcf_count += overshoot; 2560 if (p->pcf_wait) { 2561 mutex_enter(&new_freemem_lock); 2562 if (freemem_wait) { 2563 cv_signal(&freemem_cv); 2564 p->pcf_wait--; 2565 } else { 2566 p->pcf_wait = 0; 2567 } 2568 mutex_exit(&new_freemem_lock); 2569 } 2570 } 2571 mutex_exit(&p->pcf_lock); 2572 /* freemem is approximate, so this test OK */ 2573 if (!p->pcf_block) 2574 freemem += overshoot; 2575 } 2576 } 2577 2578 return (plist); 2579 } 2580 2581 /* 2582 * One or more constituent pages of this large page has been marked 2583 * toxic. Simply demote the large page to PAGESIZE pages and let 2584 * page_free() handle it. This routine should only be called by 2585 * large page free routines (page_free_pages() and page_destroy_pages(). 2586 * All pages are locked SE_EXCL and have already been marked free. 2587 */ 2588 static void 2589 page_free_toxic_pages(page_t *rootpp) 2590 { 2591 page_t *tpp; 2592 pgcnt_t i, pgcnt = page_get_pagecnt(rootpp->p_szc); 2593 uint_t szc = rootpp->p_szc; 2594 2595 for (i = 0, tpp = rootpp; i < pgcnt; i++, tpp = tpp->p_next) { 2596 ASSERT(tpp->p_szc == szc); 2597 ASSERT((PAGE_EXCL(tpp) && 2598 !page_iolock_assert(tpp)) || panicstr); 2599 tpp->p_szc = 0; 2600 } 2601 2602 while (rootpp != NULL) { 2603 tpp = rootpp; 2604 page_sub(&rootpp, tpp); 2605 ASSERT(PP_ISFREE(tpp)); 2606 PP_CLRFREE(tpp); 2607 page_free(tpp, 1); 2608 } 2609 } 2610 2611 /* 2612 * Put page on the "free" list. 2613 * The free list is really two lists maintained by 2614 * the PSM of whatever machine we happen to be on. 2615 */ 2616 void 2617 page_free(page_t *pp, int dontneed) 2618 { 2619 struct pcf *p; 2620 uint_t pcf_index; 2621 2622 ASSERT((PAGE_EXCL(pp) && 2623 !page_iolock_assert(pp)) || panicstr); 2624 2625 if (PP_ISFREE(pp)) { 2626 panic("page_free: page %p is free", (void *)pp); 2627 } 2628 2629 if (pp->p_szc != 0) { 2630 if (pp->p_vnode == NULL || IS_SWAPFSVP(pp->p_vnode) || 2631 PP_ISKAS(pp)) { 2632 panic("page_free: anon or kernel " 2633 "or no vnode large page %p", (void *)pp); 2634 } 2635 page_demote_vp_pages(pp); 2636 ASSERT(pp->p_szc == 0); 2637 } 2638 2639 /* 2640 * The page_struct_lock need not be acquired to examine these 2641 * fields since the page has an "exclusive" lock. 2642 */ 2643 if (hat_page_is_mapped(pp) || pp->p_lckcnt != 0 || pp->p_cowcnt != 0 || 2644 pp->p_slckcnt != 0) { 2645 panic("page_free pp=%p, pfn=%lx, lckcnt=%d, cowcnt=%d " 2646 "slckcnt = %d", (void *)pp, page_pptonum(pp), pp->p_lckcnt, 2647 pp->p_cowcnt, pp->p_slckcnt); 2648 /*NOTREACHED*/ 2649 } 2650 2651 ASSERT(!hat_page_getshare(pp)); 2652 2653 PP_SETFREE(pp); 2654 ASSERT(pp->p_vnode == NULL || !IS_VMODSORT(pp->p_vnode) || 2655 !hat_ismod(pp)); 2656 page_clr_all_props(pp, 0); 2657 ASSERT(!hat_page_getshare(pp)); 2658 2659 /* 2660 * Now we add the page to the head of the free list. 2661 * But if this page is associated with a paged vnode 2662 * then we adjust the head forward so that the page is 2663 * effectively at the end of the list. 2664 */ 2665 if (pp->p_vnode == NULL) { 2666 /* 2667 * Page has no identity, put it on the free list. 2668 */ 2669 PP_SETAGED(pp); 2670 pp->p_offset = (u_offset_t)-1; 2671 page_list_add(pp, PG_FREE_LIST | PG_LIST_TAIL); 2672 VM_STAT_ADD(pagecnt.pc_free_free); 2673 TRACE_1(TR_FAC_VM, TR_PAGE_FREE_FREE, 2674 "page_free_free:pp %p", pp); 2675 } else { 2676 PP_CLRAGED(pp); 2677 2678 if (!dontneed || nopageage) { 2679 /* move it to the tail of the list */ 2680 page_list_add(pp, PG_CACHE_LIST | PG_LIST_TAIL); 2681 2682 VM_STAT_ADD(pagecnt.pc_free_cache); 2683 TRACE_1(TR_FAC_VM, TR_PAGE_FREE_CACHE_TAIL, 2684 "page_free_cache_tail:pp %p", pp); 2685 } else { 2686 page_list_add(pp, PG_CACHE_LIST | PG_LIST_HEAD); 2687 2688 VM_STAT_ADD(pagecnt.pc_free_dontneed); 2689 TRACE_1(TR_FAC_VM, TR_PAGE_FREE_CACHE_HEAD, 2690 "page_free_cache_head:pp %p", pp); 2691 } 2692 } 2693 page_unlock(pp); 2694 2695 /* 2696 * Now do the `freemem' accounting. 2697 */ 2698 pcf_index = PCF_INDEX(); 2699 p = &pcf[pcf_index]; 2700 2701 mutex_enter(&p->pcf_lock); 2702 if (p->pcf_block) { 2703 p->pcf_reserve += 1; 2704 } else { 2705 p->pcf_count += 1; 2706 if (p->pcf_wait) { 2707 mutex_enter(&new_freemem_lock); 2708 /* 2709 * Check to see if some other thread 2710 * is actually waiting. Another bucket 2711 * may have woken it up by now. If there 2712 * are no waiters, then set our pcf_wait 2713 * count to zero to avoid coming in here 2714 * next time. Also, since only one page 2715 * was put on the free list, just wake 2716 * up one waiter. 2717 */ 2718 if (freemem_wait) { 2719 cv_signal(&freemem_cv); 2720 p->pcf_wait--; 2721 } else { 2722 p->pcf_wait = 0; 2723 } 2724 mutex_exit(&new_freemem_lock); 2725 } 2726 } 2727 mutex_exit(&p->pcf_lock); 2728 2729 /* freemem is approximate, so this test OK */ 2730 if (!p->pcf_block) 2731 freemem += 1; 2732 } 2733 2734 /* 2735 * Put page on the "free" list during intial startup. 2736 * This happens during initial single threaded execution. 2737 */ 2738 void 2739 page_free_at_startup(page_t *pp) 2740 { 2741 struct pcf *p; 2742 uint_t pcf_index; 2743 2744 page_list_add(pp, PG_FREE_LIST | PG_LIST_HEAD | PG_LIST_ISINIT); 2745 VM_STAT_ADD(pagecnt.pc_free_free); 2746 2747 /* 2748 * Now do the `freemem' accounting. 2749 */ 2750 pcf_index = PCF_INDEX(); 2751 p = &pcf[pcf_index]; 2752 2753 ASSERT(p->pcf_block == 0); 2754 ASSERT(p->pcf_wait == 0); 2755 p->pcf_count += 1; 2756 2757 /* freemem is approximate, so this is OK */ 2758 freemem += 1; 2759 } 2760 2761 void 2762 page_free_pages(page_t *pp) 2763 { 2764 page_t *tpp, *rootpp = NULL; 2765 pgcnt_t pgcnt = page_get_pagecnt(pp->p_szc); 2766 pgcnt_t i; 2767 uint_t szc = pp->p_szc; 2768 2769 VM_STAT_ADD(pagecnt.pc_free_pages); 2770 TRACE_1(TR_FAC_VM, TR_PAGE_FREE_FREE, 2771 "page_free_free:pp %p", pp); 2772 2773 ASSERT(pp->p_szc != 0 && pp->p_szc < page_num_pagesizes()); 2774 if ((page_pptonum(pp) & (pgcnt - 1)) != 0) { 2775 panic("page_free_pages: not root page %p", (void *)pp); 2776 /*NOTREACHED*/ 2777 } 2778 2779 for (i = 0, tpp = pp; i < pgcnt; i++, tpp++) { 2780 ASSERT((PAGE_EXCL(tpp) && 2781 !page_iolock_assert(tpp)) || panicstr); 2782 if (PP_ISFREE(tpp)) { 2783 panic("page_free_pages: page %p is free", (void *)tpp); 2784 /*NOTREACHED*/ 2785 } 2786 if (hat_page_is_mapped(tpp) || tpp->p_lckcnt != 0 || 2787 tpp->p_cowcnt != 0 || tpp->p_slckcnt != 0) { 2788 panic("page_free_pages %p", (void *)tpp); 2789 /*NOTREACHED*/ 2790 } 2791 2792 ASSERT(!hat_page_getshare(tpp)); 2793 ASSERT(tpp->p_vnode == NULL); 2794 ASSERT(tpp->p_szc == szc); 2795 2796 PP_SETFREE(tpp); 2797 page_clr_all_props(tpp, 0); 2798 PP_SETAGED(tpp); 2799 tpp->p_offset = (u_offset_t)-1; 2800 ASSERT(tpp->p_next == tpp); 2801 ASSERT(tpp->p_prev == tpp); 2802 page_list_concat(&rootpp, &tpp); 2803 } 2804 ASSERT(rootpp == pp); 2805 2806 page_list_add_pages(rootpp, 0); 2807 page_create_putback(pgcnt); 2808 } 2809 2810 int free_pages = 1; 2811 2812 /* 2813 * This routine attempts to return pages to the cachelist via page_release(). 2814 * It does not *have* to be successful in all cases, since the pageout scanner 2815 * will catch any pages it misses. It does need to be fast and not introduce 2816 * too much overhead. 2817 * 2818 * If a page isn't found on the unlocked sweep of the page_hash bucket, we 2819 * don't lock and retry. This is ok, since the page scanner will eventually 2820 * find any page we miss in free_vp_pages(). 2821 */ 2822 void 2823 free_vp_pages(vnode_t *vp, u_offset_t off, size_t len) 2824 { 2825 page_t *pp; 2826 u_offset_t eoff; 2827 extern int swap_in_range(vnode_t *, u_offset_t, size_t); 2828 2829 eoff = off + len; 2830 2831 if (free_pages == 0) 2832 return; 2833 if (swap_in_range(vp, off, len)) 2834 return; 2835 2836 for (; off < eoff; off += PAGESIZE) { 2837 2838 /* 2839 * find the page using a fast, but inexact search. It'll be OK 2840 * if a few pages slip through the cracks here. 2841 */ 2842 pp = page_exists(vp, off); 2843 2844 /* 2845 * If we didn't find the page (it may not exist), the page 2846 * is free, looks still in use (shared), or we can't lock it, 2847 * just give up. 2848 */ 2849 if (pp == NULL || 2850 PP_ISFREE(pp) || 2851 page_share_cnt(pp) > 0 || 2852 !page_trylock(pp, SE_EXCL)) 2853 continue; 2854 2855 /* 2856 * Once we have locked pp, verify that it's still the 2857 * correct page and not already free 2858 */ 2859 ASSERT(PAGE_LOCKED_SE(pp, SE_EXCL)); 2860 if (pp->p_vnode != vp || pp->p_offset != off || PP_ISFREE(pp)) { 2861 page_unlock(pp); 2862 continue; 2863 } 2864 2865 /* 2866 * try to release the page... 2867 */ 2868 (void) page_release(pp, 1); 2869 } 2870 } 2871 2872 /* 2873 * Reclaim the given page from the free list. 2874 * If pp is part of a large pages, only the given constituent page is reclaimed 2875 * and the large page it belonged to will be demoted. This can only happen 2876 * if the page is not on the cachelist. 2877 * 2878 * Returns 1 on success or 0 on failure. 2879 * 2880 * The page is unlocked if it can't be reclaimed (when freemem == 0). 2881 * If `lock' is non-null, it will be dropped and re-acquired if 2882 * the routine must wait while freemem is 0. 2883 * 2884 * As it turns out, boot_getpages() does this. It picks a page, 2885 * based on where OBP mapped in some address, gets its pfn, searches 2886 * the memsegs, locks the page, then pulls it off the free list! 2887 */ 2888 int 2889 page_reclaim(page_t *pp, kmutex_t *lock) 2890 { 2891 struct pcf *p; 2892 struct cpu *cpup; 2893 int enough; 2894 uint_t i; 2895 2896 ASSERT(lock != NULL ? MUTEX_HELD(lock) : 1); 2897 ASSERT(PAGE_EXCL(pp) && PP_ISFREE(pp)); 2898 2899 /* 2900 * If `freemem' is 0, we cannot reclaim this page from the 2901 * freelist, so release every lock we might hold: the page, 2902 * and the `lock' before blocking. 2903 * 2904 * The only way `freemem' can become 0 while there are pages 2905 * marked free (have their p->p_free bit set) is when the 2906 * system is low on memory and doing a page_create(). In 2907 * order to guarantee that once page_create() starts acquiring 2908 * pages it will be able to get all that it needs since `freemem' 2909 * was decreased by the requested amount. So, we need to release 2910 * this page, and let page_create() have it. 2911 * 2912 * Since `freemem' being zero is not supposed to happen, just 2913 * use the usual hash stuff as a starting point. If that bucket 2914 * is empty, then assume the worst, and start at the beginning 2915 * of the pcf array. If we always start at the beginning 2916 * when acquiring more than one pcf lock, there won't be any 2917 * deadlock problems. 2918 */ 2919 2920 /* TODO: Do we need to test kcage_freemem if PG_NORELOC(pp)? */ 2921 2922 if (freemem <= throttlefree && !page_create_throttle(1l, 0)) { 2923 pcf_acquire_all(); 2924 goto page_reclaim_nomem; 2925 } 2926 2927 enough = pcf_decrement_bucket(1); 2928 2929 if (!enough) { 2930 VM_STAT_ADD(page_reclaim_zero); 2931 /* 2932 * Check again. Its possible that some other thread 2933 * could have been right behind us, and added one 2934 * to a list somewhere. Acquire each of the pcf locks 2935 * until we find a page. 2936 */ 2937 p = pcf; 2938 for (i = 0; i < pcf_fanout; i++) { 2939 mutex_enter(&p->pcf_lock); 2940 if (p->pcf_count >= 1) { 2941 p->pcf_count -= 1; 2942 enough = 1; 2943 break; 2944 } 2945 p++; 2946 } 2947 2948 if (!enough) { 2949 page_reclaim_nomem: 2950 /* 2951 * We really can't have page `pp'. 2952 * Time for the no-memory dance with 2953 * page_free(). This is just like 2954 * page_create_wait(). Plus the added 2955 * attraction of releasing whatever mutex 2956 * we held when we were called with in `lock'. 2957 * Page_unlock() will wakeup any thread 2958 * waiting around for this page. 2959 */ 2960 if (lock) { 2961 VM_STAT_ADD(page_reclaim_zero_locked); 2962 mutex_exit(lock); 2963 } 2964 page_unlock(pp); 2965 2966 /* 2967 * get this before we drop all the pcf locks. 2968 */ 2969 mutex_enter(&new_freemem_lock); 2970 2971 p = pcf; 2972 for (i = 0; i < pcf_fanout; i++) { 2973 p->pcf_wait++; 2974 mutex_exit(&p->pcf_lock); 2975 p++; 2976 } 2977 2978 freemem_wait++; 2979 cv_wait(&freemem_cv, &new_freemem_lock); 2980 freemem_wait--; 2981 2982 mutex_exit(&new_freemem_lock); 2983 2984 if (lock) { 2985 mutex_enter(lock); 2986 } 2987 return (0); 2988 } 2989 2990 /* 2991 * The pcf accounting has been done, 2992 * though none of the pcf_wait flags have been set, 2993 * drop the locks and continue on. 2994 */ 2995 while (p >= pcf) { 2996 mutex_exit(&p->pcf_lock); 2997 p--; 2998 } 2999 } 3000 3001 /* 3002 * freemem is not protected by any lock. Thus, we cannot 3003 * have any assertion containing freemem here. 3004 */ 3005 freemem -= 1; 3006 3007 VM_STAT_ADD(pagecnt.pc_reclaim); 3008 3009 /* 3010 * page_list_sub will handle the case where pp is a large page. 3011 * It's possible that the page was promoted while on the freelist 3012 */ 3013 if (PP_ISAGED(pp)) { 3014 page_list_sub(pp, PG_FREE_LIST); 3015 TRACE_1(TR_FAC_VM, TR_PAGE_UNFREE_FREE, 3016 "page_reclaim_free:pp %p", pp); 3017 } else { 3018 page_list_sub(pp, PG_CACHE_LIST); 3019 TRACE_1(TR_FAC_VM, TR_PAGE_UNFREE_CACHE, 3020 "page_reclaim_cache:pp %p", pp); 3021 } 3022 3023 /* 3024 * clear the p_free & p_age bits since this page is no longer 3025 * on the free list. Notice that there was a brief time where 3026 * a page is marked as free, but is not on the list. 3027 * 3028 * Set the reference bit to protect against immediate pageout. 3029 */ 3030 PP_CLRFREE(pp); 3031 PP_CLRAGED(pp); 3032 page_set_props(pp, P_REF); 3033 3034 CPU_STATS_ENTER_K(); 3035 cpup = CPU; /* get cpup now that CPU cannot change */ 3036 CPU_STATS_ADDQ(cpup, vm, pgrec, 1); 3037 CPU_STATS_ADDQ(cpup, vm, pgfrec, 1); 3038 CPU_STATS_EXIT_K(); 3039 ASSERT(pp->p_szc == 0); 3040 3041 return (1); 3042 } 3043 3044 /* 3045 * Destroy identity of the page and put it back on 3046 * the page free list. Assumes that the caller has 3047 * acquired the "exclusive" lock on the page. 3048 */ 3049 void 3050 page_destroy(page_t *pp, int dontfree) 3051 { 3052 ASSERT((PAGE_EXCL(pp) && 3053 !page_iolock_assert(pp)) || panicstr); 3054 ASSERT(pp->p_slckcnt == 0 || panicstr); 3055 3056 if (pp->p_szc != 0) { 3057 if (pp->p_vnode == NULL || IS_SWAPFSVP(pp->p_vnode) || 3058 PP_ISKAS(pp)) { 3059 panic("page_destroy: anon or kernel or no vnode " 3060 "large page %p", (void *)pp); 3061 } 3062 page_demote_vp_pages(pp); 3063 ASSERT(pp->p_szc == 0); 3064 } 3065 3066 TRACE_1(TR_FAC_VM, TR_PAGE_DESTROY, "page_destroy:pp %p", pp); 3067 3068 /* 3069 * Unload translations, if any, then hash out the 3070 * page to erase its identity. 3071 */ 3072 (void) hat_pageunload(pp, HAT_FORCE_PGUNLOAD); 3073 page_hashout(pp, NULL); 3074 3075 if (!dontfree) { 3076 /* 3077 * Acquire the "freemem_lock" for availrmem. 3078 * The page_struct_lock need not be acquired for lckcnt 3079 * and cowcnt since the page has an "exclusive" lock. 3080 * We are doing a modified version of page_pp_unlock here. 3081 */ 3082 if ((pp->p_lckcnt != 0) || (pp->p_cowcnt != 0)) { 3083 mutex_enter(&freemem_lock); 3084 if (pp->p_lckcnt != 0) { 3085 availrmem++; 3086 pages_locked--; 3087 pp->p_lckcnt = 0; 3088 } 3089 if (pp->p_cowcnt != 0) { 3090 availrmem += pp->p_cowcnt; 3091 pages_locked -= pp->p_cowcnt; 3092 pp->p_cowcnt = 0; 3093 } 3094 mutex_exit(&freemem_lock); 3095 } 3096 /* 3097 * Put the page on the "free" list. 3098 */ 3099 page_free(pp, 0); 3100 } 3101 } 3102 3103 void 3104 page_destroy_pages(page_t *pp) 3105 { 3106 3107 page_t *tpp, *rootpp = NULL; 3108 pgcnt_t pgcnt = page_get_pagecnt(pp->p_szc); 3109 pgcnt_t i, pglcks = 0; 3110 uint_t szc = pp->p_szc; 3111 3112 ASSERT(pp->p_szc != 0 && pp->p_szc < page_num_pagesizes()); 3113 3114 VM_STAT_ADD(pagecnt.pc_destroy_pages); 3115 3116 TRACE_1(TR_FAC_VM, TR_PAGE_DESTROY, "page_destroy_pages:pp %p", pp); 3117 3118 if ((page_pptonum(pp) & (pgcnt - 1)) != 0) { 3119 panic("page_destroy_pages: not root page %p", (void *)pp); 3120 /*NOTREACHED*/ 3121 } 3122 3123 for (i = 0, tpp = pp; i < pgcnt; i++, tpp++) { 3124 ASSERT((PAGE_EXCL(tpp) && 3125 !page_iolock_assert(tpp)) || panicstr); 3126 ASSERT(tpp->p_slckcnt == 0 || panicstr); 3127 (void) hat_pageunload(tpp, HAT_FORCE_PGUNLOAD); 3128 page_hashout(tpp, NULL); 3129 ASSERT(tpp->p_offset == (u_offset_t)-1); 3130 if (tpp->p_lckcnt != 0) { 3131 pglcks++; 3132 tpp->p_lckcnt = 0; 3133 } else if (tpp->p_cowcnt != 0) { 3134 pglcks += tpp->p_cowcnt; 3135 tpp->p_cowcnt = 0; 3136 } 3137 ASSERT(!hat_page_getshare(tpp)); 3138 ASSERT(tpp->p_vnode == NULL); 3139 ASSERT(tpp->p_szc == szc); 3140 3141 PP_SETFREE(tpp); 3142 page_clr_all_props(tpp, 0); 3143 PP_SETAGED(tpp); 3144 ASSERT(tpp->p_next == tpp); 3145 ASSERT(tpp->p_prev == tpp); 3146 page_list_concat(&rootpp, &tpp); 3147 } 3148 3149 ASSERT(rootpp == pp); 3150 if (pglcks != 0) { 3151 mutex_enter(&freemem_lock); 3152 availrmem += pglcks; 3153 mutex_exit(&freemem_lock); 3154 } 3155 3156 page_list_add_pages(rootpp, 0); 3157 page_create_putback(pgcnt); 3158 } 3159 3160 /* 3161 * Similar to page_destroy(), but destroys pages which are 3162 * locked and known to be on the page free list. Since 3163 * the page is known to be free and locked, no one can access 3164 * it. 3165 * 3166 * Also, the number of free pages does not change. 3167 */ 3168 void 3169 page_destroy_free(page_t *pp) 3170 { 3171 ASSERT(PAGE_EXCL(pp)); 3172 ASSERT(PP_ISFREE(pp)); 3173 ASSERT(pp->p_vnode); 3174 ASSERT(hat_page_getattr(pp, P_MOD | P_REF | P_RO) == 0); 3175 ASSERT(!hat_page_is_mapped(pp)); 3176 ASSERT(PP_ISAGED(pp) == 0); 3177 ASSERT(pp->p_szc == 0); 3178 3179 VM_STAT_ADD(pagecnt.pc_destroy_free); 3180 page_list_sub(pp, PG_CACHE_LIST); 3181 3182 page_hashout(pp, NULL); 3183 ASSERT(pp->p_vnode == NULL); 3184 ASSERT(pp->p_offset == (u_offset_t)-1); 3185 ASSERT(pp->p_hash == NULL); 3186 3187 PP_SETAGED(pp); 3188 page_list_add(pp, PG_FREE_LIST | PG_LIST_TAIL); 3189 page_unlock(pp); 3190 3191 mutex_enter(&new_freemem_lock); 3192 if (freemem_wait) { 3193 cv_signal(&freemem_cv); 3194 } 3195 mutex_exit(&new_freemem_lock); 3196 } 3197 3198 /* 3199 * Rename the page "opp" to have an identity specified 3200 * by [vp, off]. If a page already exists with this name 3201 * it is locked and destroyed. Note that the page's 3202 * translations are not unloaded during the rename. 3203 * 3204 * This routine is used by the anon layer to "steal" the 3205 * original page and is not unlike destroying a page and 3206 * creating a new page using the same page frame. 3207 * 3208 * XXX -- Could deadlock if caller 1 tries to rename A to B while 3209 * caller 2 tries to rename B to A. 3210 */ 3211 void 3212 page_rename(page_t *opp, vnode_t *vp, u_offset_t off) 3213 { 3214 page_t *pp; 3215 int olckcnt = 0; 3216 int ocowcnt = 0; 3217 kmutex_t *phm; 3218 ulong_t index; 3219 3220 ASSERT(PAGE_EXCL(opp) && !page_iolock_assert(opp)); 3221 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 3222 ASSERT(PP_ISFREE(opp) == 0); 3223 3224 VM_STAT_ADD(page_rename_count); 3225 3226 TRACE_3(TR_FAC_VM, TR_PAGE_RENAME, 3227 "page rename:pp %p vp %p off %llx", opp, vp, off); 3228 3229 /* 3230 * CacheFS may call page_rename for a large NFS page 3231 * when both CacheFS and NFS mount points are used 3232 * by applications. Demote this large page before 3233 * renaming it, to ensure that there are no "partial" 3234 * large pages left lying around. 3235 */ 3236 if (opp->p_szc != 0) { 3237 vnode_t *ovp = opp->p_vnode; 3238 ASSERT(ovp != NULL); 3239 ASSERT(!IS_SWAPFSVP(ovp)); 3240 ASSERT(!VN_ISKAS(ovp)); 3241 page_demote_vp_pages(opp); 3242 ASSERT(opp->p_szc == 0); 3243 } 3244 3245 page_hashout(opp, NULL); 3246 PP_CLRAGED(opp); 3247 3248 /* 3249 * Acquire the appropriate page hash lock, since 3250 * we're going to rename the page. 3251 */ 3252 index = PAGE_HASH_FUNC(vp, off); 3253 phm = PAGE_HASH_MUTEX(index); 3254 mutex_enter(phm); 3255 top: 3256 /* 3257 * Look for an existing page with this name and destroy it if found. 3258 * By holding the page hash lock all the way to the page_hashin() 3259 * call, we are assured that no page can be created with this 3260 * identity. In the case when the phm lock is dropped to undo any 3261 * hat layer mappings, the existing page is held with an "exclusive" 3262 * lock, again preventing another page from being created with 3263 * this identity. 3264 */ 3265 PAGE_HASH_SEARCH(index, pp, vp, off); 3266 if (pp != NULL) { 3267 VM_STAT_ADD(page_rename_exists); 3268 3269 /* 3270 * As it turns out, this is one of only two places where 3271 * page_lock() needs to hold the passed in lock in the 3272 * successful case. In all of the others, the lock could 3273 * be dropped as soon as the attempt is made to lock 3274 * the page. It is tempting to add yet another arguement, 3275 * PL_KEEP or PL_DROP, to let page_lock know what to do. 3276 */ 3277 if (!page_lock(pp, SE_EXCL, phm, P_RECLAIM)) { 3278 /* 3279 * Went to sleep because the page could not 3280 * be locked. We were woken up when the page 3281 * was unlocked, or when the page was destroyed. 3282 * In either case, `phm' was dropped while we 3283 * slept. Hence we should not just roar through 3284 * this loop. 3285 */ 3286 goto top; 3287 } 3288 3289 /* 3290 * If an existing page is a large page, then demote 3291 * it to ensure that no "partial" large pages are 3292 * "created" after page_rename. An existing page 3293 * can be a CacheFS page, and can't belong to swapfs. 3294 */ 3295 if (hat_page_is_mapped(pp)) { 3296 /* 3297 * Unload translations. Since we hold the 3298 * exclusive lock on this page, the page 3299 * can not be changed while we drop phm. 3300 * This is also not a lock protocol violation, 3301 * but rather the proper way to do things. 3302 */ 3303 mutex_exit(phm); 3304 (void) hat_pageunload(pp, HAT_FORCE_PGUNLOAD); 3305 if (pp->p_szc != 0) { 3306 ASSERT(!IS_SWAPFSVP(vp)); 3307 ASSERT(!VN_ISKAS(vp)); 3308 page_demote_vp_pages(pp); 3309 ASSERT(pp->p_szc == 0); 3310 } 3311 mutex_enter(phm); 3312 } else if (pp->p_szc != 0) { 3313 ASSERT(!IS_SWAPFSVP(vp)); 3314 ASSERT(!VN_ISKAS(vp)); 3315 mutex_exit(phm); 3316 page_demote_vp_pages(pp); 3317 ASSERT(pp->p_szc == 0); 3318 mutex_enter(phm); 3319 } 3320 page_hashout(pp, phm); 3321 } 3322 /* 3323 * Hash in the page with the new identity. 3324 */ 3325 if (!page_hashin(opp, vp, off, phm)) { 3326 /* 3327 * We were holding phm while we searched for [vp, off] 3328 * and only dropped phm if we found and locked a page. 3329 * If we can't create this page now, then some thing 3330 * is really broken. 3331 */ 3332 panic("page_rename: Can't hash in page: %p", (void *)pp); 3333 /*NOTREACHED*/ 3334 } 3335 3336 ASSERT(MUTEX_HELD(phm)); 3337 mutex_exit(phm); 3338 3339 /* 3340 * Now that we have dropped phm, lets get around to finishing up 3341 * with pp. 3342 */ 3343 if (pp != NULL) { 3344 ASSERT(!hat_page_is_mapped(pp)); 3345 /* for now large pages should not end up here */ 3346 ASSERT(pp->p_szc == 0); 3347 /* 3348 * Save the locks for transfer to the new page and then 3349 * clear them so page_free doesn't think they're important. 3350 * The page_struct_lock need not be acquired for lckcnt and 3351 * cowcnt since the page has an "exclusive" lock. 3352 */ 3353 olckcnt = pp->p_lckcnt; 3354 ocowcnt = pp->p_cowcnt; 3355 pp->p_lckcnt = pp->p_cowcnt = 0; 3356 3357 /* 3358 * Put the page on the "free" list after we drop 3359 * the lock. The less work under the lock the better. 3360 */ 3361 /*LINTED: constant in conditional context*/ 3362 VN_DISPOSE(pp, B_FREE, 0, kcred); 3363 } 3364 3365 /* 3366 * Transfer the lock count from the old page (if any). 3367 * The page_struct_lock need not be acquired for lckcnt and 3368 * cowcnt since the page has an "exclusive" lock. 3369 */ 3370 opp->p_lckcnt += olckcnt; 3371 opp->p_cowcnt += ocowcnt; 3372 } 3373 3374 /* 3375 * low level routine to add page `pp' to the hash and vp chains for [vp, offset] 3376 * 3377 * Pages are normally inserted at the start of a vnode's v_pages list. 3378 * If the vnode is VMODSORT and the page is modified, it goes at the end. 3379 * This can happen when a modified page is relocated for DR. 3380 * 3381 * Returns 1 on success and 0 on failure. 3382 */ 3383 static int 3384 page_do_hashin(page_t *pp, vnode_t *vp, u_offset_t offset) 3385 { 3386 page_t **listp; 3387 page_t *tp; 3388 ulong_t index; 3389 3390 ASSERT(PAGE_EXCL(pp)); 3391 ASSERT(vp != NULL); 3392 ASSERT(MUTEX_HELD(page_vnode_mutex(vp))); 3393 3394 /* 3395 * Be sure to set these up before the page is inserted on the hash 3396 * list. As soon as the page is placed on the list some other 3397 * thread might get confused and wonder how this page could 3398 * possibly hash to this list. 3399 */ 3400 pp->p_vnode = vp; 3401 pp->p_offset = offset; 3402 3403 /* 3404 * record if this page is on a swap vnode 3405 */ 3406 if ((vp->v_flag & VISSWAP) != 0) 3407 PP_SETSWAP(pp); 3408 3409 index = PAGE_HASH_FUNC(vp, offset); 3410 ASSERT(MUTEX_HELD(PAGE_HASH_MUTEX(index))); 3411 listp = &page_hash[index]; 3412 3413 /* 3414 * If this page is already hashed in, fail this attempt to add it. 3415 */ 3416 for (tp = *listp; tp != NULL; tp = tp->p_hash) { 3417 if (tp->p_vnode == vp && tp->p_offset == offset) { 3418 pp->p_vnode = NULL; 3419 pp->p_offset = (u_offset_t)(-1); 3420 return (0); 3421 } 3422 } 3423 pp->p_hash = *listp; 3424 *listp = pp; 3425 3426 /* 3427 * Add the page to the vnode's list of pages 3428 */ 3429 if (vp->v_pages != NULL && IS_VMODSORT(vp) && hat_ismod(pp)) 3430 listp = &vp->v_pages->p_vpprev->p_vpnext; 3431 else 3432 listp = &vp->v_pages; 3433 3434 page_vpadd(listp, pp); 3435 3436 return (1); 3437 } 3438 3439 /* 3440 * Add page `pp' to both the hash and vp chains for [vp, offset]. 3441 * 3442 * Returns 1 on success and 0 on failure. 3443 * If hold is passed in, it is not dropped. 3444 */ 3445 int 3446 page_hashin(page_t *pp, vnode_t *vp, u_offset_t offset, kmutex_t *hold) 3447 { 3448 kmutex_t *phm = NULL; 3449 kmutex_t *vphm; 3450 int rc; 3451 3452 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(vp))); 3453 ASSERT(pp->p_fsdata == 0 || panicstr); 3454 3455 TRACE_3(TR_FAC_VM, TR_PAGE_HASHIN, 3456 "page_hashin:pp %p vp %p offset %llx", 3457 pp, vp, offset); 3458 3459 VM_STAT_ADD(hashin_count); 3460 3461 if (hold != NULL) 3462 phm = hold; 3463 else { 3464 VM_STAT_ADD(hashin_not_held); 3465 phm = PAGE_HASH_MUTEX(PAGE_HASH_FUNC(vp, offset)); 3466 mutex_enter(phm); 3467 } 3468 3469 vphm = page_vnode_mutex(vp); 3470 mutex_enter(vphm); 3471 rc = page_do_hashin(pp, vp, offset); 3472 mutex_exit(vphm); 3473 if (hold == NULL) 3474 mutex_exit(phm); 3475 if (rc == 0) 3476 VM_STAT_ADD(hashin_already); 3477 return (rc); 3478 } 3479 3480 /* 3481 * Remove page ``pp'' from the hash and vp chains and remove vp association. 3482 * All mutexes must be held 3483 */ 3484 static void 3485 page_do_hashout(page_t *pp) 3486 { 3487 page_t **hpp; 3488 page_t *hp; 3489 vnode_t *vp = pp->p_vnode; 3490 3491 ASSERT(vp != NULL); 3492 ASSERT(MUTEX_HELD(page_vnode_mutex(vp))); 3493 3494 /* 3495 * First, take pp off of its hash chain. 3496 */ 3497 hpp = &page_hash[PAGE_HASH_FUNC(vp, pp->p_offset)]; 3498 3499 for (;;) { 3500 hp = *hpp; 3501 if (hp == pp) 3502 break; 3503 if (hp == NULL) { 3504 panic("page_do_hashout"); 3505 /*NOTREACHED*/ 3506 } 3507 hpp = &hp->p_hash; 3508 } 3509 *hpp = pp->p_hash; 3510 3511 /* 3512 * Now remove it from its associated vnode. 3513 */ 3514 if (vp->v_pages) 3515 page_vpsub(&vp->v_pages, pp); 3516 3517 pp->p_hash = NULL; 3518 page_clr_all_props(pp, 1); 3519 PP_CLRSWAP(pp); 3520 pp->p_vnode = NULL; 3521 pp->p_offset = (u_offset_t)-1; 3522 pp->p_fsdata = 0; 3523 } 3524 3525 /* 3526 * Remove page ``pp'' from the hash and vp chains and remove vp association. 3527 * 3528 * When `phm' is non-NULL it contains the address of the mutex protecting the 3529 * hash list pp is on. It is not dropped. 3530 */ 3531 void 3532 page_hashout(page_t *pp, kmutex_t *phm) 3533 { 3534 vnode_t *vp; 3535 ulong_t index; 3536 kmutex_t *nphm; 3537 kmutex_t *vphm; 3538 kmutex_t *sep; 3539 3540 ASSERT(phm != NULL ? MUTEX_HELD(phm) : 1); 3541 ASSERT(pp->p_vnode != NULL); 3542 ASSERT((PAGE_EXCL(pp) && !page_iolock_assert(pp)) || panicstr); 3543 ASSERT(MUTEX_NOT_HELD(page_vnode_mutex(pp->p_vnode))); 3544 3545 vp = pp->p_vnode; 3546 3547 TRACE_2(TR_FAC_VM, TR_PAGE_HASHOUT, 3548 "page_hashout:pp %p vp %p", pp, vp); 3549 3550 /* Kernel probe */ 3551 TNF_PROBE_2(page_unmap, "vm pagefault", /* CSTYLED */, 3552 tnf_opaque, vnode, vp, 3553 tnf_offset, offset, pp->p_offset); 3554 3555 /* 3556 * 3557 */ 3558 VM_STAT_ADD(hashout_count); 3559 index = PAGE_HASH_FUNC(vp, pp->p_offset); 3560 if (phm == NULL) { 3561 VM_STAT_ADD(hashout_not_held); 3562 nphm = PAGE_HASH_MUTEX(index); 3563 mutex_enter(nphm); 3564 } 3565 ASSERT(phm ? phm == PAGE_HASH_MUTEX(index) : 1); 3566 3567 3568 /* 3569 * grab page vnode mutex and remove it... 3570 */ 3571 vphm = page_vnode_mutex(vp); 3572 mutex_enter(vphm); 3573 3574 page_do_hashout(pp); 3575 3576 mutex_exit(vphm); 3577 if (phm == NULL) 3578 mutex_exit(nphm); 3579 3580 /* 3581 * Wake up processes waiting for this page. The page's 3582 * identity has been changed, and is probably not the 3583 * desired page any longer. 3584 */ 3585 sep = page_se_mutex(pp); 3586 mutex_enter(sep); 3587 pp->p_selock &= ~SE_EWANTED; 3588 if (CV_HAS_WAITERS(&pp->p_cv)) 3589 cv_broadcast(&pp->p_cv); 3590 mutex_exit(sep); 3591 } 3592 3593 /* 3594 * Add the page to the front of a linked list of pages 3595 * using the p_next & p_prev pointers for the list. 3596 * The caller is responsible for protecting the list pointers. 3597 */ 3598 void 3599 page_add(page_t **ppp, page_t *pp) 3600 { 3601 ASSERT(PAGE_EXCL(pp) || (PAGE_SHARED(pp) && page_iolock_assert(pp))); 3602 3603 page_add_common(ppp, pp); 3604 } 3605 3606 3607 3608 /* 3609 * Common code for page_add() and mach_page_add() 3610 */ 3611 void 3612 page_add_common(page_t **ppp, page_t *pp) 3613 { 3614 if (*ppp == NULL) { 3615 pp->p_next = pp->p_prev = pp; 3616 } else { 3617 pp->p_next = *ppp; 3618 pp->p_prev = (*ppp)->p_prev; 3619 (*ppp)->p_prev = pp; 3620 pp->p_prev->p_next = pp; 3621 } 3622 *ppp = pp; 3623 } 3624 3625 3626 /* 3627 * Remove this page from a linked list of pages 3628 * using the p_next & p_prev pointers for the list. 3629 * 3630 * The caller is responsible for protecting the list pointers. 3631 */ 3632 void 3633 page_sub(page_t **ppp, page_t *pp) 3634 { 3635 ASSERT((PP_ISFREE(pp)) ? 1 : 3636 (PAGE_EXCL(pp)) || (PAGE_SHARED(pp) && page_iolock_assert(pp))); 3637 3638 if (*ppp == NULL || pp == NULL) { 3639 panic("page_sub: bad arg(s): pp %p, *ppp %p", 3640 (void *)pp, (void *)(*ppp)); 3641 /*NOTREACHED*/ 3642 } 3643 3644 page_sub_common(ppp, pp); 3645 } 3646 3647 3648 /* 3649 * Common code for page_sub() and mach_page_sub() 3650 */ 3651 void 3652 page_sub_common(page_t **ppp, page_t *pp) 3653 { 3654 if (*ppp == pp) 3655 *ppp = pp->p_next; /* go to next page */ 3656 3657 if (*ppp == pp) 3658 *ppp = NULL; /* page list is gone */ 3659 else { 3660 pp->p_prev->p_next = pp->p_next; 3661 pp->p_next->p_prev = pp->p_prev; 3662 } 3663 pp->p_prev = pp->p_next = pp; /* make pp a list of one */ 3664 } 3665 3666 3667 /* 3668 * Break page list cppp into two lists with npages in the first list. 3669 * The tail is returned in nppp. 3670 */ 3671 void 3672 page_list_break(page_t **oppp, page_t **nppp, pgcnt_t npages) 3673 { 3674 page_t *s1pp = *oppp; 3675 page_t *s2pp; 3676 page_t *e1pp, *e2pp; 3677 long n = 0; 3678 3679 if (s1pp == NULL) { 3680 *nppp = NULL; 3681 return; 3682 } 3683 if (npages == 0) { 3684 *nppp = s1pp; 3685 *oppp = NULL; 3686 return; 3687 } 3688 for (n = 0, s2pp = *oppp; n < npages; n++) { 3689 s2pp = s2pp->p_next; 3690 } 3691 /* Fix head and tail of new lists */ 3692 e1pp = s2pp->p_prev; 3693 e2pp = s1pp->p_prev; 3694 s1pp->p_prev = e1pp; 3695 e1pp->p_next = s1pp; 3696 s2pp->p_prev = e2pp; 3697 e2pp->p_next = s2pp; 3698 3699 /* second list empty */ 3700 if (s2pp == s1pp) { 3701 *oppp = s1pp; 3702 *nppp = NULL; 3703 } else { 3704 *oppp = s1pp; 3705 *nppp = s2pp; 3706 } 3707 } 3708 3709 /* 3710 * Concatenate page list nppp onto the end of list ppp. 3711 */ 3712 void 3713 page_list_concat(page_t **ppp, page_t **nppp) 3714 { 3715 page_t *s1pp, *s2pp, *e1pp, *e2pp; 3716 3717 if (*nppp == NULL) { 3718 return; 3719 } 3720 if (*ppp == NULL) { 3721 *ppp = *nppp; 3722 return; 3723 } 3724 s1pp = *ppp; 3725 e1pp = s1pp->p_prev; 3726 s2pp = *nppp; 3727 e2pp = s2pp->p_prev; 3728 s1pp->p_prev = e2pp; 3729 e2pp->p_next = s1pp; 3730 e1pp->p_next = s2pp; 3731 s2pp->p_prev = e1pp; 3732 } 3733 3734 /* 3735 * return the next page in the page list 3736 */ 3737 page_t * 3738 page_list_next(page_t *pp) 3739 { 3740 return (pp->p_next); 3741 } 3742 3743 3744 /* 3745 * Add the page to the front of the linked list of pages 3746 * using p_vpnext/p_vpprev pointers for the list. 3747 * 3748 * The caller is responsible for protecting the lists. 3749 */ 3750 void 3751 page_vpadd(page_t **ppp, page_t *pp) 3752 { 3753 if (*ppp == NULL) { 3754 pp->p_vpnext = pp->p_vpprev = pp; 3755 } else { 3756 pp->p_vpnext = *ppp; 3757 pp->p_vpprev = (*ppp)->p_vpprev; 3758 (*ppp)->p_vpprev = pp; 3759 pp->p_vpprev->p_vpnext = pp; 3760 } 3761 *ppp = pp; 3762 } 3763 3764 /* 3765 * Remove this page from the linked list of pages 3766 * using p_vpnext/p_vpprev pointers for the list. 3767 * 3768 * The caller is responsible for protecting the lists. 3769 */ 3770 void 3771 page_vpsub(page_t **ppp, page_t *pp) 3772 { 3773 if (*ppp == NULL || pp == NULL) { 3774 panic("page_vpsub: bad arg(s): pp %p, *ppp %p", 3775 (void *)pp, (void *)(*ppp)); 3776 /*NOTREACHED*/ 3777 } 3778 3779 if (*ppp == pp) 3780 *ppp = pp->p_vpnext; /* go to next page */ 3781 3782 if (*ppp == pp) 3783 *ppp = NULL; /* page list is gone */ 3784 else { 3785 pp->p_vpprev->p_vpnext = pp->p_vpnext; 3786 pp->p_vpnext->p_vpprev = pp->p_vpprev; 3787 } 3788 pp->p_vpprev = pp->p_vpnext = pp; /* make pp a list of one */ 3789 } 3790 3791 /* 3792 * Lock a physical page into memory "long term". Used to support "lock 3793 * in memory" functions. Accepts the page to be locked, and a cow variable 3794 * to indicate whether a the lock will travel to the new page during 3795 * a potential copy-on-write. 3796 */ 3797 int 3798 page_pp_lock( 3799 page_t *pp, /* page to be locked */ 3800 int cow, /* cow lock */ 3801 int kernel) /* must succeed -- ignore checking */ 3802 { 3803 int r = 0; /* result -- assume failure */ 3804 3805 ASSERT(PAGE_LOCKED(pp)); 3806 3807 page_struct_lock(pp); 3808 /* 3809 * Acquire the "freemem_lock" for availrmem. 3810 */ 3811 if (cow) { 3812 mutex_enter(&freemem_lock); 3813 if ((availrmem > pages_pp_maximum) && 3814 (pp->p_cowcnt < (ushort_t)PAGE_LOCK_MAXIMUM)) { 3815 availrmem--; 3816 pages_locked++; 3817 mutex_exit(&freemem_lock); 3818 r = 1; 3819 if (++pp->p_cowcnt == (ushort_t)PAGE_LOCK_MAXIMUM) { 3820 cmn_err(CE_WARN, 3821 "COW lock limit reached on pfn 0x%lx", 3822 page_pptonum(pp)); 3823 } 3824 } else 3825 mutex_exit(&freemem_lock); 3826 } else { 3827 if (pp->p_lckcnt) { 3828 if (pp->p_lckcnt < (ushort_t)PAGE_LOCK_MAXIMUM) { 3829 r = 1; 3830 if (++pp->p_lckcnt == 3831 (ushort_t)PAGE_LOCK_MAXIMUM) { 3832 cmn_err(CE_WARN, "Page lock limit " 3833 "reached on pfn 0x%lx", 3834 page_pptonum(pp)); 3835 } 3836 } 3837 } else { 3838 if (kernel) { 3839 /* availrmem accounting done by caller */ 3840 ++pp->p_lckcnt; 3841 r = 1; 3842 } else { 3843 mutex_enter(&freemem_lock); 3844 if (availrmem > pages_pp_maximum) { 3845 availrmem--; 3846 pages_locked++; 3847 ++pp->p_lckcnt; 3848 r = 1; 3849 } 3850 mutex_exit(&freemem_lock); 3851 } 3852 } 3853 } 3854 page_struct_unlock(pp); 3855 return (r); 3856 } 3857 3858 /* 3859 * Decommit a lock on a physical page frame. Account for cow locks if 3860 * appropriate. 3861 */ 3862 void 3863 page_pp_unlock( 3864 page_t *pp, /* page to be unlocked */ 3865 int cow, /* expect cow lock */ 3866 int kernel) /* this was a kernel lock */ 3867 { 3868 ASSERT(PAGE_LOCKED(pp)); 3869 3870 page_struct_lock(pp); 3871 /* 3872 * Acquire the "freemem_lock" for availrmem. 3873 * If cowcnt or lcknt is already 0 do nothing; i.e., we 3874 * could be called to unlock even if nothing is locked. This could 3875 * happen if locked file pages were truncated (removing the lock) 3876 * and the file was grown again and new pages faulted in; the new 3877 * pages are unlocked but the segment still thinks they're locked. 3878 */ 3879 if (cow) { 3880 if (pp->p_cowcnt) { 3881 mutex_enter(&freemem_lock); 3882 pp->p_cowcnt--; 3883 availrmem++; 3884 pages_locked--; 3885 mutex_exit(&freemem_lock); 3886 } 3887 } else { 3888 if (pp->p_lckcnt && --pp->p_lckcnt == 0) { 3889 if (!kernel) { 3890 mutex_enter(&freemem_lock); 3891 availrmem++; 3892 pages_locked--; 3893 mutex_exit(&freemem_lock); 3894 } 3895 } 3896 } 3897 page_struct_unlock(pp); 3898 } 3899 3900 /* 3901 * This routine reserves availrmem for npages; 3902 * flags: KM_NOSLEEP or KM_SLEEP 3903 * returns 1 on success or 0 on failure 3904 */ 3905 int 3906 page_resv(pgcnt_t npages, uint_t flags) 3907 { 3908 mutex_enter(&freemem_lock); 3909 while (availrmem < tune.t_minarmem + npages) { 3910 if (flags & KM_NOSLEEP) { 3911 mutex_exit(&freemem_lock); 3912 return (0); 3913 } 3914 mutex_exit(&freemem_lock); 3915 page_needfree(npages); 3916 kmem_reap(); 3917 delay(hz >> 2); 3918 page_needfree(-(spgcnt_t)npages); 3919 mutex_enter(&freemem_lock); 3920 } 3921 availrmem -= npages; 3922 mutex_exit(&freemem_lock); 3923 return (1); 3924 } 3925 3926 /* 3927 * This routine unreserves availrmem for npages; 3928 */ 3929 void 3930 page_unresv(pgcnt_t npages) 3931 { 3932 mutex_enter(&freemem_lock); 3933 availrmem += npages; 3934 mutex_exit(&freemem_lock); 3935 } 3936 3937 /* 3938 * See Statement at the beginning of segvn_lockop() regarding 3939 * the way we handle cowcnts and lckcnts. 3940 * 3941 * Transfer cowcnt on 'opp' to cowcnt on 'npp' if the vpage 3942 * that breaks COW has PROT_WRITE. 3943 * 3944 * Note that, we may also break COW in case we are softlocking 3945 * on read access during physio; 3946 * in this softlock case, the vpage may not have PROT_WRITE. 3947 * So, we need to transfer lckcnt on 'opp' to lckcnt on 'npp' 3948 * if the vpage doesn't have PROT_WRITE. 3949 * 3950 * This routine is never called if we are stealing a page 3951 * in anon_private. 3952 * 3953 * The caller subtracted from availrmem for read only mapping. 3954 * if lckcnt is 1 increment availrmem. 3955 */ 3956 void 3957 page_pp_useclaim( 3958 page_t *opp, /* original page frame losing lock */ 3959 page_t *npp, /* new page frame gaining lock */ 3960 uint_t write_perm) /* set if vpage has PROT_WRITE */ 3961 { 3962 int payback = 0; 3963 3964 ASSERT(PAGE_LOCKED(opp)); 3965 ASSERT(PAGE_LOCKED(npp)); 3966 3967 page_struct_lock(opp); 3968 3969 ASSERT(npp->p_cowcnt == 0); 3970 ASSERT(npp->p_lckcnt == 0); 3971 3972 /* Don't use claim if nothing is locked (see page_pp_unlock above) */ 3973 if ((write_perm && opp->p_cowcnt != 0) || 3974 (!write_perm && opp->p_lckcnt != 0)) { 3975 3976 if (write_perm) { 3977 npp->p_cowcnt++; 3978 ASSERT(opp->p_cowcnt != 0); 3979 opp->p_cowcnt--; 3980 } else { 3981 3982 ASSERT(opp->p_lckcnt != 0); 3983 3984 /* 3985 * We didn't need availrmem decremented if p_lckcnt on 3986 * original page is 1. Here, we are unlocking 3987 * read-only copy belonging to original page and 3988 * are locking a copy belonging to new page. 3989 */ 3990 if (opp->p_lckcnt == 1) 3991 payback = 1; 3992 3993 npp->p_lckcnt++; 3994 opp->p_lckcnt--; 3995 } 3996 } 3997 if (payback) { 3998 mutex_enter(&freemem_lock); 3999 availrmem++; 4000 pages_useclaim--; 4001 mutex_exit(&freemem_lock); 4002 } 4003 page_struct_unlock(opp); 4004 } 4005 4006 /* 4007 * Simple claim adjust functions -- used to support changes in 4008 * claims due to changes in access permissions. Used by segvn_setprot(). 4009 */ 4010 int 4011 page_addclaim(page_t *pp) 4012 { 4013 int r = 0; /* result */ 4014 4015 ASSERT(PAGE_LOCKED(pp)); 4016 4017 page_struct_lock(pp); 4018 ASSERT(pp->p_lckcnt != 0); 4019 4020 if (pp->p_lckcnt == 1) { 4021 if (pp->p_cowcnt < (ushort_t)PAGE_LOCK_MAXIMUM) { 4022 --pp->p_lckcnt; 4023 r = 1; 4024 if (++pp->p_cowcnt == (ushort_t)PAGE_LOCK_MAXIMUM) { 4025 cmn_err(CE_WARN, 4026 "COW lock limit reached on pfn 0x%lx", 4027 page_pptonum(pp)); 4028 } 4029 } 4030 } else { 4031 mutex_enter(&freemem_lock); 4032 if ((availrmem > pages_pp_maximum) && 4033 (pp->p_cowcnt < (ushort_t)PAGE_LOCK_MAXIMUM)) { 4034 --availrmem; 4035 ++pages_claimed; 4036 mutex_exit(&freemem_lock); 4037 --pp->p_lckcnt; 4038 r = 1; 4039 if (++pp->p_cowcnt == (ushort_t)PAGE_LOCK_MAXIMUM) { 4040 cmn_err(CE_WARN, 4041 "COW lock limit reached on pfn 0x%lx", 4042 page_pptonum(pp)); 4043 } 4044 } else 4045 mutex_exit(&freemem_lock); 4046 } 4047 page_struct_unlock(pp); 4048 return (r); 4049 } 4050 4051 int 4052 page_subclaim(page_t *pp) 4053 { 4054 int r = 0; 4055 4056 ASSERT(PAGE_LOCKED(pp)); 4057 4058 page_struct_lock(pp); 4059 ASSERT(pp->p_cowcnt != 0); 4060 4061 if (pp->p_lckcnt) { 4062 if (pp->p_lckcnt < (ushort_t)PAGE_LOCK_MAXIMUM) { 4063 r = 1; 4064 /* 4065 * for availrmem 4066 */ 4067 mutex_enter(&freemem_lock); 4068 availrmem++; 4069 pages_claimed--; 4070 mutex_exit(&freemem_lock); 4071 4072 pp->p_cowcnt--; 4073 4074 if (++pp->p_lckcnt == (ushort_t)PAGE_LOCK_MAXIMUM) { 4075 cmn_err(CE_WARN, 4076 "Page lock limit reached on pfn 0x%lx", 4077 page_pptonum(pp)); 4078 } 4079 } 4080 } else { 4081 r = 1; 4082 pp->p_cowcnt--; 4083 pp->p_lckcnt++; 4084 } 4085 page_struct_unlock(pp); 4086 return (r); 4087 } 4088 4089 int 4090 page_addclaim_pages(page_t **ppa) 4091 { 4092 4093 pgcnt_t lckpgs = 0, pg_idx; 4094 4095 VM_STAT_ADD(pagecnt.pc_addclaim_pages); 4096 4097 mutex_enter(&page_llock); 4098 for (pg_idx = 0; ppa[pg_idx] != NULL; pg_idx++) { 4099 4100 ASSERT(PAGE_LOCKED(ppa[pg_idx])); 4101 ASSERT(ppa[pg_idx]->p_lckcnt != 0); 4102 if (ppa[pg_idx]->p_cowcnt == (ushort_t)PAGE_LOCK_MAXIMUM) { 4103 mutex_exit(&page_llock); 4104 return (0); 4105 } 4106 if (ppa[pg_idx]->p_lckcnt > 1) 4107 lckpgs++; 4108 } 4109 4110 if (lckpgs != 0) { 4111 mutex_enter(&freemem_lock); 4112 if (availrmem >= pages_pp_maximum + lckpgs) { 4113 availrmem -= lckpgs; 4114 pages_claimed += lckpgs; 4115 } else { 4116 mutex_exit(&freemem_lock); 4117 mutex_exit(&page_llock); 4118 return (0); 4119 } 4120 mutex_exit(&freemem_lock); 4121 } 4122 4123 for (pg_idx = 0; ppa[pg_idx] != NULL; pg_idx++) { 4124 ppa[pg_idx]->p_lckcnt--; 4125 ppa[pg_idx]->p_cowcnt++; 4126 } 4127 mutex_exit(&page_llock); 4128 return (1); 4129 } 4130 4131 int 4132 page_subclaim_pages(page_t **ppa) 4133 { 4134 pgcnt_t ulckpgs = 0, pg_idx; 4135 4136 VM_STAT_ADD(pagecnt.pc_subclaim_pages); 4137 4138 mutex_enter(&page_llock); 4139 for (pg_idx = 0; ppa[pg_idx] != NULL; pg_idx++) { 4140 4141 ASSERT(PAGE_LOCKED(ppa[pg_idx])); 4142 ASSERT(ppa[pg_idx]->p_cowcnt != 0); 4143 if (ppa[pg_idx]->p_lckcnt == (ushort_t)PAGE_LOCK_MAXIMUM) { 4144 mutex_exit(&page_llock); 4145 return (0); 4146 } 4147 if (ppa[pg_idx]->p_lckcnt != 0) 4148 ulckpgs++; 4149 } 4150 4151 if (ulckpgs != 0) { 4152 mutex_enter(&freemem_lock); 4153 availrmem += ulckpgs; 4154 pages_claimed -= ulckpgs; 4155 mutex_exit(&freemem_lock); 4156 } 4157 4158 for (pg_idx = 0; ppa[pg_idx] != NULL; pg_idx++) { 4159 ppa[pg_idx]->p_cowcnt--; 4160 ppa[pg_idx]->p_lckcnt++; 4161 4162 } 4163 mutex_exit(&page_llock); 4164 return (1); 4165 } 4166 4167 page_t * 4168 page_numtopp(pfn_t pfnum, se_t se) 4169 { 4170 page_t *pp; 4171 4172 retry: 4173 pp = page_numtopp_nolock(pfnum); 4174 if (pp == NULL) { 4175 return ((page_t *)NULL); 4176 } 4177 4178 /* 4179 * Acquire the appropriate lock on the page. 4180 */ 4181 while (!page_lock(pp, se, (kmutex_t *)NULL, P_RECLAIM)) { 4182 if (page_pptonum(pp) != pfnum) 4183 goto retry; 4184 continue; 4185 } 4186 4187 if (page_pptonum(pp) != pfnum) { 4188 page_unlock(pp); 4189 goto retry; 4190 } 4191 4192 return (pp); 4193 } 4194 4195 page_t * 4196 page_numtopp_noreclaim(pfn_t pfnum, se_t se) 4197 { 4198 page_t *pp; 4199 4200 retry: 4201 pp = page_numtopp_nolock(pfnum); 4202 if (pp == NULL) { 4203 return ((page_t *)NULL); 4204 } 4205 4206 /* 4207 * Acquire the appropriate lock on the page. 4208 */ 4209 while (!page_lock(pp, se, (kmutex_t *)NULL, P_NO_RECLAIM)) { 4210 if (page_pptonum(pp) != pfnum) 4211 goto retry; 4212 continue; 4213 } 4214 4215 if (page_pptonum(pp) != pfnum) { 4216 page_unlock(pp); 4217 goto retry; 4218 } 4219 4220 return (pp); 4221 } 4222 4223 /* 4224 * This routine is like page_numtopp, but will only return page structs 4225 * for pages which are ok for loading into hardware using the page struct. 4226 */ 4227 page_t * 4228 page_numtopp_nowait(pfn_t pfnum, se_t se) 4229 { 4230 page_t *pp; 4231 4232 retry: 4233 pp = page_numtopp_nolock(pfnum); 4234 if (pp == NULL) { 4235 return ((page_t *)NULL); 4236 } 4237 4238 /* 4239 * Try to acquire the appropriate lock on the page. 4240 */ 4241 if (PP_ISFREE(pp)) 4242 pp = NULL; 4243 else { 4244 if (!page_trylock(pp, se)) 4245 pp = NULL; 4246 else { 4247 if (page_pptonum(pp) != pfnum) { 4248 page_unlock(pp); 4249 goto retry; 4250 } 4251 if (PP_ISFREE(pp)) { 4252 page_unlock(pp); 4253 pp = NULL; 4254 } 4255 } 4256 } 4257 return (pp); 4258 } 4259 4260 /* 4261 * Returns a count of dirty pages that are in the process 4262 * of being written out. If 'cleanit' is set, try to push the page. 4263 */ 4264 pgcnt_t 4265 page_busy(int cleanit) 4266 { 4267 page_t *page0 = page_first(); 4268 page_t *pp = page0; 4269 pgcnt_t nppbusy = 0; 4270 u_offset_t off; 4271 4272 do { 4273 vnode_t *vp = pp->p_vnode; 4274 4275 /* 4276 * A page is a candidate for syncing if it is: 4277 * 4278 * (a) On neither the freelist nor the cachelist 4279 * (b) Hashed onto a vnode 4280 * (c) Not a kernel page 4281 * (d) Dirty 4282 * (e) Not part of a swapfile 4283 * (f) a page which belongs to a real vnode; eg has a non-null 4284 * v_vfsp pointer. 4285 * (g) Backed by a filesystem which doesn't have a 4286 * stubbed-out sync operation 4287 */ 4288 if (!PP_ISFREE(pp) && vp != NULL && !VN_ISKAS(vp) && 4289 hat_ismod(pp) && !IS_SWAPVP(vp) && vp->v_vfsp != NULL && 4290 vfs_can_sync(vp->v_vfsp)) { 4291 nppbusy++; 4292 vfs_syncprogress(); 4293 4294 if (!cleanit) 4295 continue; 4296 if (!page_trylock(pp, SE_EXCL)) 4297 continue; 4298 4299 if (PP_ISFREE(pp) || vp == NULL || IS_SWAPVP(vp) || 4300 pp->p_lckcnt != 0 || pp->p_cowcnt != 0 || 4301 !(hat_pagesync(pp, 4302 HAT_SYNC_DONTZERO | HAT_SYNC_STOPON_MOD) & P_MOD)) { 4303 page_unlock(pp); 4304 continue; 4305 } 4306 off = pp->p_offset; 4307 VN_HOLD(vp); 4308 page_unlock(pp); 4309 (void) VOP_PUTPAGE(vp, off, PAGESIZE, 4310 B_ASYNC | B_FREE, kcred, NULL); 4311 VN_RELE(vp); 4312 } 4313 } while ((pp = page_next(pp)) != page0); 4314 4315 return (nppbusy); 4316 } 4317 4318 void page_invalidate_pages(void); 4319 4320 /* 4321 * callback handler to vm sub-system 4322 * 4323 * callers make sure no recursive entries to this func. 4324 */ 4325 /*ARGSUSED*/ 4326 boolean_t 4327 callb_vm_cpr(void *arg, int code) 4328 { 4329 if (code == CB_CODE_CPR_CHKPT) 4330 page_invalidate_pages(); 4331 return (B_TRUE); 4332 } 4333 4334 /* 4335 * Invalidate all pages of the system. 4336 * It shouldn't be called until all user page activities are all stopped. 4337 */ 4338 void 4339 page_invalidate_pages() 4340 { 4341 page_t *pp; 4342 page_t *page0; 4343 pgcnt_t nbusypages; 4344 int retry = 0; 4345 const int MAXRETRIES = 4; 4346 #if defined(__sparc) 4347 extern struct vnode prom_ppages; 4348 #endif /* __sparc */ 4349 4350 top: 4351 /* 4352 * Flush dirty pages and destroy the clean ones. 4353 */ 4354 nbusypages = 0; 4355 4356 pp = page0 = page_first(); 4357 do { 4358 struct vnode *vp; 4359 u_offset_t offset; 4360 int mod; 4361 4362 /* 4363 * skip the page if it has no vnode or the page associated 4364 * with the kernel vnode or prom allocated kernel mem. 4365 */ 4366 #if defined(__sparc) 4367 if ((vp = pp->p_vnode) == NULL || VN_ISKAS(vp) || 4368 vp == &prom_ppages) 4369 #else /* x86 doesn't have prom or prom_ppage */ 4370 if ((vp = pp->p_vnode) == NULL || VN_ISKAS(vp)) 4371 #endif /* __sparc */ 4372 continue; 4373 4374 /* 4375 * skip the page which is already free invalidated. 4376 */ 4377 if (PP_ISFREE(pp) && PP_ISAGED(pp)) 4378 continue; 4379 4380 /* 4381 * skip pages that are already locked or can't be "exclusively" 4382 * locked or are already free. After we lock the page, check 4383 * the free and age bits again to be sure it's not destroyed 4384 * yet. 4385 * To achieve max. parallelization, we use page_trylock instead 4386 * of page_lock so that we don't get block on individual pages 4387 * while we have thousands of other pages to process. 4388 */ 4389 if (!page_trylock(pp, SE_EXCL)) { 4390 nbusypages++; 4391 continue; 4392 } else if (PP_ISFREE(pp)) { 4393 if (!PP_ISAGED(pp)) { 4394 page_destroy_free(pp); 4395 } else { 4396 page_unlock(pp); 4397 } 4398 continue; 4399 } 4400 /* 4401 * Is this page involved in some I/O? shared? 4402 * 4403 * The page_struct_lock need not be acquired to 4404 * examine these fields since the page has an 4405 * "exclusive" lock. 4406 */ 4407 if (pp->p_lckcnt != 0 || pp->p_cowcnt != 0) { 4408 page_unlock(pp); 4409 continue; 4410 } 4411 4412 if (vp->v_type == VCHR) { 4413 panic("vp->v_type == VCHR"); 4414 /*NOTREACHED*/ 4415 } 4416 4417 if (!page_try_demote_pages(pp)) { 4418 page_unlock(pp); 4419 continue; 4420 } 4421 4422 /* 4423 * Check the modified bit. Leave the bits alone in hardware 4424 * (they will be modified if we do the putpage). 4425 */ 4426 mod = (hat_pagesync(pp, HAT_SYNC_DONTZERO | HAT_SYNC_STOPON_MOD) 4427 & P_MOD); 4428 if (mod) { 4429 offset = pp->p_offset; 4430 /* 4431 * Hold the vnode before releasing the page lock 4432 * to prevent it from being freed and re-used by 4433 * some other thread. 4434 */ 4435 VN_HOLD(vp); 4436 page_unlock(pp); 4437 /* 4438 * No error return is checked here. Callers such as 4439 * cpr deals with the dirty pages at the dump time 4440 * if this putpage fails. 4441 */ 4442 (void) VOP_PUTPAGE(vp, offset, PAGESIZE, B_INVAL, 4443 kcred, NULL); 4444 VN_RELE(vp); 4445 } else { 4446 /*LINTED: constant in conditional context*/ 4447 VN_DISPOSE(pp, B_INVAL, 0, kcred); 4448 } 4449 } while ((pp = page_next(pp)) != page0); 4450 if (nbusypages && retry++ < MAXRETRIES) { 4451 delay(1); 4452 goto top; 4453 } 4454 } 4455 4456 /* 4457 * Replace the page "old" with the page "new" on the page hash and vnode lists 4458 * 4459 * the replacement must be done in place, ie the equivalent sequence: 4460 * 4461 * vp = old->p_vnode; 4462 * off = old->p_offset; 4463 * page_do_hashout(old) 4464 * page_do_hashin(new, vp, off) 4465 * 4466 * doesn't work, since 4467 * 1) if old is the only page on the vnode, the v_pages list has a window 4468 * where it looks empty. This will break file system assumptions. 4469 * and 4470 * 2) pvn_vplist_dirty() can't deal with pages moving on the v_pages list. 4471 */ 4472 static void 4473 page_do_relocate_hash(page_t *new, page_t *old) 4474 { 4475 page_t **hash_list; 4476 vnode_t *vp = old->p_vnode; 4477 kmutex_t *sep; 4478 4479 ASSERT(PAGE_EXCL(old)); 4480 ASSERT(PAGE_EXCL(new)); 4481 ASSERT(vp != NULL); 4482 ASSERT(MUTEX_HELD(page_vnode_mutex(vp))); 4483 ASSERT(MUTEX_HELD(PAGE_HASH_MUTEX(PAGE_HASH_FUNC(vp, old->p_offset)))); 4484 4485 /* 4486 * First find old page on the page hash list 4487 */ 4488 hash_list = &page_hash[PAGE_HASH_FUNC(vp, old->p_offset)]; 4489 4490 for (;;) { 4491 if (*hash_list == old) 4492 break; 4493 if (*hash_list == NULL) { 4494 panic("page_do_hashout"); 4495 /*NOTREACHED*/ 4496 } 4497 hash_list = &(*hash_list)->p_hash; 4498 } 4499 4500 /* 4501 * update new and replace old with new on the page hash list 4502 */ 4503 new->p_vnode = old->p_vnode; 4504 new->p_offset = old->p_offset; 4505 new->p_hash = old->p_hash; 4506 *hash_list = new; 4507 4508 if ((new->p_vnode->v_flag & VISSWAP) != 0) 4509 PP_SETSWAP(new); 4510 4511 /* 4512 * replace old with new on the vnode's page list 4513 */ 4514 if (old->p_vpnext == old) { 4515 new->p_vpnext = new; 4516 new->p_vpprev = new; 4517 } else { 4518 new->p_vpnext = old->p_vpnext; 4519 new->p_vpprev = old->p_vpprev; 4520 new->p_vpnext->p_vpprev = new; 4521 new->p_vpprev->p_vpnext = new; 4522 } 4523 if (vp->v_pages == old) 4524 vp->v_pages = new; 4525 4526 /* 4527 * clear out the old page 4528 */ 4529 old->p_hash = NULL; 4530 old->p_vpnext = NULL; 4531 old->p_vpprev = NULL; 4532 old->p_vnode = NULL; 4533 PP_CLRSWAP(old); 4534 old->p_offset = (u_offset_t)-1; 4535 page_clr_all_props(old, 1); 4536 4537 /* 4538 * Wake up processes waiting for this page. The page's 4539 * identity has been changed, and is probably not the 4540 * desired page any longer. 4541 */ 4542 sep = page_se_mutex(old); 4543 mutex_enter(sep); 4544 old->p_selock &= ~SE_EWANTED; 4545 if (CV_HAS_WAITERS(&old->p_cv)) 4546 cv_broadcast(&old->p_cv); 4547 mutex_exit(sep); 4548 } 4549 4550 /* 4551 * This function moves the identity of page "pp_old" to page "pp_new". 4552 * Both pages must be locked on entry. "pp_new" is free, has no identity, 4553 * and need not be hashed out from anywhere. 4554 */ 4555 void 4556 page_relocate_hash(page_t *pp_new, page_t *pp_old) 4557 { 4558 vnode_t *vp = pp_old->p_vnode; 4559 u_offset_t off = pp_old->p_offset; 4560 kmutex_t *phm, *vphm; 4561 4562 /* 4563 * Rehash two pages 4564 */ 4565 ASSERT(PAGE_EXCL(pp_old)); 4566 ASSERT(PAGE_EXCL(pp_new)); 4567 ASSERT(vp != NULL); 4568 ASSERT(pp_new->p_vnode == NULL); 4569 4570 /* 4571 * hashout then hashin while holding the mutexes 4572 */ 4573 phm = PAGE_HASH_MUTEX(PAGE_HASH_FUNC(vp, off)); 4574 mutex_enter(phm); 4575 vphm = page_vnode_mutex(vp); 4576 mutex_enter(vphm); 4577 4578 page_do_relocate_hash(pp_new, pp_old); 4579 4580 /* The following comment preserved from page_flip(). */ 4581 pp_new->p_fsdata = pp_old->p_fsdata; 4582 pp_old->p_fsdata = 0; 4583 mutex_exit(vphm); 4584 mutex_exit(phm); 4585 4586 /* 4587 * The page_struct_lock need not be acquired for lckcnt and 4588 * cowcnt since the page has an "exclusive" lock. 4589 */ 4590 ASSERT(pp_new->p_lckcnt == 0); 4591 ASSERT(pp_new->p_cowcnt == 0); 4592 pp_new->p_lckcnt = pp_old->p_lckcnt; 4593 pp_new->p_cowcnt = pp_old->p_cowcnt; 4594 pp_old->p_lckcnt = pp_old->p_cowcnt = 0; 4595 4596 } 4597 4598 /* 4599 * Helper routine used to lock all remaining members of a 4600 * large page. The caller is responsible for passing in a locked 4601 * pp. If pp is a large page, then it succeeds in locking all the 4602 * remaining constituent pages or it returns with only the 4603 * original page locked. 4604 * 4605 * Returns 1 on success, 0 on failure. 4606 * 4607 * If success is returned this routine guarantees p_szc for all constituent 4608 * pages of a large page pp belongs to can't change. To achieve this we 4609 * recheck szc of pp after locking all constituent pages and retry if szc 4610 * changed (it could only decrease). Since hat_page_demote() needs an EXCL 4611 * lock on one of constituent pages it can't be running after all constituent 4612 * pages are locked. hat_page_demote() with a lock on a constituent page 4613 * outside of this large page (i.e. pp belonged to a larger large page) is 4614 * already done with all constituent pages of pp since the root's p_szc is 4615 * changed last. Therefore no need to synchronize with hat_page_demote() that 4616 * locked a constituent page outside of pp's current large page. 4617 */ 4618 #ifdef DEBUG 4619 uint32_t gpg_trylock_mtbf = 0; 4620 #endif 4621 4622 int 4623 group_page_trylock(page_t *pp, se_t se) 4624 { 4625 page_t *tpp; 4626 pgcnt_t npgs, i, j; 4627 uint_t pszc = pp->p_szc; 4628 4629 #ifdef DEBUG 4630 if (gpg_trylock_mtbf && !(gethrtime() % gpg_trylock_mtbf)) { 4631 return (0); 4632 } 4633 #endif 4634 4635 if (pp != PP_GROUPLEADER(pp, pszc)) { 4636 return (0); 4637 } 4638 4639 retry: 4640 ASSERT(PAGE_LOCKED_SE(pp, se)); 4641 ASSERT(!PP_ISFREE(pp)); 4642 if (pszc == 0) { 4643 return (1); 4644 } 4645 npgs = page_get_pagecnt(pszc); 4646 tpp = pp + 1; 4647 for (i = 1; i < npgs; i++, tpp++) { 4648 if (!page_trylock(tpp, se)) { 4649 tpp = pp + 1; 4650 for (j = 1; j < i; j++, tpp++) { 4651 page_unlock(tpp); 4652 } 4653 return (0); 4654 } 4655 } 4656 if (pp->p_szc != pszc) { 4657 ASSERT(pp->p_szc < pszc); 4658 ASSERT(pp->p_vnode != NULL && !PP_ISKAS(pp) && 4659 !IS_SWAPFSVP(pp->p_vnode)); 4660 tpp = pp + 1; 4661 for (i = 1; i < npgs; i++, tpp++) { 4662 page_unlock(tpp); 4663 } 4664 pszc = pp->p_szc; 4665 goto retry; 4666 } 4667 return (1); 4668 } 4669 4670 void 4671 group_page_unlock(page_t *pp) 4672 { 4673 page_t *tpp; 4674 pgcnt_t npgs, i; 4675 4676 ASSERT(PAGE_LOCKED(pp)); 4677 ASSERT(!PP_ISFREE(pp)); 4678 ASSERT(pp == PP_PAGEROOT(pp)); 4679 npgs = page_get_pagecnt(pp->p_szc); 4680 for (i = 1, tpp = pp + 1; i < npgs; i++, tpp++) { 4681 page_unlock(tpp); 4682 } 4683 } 4684 4685 /* 4686 * returns 4687 * 0 : on success and *nrelocp is number of relocated PAGESIZE pages 4688 * ERANGE : this is not a base page 4689 * EBUSY : failure to get locks on the page/pages 4690 * ENOMEM : failure to obtain replacement pages 4691 * EAGAIN : OBP has not yet completed its boot-time handoff to the kernel 4692 * EIO : An error occurred while trying to copy the page data 4693 * 4694 * Return with all constituent members of target and replacement 4695 * SE_EXCL locked. It is the callers responsibility to drop the 4696 * locks. 4697 */ 4698 int 4699 do_page_relocate( 4700 page_t **target, 4701 page_t **replacement, 4702 int grouplock, 4703 spgcnt_t *nrelocp, 4704 lgrp_t *lgrp) 4705 { 4706 page_t *first_repl; 4707 page_t *repl; 4708 page_t *targ; 4709 page_t *pl = NULL; 4710 uint_t ppattr; 4711 pfn_t pfn, repl_pfn; 4712 uint_t szc; 4713 spgcnt_t npgs, i; 4714 int repl_contig = 0; 4715 uint_t flags = 0; 4716 spgcnt_t dofree = 0; 4717 4718 *nrelocp = 0; 4719 4720 #if defined(__sparc) 4721 /* 4722 * We need to wait till OBP has completed 4723 * its boot-time handoff of its resources to the kernel 4724 * before we allow page relocation 4725 */ 4726 if (page_relocate_ready == 0) { 4727 return (EAGAIN); 4728 } 4729 #endif 4730 4731 /* 4732 * If this is not a base page, 4733 * just return with 0x0 pages relocated. 4734 */ 4735 targ = *target; 4736 ASSERT(PAGE_EXCL(targ)); 4737 ASSERT(!PP_ISFREE(targ)); 4738 szc = targ->p_szc; 4739 ASSERT(szc < mmu_page_sizes); 4740 VM_STAT_ADD(vmm_vmstats.ppr_reloc[szc]); 4741 pfn = targ->p_pagenum; 4742 if (pfn != PFN_BASE(pfn, szc)) { 4743 VM_STAT_ADD(vmm_vmstats.ppr_relocnoroot[szc]); 4744 return (ERANGE); 4745 } 4746 4747 if ((repl = *replacement) != NULL && repl->p_szc >= szc) { 4748 repl_pfn = repl->p_pagenum; 4749 if (repl_pfn != PFN_BASE(repl_pfn, szc)) { 4750 VM_STAT_ADD(vmm_vmstats.ppr_reloc_replnoroot[szc]); 4751 return (ERANGE); 4752 } 4753 repl_contig = 1; 4754 } 4755 4756 /* 4757 * We must lock all members of this large page or we cannot 4758 * relocate any part of it. 4759 */ 4760 if (grouplock != 0 && !group_page_trylock(targ, SE_EXCL)) { 4761 VM_STAT_ADD(vmm_vmstats.ppr_relocnolock[targ->p_szc]); 4762 return (EBUSY); 4763 } 4764 4765 /* 4766 * reread szc it could have been decreased before 4767 * group_page_trylock() was done. 4768 */ 4769 szc = targ->p_szc; 4770 ASSERT(szc < mmu_page_sizes); 4771 VM_STAT_ADD(vmm_vmstats.ppr_reloc[szc]); 4772 ASSERT(pfn == PFN_BASE(pfn, szc)); 4773 4774 npgs = page_get_pagecnt(targ->p_szc); 4775 4776 if (repl == NULL) { 4777 dofree = npgs; /* Size of target page in MMU pages */ 4778 if (!page_create_wait(dofree, 0)) { 4779 if (grouplock != 0) { 4780 group_page_unlock(targ); 4781 } 4782 VM_STAT_ADD(vmm_vmstats.ppr_relocnomem[szc]); 4783 return (ENOMEM); 4784 } 4785 4786 /* 4787 * seg kmem pages require that the target and replacement 4788 * page be the same pagesize. 4789 */ 4790 flags = (VN_ISKAS(targ->p_vnode)) ? PGR_SAMESZC : 0; 4791 repl = page_get_replacement_page(targ, lgrp, flags); 4792 if (repl == NULL) { 4793 if (grouplock != 0) { 4794 group_page_unlock(targ); 4795 } 4796 page_create_putback(dofree); 4797 VM_STAT_ADD(vmm_vmstats.ppr_relocnomem[szc]); 4798 return (ENOMEM); 4799 } 4800 } 4801 #ifdef DEBUG 4802 else { 4803 ASSERT(PAGE_LOCKED(repl)); 4804 } 4805 #endif /* DEBUG */ 4806 4807 #if defined(__sparc) 4808 /* 4809 * Let hat_page_relocate() complete the relocation if it's kernel page 4810 */ 4811 if (VN_ISKAS(targ->p_vnode)) { 4812 *replacement = repl; 4813 if (hat_page_relocate(target, replacement, nrelocp) != 0) { 4814 if (grouplock != 0) { 4815 group_page_unlock(targ); 4816 } 4817 if (dofree) { 4818 *replacement = NULL; 4819 page_free_replacement_page(repl); 4820 page_create_putback(dofree); 4821 } 4822 VM_STAT_ADD(vmm_vmstats.ppr_krelocfail[szc]); 4823 return (EAGAIN); 4824 } 4825 VM_STAT_ADD(vmm_vmstats.ppr_relocok[szc]); 4826 return (0); 4827 } 4828 #else 4829 #if defined(lint) 4830 dofree = dofree; 4831 #endif 4832 #endif 4833 4834 first_repl = repl; 4835 4836 for (i = 0; i < npgs; i++) { 4837 ASSERT(PAGE_EXCL(targ)); 4838 ASSERT(targ->p_slckcnt == 0); 4839 ASSERT(repl->p_slckcnt == 0); 4840 4841 (void) hat_pageunload(targ, HAT_FORCE_PGUNLOAD); 4842 4843 ASSERT(hat_page_getshare(targ) == 0); 4844 ASSERT(!PP_ISFREE(targ)); 4845 ASSERT(targ->p_pagenum == (pfn + i)); 4846 ASSERT(repl_contig == 0 || 4847 repl->p_pagenum == (repl_pfn + i)); 4848 4849 /* 4850 * Copy the page contents and attributes then 4851 * relocate the page in the page hash. 4852 */ 4853 if (ppcopy(targ, repl) == 0) { 4854 targ = *target; 4855 repl = first_repl; 4856 VM_STAT_ADD(vmm_vmstats.ppr_copyfail); 4857 if (grouplock != 0) { 4858 group_page_unlock(targ); 4859 } 4860 if (dofree) { 4861 *replacement = NULL; 4862 page_free_replacement_page(repl); 4863 page_create_putback(dofree); 4864 } 4865 return (EIO); 4866 } 4867 4868 targ++; 4869 if (repl_contig != 0) { 4870 repl++; 4871 } else { 4872 repl = repl->p_next; 4873 } 4874 } 4875 4876 repl = first_repl; 4877 targ = *target; 4878 4879 for (i = 0; i < npgs; i++) { 4880 ppattr = hat_page_getattr(targ, (P_MOD | P_REF | P_RO)); 4881 page_clr_all_props(repl, 0); 4882 page_set_props(repl, ppattr); 4883 page_relocate_hash(repl, targ); 4884 4885 ASSERT(hat_page_getshare(targ) == 0); 4886 ASSERT(hat_page_getshare(repl) == 0); 4887 /* 4888 * Now clear the props on targ, after the 4889 * page_relocate_hash(), they no longer 4890 * have any meaning. 4891 */ 4892 page_clr_all_props(targ, 0); 4893 ASSERT(targ->p_next == targ); 4894 ASSERT(targ->p_prev == targ); 4895 page_list_concat(&pl, &targ); 4896 4897 targ++; 4898 if (repl_contig != 0) { 4899 repl++; 4900 } else { 4901 repl = repl->p_next; 4902 } 4903 } 4904 /* assert that we have come full circle with repl */ 4905 ASSERT(repl_contig == 1 || first_repl == repl); 4906 4907 *target = pl; 4908 if (*replacement == NULL) { 4909 ASSERT(first_repl == repl); 4910 *replacement = repl; 4911 } 4912 VM_STAT_ADD(vmm_vmstats.ppr_relocok[szc]); 4913 *nrelocp = npgs; 4914 return (0); 4915 } 4916 /* 4917 * On success returns 0 and *nrelocp the number of PAGESIZE pages relocated. 4918 */ 4919 int 4920 page_relocate( 4921 page_t **target, 4922 page_t **replacement, 4923 int grouplock, 4924 int freetarget, 4925 spgcnt_t *nrelocp, 4926 lgrp_t *lgrp) 4927 { 4928 spgcnt_t ret; 4929 4930 /* do_page_relocate returns 0 on success or errno value */ 4931 ret = do_page_relocate(target, replacement, grouplock, nrelocp, lgrp); 4932 4933 if (ret != 0 || freetarget == 0) { 4934 return (ret); 4935 } 4936 if (*nrelocp == 1) { 4937 ASSERT(*target != NULL); 4938 page_free(*target, 1); 4939 } else { 4940 page_t *tpp = *target; 4941 uint_t szc = tpp->p_szc; 4942 pgcnt_t npgs = page_get_pagecnt(szc); 4943 ASSERT(npgs > 1); 4944 ASSERT(szc != 0); 4945 do { 4946 ASSERT(PAGE_EXCL(tpp)); 4947 ASSERT(!hat_page_is_mapped(tpp)); 4948 ASSERT(tpp->p_szc == szc); 4949 PP_SETFREE(tpp); 4950 PP_SETAGED(tpp); 4951 npgs--; 4952 } while ((tpp = tpp->p_next) != *target); 4953 ASSERT(npgs == 0); 4954 page_list_add_pages(*target, 0); 4955 npgs = page_get_pagecnt(szc); 4956 page_create_putback(npgs); 4957 } 4958 return (ret); 4959 } 4960 4961 /* 4962 * it is up to the caller to deal with pcf accounting. 4963 */ 4964 void 4965 page_free_replacement_page(page_t *pplist) 4966 { 4967 page_t *pp; 4968 4969 while (pplist != NULL) { 4970 /* 4971 * pp_targ is a linked list. 4972 */ 4973 pp = pplist; 4974 if (pp->p_szc == 0) { 4975 page_sub(&pplist, pp); 4976 page_clr_all_props(pp, 0); 4977 PP_SETFREE(pp); 4978 PP_SETAGED(pp); 4979 page_list_add(pp, PG_FREE_LIST | PG_LIST_TAIL); 4980 page_unlock(pp); 4981 VM_STAT_ADD(pagecnt.pc_free_replacement_page[0]); 4982 } else { 4983 spgcnt_t curnpgs = page_get_pagecnt(pp->p_szc); 4984 page_t *tpp; 4985 page_list_break(&pp, &pplist, curnpgs); 4986 tpp = pp; 4987 do { 4988 ASSERT(PAGE_EXCL(tpp)); 4989 ASSERT(!hat_page_is_mapped(tpp)); 4990 page_clr_all_props(tpp, 0); 4991 PP_SETFREE(tpp); 4992 PP_SETAGED(tpp); 4993 } while ((tpp = tpp->p_next) != pp); 4994 page_list_add_pages(pp, 0); 4995 VM_STAT_ADD(pagecnt.pc_free_replacement_page[1]); 4996 } 4997 } 4998 } 4999 5000 /* 5001 * Relocate target to non-relocatable replacement page. 5002 */ 5003 int 5004 page_relocate_cage(page_t **target, page_t **replacement) 5005 { 5006 page_t *tpp, *rpp; 5007 spgcnt_t pgcnt, npgs; 5008 int result; 5009 5010 tpp = *target; 5011 5012 ASSERT(PAGE_EXCL(tpp)); 5013 ASSERT(tpp->p_szc == 0); 5014 5015 pgcnt = btop(page_get_pagesize(tpp->p_szc)); 5016 5017 do { 5018 (void) page_create_wait(pgcnt, PG_WAIT | PG_NORELOC); 5019 rpp = page_get_replacement_page(tpp, NULL, PGR_NORELOC); 5020 if (rpp == NULL) { 5021 page_create_putback(pgcnt); 5022 kcage_cageout_wakeup(); 5023 } 5024 } while (rpp == NULL); 5025 5026 ASSERT(PP_ISNORELOC(rpp)); 5027 5028 result = page_relocate(&tpp, &rpp, 0, 1, &npgs, NULL); 5029 5030 if (result == 0) { 5031 *replacement = rpp; 5032 if (pgcnt != npgs) 5033 panic("page_relocate_cage: partial relocation"); 5034 } 5035 5036 return (result); 5037 } 5038 5039 /* 5040 * Release the page lock on a page, place on cachelist 5041 * tail if no longer mapped. Caller can let us know if 5042 * the page is known to be clean. 5043 */ 5044 int 5045 page_release(page_t *pp, int checkmod) 5046 { 5047 int status; 5048 5049 ASSERT(PAGE_LOCKED(pp) && !PP_ISFREE(pp) && 5050 (pp->p_vnode != NULL)); 5051 5052 if (!hat_page_is_mapped(pp) && !IS_SWAPVP(pp->p_vnode) && 5053 ((PAGE_SHARED(pp) && page_tryupgrade(pp)) || PAGE_EXCL(pp)) && 5054 pp->p_lckcnt == 0 && pp->p_cowcnt == 0 && 5055 !hat_page_is_mapped(pp)) { 5056 5057 /* 5058 * If page is modified, unlock it 5059 * 5060 * (p_nrm & P_MOD) bit has the latest stuff because: 5061 * (1) We found that this page doesn't have any mappings 5062 * _after_ holding SE_EXCL and 5063 * (2) We didn't drop SE_EXCL lock after the check in (1) 5064 */ 5065 if (checkmod && hat_ismod(pp)) { 5066 page_unlock(pp); 5067 status = PGREL_MOD; 5068 } else { 5069 /*LINTED: constant in conditional context*/ 5070 VN_DISPOSE(pp, B_FREE, 0, kcred); 5071 status = PGREL_CLEAN; 5072 } 5073 } else { 5074 page_unlock(pp); 5075 status = PGREL_NOTREL; 5076 } 5077 return (status); 5078 } 5079 5080 /* 5081 * Given a constituent page, try to demote the large page on the freelist. 5082 * 5083 * Returns nonzero if the page could be demoted successfully. Returns with 5084 * the constituent page still locked. 5085 */ 5086 int 5087 page_try_demote_free_pages(page_t *pp) 5088 { 5089 page_t *rootpp = pp; 5090 pfn_t pfn = page_pptonum(pp); 5091 spgcnt_t npgs; 5092 uint_t szc = pp->p_szc; 5093 5094 ASSERT(PP_ISFREE(pp)); 5095 ASSERT(PAGE_EXCL(pp)); 5096 5097 /* 5098 * Adjust rootpp and lock it, if `pp' is not the base 5099 * constituent page. 5100 */ 5101 npgs = page_get_pagecnt(pp->p_szc); 5102 if (npgs == 1) { 5103 return (0); 5104 } 5105 5106 if (!IS_P2ALIGNED(pfn, npgs)) { 5107 pfn = P2ALIGN(pfn, npgs); 5108 rootpp = page_numtopp_nolock(pfn); 5109 } 5110 5111 if (pp != rootpp && !page_trylock(rootpp, SE_EXCL)) { 5112 return (0); 5113 } 5114 5115 if (rootpp->p_szc != szc) { 5116 if (pp != rootpp) 5117 page_unlock(rootpp); 5118 return (0); 5119 } 5120 5121 page_demote_free_pages(rootpp); 5122 5123 if (pp != rootpp) 5124 page_unlock(rootpp); 5125 5126 ASSERT(PP_ISFREE(pp)); 5127 ASSERT(PAGE_EXCL(pp)); 5128 return (1); 5129 } 5130 5131 /* 5132 * Given a constituent page, try to demote the large page. 5133 * 5134 * Returns nonzero if the page could be demoted successfully. Returns with 5135 * the constituent page still locked. 5136 */ 5137 int 5138 page_try_demote_pages(page_t *pp) 5139 { 5140 page_t *tpp, *rootpp = pp; 5141 pfn_t pfn = page_pptonum(pp); 5142 spgcnt_t i, npgs; 5143 uint_t szc = pp->p_szc; 5144 vnode_t *vp = pp->p_vnode; 5145 5146 ASSERT(PAGE_EXCL(pp)); 5147 5148 VM_STAT_ADD(pagecnt.pc_try_demote_pages[0]); 5149 5150 if (pp->p_szc == 0) { 5151 VM_STAT_ADD(pagecnt.pc_try_demote_pages[1]); 5152 return (1); 5153 } 5154 5155 if (vp != NULL && !IS_SWAPFSVP(vp) && !VN_ISKAS(vp)) { 5156 VM_STAT_ADD(pagecnt.pc_try_demote_pages[2]); 5157 page_demote_vp_pages(pp); 5158 ASSERT(pp->p_szc == 0); 5159 return (1); 5160 } 5161 5162 /* 5163 * Adjust rootpp if passed in is not the base 5164 * constituent page. 5165 */ 5166 npgs = page_get_pagecnt(pp->p_szc); 5167 ASSERT(npgs > 1); 5168 if (!IS_P2ALIGNED(pfn, npgs)) { 5169 pfn = P2ALIGN(pfn, npgs); 5170 rootpp = page_numtopp_nolock(pfn); 5171 VM_STAT_ADD(pagecnt.pc_try_demote_pages[3]); 5172 ASSERT(rootpp->p_vnode != NULL); 5173 ASSERT(rootpp->p_szc == szc); 5174 } 5175 5176 /* 5177 * We can't demote kernel pages since we can't hat_unload() 5178 * the mappings. 5179 */ 5180 if (VN_ISKAS(rootpp->p_vnode)) 5181 return (0); 5182 5183 /* 5184 * Attempt to lock all constituent pages except the page passed 5185 * in since it's already locked. 5186 */ 5187 for (tpp = rootpp, i = 0; i < npgs; i++, tpp++) { 5188 ASSERT(!PP_ISFREE(tpp)); 5189 ASSERT(tpp->p_vnode != NULL); 5190 5191 if (tpp != pp && !page_trylock(tpp, SE_EXCL)) 5192 break; 5193 ASSERT(tpp->p_szc == rootpp->p_szc); 5194 ASSERT(page_pptonum(tpp) == page_pptonum(rootpp) + i); 5195 } 5196 5197 /* 5198 * If we failed to lock them all then unlock what we have 5199 * locked so far and bail. 5200 */ 5201 if (i < npgs) { 5202 tpp = rootpp; 5203 while (i-- > 0) { 5204 if (tpp != pp) 5205 page_unlock(tpp); 5206 tpp++; 5207 } 5208 VM_STAT_ADD(pagecnt.pc_try_demote_pages[4]); 5209 return (0); 5210 } 5211 5212 for (tpp = rootpp, i = 0; i < npgs; i++, tpp++) { 5213 ASSERT(PAGE_EXCL(tpp)); 5214 ASSERT(tpp->p_slckcnt == 0); 5215 (void) hat_pageunload(tpp, HAT_FORCE_PGUNLOAD); 5216 tpp->p_szc = 0; 5217 } 5218 5219 /* 5220 * Unlock all pages except the page passed in. 5221 */ 5222 for (tpp = rootpp, i = 0; i < npgs; i++, tpp++) { 5223 ASSERT(!hat_page_is_mapped(tpp)); 5224 if (tpp != pp) 5225 page_unlock(tpp); 5226 } 5227 5228 VM_STAT_ADD(pagecnt.pc_try_demote_pages[5]); 5229 return (1); 5230 } 5231 5232 /* 5233 * Called by page_free() and page_destroy() to demote the page size code 5234 * (p_szc) to 0 (since we can't just put a single PAGESIZE page with non zero 5235 * p_szc on free list, neither can we just clear p_szc of a single page_t 5236 * within a large page since it will break other code that relies on p_szc 5237 * being the same for all page_t's of a large page). Anonymous pages should 5238 * never end up here because anon_map_getpages() cannot deal with p_szc 5239 * changes after a single constituent page is locked. While anonymous or 5240 * kernel large pages are demoted or freed the entire large page at a time 5241 * with all constituent pages locked EXCL for the file system pages we 5242 * have to be able to demote a large page (i.e. decrease all constituent pages 5243 * p_szc) with only just an EXCL lock on one of constituent pages. The reason 5244 * we can easily deal with anonymous page demotion the entire large page at a 5245 * time is that those operation originate at address space level and concern 5246 * the entire large page region with actual demotion only done when pages are 5247 * not shared with any other processes (therefore we can always get EXCL lock 5248 * on all anonymous constituent pages after clearing segment page 5249 * cache). However file system pages can be truncated or invalidated at a 5250 * PAGESIZE level from the file system side and end up in page_free() or 5251 * page_destroy() (we also allow only part of the large page to be SOFTLOCKed 5252 * and therefore pageout should be able to demote a large page by EXCL locking 5253 * any constituent page that is not under SOFTLOCK). In those cases we cannot 5254 * rely on being able to lock EXCL all constituent pages. 5255 * 5256 * To prevent szc changes on file system pages one has to lock all constituent 5257 * pages at least SHARED (or call page_szc_lock()). The only subsystem that 5258 * doesn't rely on locking all constituent pages (or using page_szc_lock()) to 5259 * prevent szc changes is hat layer that uses its own page level mlist 5260 * locks. hat assumes that szc doesn't change after mlist lock for a page is 5261 * taken. Therefore we need to change szc under hat level locks if we only 5262 * have an EXCL lock on a single constituent page and hat still references any 5263 * of constituent pages. (Note we can't "ignore" hat layer by simply 5264 * hat_pageunload() all constituent pages without having EXCL locks on all of 5265 * constituent pages). We use hat_page_demote() call to safely demote szc of 5266 * all constituent pages under hat locks when we only have an EXCL lock on one 5267 * of constituent pages. 5268 * 5269 * This routine calls page_szc_lock() before calling hat_page_demote() to 5270 * allow segvn in one special case not to lock all constituent pages SHARED 5271 * before calling hat_memload_array() that relies on p_szc not changing even 5272 * before hat level mlist lock is taken. In that case segvn uses 5273 * page_szc_lock() to prevent hat_page_demote() changing p_szc values. 5274 * 5275 * Anonymous or kernel page demotion still has to lock all pages exclusively 5276 * and do hat_pageunload() on all constituent pages before demoting the page 5277 * therefore there's no need for anonymous or kernel page demotion to use 5278 * hat_page_demote() mechanism. 5279 * 5280 * hat_page_demote() removes all large mappings that map pp and then decreases 5281 * p_szc starting from the last constituent page of the large page. By working 5282 * from the tail of a large page in pfn decreasing order allows one looking at 5283 * the root page to know that hat_page_demote() is done for root's szc area. 5284 * e.g. if a root page has szc 1 one knows it only has to lock all constituent 5285 * pages within szc 1 area to prevent szc changes because hat_page_demote() 5286 * that started on this page when it had szc > 1 is done for this szc 1 area. 5287 * 5288 * We are guaranteed that all constituent pages of pp's large page belong to 5289 * the same vnode with the consecutive offsets increasing in the direction of 5290 * the pfn i.e. the identity of constituent pages can't change until their 5291 * p_szc is decreased. Therefore it's safe for hat_page_demote() to remove 5292 * large mappings to pp even though we don't lock any constituent page except 5293 * pp (i.e. we won't unload e.g. kernel locked page). 5294 */ 5295 static void 5296 page_demote_vp_pages(page_t *pp) 5297 { 5298 kmutex_t *mtx; 5299 5300 ASSERT(PAGE_EXCL(pp)); 5301 ASSERT(!PP_ISFREE(pp)); 5302 ASSERT(pp->p_vnode != NULL); 5303 ASSERT(!IS_SWAPFSVP(pp->p_vnode)); 5304 ASSERT(!PP_ISKAS(pp)); 5305 5306 VM_STAT_ADD(pagecnt.pc_demote_pages[0]); 5307 5308 mtx = page_szc_lock(pp); 5309 if (mtx != NULL) { 5310 hat_page_demote(pp); 5311 mutex_exit(mtx); 5312 } 5313 ASSERT(pp->p_szc == 0); 5314 } 5315 5316 /* 5317 * Mark any existing pages for migration in the given range 5318 */ 5319 void 5320 page_mark_migrate(struct seg *seg, caddr_t addr, size_t len, 5321 struct anon_map *amp, ulong_t anon_index, vnode_t *vp, 5322 u_offset_t vnoff, int rflag) 5323 { 5324 struct anon *ap; 5325 vnode_t *curvp; 5326 lgrp_t *from; 5327 pgcnt_t i; 5328 pgcnt_t nlocked; 5329 u_offset_t off; 5330 pfn_t pfn; 5331 size_t pgsz; 5332 size_t segpgsz; 5333 pgcnt_t pages; 5334 uint_t pszc; 5335 page_t **ppa; 5336 pgcnt_t ppa_nentries; 5337 page_t *pp; 5338 caddr_t va; 5339 ulong_t an_idx; 5340 anon_sync_obj_t cookie; 5341 5342 ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as, &seg->s_as->a_lock)); 5343 5344 /* 5345 * Don't do anything if don't need to do lgroup optimizations 5346 * on this system 5347 */ 5348 if (!lgrp_optimizations()) 5349 return; 5350 5351 /* 5352 * Align address and length to (potentially large) page boundary 5353 */ 5354 segpgsz = page_get_pagesize(seg->s_szc); 5355 addr = (caddr_t)P2ALIGN((uintptr_t)addr, segpgsz); 5356 if (rflag) 5357 len = P2ROUNDUP(len, segpgsz); 5358 5359 /* 5360 * Allocate page array to accommodate largest page size 5361 */ 5362 pgsz = page_get_pagesize(page_num_pagesizes() - 1); 5363 ppa_nentries = btop(pgsz); 5364 ppa = kmem_zalloc(ppa_nentries * sizeof (page_t *), KM_SLEEP); 5365 5366 /* 5367 * Do one (large) page at a time 5368 */ 5369 va = addr; 5370 while (va < addr + len) { 5371 /* 5372 * Lookup (root) page for vnode and offset corresponding to 5373 * this virtual address 5374 * Try anonmap first since there may be copy-on-write 5375 * pages, but initialize vnode pointer and offset using 5376 * vnode arguments just in case there isn't an amp. 5377 */ 5378 curvp = vp; 5379 off = vnoff + va - seg->s_base; 5380 if (amp) { 5381 ANON_LOCK_ENTER(&->a_rwlock, RW_READER); 5382 an_idx = anon_index + seg_page(seg, va); 5383 anon_array_enter(amp, an_idx, &cookie); 5384 ap = anon_get_ptr(amp->ahp, an_idx); 5385 if (ap) 5386 swap_xlate(ap, &curvp, &off); 5387 anon_array_exit(&cookie); 5388 ANON_LOCK_EXIT(&->a_rwlock); 5389 } 5390 5391 pp = NULL; 5392 if (curvp) 5393 pp = page_lookup(curvp, off, SE_SHARED); 5394 5395 /* 5396 * If there isn't a page at this virtual address, 5397 * skip to next page 5398 */ 5399 if (pp == NULL) { 5400 va += PAGESIZE; 5401 continue; 5402 } 5403 5404 /* 5405 * Figure out which lgroup this page is in for kstats 5406 */ 5407 pfn = page_pptonum(pp); 5408 from = lgrp_pfn_to_lgrp(pfn); 5409 5410 /* 5411 * Get page size, and round up and skip to next page boundary 5412 * if unaligned address 5413 */ 5414 pszc = pp->p_szc; 5415 pgsz = page_get_pagesize(pszc); 5416 pages = btop(pgsz); 5417 if (!IS_P2ALIGNED(va, pgsz) || 5418 !IS_P2ALIGNED(pfn, pages) || 5419 pgsz > segpgsz) { 5420 pgsz = MIN(pgsz, segpgsz); 5421 page_unlock(pp); 5422 i = btop(P2END((uintptr_t)va, pgsz) - 5423 (uintptr_t)va); 5424 va = (caddr_t)P2END((uintptr_t)va, pgsz); 5425 lgrp_stat_add(from->lgrp_id, LGRP_PMM_FAIL_PGS, i); 5426 continue; 5427 } 5428 5429 /* 5430 * Upgrade to exclusive lock on page 5431 */ 5432 if (!page_tryupgrade(pp)) { 5433 page_unlock(pp); 5434 va += pgsz; 5435 lgrp_stat_add(from->lgrp_id, LGRP_PMM_FAIL_PGS, 5436 btop(pgsz)); 5437 continue; 5438 } 5439 5440 /* 5441 * Remember pages locked exclusively and how many 5442 */ 5443 ppa[0] = pp; 5444 nlocked = 1; 5445 5446 /* 5447 * Lock constituent pages if this is large page 5448 */ 5449 if (pages > 1) { 5450 /* 5451 * Lock all constituents except root page, since it 5452 * should be locked already. 5453 */ 5454 for (i = 1; i < pages; i++) { 5455 pp++; 5456 if (!page_trylock(pp, SE_EXCL)) { 5457 break; 5458 } 5459 if (PP_ISFREE(pp) || 5460 pp->p_szc != pszc) { 5461 /* 5462 * hat_page_demote() raced in with us. 5463 */ 5464 ASSERT(!IS_SWAPFSVP(curvp)); 5465 page_unlock(pp); 5466 break; 5467 } 5468 ppa[nlocked] = pp; 5469 nlocked++; 5470 } 5471 } 5472 5473 /* 5474 * If all constituent pages couldn't be locked, 5475 * unlock pages locked so far and skip to next page. 5476 */ 5477 if (nlocked != pages) { 5478 for (i = 0; i < nlocked; i++) 5479 page_unlock(ppa[i]); 5480 va += pgsz; 5481 lgrp_stat_add(from->lgrp_id, LGRP_PMM_FAIL_PGS, 5482 btop(pgsz)); 5483 continue; 5484 } 5485 5486 /* 5487 * hat_page_demote() can no longer happen 5488 * since last cons page had the right p_szc after 5489 * all cons pages were locked. all cons pages 5490 * should now have the same p_szc. 5491 */ 5492 5493 /* 5494 * All constituent pages locked successfully, so mark 5495 * large page for migration and unload the mappings of 5496 * constituent pages, so a fault will occur on any part of the 5497 * large page 5498 */ 5499 PP_SETMIGRATE(ppa[0]); 5500 for (i = 0; i < nlocked; i++) { 5501 pp = ppa[i]; 5502 (void) hat_pageunload(pp, HAT_FORCE_PGUNLOAD); 5503 ASSERT(hat_page_getshare(pp) == 0); 5504 page_unlock(pp); 5505 } 5506 lgrp_stat_add(from->lgrp_id, LGRP_PMM_PGS, nlocked); 5507 5508 va += pgsz; 5509 } 5510 kmem_free(ppa, ppa_nentries * sizeof (page_t *)); 5511 } 5512 5513 /* 5514 * Migrate any pages that have been marked for migration in the given range 5515 */ 5516 void 5517 page_migrate( 5518 struct seg *seg, 5519 caddr_t addr, 5520 page_t **ppa, 5521 pgcnt_t npages) 5522 { 5523 lgrp_t *from; 5524 lgrp_t *to; 5525 page_t *newpp; 5526 page_t *pp; 5527 pfn_t pfn; 5528 size_t pgsz; 5529 spgcnt_t page_cnt; 5530 spgcnt_t i; 5531 uint_t pszc; 5532 5533 ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as, &seg->s_as->a_lock)); 5534 5535 while (npages > 0) { 5536 pp = *ppa; 5537 pszc = pp->p_szc; 5538 pgsz = page_get_pagesize(pszc); 5539 page_cnt = btop(pgsz); 5540 5541 /* 5542 * Check to see whether this page is marked for migration 5543 * 5544 * Assume that root page of large page is marked for 5545 * migration and none of the other constituent pages 5546 * are marked. This really simplifies clearing the 5547 * migrate bit by not having to clear it from each 5548 * constituent page. 5549 * 5550 * note we don't want to relocate an entire large page if 5551 * someone is only using one subpage. 5552 */ 5553 if (npages < page_cnt) 5554 break; 5555 5556 /* 5557 * Is it marked for migration? 5558 */ 5559 if (!PP_ISMIGRATE(pp)) 5560 goto next; 5561 5562 /* 5563 * Determine lgroups that page is being migrated between 5564 */ 5565 pfn = page_pptonum(pp); 5566 if (!IS_P2ALIGNED(pfn, page_cnt)) { 5567 break; 5568 } 5569 from = lgrp_pfn_to_lgrp(pfn); 5570 to = lgrp_mem_choose(seg, addr, pgsz); 5571 5572 /* 5573 * Need to get exclusive lock's to migrate 5574 */ 5575 for (i = 0; i < page_cnt; i++) { 5576 ASSERT(PAGE_LOCKED(ppa[i])); 5577 if (page_pptonum(ppa[i]) != pfn + i || 5578 ppa[i]->p_szc != pszc) { 5579 break; 5580 } 5581 if (!page_tryupgrade(ppa[i])) { 5582 lgrp_stat_add(from->lgrp_id, 5583 LGRP_PM_FAIL_LOCK_PGS, 5584 page_cnt); 5585 break; 5586 } 5587 5588 /* 5589 * Check to see whether we are trying to migrate 5590 * page to lgroup where it is allocated already. 5591 * If so, clear the migrate bit and skip to next 5592 * page. 5593 */ 5594 if (i == 0 && to == from) { 5595 PP_CLRMIGRATE(ppa[0]); 5596 page_downgrade(ppa[0]); 5597 goto next; 5598 } 5599 } 5600 5601 /* 5602 * If all constituent pages couldn't be locked, 5603 * unlock pages locked so far and skip to next page. 5604 */ 5605 if (i != page_cnt) { 5606 while (--i != -1) { 5607 page_downgrade(ppa[i]); 5608 } 5609 goto next; 5610 } 5611 5612 (void) page_create_wait(page_cnt, PG_WAIT); 5613 newpp = page_get_replacement_page(pp, to, PGR_SAMESZC); 5614 if (newpp == NULL) { 5615 page_create_putback(page_cnt); 5616 for (i = 0; i < page_cnt; i++) { 5617 page_downgrade(ppa[i]); 5618 } 5619 lgrp_stat_add(to->lgrp_id, LGRP_PM_FAIL_ALLOC_PGS, 5620 page_cnt); 5621 goto next; 5622 } 5623 ASSERT(newpp->p_szc == pszc); 5624 /* 5625 * Clear migrate bit and relocate page 5626 */ 5627 PP_CLRMIGRATE(pp); 5628 if (page_relocate(&pp, &newpp, 0, 1, &page_cnt, to)) { 5629 panic("page_migrate: page_relocate failed"); 5630 } 5631 ASSERT(page_cnt * PAGESIZE == pgsz); 5632 5633 /* 5634 * Keep stats for number of pages migrated from and to 5635 * each lgroup 5636 */ 5637 lgrp_stat_add(from->lgrp_id, LGRP_PM_SRC_PGS, page_cnt); 5638 lgrp_stat_add(to->lgrp_id, LGRP_PM_DEST_PGS, page_cnt); 5639 /* 5640 * update the page_t array we were passed in and 5641 * unlink constituent pages of a large page. 5642 */ 5643 for (i = 0; i < page_cnt; ++i, ++pp) { 5644 ASSERT(PAGE_EXCL(newpp)); 5645 ASSERT(newpp->p_szc == pszc); 5646 ppa[i] = newpp; 5647 pp = newpp; 5648 page_sub(&newpp, pp); 5649 page_downgrade(pp); 5650 } 5651 ASSERT(newpp == NULL); 5652 next: 5653 addr += pgsz; 5654 ppa += page_cnt; 5655 npages -= page_cnt; 5656 } 5657 } 5658 5659 ulong_t mem_waiters = 0; 5660 ulong_t max_count = 20; 5661 #define MAX_DELAY 0x1ff 5662 5663 /* 5664 * Check if enough memory is available to proceed. 5665 * Depending on system configuration and how much memory is 5666 * reserved for swap we need to check against two variables. 5667 * e.g. on systems with little physical swap availrmem can be 5668 * more reliable indicator of how much memory is available. 5669 * On systems with large phys swap freemem can be better indicator. 5670 * If freemem drops below threshold level don't return an error 5671 * immediately but wake up pageout to free memory and block. 5672 * This is done number of times. If pageout is not able to free 5673 * memory within certain time return an error. 5674 * The same applies for availrmem but kmem_reap is used to 5675 * free memory. 5676 */ 5677 int 5678 page_mem_avail(pgcnt_t npages) 5679 { 5680 ulong_t count; 5681 5682 #if defined(__i386) 5683 if (freemem > desfree + npages && 5684 availrmem > swapfs_reserve + npages && 5685 btop(vmem_size(heap_arena, VMEM_FREE)) > tune.t_minarmem + 5686 npages) 5687 return (1); 5688 #else 5689 if (freemem > desfree + npages && 5690 availrmem > swapfs_reserve + npages) 5691 return (1); 5692 #endif 5693 5694 count = max_count; 5695 atomic_add_long(&mem_waiters, 1); 5696 5697 while (freemem < desfree + npages && --count) { 5698 cv_signal(&proc_pageout->p_cv); 5699 if (delay_sig(hz + (mem_waiters & MAX_DELAY))) { 5700 atomic_add_long(&mem_waiters, -1); 5701 return (0); 5702 } 5703 } 5704 if (count == 0) { 5705 atomic_add_long(&mem_waiters, -1); 5706 return (0); 5707 } 5708 5709 count = max_count; 5710 while (availrmem < swapfs_reserve + npages && --count) { 5711 kmem_reap(); 5712 if (delay_sig(hz + (mem_waiters & MAX_DELAY))) { 5713 atomic_add_long(&mem_waiters, -1); 5714 return (0); 5715 } 5716 } 5717 atomic_add_long(&mem_waiters, -1); 5718 if (count == 0) 5719 return (0); 5720 5721 #if defined(__i386) 5722 if (btop(vmem_size(heap_arena, VMEM_FREE)) < 5723 tune.t_minarmem + npages) 5724 return (0); 5725 #endif 5726 return (1); 5727 } 5728 5729 #define MAX_CNT 60 /* max num of iterations */ 5730 /* 5731 * Reclaim/reserve availrmem for npages. 5732 * If there is not enough memory start reaping seg, kmem caches. 5733 * Start pageout scanner (via page_needfree()). 5734 * Exit after ~ MAX_CNT s regardless of how much memory has been released. 5735 * Note: There is no guarantee that any availrmem will be freed as 5736 * this memory typically is locked (kernel heap) or reserved for swap. 5737 * Also due to memory fragmentation kmem allocator may not be able 5738 * to free any memory (single user allocated buffer will prevent 5739 * freeing slab or a page). 5740 */ 5741 int 5742 page_reclaim_mem(pgcnt_t npages, pgcnt_t epages, int adjust) 5743 { 5744 int i = 0; 5745 int ret = 0; 5746 pgcnt_t deficit; 5747 pgcnt_t old_availrmem; 5748 5749 mutex_enter(&freemem_lock); 5750 old_availrmem = availrmem - 1; 5751 while ((availrmem < tune.t_minarmem + npages + epages) && 5752 (old_availrmem < availrmem) && (i++ < MAX_CNT)) { 5753 old_availrmem = availrmem; 5754 deficit = tune.t_minarmem + npages + epages - availrmem; 5755 mutex_exit(&freemem_lock); 5756 page_needfree(deficit); 5757 kmem_reap(); 5758 delay(hz); 5759 page_needfree(-(spgcnt_t)deficit); 5760 mutex_enter(&freemem_lock); 5761 } 5762 5763 if (adjust && (availrmem >= tune.t_minarmem + npages + epages)) { 5764 availrmem -= npages; 5765 ret = 1; 5766 } 5767 5768 mutex_exit(&freemem_lock); 5769 5770 return (ret); 5771 } 5772 5773 /* 5774 * Search the memory segments to locate the desired page. Within a 5775 * segment, pages increase linearly with one page structure per 5776 * physical page frame (size PAGESIZE). The search begins 5777 * with the segment that was accessed last, to take advantage of locality. 5778 * If the hint misses, we start from the beginning of the sorted memseg list 5779 */ 5780 5781 5782 /* 5783 * Some data structures for pfn to pp lookup. 5784 */ 5785 ulong_t mhash_per_slot; 5786 struct memseg *memseg_hash[N_MEM_SLOTS]; 5787 5788 page_t * 5789 page_numtopp_nolock(pfn_t pfnum) 5790 { 5791 struct memseg *seg; 5792 page_t *pp; 5793 vm_cpu_data_t *vc; 5794 5795 /* 5796 * We need to disable kernel preemption while referencing the 5797 * cpu_vm_data field in order to prevent us from being switched to 5798 * another cpu and trying to reference it after it has been freed. 5799 * This will keep us on cpu and prevent it from being removed while 5800 * we are still on it. 5801 */ 5802 kpreempt_disable(); 5803 vc = CPU->cpu_vm_data; 5804 ASSERT(vc != NULL); 5805 5806 MEMSEG_STAT_INCR(nsearch); 5807 5808 /* Try last winner first */ 5809 if (((seg = vc->vc_pnum_memseg) != NULL) && 5810 (pfnum >= seg->pages_base) && (pfnum < seg->pages_end)) { 5811 MEMSEG_STAT_INCR(nlastwon); 5812 pp = seg->pages + (pfnum - seg->pages_base); 5813 if (pp->p_pagenum == pfnum) { 5814 kpreempt_enable(); 5815 return ((page_t *)pp); 5816 } 5817 } 5818 5819 /* Else Try hash */ 5820 if (((seg = memseg_hash[MEMSEG_PFN_HASH(pfnum)]) != NULL) && 5821 (pfnum >= seg->pages_base) && (pfnum < seg->pages_end)) { 5822 MEMSEG_STAT_INCR(nhashwon); 5823 vc->vc_pnum_memseg = seg; 5824 pp = seg->pages + (pfnum - seg->pages_base); 5825 if (pp->p_pagenum == pfnum) { 5826 kpreempt_enable(); 5827 return ((page_t *)pp); 5828 } 5829 } 5830 5831 /* Else Brute force */ 5832 for (seg = memsegs; seg != NULL; seg = seg->next) { 5833 if (pfnum >= seg->pages_base && pfnum < seg->pages_end) { 5834 vc->vc_pnum_memseg = seg; 5835 pp = seg->pages + (pfnum - seg->pages_base); 5836 kpreempt_enable(); 5837 return ((page_t *)pp); 5838 } 5839 } 5840 vc->vc_pnum_memseg = NULL; 5841 kpreempt_enable(); 5842 MEMSEG_STAT_INCR(nnotfound); 5843 return ((page_t *)NULL); 5844 5845 } 5846 5847 struct memseg * 5848 page_numtomemseg_nolock(pfn_t pfnum) 5849 { 5850 struct memseg *seg; 5851 page_t *pp; 5852 5853 /* Try hash */ 5854 if (((seg = memseg_hash[MEMSEG_PFN_HASH(pfnum)]) != NULL) && 5855 (pfnum >= seg->pages_base) && (pfnum < seg->pages_end)) { 5856 pp = seg->pages + (pfnum - seg->pages_base); 5857 if (pp->p_pagenum == pfnum) 5858 return (seg); 5859 } 5860 5861 /* Else Brute force */ 5862 for (seg = memsegs; seg != NULL; seg = seg->next) { 5863 if (pfnum >= seg->pages_base && pfnum < seg->pages_end) { 5864 return (seg); 5865 } 5866 } 5867 return ((struct memseg *)NULL); 5868 } 5869 5870 /* 5871 * Given a page and a count return the page struct that is 5872 * n structs away from the current one in the global page 5873 * list. 5874 * 5875 * This function wraps to the first page upon 5876 * reaching the end of the memseg list. 5877 */ 5878 page_t * 5879 page_nextn(page_t *pp, ulong_t n) 5880 { 5881 struct memseg *seg; 5882 page_t *ppn; 5883 vm_cpu_data_t *vc; 5884 5885 /* 5886 * We need to disable kernel preemption while referencing the 5887 * cpu_vm_data field in order to prevent us from being switched to 5888 * another cpu and trying to reference it after it has been freed. 5889 * This will keep us on cpu and prevent it from being removed while 5890 * we are still on it. 5891 */ 5892 kpreempt_disable(); 5893 vc = (vm_cpu_data_t *)CPU->cpu_vm_data; 5894 5895 ASSERT(vc != NULL); 5896 5897 if (((seg = vc->vc_pnext_memseg) == NULL) || 5898 (seg->pages_base == seg->pages_end) || 5899 !(pp >= seg->pages && pp < seg->epages)) { 5900 5901 for (seg = memsegs; seg; seg = seg->next) { 5902 if (pp >= seg->pages && pp < seg->epages) 5903 break; 5904 } 5905 5906 if (seg == NULL) { 5907 /* Memory delete got in, return something valid. */ 5908 /* TODO: fix me. */ 5909 seg = memsegs; 5910 pp = seg->pages; 5911 } 5912 } 5913 5914 /* check for wraparound - possible if n is large */ 5915 while ((ppn = (pp + n)) >= seg->epages || ppn < pp) { 5916 n -= seg->epages - pp; 5917 seg = seg->next; 5918 if (seg == NULL) 5919 seg = memsegs; 5920 pp = seg->pages; 5921 } 5922 vc->vc_pnext_memseg = seg; 5923 kpreempt_enable(); 5924 return (ppn); 5925 } 5926 5927 /* 5928 * Initialize for a loop using page_next_scan_large(). 5929 */ 5930 page_t * 5931 page_next_scan_init(void **cookie) 5932 { 5933 ASSERT(cookie != NULL); 5934 *cookie = (void *)memsegs; 5935 return ((page_t *)memsegs->pages); 5936 } 5937 5938 /* 5939 * Return the next page in a scan of page_t's, assuming we want 5940 * to skip over sub-pages within larger page sizes. 5941 * 5942 * The cookie is used to keep track of the current memseg. 5943 */ 5944 page_t * 5945 page_next_scan_large( 5946 page_t *pp, 5947 ulong_t *n, 5948 void **cookie) 5949 { 5950 struct memseg *seg = (struct memseg *)*cookie; 5951 page_t *new_pp; 5952 ulong_t cnt; 5953 pfn_t pfn; 5954 5955 5956 /* 5957 * get the count of page_t's to skip based on the page size 5958 */ 5959 ASSERT(pp != NULL); 5960 if (pp->p_szc == 0) { 5961 cnt = 1; 5962 } else { 5963 pfn = page_pptonum(pp); 5964 cnt = page_get_pagecnt(pp->p_szc); 5965 cnt -= pfn & (cnt - 1); 5966 } 5967 *n += cnt; 5968 new_pp = pp + cnt; 5969 5970 /* 5971 * Catch if we went past the end of the current memory segment. If so, 5972 * just move to the next segment with pages. 5973 */ 5974 if (new_pp >= seg->epages) { 5975 do { 5976 seg = seg->next; 5977 if (seg == NULL) 5978 seg = memsegs; 5979 } while (seg->pages == seg->epages); 5980 new_pp = seg->pages; 5981 *cookie = (void *)seg; 5982 } 5983 5984 return (new_pp); 5985 } 5986 5987 5988 /* 5989 * Returns next page in list. Note: this function wraps 5990 * to the first page in the list upon reaching the end 5991 * of the list. Callers should be aware of this fact. 5992 */ 5993 5994 /* We should change this be a #define */ 5995 5996 page_t * 5997 page_next(page_t *pp) 5998 { 5999 return (page_nextn(pp, 1)); 6000 } 6001 6002 page_t * 6003 page_first() 6004 { 6005 return ((page_t *)memsegs->pages); 6006 } 6007 6008 6009 /* 6010 * This routine is called at boot with the initial memory configuration 6011 * and when memory is added or removed. 6012 */ 6013 void 6014 build_pfn_hash() 6015 { 6016 pfn_t cur; 6017 pgcnt_t index; 6018 struct memseg *pseg; 6019 int i; 6020 6021 /* 6022 * Clear memseg_hash array. 6023 * Since memory add/delete is designed to operate concurrently 6024 * with normal operation, the hash rebuild must be able to run 6025 * concurrently with page_numtopp_nolock(). To support this 6026 * functionality, assignments to memseg_hash array members must 6027 * be done atomically. 6028 * 6029 * NOTE: bzero() does not currently guarantee this for kernel 6030 * threads, and cannot be used here. 6031 */ 6032 for (i = 0; i < N_MEM_SLOTS; i++) 6033 memseg_hash[i] = NULL; 6034 6035 hat_kpm_mseghash_clear(N_MEM_SLOTS); 6036 6037 /* 6038 * Physmax is the last valid pfn. 6039 */ 6040 mhash_per_slot = (physmax + 1) >> MEM_HASH_SHIFT; 6041 for (pseg = memsegs; pseg != NULL; pseg = pseg->next) { 6042 index = MEMSEG_PFN_HASH(pseg->pages_base); 6043 cur = pseg->pages_base; 6044 do { 6045 if (index >= N_MEM_SLOTS) 6046 index = MEMSEG_PFN_HASH(cur); 6047 6048 if (memseg_hash[index] == NULL || 6049 memseg_hash[index]->pages_base > pseg->pages_base) { 6050 memseg_hash[index] = pseg; 6051 hat_kpm_mseghash_update(index, pseg); 6052 } 6053 cur += mhash_per_slot; 6054 index++; 6055 } while (cur < pseg->pages_end); 6056 } 6057 } 6058 6059 /* 6060 * Return the pagenum for the pp 6061 */ 6062 pfn_t 6063 page_pptonum(page_t *pp) 6064 { 6065 return (pp->p_pagenum); 6066 } 6067 6068 /* 6069 * interface to the referenced and modified etc bits 6070 * in the PSM part of the page struct 6071 * when no locking is desired. 6072 */ 6073 void 6074 page_set_props(page_t *pp, uint_t flags) 6075 { 6076 ASSERT((flags & ~(P_MOD | P_REF | P_RO)) == 0); 6077 pp->p_nrm |= (uchar_t)flags; 6078 } 6079 6080 extern void mach_sync_icache_pp(page_t *); 6081 #pragma weak mach_sync_icache_pp 6082 6083 /* 6084 * Flush I-cache if the page is being reassigned. The hashout flag is 6085 * set when a page has been removed from a hash chain (i.e. vnode 6086 * pages). If the page stays on the hash chain there is a chance it 6087 * will be re-used, therefore there is no need to flush the 6088 * I-cache. However, if the page is being removed from a hash chain 6089 * then the page can be used for any new purpose, and the I-cache must 6090 * be flushed. 6091 */ 6092 /* ARGSUSED */ 6093 void 6094 page_clr_all_props(page_t *pp, int hashout) 6095 { 6096 if (&mach_sync_icache_pp != NULL && hashout) { 6097 mach_sync_icache_pp(pp); 6098 } 6099 pp->p_nrm = 0; 6100 } 6101 6102 /* 6103 * Clear p_lckcnt and p_cowcnt, adjusting freemem if required. 6104 */ 6105 int 6106 page_clear_lck_cow(page_t *pp, int adjust) 6107 { 6108 int f_amount; 6109 6110 ASSERT(PAGE_EXCL(pp)); 6111 6112 /* 6113 * The page_struct_lock need not be acquired here since 6114 * we require the caller hold the page exclusively locked. 6115 */ 6116 f_amount = 0; 6117 if (pp->p_lckcnt) { 6118 f_amount = 1; 6119 pp->p_lckcnt = 0; 6120 } 6121 if (pp->p_cowcnt) { 6122 f_amount += pp->p_cowcnt; 6123 pp->p_cowcnt = 0; 6124 } 6125 6126 if (adjust && f_amount) { 6127 mutex_enter(&freemem_lock); 6128 availrmem += f_amount; 6129 mutex_exit(&freemem_lock); 6130 } 6131 6132 return (f_amount); 6133 } 6134 6135 /* 6136 * The following functions is called from free_vp_pages() 6137 * for an inexact estimate of a newly free'd page... 6138 */ 6139 ulong_t 6140 page_share_cnt(page_t *pp) 6141 { 6142 return (hat_page_getshare(pp)); 6143 } 6144 6145 int 6146 page_isshared(page_t *pp) 6147 { 6148 return (hat_page_checkshare(pp, 1)); 6149 } 6150 6151 int 6152 page_isfree(page_t *pp) 6153 { 6154 return (PP_ISFREE(pp)); 6155 } 6156 6157 int 6158 page_isref(page_t *pp) 6159 { 6160 return (hat_page_getattr(pp, P_REF)); 6161 } 6162 6163 int 6164 page_ismod(page_t *pp) 6165 { 6166 return (hat_page_getattr(pp, P_MOD)); 6167 } 6168 6169 /* 6170 * The following code all currently relates to the page capture logic: 6171 * 6172 * This logic is used for cases where there is a desire to claim a certain 6173 * physical page in the system for the caller. As it may not be possible 6174 * to capture the page immediately, the p_toxic bits are used in the page 6175 * structure to indicate that someone wants to capture this page. When the 6176 * page gets unlocked, the toxic flag will be noted and an attempt to capture 6177 * the page will be made. If it is successful, the original callers callback 6178 * will be called with the page to do with it what they please. 6179 * 6180 * There is also an async thread which wakes up to attempt to capture 6181 * pages occasionally which have the capture bit set. All of the pages which 6182 * need to be captured asynchronously have been inserted into the 6183 * page_capture_hash and thus this thread walks that hash list. Items in the 6184 * hash have an expiration time so this thread handles that as well by removing 6185 * the item from the hash if it has expired. 6186 * 6187 * Some important things to note are: 6188 * - if the PR_CAPTURE bit is set on a page, then the page is in the 6189 * page_capture_hash. The page_capture_hash_head.pchh_mutex is needed 6190 * to set and clear this bit, and while the lock is held is the only time 6191 * you can add or remove an entry from the hash. 6192 * - the PR_CAPTURE bit can only be set and cleared while holding the 6193 * page_capture_hash_head.pchh_mutex 6194 * - the t_flag field of the thread struct is used with the T_CAPTURING 6195 * flag to prevent recursion while dealing with large pages. 6196 * - pages which need to be retired never expire on the page_capture_hash. 6197 */ 6198 6199 static void page_capture_thread(void); 6200 static kthread_t *pc_thread_id; 6201 kcondvar_t pc_cv; 6202 static kmutex_t pc_thread_mutex; 6203 static clock_t pc_thread_shortwait; 6204 static clock_t pc_thread_longwait; 6205 static int pc_thread_retry; 6206 6207 struct page_capture_callback pc_cb[PC_NUM_CALLBACKS]; 6208 6209 /* Note that this is a circular linked list */ 6210 typedef struct page_capture_hash_bucket { 6211 page_t *pp; 6212 uint_t szc; 6213 uint_t flags; 6214 clock_t expires; /* lbolt at which this request expires. */ 6215 void *datap; /* Cached data passed in for callback */ 6216 struct page_capture_hash_bucket *next; 6217 struct page_capture_hash_bucket *prev; 6218 } page_capture_hash_bucket_t; 6219 6220 /* 6221 * Each hash bucket will have it's own mutex and two lists which are: 6222 * active (0): represents requests which have not been processed by 6223 * the page_capture async thread yet. 6224 * walked (1): represents requests which have been processed by the 6225 * page_capture async thread within it's given walk of this bucket. 6226 * 6227 * These are all needed so that we can synchronize all async page_capture 6228 * events. When the async thread moves to a new bucket, it will append the 6229 * walked list to the active list and walk each item one at a time, moving it 6230 * from the active list to the walked list. Thus if there is an async request 6231 * outstanding for a given page, it will always be in one of the two lists. 6232 * New requests will always be added to the active list. 6233 * If we were not able to capture a page before the request expired, we'd free 6234 * up the request structure which would indicate to page_capture that there is 6235 * no longer a need for the given page, and clear the PR_CAPTURE flag if 6236 * possible. 6237 */ 6238 typedef struct page_capture_hash_head { 6239 kmutex_t pchh_mutex; 6240 uint_t num_pages; 6241 page_capture_hash_bucket_t lists[2]; /* sentinel nodes */ 6242 } page_capture_hash_head_t; 6243 6244 #ifdef DEBUG 6245 #define NUM_PAGE_CAPTURE_BUCKETS 4 6246 #else 6247 #define NUM_PAGE_CAPTURE_BUCKETS 64 6248 #endif 6249 6250 page_capture_hash_head_t page_capture_hash[NUM_PAGE_CAPTURE_BUCKETS]; 6251 6252 /* for now use a very simple hash based upon the size of a page struct */ 6253 #define PAGE_CAPTURE_HASH(pp) \ 6254 ((int)(((uintptr_t)pp >> 7) & (NUM_PAGE_CAPTURE_BUCKETS - 1))) 6255 6256 extern pgcnt_t swapfs_minfree; 6257 6258 int page_trycapture(page_t *pp, uint_t szc, uint_t flags, void *datap); 6259 6260 /* 6261 * a callback function is required for page capture requests. 6262 */ 6263 void 6264 page_capture_register_callback(uint_t index, clock_t duration, 6265 int (*cb_func)(page_t *, void *, uint_t)) 6266 { 6267 ASSERT(pc_cb[index].cb_active == 0); 6268 ASSERT(cb_func != NULL); 6269 rw_enter(&pc_cb[index].cb_rwlock, RW_WRITER); 6270 pc_cb[index].duration = duration; 6271 pc_cb[index].cb_func = cb_func; 6272 pc_cb[index].cb_active = 1; 6273 rw_exit(&pc_cb[index].cb_rwlock); 6274 } 6275 6276 void 6277 page_capture_unregister_callback(uint_t index) 6278 { 6279 int i, j; 6280 struct page_capture_hash_bucket *bp1; 6281 struct page_capture_hash_bucket *bp2; 6282 struct page_capture_hash_bucket *head = NULL; 6283 uint_t flags = (1 << index); 6284 6285 rw_enter(&pc_cb[index].cb_rwlock, RW_WRITER); 6286 ASSERT(pc_cb[index].cb_active == 1); 6287 pc_cb[index].duration = 0; /* Paranoia */ 6288 pc_cb[index].cb_func = NULL; /* Paranoia */ 6289 pc_cb[index].cb_active = 0; 6290 rw_exit(&pc_cb[index].cb_rwlock); 6291 6292 /* 6293 * Just move all the entries to a private list which we can walk 6294 * through without the need to hold any locks. 6295 * No more requests can get added to the hash lists for this consumer 6296 * as the cb_active field for the callback has been cleared. 6297 */ 6298 for (i = 0; i < NUM_PAGE_CAPTURE_BUCKETS; i++) { 6299 mutex_enter(&page_capture_hash[i].pchh_mutex); 6300 for (j = 0; j < 2; j++) { 6301 bp1 = page_capture_hash[i].lists[j].next; 6302 /* walk through all but first (sentinel) element */ 6303 while (bp1 != &page_capture_hash[i].lists[j]) { 6304 bp2 = bp1; 6305 if (bp2->flags & flags) { 6306 bp1 = bp2->next; 6307 bp1->prev = bp2->prev; 6308 bp2->prev->next = bp1; 6309 bp2->next = head; 6310 head = bp2; 6311 /* 6312 * Clear the PR_CAPTURE bit as we 6313 * hold appropriate locks here. 6314 */ 6315 page_clrtoxic(head->pp, PR_CAPTURE); 6316 page_capture_hash[i].num_pages--; 6317 continue; 6318 } 6319 bp1 = bp1->next; 6320 } 6321 } 6322 mutex_exit(&page_capture_hash[i].pchh_mutex); 6323 } 6324 6325 while (head != NULL) { 6326 bp1 = head; 6327 head = head->next; 6328 kmem_free(bp1, sizeof (*bp1)); 6329 } 6330 } 6331 6332 6333 /* 6334 * Find pp in the active list and move it to the walked list if it 6335 * exists. 6336 * Note that most often pp should be at the front of the active list 6337 * as it is currently used and thus there is no other sort of optimization 6338 * being done here as this is a linked list data structure. 6339 * Returns 1 on successful move or 0 if page could not be found. 6340 */ 6341 static int 6342 page_capture_move_to_walked(page_t *pp) 6343 { 6344 page_capture_hash_bucket_t *bp; 6345 int index; 6346 6347 index = PAGE_CAPTURE_HASH(pp); 6348 6349 mutex_enter(&page_capture_hash[index].pchh_mutex); 6350 bp = page_capture_hash[index].lists[0].next; 6351 while (bp != &page_capture_hash[index].lists[0]) { 6352 if (bp->pp == pp) { 6353 /* Remove from old list */ 6354 bp->next->prev = bp->prev; 6355 bp->prev->next = bp->next; 6356 6357 /* Add to new list */ 6358 bp->next = page_capture_hash[index].lists[1].next; 6359 bp->prev = &page_capture_hash[index].lists[1]; 6360 page_capture_hash[index].lists[1].next = bp; 6361 bp->next->prev = bp; 6362 mutex_exit(&page_capture_hash[index].pchh_mutex); 6363 6364 return (1); 6365 } 6366 bp = bp->next; 6367 } 6368 mutex_exit(&page_capture_hash[index].pchh_mutex); 6369 return (0); 6370 } 6371 6372 /* 6373 * Add a new entry to the page capture hash. The only case where a new 6374 * entry is not added is when the page capture consumer is no longer registered. 6375 * In this case, we'll silently not add the page to the hash. We know that 6376 * page retire will always be registered for the case where we are currently 6377 * unretiring a page and thus there are no conflicts. 6378 */ 6379 static void 6380 page_capture_add_hash(page_t *pp, uint_t szc, uint_t flags, void *datap) 6381 { 6382 page_capture_hash_bucket_t *bp1; 6383 page_capture_hash_bucket_t *bp2; 6384 int index; 6385 int cb_index; 6386 int i; 6387 #ifdef DEBUG 6388 page_capture_hash_bucket_t *tp1; 6389 int l; 6390 #endif 6391 6392 ASSERT(!(flags & CAPTURE_ASYNC)); 6393 6394 bp1 = kmem_alloc(sizeof (struct page_capture_hash_bucket), KM_SLEEP); 6395 6396 bp1->pp = pp; 6397 bp1->szc = szc; 6398 bp1->flags = flags; 6399 bp1->datap = datap; 6400 6401 for (cb_index = 0; cb_index < PC_NUM_CALLBACKS; cb_index++) { 6402 if ((flags >> cb_index) & 1) { 6403 break; 6404 } 6405 } 6406 6407 ASSERT(cb_index != PC_NUM_CALLBACKS); 6408 6409 rw_enter(&pc_cb[cb_index].cb_rwlock, RW_READER); 6410 if (pc_cb[cb_index].cb_active) { 6411 if (pc_cb[cb_index].duration == -1) { 6412 bp1->expires = (clock_t)-1; 6413 } else { 6414 bp1->expires = lbolt + pc_cb[cb_index].duration; 6415 } 6416 } else { 6417 /* There's no callback registered so don't add to the hash */ 6418 rw_exit(&pc_cb[cb_index].cb_rwlock); 6419 kmem_free(bp1, sizeof (*bp1)); 6420 return; 6421 } 6422 6423 index = PAGE_CAPTURE_HASH(pp); 6424 6425 /* 6426 * Only allow capture flag to be modified under this mutex. 6427 * Prevents multiple entries for same page getting added. 6428 */ 6429 mutex_enter(&page_capture_hash[index].pchh_mutex); 6430 6431 /* 6432 * if not already on the hash, set capture bit and add to the hash 6433 */ 6434 if (!(pp->p_toxic & PR_CAPTURE)) { 6435 #ifdef DEBUG 6436 /* Check for duplicate entries */ 6437 for (l = 0; l < 2; l++) { 6438 tp1 = page_capture_hash[index].lists[l].next; 6439 while (tp1 != &page_capture_hash[index].lists[l]) { 6440 if (tp1->pp == pp) { 6441 panic("page pp 0x%p already on hash " 6442 "at 0x%p\n", 6443 (void *)pp, (void *)tp1); 6444 } 6445 tp1 = tp1->next; 6446 } 6447 } 6448 6449 #endif 6450 page_settoxic(pp, PR_CAPTURE); 6451 bp1->next = page_capture_hash[index].lists[0].next; 6452 bp1->prev = &page_capture_hash[index].lists[0]; 6453 bp1->next->prev = bp1; 6454 page_capture_hash[index].lists[0].next = bp1; 6455 page_capture_hash[index].num_pages++; 6456 if (flags & CAPTURE_RETIRE) { 6457 page_retire_incr_pend_count(datap); 6458 } 6459 mutex_exit(&page_capture_hash[index].pchh_mutex); 6460 rw_exit(&pc_cb[cb_index].cb_rwlock); 6461 cv_signal(&pc_cv); 6462 return; 6463 } 6464 6465 /* 6466 * A page retire request will replace any other request. 6467 * A second physmem request which is for a different process than 6468 * the currently registered one will be dropped as there is 6469 * no way to hold the private data for both calls. 6470 * In the future, once there are more callers, this will have to 6471 * be worked out better as there needs to be private storage for 6472 * at least each type of caller (maybe have datap be an array of 6473 * *void's so that we can index based upon callers index). 6474 */ 6475 6476 /* walk hash list to update expire time */ 6477 for (i = 0; i < 2; i++) { 6478 bp2 = page_capture_hash[index].lists[i].next; 6479 while (bp2 != &page_capture_hash[index].lists[i]) { 6480 if (bp2->pp == pp) { 6481 if (flags & CAPTURE_RETIRE) { 6482 if (!(bp2->flags & CAPTURE_RETIRE)) { 6483 page_retire_incr_pend_count( 6484 datap); 6485 bp2->flags = flags; 6486 bp2->expires = bp1->expires; 6487 bp2->datap = datap; 6488 } 6489 } else { 6490 ASSERT(flags & CAPTURE_PHYSMEM); 6491 if (!(bp2->flags & CAPTURE_RETIRE) && 6492 (datap == bp2->datap)) { 6493 bp2->expires = bp1->expires; 6494 } 6495 } 6496 mutex_exit(&page_capture_hash[index]. 6497 pchh_mutex); 6498 rw_exit(&pc_cb[cb_index].cb_rwlock); 6499 kmem_free(bp1, sizeof (*bp1)); 6500 return; 6501 } 6502 bp2 = bp2->next; 6503 } 6504 } 6505 6506 /* 6507 * the PR_CAPTURE flag is protected by the page_capture_hash mutexes 6508 * and thus it either has to be set or not set and can't change 6509 * while holding the mutex above. 6510 */ 6511 panic("page_capture_add_hash, PR_CAPTURE flag set on pp %p\n", 6512 (void *)pp); 6513 } 6514 6515 /* 6516 * We have a page in our hands, lets try and make it ours by turning 6517 * it into a clean page like it had just come off the freelists. 6518 * 6519 * Returns 0 on success, with the page still EXCL locked. 6520 * On failure, the page will be unlocked, and returns EAGAIN 6521 */ 6522 static int 6523 page_capture_clean_page(page_t *pp) 6524 { 6525 page_t *newpp; 6526 int skip_unlock = 0; 6527 spgcnt_t count; 6528 page_t *tpp; 6529 int ret = 0; 6530 int extra; 6531 6532 ASSERT(PAGE_EXCL(pp)); 6533 ASSERT(!PP_RETIRED(pp)); 6534 ASSERT(curthread->t_flag & T_CAPTURING); 6535 6536 if (PP_ISFREE(pp)) { 6537 if (!page_reclaim(pp, NULL)) { 6538 skip_unlock = 1; 6539 ret = EAGAIN; 6540 goto cleanup; 6541 } 6542 ASSERT(pp->p_szc == 0); 6543 if (pp->p_vnode != NULL) { 6544 /* 6545 * Since this page came from the 6546 * cachelist, we must destroy the 6547 * old vnode association. 6548 */ 6549 page_hashout(pp, NULL); 6550 } 6551 goto cleanup; 6552 } 6553 6554 /* 6555 * If we know page_relocate will fail, skip it 6556 * It could still fail due to a UE on another page but we 6557 * can't do anything about that. 6558 */ 6559 if (pp->p_toxic & PR_UE) { 6560 goto skip_relocate; 6561 } 6562 6563 /* 6564 * It's possible that pages can not have a vnode as fsflush comes 6565 * through and cleans up these pages. It's ugly but that's how it is. 6566 */ 6567 if (pp->p_vnode == NULL) { 6568 goto skip_relocate; 6569 } 6570 6571 /* 6572 * Page was not free, so lets try to relocate it. 6573 * page_relocate only works with root pages, so if this is not a root 6574 * page, we need to demote it to try and relocate it. 6575 * Unfortunately this is the best we can do right now. 6576 */ 6577 newpp = NULL; 6578 if ((pp->p_szc > 0) && (pp != PP_PAGEROOT(pp))) { 6579 if (page_try_demote_pages(pp) == 0) { 6580 ret = EAGAIN; 6581 goto cleanup; 6582 } 6583 } 6584 ret = page_relocate(&pp, &newpp, 1, 0, &count, NULL); 6585 if (ret == 0) { 6586 page_t *npp; 6587 /* unlock the new page(s) */ 6588 while (count-- > 0) { 6589 ASSERT(newpp != NULL); 6590 npp = newpp; 6591 page_sub(&newpp, npp); 6592 page_unlock(npp); 6593 } 6594 ASSERT(newpp == NULL); 6595 /* 6596 * Check to see if the page we have is too large. 6597 * If so, demote it freeing up the extra pages. 6598 */ 6599 if (pp->p_szc > 0) { 6600 /* For now demote extra pages to szc == 0 */ 6601 extra = page_get_pagecnt(pp->p_szc) - 1; 6602 while (extra > 0) { 6603 tpp = pp->p_next; 6604 page_sub(&pp, tpp); 6605 tpp->p_szc = 0; 6606 page_free(tpp, 1); 6607 extra--; 6608 } 6609 /* Make sure to set our page to szc 0 as well */ 6610 ASSERT(pp->p_next == pp && pp->p_prev == pp); 6611 pp->p_szc = 0; 6612 } 6613 goto cleanup; 6614 } else if (ret == EIO) { 6615 ret = EAGAIN; 6616 goto cleanup; 6617 } else { 6618 /* 6619 * Need to reset return type as we failed to relocate the page 6620 * but that does not mean that some of the next steps will not 6621 * work. 6622 */ 6623 ret = 0; 6624 } 6625 6626 skip_relocate: 6627 6628 if (pp->p_szc > 0) { 6629 if (page_try_demote_pages(pp) == 0) { 6630 ret = EAGAIN; 6631 goto cleanup; 6632 } 6633 } 6634 6635 ASSERT(pp->p_szc == 0); 6636 6637 if (hat_ismod(pp)) { 6638 ret = EAGAIN; 6639 goto cleanup; 6640 } 6641 if (PP_ISKAS(pp)) { 6642 ret = EAGAIN; 6643 goto cleanup; 6644 } 6645 if (pp->p_lckcnt || pp->p_cowcnt) { 6646 ret = EAGAIN; 6647 goto cleanup; 6648 } 6649 6650 (void) hat_pageunload(pp, HAT_FORCE_PGUNLOAD); 6651 ASSERT(!hat_page_is_mapped(pp)); 6652 6653 if (hat_ismod(pp)) { 6654 /* 6655 * This is a semi-odd case as the page is now modified but not 6656 * mapped as we just unloaded the mappings above. 6657 */ 6658 ret = EAGAIN; 6659 goto cleanup; 6660 } 6661 if (pp->p_vnode != NULL) { 6662 page_hashout(pp, NULL); 6663 } 6664 6665 /* 6666 * At this point, the page should be in a clean state and 6667 * we can do whatever we want with it. 6668 */ 6669 6670 cleanup: 6671 if (ret != 0) { 6672 if (!skip_unlock) { 6673 page_unlock(pp); 6674 } 6675 } else { 6676 ASSERT(pp->p_szc == 0); 6677 ASSERT(PAGE_EXCL(pp)); 6678 6679 pp->p_next = pp; 6680 pp->p_prev = pp; 6681 } 6682 return (ret); 6683 } 6684 6685 /* 6686 * Various callers of page_trycapture() can have different restrictions upon 6687 * what memory they have access to. 6688 * Returns 0 on success, with the following error codes on failure: 6689 * EPERM - The requested page is long term locked, and thus repeated 6690 * requests to capture this page will likely fail. 6691 * ENOMEM - There was not enough free memory in the system to safely 6692 * map the requested page. 6693 * ENOENT - The requested page was inside the kernel cage, and the 6694 * PHYSMEM_CAGE flag was not set. 6695 */ 6696 int 6697 page_capture_pre_checks(page_t *pp, uint_t flags) 6698 { 6699 #if defined(__sparc) 6700 extern struct vnode prom_ppages; 6701 #endif /* __sparc */ 6702 6703 ASSERT(pp != NULL); 6704 6705 #if defined(__sparc) 6706 if (pp->p_vnode == &prom_ppages) { 6707 return (EPERM); 6708 } 6709 6710 if (PP_ISNORELOC(pp) && !(flags & CAPTURE_GET_CAGE) && 6711 (flags & CAPTURE_PHYSMEM)) { 6712 return (ENOENT); 6713 } 6714 6715 if (PP_ISNORELOCKERNEL(pp)) { 6716 return (EPERM); 6717 } 6718 #else 6719 if (PP_ISKAS(pp)) { 6720 return (EPERM); 6721 } 6722 #endif /* __sparc */ 6723 6724 /* only physmem currently has the restrictions checked below */ 6725 if (!(flags & CAPTURE_PHYSMEM)) { 6726 return (0); 6727 } 6728 6729 if (availrmem < swapfs_minfree) { 6730 /* 6731 * We won't try to capture this page as we are 6732 * running low on memory. 6733 */ 6734 return (ENOMEM); 6735 } 6736 return (0); 6737 } 6738 6739 /* 6740 * Once we have a page in our mits, go ahead and complete the capture 6741 * operation. 6742 * Returns 1 on failure where page is no longer needed 6743 * Returns 0 on success 6744 * Returns -1 if there was a transient failure. 6745 * Failure cases must release the SE_EXCL lock on pp (usually via page_free). 6746 */ 6747 int 6748 page_capture_take_action(page_t *pp, uint_t flags, void *datap) 6749 { 6750 int cb_index; 6751 int ret = 0; 6752 page_capture_hash_bucket_t *bp1; 6753 page_capture_hash_bucket_t *bp2; 6754 int index; 6755 int found = 0; 6756 int i; 6757 6758 ASSERT(PAGE_EXCL(pp)); 6759 ASSERT(curthread->t_flag & T_CAPTURING); 6760 6761 for (cb_index = 0; cb_index < PC_NUM_CALLBACKS; cb_index++) { 6762 if ((flags >> cb_index) & 1) { 6763 break; 6764 } 6765 } 6766 ASSERT(cb_index < PC_NUM_CALLBACKS); 6767 6768 /* 6769 * Remove the entry from the page_capture hash, but don't free it yet 6770 * as we may need to put it back. 6771 * Since we own the page at this point in time, we should find it 6772 * in the hash if this is an ASYNC call. If we don't it's likely 6773 * that the page_capture_async() thread decided that this request 6774 * had expired, in which case we just continue on. 6775 */ 6776 if (flags & CAPTURE_ASYNC) { 6777 6778 index = PAGE_CAPTURE_HASH(pp); 6779 6780 mutex_enter(&page_capture_hash[index].pchh_mutex); 6781 for (i = 0; i < 2 && !found; i++) { 6782 bp1 = page_capture_hash[index].lists[i].next; 6783 while (bp1 != &page_capture_hash[index].lists[i]) { 6784 if (bp1->pp == pp) { 6785 bp1->next->prev = bp1->prev; 6786 bp1->prev->next = bp1->next; 6787 page_capture_hash[index].num_pages--; 6788 page_clrtoxic(pp, PR_CAPTURE); 6789 found = 1; 6790 break; 6791 } 6792 bp1 = bp1->next; 6793 } 6794 } 6795 mutex_exit(&page_capture_hash[index].pchh_mutex); 6796 } 6797 6798 /* Synchronize with the unregister func. */ 6799 rw_enter(&pc_cb[cb_index].cb_rwlock, RW_READER); 6800 if (!pc_cb[cb_index].cb_active) { 6801 page_free(pp, 1); 6802 rw_exit(&pc_cb[cb_index].cb_rwlock); 6803 if (found) { 6804 kmem_free(bp1, sizeof (*bp1)); 6805 } 6806 return (1); 6807 } 6808 6809 /* 6810 * We need to remove the entry from the page capture hash and turn off 6811 * the PR_CAPTURE bit before calling the callback. We'll need to cache 6812 * the entry here, and then based upon the return value, cleanup 6813 * appropriately or re-add it to the hash, making sure that someone else 6814 * hasn't already done so. 6815 * It should be rare for the callback to fail and thus it's ok for 6816 * the failure path to be a bit complicated as the success path is 6817 * cleaner and the locking rules are easier to follow. 6818 */ 6819 6820 ret = pc_cb[cb_index].cb_func(pp, datap, flags); 6821 6822 rw_exit(&pc_cb[cb_index].cb_rwlock); 6823 6824 /* 6825 * If this was an ASYNC request, we need to cleanup the hash if the 6826 * callback was successful or if the request was no longer valid. 6827 * For non-ASYNC requests, we return failure to map and the caller 6828 * will take care of adding the request to the hash. 6829 * Note also that the callback itself is responsible for the page 6830 * at this point in time in terms of locking ... The most common 6831 * case for the failure path should just be a page_free. 6832 */ 6833 if (ret >= 0) { 6834 if (found) { 6835 if (bp1->flags & CAPTURE_RETIRE) { 6836 page_retire_decr_pend_count(datap); 6837 } 6838 kmem_free(bp1, sizeof (*bp1)); 6839 } 6840 return (ret); 6841 } 6842 if (!found) { 6843 return (ret); 6844 } 6845 6846 ASSERT(flags & CAPTURE_ASYNC); 6847 6848 /* 6849 * Check for expiration time first as we can just free it up if it's 6850 * expired. 6851 */ 6852 if (lbolt > bp1->expires && bp1->expires != -1) { 6853 kmem_free(bp1, sizeof (*bp1)); 6854 return (ret); 6855 } 6856 6857 /* 6858 * The callback failed and there used to be an entry in the hash for 6859 * this page, so we need to add it back to the hash. 6860 */ 6861 mutex_enter(&page_capture_hash[index].pchh_mutex); 6862 if (!(pp->p_toxic & PR_CAPTURE)) { 6863 /* just add bp1 back to head of walked list */ 6864 page_settoxic(pp, PR_CAPTURE); 6865 bp1->next = page_capture_hash[index].lists[1].next; 6866 bp1->prev = &page_capture_hash[index].lists[1]; 6867 bp1->next->prev = bp1; 6868 page_capture_hash[index].lists[1].next = bp1; 6869 page_capture_hash[index].num_pages++; 6870 mutex_exit(&page_capture_hash[index].pchh_mutex); 6871 return (ret); 6872 } 6873 6874 /* 6875 * Otherwise there was a new capture request added to list 6876 * Need to make sure that our original data is represented if 6877 * appropriate. 6878 */ 6879 for (i = 0; i < 2; i++) { 6880 bp2 = page_capture_hash[index].lists[i].next; 6881 while (bp2 != &page_capture_hash[index].lists[i]) { 6882 if (bp2->pp == pp) { 6883 if (bp1->flags & CAPTURE_RETIRE) { 6884 if (!(bp2->flags & CAPTURE_RETIRE)) { 6885 bp2->szc = bp1->szc; 6886 bp2->flags = bp1->flags; 6887 bp2->expires = bp1->expires; 6888 bp2->datap = bp1->datap; 6889 } 6890 } else { 6891 ASSERT(bp1->flags & CAPTURE_PHYSMEM); 6892 if (!(bp2->flags & CAPTURE_RETIRE)) { 6893 bp2->szc = bp1->szc; 6894 bp2->flags = bp1->flags; 6895 bp2->expires = bp1->expires; 6896 bp2->datap = bp1->datap; 6897 } 6898 } 6899 mutex_exit(&page_capture_hash[index]. 6900 pchh_mutex); 6901 kmem_free(bp1, sizeof (*bp1)); 6902 return (ret); 6903 } 6904 bp2 = bp2->next; 6905 } 6906 } 6907 panic("PR_CAPTURE set but not on hash for pp 0x%p\n", (void *)pp); 6908 /*NOTREACHED*/ 6909 } 6910 6911 /* 6912 * Try to capture the given page for the caller specified in the flags 6913 * parameter. The page will either be captured and handed over to the 6914 * appropriate callback, or will be queued up in the page capture hash 6915 * to be captured asynchronously. 6916 * If the current request is due to an async capture, the page must be 6917 * exclusively locked before calling this function. 6918 * Currently szc must be 0 but in the future this should be expandable to 6919 * other page sizes. 6920 * Returns 0 on success, with the following error codes on failure: 6921 * EPERM - The requested page is long term locked, and thus repeated 6922 * requests to capture this page will likely fail. 6923 * ENOMEM - There was not enough free memory in the system to safely 6924 * map the requested page. 6925 * ENOENT - The requested page was inside the kernel cage, and the 6926 * CAPTURE_GET_CAGE flag was not set. 6927 * EAGAIN - The requested page could not be capturead at this point in 6928 * time but future requests will likely work. 6929 * EBUSY - The requested page is retired and the CAPTURE_GET_RETIRED flag 6930 * was not set. 6931 */ 6932 int 6933 page_itrycapture(page_t *pp, uint_t szc, uint_t flags, void *datap) 6934 { 6935 int ret; 6936 int cb_index; 6937 6938 if (flags & CAPTURE_ASYNC) { 6939 ASSERT(PAGE_EXCL(pp)); 6940 goto async; 6941 } 6942 6943 /* Make sure there's enough availrmem ... */ 6944 ret = page_capture_pre_checks(pp, flags); 6945 if (ret != 0) { 6946 return (ret); 6947 } 6948 6949 if (!page_trylock(pp, SE_EXCL)) { 6950 for (cb_index = 0; cb_index < PC_NUM_CALLBACKS; cb_index++) { 6951 if ((flags >> cb_index) & 1) { 6952 break; 6953 } 6954 } 6955 ASSERT(cb_index < PC_NUM_CALLBACKS); 6956 ret = EAGAIN; 6957 /* Special case for retired pages */ 6958 if (PP_RETIRED(pp)) { 6959 if (flags & CAPTURE_GET_RETIRED) { 6960 if (!page_unretire_pp(pp, PR_UNR_TEMP)) { 6961 /* 6962 * Need to set capture bit and add to 6963 * hash so that the page will be 6964 * retired when freed. 6965 */ 6966 page_capture_add_hash(pp, szc, 6967 CAPTURE_RETIRE, NULL); 6968 ret = 0; 6969 goto own_page; 6970 } 6971 } else { 6972 return (EBUSY); 6973 } 6974 } 6975 page_capture_add_hash(pp, szc, flags, datap); 6976 return (ret); 6977 } 6978 6979 async: 6980 ASSERT(PAGE_EXCL(pp)); 6981 6982 /* Need to check for physmem async requests that availrmem is sane */ 6983 if ((flags & (CAPTURE_ASYNC | CAPTURE_PHYSMEM)) == 6984 (CAPTURE_ASYNC | CAPTURE_PHYSMEM) && 6985 (availrmem < swapfs_minfree)) { 6986 page_unlock(pp); 6987 return (ENOMEM); 6988 } 6989 6990 ret = page_capture_clean_page(pp); 6991 6992 if (ret != 0) { 6993 /* We failed to get the page, so lets add it to the hash */ 6994 if (!(flags & CAPTURE_ASYNC)) { 6995 page_capture_add_hash(pp, szc, flags, datap); 6996 } 6997 return (ret); 6998 } 6999 7000 own_page: 7001 ASSERT(PAGE_EXCL(pp)); 7002 ASSERT(pp->p_szc == 0); 7003 7004 /* Call the callback */ 7005 ret = page_capture_take_action(pp, flags, datap); 7006 7007 if (ret == 0) { 7008 return (0); 7009 } 7010 7011 /* 7012 * Note that in the failure cases from page_capture_take_action, the 7013 * EXCL lock will have already been dropped. 7014 */ 7015 if ((ret == -1) && (!(flags & CAPTURE_ASYNC))) { 7016 page_capture_add_hash(pp, szc, flags, datap); 7017 } 7018 return (EAGAIN); 7019 } 7020 7021 int 7022 page_trycapture(page_t *pp, uint_t szc, uint_t flags, void *datap) 7023 { 7024 int ret; 7025 7026 curthread->t_flag |= T_CAPTURING; 7027 ret = page_itrycapture(pp, szc, flags, datap); 7028 curthread->t_flag &= ~T_CAPTURING; /* xor works as we know its set */ 7029 return (ret); 7030 } 7031 7032 /* 7033 * When unlocking a page which has the PR_CAPTURE bit set, this routine 7034 * gets called to try and capture the page. 7035 */ 7036 void 7037 page_unlock_capture(page_t *pp) 7038 { 7039 page_capture_hash_bucket_t *bp; 7040 int index; 7041 int i; 7042 uint_t szc; 7043 uint_t flags = 0; 7044 void *datap; 7045 kmutex_t *mp; 7046 extern vnode_t retired_pages; 7047 7048 /* 7049 * We need to protect against a possible deadlock here where we own 7050 * the vnode page hash mutex and want to acquire it again as there 7051 * are locations in the code, where we unlock a page while holding 7052 * the mutex which can lead to the page being captured and eventually 7053 * end up here. As we may be hashing out the old page and hashing into 7054 * the retire vnode, we need to make sure we don't own them. 7055 * Other callbacks who do hash operations also need to make sure that 7056 * before they hashin to a vnode that they do not currently own the 7057 * vphm mutex otherwise there will be a panic. 7058 */ 7059 if (mutex_owned(page_vnode_mutex(&retired_pages))) { 7060 page_unlock_nocapture(pp); 7061 return; 7062 } 7063 if (pp->p_vnode != NULL && mutex_owned(page_vnode_mutex(pp->p_vnode))) { 7064 page_unlock_nocapture(pp); 7065 return; 7066 } 7067 7068 index = PAGE_CAPTURE_HASH(pp); 7069 7070 mp = &page_capture_hash[index].pchh_mutex; 7071 mutex_enter(mp); 7072 for (i = 0; i < 2; i++) { 7073 bp = page_capture_hash[index].lists[i].next; 7074 while (bp != &page_capture_hash[index].lists[i]) { 7075 if (bp->pp == pp) { 7076 szc = bp->szc; 7077 flags = bp->flags | CAPTURE_ASYNC; 7078 datap = bp->datap; 7079 mutex_exit(mp); 7080 (void) page_trycapture(pp, szc, flags, datap); 7081 return; 7082 } 7083 bp = bp->next; 7084 } 7085 } 7086 7087 /* Failed to find page in hash so clear flags and unlock it. */ 7088 page_clrtoxic(pp, PR_CAPTURE); 7089 page_unlock(pp); 7090 7091 mutex_exit(mp); 7092 } 7093 7094 void 7095 page_capture_init() 7096 { 7097 int i; 7098 for (i = 0; i < NUM_PAGE_CAPTURE_BUCKETS; i++) { 7099 page_capture_hash[i].lists[0].next = 7100 &page_capture_hash[i].lists[0]; 7101 page_capture_hash[i].lists[0].prev = 7102 &page_capture_hash[i].lists[0]; 7103 page_capture_hash[i].lists[1].next = 7104 &page_capture_hash[i].lists[1]; 7105 page_capture_hash[i].lists[1].prev = 7106 &page_capture_hash[i].lists[1]; 7107 } 7108 7109 pc_thread_shortwait = 23 * hz; 7110 pc_thread_longwait = 1201 * hz; 7111 pc_thread_retry = 3; 7112 mutex_init(&pc_thread_mutex, NULL, MUTEX_DEFAULT, NULL); 7113 cv_init(&pc_cv, NULL, CV_DEFAULT, NULL); 7114 pc_thread_id = thread_create(NULL, 0, page_capture_thread, NULL, 0, &p0, 7115 TS_RUN, minclsyspri); 7116 } 7117 7118 /* 7119 * It is necessary to scrub any failing pages prior to reboot in order to 7120 * prevent a latent error trap from occurring on the next boot. 7121 */ 7122 void 7123 page_retire_mdboot() 7124 { 7125 page_t *pp; 7126 int i, j; 7127 page_capture_hash_bucket_t *bp; 7128 7129 /* walk lists looking for pages to scrub */ 7130 for (i = 0; i < NUM_PAGE_CAPTURE_BUCKETS; i++) { 7131 if (page_capture_hash[i].num_pages == 0) 7132 continue; 7133 7134 mutex_enter(&page_capture_hash[i].pchh_mutex); 7135 7136 for (j = 0; j < 2; j++) { 7137 bp = page_capture_hash[i].lists[j].next; 7138 while (bp != &page_capture_hash[i].lists[j]) { 7139 pp = bp->pp; 7140 if (PP_TOXIC(pp)) { 7141 if (page_trylock(pp, SE_EXCL)) { 7142 PP_CLRFREE(pp); 7143 pagescrub(pp, 0, PAGESIZE); 7144 page_unlock(pp); 7145 } 7146 } 7147 bp = bp->next; 7148 } 7149 } 7150 mutex_exit(&page_capture_hash[i].pchh_mutex); 7151 } 7152 } 7153 7154 /* 7155 * Walk the page_capture_hash trying to capture pages and also cleanup old 7156 * entries which have expired. 7157 */ 7158 void 7159 page_capture_async() 7160 { 7161 page_t *pp; 7162 int i; 7163 int ret; 7164 page_capture_hash_bucket_t *bp1, *bp2; 7165 uint_t szc; 7166 uint_t flags; 7167 void *datap; 7168 7169 /* If there are outstanding pages to be captured, get to work */ 7170 for (i = 0; i < NUM_PAGE_CAPTURE_BUCKETS; i++) { 7171 if (page_capture_hash[i].num_pages == 0) 7172 continue; 7173 /* Append list 1 to list 0 and then walk through list 0 */ 7174 mutex_enter(&page_capture_hash[i].pchh_mutex); 7175 bp1 = &page_capture_hash[i].lists[1]; 7176 bp2 = bp1->next; 7177 if (bp1 != bp2) { 7178 bp1->prev->next = page_capture_hash[i].lists[0].next; 7179 bp2->prev = &page_capture_hash[i].lists[0]; 7180 page_capture_hash[i].lists[0].next->prev = bp1->prev; 7181 page_capture_hash[i].lists[0].next = bp2; 7182 bp1->next = bp1; 7183 bp1->prev = bp1; 7184 } 7185 7186 /* list[1] will be empty now */ 7187 7188 bp1 = page_capture_hash[i].lists[0].next; 7189 while (bp1 != &page_capture_hash[i].lists[0]) { 7190 /* Check expiration time */ 7191 if ((lbolt > bp1->expires && bp1->expires != -1) || 7192 page_deleted(bp1->pp)) { 7193 page_capture_hash[i].lists[0].next = bp1->next; 7194 bp1->next->prev = 7195 &page_capture_hash[i].lists[0]; 7196 page_capture_hash[i].num_pages--; 7197 7198 /* 7199 * We can safely remove the PR_CAPTURE bit 7200 * without holding the EXCL lock on the page 7201 * as the PR_CAPTURE bit requres that the 7202 * page_capture_hash[].pchh_mutex be held 7203 * to modify it. 7204 */ 7205 page_clrtoxic(bp1->pp, PR_CAPTURE); 7206 mutex_exit(&page_capture_hash[i].pchh_mutex); 7207 kmem_free(bp1, sizeof (*bp1)); 7208 mutex_enter(&page_capture_hash[i].pchh_mutex); 7209 bp1 = page_capture_hash[i].lists[0].next; 7210 continue; 7211 } 7212 pp = bp1->pp; 7213 szc = bp1->szc; 7214 flags = bp1->flags; 7215 datap = bp1->datap; 7216 mutex_exit(&page_capture_hash[i].pchh_mutex); 7217 if (page_trylock(pp, SE_EXCL)) { 7218 ret = page_trycapture(pp, szc, 7219 flags | CAPTURE_ASYNC, datap); 7220 } else { 7221 ret = 1; /* move to walked hash */ 7222 } 7223 7224 if (ret != 0) { 7225 /* Move to walked hash */ 7226 (void) page_capture_move_to_walked(pp); 7227 } 7228 mutex_enter(&page_capture_hash[i].pchh_mutex); 7229 bp1 = page_capture_hash[i].lists[0].next; 7230 } 7231 7232 mutex_exit(&page_capture_hash[i].pchh_mutex); 7233 } 7234 } 7235 7236 /* 7237 * This function is called by the page_capture_thread, and is needed in 7238 * in order to initiate aio cleanup, so that pages used in aio 7239 * will be unlocked and subsequently retired by page_capture_thread. 7240 */ 7241 static int 7242 do_aio_cleanup(void) 7243 { 7244 proc_t *procp; 7245 int (*aio_cleanup_dr_delete_memory)(proc_t *); 7246 int cleaned = 0; 7247 7248 if (modload("sys", "kaio") == -1) { 7249 cmn_err(CE_WARN, "do_aio_cleanup: cannot load kaio"); 7250 return (0); 7251 } 7252 /* 7253 * We use the aio_cleanup_dr_delete_memory function to 7254 * initiate the actual clean up; this function will wake 7255 * up the per-process aio_cleanup_thread. 7256 */ 7257 aio_cleanup_dr_delete_memory = (int (*)(proc_t *)) 7258 modgetsymvalue("aio_cleanup_dr_delete_memory", 0); 7259 if (aio_cleanup_dr_delete_memory == NULL) { 7260 cmn_err(CE_WARN, 7261 "aio_cleanup_dr_delete_memory not found in kaio"); 7262 return (0); 7263 } 7264 mutex_enter(&pidlock); 7265 for (procp = practive; (procp != NULL); procp = procp->p_next) { 7266 mutex_enter(&procp->p_lock); 7267 if (procp->p_aio != NULL) { 7268 /* cleanup proc's outstanding kaio */ 7269 cleaned += (*aio_cleanup_dr_delete_memory)(procp); 7270 } 7271 mutex_exit(&procp->p_lock); 7272 } 7273 mutex_exit(&pidlock); 7274 return (cleaned); 7275 } 7276 7277 /* 7278 * helper function for page_capture_thread 7279 */ 7280 static void 7281 page_capture_handle_outstanding(void) 7282 { 7283 int ntry; 7284 7285 /* Reap pages before attempting capture pages */ 7286 kmem_reap(); 7287 7288 if ((page_retire_pend_count() > page_retire_pend_kas_count()) && 7289 hat_supported(HAT_DYNAMIC_ISM_UNMAP, (void *)0)) { 7290 /* 7291 * Note: Purging only for platforms that support 7292 * ISM hat_pageunload() - mainly SPARC. On x86/x64 7293 * platforms ISM pages SE_SHARED locked until destroyed. 7294 */ 7295 7296 /* disable and purge seg_pcache */ 7297 (void) seg_p_disable(); 7298 for (ntry = 0; ntry < pc_thread_retry; ntry++) { 7299 if (!page_retire_pend_count()) 7300 break; 7301 if (do_aio_cleanup()) { 7302 /* 7303 * allow the apps cleanup threads 7304 * to run 7305 */ 7306 delay(pc_thread_shortwait); 7307 } 7308 page_capture_async(); 7309 } 7310 /* reenable seg_pcache */ 7311 seg_p_enable(); 7312 7313 /* completed what can be done. break out */ 7314 return; 7315 } 7316 7317 /* 7318 * For kernel pages and/or unsupported HAT_DYNAMIC_ISM_UNMAP, reap 7319 * and then attempt to capture. 7320 */ 7321 seg_preap(); 7322 page_capture_async(); 7323 } 7324 7325 /* 7326 * The page_capture_thread loops forever, looking to see if there are 7327 * pages still waiting to be captured. 7328 */ 7329 static void 7330 page_capture_thread(void) 7331 { 7332 callb_cpr_t c; 7333 int outstanding; 7334 int i; 7335 7336 CALLB_CPR_INIT(&c, &pc_thread_mutex, callb_generic_cpr, "page_capture"); 7337 7338 mutex_enter(&pc_thread_mutex); 7339 for (;;) { 7340 outstanding = 0; 7341 for (i = 0; i < NUM_PAGE_CAPTURE_BUCKETS; i++) 7342 outstanding += page_capture_hash[i].num_pages; 7343 if (outstanding) { 7344 page_capture_handle_outstanding(); 7345 CALLB_CPR_SAFE_BEGIN(&c); 7346 (void) cv_timedwait(&pc_cv, &pc_thread_mutex, 7347 lbolt + pc_thread_shortwait); 7348 CALLB_CPR_SAFE_END(&c, &pc_thread_mutex); 7349 } else { 7350 CALLB_CPR_SAFE_BEGIN(&c); 7351 (void) cv_timedwait(&pc_cv, &pc_thread_mutex, 7352 lbolt + pc_thread_longwait); 7353 CALLB_CPR_SAFE_END(&c, &pc_thread_mutex); 7354 } 7355 } 7356 /*NOTREACHED*/ 7357 } 7358 /* 7359 * Attempt to locate a bucket that has enough pages to satisfy the request. 7360 * The initial check is done without the lock to avoid unneeded contention. 7361 * The function returns 1 if enough pages were found, else 0 if it could not 7362 * find enough pages in a bucket. 7363 */ 7364 static int 7365 pcf_decrement_bucket(pgcnt_t npages) 7366 { 7367 struct pcf *p; 7368 struct pcf *q; 7369 int i; 7370 7371 p = &pcf[PCF_INDEX()]; 7372 q = &pcf[pcf_fanout]; 7373 for (i = 0; i < pcf_fanout; i++) { 7374 if (p->pcf_count > npages) { 7375 /* 7376 * a good one to try. 7377 */ 7378 mutex_enter(&p->pcf_lock); 7379 if (p->pcf_count > npages) { 7380 p->pcf_count -= (uint_t)npages; 7381 /* 7382 * freemem is not protected by any lock. 7383 * Thus, we cannot have any assertion 7384 * containing freemem here. 7385 */ 7386 freemem -= npages; 7387 mutex_exit(&p->pcf_lock); 7388 return (1); 7389 } 7390 mutex_exit(&p->pcf_lock); 7391 } 7392 p++; 7393 if (p >= q) { 7394 p = pcf; 7395 } 7396 } 7397 return (0); 7398 } 7399 7400 /* 7401 * Arguments: 7402 * pcftotal_ret: If the value is not NULL and we have walked all the 7403 * buckets but did not find enough pages then it will 7404 * be set to the total number of pages in all the pcf 7405 * buckets. 7406 * npages: Is the number of pages we have been requested to 7407 * find. 7408 * unlock: If set to 0 we will leave the buckets locked if the 7409 * requested number of pages are not found. 7410 * 7411 * Go and try to satisfy the page request from any number of buckets. 7412 * This can be a very expensive operation as we have to lock the buckets 7413 * we are checking (and keep them locked), starting at bucket 0. 7414 * 7415 * The function returns 1 if enough pages were found, else 0 if it could not 7416 * find enough pages in the buckets. 7417 * 7418 */ 7419 static int 7420 pcf_decrement_multiple(pgcnt_t *pcftotal_ret, pgcnt_t npages, int unlock) 7421 { 7422 struct pcf *p; 7423 pgcnt_t pcftotal; 7424 int i; 7425 7426 p = pcf; 7427 /* try to collect pages from several pcf bins */ 7428 for (pcftotal = 0, i = 0; i < pcf_fanout; i++) { 7429 mutex_enter(&p->pcf_lock); 7430 pcftotal += p->pcf_count; 7431 if (pcftotal >= npages) { 7432 /* 7433 * Wow! There are enough pages laying around 7434 * to satisfy the request. Do the accounting, 7435 * drop the locks we acquired, and go back. 7436 * 7437 * freemem is not protected by any lock. So, 7438 * we cannot have any assertion containing 7439 * freemem. 7440 */ 7441 freemem -= npages; 7442 while (p >= pcf) { 7443 if (p->pcf_count <= npages) { 7444 npages -= p->pcf_count; 7445 p->pcf_count = 0; 7446 } else { 7447 p->pcf_count -= (uint_t)npages; 7448 npages = 0; 7449 } 7450 mutex_exit(&p->pcf_lock); 7451 p--; 7452 } 7453 ASSERT(npages == 0); 7454 return (1); 7455 } 7456 p++; 7457 } 7458 if (unlock) { 7459 /* failed to collect pages - release the locks */ 7460 while (--p >= pcf) { 7461 mutex_exit(&p->pcf_lock); 7462 } 7463 } 7464 if (pcftotal_ret != NULL) 7465 *pcftotal_ret = pcftotal; 7466 return (0); 7467 } 7468