/*	$NetBSD: t_renamerace.c,v 1.9 2009/10/14 18:22:50 pooka 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 <atf-c.h>
#include <errno.h>
#include <fcntl.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

#include <rump/rump.h>
#include <rump/rump_syscalls.h>

#include <ufs/ufs/ufsmount.h>

#include "../../h_macros.h"

ATF_TC_WITH_CLEANUP(renamerace);
ATF_TC_HEAD(renamerace, tc)
{
	atf_tc_set_md_var(tc, "descr", "rename(2) race against files "
	    "unlinked mid-operation, kern/40948");
	/* XXX: test hangs in qemu for unknown reasons */
	atf_tc_set_md_var(tc, "timeout", "20");
}

volatile int quit;

static void *
w1(void *arg)
{
	int fd;

	while (!quit) {
		fd = rump_sys_open("/mp/rename.test1",
		    O_WRONLY|O_CREAT|O_TRUNC, 0666);
		rump_sys_unlink("/mp/rename.test1");
		rump_sys_close(fd);
	}
	return NULL;
}

static void *
w2(void *arg)
{

	while (!quit)
		rump_sys_rename("/mp/rename.test1", "/mp/rename.test2");

	return NULL;
}

/* XXX: how to do cleanup if we use mkdtemp? */
#define IMAGENAME "/tmp/ffsatf.img"
static char image[MAXPATHLEN];

#define FAKEBLK "/dev/sp00ka"

ATF_TC_BODY(renamerace, tc)
{
	struct ufs_args args;
	char cmd[256];
	pthread_t pt1, pt2;

#if 0
	strcpy(image, TMPPATH);
	if (mkdtemp(image) == NULL)
		atf_tc_fail_errno("can't create tmpdir %s", TMPPATH);
	strcat(image, "/ffsatf.img");
#else
	strcpy(image, IMAGENAME);
#endif

	strcpy(cmd, "newfs -F -s 10000 ");
	strcat(cmd, image);

	if (system(cmd) == -1)
		atf_tc_fail_errno("newfs failed");

	memset(&args, 0, sizeof(args));
	args.fspec = __UNCONST(FAKEBLK);

	rump_init();
	if (rump_sys_mkdir("/mp", 0777) == -1)
		atf_tc_fail_errno("cannot create mountpoint");
	rump_pub_etfs_register(FAKEBLK, image, RUMP_ETFS_BLK);
	if (rump_sys_mount(MOUNT_FFS, "/mp", MNT_LOG, &args, sizeof(args))==-1)
		atf_tc_fail_errno("rump_sys_mount failed");

	pthread_create(&pt1, NULL, w1, NULL);
	pthread_create(&pt2, NULL, w2, NULL);

	sleep(10);

	quit = 1;
	pthread_join(pt1, NULL);
	pthread_join(pt2, NULL);

	if (rump_sys_unmount("/mp", 0) == -1)
		atf_tc_fail_errno("unmount failed");
}

ATF_TC_CLEANUP(renamerace, tc)
{
#if 0
	char *img;

	img = strrchr(image, '/');
	if (!img)
		return;

	printf("removing %s\n", img+1);
	unlink(img+1);
	*img = '\0';
	rmdir(img);
#else
	unlink(IMAGENAME);
#endif
}

ATF_TP_ADD_TCS(tp)
{
	ATF_TP_ADD_TC(tp, renamerace);
	return 0; /* ??? */
}