projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
steadystate: instead of including ss_sum_y in thread_stat record whether ss_sum_y...
[fio.git]
/
stat.h
diff --git
a/stat.h
b/stat.h
index 0fc5533fd20529efbd65b3cc47e1bf5b8e84c094..8a9547917cb96d652f9c527d71becea47a67e853 100644
(file)
--- a/
stat.h
+++ b/
stat.h
@@
-213,6
+213,18
@@
struct thread_stat {
uint64_t latency_target;
fio_fp64_t latency_percentile;
uint64_t latency_window;
uint64_t latency_target;
fio_fp64_t latency_percentile;
uint64_t latency_window;
+
+ uint64_t ss_dur;
+ uint32_t ss_state;
+ uint32_t ss_head;
+
+ uint64_t *ss_iops_data;
+ uint64_t *ss_bw_data;
+
+ fio_fp64_t ss_limit;
+ fio_fp64_t ss_slope;
+ fio_fp64_t ss_deviation;
+ fio_fp64_t ss_criterion;
} __attribute__((packed));
struct jobs_eta {
} __attribute__((packed));
struct jobs_eta {
@@
-242,12
+254,12
@@
struct jobs_eta {
extern struct fio_mutex *stat_mutex;
extern struct fio_mutex *stat_mutex;
-extern struct jobs_eta *get_jobs_eta(
int
force, size_t *size);
+extern struct jobs_eta *get_jobs_eta(
bool
force, size_t *size);
extern void stat_init(void);
extern void stat_exit(void);
extern void stat_init(void);
extern void stat_exit(void);
-extern struct json_object * show_thread_status(struct thread_stat *ts, struct group_run_stats *rs, struct buf_output *);
+extern struct json_object * show_thread_status(struct thread_stat *ts, struct group_run_stats *rs, struct
flist_head *, struct
buf_output *);
extern void show_group_stats(struct group_run_stats *rs, struct buf_output *);
extern int calc_thread_status(struct jobs_eta *je, int force);
extern void display_thread_status(struct jobs_eta *je);
extern void show_group_stats(struct group_run_stats *rs, struct buf_output *);
extern int calc_thread_status(struct jobs_eta *je, int force);
extern void display_thread_status(struct jobs_eta *je);
@@
-256,7
+268,7
@@
extern void __show_run_stats(void);
extern void __show_running_run_stats(void);
extern void show_running_run_stats(void);
extern void check_for_running_stats(void);
extern void __show_running_run_stats(void);
extern void show_running_run_stats(void);
extern void check_for_running_stats(void);
-extern void sum_thread_stats(struct thread_stat *dst, struct thread_stat *src,
int nr
);
+extern void sum_thread_stats(struct thread_stat *dst, struct thread_stat *src,
bool first
);
extern void sum_group_stats(struct group_run_stats *dst, struct group_run_stats *src);
extern void init_thread_stat(struct thread_stat *ts);
extern void init_group_run_stat(struct group_run_stats *gs);
extern void sum_group_stats(struct group_run_stats *dst, struct group_run_stats *src);
extern void init_thread_stat(struct thread_stat *ts);
extern void init_group_run_stat(struct group_run_stats *gs);
@@
-276,11
+288,12
@@
extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long,
unsigned int, uint64_t);
extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long,
unsigned int, uint64_t);
unsigned int, uint64_t);
extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long,
unsigned int, uint64_t);
-extern void add_bw_sample(struct thread_data *, enum fio_ddir, unsigned int,
- struct timeval *);
-extern void add_iops_sample(struct thread_data *, enum fio_ddir, unsigned int,
- struct timeval *);
extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int);
extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int);
+extern void add_iops_sample(struct thread_data *, struct io_u *,
+ unsigned int);
+extern void add_bw_sample(struct thread_data *, struct io_u *,
+ unsigned int, unsigned long);
+extern int calc_log_samples(void);
extern struct io_log *agg_io_log[DDIR_RWDIR_CNT];
extern int write_bw_log;
extern struct io_log *agg_io_log[DDIR_RWDIR_CNT];
extern int write_bw_log;