projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Bad header rand_seed with time_based or loops with randrepeat=0 verify
[fio.git]
/
flow.c
diff --git
a/flow.c
b/flow.c
index aca051e6de40bd8b38516c53b6bdeb56eaa16a58..c64bb3b27559053d27a79fa2c9a45f68de6e71c2 100644
(file)
--- a/
flow.c
+++ b/
flow.c
@@
-7,7
+7,7
@@
struct fio_flow {
unsigned int refs;
unsigned int id;
struct flist_head list;
unsigned int refs;
unsigned int id;
struct flist_head list;
- unsigned long
long
flow_counter;
+ unsigned long flow_counter;
unsigned int total_weight;
};
unsigned int total_weight;
};
@@
-37,6
+37,8
@@
int flow_threshold_exceeded(struct thread_data *td)
if (td->o.flow_sleep) {
io_u_quiesce(td);
usleep(td->o.flow_sleep);
if (td->o.flow_sleep) {
io_u_quiesce(td);
usleep(td->o.flow_sleep);
+ } else if (td->o.zone_mode == ZONE_MODE_ZBD) {
+ io_u_quiesce(td);
}
return 1;
}
return 1;
@@
-90,7
+92,7
@@
static struct fio_flow *flow_get(unsigned int id)
return flow;
}
return flow;
}
-static void flow_put(struct fio_flow *flow, unsigned long
long
flow_counter,
+static void flow_put(struct fio_flow *flow, unsigned long flow_counter,
unsigned int weight)
{
if (!flow_lock)
unsigned int weight)
{
if (!flow_lock)