#include <sys/types.h>
#include "fio.h"
-#include "os.h"
static int extend_file(struct thread_data *td, struct fio_file *f)
{
+ int r, new_layout = 0, unlink_file = 0, flags;
unsigned long long left;
unsigned int bs;
char *b;
- int r;
- if (f->flags & FIO_FILE_EXISTS) {
+ /*
+ * check if we need to lay the file out complete again. fio
+ * does that for operations involving reads, or for writes
+ * where overwrite is set
+ */
+ if (td_read(td) || (td_write(td) && td->o.overwrite))
+ new_layout = 1;
+ if (td_write(td) && !td->o.overwrite)
+ unlink_file = 1;
+
+ if ((unlink_file || new_layout) && (f->flags & FIO_FILE_EXISTS)) {
if (unlink(f->file_name) < 0) {
td_verror(td, errno, "unlink");
return 1;
}
}
- f->fd = open(f->file_name, O_WRONLY | O_CREAT | O_TRUNC, 0644);
+ flags = O_WRONLY | O_CREAT;
+ if (new_layout)
+ flags |= O_TRUNC;
+
+ f->fd = open(f->file_name, flags, 0644);
if (f->fd < 0) {
td_verror(td, errno, "open");
return 1;
goto err;
}
+ if (!new_layout)
+ goto done;
+
if (posix_fallocate(f->fd, 0, f->real_file_size) < 0) {
td_verror(td, errno, "posix_fallocate");
goto err;
fsync(f->fd);
free(b);
+done:
close(f->fd);
f->fd = -1;
return 0;
{
int ret = 0;
+ if (f->flags & FIO_SIZE_KNOWN)
+ return 0;
+
if (f->filetype == FIO_TYPE_FILE)
ret = file_size(td, f);
else if (f->filetype == FIO_TYPE_BD)
return 1;
}
+ f->flags |= FIO_SIZE_KNOWN;
return 0;
}
log_err("fio: only root may flush block devices. Cache flush bypassed!\n");
ret = 0;
}
- } else if (f->filetype == FIO_TYPE_CHAR)
+ } else if (f->filetype == FIO_TYPE_CHAR || f->filetype == FIO_TYPE_PIPE)
ret = 0;
if (ret < 0) {
int generic_open_file(struct thread_data *td, struct fio_file *f)
{
+ int is_std = 0;
int flags = 0;
+ if (!strcmp(f->file_name, "-")) {
+ if (td_rw(td)) {
+ log_err("fio: can't read/write to stdin/out\n");
+ return 1;
+ }
+ is_std = 1;
+
+ /*
+ * move output logging to stderr, if we are writing to stdout
+ */
+ if (td_write(td))
+ f_out = stderr;
+ }
+
if (td->o.odirect)
flags |= OS_O_DIRECT;
if (td->o.sync_io)
flags |= O_SYNC;
- if (td_write(td) || td_rw(td)) {
+ if (td_write(td)) {
flags |= O_RDWR;
if (f->filetype == FIO_TYPE_FILE)
flags |= O_CREAT;
- f->fd = open(f->file_name, flags, 0600);
+ if (is_std)
+ f->fd = dup(STDOUT_FILENO);
+ else
+ f->fd = open(f->file_name, flags, 0600);
} else {
if (f->filetype == FIO_TYPE_CHAR)
flags |= O_RDWR;
else
flags |= O_RDONLY;
- f->fd = open(f->file_name, flags);
+ if (is_std)
+ f->fd = dup(STDIN_FILENO);
+ else
+ f->fd = open(f->file_name, flags);
}
if (f->fd == -1) {
for_each_file(td, f, i) {
err = td_io_open_file(td, f);
- if (err)
+ if (err) {
+ if (td->error == EMFILE) {
+ log_err("fio: limited open files to: %d\n", td->nr_open_files);
+ td->o.open_files = td->nr_open_files;
+ err = 0;
+ clear_error(td);
+ }
break;
+ }
if (td->o.open_files == td->nr_open_files)
break;
int err = 0;
for_each_file(td, f, i) {
- err = td->io_ops->open_file(td, f);
- if (err) {
- td->error = 0;
- memset(td->verror, 0, sizeof(td->verror));
- err = 0;
- continue;
+ if (td->io_ops->open_file(td, f)) {
+ if (td->error != ENOENT) {
+ log_err("%s\n", td->verror);
+ err = 1;
+ }
+ clear_error(td);
+ } else {
+ if (td->io_ops->close_file)
+ td->io_ops->close_file(td, f);
}
- td->io_ops->close_file(td, f);
+ if (f->real_file_size == -1ULL && td->o.size)
+ f->real_file_size = td->o.size / td->o.nr_files;
}
return err;
unsigned long long total_size, extend_size;
struct fio_file *f;
unsigned int i;
- int err, need_extend;
+ int err = 0, need_extend;
/*
* if ioengine defines a setup() method, it's responsible for
/*
* device/file sizes are zero and no size given, punt
*/
- if (!total_size && !td->o.size) {
+ if ((!total_size || total_size == -1ULL) && !td->o.size) {
log_err("%s: you need to specify size=\n", td->o.name);
td_verror(td, EINVAL, "total_file_size");
return 1;
if (!(f->flags & FIO_FILE_EXTEND))
continue;
+ assert(f->filetype == FIO_TYPE_FILE);
f->flags &= ~FIO_FILE_EXTEND;
f->real_file_size = f->io_size;
err = extend_file(td, f);
{
struct stat sb;
- f->filetype = FIO_TYPE_FILE;
+ if (!strcmp(f->file_name, "-"))
+ f->filetype = FIO_TYPE_PIPE;
+ else
+ f->filetype = FIO_TYPE_FILE;
if (!lstat(f->file_name, &sb)) {
if (S_ISBLK(sb.st_mode))
f->filetype = FIO_TYPE_BD;
else if (S_ISCHR(sb.st_mode))
f->filetype = FIO_TYPE_CHAR;
+ else if (S_ISFIFO(sb.st_mode))
+ f->filetype = FIO_TYPE_PIPE;
}
}
memset(f, 0, sizeof(*f));
f->fd = -1;
+ /*
+ * init function, io engine may not be loaded yet
+ */
+ if (td->io_ops && (td->io_ops->flags & FIO_DISKLESSIO))
+ f->real_file_size = -1ULL;
+
if (td->o.directory)
len = sprintf(file_name, "%s/", td->o.directory);
if (td->io_ops->close_file)
td->io_ops->close_file(td, f);
+
td->nr_open_files--;
f->flags &= ~FIO_FILE_OPEN;
}
D = opendir(dirname);
if (!D) {
- td_verror(td, errno, "opendir");
+ char buf[FIO_VERROR_SIZE];
+
+ snprintf(buf, FIO_VERROR_SIZE - 1, "opendir(%s)", dirname);
+ td_verror(td, errno, buf);
return 1;
}
td->o.nr_files++;
continue;
}
+ if (!S_ISDIR(sb.st_mode))
+ continue;
if ((ret = recurse_dir(td, full_path)) != 0)
break;
int add_dir_files(struct thread_data *td, const char *path)
{
- return recurse_dir(td, path);
+ int ret = recurse_dir(td, path);
+
+ if (!ret)
+ log_info("fio: opendir added %d files\n", td->o.nr_files);
+
+ return ret;
}
void dup_files(struct thread_data *td, struct thread_data *org)