t_renamerace.c revision 272343
1/* $NetBSD: t_renamerace.c,v 1.13 2011/08/18 21:44:55 riastradh Exp $ */ 2 3/* 4 * Modified for rump and atf from a program supplied 5 * by Nicolas Joly in kern/40948 6 */ 7 8#include <sys/types.h> 9#include <sys/mount.h> 10#include <sys/utsname.h> 11 12#include <atf-c.h> 13#include <errno.h> 14#include <fcntl.h> 15#include <pthread.h> 16#include <stdio.h> 17#include <stdlib.h> 18#include <string.h> 19#include <unistd.h> 20 21#include <rump/rump.h> 22#include <rump/rump_syscalls.h> 23 24#include <fs/tmpfs/tmpfs_args.h> 25 26#include "../../h_macros.h" 27 28ATF_TC(renamerace2); 29ATF_TC_HEAD(renamerace2, tc) 30{ 31 atf_tc_set_md_var(tc, "descr", "rename(2) lock order inversion"); 32 atf_tc_set_md_var(tc, "timeout", "6"); 33} 34 35static volatile int quittingtime = 0; 36static pid_t wrkpid; 37 38static void * 39r2w1(void *arg) 40{ 41 int fd; 42 43 rump_pub_lwproc_newlwp(wrkpid); 44 45 fd = rump_sys_open("/file", O_CREAT | O_RDWR, 0777); 46 if (fd == -1) 47 atf_tc_fail_errno("creat"); 48 rump_sys_close(fd); 49 50 while (!quittingtime) { 51 if (rump_sys_rename("/file", "/dir/file") == -1) 52 atf_tc_fail_errno("rename 1"); 53 if (rump_sys_rename("/dir/file", "/file") == -1) 54 atf_tc_fail_errno("rename 2"); 55 } 56 57 return NULL; 58} 59 60static void * 61r2w2(void *arg) 62{ 63 int fd; 64 65 rump_pub_lwproc_newlwp(wrkpid); 66 67 while (!quittingtime) { 68 fd = rump_sys_open("/dir/file1", O_RDWR); 69 if (fd != -1) 70 rump_sys_close(fd); 71 } 72 73 return NULL; 74} 75 76ATF_TC_BODY(renamerace2, tc) 77{ 78 struct tmpfs_args args; 79 pthread_t pt[2]; 80 81 /* 82 * Force SMP regardless of how many host CPUs there are. 83 * Deadlock is highly unlikely to trigger otherwise. 84 */ 85 setenv("RUMP_NCPU", "2", 1); 86 87 rump_init(); 88 memset(&args, 0, sizeof(args)); 89 args.ta_version = TMPFS_ARGS_VERSION; 90 args.ta_root_mode = 0777; 91 if (rump_sys_mount(MOUNT_TMPFS, "/", 0, &args, sizeof(args)) == -1) 92 atf_tc_fail_errno("could not mount tmpfs"); 93 94 if (rump_sys_mkdir("/dir", 0777) == -1) 95 atf_tc_fail_errno("cannot create directory"); 96 97 RZ(rump_pub_lwproc_rfork(RUMP_RFCFDG)); 98 RL(wrkpid = rump_sys_getpid()); 99 pthread_create(&pt[0], NULL, r2w1, NULL); 100 pthread_create(&pt[1], NULL, r2w2, NULL); 101 102 /* usually triggers in <<1s for me */ 103 sleep(4); 104 quittingtime = 1; 105 106 pthread_join(pt[0], NULL); 107 pthread_join(pt[1], NULL); 108} 109 110ATF_TP_ADD_TCS(tp) 111{ 112 ATF_TP_ADD_TC(tp, renamerace2); 113 114 return atf_no_error(); 115} 116