Home | History | Annotate | Line # | Download | only in vfs
t_renamerace.c revision 1.2
      1 /*	$NetBSD: t_renamerace.c,v 1.2 2010/07/14 21:44:40 pooka 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 "../common/h_fsmacros.h"
     25 #include "../../h_macros.h"
     26 
     27 static volatile int quittingtime;
     28 
     29 static void *
     30 w1(void *arg)
     31 {
     32 	int fd;
     33 
     34 	rump_pub_lwp_alloc_and_switch(0, 10);
     35 	rump_sys_chdir(arg);
     36 
     37 	while (!quittingtime) {
     38 		fd = rump_sys_open("rename.test1",
     39 		    O_WRONLY|O_CREAT|O_TRUNC, 0666);
     40 		if (fd == -1)
     41 			atf_tc_fail_errno("create");
     42 		rump_sys_unlink("rename.test1");
     43 		rump_sys_close(fd);
     44 	}
     45 
     46 	rump_sys_chdir("/");
     47 
     48 	return NULL;
     49 }
     50 
     51 static void *
     52 w2(void *arg)
     53 {
     54 
     55 	rump_pub_lwp_alloc_and_switch(0, 11);
     56 	rump_sys_chdir(arg);
     57 
     58 	while (!quittingtime) {
     59 		rump_sys_rename("rename.test1", "rename.test2");
     60 	}
     61 
     62 	rump_sys_chdir("/");
     63 
     64 	return NULL;
     65 }
     66 
     67 static void
     68 renamerace(const atf_tc_t *tc, const char *mp)
     69 {
     70 	pthread_t pt1, pt2;
     71 
     72 	if (FSTYPE_LFS(tc))
     73 		atf_tc_expect_signal(-1, "PR kern/43582");
     74 
     75 	pthread_create(&pt1, NULL, w1, __UNCONST(mp));
     76 	pthread_create(&pt2, NULL, w2, __UNCONST(mp));
     77 
     78 	sleep(5);
     79 	quittingtime = 1;
     80 
     81 	pthread_join(pt1, NULL);
     82 	pthread_join(pt2, NULL);
     83 }
     84 
     85 ATF_TC_FSAPPLY(renamerace, "rename(2) race with file unlinked mid-operation");
     86 
     87 ATF_TP_ADD_TCS(tp)
     88 {
     89 
     90 	ATF_TP_FSAPPLY(renamerace); /* PR kern/41128 */
     91 
     92 	return atf_no_error();
     93 }
     94