1 /*        $NetBSD: t_renamerace.c,v 1.15 2020/06/26 07:50:12 jruoho Exp $       */
2 
3 /*
4  * Modified for rump and atf from a program supplied
5  * by Nicolas Joly in PR 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 
28 ATF_TC(renamerace2);
ATF_TC_HEAD(renamerace2,tc)29 ATF_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 
35 static volatile int quittingtime = 0;
36 static pid_t wrkpid;
37 
38 static void *
r2w1(void * arg)39 r2w1(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 
60 static void *
r2w2(void * arg)61 r2w2(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 
ATF_TC_BODY(renamerace2,tc)76 ATF_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 
ATF_TP_ADD_TCS(tp)110 ATF_TP_ADD_TCS(tp)
111 {
112           ATF_TP_ADD_TC(tp, renamerace2);
113 
114           return atf_no_error();
115 }
116