test5.c

Go to the documentation of this file.

/*
 *      @(#)test5.c     1.8     2003/12/01 Connectathon Testsuite
 *      1.5 Lachman ONC Test Suite source
 *
 * Test read and write
 *
 * Uses the following important system calls against the server:
 *
 *      chdir()
 *      mkdir()         (for initial directory creation if not -m)
 *      creat()
 *      open()
 *      read()
 *      write()
 *      stat()
 *      fstat()
 *      unlink()
 */

#if defined (DOS) || defined (WIN32)
/* If Dos, Windows or Win32 */
#define DOSorWIN32
/* Synchronous Write is Not supported in the Windows version yet.*/
#undef O_SYNC
#endif

#ifndef DOSorWIN32
#include <sys/param.h>
#include <unistd.h>
#endif

#include <fcntl.h>
#include <sys/stat.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#ifdef DOSorWIN32
#include <time.h>
#else
#include <sys/time.h>
#endif
#ifdef MMAP
#include <sys/mman.h>
#endif

#include "tests.h"
#include "Connectathon_config_parsing.h"

#if defined(O_SYNC) || defined(DOSorWIN32)
#define USE_OPEN
#endif

#ifndef MIN
#define MIN(a, b)       ((a) < (b) ? (a) : (b))
#endif

#define BUFSZ   8192

static int Tflag = 0;           /* print timing */
static int Fflag = 0;           /* test function only;  set count to 1, negate -t */
static int Nflag = 0;           /* Suppress directory operations */
#ifdef O_SYNC
static int Sflag = 0;           /* use synchronous writes */
#endif

static void usage()
{
  fprintf(stdout, "usage: %s [-htfns] <config_file>\n", Myname);
  fprintf(stdout, "  Flags:  h    Help - print this usage info\n");
  fprintf(stdout, "          t    Print execution time statistics\n");
  fprintf(stdout, "          f    Test function only (negate -t)\n");
  fprintf(stdout, "          n    Suppress test directory create operations\n");
#ifdef O_SYNC
  fprintf(stdout, "          s    Use synchronous writes\n");
#endif
}

