/* * Copyright (c) 2000 Silicon Graphics, Inc. All Rights Reserved. * * This program is free software; you can redistribute it and/or modify it * under the terms of version 2 of the GNU General Public License as * published by the Free Software Foundation. * * This program is distributed in the hope that it would be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * * Further, this software is distributed without any warranty that it is * free of the rightful claim of any third person regarding infringement * or the like. Any license provided herein, whether implied or * otherwise, applies only to this software file. Patent licenses, if * any, provided herein do not apply to combinations of this program with * other software, or any other product whatsoever. * * You should have received a copy of the GNU General Public License along * with this program; if not, write the Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. * * Contact information: Silicon Graphics, Inc., 1600 Amphitheatre Pkwy, * Mountain View, CA 94043, or: * * http://www.sgi.com * * For further information regarding this notice, see: * * http://oss.sgi.com/projects/GenInfo/NoticeExplan/ */ /* * iogen - a tool for generating file/sds io for a doio process */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef CRAY #include #include #include #endif #ifdef sgi #include #include #endif #ifdef CRAY #include "libkern.h" #endif #include "doio.h" #include "bytes_by_prefix.h" #include "string_to_tokens.h" #include "open_flags.h" #include "random_range.h" #ifndef PATH_MAX #define PATH_MAX 512 /* ??? */ #endif #ifndef BSIZE #ifdef linux #define BSIZE DEV_BSIZE #else #define BSIZE 512 #endif #endif #define RAW_IO(_flags_) ((_flags_) & (O_RAW | O_SSD)) #ifndef __linux__ extern char *sys_errlist[]; #endif #define SYSERR strerror(errno) /* * Structure for retaining test file information */ struct file_info { char f_path[MAX_FNAME_LENGTH + 1]; /* file name (full path) */ int f_length; /* length in bytes */ int f_iou; /* file iounit */ int f_riou; /* file raw iounit (for O_RAW/O_SSD) */ int f_dalign; /* direct I/O alignment */ int f_nextoff; /* offset of end of last io operation */ int f_type; /* file type S_IFREG, etc... */ int f_lastoffset; /* offset of last io operation */ int f_lastlength; /* length of last io operation */ }; /* * Simple structure for associating strings with values - useful for converting * cmdline args to internal values, as well as printing internal values in * a human readable form. */ struct strmap { char *m_string; int m_value; int m_flags; }; void startup_info(FILE * stream, int seed); int init_output(void); int form_iorequest(struct io_req *req); int get_file_info(struct file_info *rec); int create_file(char *path, int nbytes); int str_to_value(struct strmap *map, char *str); struct strmap *str_lookup(struct strmap *map, char *str); char *value_to_string(struct strmap *map, int val); int parse_cmdline(int argc, char **argv, char *opts); int help(FILE * stream); int usage(FILE * stream); /* * Declare cmdline option flags/variables initialized in parse_cmdline() */ #define OPTS "a:dhf:i:L:m:op:qr:s:t:T:O:N:" int a_opt = 0; /* async io comp. types supplied */ int o_opt = 0; /* form overlapping requests */ int f_opt = 0; /* test flags */ int i_opt = 0; /* iterations - 0 implies infinite */ int L_opt = 0; /* listio min-max nstrides & nents */ int m_opt = 0; /* offset mode */ int O_opt = 0; /* file creation Open flags */ int p_opt = 0; /* output pipe - default is stdout */ int r_opt = 0; /* specify raw io multiple instead of */ /* getting it from the mounted on device. */ /* Only applies to regular files. */ int s_opt = 0; /* syscalls */ int t_opt = 0; /* min transfer size (bytes) */ int T_opt = 0; /* max transfer size (bytes) */ int q_opt = 0; /* quiet operation on startup */ char TagName[40]; /* name of this iogen (see Monster) */ struct strmap *Offset_Mode; /* M_SEQUENTIAL, M_RANDOM, etc. */ int Iterations; /* # requests to generate (0 --> infinite) */ int Time_Mode = 0; /* non-zero if Iterations is in seconds */ /* (ie. -i arg was suffixed with 's') */ char *Outpipe; /* Pipe to write output to if p_opt */ int Mintrans; /* min io transfer size */ int Maxtrans; /* max io transfer size */ int Rawmult; /* raw/ssd io multiple (from -r) */ int Minstrides; /* min # of listio strides per request */ int Maxstrides; /* max # of listio strides per request */ int Oflags; /* open(2) flags for creating files */ int Ocbits; /* open(2) cbits for creating files */ int Ocblks; /* open(2) cblks for creating files */ int Orealtime = 0; /* flag set for -O REALTIME */ int Oextsize = 0; /* real-time extent size */ int Oreserve = 1; /* flag for -O [no]reserve */ int Oallocate = 0; /* flag for -O allocate */ int Owrite = 1; /* flag for -O nowrite */ int Nfiles = 0; /* # files on cmdline */ struct file_info *File_List; /* info about each file */ int Nflags = 0; /* # flags on cmdline */ struct strmap *Flag_List[128]; /* flags selected from cmdline */ int Nsyscalls = 0; /* # syscalls on cmdline */ struct strmap *Syscall_List[128]; /* syscalls selected on cmdline */ int Fileio = 0; /* flag indicating that a file */ /* io syscall has been chosen. */ int Naio_Strat_Types = 0; /* # async io completion types */ struct strmap *Aio_Strat_List[128]; /* Async io completion types */ /* * Map async io completion modes (-a args) names to values. Macros are * defined in doio.h. */ struct strmap Aio_Strat_Map[] = { #ifndef linux {"poll", A_POLL}, {"signal", A_SIGNAL}, #else {"none", 0}, #endif /* !linux */ #ifdef CRAY #if _UMK || RELEASE_LEVEL >= 8000 {"recall", A_RECALL}, #endif #ifdef RECALL_SIZEOF {"recalla", A_RECALLA}, #endif {"recalls", A_RECALLS}, #endif /* CRAY */ #ifdef sgi {"suspend", A_SUSPEND}, {"callback", A_CALLBACK}, #endif {NULL, -1} }; /* * Offset_Mode #defines */ #define M_RANDOM 1 #define M_SEQUENTIAL 2 #define M_REVERSE 3 /* * Map offset mode (-m args) names to values */ struct strmap Omode_Map[] = { {"random", M_RANDOM}, {"sequential", M_SEQUENTIAL}, {"reverse", M_REVERSE}, {NULL, -1} }; /* * Map syscall names (-s args) to values - macros are defined in doio.h. */ #define SY_ASYNC 00001 #define SY_WRITE 00002 #define SY_SDS 00010 #define SY_LISTIO 00020 #define SY_NENT 00100 /* multi entry vs multi stride >>> */ struct strmap Syscall_Map[] = { {"read", READ, 0}, {"write", WRITE, SY_WRITE}, #ifdef CRAY {"reada", READA, SY_ASYNC}, {"writea", WRITEA, SY_WRITE | SY_ASYNC}, #ifndef _CRAYMPP {"ssread", SSREAD, SY_SDS}, {"sswrite", SSWRITE, SY_WRITE | SY_SDS}, #endif {"listio", LISTIO, SY_ASYNC}, /* listio as 4 system calls */ {"lread", LREAD, 0}, {"lreada", LREADA, SY_ASYNC}, {"lwrite", LWRITE, SY_WRITE}, {"lwritea", LWRITEA, SY_WRITE | SY_ASYNC}, /* listio with nstrides > 1 */ {"lsread", LSREAD, 0}, {"lsreada", LSREADA, SY_ASYNC}, {"lswrite", LSWRITE, SY_WRITE}, {"lswritea", LSWRITEA, SY_WRITE | SY_ASYNC}, /* listio with nents > 1 */ {"leread", LEREAD, 0 | SY_NENT}, {"lereada", LEREADA, SY_ASYNC | SY_NENT}, {"lewrite", LEWRITE, SY_WRITE | SY_NENT}, {"lewritea", LEWRITEA, SY_WRITE | SY_ASYNC | SY_NENT}, /* listio with nents > 1 & nstrides > 1 */ /* all listio system calls under one name */ {"listio+", LREAD, 0}, {"listio+", LREADA, SY_ASYNC}, {"listio+", LWRITE, SY_WRITE}, {"listio+", LWRITEA, SY_WRITE | SY_ASYNC}, {"listio+", LSREAD, 0}, {"listio+", LSREADA, SY_ASYNC}, {"listio+", LSWRITE, SY_WRITE}, {"listio+", LSWRITEA, SY_WRITE | SY_ASYNC}, {"listio+", LEREAD, 0 | SY_NENT}, {"listio+", LEREADA, SY_ASYNC | SY_NENT}, {"listio+", LEWRITE, SY_WRITE | SY_NENT}, {"listio+", LEWRITEA, SY_WRITE | SY_ASYNC | SY_NENT}, #endif #ifdef sgi {"pread", PREAD}, {"pwrite", PWRITE, SY_WRITE}, {"aread", AREAD, SY_ASYNC}, {"awrite", AWRITE, SY_WRITE | SY_ASYNC}, #if 0 /* not written yet */ {"llread", LLREAD, 0}, {"llaread", LLAREAD, SY_ASYNC}, {"llwrite", LLWRITE, 0}, {"llawrite", LLAWRITE, SY_ASYNC}, #endif {"resvsp", RESVSP, SY_WRITE}, {"unresvsp", UNRESVSP, SY_WRITE}, {"reserve", RESVSP, SY_WRITE}, {"unreserve", UNRESVSP, SY_WRITE}, {"ffsync", DFFSYNC, SY_WRITE}, #endif /* SGI */ #ifndef CRAY {"readv", READV}, {"writev", WRITEV, SY_WRITE}, {"mmread", MMAPR}, {"mmwrite", MMAPW, SY_WRITE}, {"fsync2", FSYNC2, SY_WRITE}, {"fdatasync", FDATASYNC, SY_WRITE}, #endif {NULL, -1} }; /* * Map open flags (-f args) to values */ #define FLG_RAW 00001 struct strmap Flag_Map[] = { {"buffered", 0, 0}, {"sync", O_SYNC, 0}, #ifdef CRAY {"raw", O_RAW, FLG_RAW}, {"raw+wf", O_RAW | O_WELLFORMED, FLG_RAW}, {"raw+wf+ldraw", O_RAW | O_WELLFORMED | O_LDRAW, FLG_RAW}, {"raw+wf+ldraw+sync", O_RAW | O_WELLFORMED | O_LDRAW | O_SYNC, FLG_RAW}, #ifdef O_SSD {"ssd", O_SSD, FLG_RAW}, #endif #ifdef O_LDRAW {"ldraw", O_LDRAW, 0}, #endif #ifdef O_PARALLEL {"parallel", O_PARALLEL | O_RAW | O_WELLFORMED, FLG_RAW}, {"parallel+sync", O_PARALLEL | O_RAW | O_WELLFORMED | O_SYNC, FLG_RAW}, {"parallel+ldraw", O_PARALLEL | O_RAW | O_WELLFORMED | O_LDRAW, FLG_RAW}, {"parallel+ldraw+sync", O_PARALLEL | O_RAW | O_WELLFORMED | O_LDRAW | O_SYNC, FLG_RAW}, #endif #endif /* CRAY */ #ifdef sgi {"direct", O_DIRECT, FLG_RAW}, {"dsync", O_DSYNC}, /* affects writes */ {"rsync", O_RSYNC}, /* affects reads */ {"rsync+dsync", O_RSYNC | O_DSYNC}, #endif {NULL, -1} }; /* * Map file types to strings */ struct strmap Ftype_Map[] = { {"regular", S_IFREG}, {"blk-spec", S_IFBLK}, {"chr-spec", S_IFCHR}, {NULL, 0} }; /* * Misc declarations */ int Sds_Avail; char Byte_Patterns[26] = { 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z' }; int main(int argc, char **argv) { int rseed, outfd, infinite; time_t start_time; struct io_req req; umask(0); #ifdef CRAY Sds_Avail = sysconf(_SC_CRAY_SDS); #else Sds_Avail = 0; #endif TagName[0] = '\0'; parse_cmdline(argc, argv, OPTS); /* * Initialize output descriptor. */ if (!p_opt) { outfd = 1; } else { outfd = init_output(); } rseed = getpid(); random_range_seed(rseed); /* initialize random number generator */ /* * Print out startup information, unless we're running in quiet mode */ if (!q_opt) startup_info(stderr, rseed); { struct timeval ts; gettimeofday(&ts, NULL); start_time = ts.tv_sec; } /* * While iterations (or forever if Iterations == 0) - compute an * io request, and write the structure to the output descriptor */ infinite = !Iterations; struct timeval ts; gettimeofday(&ts, NULL); while (infinite || (!Time_Mode && Iterations--) || (Time_Mode && (ts.tv_sec - start_time <= Iterations))) { gettimeofday(&ts, NULL); memset(&req, 0, sizeof(struct io_req)); if (form_iorequest(&req) == -1) { fprintf(stderr, "iogen%s: form_iorequest() failed\n", TagName); continue; } req.r_magic = DOIO_MAGIC; if (write(outfd, (char *)&req, sizeof(req)) == -1) perror("Warning: Could not write"); } exit(0); } /* main */ void startup_info(FILE * stream, int seed) { char *value_to_string(), *type; int i; fprintf(stream, "\n"); fprintf(stream, "iogen%s starting up with the following:\n", TagName); fprintf(stream, "\n"); fprintf(stream, "Out-pipe: %s\n", p_opt ? Outpipe : "stdout"); if (Iterations) { fprintf(stream, "Iterations: %d", Iterations); if (Time_Mode) fprintf(stream, " seconds"); fprintf(stream, "\n"); } else { fprintf(stream, "Iterations: Infinite\n"); } fprintf(stream, "Seed: %d\n", seed); fprintf(stream, "Offset-Mode: %s\n", Offset_Mode->m_string); fprintf(stream, "Overlap Flag: %s\n", o_opt ? "on" : "off"); fprintf(stream, "Mintrans: %-11d (%d blocks)\n", Mintrans, (Mintrans + BSIZE - 1) / BSIZE); fprintf(stream, "Maxtrans: %-11d (%d blocks)\n", Maxtrans, (Maxtrans + BSIZE - 1) / BSIZE); if (!r_opt) fprintf(stream, "O_RAW/O_SSD Multiple: (Determined by device)\n"); else fprintf(stream, "O_RAW/O_SSD Multiple: %-11d (%d blocks)\n", Rawmult, (Rawmult + BSIZE - 1) / BSIZE); fprintf(stream, "Syscalls: "); for (i = 0; i < Nsyscalls; i++) fprintf(stream, "%s ", Syscall_List[i]->m_string); fprintf(stream, "\n"); fprintf(stream, "Aio completion types: "); for (i = 0; i < Naio_Strat_Types; i++) fprintf(stream, "%s ", Aio_Strat_List[i]->m_string); fprintf(stream, "\n"); if (Fileio) { fprintf(stream, "Flags: "); for (i = 0; i < Nflags; i++) fprintf(stream, "%s ", Flag_List[i]->m_string); fprintf(stream, "\n"); fprintf(stream, "\n"); fprintf(stream, "Test Files: \n"); fprintf(stream, "\n"); fprintf(stream, "Path Length iou raw iou file\n"); fprintf(stream, " (bytes) (bytes) (bytes) type\n"); fprintf(stream, "-----------------------------------------------------------------------------\n"); for (i = 0; i < Nfiles; i++) { type = value_to_string(Ftype_Map, File_List[i].f_type); fprintf(stream, "%-40s %12d %7d %7d %s\n", File_List[i].f_path, File_List[i].f_length, File_List[i].f_iou, File_List[i].f_riou, type); } } } /* * Initialize output descriptor. If going to stdout, its easy, * otherwise, attempt to create a FIFO on path Outpipe. Exit with an * error code if this cannot be done. */ int init_output(void) { int outfd; struct stat sbuf; if (stat(Outpipe, &sbuf) == -1) { if (errno == ENOENT) { if (mkfifo(Outpipe, 0666) == -1) { fprintf(stderr, "iogen%s: Could not mkfifo %s: %s\n", TagName, Outpipe, SYSERR); exit(2); } } else { fprintf(stderr, "iogen%s: Could not stat outpipe %s: %s\n", TagName, Outpipe, SYSERR); exit(2); } } else { if (!S_ISFIFO(sbuf.st_mode)) { fprintf(stderr, "iogen%s: Output file %s exists, but is not a FIFO\n", TagName, Outpipe); exit(2); } } if ((outfd = open(Outpipe, O_RDWR)) == -1) { fprintf(stderr, "iogen%s: Couldn't open outpipe %s with flags O_RDWR: %s\n", TagName, Outpipe, SYSERR); exit(2); } return (outfd); } /* * Main io generation function. form_iorequest() selects a system call to * do based on cmdline arguments, and proceeds to select parameters for that * system call. * * Returns 0 if req is filled in with a complete doio request, otherwise * returns -1. */ int form_iorequest(struct io_req *req) { int mult, offset = 0, length = 0, slength; int minlength, maxlength, laststart, lastend; int minoffset, maxoffset; int maxstride, nstrides; char pattern, *errp; struct strmap *flags, *sc, *aio_strat; struct file_info *fptr; #ifdef CRAY int opcode, cmd; #endif /* * Choose system call, flags, and file */ sc = Syscall_List[random_range(0, Nsyscalls - 1, 1, NULL)]; req->r_type = sc->m_value; #ifdef CRAY if (sc->m_value == LISTIO) { opcode = random_range(0, 1, 1, NULL) ? LO_READ : LO_WRITE; cmd = random_range(0, 1, 1, NULL) ? LC_START : LC_WAIT; } #endif if (sc->m_flags & SY_WRITE) pattern = Byte_Patterns[random_range (0, sizeof(Byte_Patterns) - 1, 1, NULL)]; else pattern = 0; #if CRAY /* * If sds io, simply choose a length (possibly pattern) and return */ if (sc->m_flags & SY_SDS) { req->r_data.ssread.r_nbytes = random_range(Mintrans, Maxtrans, BSIZE, NULL); if (sc->m_flags & SY_WRITE) req->r_data.sswrite.r_pattern = pattern; return 0; } #endif /* * otherwise, we're doing file io. Choose starting offset, length, * open flags, and possibly a pattern (for write/writea). */ fptr = &File_List[random_range(0, Nfiles - 1, 1, NULL)]; flags = Flag_List[random_range(0, Nflags - 1, 1, NULL)]; /* * Choose offset/length multiple. IO going to a device, or regular * IO that is O_RAW or O_SSD must be aligned on the file r_iou. Otherwise * it must be aligned on the regular iou (normally 1). */ if (fptr->f_type == S_IFREG && (flags->m_flags & FLG_RAW)) mult = fptr->f_riou; else mult = fptr->f_iou; /* * Choose offset and length. Both must be a multiple of mult */ /* * Choose length first - it must be a multiple of mult */ laststart = fptr->f_lastoffset; lastend = fptr->f_lastoffset + fptr->f_lastlength - 1; minlength = (Mintrans > mult) ? Mintrans : mult; switch (Offset_Mode->m_value) { case M_SEQUENTIAL: if (o_opt && lastend > laststart) offset = random_range(laststart, lastend, 1, NULL); else offset = lastend + 1; if (offset && (offset % mult)) offset += mult - (offset % mult); if (minlength > fptr->f_length - offset) offset = 0; maxlength = fptr->f_length - offset; if (maxlength > Maxtrans) maxlength = Maxtrans; length = random_range(minlength, maxlength, mult, &errp); if (errp != NULL) { fprintf(stderr, "iogen%s: random_range(%d, %d, %d) failed\n", TagName, minlength, maxlength, mult); return -1; } break; case M_REVERSE: maxlength = laststart; if (maxlength > Maxtrans) maxlength = Maxtrans; if (minlength > maxlength) { laststart = fptr->f_length; lastend = fptr->f_length; maxlength = Maxtrans; } length = random_range(minlength, maxlength, mult, &errp); if (errp != NULL) { fprintf(stderr, "iogen%s: random_range(%d, %d, %d) failed\n", TagName, minlength, maxlength, mult); return -1; } offset = laststart - length; if (o_opt && lastend > laststart) offset += random_range(1, lastend - laststart, 1, NULL); if (offset && (offset % mult)) offset -= offset % mult; break; case M_RANDOM: length = random_range(Mintrans, Maxtrans, mult, NULL); if (o_opt && lastend > laststart) { minoffset = laststart - length + 1; if (minoffset < 0) { minoffset = 0; } if (lastend + length > fptr->f_length) { maxoffset = fptr->f_length - length; } else { maxoffset = lastend; } } else { minoffset = 0; maxoffset = fptr->f_length - length; } if (minoffset < 0) minoffset = 0; offset = random_range(minoffset, maxoffset, mult, &errp); if (errp != NULL) { fprintf(stderr, "iogen%s: random_range(%d, %d, %d) failed\n", TagName, minoffset, maxoffset, mult); return -1; } } fptr->f_lastoffset = offset; fptr->f_lastlength = length; /* * Choose an async io completion strategy if necessary */ if (sc->m_flags & SY_ASYNC) aio_strat = Aio_Strat_List[random_range(0, Naio_Strat_Types - 1, 1, NULL)]; else aio_strat = NULL; /* * fill in specific syscall record data */ switch (sc->m_value) { case READ: case READA: strcpy(req->r_data.read.r_file, fptr->f_path); req->r_data.read.r_oflags = O_RDONLY | flags->m_value; req->r_data.read.r_offset = offset; req->r_data.read.r_nbytes = length; req->r_data.read.r_uflags = (flags->m_flags & FLG_RAW) ? F_WORD_ALIGNED : 0; req->r_data.read.r_aio_strat = (aio_strat == NULL) ? 0 : aio_strat->m_value; req->r_data.read.r_nstrides = 1; req->r_data.read.r_nent = 1; break; case WRITE: case WRITEA: strcpy(req->r_data.write.r_file, fptr->f_path); req->r_data.write.r_oflags = O_WRONLY | flags->m_value; req->r_data.write.r_offset = offset; req->r_data.write.r_nbytes = length; req->r_data.write.r_pattern = pattern; req->r_data.write.r_uflags = (flags->m_flags & FLG_RAW) ? F_WORD_ALIGNED : 0; req->r_data.write.r_aio_strat = (aio_strat == NULL) ? 0 : aio_strat->m_value; req->r_data.write.r_nstrides = 1; req->r_data.write.r_nent = 1; break; case READV: case AREAD: case PREAD: case WRITEV: case AWRITE: case PWRITE: case LREAD: case LREADA: case LWRITE: case LWRITEA: case RESVSP: case UNRESVSP: case DFFSYNC: case FSYNC2: case FDATASYNC: strcpy(req->r_data.io.r_file, fptr->f_path); req->r_data.io.r_oflags = ((sc->m_flags & SY_WRITE) ? O_WRONLY : O_RDONLY) | flags-> m_value; req->r_data.io.r_offset = offset; req->r_data.io.r_nbytes = length; req->r_data.io.r_pattern = pattern; req->r_data.io.r_uflags = (flags->m_flags & FLG_RAW) ? F_WORD_ALIGNED : 0; req->r_data.io.r_aio_strat = (aio_strat == NULL) ? 0 : aio_strat->m_value; req->r_data.io.r_nstrides = 1; req->r_data.io.r_nent = 1; break; case MMAPR: case MMAPW: strcpy(req->r_data.io.r_file, fptr->f_path); /* a subtle "feature" of mmap: a write-map requires the file open read/write */ req->r_data.io.r_oflags = ((sc->m_flags & SY_WRITE) ? O_RDWR : O_RDONLY) | flags-> m_value; req->r_data.io.r_offset = offset; req->r_data.io.r_nbytes = length; req->r_data.io.r_pattern = pattern; req->r_data.io.r_uflags = (flags->m_flags & FLG_RAW) ? F_WORD_ALIGNED : 0; req->r_data.io.r_aio_strat = (aio_strat == NULL) ? 0 : aio_strat->m_value; req->r_data.io.r_nstrides = 1; req->r_data.io.r_nent = 1; break; case LSREAD: case LSREADA: case LEREAD: case LEREADA: case LSWRITE: case LSWRITEA: case LEWRITE: case LEWRITEA: /* multi-strided */ strcpy(req->r_data.io.r_file, fptr->f_path); req->r_data.io.r_oflags = ((sc->m_flags & SY_WRITE) ? O_WRONLY : O_RDONLY) | flags-> m_value; req->r_data.io.r_offset = offset; req->r_data.io.r_uflags = (flags->m_flags & FLG_RAW) ? F_WORD_ALIGNED : 0; req->r_data.io.r_aio_strat = (aio_strat == NULL) ? 0 : aio_strat->m_value; req->r_data.io.r_pattern = pattern; /* multi-strided request... * random number of strides (1...MaxStrides) * length of stride must be > minlength * length of stride must be % mult * * maxstrides = min(length / mult, overall.max#strides) * nstrides = random # * while (length / nstrides < minlength) * nstrides = new random # */ maxstride = length / mult; if (maxstride > Maxstrides) maxstride = Maxstrides; if (!Minstrides) Minstrides = 1; nstrides = random_range(Minstrides, maxstride, 1, &errp); if (errp != NULL) { fprintf(stderr, "iogen%s: random_range(%d, %d, %d) failed\n", TagName, Minstrides, maxstride, 1); return -1; } slength = length / nstrides; if (slength % mult != 0) { if (mult > slength) { slength = mult; } else { slength -= slength % mult; } nstrides = length / slength; if (nstrides > Maxstrides) nstrides = Maxstrides; } req->r_data.io.r_nbytes = slength; if (sc->m_flags & SY_NENT) { req->r_data.io.r_nstrides = 1; req->r_data.io.r_nent = nstrides; } else { req->r_data.io.r_nstrides = nstrides; req->r_data.io.r_nent = 1; } break; case LISTIO: #ifdef CRAY strcpy(req->r_data.listio.r_file, fptr->f_path); req->r_data.listio.r_offset = offset; req->r_data.listio.r_cmd = cmd; req->r_data.listio.r_aio_strat = (aio_strat == NULL) ? 0 : aio_strat->m_value; req->r_data.listio.r_filestride = 0; req->r_data.listio.r_memstride = 0; req->r_data.listio.r_opcode = opcode; req->r_data.listio.r_nstrides = 1; req->r_data.listio.r_nbytes = length; req->r_data.listio.r_uflags = (flags->m_flags & FLG_RAW) ? F_WORD_ALIGNED : 0; if (opcode == LO_WRITE) { req->r_data.listio.r_pattern = pattern; req->r_data.listio.r_oflags = O_WRONLY | flags->m_value; } else { req->r_data.listio.r_oflags = O_RDONLY | flags->m_value; } #endif break; } return 0; } /* * Get information about a file that iogen uses to choose io length and * offset. Information gathered is file length, iounit, and raw iounit. * For regurlar files, iounit is 1, and raw iounit is the iounit of the * device on which the file resides. For block/character special files * the iounit and raw iounit are both the iounit of the device. * * Note: buffered and osync io must be iounit aligned * raw and ossd io must be raw iounit aligned */ int get_file_info(struct file_info *rec) { struct stat sbuf; #ifdef CRAY struct lk_device_info dinfo; #endif #ifdef sgi int fd; struct dioattr finfo; #endif /* * Figure out if the files is regular, block or character special. Any * other type is an error. */ if (stat(rec->f_path, &sbuf) == -1) { fprintf(stderr, "iogen%s: get_file_info(): Could not stat() %s: %s\n", TagName, rec->f_path, SYSERR); return -1; } #if _CRAY2 if ((!S_ISREG(sbuf.st_mode)) || strncmp(rec->f_path, "/dev/", 5) == 0) { fprintf(stderr, "iogen%s: device level io not supported on cray2\n", TagName); return -1; } #endif rec->f_type = sbuf.st_mode & S_IFMT; /* * If regular, iou is 1, and we must figure out the device on * which the file resides. riou is the iou (logical sector size) of * this device. */ if (S_ISREG(sbuf.st_mode)) { rec->f_iou = 1; rec->f_length = sbuf.st_size; /* * If -r used, take Rawmult as the raw/ssd io multiple. Otherwise * attempt to determine it by looking at the device the file * resides on. */ if (r_opt) { rec->f_riou = Rawmult; return 0; } #ifdef CRAY if (lk_rawdev(rec->f_path, dinfo.path, sizeof(dinfo.path), 0) == -1) return -1; if (lk_devinfo(&dinfo, 0) == -1) { /* can't get raw I/O unit -- use stat to fudge it */ rec->f_riou = sbuf.st_blksize; } else { rec->f_riou = ctob(dinfo.iou); } #endif #ifdef linux rec->f_riou = BSIZE; #endif #ifdef sgi if ((fd = open(rec->f_path, O_RDWR | O_DIRECT, 0)) != -1) { if (fcntl(fd, F_DIOINFO, &finfo) != -1) { rec->f_riou = finfo.d_miniosz; } else { fprintf(stderr, "iogen%s: Error %s (%d) getting direct I/O info of file %s\n", TagName, strerror(errno), errno, rec->f_path); } close(fd); } else { rec->f_riou = BBSIZE; } #endif /* SGI */ } else { #ifdef CRAY /* * Otherwise, file is a device. Use lk_devinfo() to get its logical * sector size. This is the iou and riou */ strcpy(dinfo.path, rec->f_path); if (lk_devinfo(&dinfo, 0) == -1) { fprintf(stderr, "iogen%s: %s: %s\n", TagName, Lk_err_func, Lk_err_mesg); return -1; } rec->f_iou = ctob(dinfo.iou); rec->f_riou = ctob(dinfo.iou); rec->f_length = ctob(dinfo.length); #else #ifdef sgi rec->f_riou = BBSIZE; rec->f_length = BBSIZE; #else rec->f_riou = BSIZE; rec->f_length = BSIZE; #endif /* sgi */ #endif /* CRAY */ } return 0; } /* * Create file path as nbytes long. If path exists, the file will either be * extended or truncated to be nbytes long. Returns final size of file, * or -1 if there was a failure. */ int create_file(char *path, int nbytes) { int fd, rval; char c; struct stat sbuf; #ifdef sgi int nb; struct flock f; struct fsxattr xattr; struct dioattr finfo; char *b, *buf; #endif errno = 0; rval = stat(path, &sbuf); if (rval == -1) { if (errno == ENOENT) { sbuf.st_size = 0; } else { fprintf(stderr, "iogen%s: Could not stat file %s: %s (%d)\n", TagName, path, SYSERR, errno); return -1; } } else { if (!S_ISREG(sbuf.st_mode)) { fprintf(stderr, "iogen%s: file %s exists, but is not a regular file - cannot modify length\n", TagName, path); return -1; } } if (sbuf.st_size == nbytes) return nbytes; Oflags |= O_CREAT | O_WRONLY; if ((fd = open(path, Oflags, 0666)) == -1) { fprintf(stderr, "iogen%s: Could not create/open file %s: %s (%d)\n", TagName, path, SYSERR, errno); return -1; } /* * Truncate file if it is longer than nbytes, otherwise attempt to * pre-allocate file blocks. */ if (sbuf.st_size > nbytes) { if (ftruncate(fd, nbytes) == -1) { fprintf(stderr, "iogen%s: Could not ftruncate() %s to %d bytes: %s (%d)\n", TagName, path, nbytes, SYSERR, errno); close(fd); return -1; } } else { #ifdef sgi /* * The file must be designated as Real-Time before any data * is allocated to it. * */ if (Orealtime != 0) { memset(&xattr, 0x00, sizeof(xattr)); xattr.fsx_xflags = XFS_XFLAG_REALTIME; /*fprintf(stderr, "set: fsx_xflags = 0x%x\n", xattr.fsx_xflags); */ if (fcntl(fd, F_FSSETXATTR, &xattr) == -1) { fprintf(stderr, "iogen%s: Error %s (%d) setting XFS XATTR->Realtime on file %s\n", TagName, SYSERR, errno, path); close(fd); return -1; } #ifdef DEBUG if (fcntl(fd, F_FSGETXATTR, &xattr) == -1) { fprintf(stderr, "iogen%s: Error getting realtime flag %s (%d)\n", TagName, SYSERR, errno); close(fd); return -1; } else { fprintf(stderr, "get: fsx_xflags = 0x%x\n", xattr.fsx_xflags); } #endif } /* * Reserve space with F_RESVSP * * Failure is ignored since F_RESVSP only works on XFS and the * filesystem could be on EFS or NFS */ if (Oreserve) { f.l_whence = SEEK_SET; f.l_start = 0; f.l_len = nbytes; /*fprintf(stderr, "create_file: fcntl(%d, F_RESVSP, { %d, %lld, %lld })\n", fd, f.l_whence, (long long)f.l_start, (long long)f.l_len); */ /* non-zeroing reservation */ if (fcntl(fd, F_RESVSP, &f) == -1) { fprintf(stderr, "iogen%s: Could not fcntl(F_RESVSP) %d bytes in file %s: %s (%d)\n", TagName, nbytes, path, SYSERR, errno); close(fd); return -1; } } if (Oallocate) { /* F_ALLOCSP allocates from the start of the file to l_start */ f.l_whence = SEEK_SET; f.l_start = nbytes; f.l_len = 0; /*fprintf(stderr, "create_file: fcntl(%d, F_ALLOCSP, { %d, %lld, %lld })\n", fd, f.l_whence, (long long)f.l_start, (long long)f.l_len); */ /* zeroing reservation */ if (fcntl(fd, F_ALLOCSP, &f) == -1) { fprintf(stderr, "iogen%s: Could not fcntl(F_ALLOCSP) %d bytes in file %s: %s (%d)\n", TagName, nbytes, path, SYSERR, errno); close(fd); return -1; } } #endif /* sgi */ /* * Write a byte at the end of file so that stat() sets the right * file size. */ #ifdef sgi if (Owrite == 2) { close(fd); if ((fd = open(path, O_CREAT | O_RDWR | O_DIRECT, 0)) != -1) { if (fcntl(fd, F_DIOINFO, &finfo) == -1) { fprintf(stderr, "iogen%s: Error %s (%d) getting direct I/O info for file %s\n", TagName, SYSERR, errno, path); return -1; } else { /*fprintf(stderr, "%s: miniosz=%d\n", path, finfo.d_miniosz); */ } } else { fprintf(stderr, "iogen%s: Error %s (%d) opening file %s with flags O_CREAT|O_RDWR|O_DIRECT\n", TagName, SYSERR, errno, path); return -1; } /* * nb is nbytes adjusted down by an even d_miniosz block * * Note: the first adjustment can cause iogen to print a warning * about not being able to create a file of length, * since the file will be shorter. */ nb = nbytes - finfo.d_miniosz; nb = nb - nb % finfo.d_miniosz; /*fprintf(stderr, "create_file_ow2: lseek(%d, %d {%d %d}, SEEK_SET)\n", fd, nb, nbytes, finfo.d_miniosz); */ if (lseek(fd, nb, SEEK_SET) == -1) { fprintf(stderr, "iogen%s: Could not lseek() to EOF of file %s: %s (%d)\n\tactual offset %d file size goal %d miniosz %lld\n", TagName, path, SYSERR, errno, nb, nbytes, (long long)finfo.d_miniosz); close(fd); return -1; } b = buf = malloc(finfo.d_miniosz + finfo.d_mem); if (((long)buf % finfo.d_mem != 0)) { buf += finfo.d_mem - ((long)buf % finfo.d_mem); } memset(buf, 0, finfo.d_miniosz); if ((rval = write(fd, buf, finfo.d_miniosz)) != finfo.d_miniosz) { fprintf(stderr, "iogen%s: Could not write %d byte length file %s: %s (%d)\n", TagName, nb, path, SYSERR, errno); fprintf(stderr, "\twrite(%d, 0x%lx, %d) = %d\n", fd, (long)buf, finfo.d_miniosz, rval); fprintf(stderr, "\toffset %d file size goal %d, miniosz=%d\n", nb, nbytes, finfo.d_miniosz); close(fd); return -1; } free(b); } else #endif /* sgi */ if (Owrite) { /*fprintf(stderr, "create_file_Owrite: lseek(%d, %d {%d}, SEEK_SET)\n", fd, nbytes-1, nbytes); */ if (lseek(fd, nbytes - 1, SEEK_SET) == -1) { fprintf(stderr, "iogen%s: Could not lseek() to EOF in file %s: %s (%d)\n\toffset goal %d\n", TagName, path, SYSERR, errno, nbytes - 1); close(fd); return -1; } if ((rval = write(fd, &c, 1)) != 1) { fprintf(stderr, "iogen%s: Could not create a %d byte length file %s: %s (%d)\n", TagName, nbytes, path, SYSERR, errno); fprintf(stderr, "\twrite(%d, 0x%lx, %d) = %d\n", fd, (long)&c, 1, rval); fprintf(stderr, "\toffset %d file size goal %d\n", nbytes - 1, nbytes); close(fd); return -1; } } } fstat(fd, &sbuf); close(fd); return sbuf.st_size; } /* * Function to convert a string to its corresponding value in a strmap array. * If the string is not found in the array, the value corresponding to the * NULL string (the last element in the array) is returned. */ int str_to_value(struct strmap *map, char *str) { struct strmap *mp; for (mp = map; mp->m_string != NULL; mp++) if (strcmp(mp->m_string, str) == 0) break; return mp->m_value; } /* * Function to convert a string to its corresponding entry in a strmap array. * If the string is not found in the array, a NULL is returned. */ struct strmap *str_lookup(struct strmap *map, char *str) { struct strmap *mp; for (mp = map; mp->m_string != NULL; mp++) if (strcmp(mp->m_string, str) == 0) break; return ((mp->m_string == NULL) ? NULL : mp); } /* * Function to convert a value to its corresponding string in a strmap array. * If the value is not found in the array, NULL is returned. */ char *value_to_string(struct strmap *map, int val) { struct strmap *mp; for (mp = map; mp->m_string != NULL; mp++) if (mp->m_value == val) break; return mp->m_string; } /* * Interpret cmdline options/arguments. Exit with 1 if something on the * cmdline isn't kosher. */ int parse_cmdline(int argc, char **argv, char *opts) { int o, len, nb, format_error; struct strmap *flgs, *sc; char *file, *cp, ch; extern int opterr; extern int optind; extern char *optarg; struct strmap *mp; struct file_info *fptr; int nopenargs; char *openargs[5]; /* Flags, cbits, cblks */ char *errmsg; int str_to_int(); opterr = 0; #ifndef linux char *ranges; struct strmap *type; #endif while ((o = getopt(argc, argv, opts)) != EOF) { switch ((char)o) { case 'a': #ifdef linux fprintf(stderr, "iogen%s: Unrecognized option -a on this platform\n", TagName); exit(2); #else cp = strtok(optarg, ","); while (cp != NULL) { if ((type = str_lookup(Aio_Strat_Map, cp)) == NULL) { fprintf(stderr, "iogen%s: Unrecognized aio completion strategy: %s\n", TagName, cp); exit(2); } Aio_Strat_List[Naio_Strat_Types++] = type; cp = strtok(NULL, ","); } a_opt++; #endif break; case 'f': cp = strtok(optarg, ","); while (cp != NULL) { if ((flgs = str_lookup(Flag_Map, cp)) == NULL) { fprintf(stderr, "iogen%s: Unrecognized flags: %s\n", TagName, cp); exit(2); } cp = strtok(NULL, ","); #ifdef O_SSD if (flgs->m_value & O_SSD && !Sds_Avail) { fprintf(stderr, "iogen%s: Warning - no sds available, ignoring ssd flag\n", TagName); continue; } #endif Flag_List[Nflags++] = flgs; } f_opt++; break; case 'h': help(stdout); exit(0); break; case 'i': format_error = 0; switch (sscanf(optarg, "%i%c", &Iterations, &ch)) { case 1: Time_Mode = 0; break; case 2: if (ch == 's') Time_Mode = 1; else format_error = 1; break; default: format_error = 1; } if (Iterations < 0) format_error = 1; if (format_error) { fprintf(stderr, "iogen%s: Illegal -i arg (%s): Must be of the format: number[s]\n", TagName, optarg); fprintf(stderr, " where 'number' is >= 0\n"); exit(1); } i_opt++; break; case 'L': #ifdef linux fprintf(stderr, "iogen%s: Unrecognized option -L on this platform\n", TagName); exit(2); #else if (parse_ranges(optarg, 1, 255, 1, NULL, &ranges, &errmsg) == -1) { fprintf(stderr, "iogen%s: error parsing listio range '%s': %s\n", TagName, optarg, errmsg); exit(1); } Minstrides = range_min(ranges, 0); Maxstrides = range_max(ranges, 0); free(ranges); L_opt++; #endif break; case 'm': if ((Offset_Mode = str_lookup(Omode_Map, optarg)) == NULL) { fprintf(stderr, "iogen%s: Illegal -m arg (%s)\n", TagName, optarg); exit(1); } m_opt++; break; case 'N': sprintf(TagName, "(%.39s)", optarg); break; case 'o': o_opt++; break; case 'O': nopenargs = string_to_tokens(optarg, openargs, 4, ":/"); #ifdef CRAY if (nopenargs) sscanf(openargs[1], "%i", &Ocbits); if (nopenargs > 1) sscanf(openargs[2], "%i", &Ocblks); Oflags = parse_open_flags(openargs[0], &errmsg); if (Oflags == -1) { fprintf(stderr, "iogen%s: -O %s error: %s\n", TagName, optarg, errmsg); exit(1); } #endif #ifdef linux Oflags = parse_open_flags(openargs[0], &errmsg); if (Oflags == -1) { fprintf(stderr, "iogen%s: -O %s error: %s\n", TagName, optarg, errmsg); exit(1); } #endif #ifdef sgi if (!strcmp(openargs[0], "realtime")) { /* * -O realtime:extsize */ Orealtime = 1; if (nopenargs > 1) sscanf(openargs[1], "%i", &Oextsize); else Oextsize = 0; } else if (!strcmp(openargs[0], "allocate") || !strcmp(openargs[0], "allocsp")) { /* * -O allocate */ Oreserve = 0; Oallocate = 1; } else if (!strcmp(openargs[0], "reserve")) { /* * -O [no]reserve */ Oallocate = 0; Oreserve = 1; } else if (!strcmp(openargs[0], "noreserve")) { /* Oreserve=1 by default; this clears that default */ Oreserve = 0; } else if (!strcmp(openargs[0], "nowrite")) { /* Owrite=1 by default; this clears that default */ Owrite = 0; } else if (!strcmp(openargs[0], "direct")) { /* this means "use direct i/o to preallocate file" */ Owrite = 2; } else { fprintf(stderr, "iogen%s: Error: -O %s error: unrecognized option\n", TagName, openargs[0]); exit(1); } #endif O_opt++; break; case 'p': Outpipe = optarg; p_opt++; break; case 'r': if ((Rawmult = bytes_by_prefix(optarg)) == -1 || Rawmult < 11 || Rawmult % BSIZE) { fprintf(stderr, "iogen%s: Illegal -r arg (%s). Must be > 0 and multipe of BSIZE (%d)\n", TagName, optarg, BSIZE); exit(1); } r_opt++; break; case 's': cp = strtok(optarg, ","); while (cp != NULL) { if ((sc = str_lookup(Syscall_Map, cp)) == NULL) { fprintf(stderr, "iogen%s: Unrecognized syscall: %s\n", TagName, cp); exit(2); } do { /* >>> sc->m_flags & FLG_SDS */ if (sc->m_value != SSREAD && sc->m_value != SSWRITE) Fileio++; Syscall_List[Nsyscalls++] = sc; } while ((sc = str_lookup(++sc, cp)) != NULL); cp = strtok(NULL, ","); } s_opt++; break; case 't': if ((Mintrans = bytes_by_prefix(optarg)) == -1) { fprintf(stderr, "iogen%s: Illegal -t arg (%s): Must have the form num[bkm]\n", TagName, optarg); exit(1); } t_opt++; break; case 'T': if ((Maxtrans = bytes_by_prefix(optarg)) == -1) { fprintf(stderr, "iogen%s: Illegal -T arg (%s): Must have the form num[bkm]\n", TagName, optarg); exit(1); } T_opt++; break; case 'q': q_opt++; break; case '?': usage(stderr); exit(1); } } /* * Supply defaults */ if (!L_opt) { Minstrides = 1; Maxstrides = 255; } if (!m_opt) Offset_Mode = str_lookup(Omode_Map, "sequential"); if (!i_opt) Iterations = 0; if (!t_opt) Mintrans = 1; if (!T_opt) Maxtrans = 256 * BSIZE; if (!O_opt) Oflags = Ocbits = Ocblks = 0; /* * Supply default async io completion strategy types. */ if (!a_opt) { for (mp = Aio_Strat_Map; mp->m_string != NULL; mp++) { Aio_Strat_List[Naio_Strat_Types++] = mp; } } /* * Supply default syscalls. Default is read,write,reada,writea,listio. */ if (!s_opt) { Nsyscalls = 0; Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "read"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "write"); #ifdef CRAY Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "reada"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "writea"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "lread"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "lreada"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "lwrite"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "lwritea"); #endif #ifdef sgi Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "pread"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "pwrite"); /*Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "aread"); */ /*Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "awrite"); */ #endif #ifndef CRAY Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "readv"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "writev"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "mmread"); Syscall_List[Nsyscalls++] = str_lookup(Syscall_Map, "mmwrite"); #endif Fileio = 1; } if (Fileio && (argc - optind < 1)) { fprintf(stderr, "iogen%s: No files specified on the cmdline\n", TagName); exit(1); } /* * Supply default file io flags - defaut is 'buffered,raw,sync,ldraw'. */ if (!f_opt && Fileio) { Nflags = 0; Flag_List[Nflags++] = str_lookup(Flag_Map, "buffered"); Flag_List[Nflags++] = str_lookup(Flag_Map, "sync"); #ifdef CRAY Flag_List[Nflags++] = str_lookup(Flag_Map, "raw+wf"); Flag_List[Nflags++] = str_lookup(Flag_Map, "ldraw"); #endif #ifdef sgi /* Warning: cannot mix direct i/o with others! */ Flag_List[Nflags++] = str_lookup(Flag_Map, "dsync"); Flag_List[Nflags++] = str_lookup(Flag_Map, "rsync"); /* Flag_List[Nflags++] = str_lookup(Flag_Map, "rsync+sync"); */ /* Flag_List[Nflags++] = str_lookup(Flag_Map, "rsync+dsync"); */ #endif } if (Fileio) { if (optind >= argc) { fprintf(stderr, "iogen%s: No files listed on the cmdline\n", TagName); exit(1); } /* * Initialize File_List[] - only necessary if doing file io. First * space for the File_List array, then fill it in. */ File_List = malloc((argc - optind) * sizeof(struct file_info)); if (File_List == NULL) { fprintf(stderr, "iogen%s: Could not malloc space for %d file_info structures\n", TagName, argc - optind); exit(2); } memset(File_List, 0, (argc - optind) * sizeof(struct file_info)); Nfiles = 0; while (optind < argc) { len = -1; /* * Pick off leading len: if it's there and create/extend/trunc * the file to the desired length. Otherwise, just make sure * the file is accessable. */ if ((cp = strchr(argv[optind], ':')) != NULL) { *cp = '\0'; if ((len = bytes_by_prefix(argv[optind])) == -1) { fprintf(stderr, "iogen%s: illegal file length (%s) for file %s\n", TagName, argv[optind], cp + 1); exit(2); } *cp = ':'; file = cp + 1; if (strlen(file) > MAX_FNAME_LENGTH) { fprintf(stderr, "iogen%s: Max fname length is %d chars - ignoring file %s\n", TagName, MAX_FNAME_LENGTH, file); optind++; continue; } nb = create_file(file, len); if (nb < len) { fprintf(stderr, "iogen%s warning: Couldn't create file %s of %d bytes\n", TagName, file, len); if (nb <= 0) { optind++; continue; } } } else { file = argv[optind]; if (access(file, R_OK | W_OK) == -1) { fprintf(stderr, "iogen%s: file %s cannot be accessed for reading and/or writing: %s (%d)\n", TagName, file, SYSERR, errno); exit(2); } } /* * get per-file information */ fptr = &File_List[Nfiles]; if (file[0] == '/') { strcpy(fptr->f_path, file); } else { if (getcwd (fptr->f_path, sizeof(fptr->f_path) - 1) == NULL) perror ("Could not get current working directory"); strcat(fptr->f_path, "/"); strcat(fptr->f_path, file); } if (get_file_info(fptr) == -1) { fprintf(stderr, "iogen%s warning: Error getting file info for %s\n", TagName, file); } else { /* * If the file length is smaller than our min transfer size, * ignore it. */ if (fptr->f_length < Mintrans) { fprintf(stderr, "iogen%s warning: Ignoring file %s\n", TagName, fptr->f_path); fprintf(stderr, " length (%d) is < min transfer size (%d)\n", fptr->f_length, Mintrans); optind++; continue; } /* * If the file length is smaller than our max transfer size, * ignore it. */ if (fptr->f_length < Maxtrans) { fprintf(stderr, "iogen%s warning: Ignoring file %s\n", TagName, fptr->f_path); fprintf(stderr, " length (%d) is < max transfer size (%d)\n", fptr->f_length, Maxtrans); optind++; continue; } if (fptr->f_length > 0) { switch (Offset_Mode->m_value) { case M_SEQUENTIAL: fptr->f_lastoffset = 0; fptr->f_lastlength = 0; break; case M_REVERSE: fptr->f_lastoffset = fptr->f_length; fptr->f_lastlength = 0; break; case M_RANDOM: fptr->f_lastoffset = fptr->f_length / 2; fptr->f_lastlength = 0; break; } Nfiles++; } } optind++; } if (Nfiles == 0) { fprintf(stderr, "iogen%s: Could not create, or gather info for any test files\n", TagName); exit(2); } } return 0; } int help(FILE * stream) { usage(stream); fprintf(stream, "\n"); #ifndef linux fprintf(stream, "\t-a aio_type,... Async io completion types to choose. Supported types\n"); #ifdef CRAY #if _UMK || RELEASE_LEVEL >= 8000 fprintf(stream, "\t are: poll, signal, recall, recalla, and recalls.\n"); #else fprintf(stream, "\t are: poll, signal, recalla, and recalls.\n"); #endif #else fprintf(stream, "\t are: poll, signal, suspend, and callback.\n"); #endif fprintf(stream, "\t Default is all of the above.\n"); #else /* !linux */ fprintf(stream, "\t-a (Not used on Linux).\n"); #endif /* !linux */ fprintf(stream, "\t-f flag,... Flags to use for file IO. Supported flags are\n"); #ifdef CRAY fprintf(stream, "\t raw, ssd, buffered, ldraw, sync,\n"); fprintf(stream, "\t raw+wf, raw+wf+ldraw, raw+wf+ldraw+sync,\n"); fprintf(stream, "\t and parallel (unicos/mk on MPP only).\n"); fprintf(stream, "\t Default is 'raw,ldraw,sync,buffered'.\n"); #else #ifdef sgi fprintf(stream, "\t buffered, direct, sync, dsync, rsync,\n"); fprintf(stream, "\t rsync+dsync.\n"); fprintf(stream, "\t Default is 'buffered,sync,dsync,rsync'.\n"); #else fprintf(stream, "\t buffered, sync.\n"); fprintf(stream, "\t Default is 'buffered,sync'.\n"); #endif /* sgi */ #endif /* CRAY */ fprintf(stream, "\t-h This help.\n"); fprintf(stream, "\t-i iterations[s] # of requests to generate. 0 means causes iogen\n"); fprintf(stream, "\t to run until it's killed. If iterations is suffixed\n"); fprintf(stream, "\t with 's', then iterations is the number of seconds\n"); fprintf(stream, "\t that iogen should run for. Default is '0'.\n"); #ifndef linux fprintf(stream, "\t-L min:max listio nstrides / nrequests range\n"); #else fprintf(stream, "\t-L (Not used on Linux).\n"); #endif /* !linux */ fprintf(stream, "\t-m offset-mode The mode by which iogen chooses the offset for\n"); fprintf(stream, "\t consectutive transfers within a given file.\n"); fprintf(stream, "\t Allowed values are 'random', 'sequential',\n"); fprintf(stream, "\t and 'reverse'.\n"); fprintf(stream, "\t sequential is the default.\n"); fprintf(stream, "\t-N tagname Tag name, for Monster.\n"); fprintf(stream, "\t-o Form overlapping consecutive requests.\n"); fprintf(stream, "\t-O Open flags for creating files\n"); #ifdef CRAY fprintf(stream, "\t {O_PLACE,O_BIG,etc}[:CBITS[:CBLKS]]\n"); #endif #ifdef sgi fprintf(stream, "\t realtime:extsize - put file on real-time volume\n"); fprintf(stream, "\t allocate - allocate space with F_ALLOCSP\n"); fprintf(stream, "\t reserve - reserve space with F_RESVSP (default)\n"); fprintf(stream, "\t noreserve - do not reserve with F_RESVSP\n"); fprintf(stream, "\t direct - use O_DIRECT I/O to write to the file\n"); #endif #ifdef linux fprintf(stream, "\t {O_SYNC,etc}\n"); #endif fprintf(stream, "\t-p Output pipe. Default is stdout.\n"); fprintf(stream, "\t-q Quiet mode. Normally iogen spits out info\n"); fprintf(stream, "\t about test files, options, etc. before starting.\n"); fprintf(stream, "\t-s syscall,... Syscalls to do. Supported syscalls are\n"); #ifdef sgi fprintf(stream, "\t read, write, pread, pwrite, readv, writev\n"); fprintf(stream, "\t aread, awrite, resvsp, unresvsp, ffsync,\n"); fprintf(stream, "\t mmread, mmwrite, fsync2, fdatasync,\n"); fprintf(stream, "\t Default is 'read,write,pread,pwrite,readv,writev,mmread,mmwrite'.\n"); #endif #ifdef CRAY fprintf(stream, "\t read, write, reada, writea, listio,\n"); fprintf(stream, "\t ssread (PVP only), and sswrite (PVP only).\n"); fprintf(stream, "\t Default is 'read,write,reada,writea,listio'.\n"); #endif #ifdef linux fprintf(stream, "\t read, write, readv, writev,\n"); fprintf(stream, "\t mmread, mmwrite, fsync2, fdatasync,\n"); fprintf(stream, "\t Default is 'read,write,readv,writev,mmread,mmwrite'.\n"); #endif fprintf(stream, "\t-t mintrans Min transfer length\n"); fprintf(stream, "\t-T maxtrans Max transfer length\n"); fprintf(stream, "\n"); fprintf(stream, "\t[len:]file,... Test files to do IO against (note ssread/sswrite\n"); fprintf(stream, "\t don't need a test file). The len: syntax\n"); fprintf(stream, "\t informs iogen to first create/expand/truncate the\n"); fprintf(stream, "\t to the desired length.\n"); fprintf(stream, "\n"); fprintf(stream, "\tNote: The ssd flag causes sds transfers to also be done.\n"); fprintf(stream, "\t To totally eliminate sds transfers, you must eleminate sds\n"); fprintf(stream, "\t from the flags (-f) and ssread,ssrite from the syscalls (-s)\n"); fprintf(stream, "\tThe mintrans, maxtrans, and len: parameters are numbers of the\n"); fprintf(stream, "\tform [0-9]+[bkm]. The optional trailing b, k, or m multiplies\n"); fprintf(stream, "\tthe number by blocks, kilobytes, or megabytes. If no trailing\n"); fprintf(stream, "\tmultiplier is present, the number is interpreted as bytes\n"); return 0; } /* * Obvious - usage clause */ int usage(FILE * stream) { fprintf(stream, "usage%s: iogen [-hoq] [-a aio_type,...] [-f flag[,flag...]] [-i iterations] [-p outpipe] [-m offset-mode] [-s syscall[,syscall...]] [-t mintrans] [-T maxtrans] [ -O file-create-flags ] [[len:]file ...]\n", TagName); return 0; }