t_renamerace.c revision 1.10 
1/*	$NetBSD: t_renamerace.c,v 1.10 2011/01/02 12:58:17 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 <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	struct utsname un;
80	pthread_t pt[2];
81
82	/*
83	 * Check that we are running on an SMP-capable arch.  It should
84	 * be a rump capability, but after the CPU_INFO_FOREACH is
85	 * fixed, it will be every arch (for rump), so don't bother.
86	 */
87	if (uname(&un) == -1)
88		atf_tc_fail_errno("uname");
89	if (strcmp(un.machine, "i386") != 0 && strcmp(un.machine, "amd64") != 0)
90		atf_tc_skip("i386 or amd64 required (have %s)", un.machine);
91
92	/*
93	 * Force SMP regardless of how many host CPUs there are.
94	 * Deadlock is highly unlikely to trigger otherwise.
95	 */
96	setenv("RUMP_NCPU", "2", 1);
97
98	rump_init();
99	memset(&args, 0, sizeof(args));
100	args.ta_version = TMPFS_ARGS_VERSION;
101	args.ta_root_mode = 0777;
102	if (rump_sys_mount(MOUNT_TMPFS, "/", 0, &args, sizeof(args)) == -1)
103		atf_tc_fail_errno("could not mount tmpfs");
104
105	if (rump_sys_mkdir("/dir", 0777) == -1)
106		atf_tc_fail_errno("cannot create directory");
107
108	RZ(rump_pub_lwproc_rfork(RUMP_RFCFDG));
109	RL(wrkpid = rump_sys_getpid());
110	pthread_create(&pt[0], NULL, r2w1, NULL);
111	pthread_create(&pt[1], NULL, r2w2, NULL);
112
113	/* usually triggers in <<1s for me */
114	sleep(4);
115	quittingtime = 1;
116
117	atf_tc_expect_timeout("PR kern/36681");
118
119	pthread_join(pt[0], NULL);
120	pthread_join(pt[1], NULL);
121}
122
123ATF_TP_ADD_TCS(tp)
124{
125	ATF_TP_ADD_TC(tp, renamerace2);
126
127	return atf_no_error();
128}
129