#include "fio.h"
+static int root_warn;
+
static int extend_file(struct thread_data *td, struct fio_file *f)
{
int r, new_layout = 0, unlink_file = 0, flags;
else if (f->filetype == FIO_TYPE_BD) {
ret = blockdev_invalidate_cache(f->fd);
if (ret < 0 && errno == EACCES && geteuid()) {
- log_err("fio: only root may flush block devices. Cache flush bypassed!\n");
+ if (!root_warn) {
+ log_err("fio: only root may flush block devices. Cache flush bypassed!\n");
+ root_warn = 1;
+ }
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) {
if (td->io_ops->open_file(td, f)) {
- log_err("%s\n", td->verror);
- err = 1;
+ if (td->error != ENOENT) {
+ log_err("%s\n", td->verror);
+ err = 1;
+ }
clear_error(td);
- } else
- td->io_ops->close_file(td, f);
+ } else {
+ if (td->io_ops->close_file)
+ 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;
unsigned int i;
for_each_file(td, f, i) {
- if ((f->flags & FIO_FILE_UNLINK) &&
- f->filetype == FIO_TYPE_FILE)
+ if (td->o.unlink && f->filetype == FIO_TYPE_FILE)
unlink(f->file_name);
td_io_close_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;
}
}
-void add_file(struct thread_data *td, const char *fname)
+int add_file(struct thread_data *td, const char *fname)
{
int cur_files = td->files_index;
char file_name[PATH_MAX];
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);
td->files_index++;
if (f->filetype == FIO_TYPE_FILE)
td->nr_normal_files++;
+
+ return cur_files;
}
void get_file(struct fio_file *f)
{
+ assert(f->flags & FIO_FILE_OPEN);
f->references++;
}
f->file_name = strdup(f->file_name);
}
}
+
+/*
+ * Returns the index that matches the filename, or -1 if not there
+ */
+int get_fileno(struct thread_data *td, const char *fname)
+{
+ struct fio_file *f;
+ unsigned int i;
+
+ for_each_file(td, f, i)
+ if (!strcmp(f->file_name, fname))
+ return i;
+
+ return -1;
+}
+
+/*
+ * For log usage, where we add/open/close files automatically
+ */
+void free_release_files(struct thread_data *td)
+{
+ close_files(td);
+ td->files_index = 0;
+ td->nr_normal_files = 0;
+}