projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
t/io_uring: clean up aio wait loop
[fio.git]
/
flow.c
diff --git
a/flow.c
b/flow.c
index ee4d761db42bf30bb1f7b9667dda11f0b5d80d0c..c64bb3b27559053d27a79fa2c9a45f68de6e71c2 100644
(file)
--- a/
flow.c
+++ b/
flow.c
@@
-5,9
+5,9
@@
struct fio_flow {
unsigned int refs;
struct fio_flow {
unsigned int refs;
- struct flist_head list;
unsigned int id;
unsigned int id;
- unsigned long long flow_counter;
+ struct flist_head list;
+ 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)