Index: user/pho/stress2/misc/holdcnt02.sh =================================================================== --- user/pho/stress2/misc/holdcnt02.sh (revision 355521) +++ user/pho/stress2/misc/holdcnt02.sh (revision 355522) @@ -1,239 +1,240 @@ #!/bin/sh # # Copyright (c) 2015 EMC Corp. # All rights reserved. # # Redistribution and use in source and binary forms, with or without # modification, are permitted provided that the following conditions # are met: # 1. Redistributions of source code must retain the above copyright # notice, this list of conditions and the following disclaimer. # 2. Redistributions in binary form must reproduce the above copyright # notice, this list of conditions and the following disclaimer in the # documentation and/or other materials provided with the distribution. # # THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND # ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE # IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE # ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE # FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL # DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS # OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) # HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY # OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF # SUCH DAMAGE. # # $FreeBSD$ # # Copy of holdcnt0.sh, but without the memory disk usage. # Test scenario suggestion by alc@ [ `id -u ` -ne 0 ] && echo "Must be root!" && exit 1 [ `swapinfo | wc -l` -eq 1 ] && exit 0 -[ `sysctl -n hw.physmem` -lt $((9 * 1024 * 1024 * 1024)) ] && exit 0 +[ `sysctl -n hw.physmem` -lt $((32 * 1024 * 1024 * 1024)) ] && exit 0 . ../default.cfg here=`pwd` cd /tmp sed '1,/^EOF/d' < $here/$0 > holdcnt02.c mycc -o holdcnt02 -Wall -Wextra -g holdcnt02.c || exit 1 rm -f holdcnt02.c cd $here trap "rm -f /tmp/holdcnt02 `dirname $diskimage`/f000???" EXIT INT (cd `dirname $diskimage`; /tmp/holdcnt02) & pid=$! sleep 5 while kill -0 $! 2> /dev/null; do (cd ../testcases/swap; ./swap -t 1m -i 1) > /dev/null 2>&1 done wait $pid exit EOF /* A test that causes the page daemon to generate cached pages within a bunch of files and has some consumer that is trying to allocate new pages to the same files. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #define BUFSIZE (1024 * 1024) #define FILES 200 #define RPARALLEL 8 #define WPARALLEL 2 static jmp_buf jbuf; static off_t maxsize; static int ps; static char *buf; static volatile char val; static void hand(int i __unused) { /* handler */ longjmp(jbuf, 1); } static void cleanup(void) { int i; char file[80]; for (i = 0; i < FILES; i++) { snprintf(file, sizeof(file), "f%06d", i); unlink(file); } } static void init(void) { int fd, i; char file[80]; for (i = 0; i < FILES; i++) { snprintf(file, sizeof(file), "f%06d", i); if ((fd = open(file, O_RDWR | O_CREAT | O_TRUNC, 0644)) == -1) err(1, "open(%s)", file); if (write(fd, buf, BUFSIZE) != BUFSIZE) err(1, "write"); close(fd); } } static void writer(void) { int fd, i; char file[80]; time_t start; struct stat statbuf; setproctitle("writer"); start = time(NULL); while (time(NULL) - start < 600) { for (i = 0; i < FILES; i++) { snprintf(file, sizeof(file), "f%06d", i); if ((fd = open(file, O_RDWR | O_APPEND)) == -1) { if (errno != ENOENT) err(1, "open(%s) append", file); goto err; } if (fstat(fd, &statbuf) < 0) err(1, "fstat error"); if (statbuf.st_size < maxsize) { if (write(fd, buf, ps) != ps) { warn("writer"); goto err; } } close(fd); } } err: cleanup(); _exit(0); } static void reader(void) { int fd, i, j, n; void *p; size_t len; char file[80]; struct stat statbuf; setproctitle("reader"); signal(SIGSEGV, hand); + signal(SIGBUS, hand); fd = 0; for (;;) { (void)setjmp(jbuf); for (i = 0; i < FILES; i++) { snprintf(file, sizeof(file), "f%06d", i); if (fd > 0) close(fd); if ((fd = open(file, O_RDWR)) == -1) { if (errno != ENOENT) warn("reader(%s)", file); _exit(0); } if (fstat(fd, &statbuf) < 0) err(1, "fstat error"); if (statbuf.st_size >= maxsize) { if (ftruncate(fd, ps) == -1) err(1, "ftruncate"); continue; } len = statbuf.st_size; if ((p = mmap(p, len, PROT_READ, MAP_SHARED, fd, 0)) == MAP_FAILED) err(1, "mmap()"); close(fd); n = statbuf.st_size / ps; for (j = 0; j < n; j++) { val = *(char *)p; p = p + ps; } #if 0 if (munmap(p, len) == -1) perror("munmap"); #endif } } _exit(0); } int main(void) { pid_t rpid[RPARALLEL], wpid[WPARALLEL]; int e, i, s; maxsize = 2LL * 1024 * 1024 * 1024 / FILES; buf = malloc(BUFSIZE); ps = getpagesize(); init(); e = 0; for (i = 0; i < WPARALLEL; i++) { if ((wpid[i] = fork()) == 0) writer(); } for (i = 0; i < RPARALLEL; i++) { if ((rpid[i] = fork()) == 0) reader(); } for (i = 0; i < WPARALLEL; i++) waitpid(wpid[i], &s, 0); e += s == 0 ? 0 : 1; for (i = 0; i < RPARALLEL; i++) waitpid(rpid[i], &s, 0); e += s == 0 ? 0 : 1; free(buf); return (e); }