path: root/ltp/growfiles.c

/*
 * 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 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.  See the
 * GNU General Public License for more details.
 *
 * 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 St, Fifth Floor, Boston, MA  02110-1301  USA
 */
/*
 * This program will grow a list of files.
 * Each file will grow by grow_incr before the same
 * file grows twice.  Each file is open and closed before next file is opened.
 *
 * To just verify file contents: growfiles -g 0 -c 1 filename
 *
 * See help and prt_examples functions below.
 *
 * Basic code layout
 *  process cmdline 
 *  print debug message about options used
 *  setup signal handlers
 *  return control to user (if wanted - default action)
 *  fork number of desired childern (if wanted)
 *  re-exec self (if wanted)
 *  Determine number of files
 *  malloc space or i/o buffer
 *  Loop until stop is set
 *    Determine if hit iteration, time, max errors or num bytes reached
 *    Loop through each file
 *	open file
 *	fstat file - to determine if file is a fifo
 *	prealloc file space (if wanted)
 *      growfile
 *	check last write
 *	check whole file
 *	shrink file
 *	close file
 *	delay (if wanted)
 *    End loop
 *  End loop
 *  remove all files (if wanted)
 *
 * Author: Richard Logan
 *
 */

#include "global.h"

#ifdef HAVE_SYS_FILE_H
#include <sys/file.h>
#endif

#include "dataascii.h"
#include "random_range.h"
#include "databin.h"
#include "open_flags.h"
#include "forker.h"
#include "file_lock.h"

extern int datapidgen(int pid, unsigned char *buffer, int bsize, int offset);
extern void databingen(int mode, unsigned char *buffer, int bsize, int offset);
extern int datapidchk(int pid, char *buffer, int bsize, int offset, char **errmsg);
extern int databinchk(int mode, char *buffer, int bsize, int offset, char **errmsg);

int file_size(int fd);
int check_write(int fd, int cf_inter, char *filename, int mode);
int shrinkfile(int fd, char *filename, int trunc_incr, int trunc_inter, int just_trunc);
int check_file(int fd, int cf_inter, char *filename, int no_file_check);
int growfile(int fd, char *file, int grow_incr, unsigned char *buf);
int cleanup();
int handle_error();
int lkfile(int fd, int operation, int lklevel);
void usage();
void help();
void prt_examples(FILE *stream);
int set_sig();
void sig_handler();
static void notify_others();
int pre_alloc(char *file, int fd, int size);


#define NEWIO	1	/* Use the tlibio.c functions */

#ifndef NEWIO
#define NEWIO	0	/* specifies to use original iowrite.c */
			/* functions instead of tlibio.c functions */
			/* Once it is proven tlibio.c functions work properly, */
			/* only tlibio.c functions will be used */
#else
#include "tlibio.h"
#endif

#ifndef PATH_MAX
#define PATH_MAX	1023
#endif


#define DEF_DIR		"."
#define DEF_FILE	"gf"

char *Progname;
int Debug  = 1;

int Pid=0;

int io_type = 0;			/* I/O type -sync */
int open_flags = O_RDWR|O_CREAT;	/* open flags */

#define MAX_FC_READ	196608		/* 4096 * 48 - 48 blocks */

#define PATTERN_ASCII	1	/* repeating alphabet letter pattern */
				/* allows multiple writers and to be checked */
#define PATTERN_PID	2	/* <pid><words byte offset><pid> */
				/* Assumes 64 bit word. Only allows single */
				/* process to write and check */
/*
 *	1234567890123456789012345678901234567890123456789012345678901234
 *	________________________________________________________________
 *	<    pid       >< offset in file of this word  ><    pid       >
 */
	
#define PATTERN_OFFSET	3	/* Like PATTERN_PID but has a fixed number */
				/* (STATIC_NUM) instead of pid. */
				/* Allows multiple processes to write/read */
#define PATTERN_ALT	4	/* alternating bit pattern (i.e. 0x5555555...) */
#define PATTERN_CHKER	5	/* checkerboard pattern (i.e. 0xff00ff00ff00...) */
#define PATTERN_CNTING  6	/* counting pattern (i.e. 0 - 07, 0 - 07, ...) */
#define PATTERN_ONES	7	/* all bits set (i.e. 0xffffffffffffff...) */
#define PATTERN_ZEROS	8	/* all bits cleared (i.e. 0x000000000...) */
#define PATTERN_RANDOM	9	/* random integers - can not be checked */
#define STATIC_NUM	221849	/* used instead of pid when PATTERN_OFFSET */

#define MODE_RAND_SIZE	1	/* random write and trunc */
#define MODE_RAND_LSEEK	2	/* random lseek before write */
#define MODE_GROW_BY_LSEEK 4	/* lseek beyond end of file then write a byte */
#define RANDOM_OPEN	999876	/* if Open_flags set to this value, open flags */
				/* will be randomly choosen from Open_flags[] */
#define MODE_FIFO	S_IFIFO	/* defined in stat.h  0010000 */

int num_files = 0;		/* num_auto_files + cmd line files */
char *filenames;		/* pointer to space containing filenames */
int remove_files = 0;		/* if set, cleanup default is not to cleanup */
int bytes_consumed = 0;		/* total bytes consumed, all files */
int bytes_to_consume = 0;   	/* non-zero if -B was specified, total bytes */
int Maxerrs = 100;		/* Max number errors before forced exit */
int Errors = 0;			/* number of encountered errors */
int Upanic_on_error = 0;	/* call upanic if error and this variable set */

/* The *_size variables are only used when random iosize option (-r) is used */
int max_size=5000;
int min_size=1;			/* also set in option parsing */
int mult_size=1;		/* when random iosz, iosz must be mult of mult_size */
/* the *_lseek variables are only used when radon lseek option (-R) is used */
int min_lseek=0;		/* also set in option parsing */
int max_lseek=-1;		/* -1 means size of file */
int Pattern=PATTERN_ASCII;
int Seed=-1;			/* random number seed, < 0 == uninitialized  */
int Nseeds=0;			/* Number of seed specified by the user */
int *Seeds;			/* malloc'ed arrary of ints holding user spec seeds */

int using_random=0;		/* flag indicating randomization is being used */
float delaysecs=0.0;		/* delay between iterations (in seconds) */
int delaytime;			/* delay between iterations in clocks/uses */
int lockfile=0;			/* if set, do file locking */
				/* 1 = do file locking around write, trunc */
				/* and reads. */
				/* 2 = write lock around all file operations */

int Woffset=0;			/* offset before last write */
int Grow_incr=4096;		/* sz of last write */
int Mode=0;			/* bitmask of write/trunc mode */
				/* also knows if dealing with fifo */
char *Buffer = NULL;		/* buffer used by write and write check */
int Alignment=0;		/* if non word multiple, io will not be word aligned */
int Opid=0;			/* original pid */

int Sync_with_others = 0;	/* Flag indicating to stop other if we stop before DONE */
int Iter_cnt = 0;		/* contains current iteration count value */
char	TagName[40];		/* name of this growfiles (see Monster)	    */

struct fileinfo_t {
    char *filename;
    int fd;
    int openflags;
    int mode;
}  Fileinfo;

/*
 * Define open flags that will be used when '-o random' option is used.
 * Note: If there is more than one growfiles doing its thing to the same
 * file, O_TRUNC will cause data mismatches.  How you ask?
 * timing of events, example:
 *   Process one		Process two
 *   ---------------		-------------
 *   get write lock
 *   fstat file
 *   lseek
 *   generate pattern
 *				open with O_TRUNC 
 *   write with wrong pattern
 *	because offset is wrong
 *
 *  The second process truncated the file after the pattern was
 *  determined, thus the pattern is wrong for the file location.
 *
 * There can also be a timing problem with open flag O_APPEND if
 * file locks are not being used (-l option).  Things could happen
 * between the fstat and the write. Thus, writing the wrong pattern.
 * If all processes observe the file locks, O_APPEND should be ok
 * to use.
 */
int Open_flags[] = { 
	O_RDWR|O_CREAT,
	O_RDWR|O_CREAT|O_APPEND,
	O_RDWR|O_CREAT|O_NDELAY,
	O_RDWR|O_CREAT|O_SYNC,
	O_RDWR|O_CREAT|O_SYNC|O_NDELAY,
	O_RDWR|O_CREAT|O_APPEND|O_NDELAY,

};

#define REXEC_INIT	0	/* don't do re-exec of childern */
#define REXEC_DOIT	1	/* Do re-exec of childern */
#define REXEC_DONE	2	/* We've already been re-exec'ed */

#ifndef BSIZE
#define BSIZE	512
#endif  /* BSIZE */

#define USECS_PER_SEC	1000000  /* microseconds per second */

/*
 * Define marcos used when dealing with file locks.
 */
#define LKLVL0		1	/* file lock around write/read/trunc */
#define LKLVL1		2	/* file lock after open to before close */

/*
 * Define special max lseek values
 */
#define LSK_EOF       	    -1	/* set fptr up to EOF */
#define LSK_EOFPLUSGROW	    -2	/* set fptr up to EOF + grow - leave whole */
#define LSK_EOFMINUSGROW    -3	/* set fptr up to EOF-grow - no grow */


/***********************************************************************
 * MAIN
 ***********************************************************************/
