Home | History | Annotate | Line # | Download | only in vfs
t_renamerace.c revision 1.29 
      1 /*	$NetBSD: t_renamerace.c,v 1.29 2013/07/10 18:55:00 reinoud 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 /* Bump the size of the test file system image to a larger value.
     25  *
     26  * These tests cause a lot of churn in the file system by creating and
     27  * deleting files/directories in quick succession.  A faster CPU will cause
     28  * more churn because the tests are capped by a run time period in seconds,
     29  * not number of operations.
     30  *
     31  * This is all fine except for LFS, because the lfs_cleanerd cannot keep up
     32  * with the churn and thus causes the test to fail on fast machines.  Hence
     33  * the reason for this hack. */
     34 #define FSTEST_IMGSIZE (50000 * 512)
     35 
     36 #include "../common/h_fsmacros.h"
     37 #include "../../h_macros.h"
     38 
     39 static volatile int quittingtime;
     40 pid_t wrkpid;
     41 
     42 static void *
     43 w1(void *arg)
     44 {
     45 	int fd;
     46 
     47 	rump_pub_lwproc_newlwp(wrkpid);
     48 
     49 	while (!quittingtime) {
     50 		fd = rump_sys_open("rename.test1",
     51 		    O_WRONLY|O_CREAT|O_TRUNC, 0666);
     52 		if (fd == -1 && errno != EEXIST)
     53 			atf_tc_fail_errno("create");
     54 		rump_sys_unlink("rename.test1");
     55 		rump_sys_close(fd);
     56 	}
     57 
     58 	return NULL;
     59 }
     60 
     61 static void *
     62 w1_dirs(void *arg)
     63 {
     64 
     65 	rump_pub_lwproc_newlwp(wrkpid);
     66 
     67 	while (!quittingtime) {
     68 		if (rump_sys_mkdir("rename.test1", 0777) == -1)
     69 			atf_tc_fail_errno("mkdir");
     70 		rump_sys_rmdir("rename.test1");
     71 	}
     72 
     73 	return NULL;
     74 }
     75 
     76 static void *
     77 w2(void *arg)
     78 {
     79 
     80 	rump_pub_lwproc_newlwp(wrkpid);
     81 
     82 	while (!quittingtime) {
     83 		rump_sys_rename("rename.test1", "rename.test2");
     84 	}
     85 
     86 	return NULL;
     87 }
     88 
     89 #define NWRK 8
     90 static void
     91 renamerace(const atf_tc_t *tc, const char *mp)
     92 {
     93 	pthread_t pt1[NWRK], pt2[NWRK];
     94 	int i;
     95 
     96 	if (FSTYPE_RUMPFS(tc))
     97 		atf_tc_skip("rename not supported by file system");
     98 
     99 	if (FSTYPE_UDF(tc))
    100 		atf_tc_expect_fail("Test expected to fail");
    101 
    102 	RZ(rump_pub_lwproc_rfork(RUMP_RFCFDG));
    103 	RL(wrkpid = rump_sys_getpid());
    104 
    105 	RL(rump_sys_chdir(mp));
    106 	for (i = 0; i < NWRK; i++)
    107 		pthread_create(&pt1[i], NULL, w1, NULL);
    108 
    109 	for (i = 0; i < NWRK; i++)
    110 		pthread_create(&pt2[i], NULL, w2, NULL);
    111 
    112 	sleep(5);
    113 	quittingtime = 1;
    114 
    115 	for (i = 0; i < NWRK; i++)
    116 		pthread_join(pt1[i], NULL);
    117 	for (i = 0; i < NWRK; i++)
    118 		pthread_join(pt2[i], NULL);
    119 	RL(rump_sys_chdir("/"));
    120 
    121 	if (FSTYPE_MSDOS(tc)) {
    122 		atf_tc_expect_fail("PR kern/44661");
    123 		/*
    124 		 * XXX: race does not trigger every time at least
    125 		 * on amd64/qemu.
    126 		 */
    127 		if (msdosfs_fstest_unmount(tc, mp, 0) != 0) {
    128 			rump_pub_vfs_mount_print(mp, 1);
    129 			atf_tc_fail_errno("unmount failed");
    130 		}
    131 		atf_tc_fail("race did not trigger this time");
    132 	}
    133 }
    134 
    135 static void
    136 renamerace_dirs(const atf_tc_t *tc, const char *mp)
    137 {
    138 	pthread_t pt1, pt2;
    139 
    140 	if (FSTYPE_SYSVBFS(tc))
    141 		atf_tc_skip("directories not supported by file system");
    142 
    143 	if (FSTYPE_RUMPFS(tc))
    144 		atf_tc_skip("rename not supported by file system");
    145 
    146 	if (FSTYPE_UDF(tc))
    147 		atf_tc_expect_fail("Test expected to fail");
    148 
    149 	/* XXX: msdosfs also sometimes hangs */
    150 	if (FSTYPE_MSDOS(tc))
    151 		atf_tc_expect_signal(-1, "PR kern/43626");
    152 
    153 	RZ(rump_pub_lwproc_rfork(RUMP_RFCFDG));
    154 	RL(wrkpid = rump_sys_getpid());
    155 
    156 	RL(rump_sys_chdir(mp));
    157 	pthread_create(&pt1, NULL, w1_dirs, NULL);
    158 	pthread_create(&pt2, NULL, w2, NULL);
    159 
    160 	sleep(5);
    161 	quittingtime = 1;
    162 
    163 	pthread_join(pt1, NULL);
    164 	pthread_join(pt2, NULL);
    165 	RL(rump_sys_chdir("/"));
    166 
    167 	/*
    168 	 * Doesn't always trigger when run on a slow backend
    169 	 * (i.e. not on tmpfs/mfs).  So do the usual kludge.
    170 	 */
    171 	if (FSTYPE_MSDOS(tc))
    172 		abort();
    173 }
    174 
    175 ATF_TC_FSAPPLY(renamerace, "rename(2) race with file unlinked mid-operation");
    176 ATF_TC_FSAPPLY(renamerace_dirs, "rename(2) race with directories");
    177 
    178 ATF_TP_ADD_TCS(tp)
    179 {
    180 
    181 	ATF_TP_FSAPPLY(renamerace); /* PR kern/41128 */
    182 	ATF_TP_FSAPPLY(renamerace_dirs);
    183 
    184 	return atf_no_error();
    185 }
    186