/* * DiskSim Storage Subsystem Simulation Environment (Version 4.0) * Revision Authors: John Bucy, Greg Ganger * Contributors: John Griffin, Jiri Schindler, Steve Schlosser * * Copyright (c) of Carnegie Mellon University, 2001-2008. * * This software is being provided by the copyright holders under the * following license. By obtaining, using and/or copying this software, * you agree that you have read, understood, and will comply with the * following terms and conditions: * * Permission to reproduce, use, and prepare derivative works of this * software is granted provided the copyright and "No Warranty" statements * are included with all reproductions and derivative works and associated * documentation. This software may also be redistributed without charge * provided that the copyright and "No Warranty" statements are included * in all redistributions. * * NO WARRANTY. THIS SOFTWARE IS FURNISHED ON AN "AS IS" BASIS. * CARNEGIE MELLON UNIVERSITY MAKES NO WARRANTIES OF ANY KIND, EITHER * EXPRESSED OR IMPLIED AS TO THE MATTER INCLUDING, BUT NOT LIMITED * TO: WARRANTY OF FITNESS FOR PURPOSE OR MERCHANTABILITY, EXCLUSIVITY * OF RESULTS OR RESULTS OBTAINED FROM USE OF THIS SOFTWARE. CARNEGIE * MELLON UNIVERSITY DOES NOT MAKE ANY WARRANTY OF ANY KIND WITH RESPECT * TO FREEDOM FROM PATENT, TRADEMARK, OR COPYRIGHT INFRINGEMENT. * COPYRIGHT HOLDERS WILL BEAR NO LIABILITY FOR ANY USE OF THIS SOFTWARE * OR DOCUMENTATION. * *//* * DiskSim Storage Subsystem Simulation Environment (Version 2.0) * Revision Authors: Greg Ganger * Contributors: Ross Cohen, John Griffin, Steve Schlosser * * Copyright (c) of Carnegie Mellon University, 1999. * * Permission to reproduce, use, and prepare derivative works of * this software for internal use is granted provided the copyright * and "No Warranty" statements are included with all reproductions * and derivative works. This software may also be redistributed * without charge provided that the copyright and "No Warranty" * statements are included in all redistributions. * * NO WARRANTY. THIS SOFTWARE IS FURNISHED ON AN "AS IS" BASIS. * CARNEGIE MELLON UNIVERSITY MAKES NO WARRANTIES OF ANY KIND, EITHER * EXPRESSED OR IMPLIED AS TO THE MATTER INCLUDING, BUT NOT LIMITED * TO: WARRANTY OF FITNESS FOR PURPOSE OR MERCHANTABILITY, EXCLUSIVITY * OF RESULTS OR RESULTS OBTAINED FROM USE OF THIS SOFTWARE. CARNEGIE * MELLON UNIVERSITY DOES NOT MAKE ANY WARRANTY OF ANY KIND WITH RESPECT * TO FREEDOM FROM PATENT, TRADEMARK, OR COPYRIGHT INFRINGEMENT. *//* * DiskSim Storage Subsystem Simulation Environment * Authors: Greg Ganger, Bruce Worthington, Yale Patt * * Copyright (C) 1993, 1995, 1997 The Regents of the University of Michigan  * * This software is being provided by the copyright holders under the * following license. By obtaining, using and/or copying this software, * you agree that you have read, understood, and will comply with the * following terms and conditions: * * Permission to use, copy, modify, distribute, and sell this software * and its documentation for any purpose and without fee or royalty is * hereby granted, provided that the full text of this NOTICE appears on * ALL copies of the software and documentation or portions thereof, * including modifications, that you make. * * THIS SOFTWARE IS PROVIDED "AS IS," AND COPYRIGHT HOLDERS MAKE NO * REPRESENTATIONS OR WARRANTIES, EXPRESS OR IMPLIED. BY WAY OF EXAMPLE, * BUT NOT LIMITATION, COPYRIGHT HOLDERS MAKE NO REPRESENTATIONS OR * WARRANTIES OF MERCHANTABILITY OR FITNESS FOR ANY PARTICULAR PURPOSE OR * THAT THE USE OF THE SOFTWARE OR DOCUMENTATION WILL NOT INFRINGE ANY * THIRD PARTY PATENTS, COPYRIGHTS, TRADEMARKS OR OTHER RIGHTS. COPYRIGHT * HOLDERS WILL BEAR NO LIABILITY FOR ANY USE OF THIS SOFTWARE OR * DOCUMENTATION. * *  This software is provided AS IS, WITHOUT REPRESENTATION FROM THE * UNIVERSITY OF MICHIGAN AS TO ITS FITNESS FOR ANY PURPOSE, AND * WITHOUT WARRANTY BY THE UNIVERSITY OF MICHIGAN OF ANY KIND, EITHER * EXPRESSED OR IMPLIED, INCLUDING WITHOUT LIMITATION THE IMPLIED * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. THE REGENTS * OF THE UNIVERSITY OF MICHIGAN SHALL NOT BE LIABLE FOR ANY DAMAGES, * INCLUDING SPECIAL , INDIRECT, INCIDENTAL, OR CONSEQUENTIAL DAMAGES, * WITH RESPECT TO ANY CLAIM ARISING OUT OF OR IN CONNECTION WITH THE * USE OF OR IN CONNECTION WITH THE USE OF THE SOFTWARE, EVEN IF IT HAS * BEEN OR IS HEREAFTER ADVISED OF THE POSSIBILITY OF SUCH DAMAGES * * The names and trademarks of copyright holders or authors may NOT be * used in advertising or publicity pertaining to the software without * specific, written prior permission. Title to copyright in this software * and any associated documentation will at all times remain with copyright * holders. */#include "config.h"#include "disksim_global.h"#include "disksim_hptrace.h"#include "disksim_iotrace.h"static void iotrace_initialize_iotrace_info (){   disksim->iotrace_info = DISKSIM_malloc (sizeof(iotrace_info_t));   bzero ((char *)disksim->iotrace_info, sizeof(iotrace_info_t));   tracebasetime = 0.0;   firstio = TRUE;   lasttime = 0.0;   basebigtime = -1;   basesmalltime = -1;   basesimtime = 0.0;   validate_lastserv = 0.0;   validate_nextinter = 0.0;   accumulated_event_time = 0.0;   lastaccesstime = 0.0;}void iotrace_set_format (char *formatname){   if (disksim->iotrace_info == NULL) {      iotrace_initialize_iotrace_info();   }   disksim->traceendian = _LITTLE_ENDIAN;   disksim->traceheader = TRUE;   if (strcmp(formatname, "0") == 0) {      disksim->traceformat = DEFAULT;   } else if (strcmp(formatname, "ascii") == 0) {	/* default ascii trace format */      disksim->traceformat = ASCII;   } else if (strcmp(formatname, "raw") == 0) {	/* format of traces collected at Michigan */      disksim->traceformat = RAW;   } else if (strcmp(formatname, "validate") == 0) {	/* format of disk validation traces */      disksim->traceformat = VALIDATE;   } else if (strcmp(formatname, "hpl") == 0) {	/* format of traces provided by HPLabs for research purposes */      disksim->traceformat = HPL;      disksim->traceendian = _BIG_ENDIAN;   } else if (strcmp(formatname, "hpl2") == 0) {	/* format of traces provided by HPLabs for research purposes,     */        /* after they have been modified/combined by the `hplcomb' program */      disksim->traceformat = HPL;      disksim->traceendian = _BIG_ENDIAN;      disksim->traceheader = FALSE;   } else if (strcmp(formatname, "dec") == 0) {	/* format of some traces provided by dec for research purposes */      disksim->traceformat = DEC;   } else if (strcmp(formatname, "emcsymm") == 0) {	/* format of Symmetrix traces provided by EMC for research purposes */      disksim->traceformat = EMCSYMM;   } else if (strcmp(formatname, "emcbackend") == 0) {        /* format of Symmetrix backend traces that have been converted to map	   logical devices to physical devices  */      disksim->traceformat = EMCBACKEND;   } else if (strcmp(formatname, "batch") == 0) {        /* ascii traces with added batch information */      disksim->traceformat = BATCH;   } else {      fprintf(stderr, "Unknown trace format - %s\n", formatname);      exit(1);   }}static int iotrace_read_space (FILE *tracefile, char *spaceptr, int spacesize){   if (fread(spaceptr, spacesize, 1, tracefile) != 1) {      return(-1);   }   return(0);}static int iotrace_read_char (FILE *tracefile, char *charptr){   StaticAssert (sizeof(char) == 1);   if (fread(charptr, sizeof(char), 1, tracefile) != 1) {      return(-1);   }   return(0);}static int iotrace_read_short (FILE *tracefile, short *shortptr){   StaticAssert (sizeof(short) == 2);   if (fread(shortptr, sizeof(short), 1, tracefile) != 1) {      return(-1);   }   if (disksim->endian != disksim->traceendian) {      *shortptr = ((*shortptr) << 8) + (((*shortptr) >> 8) & 0xFF);   }   return(0);}static int iotrace_read_int32 (FILE *tracefile, int32_t *intP){   int i;   intchar swapval;   intchar intcharval;   StaticAssert (sizeof(int) == 4);   if (fread(&intcharval.value, sizeof(int), 1, tracefile) != 1) {      return(-1);   }   if (disksim->endian != disksim->traceendian) {      for (i=0; i<sizeof(int); i++) {         swapval.byte[i] = intcharval.byte[(sizeof(int) - i - 1)];      }/*      fprintf (outputfile, "intptr.value %x, swapval.value %x\n", intcharval.value, swapval.value);*/      intcharval.value = swapval.value;   }   *intP = intcharval.value;   return(0);}#define iotrace_read_float(a, b) iotrace_read_int32(a, b)ioreq_event * iotrace_validate_get_ioreq_event (FILE *tracefile, ioreq_event *new){   char line[201];   char rw;   double servtime;   if (fgets(line, 200, tracefile) == NULL) {      addtoextraq((event *) new);      return(NULL);   }   new->time = simtime + (validate_nextinter / (double) 1000);   if (sscanf(line, "%c %s %d %d %lf %lf\n", 	      &rw, 	      validate_buffaction, 	      &new->blkno, 	      &new->bcount, 	      &servtime, 	      &validate_nextinter) != 6)    {      fprintf(stderr, "Wrong number of arguments for I/O trace event type\n");      ddbg_assert(0);   }   validate_lastserv = servtime / (double) 1000;   if (rw == 'R') {      new->flags = READ;   } else if (rw == 'W') {      new->flags = WRITE;   } else {      fprintf(stderr, "Invalid R/W value: %c\n", rw);      exit(1);   }   new->devno = 0;   new->buf = 0;   new->opid = 0;   new->cause = 0;   new->busno = 0;   new->tempint2 = 0;   new->tempint1 = 0;   validate_lastblkno = new->blkno;   validate_lastbcount = new->bcount;   validate_lastread = new->flags & READ;   return(new);}static ioreq_event * iotrace_dec_get_ioreq_event (FILE *tracefile, ioreq_event *new){   assert ("removed for distribution" == 0);   iotrace_read_space (tracefile, NULL, 0);   return (NULL);}static void iotrace_hpl_srt_convert_flags (ioreq_event *curr){   int flags;   flags = curr->flags;   curr->flags = 0;   if (flags & HPL_READ) {      curr->flags |= READ;      hpreads++;   } else {      hpwrites++;   }   if (!(flags & HPL_ASYNC)) {      curr->flags |= TIME_CRITICAL;      if (curr->flags & READ) {         syncreads++;      } else {         syncwrites++;      }   }   if (flags & HPL_ASYNC) {      if (curr->flags & READ) {         curr->flags |= TIME_LIMITED;         asyncreads++;      } else {         asyncwrites++;      }   }}static ioreq_event * iotrace_hpl_get_ioreq_event (FILE *tracefile, ioreq_event *new){   int32_t size;   int32_t id;   int32_t sec;   int32_t usec;   int32_t val;   int32_t junkint;   unsigned int failure = 0;   while (TRUE) {      failure |= iotrace_read_int32(tracefile, &size);      failure |= iotrace_read_int32(tracefile, &id);      failure |= iotrace_read_int32(tracefile, &sec);      failure |= iotrace_read_int32(tracefile, &usec);      if (failure) {         addtoextraq((event *) new);         return(NULL);      }      if (((id >> 16) < 1) || ((id >> 16) > 4)) {         fprintf(stderr, "Error in trace format - id %x\n", id);         exit(1);      }      if (((id & 0xFFFF) != HPL_SHORTIO) && ((id & 0xFFFF) != HPL_SUSPECTIO)) {         fprintf(stderr, "Unexpected record type - %x\n", id);         exit(1);      }      new->time = (double) sec * (double) MILLI;      new->time += (double) usec / (double) MILLI;      if ((disksim->traceheader == FALSE) && (new->time == 0.0)) {         tracebasetime = simtime;      }      failure |= iotrace_read_int32(tracefile, &val);    /* traced request start time */      new->tempint1 = val;      failure |= iotrace_read_int32(tracefile, &val);    /* traced request stop time */      new->tempint2 = val;      new->tempint2 -= new->tempint1;      failure |= iotrace_read_int32(tracefile, &val);      new->bcount = val;      if (new->bcount & 0x000001FF) {         fprintf(stderr, "HPL request for non-512B multiple size: %d\n", new->bcount);         exit(1);      }      new->bcount = new->bcount >> 9;      failure |= iotrace_read_int32(tracefile, &val);      new->blkno = val;      failure |= iotrace_read_int32(tracefile, &val);      new->devno = (val >> 8) & 0xFF;      failure |= iotrace_read_int32(tracefile, &val);       /* drivertype */      failure |= iotrace_read_int32(tracefile, &val);       /* cylno */      /* for convenience and historical reasons, this cast is being allowed */      /* (the value is certain to be less than 32 sig bits, and will not be */      /* used as a pointer).                                                */      new->buf = (void *) val;      failure |= iotrace_read_int32(tracefile, &val);      new->flags = val;      iotrace_hpl_srt_convert_flags(new);      failure |= iotrace_read_int32(tracefile, &junkint);           /* info */      size -= 13 * sizeof(int32_t);      if ((id >> 16) == 4) {         failure |= iotrace_read_int32(tracefile, &val);  /* queuelen */         new->slotno = val;         size -= sizeof(int32_t);      }      if ((id & 0xFFFF) == HPL_SUSPECTIO) {         failure |= iotrace_read_int32(tracefile, &junkint);    /* susflags */         size -= sizeof(int32_t);      }      if (failure) {         addtoextraq((event *) new);