int
main(argc, argv)
int argc;
char **argv;
{
extern char *optarg;            /* used by getopt */
extern int optind;
extern int opterr;

int ind;
int first_file_ind = 0;
int num_auto_files = 0;		/* files created by tool */
int seq_auto_files = 0;		/* auto files created by tool created by tool */
char *auto_dir = DEF_DIR;
char *auto_file = DEF_FILE;
int grow_incr = 4096;
int trunc_incr = 4096;
int trunc_inter = 0;		/* 0 means none, */
int unlink_inter = 0;		/* 0 means none, 1 means always unlink */
int unlink_inter_ran = -1;	/* -1 -use unlink_inter, otherwise randomly choose */
				/* between unlink_inter and unlink_inter_ran */
int file_check_inter = 0;	/* 0 means never, 1 means always */
int write_check_inter = 1;	/* 0 means never, 1 means always */
int iterations = 1;		/* number of increments to be added */
int no_file_check = 0;		/* if set, no whole file checking will be done */
int num;
int fd;				/* file descriptor */
int stop = 0;			/* loop stopper if set */
int tmp;
char chr;
int ret;
int pre_alloc_space = 0;
int total_grow_value = 0;	/* used in pre-allocations */
int backgrnd = 1;		/* return control to user */
struct stat statbuf;
int time_iterval = -1;
time_t start_time = 0;
char reason[40];		/* reason for loop termination */
int num_procs=1;
int forker_mode=0;
int reexec=REXEC_INIT;		/* reexec info */
char *exec_path=NULL;

char *strrchr();

char *filename;                 /* name of file specified by user */
char *cptr;			/* temp char pointer */
extern int Forker_npids;	/* num of forked pid, defined in forker.c */


	if ( argv[0][0] == '-' )
	   reexec=REXEC_DONE;
	/*
	 * Determine name of file used to invoke this program
	 */
	if ((Progname=strrchr(argv[0], '/')) != NULL)
		Progname++;
	else
		Progname=argv[0];

	TagName[0] = '\0';

	/*
	 * Process options
	 */
	while ((ind=getopt(argc, argv, 
	    "hB:C:c:bd:D:e:Ef:g:H:I:i:lL:n:N:O:o:pP:q:wt:r:R:s:S:T:uU:W:xy")) != EOF) {
		switch(ind) {

		case 'h' :
			help();
			exit(0);

		case 'B':
			switch (sscanf(optarg, "%i%c",
				   &bytes_to_consume, &chr)) {
			case 1: /* noop */
			        break;

			case 2:
				if (chr == 'b') {
				    bytes_to_consume *= BSIZE;
				} else {
				    fprintf(stderr,
					"%s%s:  --B option arg invalid\n",
					Progname, TagName);
				    usage();
				    exit(1);
				}
				break;

			default:
				fprintf(stderr, "%s%s: --B option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
				break;
			}

			break;

		case 'E' :
			prt_examples(stdout);
			exit(0);

		case 'b' :	/* batch */
			backgrnd=0;
			break;

		case 'C':
			if (sscanf(optarg, "%i", &write_check_inter) != 1 ) {
				fprintf(stderr, "%s%s: --c option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
		       break;

		case 'c':
			if (sscanf(optarg, "%i", &file_check_inter) != 1 ) {
				fprintf(stderr, "%s%s: --c option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;


		case 'd':
			auto_dir=optarg;
			if ( stat(auto_dir, &statbuf) == -1 ) {
			    if ( mkdir(auto_dir, 0777) == -1 ) {
				if ( errno != EEXIST ) {
				    fprintf(stderr,
				        "%s%s: Unable to make dir %s\n", 
				        Progname, TagName, auto_dir);
				    exit(1);
			        }
			    }
			}
			else {
			    if ( ! (statbuf.st_mode & S_IFDIR) )  {
				fprintf(stderr,
				    "%s%s: %s already exists and is not a directory\n",
				    Progname, TagName, auto_dir);
				exit(1);
			    }
			}
			break;

		case 'D':
			if (sscanf(optarg, "%i", &Debug) != 1 ) {
				fprintf(stderr, "%s%s: --D option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'e':
			if (sscanf(optarg, "%i", &Maxerrs) != 1 ) {
				fprintf(stderr, "%s%s: --e option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'f':
			auto_file=optarg;
			break;

		case 'g':
			if ((ret=sscanf(optarg, "%i%c", &grow_incr, &chr)) < 1 ||
				grow_incr < 0 ) {

				fprintf(stderr, "%s%s: --g option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			if ( ret == 2 ) {
				if ( chr == 'b' || chr == 'B' )
					grow_incr *= 4096;
				else {
					fprintf(stderr,
						"%s%s: --g option arg invalid\n",
						Progname, TagName);
					usage();
					exit(1);
				}
			}
			break;

		case 'H':
			if (sscanf(optarg, "%f", &delaysecs) != 1 || delaysecs < 0 ) {

				fprintf(stderr, "%s%s: --H option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'i':
			if (sscanf(optarg, "%i", &iterations) != 1 ||
				iterations < 0 ) {

				fprintf(stderr, "%s%s: --i option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'I':
#if NEWIO
			if((io_type=lio_parse_io_arg1(optarg)) == -1 ) {
			    fprintf(stderr,
				"%s%s: --I arg is invalid, must be s, p, f, a, l, L or r.\n",
				Progname, TagName);
			    exit(1);
			}
			if( io_type & LIO_RANDOM )
				using_random++;
#else
			if((io_type=parse_io_arg(optarg)) == -1 ) {
			    fprintf(stderr,
				"%s%s: --I arg is invalid, must be s, p, f, a, l, L or r.\n",
				Progname, TagName);
			    exit(1);
			}
			if( io_type == 99 ) /* hold-over until tlibio.h */
				using_random++;
#endif
			break;

		case 'l':
			lockfile++;
			if ( lockfile > 2 )
			   lockfile=2;	/* lockfile can only be 1 or 2 */
			break;

		case 'L':
			if (sscanf(optarg, "%i", &time_iterval) != 1 ||
				time_iterval < 0 ) {
				fprintf(stderr, "%s%s: --L option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'n':
			if (sscanf(optarg, "%i:%i", &num_procs, &forker_mode) < 1 ||
                                num_procs < 0 ) {

                                fprintf(stderr, "%s%s: --n option arg invalid\n",
                                        Progname, TagName);
                                usage();
                                exit(1);
                        }

			break;

		case 'N':
			if (sscanf(optarg, "%i", &num_auto_files) != 1 ||
				num_auto_files < 0 ) {

				fprintf(stderr, "%s%s: --N option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'O':
			if (sscanf(optarg, "%i", &Alignment) != 1 ||
				num_auto_files < 0 ) {

				fprintf(stderr, "%s%s: --O option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'o':
		        if ( strcmp(optarg, "random") == 0 ){
			    open_flags=RANDOM_OPEN;
			    using_random++;

		        } else if ((open_flags=parse_open_flags(optarg, NULL)) == -1 ) {
		            fprintf(stderr, "%s%s: --o arg contains invalid flag\n",
				Progname, TagName);
		            exit(1);
		        }
		        break;


		case 'p' :	/* pre allocate space */
			printf("%s%s: --p is illegal option on this system\n",
				Progname, TagName);
			exit(1);
			break;

		case 'P':
			printf("%s%s: --P is illegal option on non-cray system\n",
				Progname, TagName);
			exit(1);
			break;

		case 'q':	/* file content or pattern */
			switch(optarg[0]) {
			case 'A':
			    Pattern = PATTERN_ALT;
			    break;
			case 'a':
			    Pattern = PATTERN_ASCII;
			    break;
			case 'p':
			    Pattern = PATTERN_PID;
			    break;
			case 'o':
			    Pattern = PATTERN_OFFSET;
			    break;
			case 'c':
			    Pattern = PATTERN_CHKER;
			    break;
			case 'C':
			    Pattern = PATTERN_CNTING;
			    break;
			case 'r':
			    Pattern = PATTERN_RANDOM;
			    using_random++;
			    break;
			case 'z':
			    Pattern = PATTERN_ZEROS;
			    break;
			case 'O':
			    Pattern = PATTERN_ONES;
			    break;
			default:
			    fprintf(stderr,
				"%s%s: --C option arg invalid, A, a, p, o, c, C, r, z, or 0\n",
				Progname, TagName);
			    usage();
			    exit(1);
			}
			break;

		case 'R':	/* random lseek before write arg: [min-]max*/
			if (sscanf(optarg, "%i-%i", &min_lseek, &max_lseek) != 2 ) {
			    min_lseek=1;    /* same as default in define */
			    if (sscanf(optarg, "%i%c", &max_lseek, &chr) != 1 ) {
				fprintf(stderr, "%s%s: --R option arg invalid: [min-]max\n",
				    Progname, TagName);
				exit(1);
			    }
			}
			if ( max_lseek < LSK_EOFMINUSGROW ) {
			    fprintf(stderr, "%s%s: --R option, max_lseek is invalid\n",
				Progname, TagName);
                            exit(1);
			}
			Mode |= MODE_RAND_LSEEK;
			using_random++;
		        break;

		case 'r':	/* random io size arg: [min-]max[:mult] */

			/* min-max:mult format */
			if (sscanf(optarg, "%i-%i:%i%c", &min_size, &max_size,
							&mult_size, &chr) != 3 ) {
			  min_size=1;   
			  /* max:mult format */
		  	  if (sscanf(optarg, "%i:%i%c", &max_size,
							&mult_size, &chr) != 2 ) {
			    /* min-max format */
		    	    if (sscanf(optarg, "%i-%i%c", &min_size,
							&max_size, &chr) != 2 ) {
			      min_size=1;   
		      	      if (sscanf(optarg, "%i%c", &max_size, &chr) != 1 ) {
				fprintf(stderr,
				     "%s%s: --r option arg invalid: [min-]max[:mult]\n",
			    	Progname, TagName);
				exit(1);
		      	      }
		    	    }
		  	  }
			}

			if ( max_size < 0 ) {
			    fprintf(stderr, "%s%s: --r option, max_size is invalid\n",
				Progname, TagName);
                            exit(1);
			}
			/*
			 * If min and max are the same, no randomness
			 */
			if ( min_size != max_size ) {
			    Mode |= MODE_RAND_SIZE;
			    using_random++;
 			}
		        break;

		case 'S':
			if (sscanf(optarg, "%i", &seq_auto_files) != 1 ||
				seq_auto_files < 0 ) {

				fprintf(stderr, "%s%s: --S option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 's':	/* format: seed[,seed...] */
			
			/* count the number of seeds */
			cptr=optarg;
			for(Nseeds=1; *cptr ; Nseeds++) {
			    if ( (filename=strchr(cptr, ',')) == NULL )
				break;
			    cptr=filename;
			    cptr++;
			}
			Seeds=(int *)malloc(Nseeds*sizeof(int));

			/*
			 * check that each seed is valid and put them in 
			 * the newly malloc'ed Seeds arrary.
			 */
			filename=cptr=optarg;
			for(Nseeds=0; *cptr; Nseeds++) {
			    if ( (filename=strchr(cptr, ',')) == NULL ) {
				if ( sscanf(cptr, "%i", &Seeds[Nseeds]) < 1 ) {
                                    fprintf(stderr, "%s%s: --s option arg %s invalid\n",
                                        Progname, TagName, cptr);
                                    usage();
                                    exit(1);
				}
				Nseeds++;
                                break;
			    }

			    *filename='\0';
			    if ( sscanf(cptr, "%i", &Seeds[Nseeds]) < 1 ) {
                               fprintf(stderr, "%s%s: --s option arg %s invalid\n",
                                        Progname, TagName, cptr);
                                usage();
                                exit(1);
			    }
			    *filename=',';   /* restore string */
                            cptr=filename;
			    cptr++;
			}
			break;

		case 't':
			if ((ret=sscanf(optarg, "%i%c", &trunc_incr, &chr)) < 1 ||
				trunc_incr < 0 ) {

				fprintf(stderr, "%s%s: --t option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			if ( ret == 2 ) {
				if ( chr == 'b' || chr == 'B' )
					trunc_incr *= 4096;
				else {
					fprintf(stderr,
						"%s%s: --t option arg invalid\n",
						Progname, TagName);
					usage();
					exit(1);
				}
			}
			break;

		case 'T':	/* truncate interval */
			if (sscanf(optarg, "%i%c", &trunc_inter, &chr) != 1 ||
				trunc_inter < 0 ) {

				fprintf(stderr, "%s%s: --T option arg invalid\n",
					Progname, TagName);
				usage();
				exit(1);
			}
			break;

		case 'u':
			remove_files++;
			break;

		case 'U':   /* how often to unlink file */
		       /* 
			* formats:   
			*      A-B  - randomly pick interval between A and B 
			*      X    - unlink file every X iteration
			*/
                       if (sscanf(optarg, "%i-%i", &unlink_inter, 
						&unlink_inter_ran) == 2 ) {

			   if ( unlink_inter < 0 || unlink_inter_ran < 0 ) {
                                fprintf(stderr, "%s%s: --U option arg invalid\n",
                                        Progname, TagName);
                                usage();
                                exit(1);
			   }
			   /* ensure unlink_inter contains smaller value */
			   if ( unlink_inter > unlink_inter_ran ) {
				tmp=unlink_inter_ran;
				unlink_inter_ran=unlink_inter;
				unlink_inter=tmp;
			   }
			   using_random++;

                       } else if (sscanf(optarg, "%i%c", &unlink_inter, &chr) != 1 ||
                                unlink_inter < 0 ) {

                            fprintf(stderr, "%s%s: --U option arg invalid\n",
                                 Progname, TagName);
                            usage();
                            exit(1);
                        }
			break;

	        case 'x':
			if ( reexec != REXEC_DONE )
			    reexec=REXEC_DOIT;
			break;

		case 'w':
			Mode |= MODE_GROW_BY_LSEEK;
			break;

		case 'W':
			sprintf( TagName, "(%.39s)", optarg );
			break;

		case 'y':
			Sync_with_others=1;
			break;

		case '?':
			usage();
			exit(1);
			break;
		}
	}

	if( Debug == 1 ){
		cptr = getenv("TOUTPUT");
		if( (cptr != NULL) && (strcmp( cptr, "NOPASS" ) == 0) ){
			Debug = 0;
		}
	}

	if ( Pattern == PATTERN_RANDOM ) {
	    no_file_check=1;
	    if ( write_check_inter || file_check_inter )
                printf("%s%s: %d Using random pattern - no data checking will be performed!\n",
		    Progname, TagName, (int)getpid());
	}
	else if ( max_lseek == LSK_EOFPLUSGROW || Mode & MODE_GROW_BY_LSEEK ) {
	    no_file_check=1;

	    if ( file_check_inter )
	        printf("%s%s: %d Using random lseek beyond EOF or lseek grow,\n\
no whole file checking will be performed!\n", Progname, TagName, (int)getpid());

	}

	if ( Mode & MODE_RAND_SIZE )
	    grow_incr=max_size;

	set_sig();

	Opid=getpid();
	Pid=Opid;

	if ( backgrnd ) {
	    if ( Debug > 1 )
		printf("%s: %d DEBUG2 forking, returning control to the user\n",
		    Progname, Opid);
	    background(Progname);	/* give user their prompt back */
	}

	if ( Debug > 3 ) {
#if NEWIO
	    lio_set_debug(Debug-3);
#else
	    set_iowrite_debug(Debug-3);
#endif
	}

	/*
	 * Print some program information here if debug is turned on to
	 * level 3 or higher.
	 */

        if ( Debug > 2 ) {
	    
	    if (  Mode & MODE_GROW_BY_LSEEK )
		printf("%s: %d DEBUG lseeking past end of file, writting a \"w\"\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_OFFSET )
		printf("%s: %d DEBUG3 %d<byteoffset>%d per word pattern multi-writers.\n",
		    Progname, Pid, STATIC_NUM, STATIC_NUM);
	    else if ( Pattern == PATTERN_PID )
		printf("%s: %d DEBUG3 <pid><byteoffset><pid> per word pattern - 1 writer\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_ASCII )
		printf("%s: %d DEBUG3 ascii pattern (vi'able)- allows multiple writers\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_ALT )
		printf("%s: %d DEBUG3 alt bit pattern - allows multiple writers\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_CHKER )
		printf("%s: %d DEBUG3 checkerboard pattern - allows multiple writers\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_CNTING )
		printf("%s: %d DEBUG3 counting pattern - allows multiple writers\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_RANDOM )
		printf("%s: %d DEBUG3 random integer pattern - no write/file checking\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_ONES )
		printf("%s: %d DEBUG3 all ones pattern - allows multiple writers\n",
		    Progname, Pid);
	    else if ( Pattern == PATTERN_ZEROS )
		printf("%s: %d DEBUG3 all zeros pattern - allows multiple writers\n",
		    Progname, Pid);
	
	    else
		printf("%s: %d DEBUG3 unknown pattern\n",
		    Progname, Pid);
	    if ( bytes_to_consume )
	        printf("%s: %d DEBUG3 bytes_to_consume = %d\n",
		    Progname, Pid, bytes_to_consume);
	    printf("%s: %d DEBUG3 Maxerrs = %d, pre_alloc_space = %d, filelocking = %d\n", 
		Progname, Pid, Maxerrs, pre_alloc_space, lockfile);

	    printf("%s: %d DEBUG3 Debug = %d, remove files in cleanup : %d\n",
		Progname, Pid, Debug, remove_files);

	    printf("%s: %d DEBUG3 Mode = %#o\n", Progname, Pid, Mode);

	    if ( open_flags == RANDOM_OPEN )
	       printf("%s: %d DEBUG3 open_flags = (random), io_type = %#o\n", Progname,
		 Pid, io_type);
	    else
	       printf("%s: %d DEBUG3 open_flags = %#o, io_type = %#o\n", Progname,
		 Pid, open_flags, io_type);

	    if ( Mode & MODE_RAND_SIZE ) {
	        printf("%s: %d DEBUG3 random write/trunc:  min=%d, max=%d, mult = %d\n",
		    Progname, Pid, min_size, max_size, mult_size);
	    }
	    else {
		printf("%s: %d DEBUG3 grow_incr = %d\n", 
		    Progname, Pid, grow_incr);
	    }
	    if ( Mode & MODE_RAND_LSEEK ) {
		if ( max_lseek == LSK_EOF )
	          printf("%s: %d DEBUG3 random lseek:  min=%d, max=<endoffile>\n",
		    Progname, Pid, min_lseek);
		else if ( max_lseek == LSK_EOFPLUSGROW )
	          printf("%s: %d DEBUG3 random lseek:  min=%d, max=<endoffile+iosize>\n",
		    Progname, Pid, min_lseek);
		else if ( max_lseek == LSK_EOFMINUSGROW )
	          printf("%s: %d DEBUG3 random lseek:  min=%d, max=<endoffile-iosize>\n",
		    Progname, Pid, min_lseek);
		else
	          printf("%s: %d DEBUG3 random lseek:  min=%d, max=%d\n",
		    Progname, Pid, min_lseek, max_lseek);
	    }

	    printf("%s: %d DEBUG3 check write interval = %d, check file interval = %d\n",
		Progname, Pid, write_check_inter, file_check_inter);

	    printf("%s: %d DEBUG3 trunc interval = %d, trunc_incr = %d\n",
		Progname, Pid, trunc_inter, trunc_incr);

	    if ( no_file_check )
		printf("%s: %d DEBUG3 no whole file checking will be done\n",
		    Progname, Pid);
	    
	    if ( unlink_inter_ran == -1 ) {
		printf("%s: %d DEBUG3 unlink_inter = %d\n", 
		        Progname, Pid, unlink_inter);
	    } else {
		printf("%s: %d DEBUG3 unlink_inter = %d, unlink_inter_ran = %d\n", 
                        Progname, Pid, unlink_inter, unlink_inter_ran);
	    }  

	    if ( Debug > 8 ) {
	       num=sizeof(Open_flags)/sizeof(int);
	       printf("%s: %d DEBUG9 random open flags values:\n", Progname, Pid);
	       for(ind=0; ind<num; ind++) {
		    printf("\t%#o\n", Open_flags[ind]);
	       }
	    }
	}  /* end of DEBUG > 2 */

	if ( Debug > 1 && num_procs > 1 ) {
	    printf("%s: %d DEBUG2 about to fork %d more copies\n", Progname,
		Opid, num_procs-1);
	}

	fflush(stdout);	/* ensure pending i/o is flushed before forking */
	fflush(stderr);

	forker(num_procs, forker_mode, Progname);

	Pid=getpid();	/* reset after the forks */
	/*
	 * If user specified random seed(s), get that random seed value.
	 * get random seed if it was not specified by the user.
	 * This is done after the forks, because pid is used to get the seed.
         */
	if ( Nseeds == 1 ) {
	    /*
	     * If only one seed specified, all processes will get that seed. 
	     */
	    Seed=Seeds[0];
	} else if ( Nseeds > 1 ) {
	    /*
	     * More than one seed was specified.
	     * The original process gets the first seed.  Each
	     * process will be get the next seed in the specified list.
	     */
	    if ( Opid == Pid ) {
		Seed=Seeds[0];
	    } else {
		/*
		 * If user didn't specify enough seeds, use default method.
		 */
		if ( Forker_npids >= Nseeds ) 
	    	    Seed=time(0) + Pid;  /* default random seed */
		else {
		    Seed=Seeds[Forker_npids];
		}
	    }
	} else {
	    /* 
	     * Generate a random seed based on time and pid.
	     * It has a good chance of being unique for each pid.
	     */
	    Seed=time(0) + Pid;  /* default random seed */
	}

	random_range_seed(Seed);

        if ( using_random && Debug > 0 )
	    printf("%s%s: %d DEBUG1 Using random seed of %d\n",
		Progname, TagName, Pid, Seed);

	if ( unlink_inter_ran > 0 ) {
	    /*
	     * Find unlinking file interval.  This must be done after
	     * the seed was set.   This allows multiple copies to
	     * get different intervals.
	     */
	    tmp=unlink_inter;
	    unlink_inter=random_range(tmp, unlink_inter_ran, 1, NULL);

	    if ( Debug > 2 )
		printf("%s: %d DEBUG3 Unlink interval is %d (random %d - %d)\n",
		    Progname, Pid, unlink_inter, tmp, unlink_inter_ran);
	}

	/*
	 * re-exec all childern if reexec is set to REXEC_DOIT.
	 * This is useful on MPP systems to get the
	 * child process on another PE.
	 */
	if ( reexec == REXEC_DOIT && Opid != Pid ) {
	    if ( exec_path == NULL ) {
		exec_path = argv[0];
		/* Get space for cmd (2 extra, 1 for - and 1 fro NULL */
		argv[0] = (char *)malloc(strlen(exec_path) + 2);
		sprintf(argv[0], "-%s", exec_path);
	    }
	  
	    if ( Debug > 2 )
	        printf("%s: %d DEBUG3 %s/%d: execvp(%s, argv)\n",
		    Progname, Pid, __FILE__, __LINE__, argv[0]);

	    execvp(argv[0], argv);
        }

	/*** begin filename stuff here *****/
	/*
	 * Determine the number of files to be dealt with
	 */
	if ( optind == argc ) {
		/*
		 * no cmd line files, therfore, set
		 * the default number of auto created files
		 */
		if ( ! num_auto_files && ! seq_auto_files )
			num_auto_files=1;
	}
	else {
		first_file_ind=optind;
		num_files += argc-optind;
	}

	if ( num_auto_files ) {
		num_files += num_auto_files;
	}

	if ( seq_auto_files ) {
		num_files += seq_auto_files;
	}

	/*
	 * get space for file names
	 */
	if ((filenames=(char *)malloc(num_files*PATH_MAX)) == NULL) {
		fprintf(stderr, "%s%s: %d %s/%d: malloc(%d) failed: %s\n",
			Progname, TagName, Pid, __FILE__, __LINE__, num_files*PATH_MAX,
			strerror(errno));
		exit(1);
	}

	/*
	 * fill in filename cmd files then auto files.
	 */

	num=0;
	if ( first_file_ind ) {
		for(ind=first_file_ind; ind<argc; ind++, num++) {
			strcpy((char *)filenames+(num*PATH_MAX), argv[ind]);
		}
	}

	/*
	 * construct auto filename and insert them into filenames space
	 */
	for(ind=0;ind<num_auto_files; ind++, num++) {
		sprintf((char *)filenames+(num*PATH_MAX), "%s/%s.%d",
			auto_dir, auto_file, ind);
	}

	/*
	 * construct auto seq filenames
	 */
	for(ind=1; ind<=seq_auto_files; ind++, num++) {
		sprintf((char *)filenames+(num*PATH_MAX), "%s/%s%d",
			auto_dir, auto_file, ind);
	}

/**** end filename stuff ****/

	if ( time_iterval > 0 )
		start_time=time(0);

	/*
	 * get space for I/O buffer
	 */
	if ( grow_incr ) {
		if ((Buffer=(char *)malloc(grow_incr+Alignment)) == NULL) {
			fprintf(stderr, "%s%s: %d %s/%d: malloc(%d) failed: %s\n",
				Progname, TagName, Pid, __FILE__, __LINE__, grow_incr, strerror(errno));
			exit(1);
		}
		if ( Alignment )
		Buffer = Buffer + Alignment;

	}

	if ( Debug > 2 ) {
		printf("%s: %d DEBUG3 num_files = %d\n",
			Progname, Pid, num_files);
	}

	if ( pre_alloc_space ) {
		if ( iterations == 0 ) {
		    fprintf(stderr, "%s%s: %d %s/%d: can NOT pre-alloc and grow forever\n",
			Progname, TagName, Pid, __FILE__, __LINE__);
		    exit(1);
		}
		if ( Mode & MODE_RAND_SIZE ) {
		    fprintf(stderr,
			"%s%s: %d %s/%d: can NOT pre-alloc and do random io size\n",
			Progname, TagName, Pid, __FILE__, __LINE__);
		    exit(1);
		}

		total_grow_value=grow_incr * iterations;

		/*
		 * attempt to limit 
		 */
		if ( bytes_to_consume && bytes_to_consume < total_grow_value ) {
			total_grow_value=bytes_to_consume;
		}
	}

	/*
	 * If delaying between iterations, get amount time to
	 * delaysecs in clocks or usecs.
	 */
	if ( delaysecs ) {
	   delaytime=(int)((float)USECS_PER_SEC * delaysecs);
        }

	/*
	 * This is the main iteration loop.
	 * Each iteration, all files can  be opened, written to,
	 * read to check the write, check the whole file, 
	 * truncated, and closed.   
	 */
	for(Iter_cnt=1; ! stop ; Iter_cnt++) {

	    if ( iterations && Iter_cnt >= iterations+1 ) {
		strcpy(reason, "Hit iteration value");
		stop=1;
		continue;
	    }

	    if (  (time_iterval > 0) && (start_time + time_iterval < time(0)) ) {
		sprintf(reason, "Hit time value of %d", time_iterval);
		stop=1;
		continue;
	    }

	    if ( bytes_to_consume && bytes_consumed >= bytes_to_consume) {
		sprintf(reason, "Hit bytes consumed value of %d", bytes_to_consume);
		stop=1;
                continue;
            }

	    /*
	     * This loop will loop through all files.
	     * Each iteration, a single file can  be opened, written to,
	     * read to check the write, check the whole file, 
	     * truncated, and closed.   
	     */
	    for(ind=0; ind<num_files; ind++) {

		fflush(stdout);
		fflush(stderr);

		filename=(char *)filenames+(ind*PATH_MAX);
		Fileinfo.filename=(char *)filenames+(ind*PATH_MAX);


		if ( open_flags ==  RANDOM_OPEN ) {
		   ret=Open_flags[random_range(0, sizeof(Open_flags)/sizeof(int)-1, 1, NULL)];
		}

		else
		   ret=open_flags;

		Fileinfo.openflags=ret;

		if ( Debug > 3 ) {
		    printf("%s: %d DEBUG3 %s/%d: %d Open filename = %s, open flags = %#o %s\n",
			Progname, Pid, __FILE__, __LINE__, Iter_cnt, filename, ret, 
		        openflags2symbols(ret, ",", 0));
		} else if ( Debug > 2 ) {
		    printf("%s: %d DEBUG3 %s/%d: %d filename = %s, open flags = %#o\n",
			Progname, Pid, __FILE__, __LINE__, Iter_cnt, filename, ret);
		}

		/*
		 * open file with desired flags.
		 */
		if ( (fd=open(filename, ret, 0777)) == -1 ) {
		    fprintf(stderr,
                        "%s%s: %d %s/%d: open(%s, %#o, 0777) returned -1, errno:%d %s\n",
			Progname, TagName, Pid, __FILE__, __LINE__, filename, ret, errno, strerror(errno));
			handle_error();
			continue;
		}

		Fileinfo.fd=fd;

		lkfile(fd, LOCK_EX, LKLVL1);   /* lock if lockfile is LKLVL1 */

		/*
		 * preallocation is only done once, if specified.
		 */
		if ( pre_alloc_space ) {
			if (pre_alloc(filename, fd, total_grow_value) != 0 ) {
				cleanup();
				exit(2);
			}
			if ( Debug > 1 ) {
				printf("%s: %d DEBUG2 %s/%d: pre_allocated %d for file %s\n",
				    Progname, Pid, __FILE__, __LINE__, total_grow_value, filename);
			}
			lkfile(fd, LOCK_UN, LKLVL1);   /* release lock */
			close(fd);
			Iter_cnt=0;	/* reset outside loop to restart from one */
			continue;
		}

		/*
		 * grow file by desired amount.
		 * growfile() will set the Grow_incr variable and 
                 * possiblly update the Mode variable indicating
		 * if we are dealing with a FIFO file.
		 */

		if (growfile(fd, filename, grow_incr, (unsigned char *)Buffer) != 0 ) {
			handle_error();
			lkfile(fd, LOCK_UN, LKLVL1);   /* release lock */
			close(fd);
			continue;
		}

		/*
		 * check if last write is not corrupted
		 */
		if ( check_write(fd, write_check_inter, filename,
							Mode) != 0 ) {
		    handle_error();
                }

		/*
		 * Check that whole file is not corrupted.
		 */
		if ( check_file(fd, file_check_inter, filename,
						no_file_check) != 0 ) {
		    handle_error();
		}

		/*
		 * shrink file by desired amount if it is time 
		 */

		if ( shrinkfile(fd, filename, trunc_incr, trunc_inter, Mode) != 0 ) {
		    handle_error();
		}

		lkfile(fd, LOCK_UN, LKLVL1);   /* release lock */

		if ( Debug > 4 )
		    printf("%s: %d DEBUG5 %s/%d: %d Closing file %s fd:%d \n", 
			Progname, Pid, __FILE__, __LINE__, Iter_cnt, filename, fd);
		close(fd);

		/*
		 * Unlink the file if that is desired
		 */
		if ( unlink_inter && (Iter_cnt % unlink_inter == 0) ) {
		
		    if ( Debug > 4 )
			printf("%s: %d DEBUG5 %s/%d: %d Unlinking file %s\n", 
			    Progname, Pid, __FILE__, __LINE__, Iter_cnt, filename);

		    unlink(filename);
		}

	        /*
	         * delay while staying active for "delaysecs" seconds.
	         */
	        if ( delaytime ) {
		
		    int ct, end;
		    struct timeval curtime;
		    gettimeofday(&curtime, NULL);
		    ct=curtime.tv_sec*USECS_PER_SEC + curtime.tv_usec;
		    end=ct+delaytime;
                    while ( ct < end ) {

		        gettimeofday(&curtime, NULL);
		        ct=curtime.tv_sec*USECS_PER_SEC + curtime.tv_usec;
		    }
	        }
	    }
	    /*
	     * if Iter_cnt == 0, then we pre allocated space to all files
	     * and we are starting outside loop over.  Set pre_alloc_space
	     * to zero otherwise we get in infinite loop
	     */
	    if ( Iter_cnt == 0 ) {
		pre_alloc_space=0;
	    }
	}   /* end iteration for loop */


        if ( Debug ) {
	    printf("%s%s: %d %s/%d: DONE %d iterations to %d files. %s\n",
		Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, num_files, reason);
	}
	fflush(stdout);
	fflush(stderr);

	cleanup();

	if ( Errors ) {
		if ( Debug > 2 ) {
		    printf("%s%s: %d DEBUG3 %d error(s) encountered\n",
			Progname, TagName, Pid, Errors);
		    printf("%s%s: %d DEBUG3 %s/%d: exiting with value of 1\n", Progname, TagName, Pid, __FILE__, __LINE__);
		}
		exit(1);
	}
	if ( Debug > 2 )
	    printf("%s%s: %d DEBUG3 %s/%d: no errors, exiting with value of 0\n", Progname, TagName, Pid, __FILE__, __LINE__);
	exit(0);
}

/***********************************************************************
 *
 ***********************************************************************/
int
set_sig()
{
   int sig;

	
        /*
         * now loop through all signals and set the handlers
         */

        for (sig = 1; sig < NSIG; sig++) {
            switch (sig) {
                case SIGKILL:
                case SIGSTOP:
                case SIGCONT:
#ifdef SIGCKPT
	        case SIGCKPT:
#endif /* SIGCKPT */
#ifdef SIGRESTART
	        case SIGRESTART:
#endif /* SIGRESTART */
                case SIGCLD:
                    break;

                default:
                    signal(sig, sig_handler);
                break;
            }
        } /* endfor */


        return 0;
}

/***********************************************************************
 *
 ***********************************************************************/
void
sig_handler(sig)
int sig;
{
    int exit_stat = 2;

    if ( sig == SIGUSR2 ) {
	fprintf(stdout, "%s%s: %d %s/%d: received SIGUSR2 (%d) - stopping.\n",
	    Progname, TagName, Pid, __FILE__, __LINE__, sig);
        signal(sig, sig_handler);	/* allow us to get this signal more than once */
        
    } else if( sig == SIGINT ){
	/* The user has told us to cleanup, don't pretend it's an error. */
	exit_stat=0;
	if ( Debug != 0 ){
		fprintf(stderr, "%s%s: %d %s/%d: received unexpected signal: %d\n", Progname, TagName,
		    Pid, __FILE__, __LINE__, sig);
	}
    } else {
	fprintf(stderr, "%s%s: %d %s/%d: received unexpected signal: %d\n", Progname, TagName,
	    Pid, __FILE__, __LINE__, sig);
    }

    notify_others();
    cleanup();
    if ( Debug > 2 ){
	printf("%s%s: %d DEBUG3 %s/%d: Exiting with a value of %d\n",
	       Progname, TagName, Pid, __FILE__, __LINE__, exit_stat);
    }
    exit(exit_stat);
}

/***********************************************************************
 * this function attempts to send SIGUSR2 to other growfiles processes
 * telling them to stop.
 *  
 ***********************************************************************/
static void
notify_others()
{
    static int send_signals = 0;
    int ind;
    extern int Forker_pids[];
    extern int Forker_npids;

    if ( Sync_with_others && send_signals == 0 ) {

	send_signals=1; /* only send signals once */

        for (ind=0; ind< Forker_npids; ind++) {
	    if ( Forker_pids[ind] != Pid )
	        if ( Debug > 1 )
		    printf("%s%s: %d DEBUG2 %s/%d: Sending SIGUSR2 to pid %d\n",
		        Progname, TagName, Pid, __FILE__, __LINE__, Forker_pids[ind]);
	        kill(Forker_pids[ind], SIGUSR2);
        }
    }

}

/***********************************************************************
 * this function will count the number of errors encountered.
 * This function will call upanic if wanted or cleanup and
 * and exit is Maxerrs were encountered.
 ***********************************************************************/
int
handle_error()
{
    Errors++;

    if ( Maxerrs && Errors >= Maxerrs ) {
	printf("%s%s: %d %s/%d: %d Hit max errors value of %d\n", 
	    Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, Maxerrs);
	notify_others();
	cleanup();

        if ( Debug > 2 ) {
            printf("%s%s: %d DEBUG3 %d error(s) encountered\n",
                        Progname, TagName, Pid, Errors);
            printf("%s%s: %d DEBUG3 %s/%d: exiting with value of 1\n", Progname, TagName, Pid, __FILE__, __LINE__);
        }

	exit(1);
    }

    return 0;
}

/***********************************************************************
 *
 ***********************************************************************/
int
cleanup()
{
    int ind;

	if ( remove_files ) {
	    if ( Debug > 2 )
		printf("%s: %d DEBUG3 Removing all %d files\n", 
		    Progname, Pid, num_files);
	    for(ind=0; ind<=num_files; ind++) {
		unlink(filenames+(ind*PATH_MAX));
	    }
	}
	if ( using_random && Debug > 1 )
	    printf("%s%s: %d DEBUG2 Used random seed: %d\n",
		Progname, TagName, Pid, Seed);
	return 0;
}

/***********************************************************************
 *
 ***********************************************************************/
void
usage()
{
	fprintf(stderr,
	"Usage: %s%s [-bhEluy][[-g grow_incr][-i num][-t trunc_incr][-T trunc_inter]\n",
	Progname, TagName );
	fprintf(stderr,
	"[-d auto_dir][-e maxerrs][-f auto_file][-N num_files][-w][-c chk_inter][-D debug]\n");
	fprintf(stderr,
	"[-s seed][-S seq_auto_files][-p][-P PANIC][-I io_type][-o open_flags][-B maxbytes]\n");
	fprintf(stderr,
	"[-r iosizes][-R lseeks][-U unlk_inter][-W tagname] [files]\n");

	return;

}	/* end of usage */

/***********************************************************************
 *
 ***********************************************************************/
void
help()
{
	usage();

fprintf(stdout, "\
  -h             Specfied to print this help and exit.\n\
  -b             Specfied to execute in sync mode.(def async mode)\n\
  -B maxbytes    Max bytes to consume by all files.  growfiles exits when more\n\
                 than maxbytes have been consumed. (def no chk)  If maxbytes ends\n\
                 with the letter 'b', maxbytes is multiplied by BSIZE\n\
  -C write_chk   Specifies how often to check the last write (default 1)\n\
  -c file_chk    Specifies how often to check whole file (default 0)\n\
  -d auto_dir    Specifies the directory to auto created files. (default .)\n\
  -D debug_lvl   Specifies the debug level (default 1)\n\
  -E             Print examples and exit\n\
  -e errs        The number errors that will terminate this program (def 100)\n\
  -f auto_file   Specifies the base filename files created. (default \"gf\")\n\
  -g grow_incr   Specfied to grow by incr for each num. (default 4096)\n\
                 grow_incr may end in b for blocks\n\
		 If -r option is used, this option is ignored and size is random\n\
  -H delay       Amount of time to delay between each file (default 0.0)\n\
  -I io_type Specifies io type: s - sync, p - polled async, a - async (def s)\n\
		 l - listio sync, L - listio async, r - random\n\
  -i iteration   Specfied to grow each file num times. 0 means forever (default 1)\n\
  -l             Specfied to do file locking around write/read/trunc\n\
		 If specified twice, file locking after open to just before close\n\
  -L time        Specfied to exit after time secs, must be used with -i.\n\
  -N num_files   Specifies the number of files to be created.\n\
                 The default is zero if cmd line files.\n\
                 The default is one if no cmd line files.\n\
  -n num_procs   Specifies the number of copies of this cmd.\n\
  -o op_type     Specifies open flages: (def O_RDWR,O_CREAT) op_type can be 'random'\n\
  -O offset      adjust i/o buffer alignment by offset bytes\n\
  -P PANIC       Specifies to call upanic on error.\n\
  -p             Specifies to pre-allocate space\n\
  -q pattern     pattern can be a - ascii, p - pid with boff, o boff (def)\n\
		 A - Alternating bits, r - random, O - all ones, z - all zeros,\n\
		 c - checkboard, C - counting\n\
  -R [min-]max   random lseek before write and trunc, max of -1 means filesz,\n\
		 -2 means filesz+grow, -3 filesz-grow. (min def is 0)\n\
  -r [min-]max   random io write size (min def is 1)\n\
  -S seq_auto_files Specifies the number of seqental auto files (default 0)\n\
  -s seed[,seed...] Specifies the random number seed (default time(0)+pid)\n\
  -t trunc_incr  Specfied the amount to shrink file. (default 4096)\n\
                 trunc_inter may end in b for blocks\n\
		 If -R option is used, this option is ignored and trunc is random\n\
  -T trunc_inter Specfied the how many grows happen before shrink. (default 0)\n\
  -u             unlink files before exit\n\
  -U ui[-ui2]    Unlink files each ui iteration (def 0)\n\
  -w             Specfied to grow via lseek instead of writes.\n\
  -W tag-name	 Who-am-i.  My Monster tag name.  (used by Monster).\n\
  -x		 Re-exec children before continuing - useful on MPP systems\n\
  -y             Attempt to sync copies - if one fails it will send sigusr2 to others\n\
  Action to each file every iteration is open, write, write check\n\
  file check, trunc and closed.\n");

	return;
}

/***********************************************************************
 *
 ***********************************************************************/
void
prt_examples(FILE *stream)
{
	/* This example creates 200 files in directory dir1.  It writes */
	/* 4090 bytes 100 times then truncates 408990 bytes off the file */
	/* The file contents are checked every 1000 grow. */
    fprintf(stream,
	 "# run forever: writes of 4090 bytes then on every 100 iterval\n\
# truncate file by 408990 bytes.  Done to 200 files in dir1.\n\
%s -i 0 -g 4090 -T 100 -t 408990 -l -C 10 -c 1000 -d dir1 -S 200\n\n", Progname);

	/* same as above with 5000 byte grow and a 499990 byte tuncate */
    fprintf(stream,
	 "# same as above with writes of 5000 bytes and truncs of 499990\n\
%s -i 0 -g 5000 -T 100 -t 499990 -l -C 10 -c 1000 -d dir2 -S 200\n\n", Progname);

	/* This example beats on opens and closes */
    fprintf(stream,
	 "# runs forever: beats on opens and closes of file ocfile - no io\n\
%s -i 0 -g 0 -c 0 -C 0 ocfile\n\n", Progname);

    fprintf(stream,
	 "# writes 4096 to files until 50 blocks are written\n\
%s -i 0 -g 4096 -B 50b file1 file2\n\n", Progname);
	
    fprintf(stream,
	 "# write one byte to 750 files in gdir then unlinks them\n\
%s -g 1 -C 0 -d gdir -u -S 750\n\n", Progname);

    fprintf(stream,
	"# run 30 secs: random iosize, random lseek up to eof\n\
%s -r 1-5000 -R 0--1 -i 0 -L 30 -C 1 g_rand1 g_rand2\n\n", Progname);

    fprintf(stream,
	"# run 30 secs: grow by lseek then write single byte, trunc every 10 itervals\n\
%s -g 5000 -wlu -i 0 -L 30 -C 1 -T 10  g_sleek1 g_lseek2\n\n", Progname);

    fprintf(stream, 
	"# run forever: 5 copies of random iosize, random lseek to beyond eof,\n\
# rand io types doing a trunc every 5 iterations, with unlinks.\n\
%s -i0 -r 1-50000 -R 0--2 -I r -C1 -l -n5 -u -U 100-200 gf_rana gf_ranb\n\n", 
	    Progname);

    fprintf(stream, 
	"# run forever: 5 copies of random iosize, random lseek to beyond eof,\n\
# random open flags, rand io types doing a trunc every 10 iterations.\n\
%s -i0 -r 1-50000 -R 0--2 -o random -I r -C0 -l -T 20 -uU100-200 -n 5 gf_rand1 gf_rand2\n", 
	    Progname);


	return;
}

/***********************************************************************
 *
 * The file descriptor current offset is assumed to be the end of the
 * file.  
 * Woffset will be set to the offset before the write.
 * Grow_incr will be set to the size of the write or lseek write.
 ***********************************************************************/
int
growfile(fd, file, grow_incr, buf)
int fd;
char *file;
int grow_incr;
unsigned char *buf;
{
   int noffset;
   int ret;
   /* REFERENCED */
   int cur_offset;
   char *errmsg;
   int fsize;		/* current size of file */
   int size_grew;	/* size the file grew */
   struct stat stbuf;
   int tmp = 0;

        /*
         * Do a stat on the open file.
         * If the file is a fifo, set the bit in Mode variable.
         * This fifo check must be done prior to growfile() returning.
	 * Also get the current size of the file.
         */
        if ( fstat(fd, &stbuf) != -1 ) {
            if ( S_ISFIFO(stbuf.st_mode) ) {
		Fileinfo.mode |= MODE_FIFO;
                Mode |= MODE_FIFO;
                if ( Debug > 3 )
                    printf("%s: %d DEBUG4 %s/%d: file is a fifo - no lseek or truncs,\n",
                        Progname, Pid, __FILE__, __LINE__);
            }
	    fsize = stbuf.st_size;

        } else {
	    fprintf(stderr, "%s%s: %d %s/%d: Unable to fstat(%d, &buf), errno:%d %s\n",
		Progname, TagName, Pid, __FILE__, __LINE__, fd, errno, strerror(errno));

	    return -1;
	}


        if ( grow_incr <= 0 ) {   /* don't attempt i/o if grow_incr <= 0 */ 

	    Grow_incr=grow_incr;
	    if ( Debug > 2 )
		printf("%s: %d DEBUG3 %s/%d: Not attempting to grow, growsize == %d\n",
		    Progname, Pid, __FILE__, __LINE__, grow_incr);
	    return grow_incr;
	}

	if ( Mode & MODE_RAND_SIZE ) {
	    grow_incr=random_range(min_size, max_size, mult_size, &errmsg);
	    if (errmsg != NULL) {
		fprintf(stderr, "%s%s: %d %s/%d: random_range() failed - %s\n", Progname, TagName, Pid, __FILE__, __LINE__, errmsg);
		return -1;
	    }
	    Grow_incr=grow_incr;
	}
	else
	    Grow_incr=grow_incr;

	if ( ! (Mode & MODE_FIFO) ) {
	    if ((cur_offset=lseek(fd,0,SEEK_CUR)) == -1 ) {
	        fprintf(stderr, "%s%s: %d %s/%d: tell failed: %s\n",
		    Progname, TagName, Pid, __FILE__, __LINE__, strerror(errno));
	        return -1;
	    }
        }

	if ( Mode & MODE_GROW_BY_LSEEK ) {
                Woffset=fsize;
		if ( Debug > 2 ) {
		    printf("%s: %d DEBUG3 %s/%d: Current size of file is %d\n", Progname,
			Pid, __FILE__, __LINE__, Woffset);
		    printf("%s: %d DEBUG3 %s/%d: lseeking to %d byte with SEEK_END\n", Progname,
			Pid, __FILE__, __LINE__, grow_incr-1);
		}

		if ((noffset=lseek(fd, grow_incr-1, SEEK_END)) == -1 ) {
			fprintf(stderr, "%s%s: %s/%d: lseek(fd, %d, SEEK_END) failed: %s\n",
				Progname, TagName, __FILE__, __LINE__, grow_incr-1, strerror(errno));
			return -1;
		}

		lkfile(fd, LOCK_EX, LKLVL0);	 /* get exclusive lock */
		
#if NEWIO
		ret=lio_write_buffer(fd, io_type, "w", 1, SIGUSR1, &errmsg,0);
#else
		ret=write_buffer(fd, io_type, "w", 1, 0, &errmsg); 
#endif

		if ( ret != 1 ) {
			fprintf(stderr, "%s%s: %d %s/%d: %d %s\n", 
			    Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg);
			if ( ret == -ENOSPC ) {
				cleanup();
				exit(2);
			}
		}
/***
		write(fd, "w", 1);
****/

		lkfile(fd, LOCK_UN, LKLVL0);

                if ( Debug > 2 )
                    printf("%s: %d DEBUG3 %s/%d: %d wrote 1 byte to file\n",
                            Progname, Pid, __FILE__, __LINE__, Iter_cnt);

	} else {  /* end of grow by lseek */

		if ( Fileinfo.openflags & O_APPEND ) {
		   /*
		    * Deal with special case of the open flag containing O_APPEND.
		    * If it does, the current offset does not matter since the write
		    * will be done end of the file.
		    */
		    if ( Debug > 4 )
			printf("%s: %d DEBUG5 %s/%d: dealing with O_APPEND condition\n",
			    Progname, Pid, __FILE__, __LINE__ );
		    lkfile(fd, LOCK_EX, LKLVL0);	 /* get exclusive lock */

		    /*
		     * do fstat again to get size of the file.
		     * This is done inside a file lock (if locks are being used).
		     */
        	    if ( fstat(fd, &stbuf) != -1 ) {
            		Woffset = stbuf.st_size;
        	    } else {
            		fprintf(stderr, "%s%s: %d %s/%d: Unable to fstat(%d, &buf), errno:%d %s\n",
                	Progname, TagName, Pid, __FILE__, __LINE__, fd, errno, strerror(errno));
	
			lkfile(fd, LOCK_UN, LKLVL0);     /* release lock */
            		return -1;
        	    }
		    if ( Debug > 2 )
			printf("%s: %d DEBUG3 %s/%d: dealing with O_APPEND condition (offset:fsz:%d)\n",
			    Progname, Pid, __FILE__, __LINE__, (int)stbuf.st_size);


		} else if ( Mode & MODE_RAND_LSEEK ) {
                   if ( max_lseek == LSK_EOF ) {	/* within file size */
                        noffset=random_range(min_lseek, fsize, 1, NULL);
                   }		
		   else if ( max_lseek == LSK_EOFPLUSGROW ) {	
		        /* max to beyond file size */
			noffset=random_range(min_lseek, fsize+grow_incr, 1, NULL);
		   }
		   else if ( max_lseek == LSK_EOFMINUSGROW ) {	
		        /* 
			 * Attempt to not grow the file.
			 * If the i/o will fit from min_lseek to EOF,
			 * pick offset to allow it to fit.
			 * Otherwise, pick the min_lseek offset and grow
			 * file by smallest amount.
			 * If min_lseek is != 0, there will be a problem
			 * with whole file checking if file is ever smaller
			 * than min_lseek.
			 */
			if ( fsize <= min_lseek + grow_incr )
			    noffset=min_lseek;  /* file will still grow */
			else
			    noffset=random_range(min_lseek, fsize-grow_incr, 1, NULL);
		   }
                   else {
                        noffset=random_range(min_lseek, max_lseek, 1, NULL);
                   }

		   if ((Woffset=lseek(fd, noffset, SEEK_SET)) == -1 ) {
                        fprintf(stderr, "%s%s: %d %s/%d: lseek(%d, %d, SEEK_SET) l2 failed: %s\n",
                                Progname, TagName, Pid, __FILE__, __LINE__, fd, noffset, strerror(errno));
                        return -1;
		   }
                   else if ( Debug > 2 )
                        printf("%s: %d DEBUG3 %s/%d: lseeked to random offset %d (fsz:%d)\n",
                            Progname, Pid, __FILE__, __LINE__, Woffset,
			    (int)stbuf.st_size);

                }

		/*
		 * lseek to end of file only if not fifo
		 */
		else if ( ! (Mode & MODE_FIFO) ) {
		    if ((Woffset=lseek(fd, 0, SEEK_END)) == -1 ) {
			fprintf(stderr, "%s%s: %d %s/%d: lseek(fd, 0, SEEK_END) failed: %s\n",
				Progname, TagName, Pid, __FILE__, __LINE__, strerror(errno));
			return -1;
		    }
                    else if ( Debug > 2 )
                        printf("%s: %d DEBUG3 %s/%d: lseeked to end of file, offset %d\n",
                            Progname, Pid, __FILE__, __LINE__, Woffset);
		}

		if ( Pattern == PATTERN_OFFSET )
		    datapidgen(STATIC_NUM, buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_PID )
		    datapidgen(Pid, buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_ASCII )
		    dataasciigen(NULL, (char *)buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_RANDOM )
		    databingen('r', buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_ALT )
		    databingen('a', buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_CHKER )
		    databingen('c', buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_CNTING )
		    databingen('C', buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_ZEROS )
		    databingen('z', buf, grow_incr, Woffset);
		else if ( Pattern == PATTERN_ONES )
		    databingen('o', buf, grow_incr, Woffset);
		else
		    dataasciigen(NULL, (char *)buf, grow_incr, Woffset);

		if ( Debug > 2 )
		    printf("%s: %d DEBUG3 %s/%d: attempting to write %d bytes\n",
			Progname, Pid, __FILE__, __LINE__, grow_incr);

		lkfile(fd, LOCK_EX, LKLVL0);	 /* get exclusive lock */

/*****
		ret=write(fd, buf, grow_incr);

		tmp=tell(fd);

		lkfile(fd, LOCK_UN, LKLVL0);	

		if ( ret != grow_incr) {
			fprintf(stderr, "%s: %s/%d: write failed: %s\n",
				Progname, __FILE__, __LINE__, strerror(errno));
			return -1;
		}
*****/

#if NEWIO
		ret=lio_write_buffer(fd, io_type, (char *)buf, grow_incr,
			 SIGUSR1, &errmsg,0);
#else
		ret=write_buffer(fd, io_type, buf, grow_incr, 0, &errmsg);
#endif

		if( Mode & MODE_FIFO ){
			/* If it is a fifo then just pretend the file
			 * offset is where we think it should be.
			 */
			tmp = Woffset + grow_incr;
		}
		else{
			if( (tmp=lseek(fd,0,SEEK_CUR)) < 0 ){ /* get offset after the write */
				fprintf(stderr, "%s%s: %s/%d: tell(2) failed: %d  %s\n",
					Progname, TagName, __FILE__, __LINE__, errno, strerror(errno) );
				return -1;
			}
		}

		lkfile(fd, LOCK_UN, LKLVL0);	

		if ( ret != grow_incr ) {
			fprintf(stderr, "%s%s: %d %s/%d: %d %s\n", 
			    Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg);
			if ( ret == -ENOSPC ) {
				cleanup();
				exit(2);
			}
			return -1;
		}

		/*
		 * Check for a condition where the file was truncated just before
		 * the write. 
		 */
		if ( tmp != Woffset + grow_incr) {
		    /*
		     * The offset after the write was not as expected.
		     * This could be caused by the following:
		     *  - file truncated after the lseek and before the write.
		     *  - the file was written to after fstat and before the write
		     *    and the file was opened with O_APPEND.
		     *
		     * The pattern written to the file will be considered corrupted.
		     */
		    if ( Debug > 0 && lockfile ) {
		        printf("%s%s: %d DEBUG1 %s/%d: offset after write(%d) not as exp(%d+%d=%d)\n", 	
			    Progname, TagName, Pid, __FILE__, __LINE__, tmp, Woffset, grow_incr, Woffset+grow_incr);
			printf("%s%s: %d DEBUG1 %s/%d: %d Assuming file changed by another process, resetting offset:%d (expect pattern mismatch)\n",
				Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, tmp-grow_incr);
		    }
		    if( Debug > 4 ){
			printf("%s: %d DEBUG5 %s/%d: about to chop Woffset.  tmp=%d, grow_incr=%d, Woffset was %d\n",
			       Progname, Pid, __FILE__, __LINE__, tmp, grow_incr, Woffset);
		    }
		    Woffset=tmp-grow_incr;
		    if( Woffset < 0 )
			Woffset = 0;
		}

	}  /* end of grow by write */


	/*
	 * Woffset - holds start of grow (start of write expect in grow by lseek)
	 * Grow_incr - holds size of grow (write).
	 * fsize - holds size of file before write
	 */
	size_grew=(Woffset + Grow_incr) - fsize;
	if ( Debug > 1) {
	     if ( Mode & MODE_FIFO ) {
		printf("%s: %d DEBUG2 %s/%d: file is fifo, %d wrote %d bytes\n",
		    Progname, Pid, __FILE__, __LINE__, Grow_incr, Iter_cnt);
	     }

	     else if ( size_grew > 0 )
		printf("%s: %d DEBUG2 %s/%d: %d wrote %d bytes(off:%d), grew file by %d bytes\n",
                        Progname, Pid, __FILE__, __LINE__, Iter_cnt, Grow_incr, Woffset, size_grew);
	     else
		printf("%s: %d DEBUG2 %s/%d: %d wrote %d bytes(off:%d), did not grow file\n",
                        Progname, Pid, __FILE__, __LINE__, Iter_cnt, Grow_incr, Woffset);
	}

    	bytes_consumed += size_grew;
	return 0;

}	/* end of growfile */

/***********************************************************************
 * shrinkfile file by trunc_incr.  file can not be made smaller than
 * size zero.  Therefore, if trunc_incr is larger than file size,
 * file will be truncated to zero.
 * The file descriptor current offset is assumed to be the end of the
 * file.
 *
 ***********************************************************************/
int
shrinkfile(fd, filename, trunc_incr, trunc_inter, just_trunc)
int fd;
char *filename;
int trunc_incr;
int trunc_inter;	/* interval */
int just_trunc;		/* lseek has already been done for you */
{
    static int shrink_cnt = 0;
    int cur_offset;
    int new_offset;
    int ret;

	shrink_cnt++;

	if ( trunc_inter == 0 || (shrink_cnt % trunc_inter != 0))  {
	    if ( Debug > 3 )
		printf("%s: %d DEBUG4 %s/%d: Not shrinking file - not time, iter=%d, cnt=%d\n",
		    Progname, Pid, __FILE__, __LINE__, trunc_inter, shrink_cnt);
	    return 0;	/* not this time */
	}

	if ( Mode & MODE_FIFO ) {
	    if ( Debug > 5 )
		printf("%s: %d DEBUG5 %s/%d: Not attempting to shrink a FIFO\n",
		    Progname, Pid, __FILE__, __LINE__);
	    return 0;	/* can not truncate fifo */
	}

	lkfile(fd, LOCK_EX, LKLVL0);

	if ((cur_offset=lseek(fd,0,SEEK_CUR)) == -1 ) {
	    fprintf(stderr, "%s%s: %d %s/%d: tell(%d) failed: %s\n",
		Progname, TagName, Pid, __FILE__, __LINE__, fd, strerror(errno));
	    lkfile(fd, LOCK_UN, LKLVL0);
	    return -1;
	}

        if ( Mode & MODE_RAND_LSEEK ) {
            if ( max_lseek <= -1 ) {
                if ( (new_offset=file_size(fd)) == -1 ) {
	            lkfile(fd, LOCK_UN, LKLVL0);
		    return -1;
		}
			
		if ( new_offset < min_lseek )
		    new_offset=min_lseek;
		else
                    new_offset=random_range(min_lseek, new_offset, 1, NULL);
            }
            else {
                new_offset=random_range(min_lseek, max_lseek, 1, NULL);
            }
        }

	else {	/* remove trunc_incr from file */

	    new_offset = cur_offset-trunc_incr;

	    if ( new_offset < 0 )
		new_offset=0;
	}

	ret=ftruncate(fd, new_offset );
	if( (ret == 0) && (Debug > 3) ){
                printf("%s: %d DEBUG4 %s/%d: ftruncated to offset %d, %d bytes from end\n",
                    Progname, Pid, __FILE__, __LINE__, new_offset, trunc_incr);
	}

	lkfile(fd, LOCK_UN, LKLVL0);

	if ( ret == -1 ) {
		fprintf(stderr, "%s%s: %d %s/%d: ftruncate failed: %s\n",
			Progname, TagName, Pid, __FILE__, __LINE__, strerror(errno));
		return -1;
	}

	if ( Debug > 2 ) {
	    printf("%s: %d DEBUG2 %s/%d: trunc file by %d bytes, to size of = %d bytes\n",
		Progname, Pid, __FILE__, __LINE__, cur_offset-new_offset, new_offset);
	}
	

        bytes_consumed -= (cur_offset - new_offset);
	return 0;

}	/* end of shrinkfile */

/***********************************************************************
 *
 ***********************************************************************/
int
check_write(fd, cf_inter, filename, mode)
int fd;
int cf_inter;   /* check file interval */
char *filename; /* needed for error messages */
int mode;       /* write mode */
{
    int fsize;
    static int cf_count = 0;
    int ret = 0;
    int tmp;
    char *errmsg;
    char *ptr;

    cf_count++;

    if ( cf_inter == 0 || (cf_count % cf_inter != 0)) {
	if ( Debug > 4 )
	    printf("%s: %d DEBUG5 %s/%d: no write check, not time iter=%d, cnt=%d\n",
		Progname, Pid, __FILE__, __LINE__, cf_inter, cf_count);
	return 0;	 /* no check done */
    }

    if ( Grow_incr <= 0 ) {
        if ( Debug > 3 )
	    printf("%s: %d DEBUG4 %s/%d: No write validation,  Grow_incr = %d, offset = %d\n",
	        Progname, Pid, __FILE__, __LINE__, Grow_incr, Woffset);
        return 0;	/* no check */
    }


    
    /*	
     * Get the shared file lock.  We need to hold the lock from before
     * we do the stat until after the read.
     */
    lkfile(fd, LOCK_SH, LKLVL0);

    if ((fsize=file_size(fd)) == -1 )  {
        lkfile(fd, LOCK_UN, LKLVL0);
        return -1;

    } else if ( fsize <= Woffset ) {
	/*
	 * The file was truncated between write and now.
	 * The contents of our last write is totally gone, no check.
	 */
	if ( Debug > 1 )
	    printf("%s%s: %d DEBUG2 %s/%d: %d File size (%d) smaller than where last wrote (%d)- no write validation\n",
		Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, fsize, Woffset);
        lkfile(fd, LOCK_UN, LKLVL0);
        return 0;	/* no validation, but not an error */
 
    } else if ( fsize < (Woffset + Grow_incr)) {
	/*
	 * The file was truncated between write and now.
	 * Part of our last write has been truncated, adjust our Grow_incr
	 * to reflect this.
	 */

	tmp=Grow_incr;
	Grow_incr=fsize-Woffset;

	if ( Debug > 1 )  {

	    printf("%s%s: %d DEBUG2 %s/%d: %d fsz:%d, lost(%d)of wrt(off:%d, sz:%d), adj=%d\n",
	    Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, fsize, tmp-Grow_incr, Woffset, tmp, Grow_incr);
	}

    }

    if ( Debug > 2 )
        printf("%s: %d DEBUG3 %s/%d: about to do write validation, offset = %d, size = %d\n",
	    Progname, Pid, __FILE__, __LINE__, Woffset, Grow_incr);

    if ( ! (mode & MODE_FIFO)  ) {

        if ( lseek(fd, Woffset, 0) == -1 ) {
            fprintf(stderr, "%s%s: %d %s/%d: lseek(fd, %d, 0) failed: %s\n",
	        Progname, TagName, Pid, __FILE__, __LINE__, Woffset, strerror(errno));
        }
        if ( Debug > 3 )
	    printf("%s: %d DEBUG4 %s/%d: lseeked to offset:%d\n",
	        Progname, Pid, __FILE__, __LINE__, Woffset);
    }

    /*
     * Read last writes data
     */
#if NEWIO
    ret=lio_read_buffer(fd, io_type, Buffer, Grow_incr, SIGUSR1, &errmsg,0);
#else
    ret=read_buffer(fd, io_type, Buffer, Grow_incr, 0, &errmsg);
#endif

    /*
     * report the error and debug information before releasing
     * the file lock
     */
    if ( ret != Grow_incr ) {
        fprintf(stderr, "%s%s: %d %s/%d: %d CW %s\n", Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg);
        {
	    struct stat stbuf;
	    fstat(fd, &stbuf);
	    if ( Debug > 2 )
	        printf("%s%s: %d DEBUG3 %s/%d: fd:%d, offset:%d, fsize:%d, openflags:%#o\n",
	            Progname, TagName, Pid, __FILE__, __LINE__, fd,
		    (int)lseek(fd,SEEK_CUR,0),	/* FIXME: 64bit/LFS ? */
		    (int)stbuf.st_size,
		    Fileinfo.openflags);
        }

	lkfile(fd, LOCK_UN, LKLVL0);
	return 1;
    }


    lkfile(fd, LOCK_UN, LKLVL0);

    if ( Mode & MODE_GROW_BY_LSEEK ) {
	/* check that all zeros upto last character */
	for(ptr=Buffer; ptr < (Buffer+Grow_incr-1); ptr++) {
	    if ( *ptr != '\0' ) {
	        fprintf(stderr,
		    "%s%s: %d %s/%d: data mismatch at offset %d, exp:%#o(zerofilled), act:%#o in file %s\n",
		    Progname, TagName, Pid, __FILE__, __LINE__, 
		    (int)(Woffset+(Grow_incr-(Buffer-ptr))),
		    0, *ptr, filename);
	        fflush(stderr);
		return 1;
	    }
	}
	/* check that the last char is a 'w' */
	if ( *ptr != 'w' ) {
	    fprintf(stderr,
	  "%s%s: %d %s/%d: data mismatch at offset %d, exp:%#o(zerofilled), act:%#o in file %s\n",
	        Progname, TagName, Pid, __FILE__, __LINE__, 
		(int)(Woffset+(Grow_incr-(Buffer-ptr))), 'w',
		*ptr, filename);
	    fflush(stderr);
	    return 1;
	}
	return 0;   /* all is well */
	
    }
    else if ( Pattern == PATTERN_OFFSET )
	ret=datapidchk(STATIC_NUM, Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_PID )
	ret=datapidchk(Pid, Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_ASCII )
        ret=dataasciichk(NULL, Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_RANDOM )
	;	/* no check for random */
    else if ( Pattern == PATTERN_ALT )
        ret=databinchk('a', Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_CHKER )
        ret=databinchk('c', Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_CNTING )
  	ret=databinchk('C', Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_ZEROS )
    	ret=databinchk('z', Buffer, Grow_incr, Woffset, &errmsg);
    else if ( Pattern == PATTERN_ONES )
    	ret=databinchk('o', Buffer, Grow_incr, Woffset, &errmsg);
    else
	ret=dataasciichk(NULL, Buffer, Grow_incr, Woffset, &errmsg);

    if ( ret >= 0 ) {
	fprintf(stderr, "%s%s: %d %s/%d: %d CW %s in file %s\n",
		Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg, filename);

	if ( Debug > 0 )
	    printf("%s%s: %d DEBUG1 %s/%d: **fd:%d, lk:%d, offset:%d, sz:%d open flags:%#o %s\n",
		Progname, TagName, Pid, __FILE__, __LINE__, fd, lockfile, 
		Woffset, Grow_incr, Fileinfo.openflags, openflags2symbols(Fileinfo.openflags, ",", 0));

	fflush(stderr);
	return 1;
    }

    if ( Debug > 6 )
        printf("%s: %d DEBUG7 %s/%d: No corruption detected on write validation , offset = %d, size = %d\n",
            Progname, Pid, __FILE__, __LINE__, Woffset, Grow_incr);

    return 0;	/* all is well */
}



/***********************************************************************
 *
 ***********************************************************************/
int
check_file(fd, cf_inter, filename, no_file_check)
int fd;
int cf_inter;	/* check file interval */
char *filename;	/* needed for error messages */
int no_file_check;	/* if set, do not do file content check */
{
    int fsize;
    static int cf_count = 0;
    char *buf;
    int ret;
    int ret_val = 0;
    int rd_cnt;
    int rd_size;
    char *errmsg;

	cf_count++;

	if ( cf_inter == 0 || (cf_count % cf_inter != 0)) {
		if ( Debug > 4 )
		    printf("%s: %d DEBUG5 %s/%d: No file check - not time, iter=%d, cnt=%d\n",
			Progname, Pid, __FILE__, __LINE__, cf_inter, cf_count);
		return 0;	 /* no check done */
	}

	/*
	 * if we can't determine file content, don't bother checking
	 */
        if ( no_file_check ) {
		if ( Debug > 4 )
		    printf("%s: %d DEBUG5 %s/%d: No file check, lseek grow or random lseeks\n",
			Progname, Pid, __FILE__, __LINE__);
		return 0;
	}

	/*
	 * Lock the file.  We need to have the file lock before
	 * the stat and until after the last read to prevent
	 * a trunc/truncate from "corrupting" our data.
	 */
	lkfile(fd, LOCK_SH, LKLVL0);
	
	if ((fsize=file_size(fd)) == -1 )  {
	    lkfile(fd, LOCK_UN, LKLVL0);
	    return -1;
	}

        if ( fsize == 0 ) {
	    if ( Debug > 2 )
            printf("%s: %d DEBUG3 %s/%d: No file validation, file size == 0\n",
                Progname, Pid, __FILE__, __LINE__);

	    lkfile(fd, LOCK_UN, LKLVL0);
	    return 0;
	}

	if ( Debug > 2 )
            printf("%s: %d DEBUG3 %s/%d: about to do file validation\n",
	        Progname, Pid, __FILE__, __LINE__);

        if ( fsize > MAX_FC_READ ) {
	    /*
	     * read the file in MAX_FC_READ chuncks.
	     */

	    if ((buf=(char *)malloc(MAX_FC_READ)) == NULL ) {
	        fprintf(stderr, "%s%s: %s/%d: malloc(%d) failed: %s\n", Progname, TagName,
		    __FILE__, __LINE__, MAX_FC_READ, strerror(errno));
	       lkfile(fd, LOCK_UN, LKLVL0);
	       return -1;
	    }

	    lseek(fd, 0, SEEK_SET);

	    lkfile(fd, LOCK_SH, LKLVL0);  /* get lock on file before getting file size */

	    rd_cnt=0;
	    while (rd_cnt < fsize ) {
	        if ( fsize - rd_cnt > MAX_FC_READ )
		    rd_size=MAX_FC_READ;
	        else
		    rd_size=fsize - rd_cnt;
				
#if NEWIO
	        ret=lio_read_buffer(fd, io_type, buf, rd_size,
		    SIGUSR1, &errmsg,0);
#else
	        ret=read_buffer(fd, io_type, buf, rd_size, 0, &errmsg);
#endif

	        if (ret != rd_size ) {
		    fprintf(stderr, "%s%s: %d %s/%d: %d CFa %s\n", 
			Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg);
		    free(buf);
		    lkfile(fd, LOCK_UN, LKLVL0);
		    return -1;
	        }
/**
	        read(fd, buf, rd_size);
***/

	        if ( Pattern == PATTERN_OFFSET )
	            ret=datapidchk(STATIC_NUM, buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_PID )
	            ret=datapidchk(Pid, buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_ASCII )
	            ret=dataasciichk(NULL, buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_RANDOM )
	   	  	;  /* no checks for random */
	        else if ( Pattern == PATTERN_ALT )
	            ret=databinchk('a', buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_CHKER )
	            ret=databinchk('c', buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_CNTING )
	            ret=databinchk('C', buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_ZEROS )
	            ret=databinchk('z', buf, rd_size, rd_cnt, &errmsg);
	        else if ( Pattern == PATTERN_ONES )
	            ret=databinchk('o', buf, rd_size, rd_cnt, &errmsg);
	        else
	            ret=dataasciichk(NULL, buf, rd_size, rd_cnt, &errmsg);
		
		    
	        if ( ret >= 0 ) {
		    fprintf(stderr,
		        "%s%s: %d %s/%d: %d CFp %s in file %s\n",
		        Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg, filename);
		    fflush(stderr);
		    ret_val=1;
		    lkfile(fd, LOCK_UN, LKLVL0);
		    break;
	        }
	        rd_cnt += rd_size;
	    }

	    lkfile(fd, LOCK_UN, LKLVL0);

	    free(buf);

	}
	else {
	    /*
	     * Read the whole file in a single read 
	     */
	    if((buf=(char *)malloc(fsize)) == NULL ) {
			fprintf(stderr, "%s%s: %s/%d: malloc(%d) failed: %s\n", Progname, TagName,
				__FILE__, __LINE__, fsize, strerror(errno));
			fflush(stderr);
			return -1;
	    }

	    lseek(fd, 0, SEEK_SET);

/****
	    read(fd, buf, fsize);
****/
#if NEWIO
	    ret=lio_read_buffer(fd, io_type, buf, fsize, SIGUSR1, &errmsg,0);
#else
	    ret=read_buffer(fd, io_type, buf, fsize, 0, &errmsg);
#endif

	    /* unlock the file as soon as we can */
	    lkfile(fd, LOCK_UN, LKLVL0);


	    if ( ret != fsize ) {
		fprintf(stderr, "%s%s: %d %s/%d: %d CFw %s\n", 
		    Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg);
		ret_val=1;
	    }
	    else  {
	        if ( Pattern == PATTERN_OFFSET )
		    ret=datapidchk(STATIC_NUM, buf, fsize, 0, &errmsg);
	        else if ( Pattern == PATTERN_PID )
		    ret=datapidchk(Pid, buf, fsize, 0, &errmsg);
		else if ( Pattern == PATTERN_ASCII )
		    ret=dataasciichk(NULL, buf, fsize, 0, &errmsg);
		else if ( Pattern == PATTERN_RANDOM )
		    ;	/* no check for random */
		else if ( Pattern == PATTERN_ALT )
		    ret=databinchk('a', buf, fsize, 0, &errmsg);
		else if ( Pattern == PATTERN_CHKER )
		    ret=databinchk('c', buf, fsize, 0, &errmsg);
		else if ( Pattern == PATTERN_CNTING )
		    ret=databinchk('C', buf, fsize, 0, &errmsg);
		else if ( Pattern == PATTERN_ZEROS )
		    ret=databinchk('z', buf, fsize, 0, &errmsg);
		else if ( Pattern == PATTERN_ONES )
		    ret=databinchk('o', buf, fsize, 0, &errmsg);
		else
		    ret=dataasciichk(NULL, buf, fsize, 0, &errmsg);

		if ( ret >= 0 ) {
		    fprintf(stderr, "%s%s: %d %s/%d: %d CFw %s in file %s\n",
			Progname, TagName, Pid, __FILE__, __LINE__, Iter_cnt, errmsg, filename);
		    fflush(stderr);
		    ret_val=1;
		}
	    }
	    free(buf);
	}

	return ret_val;

}	/* end of check_file */

/***********************************************************************
 *
 ***********************************************************************/
int
file_size(int fd)
{
    struct stat sb;

        if (fstat(fd, &sb) < 0) {
            fprintf(stderr, "%s%s: %d %s/%d: Unable to fstat(%d, &buf), errno:%d %s\n",
                Progname, TagName, Pid, __FILE__, __LINE__, fd, errno, strerror(errno));
	    return -1;
	
        }

        return sb.st_size;
}

/***********************************************************************
 *  do file lock/unlock action.
 ***********************************************************************/
int
lkfile(int fd, int operation, int lklevel)
{
    char *errmsg;

    
    if ( lockfile == lklevel) {
	
        if ( Debug > 5 ) {
	    switch (operation) {
 	    case LOCK_UN:
	        printf("%s: %d DEBUG6 %s/%d: Attempting to release lock on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, fd);
		break;

 	    case LOCK_SH:
	        printf("%s: %d DEBUG6 %s/%d: Attempting to get read/shared lock on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, fd);
		break;

 	    case LOCK_EX:
	        printf("%s: %d DEBUG6 %s/%d: Attempting to get write/exclusive lock on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, fd);
		break;
	    }
	}

	/*
	 * Attempt to get/release desired lock.
	 * file_lock will attempt to do action over and over again until
	 * either an unretryable error or the action is completed.
	 */

        if ( file_lock(fd, operation, &errmsg) != 0 ) {
	    printf("%s%s: %d %s/%d: Unable to perform lock operation. %s\n",
		Progname, TagName, Pid, __FILE__, __LINE__, errmsg);

	    /* do we count this as an error? handle_error();  */
	    return -1;
        }

        if ( Debug > 2 ) {
	    switch (operation) {
 	    case LOCK_UN:
	        printf("%s: %d DEBUG3 %s/%d: Released lock on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, fd);
		break;

 	    case LOCK_SH:
	        printf("%s: %d DEBUG3 %s/%d: Got read/shared lock on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, fd);
		break;

 	    case LOCK_EX:
	        printf("%s: %d DEBUG3 %s/%d: Got write/exclusive lock on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, fd);
		break;
	
	    default:
	        printf("%s: %d DEBUG3 %s/%d: Completed action %d on fd %d\n", 
		    Progname, Pid, __FILE__, __LINE__, operation, fd);
		break;
	    }
	}
   }

   return 0;
}

/***********************************************************************
 *
 ***********************************************************************/
int
pre_alloc(file, fd, size)
char *file;
int fd;
int size;
{

#ifdef XFS_IOC_RESVSP
    struct xfs_flock64 f;

	f.l_whence = 0;
	f.l_start = 0;
	f.l_len = size;

	/* non-zeroing reservation */
	if( xfsctl( file, fd, XFS_IOC_RESVSP, &f ) == -1 ){
                fprintf(stderr, "%s%s %s/%d: Unable to pre-alloc space: xfsctl(XFS_IOC_RESVSP) failed: %d  %s\n",
			Progname, TagName,
                        __FILE__, __LINE__, errno, strerror(errno));
		return -1;
	}
#else
    struct flock64 f;

	f.l_whence = 0;
	f.l_start = 0;
	f.l_len = size;

	/* non-zeroing reservation */
	if( fcntl( fd, F_RESVSP64, &f ) == -1 ){
                fprintf(stderr, "%s%s %s/%d: Unable to pre-alloc space: fcntl(F_RESVSP) failed: %d  %s\n",
			Progname, TagName,
                        __FILE__, __LINE__, errno, strerror(errno));
		return -1;
	}
#endif

	return 0;
}