blob: abc2aa960bacfdf74665bb05956d29f00de6de63 [file] [log] [blame]
/*
* 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/SGIGPLNoticeExplan/
*/
/** @file
@brief File system stress test.
This version of SGI fsstress has been modified to be single-threaded and to
work with the Reliance Edge POSIX-like API.
*/
#include <stdio.h>
#include <stdlib.h>
#include <limits.h>
#include <string.h>
#include <stdarg.h>
#include <time.h>
#include <redposix.h>
#include <redtests.h>
#if FSSTRESS_SUPPORTED
#include "redposixcompat.h"
#include <redosserv.h>
#include <redutils.h>
#include <redmacs.h>
#include <redvolume.h>
#include <redgetopt.h>
#include <redtoolcmn.h>
#if REDCONF_CHECKER == 1
#include <redcoreapi.h>
#endif
/* Create POSIX types. Use #define to avoid name conflicts in those
environments where the type names already exist.
*/
#define off_t int64_t
#define off64_t off_t
#define ino_t uint32_t
#define mode_t uint16_t
#define __int64_t int64_t
/** @brief Generate a random number.
@return A nonnegative random number.
*/
#define random() ((int)(RedRand32(NULL) & 0x7FFFFFFF))
/** @brief Seed the random number generator.
*/
#define srandom(seed) RedRandSeed(seed)
#define _exit(status) exit(status)
#define getpagesize() 4096U
#define getpid() 1
/** @brief Determine the maximum file size.
This is used for the MAXFSSIZE macro.
*/
static uint64_t MaxFileSize(void)
{
REDSTATFS info;
int32_t iStatus;
REDSTATUS errnoSave = errno;
uint64_t ullMaxFileSize;
iStatus = red_statvfs("", &info);
if(iStatus == 0)
{
ullMaxFileSize = info.f_maxfsize;
}
else
{
/* This function does not change errno.
*/
errno = errnoSave;
ullMaxFileSize = 0x7FFFFFFFU;
}
return ullMaxFileSize;
}
/*-------------------------------------------------------------------
Simulated current working directory support
-------------------------------------------------------------------*/
/* Forward declaration for red_chdir().
*/
static int red_stat(const char *pszPath, REDSTAT *pStat);
/* The simulated CWD functions.
*/
#undef chdir
#undef getcwd
#define chdir(path) red_chdir(path)
#define getcwd(buf, size) red_getcwd(buf, size)
/* Redefine the path-based APIs to call MakeFullPath() on their arguments
since there is no CWD support in the red_*() APIs.
*/
#undef open
#undef unlink
#undef mkdir
#undef rmdir
#undef rename
#undef link
#undef opendir
#define open(path, oflag) red_open(MakeFullPath(path), oflag)
#define unlink(path) red_unlink(MakeFullPath(path))
#define mkdir(path) red_mkdir(MakeFullPath(path))
#define rmdir(path) red_rmdir(MakeFullPath(path))
#define rename(old, new) red_rename(MakeFullPath(old), MakeFullPath(new))
#define link(path, hardlink) red_link(MakeFullPath(path), MakeFullPath(hardlink))
#define opendir(path) red_opendir(MakeFullPath(path))
#define FSSTRESS_BUF_SIZE 1024U
/* Stores the simulated current working directory.
*/
static char szLocalCwd[FSSTRESS_BUF_SIZE] = "/";
/** @brief Change the current working directory.
This function only supports a subset of what is possible with POSIX chdir().
@param pszPath The new current working directory.
@return Upon successful completion, 0 shall be returned. Otherwise, -1
shall be returned, and errno shall be set to indicate the error.
*/
static int red_chdir(
const char *pszPath)
{
uint32_t ulIdx;
int iErrno = 0;
if(strcmp(pszPath, "..") == 0)
{
uint32_t ulLastSlashIdx = 0U;
/* Chop off the last path separator and everything after it, so that
"/foo/bar/baz" becomes "/foo/bar", moving the CWD up one directory.
*/
for(ulIdx = 0U; szLocalCwd[ulIdx] != '\0'; ulIdx++)
{
if(szLocalCwd[ulIdx] == '/')
{
ulLastSlashIdx = ulIdx;
}
}
if(ulLastSlashIdx != 0U)
{
szLocalCwd[ulLastSlashIdx] = '\0';
}
}
else
{
char szOldCwd[FSSTRESS_BUF_SIZE];
/* chdir() must have no effect on the CWD if it fails, so save the CWD
so we can revert it if necessary.
*/
strcpy(szOldCwd, szLocalCwd);
if(pszPath[0U] == '/')
{
if(strlen(pszPath) >= sizeof(szLocalCwd))
{
iErrno = RED_ENAMETOOLONG;
}
else
{
strcpy(szLocalCwd, pszPath);
}
}
else
{
ulIdx = strlen(szLocalCwd);
if((ulIdx + 1U + strlen(pszPath)) >= sizeof(szLocalCwd))
{
iErrno = RED_ENAMETOOLONG;
}
else
{
if(szLocalCwd[1U] != '\0')
{
szLocalCwd[ulIdx] = '/';
ulIdx++;
}
strcpy(&szLocalCwd[ulIdx], pszPath);
}
}
if(iErrno == 0)
{
REDSTAT s;
int iStatus;
iStatus = red_stat(szLocalCwd, &s);
if(iStatus != 0)
{
iErrno = errno;
}
else if(!S_ISDIR(s.st_mode))
{
iErrno = RED_ENOTDIR;
}
else
{
/* No error, new CWD checks out.
*/
}
}
if(iErrno != 0)
{
strcpy(szLocalCwd, szOldCwd);
}
}
if(iErrno != 0)
{
errno = iErrno;
}
return iErrno == 0 ? 0 : -1;
}
/** @brief Retrieve the current working directory.
@param pszBuf On successful return, populated with the current working
directory. If NULL, memory will be allocated for the CWD
and returned by this function.
@param nSize The size of @p pszBuf.
@return On success, if @p pszBuf was non-NULL, returns @p pszBuf; if
@p pszBuf was NULL, returns an allocated buffer populated with the
CWD which must be freed by the caller. On failure, returns NULL
and errno will be set.
*/
static char *red_getcwd(
char *pszBuf,
size_t nSize)
{
char *pszRet;
if(pszBuf == NULL)
{
pszRet = malloc(strlen(szLocalCwd) + 1U);
if(pszRet == NULL)
{
errno = RED_ENOMEM;
}
else
{
strcpy(pszRet, szLocalCwd);
}
}
else if(nSize < strlen(szLocalCwd) + 1U)
{
errno = RED_ERANGE;
pszRet = NULL;
}
else
{
strcpy(pszBuf, szLocalCwd);
pszRet = pszBuf;
}
return pszRet;
}
/** @brief Make a relative path into a fully qualified path.
@param pszName The relative path.
@return On success, a pointer to a fully qualified path. On error, NULL.
*/
static const char *MakeFullPath(
const char *pszName)
{
#define MAXVOLNAME 64U /* Enough for most configs. */
static char aszFullPath[2U][MAXVOLNAME + 1U + FSSTRESS_BUF_SIZE];
static uint32_t ulWhich = 0U;
char *pszFullPath = aszFullPath[ulWhich];
const char *pszVolume = gpRedVolConf->pszPathPrefix;
int32_t iLen;
if(pszName[0U] == '/')
{
iLen = RedSNPrintf(pszFullPath, sizeof(aszFullPath[0U]), "%s%s", pszVolume, pszName);
}
else if(strcmp(pszName, ".") == 0U)
{
iLen = RedSNPrintf(pszFullPath, sizeof(aszFullPath[0U]), "%s%s", pszVolume, szLocalCwd);
}
else if((szLocalCwd[0U] == '/') && (szLocalCwd[1U] == '\0'))
{
iLen = RedSNPrintf(pszFullPath, sizeof(aszFullPath[0U]), "%s/%s", pszVolume, pszName);
}
else
{
iLen = RedSNPrintf(pszFullPath, sizeof(aszFullPath[0U]), "%s%s/%s", pszVolume, szLocalCwd, pszName);
}
if(iLen == -1)
{
/* Insufficient path buffer space.
*/
pszFullPath = NULL;
}
else
{
/* Toggle between two full path arrays; a kluge to make rename() and
link() work correctly.
*/
ulWhich ^= 1U;
}
return pszFullPath;
}
/*-------------------------------------------------------------------
POSIX functions not implemented by the RED POSIX-like API
-------------------------------------------------------------------*/
#define stat(p, s) red_stat(p, s)
#define stat64(p, s) stat(p, s)
#define lstat(p, s) stat(p, s)
#define lstat64(p, s) stat(p, s)
#define truncate(p, s) red_truncate(p, s)
#define truncate64(p, s) truncate(p, s)
/** @brief Get the status of a file or directory.
*/
static int red_stat(
const char *pszPath,
REDSTAT *pStat)
{
int iFd;
int iRet;
iFd = open(pszPath, O_RDONLY);
iRet = iFd;
if(iFd != -1)
{
iRet = fstat(iFd, pStat);
(void)close(iFd);
}
return iRet;
}
/** @brief Truncate a file to a specified length.
*/
static int red_truncate(
const char *pszPath,
off_t llSize)
{
int iFd;
int iRet;
iFd = open(pszPath, O_WRONLY);
iRet = iFd;
if(iFd != -1)
{
iRet = ftruncate(iFd, llSize);
(void)close(iFd);
}
return iRet;
}
/*-------------------------------------------------------------------
Begin ported fsstress code
-------------------------------------------------------------------*/
/* Stuff from xfscompat.h */
#define MAXNAMELEN (REDCONF_NAME_MAX+1U) /* Assumed to include NUL */
struct dioattr {
int d_miniosz, d_maxiosz, d_mem;
};
#define MIN(a,b) ((a)<(b) ? (a):(b))
#define MAX(a,b) ((a)>(b) ? (a):(b))
/* End xfscompat.h */
typedef enum {
OP_CREAT,
OP_FDATASYNC,
OP_FSYNC,
OP_GETDENTS,
OP_LINK,
OP_MKDIR,
OP_READ,
OP_RENAME,
OP_RMDIR,
OP_STAT,
OP_TRUNCATE,
OP_UNLINK,
OP_WRITE,
#if REDCONF_CHECKER == 1
OP_CHECK,
#endif
OP_LAST
} opty_t;
typedef void (*opfnc_t) (int, long);
typedef struct opdesc {
opty_t op;
const char *name;
opfnc_t func;
int freq;
int iswrite;
} opdesc_t;
typedef struct fent {
int id;
int parent;
} fent_t;
typedef struct flist {
int nfiles;
int nslots;
int tag;
fent_t *fents;
} flist_t;
typedef struct pathname {
int len;
char *path;
} pathname_t;
#define FT_DIR 0
#define FT_DIRm (1 << FT_DIR)
#define FT_REG 1
#define FT_REGm (1 << FT_REG)
#define FT_SYM 2
#define FT_SYMm (1 << FT_SYM)
#define FT_DEV 3
#define FT_DEVm (1 << FT_DEV)
#define FT_RTF 4
#define FT_RTFm (1 << FT_RTF)
#define FT_nft 5
#define FT_ANYm ((1 << FT_nft) - 1)
#define FT_REGFILE (FT_REGm | FT_RTFm)
#define FT_NOTDIR (FT_ANYm & ~FT_DIRm)
#define FLIST_SLOT_INCR 16
#define NDCACHE 64
#define MAXFSIZE MaxFileSize()
static void creat_f(int opno, long r);
static void fdatasync_f(int opno, long r);
static void fsync_f(int opno, long r);
static void getdents_f(int opno, long r);
static void link_f(int opno, long r);
static void mkdir_f(int opno, long r);
static void read_f(int opno, long r);
static void rename_f(int opno, long r);
static void rmdir_f(int opno, long r);
static void stat_f(int opno, long r);
static void truncate_f(int opno, long r);
static void unlink_f(int opno, long r);
static void write_f(int opno, long r);
#if REDCONF_CHECKER == 1
static void check_f(int opno, long r);
#endif
static opdesc_t ops[] = {
{OP_CREAT, "creat", creat_f, 4, 1},
{OP_FDATASYNC, "fdatasync", fdatasync_f, 1, 1},
{OP_FSYNC, "fsync", fsync_f, 1, 1},
{OP_GETDENTS, "getdents", getdents_f, 1, 0},
{OP_LINK, "link", link_f, 1, 1},
{OP_MKDIR, "mkdir", mkdir_f, 2, 1},
{OP_READ, "read", read_f, 1, 0},
{OP_RENAME, "rename", rename_f, 2, 1},
{OP_RMDIR, "rmdir", rmdir_f, 1, 1},
{OP_STAT, "stat", stat_f, 1, 0},
{OP_TRUNCATE, "truncate", truncate_f, 2, 1},
{OP_UNLINK, "unlink", unlink_f, 1, 1},
{OP_WRITE, "write", write_f, 4, 1},
#if REDCONF_CHECKER == 1
{OP_CHECK, "check", check_f, 1, 1},
#endif
}, *ops_end;
static flist_t flist[FT_nft] = {
{0, 0, 'd', NULL},
{0, 0, 'f', NULL},
{0, 0, 'l', NULL},
{0, 0, 'c', NULL},
{0, 0, 'r', NULL},
};
static int dcache[NDCACHE];
static opty_t *freq_table;
static int freq_table_size;
static char *homedir;
static int *ilist;
static int ilistlen;
static off64_t maxfsize;
static int namerand;
static int nameseq;
static int nops;
static int operations = 1;
static int procid;
static int rtpct;
static unsigned long seed = 0;
static ino_t top_ino;
static int verbose = 0;
static int delete_tree(const char *path);
static void add_to_flist(int fd, int it, int parent);
static void append_pathname(pathname_t *name, const char *str);
static void check_cwd(void);
static int creat_path(pathname_t *name, mode_t mode);
static void dcache_enter(int dirid, int slot);
static void dcache_init(void);
static fent_t *dcache_lookup(int dirid);
static void dcache_purge(int dirid);
static void del_from_flist(int ft, int slot);
static void doproc(void);
static void fent_to_name(pathname_t *name, flist_t *flp, fent_t *fep);
static void fix_parent(int oldid, int newid);
static void free_pathname(pathname_t *name);
static int generate_fname(fent_t *fep, int ft, pathname_t *name, int *idp, int *v);
static int get_fname(int which, long r, pathname_t *name, flist_t **flpp, fent_t **fepp, int *v);
static void init_pathname(pathname_t *name);
static int link_path(pathname_t *name1, pathname_t *name2);
static int lstat64_path(pathname_t *name, REDSTAT *sbuf);
static void make_freq_table(void);
static int mkdir_path(pathname_t *name, mode_t mode);
static void namerandpad(int id, char *buf, int len);
static int open_path(pathname_t *name, int oflag);
static DIR *opendir_path(pathname_t *name);
static int rename_path(pathname_t *name1, pathname_t *name2);
static int rmdir_path(pathname_t *name);
static void separate_pathname(pathname_t *name, char *buf, pathname_t *newname);
static int stat64_path(pathname_t *name, REDSTAT *sbuf);
static int truncate64_path(pathname_t *name, off64_t length);
static int unlink_path(pathname_t *name);
static void usage(const char *progname);
/** @brief Parse parameters for fsstress.
@param argc The number of arguments from main().
@param argv The vector of arguments from main().
@param pParam Populated with the fsstress parameters.
@param pbVolNum If non-NULL, populated with the volume number.
@param ppszDevice If non-NULL, populated with the device name argument or
NULL if no device argument is provided.
@return The result of parsing the parameters.
*/
PARAMSTATUS FsstressParseParams(
int argc,
char *argv[],
FSSTRESSPARAM *pParam,
uint8_t *pbVolNum,
const char **ppszDevice)
{
int c;
uint8_t bVolNum;
const REDOPTION aLongopts[] =
{
{ "no-cleanup", red_no_argument, NULL, 'c' },
{ "loops", red_required_argument, NULL, 'l' },
{ "nops", red_required_argument, NULL, 'n' },
{ "namepad", red_no_argument, NULL, 'r' },
{ "seed", red_required_argument, NULL, 's' },
{ "verbose", red_no_argument, NULL, 'v' },
{ "dev", red_required_argument, NULL, 'D' },
{ "help", red_no_argument, NULL, 'H' },
{ NULL }
};
/* If run without parameters, treat as a help request.
*/
if(argc <= 1)
{
goto Help;
}
/* Assume no device argument to start with.
*/
if(ppszDevice != NULL)
{
*ppszDevice = NULL;
}
/* Set default parameters.
*/
FsstressDefaultParams(pParam);
while((c = RedGetoptLong(argc, argv, "cl:n:rs:vD:H", aLongopts, NULL)) != -1)
{
switch(c)
{
case 'c': /* --no-cleanup */
pParam->fNoCleanup = true;
break;
case 'l': /* --loops */
pParam->ulLoops = RedAtoI(red_optarg);
break;
case 'n': /* --nops */
pParam->ulNops = RedAtoI(red_optarg);
break;
case 'r': /* --namepad */
pParam->fNamePad = true;
break;
case 's': /* --seed */
pParam->ulSeed = RedAtoI(red_optarg);
break;
case 'v': /* --verbose */
pParam->fVerbose = true;
break;
case 'D': /* --dev */
if(ppszDevice != NULL)
{
*ppszDevice = red_optarg;
}
break;
case 'H': /* --help */
goto Help;
case '?': /* Unknown or ambiguous option */
case ':': /* Option missing required argument */
default:
goto BadOpt;
}
}
/* RedGetoptLong() has permuted argv to move all non-option arguments to
the end. We expect to find a volume identifier.
*/
if(red_optind >= argc)
{
RedPrintf("Missing volume argument\n");
goto BadOpt;
}
bVolNum = RedFindVolumeNumber(argv[red_optind]);
if(bVolNum == REDCONF_VOLUME_COUNT)
{
RedPrintf("Error: \"%s\" is not a valid volume identifier.\n", argv[red_optind]);
goto BadOpt;
}
if(pbVolNum != NULL)
{
*pbVolNum = bVolNum;
}
red_optind++; /* Move past volume parameter. */
if(red_optind < argc)
{
int32_t ii;
for(ii = red_optind; ii < argc; ii++)
{
RedPrintf("Error: Unexpected command-line argument \"%s\".\n", argv[ii]);
}
goto BadOpt;
}
return PARAMSTATUS_OK;
BadOpt:
RedPrintf("%s - invalid parameters\n", argv[0U]);
usage(argv[0U]);
return PARAMSTATUS_BAD;
Help:
usage(argv[0U]);
return PARAMSTATUS_HELP;
}
/** @brief Set default fsstress parameters.
@param pParam Populated with the default fsstress parameters.
*/
void FsstressDefaultParams(
FSSTRESSPARAM *pParam)
{
RedMemSet(pParam, 0U, sizeof(*pParam));
pParam->ulLoops = 1U;
pParam->ulNops = 10000U;
}
/** @brief Start fsstress.
@param pParam fsstress parameters, either from FsstressParseParams() or
constructed programatically.
@return Zero on success, otherwise nonzero.
*/
int FsstressStart(
const FSSTRESSPARAM *pParam)
{
char buf[10];
int fd;
int i;
int cleanup;
int loops;
int loopcntr = 1;
nops = sizeof(ops) / sizeof(ops[0]);
ops_end = &ops[nops];
/* Copy the already-parsed parameters into the traditional variables.
*/
cleanup = pParam->fNoCleanup ? 1 : 0;
loops = pParam->ulLoops;
operations = pParam->ulNops;
namerand = pParam->fNamePad ? 1 : 0;
seed = pParam->ulSeed;
verbose = pParam->fVerbose ? 1 : 0;
make_freq_table();
while ((loopcntr <= loops) || (loops == 0)) {
RedSNPrintf(buf, sizeof(buf), "fss%x", getpid());
fd = creat(buf, 0666);
maxfsize = (off64_t) MAXFSIZE;
dcache_init();
if (!seed) {
seed = (unsigned long)RedOsClockGetTime();
RedPrintf("seed = %ld\n", seed);
}
close(fd);
unlink(buf);
procid = 0;
doproc();
if (cleanup == 0) {
delete_tree("/");
for (i = 0; i < FT_nft; i++) {
flist[i].nslots = 0;
flist[i].nfiles = 0;
free(flist[i].fents);
flist[i].fents = NULL;
}
}
loopcntr++;
}
return 0;
}
static int delete_tree(const char *path)
{
REDSTAT sb;
DIR *dp;
REDDIRENT *dep;
char *childpath;
size_t len;
int e;
e = stat(path, &sb);
if (e)
return errno;
if (!S_ISDIR(sb.st_mode))
return unlink(path) ? errno : 0;
dp = opendir(path);
if (dp == NULL)
return errno;
while((dep = readdir(dp)) != NULL) {
len = strlen(path) + 1 + strlen(dep->d_name) + 1;
childpath = malloc(len);
strcpy(childpath, path);
if (childpath[strlen(childpath) - 1] != '/')
strcat(childpath, "/");
strcat(childpath, dep->d_name);
e = delete_tree(childpath);
free(childpath);
if (e)
break;
}
if (e == 0 && strcmp(path, "/") != 0) {
e = rmdir(path) ? errno : 0;
}
closedir(dp);
return e;
}
static void add_to_flist(int ft, int id, int parent)
{
fent_t *fep;
flist_t *ftp;
ftp = &flist[ft];
if (ftp->nfiles == ftp->nslots) {
ftp->nslots += FLIST_SLOT_INCR;
ftp->fents = realloc(ftp->fents, ftp->nslots * sizeof(fent_t));
}
fep = &ftp->fents[ftp->nfiles++];
fep->id = id;
fep->parent = parent;
}
static void append_pathname(pathname_t *name, const char *str)
{
int len;
len = strlen(str);
#ifdef DEBUG
if (len && *str == '/' && name->len == 0) {
RedPrintf("fsstress: append_pathname failure\n");
chdir(homedir);
abort();
}
#endif
name->path = realloc(name->path, name->len + 1 + len);
strcpy(&name->path[name->len], str);
name->len += len;
}
static void check_cwd(void)
{
#ifdef DEBUG
REDSTAT statbuf;
if (stat64(".", &statbuf) == 0 && statbuf.st_ino == top_ino)
return;
chdir(homedir);
RedPrintf("fsstress: check_cwd failure\n");
abort();
#endif
}
static int creat_path(pathname_t *name, mode_t mode)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = creat(name->path, mode);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = creat_path(&newname, mode);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static void dcache_enter(int dirid, int slot)
{
dcache[dirid % NDCACHE] = slot;
}
static void dcache_init(void)
{
int i;
for (i = 0; i < NDCACHE; i++)
dcache[i] = -1;
}
static fent_t *dcache_lookup(int dirid)
{
fent_t *fep;
int i;
i = dcache[dirid % NDCACHE];
if (i >= 0 && (fep = &flist[FT_DIR].fents[i])->id == dirid)
return fep;
return NULL;
}
static void dcache_purge(int dirid)
{
int *dcp;
dcp = &dcache[dirid % NDCACHE];
if (*dcp >= 0 && flist[FT_DIR].fents[*dcp].id == dirid)
*dcp = -1;
}
static void del_from_flist(int ft, int slot)
{
flist_t *ftp;
ftp = &flist[ft];
if (ft == FT_DIR)
dcache_purge(ftp->fents[slot].id);
if (slot != ftp->nfiles - 1) {
if (ft == FT_DIR)
dcache_purge(ftp->fents[ftp->nfiles - 1].id);
ftp->fents[slot] = ftp->fents[--ftp->nfiles];
} else
ftp->nfiles--;
}
static fent_t *dirid_to_fent(int dirid)
{
fent_t *efep;
fent_t *fep;
flist_t *flp;
if ((fep = dcache_lookup(dirid)))
return fep;
flp = &flist[FT_DIR];
for (fep = flp->fents, efep = &fep[flp->nfiles]; fep < efep; fep++) {
if (fep->id == dirid) {
dcache_enter(dirid, (int)(fep - flp->fents));
return fep;
}
}
return NULL;
}
static void doproc(void)
{
REDSTAT statbuf;
char buf[10];
int opno;
opdesc_t *p;
RedSNPrintf(buf, sizeof(buf), "p%x", procid);
(void)mkdir(buf);
if (chdir(buf) < 0 || stat64(".", &statbuf) < 0) {
perror(buf);
_exit(1);
}
top_ino = statbuf.st_ino;
homedir = getcwd(NULL, 0);
seed += procid;
srandom(seed);
if (namerand)
namerand = random();
for (opno = 0; opno < operations; opno++) {
p = &ops[freq_table[random() % freq_table_size]];
if ((unsigned long)p->func < 4096)
abort();
p->func(opno, random());
}
free(homedir);
}
static void fent_to_name(pathname_t *name, flist_t *flp, fent_t *fep)
{
char buf[MAXNAMELEN];
int i;
fent_t *pfep;
if (fep == NULL)
return;
if (fep->parent != -1) {
pfep = dirid_to_fent(fep->parent);
fent_to_name(name, &flist[FT_DIR], pfep);
append_pathname(name, "/");
}
i = RedSNPrintf(buf, sizeof(buf), "%c%x", flp->tag, fep->id);
namerandpad(fep->id, buf, i);
append_pathname(name, buf);
}
static void fix_parent(int oldid, int newid)
{
fent_t *fep;
flist_t *flp;
int i;
int j;
for (i = 0, flp = flist; i < FT_nft; i++, flp++) {
for (j = 0, fep = flp->fents; j < flp->nfiles; j++, fep++) {
if (fep->parent == oldid)
fep->parent = newid;
}
}
}
static void free_pathname(pathname_t *name)
{
if (name->path) {
free(name->path);
name->path = NULL;
name->len = 0;
}
}
static int generate_fname(fent_t *fep, int ft, pathname_t *name, int *idp, int *v)
{
char buf[MAXNAMELEN];
flist_t *flp;
int id;
int j;
int len;
flp = &flist[ft];
len = RedSNPrintf(buf, sizeof(buf), "%c%x", flp->tag, id = nameseq++);
namerandpad(id, buf, len);
if (fep) {
fent_to_name(name, &flist[FT_DIR], fep);
append_pathname(name, "/");
}
append_pathname(name, buf);
*idp = id;
*v = verbose;
for (j = 0; !*v && j < ilistlen; j++) {
if (ilist[j] == id) {
*v = 1;
break;
}
}
return 1;
}
static int
get_fname(int which, long r, pathname_t *name, flist_t **flpp, fent_t **fepp, int *v)
{
int c;
fent_t *fep;
flist_t *flp;
int i;
int j;
int x;
for (i = 0, c = 0, flp = flist; i < FT_nft; i++, flp++) {
if (which & (1 << i))
c += flp->nfiles;
}
if (c == 0) {
if (flpp)
*flpp = NULL;
if (fepp)
*fepp = NULL;
*v = verbose;
return 0;
}
x = (int)(r % c);
for (i = 0, c = 0, flp = flist; i < FT_nft; i++, flp++) {
if (which & (1 << i)) {
if (x < c + flp->nfiles) {
fep = &flp->fents[x - c];
if (name)
fent_to_name(name, flp, fep);
if (flpp)
*flpp = flp;
if (fepp)
*fepp = fep;
*v = verbose;
for (j = 0; !*v && j < ilistlen; j++) {
if (ilist[j] == fep->id) {
*v = 1;
break;
}
}
return 1;
}
c += flp->nfiles;
}
}
#ifdef DEBUG
RedPrintf("fsstress: get_fname failure\n");
abort();
#endif
return -1;
}
static void init_pathname(pathname_t *name)
{
name->len = 0;
name->path = NULL;
}
static int link_path(pathname_t *name1, pathname_t *name2)
{
char buf1[MAXNAMELEN];
char buf2[MAXNAMELEN];
int down1;
pathname_t newname1;
pathname_t newname2;
int rval;
rval = link(name1->path, name2->path);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name1, buf1, &newname1);
separate_pathname(name2, buf2, &newname2);
if (strcmp(buf1, buf2) == 0) {
if (chdir(buf1) == 0) {
rval = link_path(&newname1, &newname2);
chdir("..");
}
} else {
if (strcmp(buf1, "..") == 0)
down1 = 0;
else if (strcmp(buf2, "..") == 0)
down1 = 1;
else if (strlen(buf1) == 0)
down1 = 0;
else if (strlen(buf2) == 0)
down1 = 1;
else
down1 = MAX(newname1.len, 3 + name2->len) <=
MAX(3 + name1->len, newname2.len);
if (down1) {
free_pathname(&newname2);
append_pathname(&newname2, "../");
append_pathname(&newname2, name2->path);
if (chdir(buf1) == 0) {
rval = link_path(&newname1, &newname2);
chdir("..");
}
} else {
free_pathname(&newname1);
append_pathname(&newname1, "../");
append_pathname(&newname1, name1->path);
if (chdir(buf2) == 0) {
rval = link_path(&newname1, &newname2);
chdir("..");
}
}
}
free_pathname(&newname1);
free_pathname(&newname2);
return rval;
}
static int lstat64_path(pathname_t *name, REDSTAT *sbuf)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = lstat64(name->path, sbuf);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = lstat64_path(&newname, sbuf);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static void make_freq_table(void)
{
int f;
int i;
opdesc_t *p;
for (p = ops, f = 0; p < ops_end; p++)
f += p->freq;
freq_table = malloc(f * sizeof(*freq_table));
freq_table_size = f;
for (p = ops, i = 0; p < ops_end; p++) {
for (f = 0; f < p->freq; f++, i++)
freq_table[i] = p->op;
}
}
static int mkdir_path(pathname_t *name, mode_t mode)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = mkdir(name->path);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = mkdir_path(&newname, mode);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static void namerandpad(int id, char *buf, int len)
{
int bucket;
static int buckets[8] = {0};
static int bucket_count = 0;
int bucket_value;
int i;
int padlen;
int padmod;
if (namerand == 0)
return;
/* buckets[] used to be a statically initialized array with the following
initializer: { 2, 4, 8, 16, 32, 64, 128, MAXNAMELEN - 1 }
The problem is that with Reliance Edge, the maximum name length might be
less than 128. So the below code populates buckets[] in a similar
fashion but avoids name lengths longer than the maximum. For example,
if the max name is 20, the resulting array is { 2, 4, 8, 16, 20 }.
*/
if (!bucket_count) {
bucket_count = sizeof(buckets) / sizeof(buckets[0]);
bucket_value = 2;
for (i = 0; i < bucket_count; i++) {
if (bucket_value > 128 || bucket_value >= (int)MAXNAMELEN - 1)
break;
buckets[i] = bucket_value;
bucket_value *= 2;
}
if (i < bucket_count) {
buckets[i] = MAXNAMELEN - 1;
i++;
}
bucket_count = i;
}
bucket = (id ^ namerand) % bucket_count;
padmod = buckets[bucket] + 1 - len;
if (padmod <= 0)
return;
padlen = (id ^ namerand) % padmod;
if (padlen) {
memset(&buf[len], 'X', padlen);
buf[len + padlen] = '\0';
}
}
static int open_path(pathname_t *name, int oflag)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = open(name->path, oflag);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = open_path(&newname, oflag);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static DIR *opendir_path(pathname_t *name)
{
char buf[MAXNAMELEN];
pathname_t newname;
DIR *rval;
rval = opendir(name->path);
if (rval || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = opendir_path(&newname);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static int rename_path(pathname_t *name1, pathname_t *name2)
{
char buf1[MAXNAMELEN];
char buf2[MAXNAMELEN];
int down1;
pathname_t newname1;
pathname_t newname2;
int rval;
rval = rename(name1->path, name2->path);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name1, buf1, &newname1);
separate_pathname(name2, buf2, &newname2);
if (strcmp(buf1, buf2) == 0) {
if (chdir(buf1) == 0) {
rval = rename_path(&newname1, &newname2);
chdir("..");
}
} else {
if (strcmp(buf1, "..") == 0)
down1 = 0;
else if (strcmp(buf2, "..") == 0)
down1 = 1;
else if (strlen(buf1) == 0)
down1 = 0;
else if (strlen(buf2) == 0)
down1 = 1;
else
down1 = MAX(newname1.len, 3 + name2->len) <=
MAX(3 + name1->len, newname2.len);
if (down1) {
free_pathname(&newname2);
append_pathname(&newname2, "../");
append_pathname(&newname2, name2->path);
if (chdir(buf1) == 0) {
rval = rename_path(&newname1, &newname2);
chdir("..");
}
} else {
free_pathname(&newname1);
append_pathname(&newname1, "../");
append_pathname(&newname1, name1->path);
if (chdir(buf2) == 0) {
rval = rename_path(&newname1, &newname2);
chdir("..");
}
}
}
free_pathname(&newname1);
free_pathname(&newname2);
return rval;
}
static int rmdir_path(pathname_t *name)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = rmdir(name->path);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = rmdir_path(&newname);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static void separate_pathname(pathname_t *name, char *buf, pathname_t *newname)
{
char *slash;
init_pathname(newname);
slash = strchr(name->path, '/');
if (slash == NULL) {
buf[0] = '\0';
return;
}
*slash = '\0';
strcpy(buf, name->path);
*slash = '/';
append_pathname(newname, slash + 1);
}
static int stat64_path(pathname_t *name, REDSTAT *sbuf)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = stat64(name->path, sbuf);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = stat64_path(&newname, sbuf);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static int truncate64_path(pathname_t *name, off64_t length)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = truncate64(name->path, length);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = truncate64_path(&newname, length);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static int unlink_path(pathname_t *name)
{
char buf[MAXNAMELEN];
pathname_t newname;
int rval;
rval = unlink(name->path);
if (rval >= 0 || errno != RED_ENAMETOOLONG)
return rval;
separate_pathname(name, buf, &newname);
if (chdir(buf) == 0) {
rval = unlink_path(&newname);
chdir("..");
}
free_pathname(&newname);
return rval;
}
static void usage(const char *progname)
{
RedPrintf("usage: %s VolumeID [Options]\n", progname);
RedPrintf("File system stress test.\n\n");
RedPrintf("Where:\n");
RedPrintf(" VolumeID\n");
RedPrintf(" A volume number (e.g., 2) or a volume path prefix (e.g., VOL1: or /data)\n");
RedPrintf(" of the volume to test.\n");
RedPrintf("And 'Options' are any of the following:\n");
RedPrintf(" --no-cleanup, -c\n");
RedPrintf(" Specifies not to remove files (cleanup) after execution\n");
RedPrintf(" --loops=count, -l count\n");
RedPrintf(" Specifies the number of times the entire test should loop. Use 0 for\n");
RedPrintf(" infinite. Default 1.\n");
RedPrintf(" --nops=count, -n count\n");
RedPrintf(" Specifies the number of operations to run (default 10000).\n");
RedPrintf(" --namepad, -r\n");
RedPrintf(" Specifies to use random name padding (resulting in longer names).\n");
RedPrintf(" --seed=value, -s value\n");
RedPrintf(" Specifies the seed for the random number generator (default timestamp).\n");
RedPrintf(" --verbose, -v\n");
RedPrintf(" Specifies verbose mode (without this, test is very quiet).\n");
RedPrintf(" --dev=devname, -D devname\n");
RedPrintf(" Specifies the device name. This is typically only meaningful when\n");
RedPrintf(" running the test on a host machine. This can be \"ram\" to test on a RAM\n");
RedPrintf(" disk, the path and name of a file disk (e.g., red.bin); or an OS-specific\n");
RedPrintf(" reference to a device (on Windows, a drive letter like G: or a device name\n");
RedPrintf(" like \\\\.\\PhysicalDrive7).\n");
RedPrintf(" --help, -H\n");
RedPrintf(" Prints this usage text and exits.\n\n");
RedPrintf("Warning: This test will format the volume -- destroying all existing data.\n\n");
}
static void creat_f(int opno, long r)
{
int e;
int e1;
pathname_t f;
int fd;
fent_t *fep;
int id;
int parid;
int type;
int v;
int v1;
int esz = 0;
if (!get_fname(FT_DIRm, r, NULL, NULL, &fep, &v1))
parid = -1;
else
parid = fep->id;
init_pathname(&f);
type = rtpct ? ((int)(random() % 100) > rtpct ? FT_REG : FT_RTF) : FT_REG;
e = generate_fname(fep, type, &f, &id, &v);
v |= v1;
if (!e) {
if (v) {
fent_to_name(&f, &flist[FT_DIR], fep);
RedPrintf("%d/%d: creat - no filename from %s\n",
procid, opno, f.path);
}
free_pathname(&f);
return;
}
fd = creat_path(&f, 0666);
e = fd < 0 ? errno : 0;
e1 = 0;
check_cwd();
esz = 0;
if (fd >= 0) {
add_to_flist(type, id, parid);
close(fd);
}
if (v)
RedPrintf("%d/%d: creat %s x:%d %d %d\n", procid, opno, f.path,
esz, e, e1);
free_pathname(&f);
}
static void fdatasync_f(int opno, long r)
{
int e;
pathname_t f;
int fd;
int v;
init_pathname(&f);
if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
if (v)
RedPrintf("%d/%d: fdatasync - no filename\n",
procid, opno);
free_pathname(&f);
return;
}
fd = open_path(&f, O_WRONLY);
e = fd < 0 ? errno : 0;
check_cwd();
if (fd < 0) {
if (v)
RedPrintf("%d/%d: fdatasync - open %s failed %d\n",
procid, opno, f.path, e);
free_pathname(&f);
return;
}
e = fdatasync(fd) < 0 ? errno : 0;
if (v)
RedPrintf("%d/%d: fdatasync %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
close(fd);
}
static void fsync_f(int opno, long r)
{
int e;
pathname_t f;
int fd;
int v;
init_pathname(&f);
if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
if (v)
RedPrintf("%d/%d: fsync - no filename\n", procid, opno);
free_pathname(&f);
return;
}
fd = open_path(&f, O_WRONLY);
e = fd < 0 ? errno : 0;
check_cwd();
if (fd < 0) {
if (v)
RedPrintf("%d/%d: fsync - open %s failed %d\n",
procid, opno, f.path, e);
free_pathname(&f);
return;
}
e = fsync(fd) < 0 ? errno : 0;
if (v)
RedPrintf("%d/%d: fsync %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
close(fd);
}
static void getdents_f(int opno, long r)
{
DIR *dir;
pathname_t f;
int v;
init_pathname(&f);
if (!get_fname(FT_DIRm, r, &f, NULL, NULL, &v))
append_pathname(&f, ".");
dir = opendir_path(&f);
check_cwd();
if (dir == NULL) {
if (v)
RedPrintf("%d/%d: getdents - can't open %s\n",
procid, opno, f.path);
free_pathname(&f);
return;
}
while (readdir64(dir) != NULL)
continue;
if (v)
RedPrintf("%d/%d: getdents %s 0\n", procid, opno, f.path);
free_pathname(&f);
closedir(dir);
}
static void link_f(int opno, long r)
{
int e;
pathname_t f;
fent_t *fep;
flist_t *flp;
int id;
pathname_t l;
int parid;
int v;
int v1;
init_pathname(&f);
if (!get_fname(FT_NOTDIR, r, &f, &flp, NULL, &v1)) {
if (v1)
RedPrintf("%d/%d: link - no file\n", procid, opno);
free_pathname(&f);
return;
}
if (!get_fname(FT_DIRm, random(), NULL, NULL, &fep, &v))
parid = -1;
else
parid = fep->id;
v |= v1;
init_pathname(&l);
e = generate_fname(fep, (int)(flp - flist), &l, &id, &v1);
v |= v1;
if (!e) {
if (v) {
fent_to_name(&l, &flist[FT_DIR], fep);
RedPrintf("%d/%d: link - no filename from %s\n",
procid, opno, l.path);
}
free_pathname(&l);
free_pathname(&f);
return;
}
e = link_path(&f, &l) < 0 ? errno : 0;
check_cwd();
if (e == 0)
add_to_flist((int)(flp - flist), id, parid);
if (v)
RedPrintf("%d/%d: link %s %s %d\n", procid, opno, f.path, l.path,
e);
free_pathname(&l);
free_pathname(&f);
}
static void mkdir_f(int opno, long r)
{
int e;
pathname_t f;
fent_t *fep;
int id;
int parid;
int v;
int v1;
if (!get_fname(FT_DIRm, r, NULL, NULL, &fep, &v))
parid = -1;
else
parid = fep->id;
init_pathname(&f);
e = generate_fname(fep, FT_DIR, &f, &id, &v1);
v |= v1;
if (!e) {
if (v) {
fent_to_name(&f, &flist[FT_DIR], fep);
RedPrintf("%d/%d: mkdir - no filename from %s\n",
procid, opno, f.path);
}
free_pathname(&f);
return;
}
e = mkdir_path(&f, 0777) < 0 ? errno : 0;
check_cwd();
if (e == 0)
add_to_flist(FT_DIR, id, parid);
if (v)
RedPrintf("%d/%d: mkdir %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
}
static void read_f(int opno, long r)
{
char *buf;
int e;
pathname_t f;
int fd;
uint32_t len;
__int64_t lr;
off64_t off;
REDSTAT stb;
int v;
init_pathname(&f);
if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
if (v)
RedPrintf("%d/%d: read - no filename\n", procid, opno);
free_pathname(&f);
return;
}
fd = open_path(&f, O_RDONLY);
e = fd < 0 ? errno : 0;
check_cwd();
if (fd < 0) {
if (v)
RedPrintf("%d/%d: read - open %s failed %d\n",
procid, opno, f.path, e);
free_pathname(&f);
return;
}
if (fstat64(fd, &stb) < 0) {
if (v)
RedPrintf("%d/%d: read - fstat64 %s failed %d\n",
procid, opno, f.path, errno);
free_pathname(&f);
close(fd);
return;
}
if (stb.st_size == 0) {
if (v)
RedPrintf("%d/%d: read - %s zero size\n", procid, opno,
f.path);
free_pathname(&f);
close(fd);
return;
}
lr = ((__int64_t) random() << 32) + random();
off = (off64_t) (lr % stb.st_size);
lseek64(fd, off, SEEK_SET);
len = (random() % (getpagesize() * 4)) + 1;
buf = malloc(len);
e = read(fd, buf, len) < 0 ? errno : 0;
free(buf);
if (v)
RedPrintf("%d/%d: read %s [%lld,%ld] %d\n",
procid, opno, f.path, (long long)off, (long int)len, e);
free_pathname(&f);
close(fd);
}
static void rename_f(int opno, long r)
{
fent_t *dfep;
int e;
pathname_t f;
fent_t *fep;
flist_t *flp;
int id;
pathname_t newf;
int oldid;
int parid;
int v;
int v1;
init_pathname(&f);
if (!get_fname(FT_ANYm, r, &f, &flp, &fep, &v1)) {
if (v1)
RedPrintf("%d/%d: rename - no filename\n", procid, opno);
free_pathname(&f);
return;
}
if (!get_fname(FT_DIRm, random(), NULL, NULL, &dfep, &v))
parid = -1;
else
parid = dfep->id;
v |= v1;
init_pathname(&newf);
e = generate_fname(dfep, (int)(flp - flist), &newf, &id, &v1);
v |= v1;
if (!e) {
if (v) {
fent_to_name(&f, &flist[FT_DIR], dfep);
RedPrintf("%d/%d: rename - no filename from %s\n",
procid, opno, f.path);
}
free_pathname(&newf);
free_pathname(&f);
return;
}
e = rename_path(&f, &newf) < 0 ? errno : 0;
check_cwd();
if (e == 0) {
if (flp - flist == FT_DIR) {
oldid = fep->id;
fix_parent(oldid, id);
}
del_from_flist((int)(flp - flist), (int)(fep - flp->fents));
add_to_flist((int)(flp - flist), id, parid);
}
if (v)
RedPrintf("%d/%d: rename %s to %s %d\n", procid, opno, f.path,
newf.path, e);
free_pathname(&newf);
free_pathname(&f);
}
static void rmdir_f(int opno, long r)
{
int e;
pathname_t f;
fent_t *fep;
int v;
init_pathname(&f);
if (!get_fname(FT_DIRm, r, &f, NULL, &fep, &v)) {
if (v)
RedPrintf("%d/%d: rmdir - no directory\n", procid, opno);
free_pathname(&f);
return;
}
e = rmdir_path(&f) < 0 ? errno : 0;
check_cwd();
if (e == 0)
del_from_flist(FT_DIR, (int)(fep - flist[FT_DIR].fents));
if (v)
RedPrintf("%d/%d: rmdir %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
}
static void stat_f(int opno, long r)
{
int e;
pathname_t f;
REDSTAT stb;
int v;
init_pathname(&f);
if (!get_fname(FT_ANYm, r, &f, NULL, NULL, &v)) {
if (v)
RedPrintf("%d/%d: stat - no entries\n", procid, opno);
free_pathname(&f);
return;
}
e = lstat64_path(&f, &stb) < 0 ? errno : 0;
check_cwd();
if (v)
RedPrintf("%d/%d: stat %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
}
static void truncate_f(int opno, long r)
{
int e;
pathname_t f;
__int64_t lr;
off64_t off;
REDSTAT stb;
int v;
init_pathname(&f);
if (!get_fname(FT_REGFILE, r, &f, NULL, NULL, &v)) {
if (v)
RedPrintf("%d/%d: truncate - no filename\n", procid, opno);
free_pathname(&f);
return;
}
e = stat64_path(&f, &stb) < 0 ? errno : 0;
check_cwd();
if (e > 0) {
if (v)
RedPrintf("%d/%d: truncate - stat64 %s failed %d\n",
procid, opno, f.path, e);
free_pathname(&f);
return;
}
lr = ((__int64_t) random() << 32) + random();
off = lr % MIN(stb.st_size + (1024 * 1024), MAXFSIZE);
off %= maxfsize;
e = truncate64_path(&f, off) < 0 ? errno : 0;
check_cwd();
if (v)
RedPrintf("%d/%d: truncate %s %lld %d\n", procid, opno, f.path,
(long long)off, e);
free_pathname(&f);
}
static void unlink_f(int opno, long r)
{
int e;
pathname_t f;
fent_t *fep;
flist_t *flp;
int v;
init_pathname(&f);
if (!get_fname(FT_NOTDIR, r, &f, &flp, &fep, &v)) {
if (v)
RedPrintf("%d/%d: unlink - no file\n", procid, opno);
free_pathname(&f);
return;
}
e = unlink_path(&f) < 0 ? errno : 0;
check_cwd();
if (e == 0)
del_from_flist((int)(flp - flist), (int)(fep - flp->fents));
if (v)
RedPrintf("%d/%d: unlink %s %d\n", procid, opno, f.path, e);
free_pathname(&f);
}
static void write_f(int opno, long r)
{
char *buf;
int e;
pathname_t f;
int fd;
uint32_t len;
__int64_t lr;
off64_t off;
REDSTAT stb;
int v;
init_pathname(&f);
if (!get_fname(FT_REGm, r, &f, NULL, NULL, &v)) {
if (v)
RedPrintf("%d/%d: write - no filename\n", procid, opno);
free_pathname(&f);
return;
}
fd = open_path(&f, O_WRONLY);
e = fd < 0 ? errno : 0;
check_cwd();
if (fd < 0) {
if (v)
RedPrintf("%d/%d: write - open %s failed %d\n",
procid, opno, f.path, e);
free_pathname(&f);
return;
}
if (fstat64(fd, &stb) < 0) {
if (v)
RedPrintf("%d/%d: write - fstat64 %s failed %d\n",
procid, opno, f.path, errno);
free_pathname(&f);
close(fd);
return;
}
lr = ((__int64_t) random() << 32) + random();
off = (off64_t) (lr % MIN(stb.st_size + (1024 * 1024), MAXFSIZE));
off %= maxfsize;
lseek64(fd, off, SEEK_SET);
len = (random() % (getpagesize() * 4)) + 1;
buf = malloc(len);
memset(buf, nameseq & 0xff, len);
e = write(fd, buf, len) < 0 ? errno : 0;
free(buf);
if (v)
RedPrintf("%d/%d: write %s [%lld,%ld] %d\n",
procid, opno, f.path, (long long)off, (long int)len, e);
free_pathname(&f);
close(fd);
}
#if REDCONF_CHECKER == 1
static void check_f(int opno, long r)
{
int32_t ret;
const char *pszVolume = gpRedVolConf->pszPathPrefix;
(void)r;
errno = 0;
ret = red_transact(pszVolume);
if(ret == 0)
{
ret = red_umount(pszVolume);
if(ret == 0)
{
int32_t ret2;
errno = -RedCoreVolCheck();
if(errno != 0)
{
ret = -1;
}
ret2 = red_mount(pszVolume);
if(ret == 0)
{
ret = ret2;
}
if(ret2 != 0)
{
exit(1);
}
}
}
if (verbose)
{
RedPrintf("%d/%d: check %s %d\n", procid, opno, pszVolume, errno);
}
}
#endif
#endif /* FSSTRESS_SUPPORTED */