18a272653SPeter Holm#!/bin/sh 28a272653SPeter Holm 38a272653SPeter Holm# 48a272653SPeter Holm# Copyright (c) 2015 EMC Corp. 58a272653SPeter Holm# All rights reserved. 68a272653SPeter Holm# 78a272653SPeter Holm# Redistribution and use in source and binary forms, with or without 88a272653SPeter Holm# modification, are permitted provided that the following conditions 98a272653SPeter Holm# are met: 108a272653SPeter Holm# 1. Redistributions of source code must retain the above copyright 118a272653SPeter Holm# notice, this list of conditions and the following disclaimer. 128a272653SPeter Holm# 2. Redistributions in binary form must reproduce the above copyright 138a272653SPeter Holm# notice, this list of conditions and the following disclaimer in the 148a272653SPeter Holm# documentation and/or other materials provided with the distribution. 158a272653SPeter Holm# 168a272653SPeter Holm# THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 178a272653SPeter Holm# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 188a272653SPeter Holm# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 198a272653SPeter Holm# ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 208a272653SPeter Holm# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 218a272653SPeter Holm# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 228a272653SPeter Holm# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 238a272653SPeter Holm# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 248a272653SPeter Holm# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 258a272653SPeter Holm# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 268a272653SPeter Holm# SUCH DAMAGE. 278a272653SPeter Holm# 288a272653SPeter Holm 298a272653SPeter Holm# Copy of holdcnt0.sh, but without the memory disk usage. 308a272653SPeter Holm 318a272653SPeter Holm# Test scenario suggestion by alc@ 328a272653SPeter Holm 338a272653SPeter Holm[ `id -u ` -ne 0 ] && echo "Must be root!" && exit 1 348a272653SPeter Holm[ `swapinfo | wc -l` -eq 1 ] && exit 0 358a272653SPeter Holm[ `sysctl -n hw.physmem` -lt $((32 * 1024 * 1024 * 1024)) ] && exit 0 368a272653SPeter Holm 378a272653SPeter Holm. ../default.cfg 388a272653SPeter Holm 398a272653SPeter Holmhere=`pwd` 408a272653SPeter Holmcd /tmp 418a272653SPeter Holmsed '1,/^EOF/d' < $here/$0 > holdcnt02.c 428a272653SPeter Holmmycc -o holdcnt02 -Wall -Wextra -g holdcnt02.c || exit 1 438a272653SPeter Holmrm -f holdcnt02.c 448a272653SPeter Holmcd $here 458a272653SPeter Holm 468a272653SPeter Holmtrap "rm -f /tmp/holdcnt02 `dirname $diskimage`/f000???" EXIT INT 478a272653SPeter Holm(cd `dirname $diskimage`; /tmp/holdcnt02) & 488a272653SPeter Holmpid=$! 498a272653SPeter Holmsleep 5 508a272653SPeter Holmwhile kill -0 $! 2> /dev/null; do 518a272653SPeter Holm (cd ../testcases/swap; ./swap -t 1m -i 1) > /dev/null 2>&1 528a272653SPeter Holmdone 538a272653SPeter Holmwait $pid 548a272653SPeter Holmexit 558a272653SPeter HolmEOF 568a272653SPeter Holm/* 578a272653SPeter Holm A test that causes the page daemon to generate cached pages 588a272653SPeter Holm within a bunch of files and has some consumer that is trying to 598a272653SPeter Holm allocate new pages to the same files. 608a272653SPeter Holm*/ 618a272653SPeter Holm 628a272653SPeter Holm#include <sys/types.h> 638a272653SPeter Holm#include <sys/mman.h> 648a272653SPeter Holm#include <sys/stat.h> 658a272653SPeter Holm#include <sys/wait.h> 668a272653SPeter Holm 678a272653SPeter Holm#include <err.h> 688a272653SPeter Holm#include <errno.h> 698a272653SPeter Holm#include <fcntl.h> 708a272653SPeter Holm#include <setjmp.h> 718a272653SPeter Holm#include <signal.h> 728a272653SPeter Holm#include <stdio.h> 738a272653SPeter Holm#include <stdlib.h> 748a272653SPeter Holm#include <time.h> 758a272653SPeter Holm#include <unistd.h> 768a272653SPeter Holm 778a272653SPeter Holm#define BUFSIZE (1024 * 1024) 788a272653SPeter Holm#define FILES 200 798a272653SPeter Holm#define RPARALLEL 8 808a272653SPeter Holm#define WPARALLEL 2 818a272653SPeter Holm 828a272653SPeter Holmstatic jmp_buf jbuf; 838a272653SPeter Holmstatic off_t maxsize; 848a272653SPeter Holmstatic int ps; 858a272653SPeter Holmstatic char *buf; 868a272653SPeter Holmstatic volatile char val; 878a272653SPeter Holm 888a272653SPeter Holmstatic void 898a272653SPeter Holmhand(int i __unused) { /* handler */ 908a272653SPeter Holm longjmp(jbuf, 1); 918a272653SPeter Holm} 928a272653SPeter Holm 938a272653SPeter Holmstatic void 948a272653SPeter Holmcleanup(void) 958a272653SPeter Holm{ 968a272653SPeter Holm int i; 978a272653SPeter Holm char file[80]; 988a272653SPeter Holm 998a272653SPeter Holm for (i = 0; i < FILES; i++) { 1008a272653SPeter Holm snprintf(file, sizeof(file), "f%06d", i); 1018a272653SPeter Holm unlink(file); 1028a272653SPeter Holm } 1038a272653SPeter Holm} 1048a272653SPeter Holm 1058a272653SPeter Holmstatic void 1068a272653SPeter Holminit(void) 1078a272653SPeter Holm{ 1088a272653SPeter Holm int fd, i; 1098a272653SPeter Holm char file[80]; 1108a272653SPeter Holm 1118a272653SPeter Holm for (i = 0; i < FILES; i++) { 1128a272653SPeter Holm snprintf(file, sizeof(file), "f%06d", i); 1138a272653SPeter Holm if ((fd = open(file, O_RDWR | O_CREAT | O_TRUNC, 0644)) == 1148a272653SPeter Holm -1) 1158a272653SPeter Holm err(1, "open(%s)", file); 1168a272653SPeter Holm if (write(fd, buf, BUFSIZE) != BUFSIZE) 1178a272653SPeter Holm err(1, "write"); 1188a272653SPeter Holm close(fd); 1198a272653SPeter Holm } 1208a272653SPeter Holm 1218a272653SPeter Holm} 1228a272653SPeter Holm 1238a272653SPeter Holmstatic void 1248a272653SPeter Holmwriter(void) 1258a272653SPeter Holm{ 1268a272653SPeter Holm int fd, i; 1278a272653SPeter Holm char file[80]; 1288a272653SPeter Holm time_t start; 1298a272653SPeter Holm struct stat statbuf; 1308a272653SPeter Holm 1318a272653SPeter Holm setproctitle("writer"); 1328a272653SPeter Holm start = time(NULL); 1338a272653SPeter Holm while (time(NULL) - start < 600) { 1348a272653SPeter Holm for (i = 0; i < FILES; i++) { 1358a272653SPeter Holm snprintf(file, sizeof(file), "f%06d", i); 1368a272653SPeter Holm if ((fd = open(file, O_RDWR | O_APPEND)) == -1) { 1378a272653SPeter Holm if (errno != ENOENT) 1388a272653SPeter Holm err(1, "open(%s) append", file); 1398a272653SPeter Holm goto err; 1408a272653SPeter Holm } 1418a272653SPeter Holm if (fstat(fd, &statbuf) < 0) 1428a272653SPeter Holm err(1, "fstat error"); 1438a272653SPeter Holm if (statbuf.st_size < maxsize) { 1448a272653SPeter Holm if (write(fd, buf, ps) != ps) { 1458a272653SPeter Holm warn("writer"); 1468a272653SPeter Holm goto err; 1478a272653SPeter Holm } 1488a272653SPeter Holm } 1498a272653SPeter Holm close(fd); 1508a272653SPeter Holm } 1518a272653SPeter Holm } 1528a272653SPeter Holmerr: 1538a272653SPeter Holm cleanup(); 1548a272653SPeter Holm 1558a272653SPeter Holm _exit(0); 1568a272653SPeter Holm} 1578a272653SPeter Holm 1588a272653SPeter Holmstatic void 1598a272653SPeter Holmreader(void) 1608a272653SPeter Holm{ 1618a272653SPeter Holm int fd, i, j, n; 1628a272653SPeter Holm void *p; 1638a272653SPeter Holm size_t len; 1648a272653SPeter Holm char file[80]; 1658a272653SPeter Holm struct stat statbuf; 1668a272653SPeter Holm 1678a272653SPeter Holm setproctitle("reader"); 1688a272653SPeter Holm signal(SIGSEGV, hand); 1698a272653SPeter Holm signal(SIGBUS, hand); 1708a272653SPeter Holm fd = 0; 1718a272653SPeter Holm for (;;) { 1728a272653SPeter Holm (void)setjmp(jbuf); 1738a272653SPeter Holm for (i = 0; i < FILES; i++) { 1748a272653SPeter Holm snprintf(file, sizeof(file), "f%06d", i); 1758a272653SPeter Holm if (fd > 0) 1768a272653SPeter Holm close(fd); 1778a272653SPeter Holm if ((fd = open(file, O_RDWR)) == -1) { 1788a272653SPeter Holm if (errno != ENOENT) 1798a272653SPeter Holm warn("reader(%s)", file); 1808a272653SPeter Holm _exit(0); 1818a272653SPeter Holm } 1828a272653SPeter Holm if (fstat(fd, &statbuf) < 0) 1838a272653SPeter Holm err(1, "fstat error"); 1848a272653SPeter Holm if (statbuf.st_size >= maxsize) { 1858a272653SPeter Holm if (ftruncate(fd, ps) == -1) 1868a272653SPeter Holm err(1, "ftruncate"); 1878a272653SPeter Holm continue; 1888a272653SPeter Holm } 1898a272653SPeter Holm len = statbuf.st_size; 1908a272653SPeter Holm if ((p = mmap(p, len, PROT_READ, MAP_SHARED, fd, 0)) 1918a272653SPeter Holm == MAP_FAILED) 1928a272653SPeter Holm err(1, "mmap()"); 1938a272653SPeter Holm close(fd); 1948a272653SPeter Holm n = statbuf.st_size / ps; 1958a272653SPeter Holm for (j = 0; j < n; j++) { 1968a272653SPeter Holm val = *(char *)p; 1978a272653SPeter Holm p = p + ps; 1988a272653SPeter Holm } 1998a272653SPeter Holm#if 0 2008a272653SPeter Holm if (munmap(p, len) == -1) 2018a272653SPeter Holm perror("munmap"); 2028a272653SPeter Holm#endif 2038a272653SPeter Holm } 2048a272653SPeter Holm } 2058a272653SPeter Holm _exit(0); 2068a272653SPeter Holm} 2078a272653SPeter Holmint 2088a272653SPeter Holmmain(void) 2098a272653SPeter Holm{ 2108a272653SPeter Holm pid_t rpid[RPARALLEL], wpid[WPARALLEL]; 2118a272653SPeter Holm int e, i, s; 2128a272653SPeter Holm 2138a272653SPeter Holm maxsize = 2LL * 1024 * 1024 * 1024 / FILES; 2148a272653SPeter Holm buf = malloc(BUFSIZE); 2158a272653SPeter Holm ps = getpagesize(); 2168a272653SPeter Holm 2178a272653SPeter Holm init(); 2188a272653SPeter Holm e = 0; 2198a272653SPeter Holm for (i = 0; i < WPARALLEL; i++) { 2208a272653SPeter Holm if ((wpid[i] = fork()) == 0) 2218a272653SPeter Holm writer(); 2228a272653SPeter Holm } 2238a272653SPeter Holm for (i = 0; i < RPARALLEL; i++) { 2248a272653SPeter Holm if ((rpid[i] = fork()) == 0) 2258a272653SPeter Holm reader(); 2268a272653SPeter Holm } 2278a272653SPeter Holm 2288a272653SPeter Holm for (i = 0; i < WPARALLEL; i++) 2298a272653SPeter Holm waitpid(wpid[i], &s, 0); 2308a272653SPeter Holm e += s == 0 ? 0 : 1; 2318a272653SPeter Holm for (i = 0; i < RPARALLEL; i++) 2328a272653SPeter Holm waitpid(rpid[i], &s, 0); 2338a272653SPeter Holm e += s == 0 ? 0 : 1; 2348a272653SPeter Holm 2358a272653SPeter Holm free(buf); 2368a272653SPeter Holm 2378a272653SPeter Holm return (e); 2388a272653SPeter Holm} 239