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