test/stress/tuxload.c

   1 /*
   2  * TUXLOAD.C
   3  *
   4  * (c)Copyright 2012 Antonio Huete Jimenez <tuxillo@quantumachine.net>,
   5  *    this code is hereby placed in the public domain.
   6  *
   7  * As a safety the directory 'tmpfiles/' must exist.  This program will
   8  * create 500 x 8MB files in tmpfiles/*, memory map the files MAP_SHARED,
   9  * R+W, make random modifications, and msync() in a loop.
  10  *
  11  * The purpose is to stress the VM system.
  12  */
  13 #include <stdio.h>
  14 #include <unistd.h>
  15 #include <fcntl.h>
  16 #include <stdlib.h>
  17 #include <sys/mman.h>
  18 #include <sys/stat.h>
  19 #include <err.h>
  20
  21 #define NFILES 500
  22
  23 static void randomfill(int fd);
  24
  25 int
  26 main(int argc, char *argv[])
  27 {
  28
  29         int i;
  30         size_t size;
  31         long jump;
  32         int fd[NFILES];
  33         struct stat st[NFILES];
  34         char name[128];
  35         char *p[NFILES];
  36
  37         for (i = 0; i <  NFILES; i++) {
  38                 snprintf(name, 128, "tmpfiles/file%d", i);
  39                 if ((fd[i] = open(name, O_RDWR)) < 1) {
  40                         if ((fd[i] = open(name, O_RDWR | O_CREAT, 0644)) < 1)
  41                                 err(1, "open");
  42                         randomfill(fd[i]);
  43                 }
  44
  45                 if ((fstat(fd[i], &st[i])) == -1)
  46                         err(1, "fstat");
  47
  48                 size = st[i].st_size;
  49                 p[i] = mmap(0, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd[i], 0);
  50                 if (p[i] == MAP_FAILED)
  51                         err(1, "mmap");
  52
  53                 for (jump = 0; jump < size; jump += 65535) {
  54                         p[i][jump] = jump + i;
  55                 }
  56                 if ((msync(*p, MS_SYNC, 0)) == -1) {
  57                         printf("%s: %d %p\n", name, i, *p);
  58                         err(1, "msync");
  59
  60                 }
  61         }
  62
  63         return 0;
  64
  65 }
  66
  67 static void
  68 randomfill(int fd)
  69 {
  70         char buf[32768];
  71         int i;
  72
  73         srandomdev();
  74         for (i = 0; i < 32768; ++i)
  75                 buf[i] = random();
  76         for (i = 0; i < 8192 * 1024; i += 32)
  77                 write(fd, buf, 32768);
  78         fsync(fd);
  79         lseek(fd, 0L, 0);
  80 }