X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=filesetup.c;h=c407d0ef1d28cb182f9c09869cd55d5ba6410d7a;hb=587af925762ff4bdf6a54965a35b2da2637f2f6e;hp=8630abdee40f7293f1c33894ab88f3569d2f1f20;hpb=f627d8ae4dca9de8a72928a7928cf2903e81ad41;p=fio.git diff --git a/filesetup.c b/filesetup.c index 8630abde..c407d0ef 100644 --- a/filesetup.c +++ b/filesetup.c @@ -18,6 +18,11 @@ static int extend_file(struct thread_data *td, struct fio_file *f) unsigned int bs; char *b; + if (read_only) { + log_err("fio: refusing extend of file due to read-only\n"); + return 0; + } + /* * check if we need to lay the file out complete again. fio * does that for operations involving reads, or for writes @@ -45,14 +50,14 @@ static int extend_file(struct thread_data *td, struct fio_file *f) return 1; } + if (!new_layout) + goto done; + if (ftruncate(f->fd, f->real_file_size) == -1) { td_verror(td, errno, "ftruncate"); 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; @@ -226,8 +231,13 @@ int generic_open_file(struct thread_data *td, struct fio_file *f) flags |= OS_O_DIRECT; if (td->o.sync_io) flags |= O_SYNC; + if (f->filetype != FIO_TYPE_FILE) + flags |= O_NOATIME; +open_again: if (td_write(td)) { + assert(!read_only); + flags |= O_RDWR; if (f->filetype == FIO_TYPE_FILE) @@ -238,7 +248,7 @@ int generic_open_file(struct thread_data *td, struct fio_file *f) else f->fd = open(f->file_name, flags, 0600); } else { - if (f->filetype == FIO_TYPE_CHAR) + if (f->filetype == FIO_TYPE_CHAR && !read_only) flags |= O_RDWR; else flags |= O_RDONLY; @@ -253,6 +263,11 @@ int generic_open_file(struct thread_data *td, struct fio_file *f) char buf[FIO_VERROR_SIZE]; int __e = errno; + if (errno == EPERM && (flags & O_NOATIME)) { + flags &= ~O_NOATIME; + goto open_again; + } + snprintf(buf, sizeof(buf) - 1, "open(%s)", f->file_name); td_verror(td, __e, buf); @@ -364,7 +379,8 @@ int setup_files(struct thread_data *td) /* * device/file sizes are zero and no size given, punt */ - if ((!total_size || total_size == -1ULL) && !td->o.size) { + if ((!total_size || total_size == -1ULL) && !td->o.size && + !(td->io_ops->flags & FIO_NOIO) && !td->o.fill_device) { log_err("%s: you need to specify size=\n", td->o.name); td_verror(td, EINVAL, "total_file_size"); return 1; @@ -387,10 +403,12 @@ int setup_files(struct thread_data *td) * zero, set it to the real file size. */ f->io_size = td->o.size / td->o.nr_files; - if (!f->io_size) { + if ((!f->io_size || f->io_size > f->real_file_size) && + f->real_file_size) { if (f->file_offset > f->real_file_size) goto err_offset; - f->io_size = f->real_file_size - f->file_offset; + if (f->file_offset) + f->io_size = f->real_file_size - f->file_offset; } } else if (f->real_file_size < td->o.file_size_low || f->real_file_size > td->o.file_size_high) { @@ -454,7 +472,12 @@ int setup_files(struct thread_data *td) if (!td->o.zone_size) td->o.zone_size = td->o.size; - td->total_io_size = td->o.size * td->o.loops; + /* + * iolog already set the total io size, if we read back + * stored entries. + */ + if (!td->o.read_iolog_file) + td->total_io_size = td->o.size * td->o.loops; return 0; err_offset: log_err("%s: you need to specify valid offset=\n", td->o.name); @@ -463,7 +486,7 @@ err_offset: int init_random_map(struct thread_data *td) { - int num_maps, blocks; + unsigned long long blocks, num_maps; struct fio_file *f; unsigned int i; @@ -471,8 +494,8 @@ int init_random_map(struct thread_data *td) return 0; for_each_file(td, f, i) { - blocks = (f->real_file_size + td->o.rw_min_bs - 1) / td->o.rw_min_bs; - num_maps = (blocks + BLOCKS_PER_MAP-1)/ BLOCKS_PER_MAP; + blocks = (f->real_file_size + td->o.rw_min_bs - 1) / (unsigned long long) td->o.rw_min_bs; + num_maps = (blocks + BLOCKS_PER_MAP-1)/ (unsigned long long) BLOCKS_PER_MAP; f->file_map = malloc(num_maps * sizeof(long)); if (!f->file_map) { log_err("fio: failed allocating random map. If running a large number of jobs, try the 'norandommap' option\n");