1#!/bin/sh 2 3# 4# Copyright (c) 2016 EMC Corp. 5# All rights reserved. 6# 7# Redistribution and use in source and binary forms, with or without 8# modification, are permitted provided that the following conditions 9# are met: 10# 1. Redistributions of source code must retain the above copyright 11# notice, this list of conditions and the following disclaimer. 12# 2. Redistributions in binary form must reproduce the above copyright 13# notice, this list of conditions and the following disclaimer in the 14# documentation and/or other materials provided with the distribution. 15# 16# THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 17# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 18# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 19# ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 20# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 21# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 22# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 23# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 24# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 25# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 26# SUCH DAMAGE. 27# 28 29# Test effort to reproduce reported: "observed a hang in a multi-threaded 30# process that had hit an assertion failure and was attempting to dump core". 31# Problem never seen. 32 33# Most interesting load are: 34# - coredumping of the multithreaded program with the current dir on NFS, 35# which also accesses NFS files; 36# - advisory locking tests on NFS files, while e.g. sending SIGSTOP/SIGCONT 37# to the test programs. 38 39# See also pthread9.sh 40 41# https://people.freebsd.org/~pho/stress/log/kostik897.txt 42# Fixed in r302013. 43 44# "panic: mutex sleepq chain not owned at subr_sleepqueue.c:1009" seen: 45# https://people.freebsd.org/~pho/stress/log/kostik914.txt 46# Fixed in r302328. 47 48[ `id -u ` -ne 0 ] && echo "Must be root!" && exit 1 49 50. ../default.cfg 51 52[ -z "$nfs_export" ] && exit 0 53ping -c 2 `echo $nfs_export | sed 's/:.*//'` > /dev/null 2>&1 || 54 exit 0 55 56USE_TIMEOUT=1 57here=`pwd` 58cd /tmp 59sed '1,/^EOF/d' < $here/$0 > nfs15.c 60mycc -o nfs15 -Wall -Wextra -O2 -g nfs15.c -lpthread || exit 1 61rm -f nfs15.c 62cd $here 63 64mount | grep "on $mntpoint " | grep nfs > /dev/null && umount $mntpoint 65 66mount -t nfs -o tcp -o retrycnt=3 -o intr,soft -o rw -o nolockd \ 67 $nfs_export $mntpoint || exit 1 68sleep 2 69wd=$mntpoint/nfs15.dir 70rm -rf $wd 71mkdir $wd 72 73(cd $wd; /tmp/nfs15) 74rm -rf $wd 75 76while mount | grep "on $mntpoint " | grep -q nfs; do 77 umount $mntpoint || sleep 1 78done 79 80rm -f /tmp/nfs15 81exit 0 82EOF 83#include <sys/stat.h> 84#include <sys/param.h> 85#include <sys/mman.h> 86#include <sys/wait.h> 87 88#include <machine/atomic.h> 89 90#include <err.h> 91#include <errno.h> 92#include <fcntl.h> 93#include <pthread.h> 94#include <signal.h> 95#include <stdio.h> 96#include <stdlib.h> 97#include <string.h> 98#include <unistd.h> 99 100#define PARALLEL 4 101#define RUNTIME 300 102#define SYNC 0 103 104volatile u_int *share; 105 106static void * 107t1(void *data __unused) 108{ 109 atomic_add_int(&share[SYNC], 1); 110 usleep(arc4random() % 8000); 111 raise(SIGABRT); 112 113 return (NULL); 114} 115 116static void * 117t2(void *data __unused) 118{ 119 int fd, i, r; 120 char file[80]; 121 122 for (i = 0; i < 100; i++) { 123 atomic_add_int(&share[SYNC], 1); 124 snprintf(file, sizeof(file), "file.%06d", i); 125 if ((fd = open(file, O_WRONLY | O_CREAT | O_APPEND, 126 DEFFILEMODE)) == -1) 127 err(1, "open(%s)", file); 128 do { 129 r = lockf(fd, F_LOCK, 0); 130 } while (r == -1 && errno == EDEADLK); 131 if (r == -1) 132 err(1, "lockf(%s, F_LOCK)", file); 133 write(fd, "x", 1); 134 if (lseek(fd, 0, SEEK_SET) == -1) 135 err(1, "lseek"); 136 if (lockf(fd, F_ULOCK, 0) == -1) 137 err(1, "lockf(%s, F_ULOCK)", file); 138 close(fd); 139 } 140 141 return (NULL); 142} 143 144int 145test(void) 146{ 147 pthread_t tid[3]; 148 int i, rc; 149 150 for (i = 0; i < 10; i++) { 151 if ((rc = pthread_create(&tid[0], NULL, t2, NULL)) == -1) 152 errc(1, rc, "pthread_create"); 153 if ((rc = pthread_create(&tid[1], NULL, t2, NULL)) == -1) 154 errc(1, rc, "pthread_create"); 155 if ((rc = pthread_create(&tid[2], NULL, t1, NULL)) == -1) 156 errc(1, rc, "pthread_create"); 157 158 if ((rc = pthread_join(tid[0], NULL)) == -1) 159 errc(1, rc, "pthread_join"); 160 if ((rc = pthread_join(tid[1], NULL)) == -1) 161 errc(1, rc, "pthread_join"); 162 if ((rc = pthread_join(tid[2], NULL)) == -1) 163 errc(1, rc, "pthread_join"); 164 } 165 166 _exit(0); 167} 168 169int 170main(void) 171{ 172 pid_t pids[PARALLEL]; 173 size_t len; 174 time_t start; 175 int i, status; 176 177 len = PAGE_SIZE; 178 if ((share = mmap(NULL, len, PROT_READ | PROT_WRITE, 179 MAP_ANON | MAP_SHARED, -1, 0)) == MAP_FAILED) 180 err(1, "mmap"); 181 182 start = time(NULL); 183 while (time(NULL) - start < RUNTIME) { 184 for (i = 0; i < PARALLEL; i++) { 185 if ((pids[i] = fork()) == 0) 186 test(); 187 } 188 189 for(;;) { 190 if (share[SYNC] > 0) 191 atomic_add_int(&share[SYNC], -1); 192 for (i = 0; i < PARALLEL; i++) 193 kill(pids[i], SIGSTOP); 194 usleep(100 + arc4random() % 1000); 195 for (i = 0; i < PARALLEL; i++) 196 kill(pids[i], SIGCONT); 197 usleep(100 + arc4random() % 400); 198 if (share[SYNC] == 0) { /* If all procs are done */ 199 usleep(500); 200 if (share[SYNC] == 0) 201 break; 202 } 203 } 204 205 for (i = 0; i < PARALLEL; i++) { 206 if (waitpid(pids[i], &status, 0) != pids[i]) 207 err(1, "waitpid"); 208 } 209 } 210 211 return (0); 212} 213