projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
engines/io_uring: add new I/O engine for uring passthrough support
[fio.git]
/
stat.c
diff --git
a/stat.c
b/stat.c
index 7947edb42fd898b56e21be711c4db30ea25ebdea..949af5edd49ffa05dfa16bbef70c7d1037de8261 100644
(file)
--- a/
stat.c
+++ b/
stat.c
@@
-1,5
+1,6
@@
#include <stdio.h>
#include <string.h>
#include <stdio.h>
#include <string.h>
+#include <stdlib.h>
#include <sys/time.h>
#include <sys/stat.h>
#include <math.h>
#include <sys/time.h>
#include <sys/stat.h>
#include <math.h>
@@
-1698,6
+1699,7
@@
static struct json_object *show_thread_status_json(struct thread_stat *ts,
if (je) {
json_object_add_value_int(root, "eta", je->eta_sec);
json_object_add_value_int(root, "elapsed", je->elapsed_sec);
if (je) {
json_object_add_value_int(root, "eta", je->eta_sec);
json_object_add_value_int(root, "elapsed", je->elapsed_sec);
+ free(je);
}
if (opt_list)
}
if (opt_list)
@@
-2731,6
+2733,9
@@
int __show_running_run_stats(void)
fio_gettime(&ts, NULL);
for_each_td(td, i) {
fio_gettime(&ts, NULL);
for_each_td(td, i) {
+ if (td->runstate >= TD_EXITED)
+ continue;
+
td->update_rusage = 1;
for_each_rw_ddir(ddir) {
td->ts.io_bytes[ddir] = td->io_bytes[ddir];
td->update_rusage = 1;
for_each_rw_ddir(ddir) {
td->ts.io_bytes[ddir] = td->io_bytes[ddir];
@@
-2759,6
+2764,9
@@
int __show_running_run_stats(void)
__show_run_stats();
for_each_td(td, i) {
__show_run_stats();
for_each_td(td, i) {
+ if (td->runstate >= TD_EXITED)
+ continue;
+
if (td_read(td) && td->ts.io_bytes[DDIR_READ])
td->ts.runtime[DDIR_READ] -= rt[i];
if (td_write(td) && td->ts.io_bytes[DDIR_WRITE])
if (td_read(td) && td->ts.io_bytes[DDIR_READ])
td->ts.runtime[DDIR_READ] -= rt[i];
if (td_write(td) && td->ts.io_bytes[DDIR_WRITE])