int main(int argc, char *argv[])
{
  int count;                    /* times to do each file */
  int ct;
  off_t size;
  off_t si;
  int i;
  int fd;
  off_t bytes = 0;
  int roflags;                  /* open read-only flags */
  int woflags;                  /* write-only create flags */
  char *bigfile;
  struct timeval time;
  struct stat statb;
  char *opts;
  char buf[BUFSZ];
  double etime1, etime2;
#ifdef MMAP
  caddr_t maddr;
#endif
  struct testparam *param;
  struct btest *b;
  char *config_file;
  char *test_dir;
  char *log_file;
  FILE *log;
  long g, d;

  umask(0);
  setbuf(stdout, NULL);
  Myname = *argv++;
  argc--;
  while(argc && **argv == '-')
    {
      for(opts = &argv[0][1]; *opts; opts++)
        {
          switch (*opts)
            {
            case 'h':          /* help */
              usage();
              exit(1);
              break;

            case 't':          /* time */
              Tflag++;
              break;

            case 'f':          /* funtionality */
              Fflag++;
              break;

            case 'n':          /* No Test Directory create */
              Nflag++;
              break;

#ifdef O_SYNC
            case 's':          /* synchronous writes */
              Sflag++;
              break;
#endif

            default:
              error("unknown option '%c'", *opts);
              usage();
              exit(1);
            }
        }
      argc--;
      argv++;
    }

  if(argc)
    {
      config_file = *argv;
      argc--;
      argv++;
    }
  else
    {
      fprintf(stderr, "Missing config_file");
      exit(1);
    }

  if(argc != 0)
    {
      fprintf(stderr, "too many parameters");
      usage();
      exit(1);
    }

  param = readin_config(config_file);
  if(param == NULL)
    {
      fprintf(stderr, "Nothing built\n");
      exit(1);
    }

  b = get_btest_args(param, FIVE);
  if(b == NULL)
    {
      fprintf(stderr, "Missing basic test number 5 in the config file '%s'\n",
              config_file);
      free_testparam(param);
      exit(1);
    }

  if(b->count == -1)
    {
      fprintf(stderr,
              "Missing 'count' parameter in the config file '%s' for the basic test number 5\n",
              config_file);
      free_testparam(param);
      exit(1);
    }
  if(b->size == -1)
    {
      fprintf(stderr,
              "Missing 'size' parameter in the config file '%s' for the basic test number 5\n",
              config_file);
      free_testparam(param);
      exit(1);
    }
  count = b->count;
  size = b->size;
  bigfile = b->bigfile;
  test_dir = get_test_directory(param);
  log_file = get_log_file(param);

  free_testparam(param);

  if(count == 0)
    {
      fprintf(stderr, "count == 0 !\n");
      exit(1);
    }

  if(!Fflag)
    {
      Tflag = 0;
      count = 1;
    }

  woflags = O_WRONLY | O_CREAT | O_TRUNC;
  roflags = O_RDONLY;
#ifdef O_SYNC
  if(Sflag)
    {
      woflags |= O_SYNC;
    }
#endif
#ifdef DOSorWIN32
  woflags |= O_BINARY | O_RDWR; /* create and open file */
  roflags |= O_BINARY;
#endif

  fprintf(stdout, "%s: read and write\n", Myname);

  if(!Nflag)
    testdir(test_dir);
  else
    mtestdir(test_dir);

  for(i = 0; i < BUFSZ / sizeof(int); i++)
    {
      ((int *)buf)[i] = i;
    }

  starttime();
  for(ct = 0; ct < count; ct++)
    {
#ifdef USE_OPEN
      if((fd = open(bigfile, woflags, CHMOD_RW)) < 0)
        {
#else
      if((fd = creat(bigfile, CHMOD_RW)) < 0)
        {
#endif
          error("can't create '%s'", bigfile);
          exit(1);
        }
      if(stat(bigfile, &statb) < 0)
        {
          error("can't stat '%s'", bigfile);
          exit(1);
        }
      if(statb.st_size != 0)
        {
          error("'%s' has size %ld, should be 0", bigfile, (long)statb.st_size);
          exit(1);
        }
      for(si = size; si > 0; si -= bytes)
        {
          bytes = MIN(BUFSZ, si);
          if(write(fd, buf, bytes) != bytes)
            {
              error("'%s' write failed", bigfile);
              exit(1);
            }
        }
      if(close(fd) < 0)
        {
          error("can't close %s", bigfile);
          exit(1);
        }
      if(stat(bigfile, &statb) < 0)
        {
          error("can't stat '%s'", bigfile);
          exit(1);
        }
      if(statb.st_size != size)
        {
          error("'%s' has size %ld, should be %ld",
                bigfile, (long)(statb.st_size), (long)size);
          exit(1);
        }
    }
  endtime(&time);

  if((fd = open(bigfile, roflags)) < 0)
    {
      error("can't open '%s'", bigfile);
      exit(1);
    }
#ifdef MMAP
  maddr = mmap((caddr_t) 0, (size_t) size, PROT_READ, MAP_PRIVATE, fd, (off_t) 0);
  if(maddr == MAP_FAILED)
    {
      error("can't mmap '%s'", bigfile);
      exit(1);
    }
  if(msync(maddr, (size_t) size, MS_INVALIDATE) < 0)
    {
      error("can't invalidate pages for '%s'", bigfile);
      exit(1);
    }
  if(munmap(maddr, (size_t) size) < 0)
    {
      error("can't munmap '%s'", bigfile);
      exit(1);
    }
#endif
  for(si = size; si > 0; si -= bytes)
    {
      bytes = MIN(BUFSZ, si);
      if(read(fd, buf, bytes) != bytes)
        {
          error("'%s' read failed", bigfile);
          exit(1);
        }
      for(i = 0; i < bytes / sizeof(int); i++)
        {
          if(((int *)buf)[i] != i)
            {
              error("bad data in '%s'", bigfile);
              exit(1);
            }
        }
    }
  close(fd);

  fprintf(stdout, "\twrote %ld byte file %d times", (long)size, count);

  if(Tflag)
    {
      etime1 = (double)time.tv_sec + (double)time.tv_usec / 1000000.0;
      if(etime1 != 0.0)
        {
          fprintf(stdout, " in %ld.%02ld seconds (%d bytes/sec)",
                  (long)time.tv_sec, (long)time.tv_usec / 10000,
                  (int)((double)size * ((double)count / etime1)));
        }
      else
        {
          fprintf(stdout, " in %ld.%02ld seconds (> %ld bytes/sec)",
                  (long)time.tv_sec, (long)time.tv_usec / 10000, (long)size * count);
        }
    }
  fprintf(stdout, "\n");

  g = time.tv_sec;
  d = (long)time.tv_usec / 10000;

  starttime();
  for(ct = 0; ct < count; ct++)
    {
      if((fd = open(bigfile, roflags)) < 0)
        {
          error("can't open '%s'", bigfile);
          exit(1);
        }
#ifdef MMAP
      maddr = mmap((caddr_t) 0, (size_t) size, PROT_READ, MAP_PRIVATE, fd, (off_t) 0);
      if(maddr == MAP_FAILED)
        {
          error("can't mmap '%s'", bigfile);
          exit(1);
        }
      if(msync(maddr, (size_t) size, MS_INVALIDATE) < 0)
        {
          error("can't invalidate pages for '%s'", bigfile);
          exit(1);
        }
      if(munmap(maddr, (size_t) size) < 0)
        {
          error("can't munmap '%s'", bigfile);
          exit(1);
        }
#endif
      for(si = size; si > 0; si -= bytes)
        {
          bytes = MIN(BUFSZ, si);
          if(read(fd, buf, bytes) != bytes)
            {
              error("'%s' read failed", bigfile);
              exit(1);
            }
        }
      close(fd);
    }
  endtime(&time);

  fprintf(stdout, "\tread %ld byte file %d times", (long)size, count);
  if(Tflag)
    {
      etime2 = (double)time.tv_sec + (double)time.tv_usec / 1000000.0;
      if(etime2 != 0.0)
        {
          fprintf(stdout, " in %ld.%02ld seconds (%d bytes/sec)",
                  (long)time.tv_sec, (long)time.tv_usec / 10000,
                  (int)((double)size * ((double)count / etime2)));
        }
      else
        {
          fprintf(stdout, " in %ld.%02ld seconds (> %ld bytes/sec)",
                  (long)time.tv_sec, (long)time.tv_usec / 10000, (long)size * count);
        }
    }
  fprintf(stdout, "\n");

  if(unlink(bigfile) < 0)
    {
      error("can't unlink '%s'", bigfile);
      exit(1);
    }

  if((log = fopen(log_file, "a")) == NULL)
    {
      printf("Enable to open the file '%s'\n", log_file);
      complete();
    }
#ifdef _TOTO
  if(etime1 != 0.0)
    {
      if(etime2 != 0.0)
        {
          fprintf(log, "b5\t%d\t%d\t%d.%02ld\t%ld.%02ld\t%ld\t%ld\n", (long)size, count,
                  g, d, (long)time.tv_sec, (long)time.tv_usec / 10000,
                  (long)((double)size * ((double)count / etime1)),
                  (long)((double)size * ((double)count / etime2)));
        }
      else
        {
          fprintf(log, "b5\t%d\t%d\t%ld.%02ld\t%ld.%02ld\t%ld\t%ld\n", (long)size, count,
                  g, d, (long)time.tv_sec, (long)time.tv_usec / 10000,
                  (long)((double)size * ((double)count / etime1)), (long)size * count);
        }
    }
  else
    {
      if(etime2 != 0.0)
        {
          fprintf(log, "b5\t%d\t%d\t%ld.%02ld\t%ld.%02ld\t%ld\t%ld\n", (long)size, count,
                  g, d, (long)time.tv_sec, (long)time.tv_usec / 10000, (long)size * count,
                  (long)((double)size * ((double)count / etime2)));
        }
      else
        {
          fprintf(log, "b5\t%d\t%d\t%ld.%02ld\t%ld.%02ld\t%ld\t%ld\n", (long)size, count,
                  g, d, (long)time.tv_sec, (long)time.tv_usec / 10000, (long)size * count,
                  (long)size * count);
        }
    }
#endif
  fclose(log);

  complete();
}