168 lines
3.2 KiB
C
168 lines
3.2 KiB
C
/* $NetBSD: t_renamerace.c,v 1.26 2012/05/09 00:22:26 riastradh 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>
|
|
|
|
#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;
|
|
|
|
if (FSTYPE_RUMPFS(tc))
|
|
atf_tc_skip("rename not supported by file system");
|
|
|
|
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_MSDOS(tc)) {
|
|
atf_tc_expect_fail("PR kern/44661");
|
|
/*
|
|
* 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();
|
|
}
|