tests/fs/tmpfs/t_renamerace.c

   1 /*      $NetBSD: t_renamerace.c,v 1.13 2011/08/18 21:44:55 riastradh 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
  28 ATF_TC(renamerace2);
  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 *
  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 *
  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
  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
 110 ATF_TP_ADD_TCS(tp)
 111 {
 112         ATF_TP_ADD_TC(tp, renamerace2);
 113
 114         return atf_no_error();
 115 }