projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
t/run-fio-tests: rename FioJobTest to FioJobFileTest
[fio.git]
/
rate-submit.c
diff --git
a/rate-submit.c
b/rate-submit.c
index 2fe768c0bea84e785000c782df1b586db57cf42a..103a80aa13f8e671f06d2b568f7fa8bc1cc342df 100644
(file)
--- a/
rate-submit.c
+++ b/
rate-submit.c
@@
-12,8
+12,7
@@
static void check_overlap(struct io_u *io_u)
{
static void check_overlap(struct io_u *io_u)
{
- int i, res;
- struct thread_data *td;
+ int res;
/*
* Allow only one thread to check for overlap at a time to prevent two
/*
* Allow only one thread to check for overlap at a time to prevent two
@@
-31,7
+30,7
@@
static void check_overlap(struct io_u *io_u)
assert(res == 0);
retry:
assert(res == 0);
retry:
- for_each_td(td
, i
) {
+ for_each_td(td) {
if (td->runstate <= TD_SETTING_UP ||
td->runstate >= TD_FINISHING ||
!td->o.serialize_overlap ||
if (td->runstate <= TD_SETTING_UP ||
td->runstate >= TD_FINISHING ||
!td->o.serialize_overlap ||
@@
-46,7
+45,7
@@
retry:
res = pthread_mutex_lock(&overlap_check);
assert(res == 0);
goto retry;
res = pthread_mutex_lock(&overlap_check);
assert(res == 0);
goto retry;
- }
+ }
end_for_each();
}
static int io_workqueue_fn(struct submit_worker *sw,
}
static int io_workqueue_fn(struct submit_worker *sw,
@@
-154,6
+153,7
@@
static int io_workqueue_init_worker_fn(struct submit_worker *sw)
dup_files(td, parent);
td->eo = parent->eo;
fio_options_mem_dupe(td);
dup_files(td, parent);
td->eo = parent->eo;
fio_options_mem_dupe(td);
+ td->iolog_f = parent->iolog_f;
if (ioengine_load(td))
goto err;
if (ioengine_load(td))
goto err;