static int root_warn;
+static inline void clear_error(struct thread_data *td)
+{
+ td->error = 0;
+ td->verror[0] = '\0';
+}
+
/*
* Leaves f->fd open on success, caller must close
*/
if (!new_layout)
goto done;
- dprint(FD_FILE, "truncate file %s, size %llu\n", f->file_name,
+ /*
+ * The size will be -1ULL when fill_device is used, so don't truncate
+ * or fallocate this file, just write it
+ */
+ if (!td->o.fill_device) {
+ dprint(FD_FILE, "truncate file %s, size %llu\n", f->file_name,
f->real_file_size);
- if (ftruncate(f->fd, f->real_file_size) == -1) {
- td_verror(td, errno, "ftruncate");
- goto err;
- }
+ if (ftruncate(f->fd, f->real_file_size) == -1) {
+ td_verror(td, errno, "ftruncate");
+ goto err;
+ }
#ifdef FIO_HAVE_FALLOCATE
- dprint(FD_FILE, "fallocate file %s, size %llu\n", f->file_name,
+ dprint(FD_FILE, "fallocate file %s, size %llu\n", f->file_name,
f->real_file_size);
- r = posix_fallocate(f->fd, 0, f->real_file_size);
- if (r < 0)
- log_err("fio: posix_fallocate fails: %s\n", strerror(-r));
+ r = posix_fallocate(f->fd, 0, f->real_file_size);
+ if (r < 0) {
+ log_err("fio: posix_fallocate fails: %s\n",
+ strerror(-r));
+ }
#endif
+ }
b = malloc(td->o.max_bs[DDIR_WRITE]);
memset(b, 0, td->o.max_bs[DDIR_WRITE]);
r = write(f->fd, b, bs);
- if (r == (int) bs) {
- left -= bs;
+ if (r > 0) {
+ left -= r;
continue;
} else {
- if (r < 0)
+ if (r < 0) {
+ int __e = errno;
+
+ if (__e == ENOSPC) {
+ if (td->o.fill_device)
+ break;
+ log_info("fio: ENOSPC on laying out "
+ "file, stopping\n");
+ break;
+ }
td_verror(td, errno, "write");
- else
+ } else
td_verror(td, EIO, "write");
break;
goto err;
}
}
+ if (td->o.fill_device && !td_write(td)) {
+ fio_file_clear_size_known(f);
+ if (td_io_get_file_size(td, f))
+ goto err;
+ if (f->io_size > f->real_file_size)
+ f->io_size = f->real_file_size;
+ }
free(b);
done:
unsigned int bs;
char *b;
- if (!(f->flags & FIO_FILE_OPEN)) {
+ if (td->io_ops->flags & FIO_PIPEIO)
+ return 0;
+
+ if (!fio_file_open(f)) {
if (td->io_ops->open_file(td, f)) {
log_err("fio: cannot pre-read, failed to open file\n");
return 1;
}
f->real_file_size = bytes;
+ td->io_ops->close_file(td, f);
return 0;
err:
td->io_ops->close_file(td, f);
{
int ret = 0;
- if (f->flags & FIO_SIZE_KNOWN)
+ if (fio_file_size_known(f))
return 0;
if (f->filetype == FIO_TYPE_FILE)
return 1;
}
- f->flags |= FIO_SIZE_KNOWN;
+ fio_file_set_size_known(f);
return 0;
}
{
int ret = 0;
- if (len == -1ULL) {
+ if (len == -1ULL)
len = f->io_size;
- if (len == -1ULL && td->o.fill_device)
- return 0;
- }
if (off == -1ULL)
off = f->file_offset;
+ if (len == -1ULL || off == -1ULL)
+ return 0;
+
dprint(FD_IO, "invalidate cache %s: %llu/%llu\n", f->file_name, off,
len);
/*
* FIXME: add blockdev flushing too
*/
- if (f->mmap_ptr)
+ if (f->mmap_ptr) {
ret = madvise(f->mmap_ptr, f->mmap_sz, MADV_DONTNEED);
- else if (f->filetype == FIO_TYPE_FILE) {
+#ifdef FIO_MADV_FREE
+ (void) madvise(f->mmap_ptr, f->mmap_sz, FIO_MADV_FREE);
+#endif
+ } else if (f->filetype == FIO_TYPE_FILE) {
ret = fadvise(f->fd, off, len, POSIX_FADV_DONTNEED);
} else if (f->filetype == FIO_TYPE_BD) {
ret = blockdev_invalidate_cache(f->fd);
int file_invalidate_cache(struct thread_data *td, struct fio_file *f)
{
- if (!(f->flags & FIO_FILE_OPEN))
+ if (!fio_file_open(f))
return 0;
- return __file_invalidate_cache(td, f, -1, -1);
+ return __file_invalidate_cache(td, f, -1ULL, -1ULL);
}
int generic_close_file(struct thread_data fio_unused *td, struct fio_file *f)
char buf[FIO_VERROR_SIZE];
int __e = errno;
- if (errno == EPERM && (flags & FIO_O_NOATIME)) {
+ if (__e == EPERM && (flags & FIO_O_NOATIME)) {
flags &= ~FIO_O_NOATIME;
goto open_again;
}
extend_size += (f->io_size + f->file_offset);
} else
f->real_file_size = f->io_size + f->file_offset;
- f->flags |= FIO_FILE_EXTEND;
+ fio_file_set_extend(f);
}
}
temp_stall_ts = 1;
if (!terse_output)
log_info("%s: Laying out IO file(s) (%u file(s) /"
- " %LuMiB)\n", td->o.name, need_extend,
+ " %LuMB)\n", td->o.name, need_extend,
extend_size >> 20);
for_each_file(td, f, i) {
- unsigned long long old_len, extend_len;
+ unsigned long long old_len = -1ULL, extend_len = -1ULL;
- if (!(f->flags & FIO_FILE_EXTEND))
+ if (!fio_file_extend(f))
continue;
assert(f->filetype == FIO_TYPE_FILE);
- f->flags &= ~FIO_FILE_EXTEND;
- old_len = f->real_file_size;
- extend_len = f->io_size + f->file_offset - old_len;
+ fio_file_clear_extend(f);
+ if (!td->o.fill_device) {
+ old_len = f->real_file_size;
+ extend_len = f->io_size + f->file_offset - old_len;
+ }
f->real_file_size = (f->io_size + f->file_offset);
err = extend_file(td, f);
if (err)
break;
-
+
err = __file_invalidate_cache(td, f, old_len,
extend_len);
close(f->fd);
struct fio_file *f;
unsigned int i;
- for_each_file(td, f, i)
- td_io_close_file(td, f);
+ for_each_file(td, f, i) {
+ if (fio_file_open(f))
+ td_io_close_file(td, f);
+ }
}
void close_and_free_files(struct thread_data *td)
unlink(f->file_name);
}
- td_io_close_file(td, f);
+ if (fio_file_open(f))
+ td_io_close_file(td, f);
+
remove_file_hash(f);
sfree(f->file_name);
void get_file(struct fio_file *f)
{
dprint(FD_FILE, "get file %s, ref=%d\n", f->file_name, f->references);
- assert(f->flags & FIO_FILE_OPEN);
+ assert(fio_file_open(f));
f->references++;
}
dprint(FD_FILE, "put file %s, ref=%d\n", f->file_name, f->references);
- if (!(f->flags & FIO_FILE_OPEN))
+ if (!fio_file_open(f)) {
+ assert(f->fd == -1);
return 0;
+ }
assert(f->references);
if (--f->references)
ret = f_ret;
td->nr_open_files--;
- f->flags &= ~FIO_FILE_OPEN;
+ fio_file_clear_open(f);
+ assert(f->fd == -1);
return ret;
}
log_err("fio: smalloc OOM\n");
assert(0);
}
+ __f->fd = -1;
if (f->file_name) {
__f->file_name = smalloc_strdup(f->file_name);
projects / fio.git / blobdiff