uvm_pdpolicy_clockpro.c revision 1.9.16.2
1 1.9.16.1 bouyer /* $NetBSD: uvm_pdpolicy_clockpro.c,v 1.9.16.2 2008/01/19 12:15:50 bouyer Exp $ */ 2 1.2 yamt 3 1.2 yamt /*- 4 1.2 yamt * Copyright (c)2005, 2006 YAMAMOTO Takashi, 5 1.2 yamt * All rights reserved. 6 1.2 yamt * 7 1.2 yamt * Redistribution and use in source and binary forms, with or without 8 1.2 yamt * modification, are permitted provided that the following conditions 9 1.2 yamt * are met: 10 1.2 yamt * 1. Redistributions of source code must retain the above copyright 11 1.2 yamt * notice, this list of conditions and the following disclaimer. 12 1.2 yamt * 2. Redistributions in binary form must reproduce the above copyright 13 1.2 yamt * notice, this list of conditions and the following disclaimer in the 14 1.2 yamt * documentation and/or other materials provided with the distribution. 15 1.2 yamt * 16 1.2 yamt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 17 1.2 yamt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 18 1.2 yamt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 19 1.2 yamt * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 20 1.2 yamt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 21 1.2 yamt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 22 1.2 yamt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 23 1.2 yamt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 24 1.2 yamt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 25 1.2 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 26 1.2 yamt * SUCH DAMAGE. 27 1.2 yamt */ 28 1.2 yamt 29 1.2 yamt /* 30 1.2 yamt * CLOCK-Pro replacement policy: 31 1.2 yamt * http://www.cs.wm.edu/hpcs/WWW/HTML/publications/abs05-3.html 32 1.2 yamt * 33 1.2 yamt * approximation of the list of non-resident pages using hash: 34 1.2 yamt * http://linux-mm.org/ClockProApproximation 35 1.2 yamt */ 36 1.2 yamt 37 1.2 yamt /* #define CLOCKPRO_DEBUG */ 38 1.2 yamt 39 1.2 yamt #if defined(PDSIM) 40 1.2 yamt 41 1.2 yamt #include "pdsim.h" 42 1.2 yamt 43 1.2 yamt #else /* defined(PDSIM) */ 44 1.2 yamt 45 1.2 yamt #include <sys/cdefs.h> 46 1.9.16.1 bouyer __KERNEL_RCSID(0, "$NetBSD: uvm_pdpolicy_clockpro.c,v 1.9.16.2 2008/01/19 12:15:50 bouyer Exp $"); 47 1.2 yamt 48 1.2 yamt #include "opt_ddb.h" 49 1.2 yamt 50 1.2 yamt #include <sys/param.h> 51 1.2 yamt #include <sys/proc.h> 52 1.2 yamt #include <sys/systm.h> 53 1.2 yamt #include <sys/kernel.h> 54 1.2 yamt #include <sys/hash.h> 55 1.2 yamt 56 1.2 yamt #include <uvm/uvm.h> 57 1.2 yamt #include <uvm/uvm_pdpolicy.h> 58 1.2 yamt #include <uvm/uvm_pdpolicy_impl.h> 59 1.2 yamt 60 1.2 yamt #if ((__STDC_VERSION__ - 0) >= 199901L) 61 1.2 yamt #define DPRINTF(...) /* nothing */ 62 1.2 yamt #define WARN(...) printf(__VA_ARGS__) 63 1.2 yamt #else /* ((__STDC_VERSION__ - 0) >= 199901L) */ 64 1.2 yamt #define DPRINTF(a...) /* nothing */ /* GCC */ 65 1.2 yamt #define WARN(a...) printf(a) 66 1.2 yamt #endif /* ((__STDC_VERSION__ - 0) >= 199901L) */ 67 1.2 yamt 68 1.2 yamt #define dump(a) /* nothing */ 69 1.2 yamt 70 1.2 yamt #undef USEONCE2 71 1.2 yamt #define LISTQ 72 1.2 yamt #undef ADAPTIVE 73 1.2 yamt 74 1.2 yamt #endif /* defined(PDSIM) */ 75 1.2 yamt 76 1.2 yamt #if !defined(CLOCKPRO_COLDPCT) 77 1.2 yamt #define CLOCKPRO_COLDPCT 10 78 1.2 yamt #endif /* !defined(CLOCKPRO_COLDPCT) */ 79 1.2 yamt 80 1.2 yamt #define CLOCKPRO_COLDPCTMAX 90 81 1.2 yamt 82 1.2 yamt #if !defined(CLOCKPRO_HASHFACTOR) 83 1.2 yamt #define CLOCKPRO_HASHFACTOR 2 84 1.2 yamt #endif /* !defined(CLOCKPRO_HASHFACTOR) */ 85 1.2 yamt 86 1.2 yamt #define CLOCKPRO_NEWQMIN ((1024 * 1024) >> PAGE_SHIFT) /* XXX */ 87 1.2 yamt 88 1.2 yamt int clockpro_hashfactor = CLOCKPRO_HASHFACTOR; 89 1.2 yamt 90 1.2 yamt PDPOL_EVCNT_DEFINE(nresrecordobj) 91 1.2 yamt PDPOL_EVCNT_DEFINE(nresrecordanon) 92 1.9 yamt PDPOL_EVCNT_DEFINE(nreslookupobj) 93 1.9 yamt PDPOL_EVCNT_DEFINE(nreslookupanon) 94 1.2 yamt PDPOL_EVCNT_DEFINE(nresfoundobj) 95 1.2 yamt PDPOL_EVCNT_DEFINE(nresfoundanon) 96 1.2 yamt PDPOL_EVCNT_DEFINE(nresanonfree) 97 1.2 yamt PDPOL_EVCNT_DEFINE(nresconflict) 98 1.2 yamt PDPOL_EVCNT_DEFINE(nresoverwritten) 99 1.2 yamt PDPOL_EVCNT_DEFINE(nreshandhot) 100 1.2 yamt 101 1.2 yamt PDPOL_EVCNT_DEFINE(hhottakeover) 102 1.2 yamt PDPOL_EVCNT_DEFINE(hhotref) 103 1.2 yamt PDPOL_EVCNT_DEFINE(hhotunref) 104 1.2 yamt PDPOL_EVCNT_DEFINE(hhotcold) 105 1.2 yamt PDPOL_EVCNT_DEFINE(hhotcoldtest) 106 1.2 yamt 107 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldtakeover) 108 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldref) 109 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldunref) 110 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldreftest) 111 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldunreftest) 112 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldunreftestspeculative) 113 1.2 yamt PDPOL_EVCNT_DEFINE(hcoldhot) 114 1.2 yamt 115 1.2 yamt PDPOL_EVCNT_DEFINE(speculativeenqueue) 116 1.2 yamt PDPOL_EVCNT_DEFINE(speculativehit1) 117 1.2 yamt PDPOL_EVCNT_DEFINE(speculativehit2) 118 1.2 yamt PDPOL_EVCNT_DEFINE(speculativemiss) 119 1.2 yamt 120 1.2 yamt #define PQ_REFERENCED PQ_PRIVATE1 121 1.2 yamt #define PQ_HOT PQ_PRIVATE2 122 1.2 yamt #define PQ_TEST PQ_PRIVATE3 123 1.2 yamt #define PQ_INITIALREF PQ_PRIVATE4 124 1.2 yamt #if PQ_PRIVATE6 != PQ_PRIVATE5 * 2 || PQ_PRIVATE7 != PQ_PRIVATE6 * 2 125 1.2 yamt #error PQ_PRIVATE 126 1.2 yamt #endif 127 1.2 yamt #define PQ_QMASK (PQ_PRIVATE5|PQ_PRIVATE6|PQ_PRIVATE7) 128 1.2 yamt #define PQ_QFACTOR PQ_PRIVATE5 129 1.2 yamt #define PQ_SPECULATIVE PQ_PRIVATE8 130 1.2 yamt 131 1.2 yamt #define CLOCKPRO_NOQUEUE 0 132 1.2 yamt #define CLOCKPRO_NEWQ 1 /* small queue to clear initial ref. */ 133 1.2 yamt #if defined(LISTQ) 134 1.2 yamt #define CLOCKPRO_COLDQ 2 135 1.2 yamt #define CLOCKPRO_HOTQ 3 136 1.2 yamt #else /* defined(LISTQ) */ 137 1.2 yamt #define CLOCKPRO_COLDQ (2 + coldqidx) /* XXX */ 138 1.2 yamt #define CLOCKPRO_HOTQ (3 - coldqidx) /* XXX */ 139 1.2 yamt #endif /* defined(LISTQ) */ 140 1.2 yamt #define CLOCKPRO_LISTQ 4 141 1.2 yamt #define CLOCKPRO_NQUEUE 4 142 1.2 yamt 143 1.2 yamt static inline void 144 1.2 yamt clockpro_setq(struct vm_page *pg, int qidx) 145 1.2 yamt { 146 1.2 yamt KASSERT(qidx >= CLOCKPRO_NOQUEUE); 147 1.2 yamt KASSERT(qidx <= CLOCKPRO_NQUEUE); 148 1.2 yamt 149 1.2 yamt pg->pqflags = (pg->pqflags & ~PQ_QMASK) | (qidx * PQ_QFACTOR); 150 1.2 yamt } 151 1.2 yamt 152 1.2 yamt static inline int 153 1.2 yamt clockpro_getq(struct vm_page *pg) 154 1.2 yamt { 155 1.2 yamt int qidx; 156 1.2 yamt 157 1.2 yamt qidx = (pg->pqflags & PQ_QMASK) / PQ_QFACTOR; 158 1.2 yamt KASSERT(qidx >= CLOCKPRO_NOQUEUE); 159 1.2 yamt KASSERT(qidx <= CLOCKPRO_NQUEUE); 160 1.2 yamt return qidx; 161 1.2 yamt } 162 1.2 yamt 163 1.2 yamt typedef struct { 164 1.2 yamt struct pglist q_q; 165 1.2 yamt int q_len; 166 1.2 yamt } pageq_t; 167 1.2 yamt 168 1.2 yamt struct clockpro_state { 169 1.2 yamt int s_npages; 170 1.2 yamt int s_coldtarget; 171 1.2 yamt int s_ncold; 172 1.2 yamt 173 1.2 yamt int s_newqlenmax; 174 1.2 yamt pageq_t s_q[CLOCKPRO_NQUEUE]; 175 1.2 yamt 176 1.2 yamt struct uvm_pctparam s_coldtargetpct; 177 1.2 yamt }; 178 1.2 yamt 179 1.2 yamt static pageq_t * 180 1.2 yamt clockpro_queue(struct clockpro_state *s, int qidx) 181 1.2 yamt { 182 1.2 yamt 183 1.2 yamt KASSERT(CLOCKPRO_NOQUEUE < qidx); 184 1.2 yamt KASSERT(qidx <= CLOCKPRO_NQUEUE); 185 1.2 yamt 186 1.2 yamt return &s->s_q[qidx - 1]; 187 1.2 yamt } 188 1.2 yamt 189 1.2 yamt #if !defined(LISTQ) 190 1.2 yamt 191 1.2 yamt static int coldqidx; 192 1.2 yamt 193 1.2 yamt static void 194 1.2 yamt clockpro_switchqueue(void) 195 1.2 yamt { 196 1.2 yamt 197 1.2 yamt coldqidx = 1 - coldqidx; 198 1.2 yamt } 199 1.2 yamt 200 1.2 yamt #endif /* !defined(LISTQ) */ 201 1.2 yamt 202 1.2 yamt static struct clockpro_state clockpro; 203 1.2 yamt static struct clockpro_scanstate { 204 1.2 yamt int ss_nscanned; 205 1.2 yamt } scanstate; 206 1.2 yamt 207 1.2 yamt /* ---------------------------------------- */ 208 1.2 yamt 209 1.2 yamt static void 210 1.2 yamt pageq_init(pageq_t *q) 211 1.2 yamt { 212 1.2 yamt 213 1.2 yamt TAILQ_INIT(&q->q_q); 214 1.2 yamt q->q_len = 0; 215 1.2 yamt } 216 1.2 yamt 217 1.2 yamt static int 218 1.2 yamt pageq_len(const pageq_t *q) 219 1.2 yamt { 220 1.2 yamt 221 1.2 yamt return q->q_len; 222 1.2 yamt } 223 1.2 yamt 224 1.2 yamt static struct vm_page * 225 1.2 yamt pageq_first(const pageq_t *q) 226 1.2 yamt { 227 1.2 yamt 228 1.2 yamt return TAILQ_FIRST(&q->q_q); 229 1.2 yamt } 230 1.2 yamt 231 1.2 yamt static void 232 1.2 yamt pageq_insert_tail(pageq_t *q, struct vm_page *pg) 233 1.2 yamt { 234 1.2 yamt 235 1.2 yamt TAILQ_INSERT_TAIL(&q->q_q, pg, pageq); 236 1.2 yamt q->q_len++; 237 1.2 yamt } 238 1.2 yamt 239 1.2 yamt static void 240 1.2 yamt pageq_insert_head(pageq_t *q, struct vm_page *pg) 241 1.2 yamt { 242 1.2 yamt 243 1.2 yamt TAILQ_INSERT_HEAD(&q->q_q, pg, pageq); 244 1.2 yamt q->q_len++; 245 1.2 yamt } 246 1.2 yamt 247 1.2 yamt static void 248 1.2 yamt pageq_remove(pageq_t *q, struct vm_page *pg) 249 1.2 yamt { 250 1.2 yamt 251 1.2 yamt #if 1 252 1.2 yamt KASSERT(clockpro_queue(&clockpro, clockpro_getq(pg)) == q); 253 1.2 yamt #endif 254 1.2 yamt KASSERT(q->q_len > 0); 255 1.2 yamt TAILQ_REMOVE(&q->q_q, pg, pageq); 256 1.2 yamt q->q_len--; 257 1.2 yamt } 258 1.2 yamt 259 1.2 yamt static struct vm_page * 260 1.2 yamt pageq_remove_head(pageq_t *q) 261 1.2 yamt { 262 1.2 yamt struct vm_page *pg; 263 1.2 yamt 264 1.2 yamt pg = TAILQ_FIRST(&q->q_q); 265 1.2 yamt if (pg == NULL) { 266 1.2 yamt KASSERT(q->q_len == 0); 267 1.2 yamt return NULL; 268 1.2 yamt } 269 1.2 yamt pageq_remove(q, pg); 270 1.2 yamt return pg; 271 1.2 yamt } 272 1.2 yamt 273 1.2 yamt /* ---------------------------------------- */ 274 1.2 yamt 275 1.2 yamt static void 276 1.2 yamt clockpro_insert_tail(struct clockpro_state *s, int qidx, struct vm_page *pg) 277 1.2 yamt { 278 1.2 yamt pageq_t *q = clockpro_queue(s, qidx); 279 1.2 yamt 280 1.2 yamt clockpro_setq(pg, qidx); 281 1.2 yamt pageq_insert_tail(q, pg); 282 1.2 yamt } 283 1.2 yamt 284 1.5 christos static void 285 1.2 yamt clockpro_insert_head(struct clockpro_state *s, int qidx, struct vm_page *pg) 286 1.2 yamt { 287 1.2 yamt pageq_t *q = clockpro_queue(s, qidx); 288 1.2 yamt 289 1.2 yamt clockpro_setq(pg, qidx); 290 1.2 yamt pageq_insert_head(q, pg); 291 1.2 yamt } 292 1.2 yamt 293 1.2 yamt /* ---------------------------------------- */ 294 1.2 yamt 295 1.2 yamt typedef uint32_t nonres_cookie_t; 296 1.2 yamt #define NONRES_COOKIE_INVAL 0 297 1.2 yamt 298 1.2 yamt typedef uintptr_t objid_t; 299 1.2 yamt 300 1.2 yamt /* 301 1.2 yamt * XXX maybe these hash functions need reconsideration, 302 1.2 yamt * given that hash distribution is critical here. 303 1.2 yamt */ 304 1.2 yamt 305 1.2 yamt static uint32_t 306 1.2 yamt pageidentityhash1(objid_t obj, off_t idx) 307 1.2 yamt { 308 1.2 yamt uint32_t hash = HASH32_BUF_INIT; 309 1.2 yamt 310 1.2 yamt #if 1 311 1.2 yamt hash = hash32_buf(&idx, sizeof(idx), hash); 312 1.2 yamt hash = hash32_buf(&obj, sizeof(obj), hash); 313 1.2 yamt #else 314 1.2 yamt hash = hash32_buf(&obj, sizeof(obj), hash); 315 1.2 yamt hash = hash32_buf(&idx, sizeof(idx), hash); 316 1.2 yamt #endif 317 1.2 yamt return hash; 318 1.2 yamt } 319 1.2 yamt 320 1.2 yamt static uint32_t 321 1.2 yamt pageidentityhash2(objid_t obj, off_t idx) 322 1.2 yamt { 323 1.2 yamt uint32_t hash = HASH32_BUF_INIT; 324 1.2 yamt 325 1.2 yamt hash = hash32_buf(&obj, sizeof(obj), hash); 326 1.2 yamt hash = hash32_buf(&idx, sizeof(idx), hash); 327 1.2 yamt return hash; 328 1.2 yamt } 329 1.2 yamt 330 1.2 yamt static nonres_cookie_t 331 1.2 yamt calccookie(objid_t obj, off_t idx) 332 1.2 yamt { 333 1.2 yamt uint32_t hash = pageidentityhash2(obj, idx); 334 1.2 yamt nonres_cookie_t cookie = hash; 335 1.2 yamt 336 1.2 yamt if (__predict_false(cookie == NONRES_COOKIE_INVAL)) { 337 1.2 yamt cookie++; /* XXX */ 338 1.2 yamt } 339 1.2 yamt return cookie; 340 1.2 yamt } 341 1.2 yamt 342 1.2 yamt #define BUCKETSIZE 14 343 1.2 yamt struct bucket { 344 1.2 yamt int cycle; 345 1.2 yamt int cur; 346 1.2 yamt nonres_cookie_t pages[BUCKETSIZE]; 347 1.2 yamt }; 348 1.2 yamt static int cycle_target; 349 1.2 yamt static int cycle_target_frac; 350 1.2 yamt 351 1.2 yamt static struct bucket static_bucket; 352 1.2 yamt static struct bucket *buckets = &static_bucket; 353 1.2 yamt static size_t hashsize = 1; 354 1.2 yamt 355 1.2 yamt static int coldadj; 356 1.2 yamt #define COLDTARGET_ADJ(d) coldadj += (d) 357 1.2 yamt 358 1.2 yamt #if defined(PDSIM) 359 1.2 yamt 360 1.2 yamt static void * 361 1.2 yamt clockpro_hashalloc(int n) 362 1.2 yamt { 363 1.2 yamt size_t allocsz = sizeof(*buckets) * n; 364 1.2 yamt 365 1.2 yamt return malloc(allocsz); 366 1.2 yamt } 367 1.2 yamt 368 1.2 yamt static void 369 1.2 yamt clockpro_hashfree(void *p, int n) 370 1.2 yamt { 371 1.2 yamt 372 1.2 yamt free(p); 373 1.2 yamt } 374 1.2 yamt 375 1.2 yamt #else /* defined(PDSIM) */ 376 1.2 yamt 377 1.2 yamt static void * 378 1.2 yamt clockpro_hashalloc(int n) 379 1.2 yamt { 380 1.2 yamt size_t allocsz = round_page(sizeof(*buckets) * n); 381 1.2 yamt 382 1.2 yamt return (void *)uvm_km_alloc(kernel_map, allocsz, 0, UVM_KMF_WIRED); 383 1.2 yamt } 384 1.2 yamt 385 1.2 yamt static void 386 1.2 yamt clockpro_hashfree(void *p, int n) 387 1.2 yamt { 388 1.2 yamt size_t allocsz = round_page(sizeof(*buckets) * n); 389 1.2 yamt 390 1.2 yamt uvm_km_free(kernel_map, (vaddr_t)p, allocsz, UVM_KMF_WIRED); 391 1.2 yamt } 392 1.2 yamt 393 1.2 yamt #endif /* defined(PDSIM) */ 394 1.2 yamt 395 1.2 yamt static void 396 1.2 yamt clockpro_hashinit(uint64_t n) 397 1.2 yamt { 398 1.2 yamt struct bucket *newbuckets; 399 1.2 yamt struct bucket *oldbuckets; 400 1.2 yamt size_t sz; 401 1.2 yamt size_t oldsz; 402 1.2 yamt int i; 403 1.2 yamt 404 1.2 yamt sz = howmany(n, BUCKETSIZE); 405 1.2 yamt sz *= clockpro_hashfactor; 406 1.2 yamt newbuckets = clockpro_hashalloc(sz); 407 1.2 yamt if (newbuckets == NULL) { 408 1.2 yamt panic("%s: allocation failure", __func__); 409 1.2 yamt } 410 1.2 yamt for (i = 0; i < sz; i++) { 411 1.2 yamt struct bucket *b = &newbuckets[i]; 412 1.2 yamt int j; 413 1.2 yamt 414 1.2 yamt b->cycle = cycle_target; 415 1.2 yamt b->cur = 0; 416 1.2 yamt for (j = 0; j < BUCKETSIZE; j++) { 417 1.2 yamt b->pages[j] = NONRES_COOKIE_INVAL; 418 1.2 yamt } 419 1.2 yamt } 420 1.2 yamt /* XXX lock */ 421 1.2 yamt oldbuckets = buckets; 422 1.2 yamt oldsz = hashsize; 423 1.2 yamt buckets = newbuckets; 424 1.2 yamt hashsize = sz; 425 1.2 yamt /* XXX unlock */ 426 1.2 yamt if (oldbuckets != &static_bucket) { 427 1.2 yamt clockpro_hashfree(oldbuckets, oldsz); 428 1.2 yamt } 429 1.2 yamt } 430 1.2 yamt 431 1.2 yamt static struct bucket * 432 1.2 yamt nonresident_getbucket(objid_t obj, off_t idx) 433 1.2 yamt { 434 1.2 yamt uint32_t hash; 435 1.2 yamt 436 1.2 yamt hash = pageidentityhash1(obj, idx); 437 1.2 yamt return &buckets[hash % hashsize]; 438 1.2 yamt } 439 1.2 yamt 440 1.2 yamt static void 441 1.2 yamt nonresident_rotate(struct bucket *b) 442 1.2 yamt { 443 1.9.16.2 bouyer int cycle; 444 1.9.16.2 bouyer int cur; 445 1.2 yamt 446 1.9.16.2 bouyer cycle = b->cycle; 447 1.9.16.2 bouyer cur = b->cur; 448 1.9.16.2 bouyer while (cycle - cycle_target < 0) { 449 1.9.16.2 bouyer if (b->pages[cur] != NONRES_COOKIE_INVAL) { 450 1.2 yamt PDPOL_EVCNT_INCR(nreshandhot); 451 1.2 yamt COLDTARGET_ADJ(-1); 452 1.2 yamt } 453 1.9.16.2 bouyer b->pages[cur] = NONRES_COOKIE_INVAL; 454 1.9.16.2 bouyer cur++; 455 1.9.16.2 bouyer if (cur == BUCKETSIZE) { 456 1.9.16.2 bouyer cur = 0; 457 1.9.16.2 bouyer } 458 1.9.16.2 bouyer cycle++; 459 1.2 yamt } 460 1.9.16.2 bouyer b->cycle = cycle; 461 1.9.16.2 bouyer b->cur = cur; 462 1.2 yamt } 463 1.2 yamt 464 1.7 thorpej static bool 465 1.2 yamt nonresident_lookupremove(objid_t obj, off_t idx) 466 1.2 yamt { 467 1.2 yamt struct bucket *b = nonresident_getbucket(obj, idx); 468 1.2 yamt nonres_cookie_t cookie = calccookie(obj, idx); 469 1.2 yamt int i; 470 1.2 yamt 471 1.2 yamt nonresident_rotate(b); 472 1.2 yamt for (i = 0; i < BUCKETSIZE; i++) { 473 1.2 yamt if (b->pages[i] == cookie) { 474 1.2 yamt b->pages[i] = NONRES_COOKIE_INVAL; 475 1.8 thorpej return true; 476 1.2 yamt } 477 1.2 yamt } 478 1.8 thorpej return false; 479 1.2 yamt } 480 1.2 yamt 481 1.2 yamt static objid_t 482 1.2 yamt pageobj(struct vm_page *pg) 483 1.2 yamt { 484 1.2 yamt const void *obj; 485 1.2 yamt 486 1.2 yamt /* 487 1.2 yamt * XXX object pointer is often freed and reused for unrelated object. 488 1.2 yamt * for vnodes, it would be better to use something like 489 1.2 yamt * a hash of fsid/fileid/generation. 490 1.2 yamt */ 491 1.2 yamt 492 1.2 yamt obj = pg->uobject; 493 1.2 yamt if (obj == NULL) { 494 1.2 yamt obj = pg->uanon; 495 1.2 yamt KASSERT(obj != NULL); 496 1.2 yamt KASSERT(pg->offset == 0); 497 1.2 yamt } 498 1.2 yamt 499 1.2 yamt return (objid_t)obj; 500 1.2 yamt } 501 1.2 yamt 502 1.2 yamt static off_t 503 1.2 yamt pageidx(struct vm_page *pg) 504 1.2 yamt { 505 1.2 yamt 506 1.2 yamt KASSERT((pg->offset & PAGE_MASK) == 0); 507 1.2 yamt return pg->offset >> PAGE_SHIFT; 508 1.2 yamt } 509 1.2 yamt 510 1.7 thorpej static bool 511 1.2 yamt nonresident_pagelookupremove(struct vm_page *pg) 512 1.2 yamt { 513 1.7 thorpej bool found = nonresident_lookupremove(pageobj(pg), pageidx(pg)); 514 1.2 yamt 515 1.9 yamt if (pg->uobject) { 516 1.9 yamt PDPOL_EVCNT_INCR(nreslookupobj); 517 1.9 yamt } else { 518 1.9 yamt PDPOL_EVCNT_INCR(nreslookupanon); 519 1.9 yamt } 520 1.2 yamt if (found) { 521 1.2 yamt if (pg->uobject) { 522 1.2 yamt PDPOL_EVCNT_INCR(nresfoundobj); 523 1.2 yamt } else { 524 1.2 yamt PDPOL_EVCNT_INCR(nresfoundanon); 525 1.2 yamt } 526 1.2 yamt } 527 1.2 yamt return found; 528 1.2 yamt } 529 1.2 yamt 530 1.2 yamt static void 531 1.2 yamt nonresident_pagerecord(struct vm_page *pg) 532 1.2 yamt { 533 1.2 yamt objid_t obj = pageobj(pg); 534 1.2 yamt off_t idx = pageidx(pg); 535 1.2 yamt struct bucket *b = nonresident_getbucket(obj, idx); 536 1.2 yamt nonres_cookie_t cookie = calccookie(obj, idx); 537 1.2 yamt 538 1.2 yamt #if defined(DEBUG) 539 1.2 yamt int i; 540 1.2 yamt 541 1.2 yamt for (i = 0; i < BUCKETSIZE; i++) { 542 1.2 yamt if (b->pages[i] == cookie) { 543 1.2 yamt PDPOL_EVCNT_INCR(nresconflict); 544 1.2 yamt } 545 1.2 yamt } 546 1.2 yamt #endif /* defined(DEBUG) */ 547 1.2 yamt 548 1.2 yamt if (pg->uobject) { 549 1.2 yamt PDPOL_EVCNT_INCR(nresrecordobj); 550 1.2 yamt } else { 551 1.2 yamt PDPOL_EVCNT_INCR(nresrecordanon); 552 1.2 yamt } 553 1.2 yamt nonresident_rotate(b); 554 1.2 yamt if (b->pages[b->cur] != NONRES_COOKIE_INVAL) { 555 1.2 yamt PDPOL_EVCNT_INCR(nresoverwritten); 556 1.2 yamt COLDTARGET_ADJ(-1); 557 1.2 yamt } 558 1.2 yamt b->pages[b->cur] = cookie; 559 1.2 yamt b->cur = (b->cur + 1) % BUCKETSIZE; 560 1.2 yamt } 561 1.2 yamt 562 1.2 yamt /* ---------------------------------------- */ 563 1.2 yamt 564 1.2 yamt #if defined(CLOCKPRO_DEBUG) 565 1.2 yamt static void 566 1.2 yamt check_sanity(void) 567 1.2 yamt { 568 1.2 yamt } 569 1.2 yamt #else /* defined(CLOCKPRO_DEBUG) */ 570 1.2 yamt #define check_sanity() /* nothing */ 571 1.2 yamt #endif /* defined(CLOCKPRO_DEBUG) */ 572 1.2 yamt 573 1.2 yamt static void 574 1.2 yamt clockpro_reinit(void) 575 1.2 yamt { 576 1.2 yamt 577 1.2 yamt clockpro_hashinit(uvmexp.npages); 578 1.2 yamt } 579 1.2 yamt 580 1.2 yamt static void 581 1.2 yamt clockpro_init(void) 582 1.2 yamt { 583 1.2 yamt struct clockpro_state *s = &clockpro; 584 1.2 yamt int i; 585 1.2 yamt 586 1.2 yamt for (i = 0; i < CLOCKPRO_NQUEUE; i++) { 587 1.2 yamt pageq_init(&s->s_q[i]); 588 1.2 yamt } 589 1.2 yamt s->s_newqlenmax = 1; 590 1.2 yamt s->s_coldtarget = 1; 591 1.2 yamt uvm_pctparam_init(&s->s_coldtargetpct, CLOCKPRO_COLDPCT, NULL); 592 1.2 yamt } 593 1.2 yamt 594 1.2 yamt static void 595 1.2 yamt clockpro_tune(void) 596 1.2 yamt { 597 1.2 yamt struct clockpro_state *s = &clockpro; 598 1.2 yamt int coldtarget; 599 1.2 yamt 600 1.2 yamt #if defined(ADAPTIVE) 601 1.2 yamt int coldmax = s->s_npages * CLOCKPRO_COLDPCTMAX / 100; 602 1.2 yamt int coldmin = 1; 603 1.2 yamt 604 1.2 yamt coldtarget = s->s_coldtarget; 605 1.2 yamt if (coldtarget + coldadj < coldmin) { 606 1.2 yamt coldadj = coldmin - coldtarget; 607 1.2 yamt } else if (coldtarget + coldadj > coldmax) { 608 1.2 yamt coldadj = coldmax - coldtarget; 609 1.2 yamt } 610 1.2 yamt coldtarget += coldadj; 611 1.2 yamt #else /* defined(ADAPTIVE) */ 612 1.2 yamt coldtarget = UVM_PCTPARAM_APPLY(&s->s_coldtargetpct, s->s_npages); 613 1.2 yamt if (coldtarget < 1) { 614 1.2 yamt coldtarget = 1; 615 1.2 yamt } 616 1.2 yamt #endif /* defined(ADAPTIVE) */ 617 1.2 yamt 618 1.2 yamt s->s_coldtarget = coldtarget; 619 1.2 yamt s->s_newqlenmax = coldtarget / 4; 620 1.2 yamt if (s->s_newqlenmax < CLOCKPRO_NEWQMIN) { 621 1.2 yamt s->s_newqlenmax = CLOCKPRO_NEWQMIN; 622 1.2 yamt } 623 1.2 yamt } 624 1.2 yamt 625 1.2 yamt static void 626 1.2 yamt clockpro_movereferencebit(struct vm_page *pg) 627 1.2 yamt { 628 1.7 thorpej bool referenced; 629 1.2 yamt 630 1.2 yamt referenced = pmap_clear_reference(pg); 631 1.2 yamt if (referenced) { 632 1.2 yamt pg->pqflags |= PQ_REFERENCED; 633 1.2 yamt } 634 1.2 yamt } 635 1.2 yamt 636 1.2 yamt static void 637 1.2 yamt clockpro_clearreferencebit(struct vm_page *pg) 638 1.2 yamt { 639 1.2 yamt 640 1.2 yamt clockpro_movereferencebit(pg); 641 1.2 yamt pg->pqflags &= ~PQ_REFERENCED; 642 1.2 yamt } 643 1.2 yamt 644 1.2 yamt static void 645 1.2 yamt clockpro___newqrotate(int len) 646 1.2 yamt { 647 1.2 yamt struct clockpro_state * const s = &clockpro; 648 1.2 yamt pageq_t * const newq = clockpro_queue(s, CLOCKPRO_NEWQ); 649 1.2 yamt struct vm_page *pg; 650 1.2 yamt 651 1.2 yamt while (pageq_len(newq) > len) { 652 1.2 yamt pg = pageq_remove_head(newq); 653 1.2 yamt KASSERT(pg != NULL); 654 1.2 yamt KASSERT(clockpro_getq(pg) == CLOCKPRO_NEWQ); 655 1.2 yamt if ((pg->pqflags & PQ_INITIALREF) != 0) { 656 1.2 yamt clockpro_clearreferencebit(pg); 657 1.2 yamt pg->pqflags &= ~PQ_INITIALREF; 658 1.2 yamt } 659 1.2 yamt /* place at the list head */ 660 1.2 yamt clockpro_insert_tail(s, CLOCKPRO_COLDQ, pg); 661 1.2 yamt } 662 1.2 yamt } 663 1.2 yamt 664 1.2 yamt static void 665 1.2 yamt clockpro_newqrotate(void) 666 1.2 yamt { 667 1.2 yamt struct clockpro_state * const s = &clockpro; 668 1.2 yamt 669 1.2 yamt check_sanity(); 670 1.2 yamt clockpro___newqrotate(s->s_newqlenmax); 671 1.2 yamt check_sanity(); 672 1.2 yamt } 673 1.2 yamt 674 1.2 yamt static void 675 1.2 yamt clockpro_newqflush(int n) 676 1.2 yamt { 677 1.2 yamt 678 1.2 yamt check_sanity(); 679 1.2 yamt clockpro___newqrotate(n); 680 1.2 yamt check_sanity(); 681 1.2 yamt } 682 1.2 yamt 683 1.2 yamt static void 684 1.2 yamt clockpro_newqflushone(void) 685 1.2 yamt { 686 1.2 yamt struct clockpro_state * const s = &clockpro; 687 1.2 yamt 688 1.2 yamt clockpro_newqflush( 689 1.2 yamt MAX(pageq_len(clockpro_queue(s, CLOCKPRO_NEWQ)) - 1, 0)); 690 1.2 yamt } 691 1.2 yamt 692 1.2 yamt /* 693 1.2 yamt * our "tail" is called "list-head" in the paper. 694 1.2 yamt */ 695 1.2 yamt 696 1.2 yamt static void 697 1.2 yamt clockpro___enqueuetail(struct vm_page *pg) 698 1.2 yamt { 699 1.2 yamt struct clockpro_state * const s = &clockpro; 700 1.2 yamt 701 1.2 yamt KASSERT(clockpro_getq(pg) == CLOCKPRO_NOQUEUE); 702 1.2 yamt 703 1.2 yamt check_sanity(); 704 1.2 yamt #if !defined(USEONCE2) 705 1.2 yamt clockpro_insert_tail(s, CLOCKPRO_NEWQ, pg); 706 1.2 yamt clockpro_newqrotate(); 707 1.2 yamt #else /* !defined(USEONCE2) */ 708 1.2 yamt #if defined(LISTQ) 709 1.2 yamt KASSERT((pg->pqflags & PQ_REFERENCED) == 0); 710 1.2 yamt #endif /* defined(LISTQ) */ 711 1.2 yamt clockpro_insert_tail(s, CLOCKPRO_COLDQ, pg); 712 1.2 yamt #endif /* !defined(USEONCE2) */ 713 1.2 yamt check_sanity(); 714 1.2 yamt } 715 1.2 yamt 716 1.2 yamt static void 717 1.2 yamt clockpro_pageenqueue(struct vm_page *pg) 718 1.2 yamt { 719 1.2 yamt struct clockpro_state * const s = &clockpro; 720 1.7 thorpej bool hot; 721 1.7 thorpej bool speculative = (pg->pqflags & PQ_SPECULATIVE) != 0; /* XXX */ 722 1.2 yamt 723 1.2 yamt KASSERT((~pg->pqflags & (PQ_INITIALREF|PQ_SPECULATIVE)) != 0); 724 1.9.16.1 bouyer KASSERT(mutex_owned(&uvm_pageqlock)); 725 1.2 yamt check_sanity(); 726 1.2 yamt KASSERT(clockpro_getq(pg) == CLOCKPRO_NOQUEUE); 727 1.2 yamt s->s_npages++; 728 1.2 yamt pg->pqflags &= ~(PQ_HOT|PQ_TEST); 729 1.2 yamt if (speculative) { 730 1.8 thorpej hot = false; 731 1.2 yamt PDPOL_EVCNT_INCR(speculativeenqueue); 732 1.2 yamt } else { 733 1.2 yamt hot = nonresident_pagelookupremove(pg); 734 1.2 yamt if (hot) { 735 1.2 yamt COLDTARGET_ADJ(1); 736 1.2 yamt } 737 1.2 yamt } 738 1.2 yamt 739 1.2 yamt /* 740 1.2 yamt * consider mmap'ed file: 741 1.2 yamt * 742 1.2 yamt * - read-ahead enqueues a page. 743 1.2 yamt * 744 1.2 yamt * - on the following read-ahead hit, the fault handler activates it. 745 1.2 yamt * 746 1.2 yamt * - finally, the userland code which caused the above fault 747 1.2 yamt * actually accesses the page. it makes its reference bit set. 748 1.2 yamt * 749 1.2 yamt * we want to count the above as a single access, rather than 750 1.2 yamt * three accesses with short reuse distances. 751 1.2 yamt */ 752 1.2 yamt 753 1.2 yamt #if defined(USEONCE2) 754 1.2 yamt pg->pqflags &= ~PQ_INITIALREF; 755 1.2 yamt if (hot) { 756 1.2 yamt pg->pqflags |= PQ_TEST; 757 1.2 yamt } 758 1.2 yamt s->s_ncold++; 759 1.2 yamt clockpro_clearreferencebit(pg); 760 1.2 yamt clockpro___enqueuetail(pg); 761 1.2 yamt #else /* defined(USEONCE2) */ 762 1.2 yamt if (speculative) { 763 1.2 yamt s->s_ncold++; 764 1.2 yamt } else if (hot) { 765 1.2 yamt pg->pqflags |= PQ_HOT; 766 1.2 yamt } else { 767 1.2 yamt pg->pqflags |= PQ_TEST; 768 1.2 yamt s->s_ncold++; 769 1.2 yamt } 770 1.2 yamt clockpro___enqueuetail(pg); 771 1.2 yamt #endif /* defined(USEONCE2) */ 772 1.2 yamt KASSERT(s->s_ncold <= s->s_npages); 773 1.2 yamt } 774 1.2 yamt 775 1.2 yamt static pageq_t * 776 1.2 yamt clockpro_pagequeue(struct vm_page *pg) 777 1.2 yamt { 778 1.2 yamt struct clockpro_state * const s = &clockpro; 779 1.2 yamt int qidx; 780 1.2 yamt 781 1.2 yamt qidx = clockpro_getq(pg); 782 1.2 yamt KASSERT(qidx != CLOCKPRO_NOQUEUE); 783 1.2 yamt 784 1.2 yamt return clockpro_queue(s, qidx); 785 1.2 yamt } 786 1.2 yamt 787 1.2 yamt static void 788 1.2 yamt clockpro_pagedequeue(struct vm_page *pg) 789 1.2 yamt { 790 1.2 yamt struct clockpro_state * const s = &clockpro; 791 1.2 yamt pageq_t *q; 792 1.2 yamt 793 1.2 yamt KASSERT(s->s_npages > 0); 794 1.2 yamt check_sanity(); 795 1.2 yamt q = clockpro_pagequeue(pg); 796 1.2 yamt pageq_remove(q, pg); 797 1.2 yamt check_sanity(); 798 1.2 yamt clockpro_setq(pg, CLOCKPRO_NOQUEUE); 799 1.2 yamt if ((pg->pqflags & PQ_HOT) == 0) { 800 1.2 yamt KASSERT(s->s_ncold > 0); 801 1.2 yamt s->s_ncold--; 802 1.2 yamt } 803 1.2 yamt KASSERT(s->s_npages > 0); 804 1.2 yamt s->s_npages--; 805 1.2 yamt check_sanity(); 806 1.2 yamt } 807 1.2 yamt 808 1.2 yamt static void 809 1.2 yamt clockpro_pagerequeue(struct vm_page *pg) 810 1.2 yamt { 811 1.2 yamt struct clockpro_state * const s = &clockpro; 812 1.2 yamt int qidx; 813 1.2 yamt 814 1.2 yamt qidx = clockpro_getq(pg); 815 1.2 yamt KASSERT(qidx == CLOCKPRO_HOTQ || qidx == CLOCKPRO_COLDQ); 816 1.2 yamt pageq_remove(clockpro_queue(s, qidx), pg); 817 1.2 yamt check_sanity(); 818 1.2 yamt clockpro_setq(pg, CLOCKPRO_NOQUEUE); 819 1.2 yamt 820 1.2 yamt clockpro___enqueuetail(pg); 821 1.2 yamt } 822 1.2 yamt 823 1.2 yamt static void 824 1.2 yamt handhot_endtest(struct vm_page *pg) 825 1.2 yamt { 826 1.2 yamt 827 1.2 yamt KASSERT((pg->pqflags & PQ_HOT) == 0); 828 1.2 yamt if ((pg->pqflags & PQ_TEST) != 0) { 829 1.2 yamt PDPOL_EVCNT_INCR(hhotcoldtest); 830 1.2 yamt COLDTARGET_ADJ(-1); 831 1.2 yamt pg->pqflags &= ~PQ_TEST; 832 1.2 yamt } else { 833 1.2 yamt PDPOL_EVCNT_INCR(hhotcold); 834 1.2 yamt } 835 1.2 yamt } 836 1.2 yamt 837 1.2 yamt static void 838 1.2 yamt handhot_advance(void) 839 1.2 yamt { 840 1.2 yamt struct clockpro_state * const s = &clockpro; 841 1.2 yamt struct vm_page *pg; 842 1.2 yamt pageq_t *hotq; 843 1.2 yamt int hotqlen; 844 1.2 yamt 845 1.2 yamt clockpro_tune(); 846 1.2 yamt 847 1.2 yamt dump("hot called"); 848 1.2 yamt if (s->s_ncold >= s->s_coldtarget) { 849 1.2 yamt return; 850 1.2 yamt } 851 1.2 yamt hotq = clockpro_queue(s, CLOCKPRO_HOTQ); 852 1.2 yamt again: 853 1.2 yamt pg = pageq_first(hotq); 854 1.2 yamt if (pg == NULL) { 855 1.2 yamt DPRINTF("%s: HHOT TAKEOVER\n", __func__); 856 1.2 yamt dump("hhottakeover"); 857 1.2 yamt PDPOL_EVCNT_INCR(hhottakeover); 858 1.2 yamt #if defined(LISTQ) 859 1.2 yamt while (/* CONSTCOND */ 1) { 860 1.2 yamt pageq_t *coldq = clockpro_queue(s, CLOCKPRO_COLDQ); 861 1.2 yamt 862 1.2 yamt pg = pageq_first(coldq); 863 1.2 yamt if (pg == NULL) { 864 1.2 yamt clockpro_newqflushone(); 865 1.2 yamt pg = pageq_first(coldq); 866 1.2 yamt if (pg == NULL) { 867 1.2 yamt WARN("hhot: no page?\n"); 868 1.2 yamt return; 869 1.2 yamt } 870 1.2 yamt } 871 1.2 yamt KASSERT(clockpro_pagequeue(pg) == coldq); 872 1.2 yamt pageq_remove(coldq, pg); 873 1.2 yamt check_sanity(); 874 1.2 yamt if ((pg->pqflags & PQ_HOT) == 0) { 875 1.2 yamt handhot_endtest(pg); 876 1.2 yamt clockpro_insert_tail(s, CLOCKPRO_LISTQ, pg); 877 1.2 yamt } else { 878 1.2 yamt clockpro_insert_head(s, CLOCKPRO_HOTQ, pg); 879 1.2 yamt break; 880 1.2 yamt } 881 1.2 yamt } 882 1.2 yamt #else /* defined(LISTQ) */ 883 1.2 yamt clockpro_newqflush(0); /* XXX XXX */ 884 1.2 yamt clockpro_switchqueue(); 885 1.2 yamt hotq = clockpro_queue(s, CLOCKPRO_HOTQ); 886 1.2 yamt goto again; 887 1.2 yamt #endif /* defined(LISTQ) */ 888 1.2 yamt } 889 1.2 yamt 890 1.2 yamt KASSERT(clockpro_pagequeue(pg) == hotq); 891 1.2 yamt 892 1.2 yamt /* 893 1.2 yamt * terminate test period of nonresident pages by cycling them. 894 1.2 yamt */ 895 1.2 yamt 896 1.2 yamt cycle_target_frac += BUCKETSIZE; 897 1.2 yamt hotqlen = pageq_len(hotq); 898 1.2 yamt while (cycle_target_frac >= hotqlen) { 899 1.2 yamt cycle_target++; 900 1.2 yamt cycle_target_frac -= hotqlen; 901 1.2 yamt } 902 1.2 yamt 903 1.2 yamt if ((pg->pqflags & PQ_HOT) == 0) { 904 1.2 yamt #if defined(LISTQ) 905 1.2 yamt panic("cold page in hotq: %p", pg); 906 1.2 yamt #else /* defined(LISTQ) */ 907 1.2 yamt handhot_endtest(pg); 908 1.2 yamt goto next; 909 1.2 yamt #endif /* defined(LISTQ) */ 910 1.2 yamt } 911 1.2 yamt KASSERT((pg->pqflags & PQ_TEST) == 0); 912 1.2 yamt KASSERT((pg->pqflags & PQ_INITIALREF) == 0); 913 1.2 yamt KASSERT((pg->pqflags & PQ_SPECULATIVE) == 0); 914 1.2 yamt 915 1.2 yamt /* 916 1.2 yamt * once we met our target, 917 1.2 yamt * stop at a hot page so that no cold pages in test period 918 1.2 yamt * have larger recency than any hot pages. 919 1.2 yamt */ 920 1.2 yamt 921 1.2 yamt if (s->s_ncold >= s->s_coldtarget) { 922 1.2 yamt dump("hot done"); 923 1.2 yamt return; 924 1.2 yamt } 925 1.2 yamt clockpro_movereferencebit(pg); 926 1.2 yamt if ((pg->pqflags & PQ_REFERENCED) == 0) { 927 1.2 yamt PDPOL_EVCNT_INCR(hhotunref); 928 1.2 yamt uvmexp.pddeact++; 929 1.2 yamt pg->pqflags &= ~PQ_HOT; 930 1.2 yamt clockpro.s_ncold++; 931 1.2 yamt KASSERT(s->s_ncold <= s->s_npages); 932 1.2 yamt } else { 933 1.2 yamt PDPOL_EVCNT_INCR(hhotref); 934 1.2 yamt } 935 1.2 yamt pg->pqflags &= ~PQ_REFERENCED; 936 1.2 yamt #if !defined(LISTQ) 937 1.2 yamt next: 938 1.2 yamt #endif /* !defined(LISTQ) */ 939 1.2 yamt clockpro_pagerequeue(pg); 940 1.2 yamt dump("hot"); 941 1.2 yamt goto again; 942 1.2 yamt } 943 1.2 yamt 944 1.2 yamt static struct vm_page * 945 1.2 yamt handcold_advance(void) 946 1.2 yamt { 947 1.2 yamt struct clockpro_state * const s = &clockpro; 948 1.2 yamt struct vm_page *pg; 949 1.2 yamt 950 1.2 yamt for (;;) { 951 1.3 yamt #if defined(LISTQ) 952 1.2 yamt pageq_t *listq = clockpro_queue(s, CLOCKPRO_LISTQ); 953 1.3 yamt #endif /* defined(LISTQ) */ 954 1.2 yamt pageq_t *coldq; 955 1.2 yamt 956 1.2 yamt clockpro_newqrotate(); 957 1.2 yamt handhot_advance(); 958 1.2 yamt #if defined(LISTQ) 959 1.2 yamt pg = pageq_first(listq); 960 1.2 yamt if (pg != NULL) { 961 1.2 yamt KASSERT(clockpro_getq(pg) == CLOCKPRO_LISTQ); 962 1.2 yamt KASSERT((pg->pqflags & PQ_TEST) == 0); 963 1.2 yamt KASSERT((pg->pqflags & PQ_HOT) == 0); 964 1.2 yamt KASSERT((pg->pqflags & PQ_INITIALREF) == 0); 965 1.2 yamt pageq_remove(listq, pg); 966 1.2 yamt check_sanity(); 967 1.2 yamt clockpro_insert_head(s, CLOCKPRO_COLDQ, pg); /* XXX */ 968 1.2 yamt goto gotcold; 969 1.2 yamt } 970 1.2 yamt #endif /* defined(LISTQ) */ 971 1.2 yamt check_sanity(); 972 1.2 yamt coldq = clockpro_queue(s, CLOCKPRO_COLDQ); 973 1.2 yamt pg = pageq_first(coldq); 974 1.2 yamt if (pg == NULL) { 975 1.2 yamt clockpro_newqflushone(); 976 1.2 yamt pg = pageq_first(coldq); 977 1.2 yamt } 978 1.2 yamt if (pg == NULL) { 979 1.2 yamt DPRINTF("%s: HCOLD TAKEOVER\n", __func__); 980 1.2 yamt dump("hcoldtakeover"); 981 1.2 yamt PDPOL_EVCNT_INCR(hcoldtakeover); 982 1.2 yamt KASSERT( 983 1.2 yamt pageq_len(clockpro_queue(s, CLOCKPRO_NEWQ)) == 0); 984 1.2 yamt #if defined(LISTQ) 985 1.2 yamt KASSERT( 986 1.2 yamt pageq_len(clockpro_queue(s, CLOCKPRO_HOTQ)) == 0); 987 1.2 yamt #else /* defined(LISTQ) */ 988 1.2 yamt clockpro_switchqueue(); 989 1.2 yamt coldq = clockpro_queue(s, CLOCKPRO_COLDQ); 990 1.2 yamt pg = pageq_first(coldq); 991 1.2 yamt #endif /* defined(LISTQ) */ 992 1.2 yamt } 993 1.2 yamt if (pg == NULL) { 994 1.2 yamt WARN("hcold: no page?\n"); 995 1.2 yamt return NULL; 996 1.2 yamt } 997 1.2 yamt KASSERT((pg->pqflags & PQ_INITIALREF) == 0); 998 1.2 yamt if ((pg->pqflags & PQ_HOT) != 0) { 999 1.2 yamt PDPOL_EVCNT_INCR(hcoldhot); 1000 1.2 yamt pageq_remove(coldq, pg); 1001 1.2 yamt clockpro_insert_tail(s, CLOCKPRO_HOTQ, pg); 1002 1.2 yamt check_sanity(); 1003 1.2 yamt KASSERT((pg->pqflags & PQ_TEST) == 0); 1004 1.2 yamt uvmexp.pdscans++; 1005 1.2 yamt continue; 1006 1.2 yamt } 1007 1.2 yamt #if defined(LISTQ) 1008 1.2 yamt gotcold: 1009 1.2 yamt #endif /* defined(LISTQ) */ 1010 1.2 yamt KASSERT((pg->pqflags & PQ_HOT) == 0); 1011 1.2 yamt uvmexp.pdscans++; 1012 1.2 yamt clockpro_movereferencebit(pg); 1013 1.2 yamt if ((pg->pqflags & PQ_SPECULATIVE) != 0) { 1014 1.2 yamt KASSERT((pg->pqflags & PQ_TEST) == 0); 1015 1.2 yamt if ((pg->pqflags & PQ_REFERENCED) != 0) { 1016 1.2 yamt PDPOL_EVCNT_INCR(speculativehit2); 1017 1.2 yamt pg->pqflags &= ~(PQ_SPECULATIVE|PQ_REFERENCED); 1018 1.2 yamt clockpro_pagedequeue(pg); 1019 1.2 yamt clockpro_pageenqueue(pg); 1020 1.2 yamt continue; 1021 1.2 yamt } 1022 1.2 yamt PDPOL_EVCNT_INCR(speculativemiss); 1023 1.2 yamt } 1024 1.2 yamt switch (pg->pqflags & (PQ_REFERENCED|PQ_TEST)) { 1025 1.2 yamt case PQ_TEST: 1026 1.2 yamt PDPOL_EVCNT_INCR(hcoldunreftest); 1027 1.2 yamt nonresident_pagerecord(pg); 1028 1.2 yamt goto gotit; 1029 1.2 yamt case 0: 1030 1.2 yamt PDPOL_EVCNT_INCR(hcoldunref); 1031 1.2 yamt gotit: 1032 1.2 yamt KASSERT(s->s_ncold > 0); 1033 1.2 yamt clockpro_pagerequeue(pg); /* XXX */ 1034 1.2 yamt dump("cold done"); 1035 1.2 yamt /* XXX "pg" is still in queue */ 1036 1.2 yamt handhot_advance(); 1037 1.2 yamt goto done; 1038 1.2 yamt 1039 1.2 yamt case PQ_REFERENCED|PQ_TEST: 1040 1.2 yamt PDPOL_EVCNT_INCR(hcoldreftest); 1041 1.2 yamt s->s_ncold--; 1042 1.2 yamt COLDTARGET_ADJ(1); 1043 1.2 yamt pg->pqflags |= PQ_HOT; 1044 1.2 yamt pg->pqflags &= ~PQ_TEST; 1045 1.2 yamt break; 1046 1.2 yamt 1047 1.2 yamt case PQ_REFERENCED: 1048 1.2 yamt PDPOL_EVCNT_INCR(hcoldref); 1049 1.2 yamt pg->pqflags |= PQ_TEST; 1050 1.2 yamt break; 1051 1.2 yamt } 1052 1.2 yamt pg->pqflags &= ~PQ_REFERENCED; 1053 1.2 yamt uvmexp.pdreact++; 1054 1.2 yamt /* move to the list head */ 1055 1.2 yamt clockpro_pagerequeue(pg); 1056 1.2 yamt dump("cold"); 1057 1.2 yamt } 1058 1.2 yamt done:; 1059 1.2 yamt return pg; 1060 1.2 yamt } 1061 1.2 yamt 1062 1.2 yamt void 1063 1.2 yamt uvmpdpol_pageactivate(struct vm_page *pg) 1064 1.2 yamt { 1065 1.2 yamt 1066 1.2 yamt if (!uvmpdpol_pageisqueued_p(pg)) { 1067 1.2 yamt KASSERT((pg->pqflags & PQ_SPECULATIVE) == 0); 1068 1.2 yamt pg->pqflags |= PQ_INITIALREF; 1069 1.2 yamt clockpro_pageenqueue(pg); 1070 1.2 yamt } else if ((pg->pqflags & PQ_SPECULATIVE)) { 1071 1.2 yamt PDPOL_EVCNT_INCR(speculativehit1); 1072 1.2 yamt pg->pqflags &= ~PQ_SPECULATIVE; 1073 1.2 yamt pg->pqflags |= PQ_INITIALREF; 1074 1.2 yamt clockpro_pagedequeue(pg); 1075 1.2 yamt clockpro_pageenqueue(pg); 1076 1.2 yamt } 1077 1.2 yamt pg->pqflags |= PQ_REFERENCED; 1078 1.2 yamt } 1079 1.2 yamt 1080 1.2 yamt void 1081 1.2 yamt uvmpdpol_pagedeactivate(struct vm_page *pg) 1082 1.2 yamt { 1083 1.2 yamt 1084 1.9.16.2 bouyer clockpro_clearreferencebit(pg); 1085 1.2 yamt } 1086 1.2 yamt 1087 1.2 yamt void 1088 1.2 yamt uvmpdpol_pagedequeue(struct vm_page *pg) 1089 1.2 yamt { 1090 1.2 yamt 1091 1.2 yamt if (!uvmpdpol_pageisqueued_p(pg)) { 1092 1.2 yamt return; 1093 1.2 yamt } 1094 1.2 yamt clockpro_pagedequeue(pg); 1095 1.6 yamt pg->pqflags &= ~(PQ_INITIALREF|PQ_SPECULATIVE); 1096 1.2 yamt } 1097 1.2 yamt 1098 1.2 yamt void 1099 1.2 yamt uvmpdpol_pageenqueue(struct vm_page *pg) 1100 1.2 yamt { 1101 1.2 yamt 1102 1.2 yamt #if 1 1103 1.2 yamt if (uvmpdpol_pageisqueued_p(pg)) { 1104 1.2 yamt return; 1105 1.2 yamt } 1106 1.2 yamt clockpro_clearreferencebit(pg); 1107 1.2 yamt pg->pqflags |= PQ_SPECULATIVE; 1108 1.2 yamt clockpro_pageenqueue(pg); 1109 1.2 yamt #else 1110 1.2 yamt uvmpdpol_pageactivate(pg); 1111 1.2 yamt #endif 1112 1.2 yamt } 1113 1.2 yamt 1114 1.2 yamt void 1115 1.2 yamt uvmpdpol_anfree(struct vm_anon *an) 1116 1.2 yamt { 1117 1.2 yamt 1118 1.2 yamt KASSERT(an->an_page == NULL); 1119 1.2 yamt if (nonresident_lookupremove((objid_t)an, 0)) { 1120 1.2 yamt PDPOL_EVCNT_INCR(nresanonfree); 1121 1.2 yamt } 1122 1.2 yamt } 1123 1.2 yamt 1124 1.2 yamt void 1125 1.2 yamt uvmpdpol_init(void) 1126 1.2 yamt { 1127 1.2 yamt 1128 1.2 yamt clockpro_init(); 1129 1.2 yamt } 1130 1.2 yamt 1131 1.2 yamt void 1132 1.2 yamt uvmpdpol_reinit(void) 1133 1.2 yamt { 1134 1.2 yamt 1135 1.2 yamt clockpro_reinit(); 1136 1.2 yamt } 1137 1.2 yamt 1138 1.2 yamt void 1139 1.2 yamt uvmpdpol_estimatepageable(int *active, int *inactive) 1140 1.2 yamt { 1141 1.2 yamt struct clockpro_state * const s = &clockpro; 1142 1.2 yamt 1143 1.2 yamt if (active) { 1144 1.2 yamt *active = s->s_npages - s->s_ncold; 1145 1.2 yamt } 1146 1.2 yamt if (inactive) { 1147 1.2 yamt *inactive = s->s_ncold; 1148 1.2 yamt } 1149 1.2 yamt } 1150 1.2 yamt 1151 1.7 thorpej bool 1152 1.2 yamt uvmpdpol_pageisqueued_p(struct vm_page *pg) 1153 1.2 yamt { 1154 1.2 yamt 1155 1.2 yamt return clockpro_getq(pg) != CLOCKPRO_NOQUEUE; 1156 1.2 yamt } 1157 1.2 yamt 1158 1.2 yamt void 1159 1.2 yamt uvmpdpol_scaninit(void) 1160 1.2 yamt { 1161 1.2 yamt struct clockpro_scanstate * const ss = &scanstate; 1162 1.2 yamt 1163 1.2 yamt ss->ss_nscanned = 0; 1164 1.2 yamt } 1165 1.2 yamt 1166 1.2 yamt struct vm_page * 1167 1.2 yamt uvmpdpol_selectvictim(void) 1168 1.2 yamt { 1169 1.2 yamt struct clockpro_state * const s = &clockpro; 1170 1.2 yamt struct clockpro_scanstate * const ss = &scanstate; 1171 1.2 yamt struct vm_page *pg; 1172 1.2 yamt 1173 1.2 yamt if (ss->ss_nscanned > s->s_npages) { 1174 1.2 yamt DPRINTF("scan too much\n"); 1175 1.2 yamt return NULL; 1176 1.2 yamt } 1177 1.2 yamt pg = handcold_advance(); 1178 1.2 yamt ss->ss_nscanned++; 1179 1.2 yamt return pg; 1180 1.2 yamt } 1181 1.2 yamt 1182 1.2 yamt static void 1183 1.2 yamt clockpro_dropswap(pageq_t *q, int *todo) 1184 1.2 yamt { 1185 1.2 yamt struct vm_page *pg; 1186 1.2 yamt 1187 1.2 yamt TAILQ_FOREACH_REVERSE(pg, &q->q_q, pglist, pageq) { 1188 1.2 yamt if (*todo <= 0) { 1189 1.2 yamt break; 1190 1.2 yamt } 1191 1.2 yamt if ((pg->pqflags & PQ_HOT) == 0) { 1192 1.2 yamt continue; 1193 1.2 yamt } 1194 1.2 yamt if ((pg->pqflags & PQ_SWAPBACKED) == 0) { 1195 1.2 yamt continue; 1196 1.2 yamt } 1197 1.2 yamt if (uvmpd_trydropswap(pg)) { 1198 1.2 yamt (*todo)--; 1199 1.2 yamt } 1200 1.2 yamt } 1201 1.2 yamt } 1202 1.2 yamt 1203 1.2 yamt void 1204 1.2 yamt uvmpdpol_balancequeue(int swap_shortage) 1205 1.2 yamt { 1206 1.2 yamt struct clockpro_state * const s = &clockpro; 1207 1.2 yamt int todo = swap_shortage; 1208 1.2 yamt 1209 1.2 yamt if (todo == 0) { 1210 1.2 yamt return; 1211 1.2 yamt } 1212 1.2 yamt 1213 1.2 yamt /* 1214 1.2 yamt * reclaim swap slots from hot pages 1215 1.2 yamt */ 1216 1.2 yamt 1217 1.2 yamt DPRINTF("%s: swap_shortage=%d\n", __func__, swap_shortage); 1218 1.2 yamt 1219 1.2 yamt clockpro_dropswap(clockpro_queue(s, CLOCKPRO_NEWQ), &todo); 1220 1.2 yamt clockpro_dropswap(clockpro_queue(s, CLOCKPRO_COLDQ), &todo); 1221 1.2 yamt clockpro_dropswap(clockpro_queue(s, CLOCKPRO_HOTQ), &todo); 1222 1.2 yamt 1223 1.2 yamt DPRINTF("%s: done=%d\n", __func__, swap_shortage - todo); 1224 1.2 yamt } 1225 1.2 yamt 1226 1.7 thorpej bool 1227 1.2 yamt uvmpdpol_needsscan_p(void) 1228 1.2 yamt { 1229 1.2 yamt struct clockpro_state * const s = &clockpro; 1230 1.2 yamt 1231 1.2 yamt if (s->s_ncold < s->s_coldtarget) { 1232 1.8 thorpej return true; 1233 1.2 yamt } 1234 1.8 thorpej return false; 1235 1.2 yamt } 1236 1.2 yamt 1237 1.2 yamt void 1238 1.2 yamt uvmpdpol_tune(void) 1239 1.2 yamt { 1240 1.2 yamt 1241 1.2 yamt clockpro_tune(); 1242 1.2 yamt } 1243 1.2 yamt 1244 1.2 yamt #if !defined(PDSIM) 1245 1.2 yamt 1246 1.2 yamt #include <sys/sysctl.h> /* XXX SYSCTL_DESCR */ 1247 1.2 yamt 1248 1.2 yamt void 1249 1.2 yamt uvmpdpol_sysctlsetup(void) 1250 1.2 yamt { 1251 1.2 yamt #if !defined(ADAPTIVE) 1252 1.2 yamt struct clockpro_state * const s = &clockpro; 1253 1.2 yamt 1254 1.2 yamt uvm_pctparam_createsysctlnode(&s->s_coldtargetpct, "coldtargetpct", 1255 1.2 yamt SYSCTL_DESCR("Percentage cold target queue of the entire queue")); 1256 1.2 yamt #endif /* !defined(ADAPTIVE) */ 1257 1.2 yamt } 1258 1.2 yamt 1259 1.2 yamt #endif /* !defined(PDSIM) */ 1260 1.2 yamt 1261 1.2 yamt #if defined(DDB) 1262 1.2 yamt 1263 1.2 yamt void clockpro_dump(void); 1264 1.2 yamt 1265 1.2 yamt void 1266 1.2 yamt clockpro_dump(void) 1267 1.2 yamt { 1268 1.2 yamt struct clockpro_state * const s = &clockpro; 1269 1.2 yamt 1270 1.2 yamt struct vm_page *pg; 1271 1.2 yamt int ncold, nhot, ntest, nspeculative, ninitialref, nref; 1272 1.2 yamt int newqlen, coldqlen, hotqlen, listqlen; 1273 1.2 yamt 1274 1.2 yamt newqlen = coldqlen = hotqlen = listqlen = 0; 1275 1.2 yamt printf("npages=%d, ncold=%d, coldtarget=%d, newqlenmax=%d\n", 1276 1.2 yamt s->s_npages, s->s_ncold, s->s_coldtarget, s->s_newqlenmax); 1277 1.2 yamt 1278 1.2 yamt #define INITCOUNT() \ 1279 1.2 yamt ncold = nhot = ntest = nspeculative = ninitialref = nref = 0 1280 1.2 yamt 1281 1.2 yamt #define COUNT(pg) \ 1282 1.2 yamt if ((pg->pqflags & PQ_HOT) != 0) { \ 1283 1.2 yamt nhot++; \ 1284 1.2 yamt } else { \ 1285 1.2 yamt ncold++; \ 1286 1.2 yamt if ((pg->pqflags & PQ_TEST) != 0) { \ 1287 1.2 yamt ntest++; \ 1288 1.2 yamt } \ 1289 1.2 yamt if ((pg->pqflags & PQ_SPECULATIVE) != 0) { \ 1290 1.2 yamt nspeculative++; \ 1291 1.2 yamt } \ 1292 1.2 yamt if ((pg->pqflags & PQ_INITIALREF) != 0) { \ 1293 1.2 yamt ninitialref++; \ 1294 1.2 yamt } else if ((pg->pqflags & PQ_REFERENCED) != 0 || \ 1295 1.2 yamt pmap_is_referenced(pg)) { \ 1296 1.2 yamt nref++; \ 1297 1.2 yamt } \ 1298 1.2 yamt } 1299 1.2 yamt 1300 1.2 yamt #define PRINTCOUNT(name) \ 1301 1.2 yamt printf("%s hot=%d, cold=%d, test=%d, speculative=%d, initialref=%d, " \ 1302 1.2 yamt "nref=%d\n", \ 1303 1.2 yamt (name), nhot, ncold, ntest, nspeculative, ninitialref, nref) 1304 1.2 yamt 1305 1.2 yamt INITCOUNT(); 1306 1.2 yamt TAILQ_FOREACH(pg, &clockpro_queue(s, CLOCKPRO_NEWQ)->q_q, pageq) { 1307 1.2 yamt if (clockpro_getq(pg) != CLOCKPRO_NEWQ) { 1308 1.2 yamt printf("newq corrupt %p\n", pg); 1309 1.2 yamt } 1310 1.2 yamt COUNT(pg) 1311 1.2 yamt newqlen++; 1312 1.2 yamt } 1313 1.2 yamt PRINTCOUNT("newq"); 1314 1.2 yamt 1315 1.2 yamt INITCOUNT(); 1316 1.2 yamt TAILQ_FOREACH(pg, &clockpro_queue(s, CLOCKPRO_COLDQ)->q_q, pageq) { 1317 1.2 yamt if (clockpro_getq(pg) != CLOCKPRO_COLDQ) { 1318 1.2 yamt printf("coldq corrupt %p\n", pg); 1319 1.2 yamt } 1320 1.2 yamt COUNT(pg) 1321 1.2 yamt coldqlen++; 1322 1.2 yamt } 1323 1.2 yamt PRINTCOUNT("coldq"); 1324 1.2 yamt 1325 1.2 yamt INITCOUNT(); 1326 1.2 yamt TAILQ_FOREACH(pg, &clockpro_queue(s, CLOCKPRO_HOTQ)->q_q, pageq) { 1327 1.2 yamt if (clockpro_getq(pg) != CLOCKPRO_HOTQ) { 1328 1.2 yamt printf("hotq corrupt %p\n", pg); 1329 1.2 yamt } 1330 1.2 yamt #if defined(LISTQ) 1331 1.2 yamt if ((pg->pqflags & PQ_HOT) == 0) { 1332 1.2 yamt printf("cold page in hotq: %p\n", pg); 1333 1.2 yamt } 1334 1.2 yamt #endif /* defined(LISTQ) */ 1335 1.2 yamt COUNT(pg) 1336 1.2 yamt hotqlen++; 1337 1.2 yamt } 1338 1.2 yamt PRINTCOUNT("hotq"); 1339 1.2 yamt 1340 1.2 yamt INITCOUNT(); 1341 1.2 yamt TAILQ_FOREACH(pg, &clockpro_queue(s, CLOCKPRO_LISTQ)->q_q, pageq) { 1342 1.2 yamt #if !defined(LISTQ) 1343 1.2 yamt printf("listq %p\n"); 1344 1.2 yamt #endif /* !defined(LISTQ) */ 1345 1.2 yamt if (clockpro_getq(pg) != CLOCKPRO_LISTQ) { 1346 1.2 yamt printf("listq corrupt %p\n", pg); 1347 1.2 yamt } 1348 1.2 yamt COUNT(pg) 1349 1.2 yamt listqlen++; 1350 1.2 yamt } 1351 1.2 yamt PRINTCOUNT("listq"); 1352 1.2 yamt 1353 1.2 yamt printf("newqlen=%d/%d, coldqlen=%d/%d, hotqlen=%d/%d, listqlen=%d/%d\n", 1354 1.2 yamt newqlen, pageq_len(clockpro_queue(s, CLOCKPRO_NEWQ)), 1355 1.2 yamt coldqlen, pageq_len(clockpro_queue(s, CLOCKPRO_COLDQ)), 1356 1.2 yamt hotqlen, pageq_len(clockpro_queue(s, CLOCKPRO_HOTQ)), 1357 1.2 yamt listqlen, pageq_len(clockpro_queue(s, CLOCKPRO_LISTQ))); 1358 1.2 yamt } 1359 1.2 yamt 1360 1.2 yamt #endif /* defined(DDB) */ 1361 1.2 yamt 1362 1.2 yamt #if defined(PDSIM) 1363 1.3 yamt #if defined(DEBUG) 1364 1.2 yamt static void 1365 1.2 yamt pdsim_dumpq(int qidx) 1366 1.2 yamt { 1367 1.2 yamt struct clockpro_state * const s = &clockpro; 1368 1.2 yamt pageq_t *q = clockpro_queue(s, qidx); 1369 1.2 yamt struct vm_page *pg; 1370 1.2 yamt 1371 1.2 yamt TAILQ_FOREACH(pg, &q->q_q, pageq) { 1372 1.2 yamt DPRINTF(" %" PRIu64 "%s%s%s%s%s%s", 1373 1.2 yamt pg->offset >> PAGE_SHIFT, 1374 1.2 yamt (pg->pqflags & PQ_HOT) ? "H" : "", 1375 1.2 yamt (pg->pqflags & PQ_TEST) ? "T" : "", 1376 1.2 yamt (pg->pqflags & PQ_REFERENCED) ? "R" : "", 1377 1.2 yamt pmap_is_referenced(pg) ? "r" : "", 1378 1.2 yamt (pg->pqflags & PQ_INITIALREF) ? "I" : "", 1379 1.2 yamt (pg->pqflags & PQ_SPECULATIVE) ? "S" : "" 1380 1.2 yamt ); 1381 1.2 yamt } 1382 1.2 yamt } 1383 1.3 yamt #endif /* defined(DEBUG) */ 1384 1.2 yamt 1385 1.2 yamt void 1386 1.2 yamt pdsim_dump(const char *id) 1387 1.2 yamt { 1388 1.2 yamt #if defined(DEBUG) 1389 1.2 yamt struct clockpro_state * const s = &clockpro; 1390 1.2 yamt 1391 1.2 yamt DPRINTF(" %s L(", id); 1392 1.2 yamt pdsim_dumpq(CLOCKPRO_LISTQ); 1393 1.2 yamt DPRINTF(" ) H("); 1394 1.2 yamt pdsim_dumpq(CLOCKPRO_HOTQ); 1395 1.2 yamt DPRINTF(" ) C("); 1396 1.2 yamt pdsim_dumpq(CLOCKPRO_COLDQ); 1397 1.2 yamt DPRINTF(" ) N("); 1398 1.2 yamt pdsim_dumpq(CLOCKPRO_NEWQ); 1399 1.2 yamt DPRINTF(" ) ncold=%d/%d, coldadj=%d\n", 1400 1.2 yamt s->s_ncold, s->s_coldtarget, coldadj); 1401 1.2 yamt #endif /* defined(DEBUG) */ 1402 1.2 yamt } 1403 1.2 yamt #endif /* defined(PDSIM) */ 1404
Indexes created Mon Sep 22 13:09:51 GMT 2025